Function insertMemoryEventTx

internal/memory/catalog.go:1579–1609

(ctx context.Context, tx *sql.Tx, record memcontract.OperationRecord, legacy bool)

}

func insertMemoryEventTx(ctx context.Context, tx *sql.Tx, record memcontract.OperationRecord, legacy bool) error {
	metadata := eventMetadata(record)
	if legacy {
		metadata[memoryEventMetadataLegacyIDKey] = strings.TrimSpace(record.ID)
	}
	payload, err := json.Marshal(metadata)
	if err != nil {
		return fmt.Errorf("memory: encode memory event metadata: %w", err)
	}
	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 (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
		canonicalEventOp(record),
		nullStringForEmpty(record.Scope.Normalize()),
		nullStringForEmpty(record.AgentName),
		nil,
		nullStringForEmpty(record.Workspace),
		nil,
		"system",
		nil,
		nullStringForEmpty(record.Filename),
		string(payload),
		timeToUnixMillis(record.Timestamp),
	); err != nil {
		return fmt.Errorf("memory: migrate memory event: %w", err)
	}
	return nil
}

func (c *catalog) listOperations(
	ctx context.Context,