Function insertMemoryEventDB

internal/memory/catalog.go:1553–1577

(ctx context.Context, db *sql.DB, record memcontract.OperationRecord)

}

func insertMemoryEventDB(ctx context.Context, db *sql.DB, record memcontract.OperationRecord) error {
	return storepkg.ExecuteWrite(ctx, db, func(ctx context.Context, 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 (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
			canonicalEventOp(record),
			nullStringForEmpty(record.Scope.Normalize()),
			nullStringForEmpty(record.AgentName),
			nil,
			nullStringForEmpty(record.Workspace),
			nil,
			"system",
			nil,
			nullStringForEmpty(record.Filename),
			mustEventMetadata(record),
			timeToUnixMillis(record.Timestamp),
		); err != nil {
			return fmt.Errorf("memory: write memory event: %w", err)
		}
		return nil
	})
}

func insertMemoryEventTx(ctx context.Context, tx *sql.Tx, record memcontract.OperationRecord, legacy bool) error {
	metadata := eventMetadata(record)