diff options
Diffstat (limited to 'src/mirrors.c')
| -rw-r--r-- | src/mirrors.c | 180 |
1 files changed, 0 insertions, 180 deletions
diff --git a/src/mirrors.c b/src/mirrors.c deleted file mode 100644 index cad3f6b..0000000 --- a/src/mirrors.c +++ /dev/null @@ -1,180 +0,0 @@ -#include "spm.h" -#include "url.h" - -char **file_readlines(const char *filename, size_t start, size_t limit, ReaderFn *readerFn) { - FILE *fp = NULL; - char **result = NULL; - char *buffer = NULL; - size_t lines = 0; - - if ((fp = fopen(filename, "r")) == NULL) { - perror(filename); - fprintf(SYSERROR); - return NULL; - } - - // Allocate buffer - if ((buffer = calloc(BUFSIZ + 1, sizeof(char))) == NULL) { - perror("line buffer"); - fprintf(SYSERROR); - fclose(fp); - return NULL; - } - - // count number the of lines in the file - while ((fgets(buffer, BUFSIZ, fp)) != NULL) { - lines++; - } - - if (!lines) { - free(buffer); - fclose(fp); - return NULL; - } - - rewind(fp); - - // Handle invalid start offset - if (start > lines) { - start = 0; - } - - // Adjust line count when start offset is non-zero - if (start != 0 && start < lines) { - lines -= start; - } - - - // Handle minimum and maximum limits - if (limit == 0 || limit > lines) { - limit = lines; - } - - // Populate results array - result = calloc(lines + 1, sizeof(char *)); - for (size_t i = start; i < limit; i++) { - if (i < start) { - continue; - } - - if (fgets(buffer, BUFSIZ, fp) == NULL) { - break; - } - - if (readerFn != NULL) { - int status = readerFn(i - start, &buffer); - // A status greater than zero indicates we should ignore this line entirely and "continue" - // A status less than zero indicates we should "break" - // A zero status proceeds normally - if (status > 0) { - i--; - continue; - } else if (status < 0) { - break; - } - } - result[i - start] = strdup(buffer); - } - - free(buffer); - fclose(fp); - return result; -} - -/** - * - * @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); -} - -void mirror_clone(Manifest *info, char *_dest) { - char *dest = NULL; - if (endswith(_dest, SPM_GLOBAL.repo_target) != 0) { - dest = strdup(_dest); - } - else { - dest = join((char *[]) {_dest, SPM_GLOBAL.repo_target, NULL}, DIRSEPS); - } - - if (exists(dest) != 0 && mkdirs(dest, 0755) != 0) { - perror("Unable to create mirror directory"); - fprintf(SYSERROR); - exit(1); - } - - printf("Remote: %s\n", info->origin); - printf("Local: %s\n", dest); - - for (size_t i = 0; i < info->records; i++) { - long response = 0; - char *archive = join((char *[]) {info->packages[i]->origin, SPM_GLOBAL.repo_target, 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); - long response = 0; - 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); - printf("done!\n"); -}
\ No newline at end of file |