Method SearchMemories

pkg/memory/database/sqlite/sqlite.go:182–253

(ctx context.Context, query, category string)

}

func (m *MemoryDatabase) SearchMemories(ctx context.Context, query, category string) (results []database.UserMemory, err error) {
	// SearchMemories is the retrieval shape per the OTel GenAI semconv:
	// the agent is recalling stored memories filtered by query/category.
	// Use the spec'd `retrieval {data_source.id}` span so this lands on
	// the same dashboard row as RAG retrievals.
	ctx, retSpan := genai.StartRetrieval(ctx, "sqlite", memoryDataSourceID, false, "")
	defer func() {
		if err != nil {
			retSpan.RecordError(err, "")
		}
		retSpan.SetResultCount(len(results))
		retSpan.End()
	}()
	if category != "" {
		retSpan.SetAttributes(attribute.String("cagent.memory.category", category))
	}

	// Assign to the named returns (not local shadows) so the deferred
	// span closure observes the live error and result count regardless
	// of which return path fires.
	var conditions []string
	var args []any

	if query != "" {
		words := strings.FieldsSeq(query)
		for word := range words {
			conditions = append(conditions, "LOWER(memory) LIKE LOWER(?) ESCAPE '\\'")
			escaped := strings.ReplaceAll(word, `\`, `\\`)
			escaped = strings.ReplaceAll(escaped, `%`, `\%`)
			escaped = strings.ReplaceAll(escaped, `_`, `\_`)
			args = append(args, "%"+escaped+"%")
		}
	}

	if category != "" {
		conditions = append(conditions, "LOWER(category) = LOWER(?)")
		args = append(args, category)
	}

	stmt := "SELECT id, created_at, memory, COALESCE(category, '') FROM memories"
	if len(conditions) > 0 {
		stmt += " WHERE " + strings.Join(conditions, " AND ") //nolint:gosec // conditions are internal SQL fragments; values are bound parameters
	}

	var rows *sql.Rows
	db, err := m.ensureDB(ctx)
	if err != nil {
		return nil, err
	}
	rows, err = db.QueryContext(ctx, stmt, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	for rows.Next() {
		var memory database.UserMemory
		// gocritic suggests `:=` here, but we want to assign to the