test(dbt): regression fixture for ingest_dbt_manifest (#576)

Signed-off-by: alexisperinger-ux <alexis.peringer@iss-stoxx.com>

Author: alexisperinger-ux

tests/test_mcp.c

@@ -2143,6 +2143,100 @@ TEST(tool_bad_project_name_no_overflow_issue235) {
 }
 #undef ISSUE235_DBNAME
 
+/* Issue #576: ingest_dbt_manifest parses a compiled dbt manifest.json and
+ * upserts model/seed/snapshot as graph nodes, source as Source nodes, and each
+ * node's depends_on.nodes as DEPENDS_ON edges, keyed by dbt unique_id. The
+ * handler opens (and creates) the project's on-disk store at
+ * <CBM_CACHE_DIR>/<project>.db, so an isolated cache dir plus a small fixture
+ * manifest exercises the whole path. The fixture carries 3 models + 1 seed +
+ * 1 snapshot + 2 sources and one `test` node that must be skipped, so the
+ * reported counts pin both the resource-type filter and the lineage edges. */
+static const char *DBT_MANIFEST_FIXTURE =
+    "{\"nodes\":{"
+    "\"model.shop.stg_orders\":{\"resource_type\":\"model\",\"name\":\"stg_orders\","
+    "\"depends_on\":{\"nodes\":[\"source.shop.raw.orders\"]}},"
+    "\"model.shop.stg_customers\":{\"resource_type\":\"model\",\"name\":\"stg_customers\","
+    "\"depends_on\":{\"nodes\":[\"source.shop.raw.customers\"]}},"
+    "\"model.shop.fct_orders\":{\"resource_type\":\"model\",\"name\":\"fct_orders\","
+    "\"depends_on\":{\"nodes\":[\"model.shop.stg_orders\",\"model.shop.stg_customers\"]}},"
+    "\"seed.shop.country_codes\":{\"resource_type\":\"seed\",\"name\":\"country_codes\","
+    "\"depends_on\":{\"nodes\":[]}},"
+    "\"snapshot.shop.orders_snap\":{\"resource_type\":\"snapshot\",\"name\":\"orders_snap\","
+    "\"depends_on\":{\"nodes\":[\"model.shop.fct_orders\"]}},"
+    "\"test.shop.not_null_fct_orders\":{\"resource_type\":\"test\",\"name\":\"not_null\","
+    "\"depends_on\":{\"nodes\":[\"model.shop.fct_orders\"]}}"
+    "},\"sources\":{"
+    "\"source.shop.raw.orders\":{\"resource_type\":\"source\",\"name\":\"orders\"},"
+    "\"source.shop.raw.customers\":{\"resource_type\":\"source\",\"name\":\"customers\"}"
+    "}}";
+
+TEST(tool_ingest_dbt_manifest_issue576) {
+    char cache[256];
+    snprintf(cache, sizeof(cache), "/tmp/cbm-dbt-manifest-XXXXXX");
+    if (!cbm_mkdtemp(cache)) {
+        PASS(); /* skip if mkdtemp fails */
+    }
+
+    const char *saved = getenv("CBM_CACHE_DIR");
+    char *saved_copy = saved ? strdup(saved) : NULL;
+    cbm_setenv("CBM_CACHE_DIR", cache, 1);
+
+    /* Write the fixture manifest into the isolated cache dir. */
+    char manifest_path[512];
+    snprintf(manifest_path, sizeof(manifest_path), "%s/manifest.json", cache);
+    FILE *fp = fopen(manifest_path, "w");
+    ASSERT_NOT_NULL(fp);
+    fputs(DBT_MANIFEST_FIXTURE, fp);
+    fclose(fp);
+
+    /* The handler opens (and creates) <CBM_CACHE_DIR>/<project>.db itself. */
+    const char *project = "test-dbt-manifest";
+    char req[2048];
+    snprintf(req, sizeof(req),
+             "{\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"tools/call\",\"params\":{\"name\":"
+             "\"ingest_dbt_manifest\",\"arguments\":{\"project\":\"%s\",\"manifest_path\":\"%s\"}}}",
+             project, manifest_path);
+
+    cbm_mcp_server_t *srv = cbm_mcp_server_new(NULL);
+    ASSERT_NOT_NULL(srv);
+    char *resp = cbm_mcp_server_handle(srv, req);
+    ASSERT_NOT_NULL(resp);
+
+    char *inner = extract_text_content(resp);
+    ASSERT_NOT_NULL(inner);
+    /* 3 models + 1 seed + 1 snapshot = 5 lineage-bearing nodes; the `test`
+     * node is skipped (so models is 5, not 6). */
+    ASSERT_NOT_NULL(strstr(inner, "\"status\":\"ingested\""));
+    ASSERT_NOT_NULL(strstr(inner, "\"models\":5"));
+    ASSERT_NOT_NULL(strstr(inner, "\"sources\":2"));
+    /* stg_orders/stg_customers -> source, fct_orders -> 2 stg, snap -> fct = 5
+     * DEPENDS_ON edges; the skipped test node contributes none. */
+    ASSERT_NOT_NULL(strstr(inner, "\"edges\":5"));
+
+    free(inner);
+    free(resp);
+    cbm_mcp_server_free(srv);
+
+    if (saved_copy) {
+        cbm_setenv("CBM_CACHE_DIR", saved_copy, 1);
+        free(saved_copy);
+    } else {
+        cbm_unsetenv("CBM_CACHE_DIR");
+    }
+    char dbpath[512];
+    snprintf(dbpath, sizeof(dbpath), "%s/%s.db", cache, project);
+    char dbwal[576];
+    char dbshm[576];
+    snprintf(dbwal, sizeof(dbwal), "%s-wal", dbpath);
+    snprintf(dbshm, sizeof(dbshm), "%s-shm", dbpath);
+    cbm_unlink(dbwal);
+    cbm_unlink(dbshm);
+    cbm_unlink(dbpath);
+    cbm_unlink(manifest_path);
+    cbm_rmdir(cache);
+    PASS();
+}
+
 /* ══════════════════════════════════════════════════════════════════
  *  SUITE
  * ══════════════════════════════════════════════════════════════════ */
@@ -2217,6 +2311,7 @@ SUITE(mcp) {
     RUN_TEST(tool_search_graph_includes_node_properties);
     RUN_TEST(tool_search_graph_query_honors_file_pattern_issue552);
     RUN_TEST(tool_query_graph_basic);
+    RUN_TEST(tool_ingest_dbt_manifest_issue576);
     RUN_TEST(tool_index_status_no_project);
     RUN_TEST(tool_index_status_includes_git_metadata);