Function resolve_db_path

src/pipeline/pipeline.c:519–552

Resolve the DB path for this pipeline. Caller must free(). */

/* Resolve the DB path for this pipeline. Caller must free(). */
static char *resolve_db_path(const cbm_pipeline_t *p) {
    if (!p) {
        return NULL;
    }
    if (p->db_path) {
        return strdup(p->db_path);
    }

    const char *cache_dir = cbm_resolve_cache_dir();
    cache_dir = cache_dir ? cache_dir : cbm_tmpdir();
    if (!cache_dir || !p->project_name) {
        return NULL;
    }
    size_t cache_len = strlen(cache_dir);
    size_t project_len = strlen(p->project_name);
    if (project_len > SIZE_MAX - cache_len) {
        return NULL;
    }
    size_t stem_len = cache_len + project_len;
    if (stem_len > SIZE_MAX - sizeof("/.db")) {
        return NULL;
    }
    size_t path_size = stem_len + sizeof("/.db");
    char *path = malloc(path_size);
    if (!path) {
        return NULL;
    }
    int n = snprintf(path, path_size, "%s/%s.db", cache_dir, p->project_name);
    if (n < 0 || (size_t)n >= path_size) {
        free(path);
        return NULL;
    }
    return path;
}

static int check_cancel(const cbm_pipeline_t *p) {
    return atomic_load(p->cancelled) ? CBM_NOT_FOUND : 0;