7 #include "run-command.h"
10 #include "send-pack.h"
12 #include "transport.h"
14 #include "sha1-array.h"
15 #include "gpg-interface.h"
19 static const char * const send_pack_usage
[] = {
20 N_("git send-pack [--all | --mirror] [--dry-run] [--force] "
21 "[--receive-pack=<git-receive-pack>] [--verbose] [--thin] [--atomic] "
22 "[<host>:]<directory> [<ref>...]\n"
23 " --all and explicit <ref> specification are mutually exclusive."),
27 static struct send_pack_args args
;
29 static void print_helper_status(struct ref
*ref
)
31 struct strbuf buf
= STRBUF_INIT
;
33 for (; ref
; ref
= ref
->next
) {
34 const char *msg
= NULL
;
47 case REF_STATUS_UPTODATE
:
52 case REF_STATUS_REJECT_NONFASTFORWARD
:
54 msg
= "non-fast forward";
57 case REF_STATUS_REJECT_FETCH_FIRST
:
62 case REF_STATUS_REJECT_NEEDS_FORCE
:
67 case REF_STATUS_REJECT_STALE
:
72 case REF_STATUS_REJECT_ALREADY_EXISTS
:
74 msg
= "already exists";
77 case REF_STATUS_REJECT_NODELETE
:
78 case REF_STATUS_REMOTE_REJECT
:
82 case REF_STATUS_EXPECTING_REPORT
:
88 strbuf_addf(&buf
, "%s %s", res
, ref
->name
);
89 if (ref
->remote_status
)
90 msg
= ref
->remote_status
;
92 strbuf_addch(&buf
, ' ');
93 quote_two_c_style(&buf
, "", msg
, 0);
95 strbuf_addch(&buf
, '\n');
97 write_or_die(1, buf
.buf
, buf
.len
);
102 static int send_pack_config(const char *k
, const char *v
, void *cb
)
104 git_gpg_config(k
, v
, NULL
);
106 if (!strcmp(k
, "push.gpgsign")) {
108 if (!git_config_get_value("push.gpgsign", &value
)) {
109 switch (git_parse_maybe_bool(value
)) {
111 args
.push_cert
= SEND_PACK_PUSH_CERT_NEVER
;
114 args
.push_cert
= SEND_PACK_PUSH_CERT_ALWAYS
;
117 if (value
&& !strcasecmp(value
, "if-asked"))
118 args
.push_cert
= SEND_PACK_PUSH_CERT_IF_ASKED
;
120 return error("Invalid value for '%s'", k
);
127 int cmd_send_pack(int argc
, const char **argv
, const char *prefix
)
129 int i
, nr_refspecs
= 0;
130 const char **refspecs
= NULL
;
131 const char *remote_name
= NULL
;
132 struct remote
*remote
= NULL
;
133 const char *dest
= NULL
;
135 struct child_process
*conn
;
136 struct oid_array extra_have
= OID_ARRAY_INIT
;
137 struct oid_array shallow
= OID_ARRAY_INIT
;
138 struct ref
*remote_refs
, *local_refs
;
140 int helper_status
= 0;
143 const char *receivepack
= "git-receive-pack";
144 unsigned dry_run
= 0;
145 unsigned send_mirror
= 0;
146 unsigned force_update
= 0;
149 struct string_list push_options
= STRING_LIST_INIT_NODUP
;
150 unsigned use_thin_pack
= 0;
152 unsigned stateless_rpc
= 0;
154 unsigned int reject_reasons
;
157 struct push_cas_option cas
= {0};
158 struct packet_reader reader
;
160 struct option options
[] = {
161 OPT__VERBOSITY(&verbose
),
162 OPT_STRING(0, "receive-pack", &receivepack
, "receive-pack", N_("receive pack program")),
163 OPT_STRING(0, "exec", &receivepack
, "receive-pack", N_("receive pack program")),
164 OPT_STRING(0, "remote", &remote_name
, "remote", N_("remote name")),
165 OPT_BOOL(0, "all", &send_all
, N_("push all refs")),
166 OPT_BOOL('n' , "dry-run", &dry_run
, N_("dry run")),
167 OPT_BOOL(0, "mirror", &send_mirror
, N_("mirror all refs")),
168 OPT_BOOL('f', "force", &force_update
, N_("force updates")),
170 0, "signed", &push_cert
, "yes|no|if-asked", N_("GPG sign the push"),
171 PARSE_OPT_OPTARG
, option_parse_push_signed
},
172 OPT_STRING_LIST(0, "push-option", &push_options
,
173 N_("server-specific"),
174 N_("option to transmit")),
175 OPT_BOOL(0, "progress", &progress
, N_("force progress reporting")),
176 OPT_BOOL(0, "thin", &use_thin_pack
, N_("use thin pack")),
177 OPT_BOOL(0, "atomic", &atomic
, N_("request atomic transaction on remote side")),
178 OPT_BOOL(0, "stateless-rpc", &stateless_rpc
, N_("use stateless RPC protocol")),
179 OPT_BOOL(0, "stdin", &from_stdin
, N_("read refs from stdin")),
180 OPT_BOOL(0, "helper-status", &helper_status
, N_("print status from remote helper")),
182 0, CAS_OPT_NAME
, &cas
, N_("refname>:<expect"),
183 N_("require old value of ref to be at this value"),
184 PARSE_OPT_OPTARG
, parseopt_push_cas_option
},
188 git_config(send_pack_config
, NULL
);
189 argc
= parse_options(argc
, argv
, prefix
, options
, send_pack_usage
, 0);
192 refspecs
= (const char **)(argv
+ 1);
193 nr_refspecs
= argc
- 1;
197 usage_with_options(send_pack_usage
, options
);
199 args
.verbose
= verbose
;
200 args
.dry_run
= dry_run
;
201 args
.send_mirror
= send_mirror
;
202 args
.force_update
= force_update
;
204 args
.push_cert
= push_cert
;
205 args
.progress
= progress
;
206 args
.use_thin_pack
= use_thin_pack
;
207 args
.atomic
= atomic
;
208 args
.stateless_rpc
= stateless_rpc
;
209 args
.push_options
= push_options
.nr
? &push_options
: NULL
;
212 struct argv_array all_refspecs
= ARGV_ARRAY_INIT
;
214 for (i
= 0; i
< nr_refspecs
; i
++)
215 argv_array_push(&all_refspecs
, refspecs
[i
]);
217 if (args
.stateless_rpc
) {
219 while ((buf
= packet_read_line(0, NULL
)))
220 argv_array_push(&all_refspecs
, buf
);
222 struct strbuf line
= STRBUF_INIT
;
223 while (strbuf_getline(&line
, stdin
) != EOF
)
224 argv_array_push(&all_refspecs
, line
.buf
);
225 strbuf_release(&line
);
228 refspecs
= all_refspecs
.argv
;
229 nr_refspecs
= all_refspecs
.argc
;
233 * --all and --mirror are incompatible; neither makes sense
236 if ((nr_refspecs
> 0 && (send_all
|| args
.send_mirror
)) ||
237 (send_all
&& args
.send_mirror
))
238 usage_with_options(send_pack_usage
, options
);
241 remote
= remote_get(remote_name
);
242 if (!remote_has_url(remote
, dest
)) {
243 die("Destination %s is not a uri for %s",
249 progress
= !args
.quiet
&& isatty(2);
250 args
.progress
= progress
;
252 if (args
.stateless_rpc
) {
257 conn
= git_connect(fd
, dest
, receivepack
,
258 args
.verbose
? CONNECT_VERBOSE
: 0);
261 packet_reader_init(&reader
, fd
[0], NULL
, 0,
262 PACKET_READ_CHOMP_NEWLINE
|
263 PACKET_READ_GENTLE_ON_EOF
);
265 switch (discover_version(&reader
)) {
267 die("support for protocol v2 not implemented yet");
271 get_remote_heads(&reader
, &remote_refs
, REF_NORMAL
,
272 &extra_have
, &shallow
);
274 case protocol_unknown_version
:
275 BUG("unknown protocol version");
278 transport_verify_remote_names(nr_refspecs
, refspecs
);
280 local_refs
= get_local_heads();
282 flags
= MATCH_REFS_NONE
;
285 flags
|= MATCH_REFS_ALL
;
286 if (args
.send_mirror
)
287 flags
|= MATCH_REFS_MIRROR
;
290 if (match_push_refs(local_refs
, &remote_refs
, nr_refspecs
, refspecs
, flags
))
293 if (!is_empty_cas(&cas
))
294 apply_push_cas(&cas
, remote
, remote_refs
);
296 set_ref_status_for_push(remote_refs
, args
.send_mirror
,
299 ret
= send_pack(&args
, fd
, conn
, remote_refs
, &extra_have
);
302 print_helper_status(remote_refs
);
307 ret
|= finish_connect(conn
);
310 transport_print_push_status(dest
, remote_refs
, args
.verbose
, 0, &reject_reasons
);
312 if (!args
.dry_run
&& remote
) {
314 for (ref
= remote_refs
; ref
; ref
= ref
->next
)
315 transport_update_tracking_ref(remote
, ref
, args
.verbose
);
318 if (!ret
&& !transport_refs_pushed(remote_refs
))
319 fprintf(stderr
, "Everything up-to-date\n");