trending/codebase-memory-mcp
1
0
Fork 0
mirror of https://github.com/DeusData/codebase-memory-mcp.git synced 2026-11-05 08:23:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(pipeline): preserve ADR across full re-index (#516)

Browse Source 
manage_adr stores ADRs in project_summaries, but a full re-index
(triggered by file changes or new files) deletes the DB in
try_incremental_or_delete_db and rebuilds it from the graph buffer,
which writes an empty project_summaries table. file_hashes were
re-persisted after the rebuild but project_summaries were not, so the
ADR was silently lost.

Fix: capture the ADR before the DB is unlinked, stash it on the
pipeline struct, and restore it after the rebuilt DB is reopened in
dump_and_persist_hashes. The incremental path is unaffected (it never
rewrites the DB). Verified: ADR now survives a full re-index.

Signed-off-by: RithvikReddy0-0 <rithvikreddymukkara@gmail.com>
This commit is contained in:
RithvikReddy0-0
2026-06-24 01:24:06 +00:00
parent 170d5a82ab
commit 7f622b1cde
1 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/pipeline/pipeline.c
+27
View File
@@ -97,6 +97,10 @@ struct cbm_pipeline {
/* Committed graph size at dump time (-1 = dump did not run). #334 gate axis. */
int committed_nodes;
int committed_edges;
/* ADR (project_summaries) captured before a full-reindex DB delete, so it
* can be restored after the rebuild. NULL when no ADR existed. Issue #516. */
char *saved_adr;
};
/* ── Global pkgmap (one active pipeline at a time) ─────────────── */
@@ -810,6 +814,22 @@ static int try_incremental_or_delete_db(cbm_pipeline_t *p, cbm_file_info_t *file
cbm_store_close(check_store);
}
cbm_log_info("pipeline.route", "path", "reindex", "action", "deleting old db");
/* Capture any ADR before deleting the DB so the full-reindex rebuild can
* restore it (project_summaries is otherwise lost). Issue #516. */
{
cbm_store_t *adr_store = cbm_store_open_path(db_path);
if (adr_store) {
cbm_adr_t existing;
if (cbm_store_adr_get(adr_store, p->project_name, &existing) == CBM_STORE_OK) {
if (existing.content) {
free(p->saved_adr);
p->saved_adr = strdup(existing.content);
}
cbm_store_adr_free(&existing);
}
cbm_store_close(adr_store);
}
}
cbm_unlink(db_path);
char wal[PL_WAL_BUF];
char shm[PL_WAL_BUF];
@@ -869,6 +889,11 @@ static int dump_and_persist_hashes(cbm_pipeline_t *p, const cbm_file_info_t *fil
cbm_store_t *hash_store = cbm_store_open_path(db_path);
if (hash_store) {
cbm_store_delete_file_hashes(hash_store, p->project_name);
/* Restore the ADR captured before the dump. Issue #516. */
if (p->saved_adr) {
cbm_store_adr_store(hash_store, p->project_name, p->saved_adr);
}
for (int i = 0; i < file_count; i++) {
struct stat fst;
if (stat(files[i].path, &fst) == 0) {
@@ -895,6 +920,8 @@ static int dump_and_persist_hashes(cbm_pipeline_t *p, const cbm_file_info_t *fil
cbm_store_close(hash_store);
cbm_log_info("pass.timing", "pass", "persist_hashes", "files", itoa_buf(file_count));
}
free(p->saved_adr);
p->saved_adr = NULL;
/* Export persistent artifact if enabled */
if (p->persistence) {