http-fetch.c

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