http-fetch.c

   1 #include "cache.h"
   2 #include "config.h"
   3 #include "exec-cmd.h"
   4 #include "http.h"
   5 #include "walker.h"
   6 #include "strvec.h"
   7 #include "urlmatch.h"
   8
   9 static const char http_fetch_usage[] = "git http-fetch "
  10 "[-c] [-t] [-a] [-v] [--recover] [-w ref] [--stdin | --packfile=hash | commit-id] url";
  11
  12 static int fetch_using_walker(const char *raw_url, int get_verbosely,
  13                               int get_recover, int commits, char **commit_id,
  14                               const char **write_ref, int commits_on_stdin)
  15 {
  16         char *url = NULL;
  17         struct walker *walker;
  18         int rc;
  19
  20         str_end_url_with_slash(raw_url, &url);
  21
  22         http_init(NULL, url, 0);
  23
  24         walker = get_http_walker(url);
  25         walker->get_verbosely = get_verbosely;
  26         walker->get_recover = get_recover;
  27         walker->get_progress = 0;
  28
  29         rc = walker_fetch(walker, commits, commit_id, write_ref, url);
  30
  31         if (commits_on_stdin)
  32                 walker_targets_free(commits, commit_id, write_ref);
  33
  34         if (walker->corrupt_object_found) {
  35                 fprintf(stderr,
  36 "Some loose object were found to be corrupt, but they might be just\n"
  37 "a false '404 Not Found' error message sent with incorrect HTTP\n"
  38 "status code.  Suggest running 'git fsck'.\n");
  39         }
  40
  41         walker_free(walker);
  42         http_cleanup();
  43         free(url);
  44
  45         return rc;
  46 }
  47
  48 static void fetch_single_packfile(struct object_id *packfile_hash,
  49                                   const char *url,
  50                                   const char **index_pack_args) {
  51         struct http_pack_request *preq;
  52         struct slot_results results;
  53         int ret;
  54
  55         http_init(NULL, url, 0);
  56
  57         preq = new_direct_http_pack_request(packfile_hash->hash, xstrdup(url));
  58         if (preq == NULL)
  59                 die("couldn't create http pack request");
  60         preq->slot->results = &results;
  61         preq->index_pack_args = index_pack_args;
  62         preq->preserve_index_pack_stdout = 1;
  63
  64         if (start_active_slot(preq->slot)) {
  65                 run_active_slot(preq->slot);
  66                 if (results.curl_result != CURLE_OK) {
  67                         struct url_info url;
  68                         char *nurl = url_normalize(preq->url, &url);
  69                         if (!nurl || !git_env_bool("GIT_TRACE_REDACT", 1)) {
  70                                 die("unable to get pack file '%s'\n%s", preq->url,
  71                                     curl_errorstr);
  72                         } else {
  73                                 die("failed to get '%.*s' url from '%.*s' "
  74                                     "(full URL redacted due to GIT_TRACE_REDACT setting)\n%s",
  75                                     (int)url.scheme_len, url.url,
  76                                     (int)url.host_len, &url.url[url.host_off], curl_errorstr);
  77                         }
  78                 }
  79         } else {
  80                 die("Unable to start request");
  81         }
  82
  83         if ((ret = finish_http_pack_request(preq)))
  84                 die("finish_http_pack_request gave result %d", ret);
  85
  86         release_http_pack_request(preq);
  87         http_cleanup();
  88 }
  89
  90 int cmd_main(int argc, const char **argv)
  91 {
  92         int commits_on_stdin = 0;
  93         int commits;
  94         const char **write_ref = NULL;
  95         char **commit_id;
  96         int arg = 1;
  97         int get_verbosely = 0;
  98         int get_recover = 0;
  99         int packfile = 0;
 100         int nongit;
 101         struct object_id packfile_hash;
 102         struct strvec index_pack_args = STRVEC_INIT;
 103
 104         setup_git_directory_gently(&nongit);
 105
 106         while (arg < argc && argv[arg][0] == '-') {
 107                 const char *p;
 108
 109                 if (argv[arg][1] == 't') {
 110                 } else if (argv[arg][1] == 'c') {
 111                 } else if (argv[arg][1] == 'a') {
 112                 } else if (argv[arg][1] == 'v') {
 113                         get_verbosely = 1;
 114                 } else if (argv[arg][1] == 'w') {
 115                         write_ref = &argv[arg + 1];
 116                         arg++;
 117                 } else if (argv[arg][1] == 'h') {
 118                         usage(http_fetch_usage);
 119                 } else if (!strcmp(argv[arg], "--recover")) {
 120                         get_recover = 1;
 121                 } else if (!strcmp(argv[arg], "--stdin")) {
 122                         commits_on_stdin = 1;
 123                 } else if (skip_prefix(argv[arg], "--packfile=", &p)) {
 124                         const char *end;
 125
 126                         packfile = 1;
 127                         if (parse_oid_hex(p, &packfile_hash, &end) || *end)
 128                                 die(_("argument to --packfile must be a valid hash (got '%s')"), p);
 129                 } else if (skip_prefix(argv[arg], "--index-pack-arg=", &p)) {
 130                         strvec_push(&index_pack_args, p);
 131                 }
 132                 arg++;
 133         }
 134         if (argc != arg + 2 - (commits_on_stdin || packfile))
 135                 usage(http_fetch_usage);
 136
 137         if (nongit)
 138                 die(_("not a git repository"));
 139
 140         git_config(git_default_config, NULL);
 141
 142         if (packfile) {
 143                 if (!index_pack_args.nr)
 144                         die(_("the option '%s' requires '%s'"), "--packfile", "--index-pack-args");
 145
 146                 fetch_single_packfile(&packfile_hash, argv[arg],
 147                                       index_pack_args.v);
 148
 149                 return 0;
 150         }
 151
 152         if (index_pack_args.nr)
 153                 die(_("the option '%s' requires '%s'"), "--index-pack-args", "--packfile");
 154
 155         if (commits_on_stdin) {
 156                 commits = walker_targets_stdin(&commit_id, &write_ref);
 157         } else {
 158                 commit_id = (char **) &argv[arg++];
 159                 commits = 1;
 160         }
 161         return fetch_using_walker(argv[arg], get_verbosely, get_recover,
 162                                   commits, commit_id, write_ref,
 163                                   commits_on_stdin);
 164 }