Method ConsumeResult

agent/memory_extraction.go:121–130

()

func (c *ExtractionController) incrementalFabricMessages(state *AgentState) ([]map[string]any, []string, int, int, string, string) {
	sessionID := firstNonEmptyString(c.SourceSessionID, state.MemorySessionID)
	if sessionID == "" {
		sessionID = "runtime-" + stableFabricTextID(c.Config.ProjectRoot()) + "-" +
			firstNonEmptyString(c.SourceAgentID, "main")
	}
	consumerID := "memory-fabric-ingest:" + firstNonEmptyString(c.SourceAgentID, "main")
	start := state.MemoryExtractionCursor
	if start < 0 {
		start = 0
	}
	if start >= len(state.Messages) {
		return nil, nil, start, start - 1, sessionID, consumerID
	}