Method insert_edges

src/db/edges.rs:55–123

Inserts a batch of edges inside a single transaction. Edges whose source or target node does not yet exist are silently skipped (#58). They will be picked up on a future sync once the referenced file is indexed. `Contains` edges are denormalized into `nodes.parent_id` via UPDATE; they do not produce edge rows.

(&self, edges: &[Edge])

    /// referenced file is indexed. `Contains` edges are denormalized into
    /// `nodes.parent_id` via UPDATE; they do not produce edge rows.
    pub async fn insert_edges(&self, edges: &[Edge]) -> Result<()> {
        if edges.is_empty() {
            return Ok(());
        }

        self.with_batch_transaction("insert_edges", async {
            // Conditional INSERT: only insert when both endpoints exist in
            // `nodes`. This avoids FK violations during incremental sync
            // when an edge references a node from a not-yet-indexed file.
            let stmt = self
                .conn()
                .prepare(
                    "INSERT OR IGNORE INTO edges (source, target, kind, line) \
                     SELECT ?1, ?2, ?3, ?4 \
                     WHERE EXISTS (SELECT 1 FROM nodes WHERE id = ?1) \
                       AND EXISTS (SELECT 1 FROM nodes WHERE id = ?2)",
                )
                .await
                .map_err(|e| TraceDecayError::Database {
                    message: format!("failed to prepare: {e}"),
                    operation: "insert_edges".to_string(),
                })?;

            let parent_stmt = self
                .conn()
                .prepare("UPDATE nodes SET parent_id = ?1 WHERE id = ?2")
                .await
                .map_err(|e| TraceDecayError::Database {
                    message: format!("failed to prepare parent update: {e}"),
                    operation: "insert_edges".to_string(),
                })?;

            for edge in edges {
                if edge.kind == EdgeKind::Contains {
                    if let Err(e) = parent_stmt
                        .execute(params![edge.source.as_str(), edge.target.as_str()])
                        .await
                    {
                        parent_stmt.reset();
                        return Err(TraceDecayError::Database {
                            message: format!("failed to set parent_id: {e}"),
                            operation: "insert_edges".to_string(),
                        });
                    }
                    parent_stmt.reset();
                    continue;
                }
                if let Err(e) = stmt
                    .execute(params![
                        edge.source.as_str(),
                        edge.target.as_str(),
                        edge.kind.as_str(),
                        edge.line.map(i64::from),
                    ])
                    .await
                {
                    stmt.reset();
                    return Err(TraceDecayError::Database {