Function recentMessages

agent/memory_extraction.go:275–280

(messages []map[string]any, limit int)

	mode, sourceIDs := fabricSynchronousMemoryRequest(events)
	policy := memory.SemanticDeferred
	if len(sourceIDs) > 0 {
		policy = memory.SemanticDurableOnly
	}
	ingested, ingestErr := c.Engine.AppendEvents(ctx, events, memory.IngestOptions{SemanticPolicy: policy})
	if !ingested.Durable {
		if ingestErr != nil {
			return "", ingestErr
		}