Function persistDiffs

internal/intent/materialize.go:367–411

(db *sql.DB, runID string, diffs []IntentRuntimeDiff)

}

func persistDiffs(db *sql.DB, runID string, diffs []IntentRuntimeDiff) error {
	tx, err := db.Begin()
	if err != nil {
		return err
	}
	defer tx.Rollback()
	if _, err := tx.Exec(`DELETE FROM intent_diffs WHERE run_id = ?`, runID); err != nil {
		return err
	}
	if _, err := tx.Exec(`DELETE FROM graph_edges WHERE run_id = ? AND edge_type IN (?, ?)`,
		runID, edgeIntentContract, edgeIntentEffect); err != nil {
		return err
	}
	now := time.Now().UTC().Format(time.RFC3339Nano)
	seq := 0
	for _, d := range diffs {
		declared, _ := json.Marshal(d.Declared)
		forbidden, _ := json.Marshal(d.Forbidden)
		observed, _ := json.Marshal(d.Observed)
		if _, err := tx.Exec(`INSERT INTO intent_diffs
			(id, run_id, agent_id, tool_call_id, contract_kind, operation, target, status, finding, confidence,
			 declared_effects, forbidden_effects, observed_effects, mismatch_reason, source, created_at)
			VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
			d.ID, runID, d.AgentID, d.ToolCallID, d.ContractKind, d.Operation, d.Target, d.Status, d.Finding, d.Confidence,
			string(declared), string(forbidden), string(observed), d.MismatchReason, d.Source, now); err != nil {
			return err
		}
		// Wire the diff into the graph: scope -> diff node, and diff node -> each
		// observed runtime event. Endpoints are not checked by graph verify, so
		// these new edge types are safe to add.
		scope := "agent/" + d.AgentID
		if d.ToolCallID != "" {
			scope = d.ToolCallID
		}
		if err := insertEdge(tx, runID, scope, d.ID, edgeIntentContract, now, &seq); err != nil {
			return err
		}
		for _, eid := range d.EventIDs {
			if err := insertEdge(tx, runID, d.ID, "runtime_event/"+eid, edgeIntentEffect, now, &seq); err != nil {
				return err
			}
		}
	}
	return tx.Commit()
}

// insertEdge writes a graph edge with a per-persist monotonic id, so the primary
// key can never collide within a run's diff materialization.