Function cbm_delta_patch

src/pipeline/pipeline_delta.c:451–563

}

int cbm_delta_patch(cbm_store_t *store, const char *project, cbm_gbuf_t *gbuf, int64_t max_db_id,
                    const cbm_delta_saved_edge_t *snapshot, int snapshot_count) {
    sqlite3 *db = cbm_store_get_db(store);
    if (!db) {
        return CBM_NOT_FOUND;
    }
    if (cbm_store_begin(store) != CBM_STORE_OK) {
        return CBM_NOT_FOUND;
    }
    delta_patch_ctx_t ctx = {.db = db, .project = project, .max_db_id = max_db_id};
    if (sqlite3_prepare_v2(db,
                           "SELECT id FROM nodes WHERE project = ?1"
                           " AND qualified_name = ?2",
                           CBM_NOT_FOUND, &ctx.qn_lookup, NULL) != SQLITE_OK) {
        cbm_store_rollback(store);
        return CBM_NOT_FOUND;
    }
    if (sqlite3_prepare_v2(db,
                           "INSERT INTO nodes (id, project, label, name, qualified_name,"
                           " file_path, start_line, end_line, properties)"
                           " VALUES (?1,?2,?3,?4,?5,?6,?7,?8,?9)",
                           CBM_NOT_FOUND, &ctx.node_stmt, NULL) != SQLITE_OK ||
        sqlite3_prepare_v2(db,
                           "INSERT OR IGNORE INTO edges (project, source_id, target_id, type,"
                           " properties) VALUES (?1,?2,?3,?4,?5)",
                           CBM_NOT_FOUND, &ctx.edge_stmt, NULL) != SQLITE_OK) {
        sqlite3_finalize(ctx.node_stmt);
        sqlite3_finalize(ctx.edge_stmt);
        sqlite3_finalize(ctx.qn_lookup);
        free(ctx.remap);
        cbm_store_rollback(store);
        return CBM_NOT_FOUND;
    }
    cbm_gbuf_foreach_node(gbuf, delta_patch_node, &ctx);
    if (!ctx.failed) {
        cbm_gbuf_foreach_edge(gbuf, delta_patch_edge, &ctx);
    }
    sqlite3_finalize(ctx.node_stmt);
    sqlite3_finalize(ctx.edge_stmt);
    sqlite3_finalize(ctx.qn_lookup);

    /* Re-link the snapshotted inbound edges by qualified name. A target
     * whose QN no longer exists simply matches no row — full-reindex
     * semantics for deleted symbols, dedup by the UNIQUE edge constraint. */
    if (!ctx.failed && snapshot_count > 0) {
        sqlite3_stmt *relink = NULL;
        if (sqlite3_prepare_v2(db,
                               "INSERT OR IGNORE INTO edges (project, source_id, target_id,"
                               " type, properties)"
                               " SELECT ?1, s.id, t.id, ?2, ?3 FROM nodes s, nodes t"
                               " WHERE s.project = ?1 AND s.qualified_name = ?4"
                               " AND t.project = ?1 AND t.qualified_name = ?5",
                               CBM_NOT_FOUND, &relink, NULL) != SQLITE_OK) {
            ctx.failed = true;
        } else {
            for (int i = 0; i < snapshot_count && !ctx.failed; i++) {
                sqlite3_reset(relink);
                sqlite3_bind_text(relink, 1, project, CBM_NOT_FOUND, SQLITE_TRANSIENT);