Function create_tests_file_edges

src/pipeline/pass_tests.c:252–283

Create TESTS_FILE edges from test File nodes to production File nodes. */

/* Create TESTS_FILE edges from test File nodes to production File nodes. */
static int create_tests_file_edges(cbm_pipeline_ctx_t *ctx) {
    int count = 0;
    const cbm_gbuf_node_t **file_nodes = NULL;
    int file_node_count = 0;
    int rc = cbm_gbuf_find_by_label(ctx->gbuf, "File", &file_nodes, &file_node_count);
    if (rc != 0) {
        return 0;
    }

    for (int i = 0; i < file_node_count; i++) {
        const cbm_gbuf_node_t *fnode = file_nodes[i];
        if (!fnode->file_path || !cbm_is_test_path(fnode->file_path)) {
            continue;
        }

        char *prod_path = test_to_prod_path(fnode->file_path);
        if (!prod_path) {
            continue;
        }

        char *prod_qn = cbm_pipeline_fqn_compute(ctx->project_name, prod_path, "__file__");
        const cbm_gbuf_node_t *prod_node = cbm_gbuf_find_by_qn(ctx->gbuf, prod_qn);
        free(prod_qn);
        free(prod_path);

        if (prod_node && fnode->id != prod_node->id) {
            cbm_gbuf_insert_edge(ctx->gbuf, fnode->id, prod_node->id, "TESTS_FILE", "{}");
            count++;
        }
    }
    return count;
}

int cbm_pipeline_pass_tests(cbm_pipeline_ctx_t *ctx, const cbm_file_info_t *files, int file_count) {
    cbm_log_info("pass.start", "pass", "tests");