Method insertRecallEvent

internal/memory/recall_source.go:465–511

(
	ctx context.Context,
	op string,
	query memcontract.Query,
	targetID string,
	metadata map[string]string,
)

}

func (s *Store) insertRecallEvent(
	ctx context.Context,
	op string,
	query memcontract.Query,
	targetID string,
	metadata map[string]string,
) error {
	if s.catalog == nil {
		return nil
	}
	payload, err := json.Marshal(metadata)
	if err != nil {
		return fmt.Errorf("memory: encode recall event metadata: %w", err)
	}
	workspaceID := strings.TrimSpace(query.WorkspaceID)
	scope := memcontract.ScopeGlobal
	if workspaceID != "" {
		scope = memcontract.ScopeWorkspace
	}
	agentName := strings.TrimSpace(query.AgentName)
	if agentName == "" {
		agentName = catalogEventAgentName
	}
	return s.catalog.withCatalogWriteTx(ctx, "recall event insert", func(tx *storepkg.WriteTx) error {
		if _, err := tx.ExecContext(
			ctx,
			`INSERT INTO memory_events (
				op, scope, agent_name, agent_tier, workspace_id, session_id, actor_kind,
				decision_id, target_id, metadata, ts_ms
			) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
			strings.TrimSpace(op),
			string(scope),
			agentName,
			nil,
			nullStringForEmpty(workspaceID),
			nil,
			"system",
			nil,
			nullStringForEmpty(targetID),
			string(payload),
			timeToUnixMillis(time.Now().UTC()),
		); err != nil {
			return fmt.Errorf("memory: write recall event %q: %w", op, err)
		}
		return nil
	})
}