Function cbm_artifact_export

src/pipeline/artifact.c:546–648

/* ── Export ───────────────────────────────────────────────────────── */

int cbm_artifact_export(const char *db_path, const char *repo_path, const char *project_name,
                        int quality) {
    clear_export_error();

    if (!db_path || !repo_path || !project_name) {
        return artifact_export_fail("validate_args", NULL, "missing_argument", 0);
    }

    /* Ensure .codebase-memory/ directory exists */
    char art_dir[CBM_SZ_4K];
    int dir_len = snprintf(art_dir, sizeof(art_dir), "%s/%s", repo_path, CBM_ARTIFACT_DIR);
    if (dir_len < 0 || (size_t)dir_len >= sizeof(art_dir)) {
        return artifact_export_fail("prepare_artifact_dir", repo_path, "path_too_long", 0);
    }
    errno = 0;
    if (!cbm_mkdir_p(art_dir, ART_DIR_PERMS)) {
        return artifact_export_fail("prepare_artifact_dir", art_dir, "mkdir_or_not_directory",
                                    errno);
    }
    if (!cbm_is_dir(art_dir)) {
        return artifact_export_fail("prepare_artifact_dir", art_dir, "not_directory", 0);
    }

    size_t db_size = 0;
    char *db_data = NULL;
    int compression_level = ART_ZSTD_FAST;

    if (quality == CBM_ARTIFACT_BEST) {
        compression_level = ART_ZSTD_BEST;
        db_data = prepare_snapshot_db(db_path, &db_size, true);
    } else {
        /* FAST keeps zstd-3 and its indexes, but still snapshots via
         * VACUUM INTO: the raw main-file bytes of a live WAL store are a
         * torn copy (#895). */
        db_data = prepare_snapshot_db(db_path, &db_size, false);
    }

    if (!db_data || db_size == 0) {
        free(db_data);
        if (cbm_artifact_export_last_error()) {
            return CBM_NOT_FOUND;
        }
        return artifact_export_fail("read_db", db_path, "empty_or_unreadable", errno);
    }

    /* Compress with zstd */
    size_t bound = cbm_zstd_compress_bound(db_size);
    char *compressed = malloc(bound);
    if (!compressed) {
        free(db_data);
        return artifact_export_fail("compress", NULL, "alloc_compressed_buffer", 0);
    }

    int64_t clen = cbm_zstd_compress(db_data, db_size, compressed, bound, compression_level);
    free(db_data);

    if (clen <= 0) {
        free(compressed);