Function observe_objectscript_export

tests/test_pipeline.c:1182–1217

} ObjectScriptExportObservation;

static ObjectScriptExportObservation observe_objectscript_export(const char *repo_path,
                                                                 const char *db_name) {
    ObjectScriptExportObservation observation = {
        .run_rc = -1,
        .store_opened = false,
        .run_nodes = -1,
        .execute_nodes = -1,
        .run_execute_calls = -1,
        .shared_payload_nodes = -1,
        .run_shared_payload_usages = -1,
    };
    char db_path[512];
    snprintf(db_path, sizeof(db_path), "%s/%s", repo_path, db_name);
    cbm_pipeline_t *pipeline = cbm_pipeline_new(repo_path, db_path, CBM_MODE_FULL);
    if (!pipeline) {
        return observation;
    }

    observation.run_rc = cbm_pipeline_run(pipeline);
    const char *project = cbm_pipeline_project_name(pipeline);
    cbm_store_t *store = cbm_store_open_path(db_path);
    observation.store_opened = store != NULL;
    if (store && project) {
        observation.run_nodes = named_node_count(store, project, "Run");
        observation.execute_nodes = named_node_count(store, project, "Execute");
        observation.run_execute_calls = named_edge_count(store, project, "CALLS", "Run", "Execute");
        observation.shared_payload_nodes = named_node_count(store, project, "SharedPayload");
        observation.run_shared_payload_usages =
            named_edge_count(store, project, "USAGE", "Run", "SharedPayload");
    }
    if (store) {
        cbm_store_close(store);
    }
    cbm_pipeline_free(pipeline);
    return observation;
}

/* Studio Export XML is transformed into ObjectScript UDL during extraction.
 * The transformed definitions already survive, but the old sequential and