7 #include "run-command.h"
10 #include "send-pack.h"
12 #include "transport.h"
14 #include "oid-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
;
32 struct ref_push_report
*report
;
34 for (; ref
; ref
= ref
->next
) {
35 const char *msg
= NULL
;
49 case REF_STATUS_UPTODATE
:
54 case REF_STATUS_REJECT_NONFASTFORWARD
:
56 msg
= "non-fast forward";
59 case REF_STATUS_REJECT_FETCH_FIRST
:
64 case REF_STATUS_REJECT_NEEDS_FORCE
:
69 case REF_STATUS_REJECT_STALE
:
74 case REF_STATUS_REJECT_ALREADY_EXISTS
:
76 msg
= "already exists";
79 case REF_STATUS_REJECT_NODELETE
:
80 case REF_STATUS_REMOTE_REJECT
:
84 case REF_STATUS_EXPECTING_REPORT
:
90 strbuf_addf(&buf
, "%s %s", res
, ref
->name
);
91 if (ref
->remote_status
)
92 msg
= ref
->remote_status
;
94 strbuf_addch(&buf
, ' ');
95 quote_two_c_style(&buf
, "", msg
, 0);
97 strbuf_addch(&buf
, '\n');
99 if (ref
->status
== REF_STATUS_OK
) {
100 for (report
= ref
->report
; report
; report
= report
->next
) {
102 strbuf_addf(&buf
, "ok %s\n", ref
->name
);
103 if (report
->ref_name
)
104 strbuf_addf(&buf
, "option refname %s\n",
107 strbuf_addf(&buf
, "option old-oid %s\n",
108 oid_to_hex(report
->old_oid
));
110 strbuf_addf(&buf
, "option new-oid %s\n",
111 oid_to_hex(report
->new_oid
));
112 if (report
->forced_update
)
113 strbuf_addstr(&buf
, "option forced-update\n");
116 write_or_die(1, buf
.buf
, buf
.len
);
118 strbuf_release(&buf
);
121 static int send_pack_config(const char *k
, const char *v
, void *cb
)
123 git_gpg_config(k
, v
, NULL
);
125 if (!strcmp(k
, "push.gpgsign")) {
127 if (!git_config_get_value("push.gpgsign", &value
)) {
128 switch (git_parse_maybe_bool(value
)) {
130 args
.push_cert
= SEND_PACK_PUSH_CERT_NEVER
;
133 args
.push_cert
= SEND_PACK_PUSH_CERT_ALWAYS
;
136 if (value
&& !strcasecmp(value
, "if-asked"))
137 args
.push_cert
= SEND_PACK_PUSH_CERT_IF_ASKED
;
139 return error("Invalid value for '%s'", k
);
143 return git_default_config(k
, v
, cb
);
146 int cmd_send_pack(int argc
, const char **argv
, const char *prefix
)
148 struct refspec rs
= REFSPEC_INIT_PUSH
;
149 const char *remote_name
= NULL
;
150 struct remote
*remote
= NULL
;
151 const char *dest
= NULL
;
153 struct child_process
*conn
;
154 struct oid_array extra_have
= OID_ARRAY_INIT
;
155 struct oid_array shallow
= OID_ARRAY_INIT
;
156 struct ref
*remote_refs
, *local_refs
;
158 int helper_status
= 0;
161 const char *receivepack
= "git-receive-pack";
162 unsigned dry_run
= 0;
163 unsigned send_mirror
= 0;
164 unsigned force_update
= 0;
167 struct string_list push_options
= STRING_LIST_INIT_NODUP
;
168 unsigned use_thin_pack
= 0;
170 unsigned stateless_rpc
= 0;
172 unsigned int reject_reasons
;
175 struct push_cas_option cas
= {0};
176 struct packet_reader reader
;
178 struct option options
[] = {
179 OPT__VERBOSITY(&verbose
),
180 OPT_STRING(0, "receive-pack", &receivepack
, "receive-pack", N_("receive pack program")),
181 OPT_STRING(0, "exec", &receivepack
, "receive-pack", N_("receive pack program")),
182 OPT_STRING(0, "remote", &remote_name
, "remote", N_("remote name")),
183 OPT_BOOL(0, "all", &send_all
, N_("push all refs")),
184 OPT_BOOL('n' , "dry-run", &dry_run
, N_("dry run")),
185 OPT_BOOL(0, "mirror", &send_mirror
, N_("mirror all refs")),
186 OPT_BOOL('f', "force", &force_update
, N_("force updates")),
188 0, "signed", &push_cert
, "(yes|no|if-asked)", N_("GPG sign the push"),
189 PARSE_OPT_OPTARG
, option_parse_push_signed
},
190 OPT_STRING_LIST(0, "push-option", &push_options
,
191 N_("server-specific"),
192 N_("option to transmit")),
193 OPT_BOOL(0, "progress", &progress
, N_("force progress reporting")),
194 OPT_BOOL(0, "thin", &use_thin_pack
, N_("use thin pack")),
195 OPT_BOOL(0, "atomic", &atomic
, N_("request atomic transaction on remote side")),
196 OPT_BOOL(0, "stateless-rpc", &stateless_rpc
, N_("use stateless RPC protocol")),
197 OPT_BOOL(0, "stdin", &from_stdin
, N_("read refs from stdin")),
198 OPT_BOOL(0, "helper-status", &helper_status
, N_("print status from remote helper")),
200 0, CAS_OPT_NAME
, &cas
, N_("<refname>:<expect>"),
201 N_("require old value of ref to be at this value"),
202 PARSE_OPT_OPTARG
, parseopt_push_cas_option
},
206 git_config(send_pack_config
, NULL
);
207 argc
= parse_options(argc
, argv
, prefix
, options
, send_pack_usage
, 0);
210 refspec_appendn(&rs
, argv
+ 1, argc
- 1);
214 usage_with_options(send_pack_usage
, options
);
216 args
.verbose
= verbose
;
217 args
.dry_run
= dry_run
;
218 args
.send_mirror
= send_mirror
;
219 args
.force_update
= force_update
;
221 args
.push_cert
= push_cert
;
222 args
.progress
= progress
;
223 args
.use_thin_pack
= use_thin_pack
;
224 args
.atomic
= atomic
;
225 args
.stateless_rpc
= stateless_rpc
;
226 args
.push_options
= push_options
.nr
? &push_options
: NULL
;
229 if (args
.stateless_rpc
) {
231 while ((buf
= packet_read_line(0, NULL
)))
232 refspec_append(&rs
, buf
);
234 struct strbuf line
= STRBUF_INIT
;
235 while (strbuf_getline(&line
, stdin
) != EOF
)
236 refspec_append(&rs
, line
.buf
);
237 strbuf_release(&line
);
242 * --all and --mirror are incompatible; neither makes sense
245 if ((rs
.nr
> 0 && (send_all
|| args
.send_mirror
)) ||
246 (send_all
&& args
.send_mirror
))
247 usage_with_options(send_pack_usage
, options
);
250 remote
= remote_get(remote_name
);
251 if (!remote_has_url(remote
, dest
)) {
252 die("Destination %s is not a uri for %s",
258 progress
= !args
.quiet
&& isatty(2);
259 args
.progress
= progress
;
261 if (args
.stateless_rpc
) {
266 conn
= git_connect(fd
, dest
, receivepack
,
267 args
.verbose
? CONNECT_VERBOSE
: 0);
270 packet_reader_init(&reader
, fd
[0], NULL
, 0,
271 PACKET_READ_CHOMP_NEWLINE
|
272 PACKET_READ_GENTLE_ON_EOF
|
273 PACKET_READ_DIE_ON_ERR_PACKET
);
275 switch (discover_version(&reader
)) {
277 die("support for protocol v2 not implemented yet");
281 get_remote_heads(&reader
, &remote_refs
, REF_NORMAL
,
282 &extra_have
, &shallow
);
284 case protocol_unknown_version
:
285 BUG("unknown protocol version");
288 local_refs
= get_local_heads();
290 flags
= MATCH_REFS_NONE
;
293 flags
|= MATCH_REFS_ALL
;
294 if (args
.send_mirror
)
295 flags
|= MATCH_REFS_MIRROR
;
298 if (match_push_refs(local_refs
, &remote_refs
, &rs
, flags
))
301 if (!is_empty_cas(&cas
))
302 apply_push_cas(&cas
, remote
, remote_refs
);
304 set_ref_status_for_push(remote_refs
, args
.send_mirror
,
307 ret
= send_pack(&args
, fd
, conn
, remote_refs
, &extra_have
);
310 print_helper_status(remote_refs
);
315 ret
|= finish_connect(conn
);
318 transport_print_push_status(dest
, remote_refs
, args
.verbose
, 0, &reject_reasons
);
320 if (!args
.dry_run
&& remote
) {
322 for (ref
= remote_refs
; ref
; ref
= ref
->next
)
323 transport_update_tracking_ref(remote
, ref
, args
.verbose
);
326 if (!ret
&& !transport_refs_pushed(remote_refs
))
327 fprintf(stderr
, "Everything up-to-date\n");