#include "spm.h"
#include "url.h"

/**
 *
 * @param filename
 * @return
 */
char **mirror_list(const char *filename) {
    char **mirrors = NULL;
    char **result = NULL;
    size_t count;

    // The configuration file isn't critical so if it isn't available, no big deal
    if (exists(filename) != 0) {
        return NULL;
    }

    mirrors = file_readlines(filename, 0, 0, NULL);
    if (mirrors == NULL) {
        return NULL;
    }

    for (count = 0; mirrors[count] != NULL; count++);
    if (!count) {
        return NULL;
    }

    result = calloc(count + 1, sizeof(char **));
    for (size_t i = 0; mirrors[i] != NULL; i++) {
        if (startswith(mirrors[i], "#") || isempty(mirrors[i])) {
            continue;
        }
        result[i] = join((char *[]) {mirrors[i], SPM_GLOBAL.repo_target, NULL}, DIRSEPS);
        free(mirrors[i]);
    }
    free(mirrors);
    return result;
}

void mirror_list_free(char **m) {
    if (m == NULL) {
        return;
    }
    for (size_t i = 0; m[i] != NULL; i++) {
        free(m[i]);
    }
    free(m);
}

int mirror_clone(Manifest *info, char *_dest) {
    char *dest;
    long response;

    response = 0;
    dest = strdup(_dest);
    if (dest == NULL) {
        perror("allocate dest string");
        return 1;
    }

    if (exists(dest) != 0 && mkdirs(dest, 0755) != 0) {
        perror("Unable to create mirror directory");
        fprintf(SYSERROR);
        return 1;
    }

    printf("Remote: %s\n", info->origin);
    printf("Local: %s\n", dest);

    for (size_t i = 0; i < info->records; i++) {
        char *archive = join((char *[]) {dirname(info->origin), info->packages[i]->archive, NULL}, DIRSEPS);
        char *path = join((char *[]) {dest, info->packages[i]->archive, NULL}, DIRSEPS);
        if (exists(path) == 0) {
            char *checksum = sha256sum(path);
            if (strcmp(checksum, info->packages[i]->checksum_sha256) == 0) {
                printf("Skipped: %s\n", archive);
                free(checksum);
                free(archive);
                free(path);
                continue;
            }
        }
        printf("Fetch: %s\n", archive);
        if ((response = fetch(archive, path)) >= 400) {
            fprintf(stderr, "WARNING: HTTP(%ld, %s): %s\n", response, http_response_str(response), archive);
        }
        free(archive);
        free(path);
    }

    // Now fetch a copy of the physical manifest
    char *datafile = join((char *[]) {dest, basename(info->origin), NULL}, DIRSEPS);
    if ((response = fetch(info->origin, datafile) >= 400)) {
        fprintf(stderr, "WARNING: HTTP(%ld, %s): %s\n", response, http_response_str(response), info->origin);
    }

    free(dest);
    free(datafile);
    return 0;
}