[git/git.git] / transport-helper.c

#include "cache.h"
#include "transport.h"
#include "quote.h"
#include "run-command.h"
#include "commit.h"
#include "diff.h"
#include "revision.h"
#include "quote.h"
#include "remote.h"

static int debug;

struct helper_data
{
	const char *name;
	struct child_process *helper;
	FILE *out;
	unsigned fetch : 1,
		import : 1,
		option : 1,
		push : 1;
	/* These go from remote name (as in "list") to private name */
	struct refspec *refspecs;
	int refspec_nr;
};

static void sendline(struct helper_data *helper, struct strbuf *buffer)
{
	if (debug)
		fprintf(stderr, "Debug: Remote helper: -> %s", buffer->buf);
	if (write_in_full(helper->helper->in, buffer->buf, buffer->len)
		!= buffer->len)
		die_errno("Full write to remote helper failed");
}

static int recvline(struct helper_data *helper, struct strbuf *buffer)
{
	strbuf_reset(buffer);
	if (debug)
		fprintf(stderr, "Debug: Remote helper: Waiting...\n");
	if (strbuf_getline(buffer, helper->out, '\n') == EOF) {
		if (debug)
			fprintf(stderr, "Debug: Remote helper quit.\n");
		exit(128);
	}

	if (debug)
		fprintf(stderr, "Debug: Remote helper: <- %s\n", buffer->buf);
	return 0;
}

static void xchgline(struct helper_data *helper, struct strbuf *buffer)
{
	sendline(helper, buffer);
	recvline(helper, buffer);
}

static void write_constant(int fd, const char *str)
{
	if (debug)
		fprintf(stderr, "Debug: Remote helper: -> %s", str);
	if (write_in_full(fd, str, strlen(str)) != strlen(str))
		die_errno("Full write to remote helper failed");
}

static struct child_process *get_helper(struct transport *transport)
{
	struct helper_data *data = transport->data;
	struct strbuf buf = STRBUF_INIT;
	struct child_process *helper;
	const char **refspecs = NULL;
	int refspec_nr = 0;
	int refspec_alloc = 0;

	if (data->helper)
		return data->helper;

	helper = xcalloc(1, sizeof(*helper));
	helper->in = -1;
	helper->out = -1;
	helper->err = 0;
	helper->argv = xcalloc(4, sizeof(*helper->argv));
	strbuf_addf(&buf, "remote-%s", data->name);
	helper->argv[0] = strbuf_detach(&buf, NULL);
	helper->argv[1] = transport->remote->name;
	helper->argv[2] = transport->url;
	helper->git_cmd = 1;
	if (start_command(helper))
		die("Unable to run helper: git %s", helper->argv[0]);
	data->helper = helper;

	write_constant(helper->in, "capabilities\n");

	data->out = xfdopen(helper->out, "r");
	while (1) {
		const char *capname;
		int mandatory = 0;
		recvline(data, &buf);

		if (!*buf.buf)
			break;

		if (*buf.buf == '*') {
			capname = buf.buf + 1;
			mandatory = 1;
		} else
			capname = buf.buf;

		if (debug)
			fprintf(stderr, "Debug: Got cap %s\n", capname);
		if (!strcmp(capname, "fetch"))
			data->fetch = 1;
		else if (!strcmp(capname, "option"))
			data->option = 1;
		else if (!strcmp(capname, "push"))
			data->push = 1;
		else if (!strcmp(capname, "import"))
			data->import = 1;
		else if (!data->refspecs && !prefixcmp(capname, "refspec ")) {
			ALLOC_GROW(refspecs,
				   refspec_nr + 1,
				   refspec_alloc);
			refspecs[refspec_nr++] = strdup(buf.buf + strlen("refspec "));
		} else if (mandatory) {
			die("Unknown madatory capability %s. This remote "
			    "helper probably needs newer version of Git.\n",
			    capname);
		}
	}
	if (refspecs) {
		int i;
		data->refspec_nr = refspec_nr;
		data->refspecs = parse_fetch_refspec(refspec_nr, refspecs);
		for (i = 0; i < refspec_nr; i++) {
			free((char *)refspecs[i]);
		}
		free(refspecs);
	}
	strbuf_release(&buf);
	if (debug)
		fprintf(stderr, "Debug: Capabilities complete.\n");
	return data->helper;
}

static int disconnect_helper(struct transport *transport)
{
	struct helper_data *data = transport->data;
	struct strbuf buf = STRBUF_INIT;

	if (data->helper) {
		if (debug)
			fprintf(stderr, "Debug: Disconnecting.\n");
		strbuf_addf(&buf, "\n");
		sendline(data, &buf);
		close(data->helper->in);
		fclose(data->out);
		finish_command(data->helper);
		free((char *)data->helper->argv[0]);
		free(data->helper->argv);
		free(data->helper);
		data->helper = NULL;
	}
	return 0;
}

static const char *unsupported_options[] = {
	TRANS_OPT_UPLOADPACK,
	TRANS_OPT_RECEIVEPACK,
	TRANS_OPT_THIN,
	TRANS_OPT_KEEP
	};
static const char *boolean_options[] = {
	TRANS_OPT_THIN,
	TRANS_OPT_KEEP,
	TRANS_OPT_FOLLOWTAGS
	};

static int set_helper_option(struct transport *transport,
			  const char *name, const char *value)
{
	struct helper_data *data = transport->data;
	struct strbuf buf = STRBUF_INIT;
	int i, ret, is_bool = 0;

	get_helper(transport);

	if (!data->option)
		return 1;

	for (i = 0; i < ARRAY_SIZE(unsupported_options); i++) {
		if (!strcmp(name, unsupported_options[i]))
			return 1;
	}

	for (i = 0; i < ARRAY_SIZE(boolean_options); i++) {
		if (!strcmp(name, boolean_options[i])) {
			is_bool = 1;
			break;
		}
	}

	strbuf_addf(&buf, "option %s ", name);
	if (is_bool)
		strbuf_addstr(&buf, value ? "true" : "false");
	else
		quote_c_style(value, &buf, NULL, 0);
	strbuf_addch(&buf, '\n');

	xchgline(data, &buf);

	if (!strcmp(buf.buf, "ok"))
		ret = 0;
	else if (!prefixcmp(buf.buf, "error")) {
		ret = -1;
	} else if (!strcmp(buf.buf, "unsupported"))
		ret = 1;
	else {
		warning("%s unexpectedly said: '%s'", data->name, buf.buf);
		ret = 1;
	}
	strbuf_release(&buf);
	return ret;
}

static void standard_options(struct transport *t)
{
	char buf[16];
	int n;
	int v = t->verbose;
	int no_progress = v < 0 || (!t->progress && !isatty(1));

	set_helper_option(t, "progress", !no_progress ? "true" : "false");

	n = snprintf(buf, sizeof(buf), "%d", v + 1);
	if (n >= sizeof(buf))
		die("impossibly large verbosity value");
	set_helper_option(t, "verbosity", buf);
}

static int release_helper(struct transport *transport)
{
	struct helper_data *data = transport->data;
	free_refspec(data->refspec_nr, data->refspecs);
	data->refspecs = NULL;
	disconnect_helper(transport);
	free(transport->data);
	return 0;
}

static int fetch_with_fetch(struct transport *transport,
			    int nr_heads, struct ref **to_fetch)
{
	struct helper_data *data = transport->data;
	int i;
	struct strbuf buf = STRBUF_INIT;

	standard_options(transport);

	for (i = 0; i < nr_heads; i++) {
		const struct ref *posn = to_fetch[i];
		if (posn->status & REF_STATUS_UPTODATE)
			continue;

		strbuf_addf(&buf, "fetch %s %s\n",
			    sha1_to_hex(posn->old_sha1), posn->name);
	}

	strbuf_addch(&buf, '\n');
	sendline(data, &buf);

	while (1) {
		recvline(data, &buf);

		if (!prefixcmp(buf.buf, "lock ")) {
			const char *name = buf.buf + 5;
			if (transport->pack_lockfile)
				warning("%s also locked %s", data->name, name);
			else
				transport->pack_lockfile = xstrdup(name);
		}
		else if (!buf.len)
			break;
		else
			warning("%s unexpectedly said: '%s'", data->name, buf.buf);
	}
	strbuf_release(&buf);
	return 0;
}

static int get_importer(struct transport *transport, struct child_process *fastimport)
{
	struct child_process *helper = get_helper(transport);
	memset(fastimport, 0, sizeof(*fastimport));
	fastimport->in = helper->out;
	fastimport->argv = xcalloc(5, sizeof(*fastimport->argv));
	fastimport->argv[0] = "fast-import";
	fastimport->argv[1] = "--quiet";

	fastimport->git_cmd = 1;
	return start_command(fastimport);
}

static int fetch_with_import(struct transport *transport,
			     int nr_heads, struct ref **to_fetch)
{
	struct child_process fastimport;
	struct helper_data *data = transport->data;
	int i;
	struct ref *posn;
	struct strbuf buf = STRBUF_INIT;

	get_helper(transport);

	if (get_importer(transport, &fastimport))
		die("Couldn't run fast-import");

	for (i = 0; i < nr_heads; i++) {
		posn = to_fetch[i];
		if (posn->status & REF_STATUS_UPTODATE)
			continue;

		strbuf_addf(&buf, "import %s\n", posn->name);
		sendline(data, &buf);
		strbuf_reset(&buf);
	}
	disconnect_helper(transport);
	finish_command(&fastimport);
	free(fastimport.argv);
	fastimport.argv = NULL;

	for (i = 0; i < nr_heads; i++) {
		char *private;
		posn = to_fetch[i];
		if (posn->status & REF_STATUS_UPTODATE)
			continue;
		if (data->refspecs)
			private = apply_refspecs(data->refspecs, data->refspec_nr, posn->name);
		else
			private = strdup(posn->name);
		read_ref(private, posn->old_sha1);
		free(private);
	}
	strbuf_release(&buf);
	return 0;
}

static int fetch(struct transport *transport,
		 int nr_heads, struct ref **to_fetch)
{
	struct helper_data *data = transport->data;
	int i, count;

	count = 0;
	for (i = 0; i < nr_heads; i++)
		if (!(to_fetch[i]->status & REF_STATUS_UPTODATE))
			count++;

	if (!count)
		return 0;

	if (data->fetch)
		return fetch_with_fetch(transport, nr_heads, to_fetch);

	if (data->import)
		return fetch_with_import(transport, nr_heads, to_fetch);

	return -1;
}

static int push_refs(struct transport *transport,
		struct ref *remote_refs, int flags)
{
	int force_all = flags & TRANSPORT_PUSH_FORCE;
	int mirror = flags & TRANSPORT_PUSH_MIRROR;
	struct helper_data *data = transport->data;
	struct strbuf buf = STRBUF_INIT;
	struct child_process *helper;
	struct ref *ref;

	if (!remote_refs)
		return 0;

	helper = get_helper(transport);
	if (!data->push)
		return 1;

	for (ref = remote_refs; ref; ref = ref->next) {
		if (ref->peer_ref)
			hashcpy(ref->new_sha1, ref->peer_ref->new_sha1);
		else if (!mirror)
			continue;

		ref->deletion = is_null_sha1(ref->new_sha1);
		if (!ref->deletion &&
			!hashcmp(ref->old_sha1, ref->new_sha1)) {
			ref->status = REF_STATUS_UPTODATE;
			continue;
		}

		if (force_all)
			ref->force = 1;

		strbuf_addstr(&buf, "push ");
		if (!ref->deletion) {
			if (ref->force)
				strbuf_addch(&buf, '+');
			if (ref->peer_ref)
				strbuf_addstr(&buf, ref->peer_ref->name);
			else
				strbuf_addstr(&buf, sha1_to_hex(ref->new_sha1));
		}
		strbuf_addch(&buf, ':');
		strbuf_addstr(&buf, ref->name);
		strbuf_addch(&buf, '\n');
	}
	if (buf.len == 0)
		return 0;

	transport->verbose = flags & TRANSPORT_PUSH_VERBOSE ? 1 : 0;
	standard_options(transport);

	if (flags & TRANSPORT_PUSH_DRY_RUN) {
		if (set_helper_option(transport, "dry-run", "true") != 0)
			die("helper %s does not support dry-run", data->name);
	}

	strbuf_addch(&buf, '\n');
	sendline(data, &buf);

	ref = remote_refs;
	while (1) {
		char *refname, *msg;
		int status;

		recvline(data, &buf);
		if (!buf.len)
			break;

		if (!prefixcmp(buf.buf, "ok ")) {
			status = REF_STATUS_OK;
			refname = buf.buf + 3;
		} else if (!prefixcmp(buf.buf, "error ")) {
			status = REF_STATUS_REMOTE_REJECT;
			refname = buf.buf + 6;
		} else
			die("expected ok/error, helper said '%s'\n", buf.buf);

		msg = strchr(refname, ' ');
		if (msg) {
			struct strbuf msg_buf = STRBUF_INIT;
			const char *end;

			*msg++ = '\0';
			if (!unquote_c_style(&msg_buf, msg, &end))
				msg = strbuf_detach(&msg_buf, NULL);
			else
				msg = xstrdup(msg);
			strbuf_release(&msg_buf);

			if (!strcmp(msg, "no match")) {
				status = REF_STATUS_NONE;
				free(msg);
				msg = NULL;
			}
			else if (!strcmp(msg, "up to date")) {
				status = REF_STATUS_UPTODATE;
				free(msg);
				msg = NULL;
			}
			else if (!strcmp(msg, "non-fast forward")) {
				status = REF_STATUS_REJECT_NONFASTFORWARD;
				free(msg);
				msg = NULL;
			}
		}

		if (ref)
			ref = find_ref_by_name(ref, refname);
		if (!ref)
			ref = find_ref_by_name(remote_refs, refname);
		if (!ref) {
			warning("helper reported unexpected status of %s", refname);
			continue;
		}

		ref->status = status;
		ref->remote_status = msg;
	}
	strbuf_release(&buf);
	return 0;
}

static int has_attribute(const char *attrs, const char *attr) {
	int len;
	if (!attrs)
		return 0;

	len = strlen(attr);
	for (;;) {
		const char *space = strchrnul(attrs, ' ');
		if (len == space - attrs && !strncmp(attrs, attr, len))
			return 1;
		if (!*space)
			return 0;
		attrs = space + 1;
	}
}

static struct ref *get_refs_list(struct transport *transport, int for_push)
{
	struct helper_data *data = transport->data;
	struct child_process *helper;
	struct ref *ret = NULL;
	struct ref **tail = &ret;
	struct ref *posn;
	struct strbuf buf = STRBUF_INIT;

	helper = get_helper(transport);

	if (data->push && for_push)
		write_str_in_full(helper->in, "list for-push\n");
	else
		write_str_in_full(helper->in, "list\n");

	while (1) {
		char *eov, *eon;
		recvline(data, &buf);

		if (!*buf.buf)
			break;

		eov = strchr(buf.buf, ' ');
		if (!eov)
			die("Malformed response in ref list: %s", buf.buf);
		eon = strchr(eov + 1, ' ');
		*eov = '\0';
		if (eon)
			*eon = '\0';
		*tail = alloc_ref(eov + 1);
		if (buf.buf[0] == '@')
			(*tail)->symref = xstrdup(buf.buf + 1);
		else if (buf.buf[0] != '?')
			get_sha1_hex(buf.buf, (*tail)->old_sha1);
		if (eon) {
			if (has_attribute(eon + 1, "unchanged")) {
				(*tail)->status |= REF_STATUS_UPTODATE;
				read_ref((*tail)->name, (*tail)->old_sha1);
			}
		}
		tail = &((*tail)->next);
	}
	if (debug)
		fprintf(stderr, "Debug: Read ref listing.\n");
	strbuf_release(&buf);

	for (posn = ret; posn; posn = posn->next)
		resolve_remote_symref(posn, ret);

	return ret;
}

int transport_helper_init(struct transport *transport, const char *name)
{
	struct helper_data *data = xcalloc(sizeof(*data), 1);
	data->name = name;

	if (getenv("GIT_TRANSPORT_HELPER_DEBUG"))
		debug = 1;

	transport->data = data;
	transport->set_option = set_helper_option;
	transport->get_refs_list = get_refs_list;
	transport->fetch = fetch;
	transport->push_refs = push_refs;
	transport->disconnect = release_helper;
	return 0;
}
Commit	Line	Data
6eb996b5 DB	1	#include "cache.h"
6eb996b5 DB	2	#include "transport.h"
ae4efe19	3	#include "quote.h"
6eb996b5 DB	4	#include "run-command.h"
	5	#include "commit.h"
	6	#include "diff.h"
	7	#include "revision.h"
ef08ef9e	8	#include "quote.h"
72ff8943	9	#include "remote.h"
6eb996b5	10
bf3c523c IL	11	static int debug;
bf3c523c IL	12
6eb996b5 DB	13	struct helper_data
	14	{
	15	const char *name;
	16	struct child_process *helper;
292ce46b	17	FILE *out;
ef08ef9e	18	unsigned fetch : 1,
a24a32dd	19	import : 1,
ae4efe19 SP	20	option : 1,
ae4efe19 SP	21	push : 1;
72ff8943 DB	22	/* These go from remote name (as in "list") to private name */
	23	struct refspec *refspecs;
	24	int refspec_nr;
6eb996b5 DB	25	};
6eb996b5 DB	26
bf3c523c IL	27	static void sendline(struct helper_data helper, struct strbuf buffer)
	28	{
	29	if (debug)
	30	fprintf(stderr, "Debug: Remote helper: -> %s", buffer->buf);
	31	if (write_in_full(helper->helper->in, buffer->buf, buffer->len)
	32	!= buffer->len)
	33	die_errno("Full write to remote helper failed");
	34	}
	35
	36	static int recvline(struct helper_data helper, struct strbuf buffer)
	37	{
	38	strbuf_reset(buffer);
	39	if (debug)
	40	fprintf(stderr, "Debug: Remote helper: Waiting...\n");
	41	if (strbuf_getline(buffer, helper->out, '\n') == EOF) {
	42	if (debug)
	43	fprintf(stderr, "Debug: Remote helper quit.\n");
	44	exit(128);
	45	}
	46
	47	if (debug)
	48	fprintf(stderr, "Debug: Remote helper: <- %s\n", buffer->buf);
	49	return 0;
	50	}
	51
	52	static void xchgline(struct helper_data helper, struct strbuf buffer)
	53	{
	54	sendline(helper, buffer);
	55	recvline(helper, buffer);
	56	}
	57
	58	static void write_constant(int fd, const char *str)
	59	{
	60	if (debug)
	61	fprintf(stderr, "Debug: Remote helper: -> %s", str);
	62	if (write_in_full(fd, str, strlen(str)) != strlen(str))
	63	die_errno("Full write to remote helper failed");
	64	}
	65
6eb996b5 DB	66	static struct child_process get_helper(struct transport transport)
	67	{
	68	struct helper_data *data = transport->data;
	69	struct strbuf buf = STRBUF_INIT;
	70	struct child_process *helper;
72ff8943 DB	71	const char **refspecs = NULL;
	72	int refspec_nr = 0;
	73	int refspec_alloc = 0;
6eb996b5 DB	74
	75	if (data->helper)
	76	return data->helper;
	77
	78	helper = xcalloc(1, sizeof(*helper));
	79	helper->in = -1;
	80	helper->out = -1;
	81	helper->err = 0;
	82	helper->argv = xcalloc(4, sizeof(*helper->argv));
	83	strbuf_addf(&buf, "remote-%s", data->name);
	84	helper->argv[0] = strbuf_detach(&buf, NULL);
	85	helper->argv[1] = transport->remote->name;
	86	helper->argv[2] = transport->url;
	87	helper->git_cmd = 1;
	88	if (start_command(helper))
	89	die("Unable to run helper: git %s", helper->argv[0]);
	90	data->helper = helper;
	91
bf3c523c	92	write_constant(helper->in, "capabilities\n");
2d14d65c	93
292ce46b	94	data->out = xfdopen(helper->out, "r");
6eb996b5	95	while (1) {
28ed5b35 IL	96	const char *capname;
28ed5b35 IL	97	int mandatory = 0;
bf3c523c	98	recvline(data, &buf);
6eb996b5 DB	99
	100	if (!*buf.buf)
	101	break;
28ed5b35 IL	102
	103	if (buf.buf == '') {
	104	capname = buf.buf + 1;
	105	mandatory = 1;
	106	} else
	107	capname = buf.buf;
	108
bf3c523c	109	if (debug)
28ed5b35 IL	110	fprintf(stderr, "Debug: Got cap %s\n", capname);
28ed5b35 IL	111	if (!strcmp(capname, "fetch"))
6eb996b5	112	data->fetch = 1;
28ed5b35	113	else if (!strcmp(capname, "option"))
ef08ef9e	114	data->option = 1;
28ed5b35	115	else if (!strcmp(capname, "push"))
ae4efe19	116	data->push = 1;
28ed5b35	117	else if (!strcmp(capname, "import"))
e65e91ed	118	data->import = 1;
28ed5b35	119	else if (!data->refspecs && !prefixcmp(capname, "refspec ")) {
72ff8943 DB	120	ALLOC_GROW(refspecs,
	121	refspec_nr + 1,
	122	refspec_alloc);
	123	refspecs[refspec_nr++] = strdup(buf.buf + strlen("refspec "));
28ed5b35 IL	124	} else if (mandatory) {
	125	die("Unknown madatory capability %s. This remote "
	126	"helper probably needs newer version of Git.\n",
	127	capname);
72ff8943 DB	128	}
	129	}
	130	if (refspecs) {
	131	int i;
	132	data->refspec_nr = refspec_nr;
	133	data->refspecs = parse_fetch_refspec(refspec_nr, refspecs);
	134	for (i = 0; i < refspec_nr; i++) {
	135	free((char *)refspecs[i]);
	136	}
	137	free(refspecs);
6eb996b5	138	}
b962dbdc	139	strbuf_release(&buf);
bf3c523c IL	140	if (debug)
bf3c523c IL	141	fprintf(stderr, "Debug: Capabilities complete.\n");
6eb996b5 DB	142	return data->helper;
	143	}
	144
	145	static int disconnect_helper(struct transport *transport)
	146	{
	147	struct helper_data *data = transport->data;
bf3c523c IL	148	struct strbuf buf = STRBUF_INIT;
bf3c523c IL	149
6eb996b5	150	if (data->helper) {
bf3c523c IL	151	if (debug)
	152	fprintf(stderr, "Debug: Disconnecting.\n");
	153	strbuf_addf(&buf, "\n");
	154	sendline(data, &buf);
6eb996b5	155	close(data->helper->in);
292ce46b	156	fclose(data->out);
6eb996b5 DB	157	finish_command(data->helper);
	158	free((char *)data->helper->argv[0]);
	159	free(data->helper->argv);
	160	free(data->helper);
	161	data->helper = NULL;
	162	}
	163	return 0;
	164	}
	165
ef08ef9e SP	166	static const char *unsupported_options[] = {
	167	TRANS_OPT_UPLOADPACK,
	168	TRANS_OPT_RECEIVEPACK,
	169	TRANS_OPT_THIN,
	170	TRANS_OPT_KEEP
	171	};
	172	static const char *boolean_options[] = {
	173	TRANS_OPT_THIN,
	174	TRANS_OPT_KEEP,
	175	TRANS_OPT_FOLLOWTAGS
	176	};
	177
	178	static int set_helper_option(struct transport *transport,
	179	const char name, const char value)
	180	{
	181	struct helper_data *data = transport->data;
ef08ef9e SP	182	struct strbuf buf = STRBUF_INIT;
	183	int i, ret, is_bool = 0;
	184
bf3c523c IL	185	get_helper(transport);
bf3c523c IL	186
ef08ef9e SP	187	if (!data->option)
	188	return 1;
	189
	190	for (i = 0; i < ARRAY_SIZE(unsupported_options); i++) {
	191	if (!strcmp(name, unsupported_options[i]))
	192	return 1;
	193	}
	194
	195	for (i = 0; i < ARRAY_SIZE(boolean_options); i++) {
	196	if (!strcmp(name, boolean_options[i])) {
	197	is_bool = 1;
	198	break;
	199	}
	200	}
	201
	202	strbuf_addf(&buf, "option %s ", name);
	203	if (is_bool)
	204	strbuf_addstr(&buf, value ? "true" : "false");
	205	else
	206	quote_c_style(value, &buf, NULL, 0);
	207	strbuf_addch(&buf, '\n');
	208
bf3c523c	209	xchgline(data, &buf);
ef08ef9e SP	210
	211	if (!strcmp(buf.buf, "ok"))
	212	ret = 0;
	213	else if (!prefixcmp(buf.buf, "error")) {
	214	ret = -1;
	215	} else if (!strcmp(buf.buf, "unsupported"))
	216	ret = 1;
	217	else {
	218	warning("%s unexpectedly said: '%s'", data->name, buf.buf);
	219	ret = 1;
	220	}
	221	strbuf_release(&buf);
	222	return ret;
	223	}
	224
	225	static void standard_options(struct transport *t)
	226	{
	227	char buf[16];
	228	int n;
	229	int v = t->verbose;
	230	int no_progress = v < 0 \|\| (!t->progress && !isatty(1));
	231
	232	set_helper_option(t, "progress", !no_progress ? "true" : "false");
	233
	234	n = snprintf(buf, sizeof(buf), "%d", v + 1);
	235	if (n >= sizeof(buf))
	236	die("impossibly large verbosity value");
	237	set_helper_option(t, "verbosity", buf);
	238	}
	239
f2a37151 DB	240	static int release_helper(struct transport *transport)
f2a37151 DB	241	{
72ff8943 DB	242	struct helper_data *data = transport->data;
	243	free_refspec(data->refspec_nr, data->refspecs);
	244	data->refspecs = NULL;
f2a37151 DB	245	disconnect_helper(transport);
	246	free(transport->data);
	247	return 0;
	248	}
	249
6eb996b5	250	static int fetch_with_fetch(struct transport *transport,
37148311	251	int nr_heads, struct ref **to_fetch)
6eb996b5	252	{
292ce46b	253	struct helper_data *data = transport->data;
6eb996b5 DB	254	int i;
	255	struct strbuf buf = STRBUF_INIT;
	256
ef08ef9e SP	257	standard_options(transport);
ef08ef9e SP	258
6eb996b5	259	for (i = 0; i < nr_heads; i++) {
1088261f	260	const struct ref *posn = to_fetch[i];
6eb996b5 DB	261	if (posn->status & REF_STATUS_UPTODATE)
6eb996b5 DB	262	continue;
2d14d65c DB	263
	264	strbuf_addf(&buf, "fetch %s %s\n",
	265	sha1_to_hex(posn->old_sha1), posn->name);
292ce46b	266	}
2d14d65c	267
292ce46b	268	strbuf_addch(&buf, '\n');
bf3c523c	269	sendline(data, &buf);
292ce46b SP	270
292ce46b SP	271	while (1) {
bf3c523c	272	recvline(data, &buf);
292ce46b SP	273
	274	if (!prefixcmp(buf.buf, "lock ")) {
	275	const char *name = buf.buf + 5;
	276	if (transport->pack_lockfile)
	277	warning("%s also locked %s", data->name, name);
	278	else
	279	transport->pack_lockfile = xstrdup(name);
	280	}
	281	else if (!buf.len)
	282	break;
	283	else
	284	warning("%s unexpectedly said: '%s'", data->name, buf.buf);
6eb996b5	285	}
292ce46b	286	strbuf_release(&buf);
6eb996b5 DB	287	return 0;
	288	}
	289
e65e91ed DB	290	static int get_importer(struct transport transport, struct child_process fastimport)
	291	{
	292	struct child_process *helper = get_helper(transport);
	293	memset(fastimport, 0, sizeof(*fastimport));
	294	fastimport->in = helper->out;
	295	fastimport->argv = xcalloc(5, sizeof(*fastimport->argv));
	296	fastimport->argv[0] = "fast-import";
	297	fastimport->argv[1] = "--quiet";
	298
	299	fastimport->git_cmd = 1;
	300	return start_command(fastimport);
	301	}
	302
	303	static int fetch_with_import(struct transport *transport,
	304	int nr_heads, struct ref **to_fetch)
	305	{
	306	struct child_process fastimport;
72ff8943	307	struct helper_data *data = transport->data;
e65e91ed DB	308	int i;
	309	struct ref *posn;
	310	struct strbuf buf = STRBUF_INIT;
	311
bf3c523c IL	312	get_helper(transport);
bf3c523c IL	313
e65e91ed DB	314	if (get_importer(transport, &fastimport))
	315	die("Couldn't run fast-import");
	316
	317	for (i = 0; i < nr_heads; i++) {
	318	posn = to_fetch[i];
	319	if (posn->status & REF_STATUS_UPTODATE)
	320	continue;
	321
	322	strbuf_addf(&buf, "import %s\n", posn->name);
bf3c523c	323	sendline(data, &buf);
e65e91ed DB	324	strbuf_reset(&buf);
	325	}
	326	disconnect_helper(transport);
	327	finish_command(&fastimport);
b962dbdc SR	328	free(fastimport.argv);
b962dbdc SR	329	fastimport.argv = NULL;
e65e91ed DB	330
e65e91ed DB	331	for (i = 0; i < nr_heads; i++) {
72ff8943	332	char *private;
e65e91ed DB	333	posn = to_fetch[i];
	334	if (posn->status & REF_STATUS_UPTODATE)
	335	continue;
72ff8943 DB	336	if (data->refspecs)
	337	private = apply_refspecs(data->refspecs, data->refspec_nr, posn->name);
	338	else
	339	private = strdup(posn->name);
	340	read_ref(private, posn->old_sha1);
	341	free(private);
e65e91ed	342	}
b962dbdc	343	strbuf_release(&buf);
e65e91ed DB	344	return 0;
	345	}
	346
6eb996b5	347	static int fetch(struct transport *transport,
37148311	348	int nr_heads, struct ref **to_fetch)
6eb996b5 DB	349	{
	350	struct helper_data *data = transport->data;
	351	int i, count;
	352
	353	count = 0;
	354	for (i = 0; i < nr_heads; i++)
	355	if (!(to_fetch[i]->status & REF_STATUS_UPTODATE))
	356	count++;
	357
	358	if (!count)
	359	return 0;
	360
	361	if (data->fetch)
	362	return fetch_with_fetch(transport, nr_heads, to_fetch);
	363
e65e91ed DB	364	if (data->import)
	365	return fetch_with_import(transport, nr_heads, to_fetch);
	366
6eb996b5 DB	367	return -1;
	368	}
	369
ae4efe19 SP	370	static int push_refs(struct transport *transport,
	371	struct ref *remote_refs, int flags)
	372	{
	373	int force_all = flags & TRANSPORT_PUSH_FORCE;
	374	int mirror = flags & TRANSPORT_PUSH_MIRROR;
	375	struct helper_data *data = transport->data;
	376	struct strbuf buf = STRBUF_INIT;
	377	struct child_process *helper;
	378	struct ref *ref;
	379
	380	if (!remote_refs)
	381	return 0;
	382
	383	helper = get_helper(transport);
	384	if (!data->push)
	385	return 1;
	386
	387	for (ref = remote_refs; ref; ref = ref->next) {
	388	if (ref->peer_ref)
	389	hashcpy(ref->new_sha1, ref->peer_ref->new_sha1);
	390	else if (!mirror)
	391	continue;
	392
	393	ref->deletion = is_null_sha1(ref->new_sha1);
	394	if (!ref->deletion &&
	395	!hashcmp(ref->old_sha1, ref->new_sha1)) {
	396	ref->status = REF_STATUS_UPTODATE;
	397	continue;
	398	}
	399
	400	if (force_all)
	401	ref->force = 1;
	402
	403	strbuf_addstr(&buf, "push ");
	404	if (!ref->deletion) {
	405	if (ref->force)
	406	strbuf_addch(&buf, '+');
	407	if (ref->peer_ref)
	408	strbuf_addstr(&buf, ref->peer_ref->name);
	409	else
	410	strbuf_addstr(&buf, sha1_to_hex(ref->new_sha1));
	411	}
	412	strbuf_addch(&buf, ':');
	413	strbuf_addstr(&buf, ref->name);
	414	strbuf_addch(&buf, '\n');
	415	}
d8f67d20 CB	416	if (buf.len == 0)
d8f67d20 CB	417	return 0;
ae4efe19 SP	418
	419	transport->verbose = flags & TRANSPORT_PUSH_VERBOSE ? 1 : 0;
	420	standard_options(transport);
	421
	422	if (flags & TRANSPORT_PUSH_DRY_RUN) {
	423	if (set_helper_option(transport, "dry-run", "true") != 0)
	424	die("helper %s does not support dry-run", data->name);
	425	}
	426
	427	strbuf_addch(&buf, '\n');
bf3c523c	428	sendline(data, &buf);
ae4efe19 SP	429
	430	ref = remote_refs;
	431	while (1) {
	432	char refname, msg;
	433	int status;
	434
bf3c523c	435	recvline(data, &buf);
ae4efe19 SP	436	if (!buf.len)
	437	break;
	438
	439	if (!prefixcmp(buf.buf, "ok ")) {
	440	status = REF_STATUS_OK;
	441	refname = buf.buf + 3;
	442	} else if (!prefixcmp(buf.buf, "error ")) {
	443	status = REF_STATUS_REMOTE_REJECT;
	444	refname = buf.buf + 6;
	445	} else
	446	die("expected ok/error, helper said '%s'\n", buf.buf);
	447
	448	msg = strchr(refname, ' ');
	449	if (msg) {
	450	struct strbuf msg_buf = STRBUF_INIT;
	451	const char *end;
	452
	453	*msg++ = '\0';
	454	if (!unquote_c_style(&msg_buf, msg, &end))
	455	msg = strbuf_detach(&msg_buf, NULL);
	456	else
	457	msg = xstrdup(msg);
	458	strbuf_release(&msg_buf);
	459
	460	if (!strcmp(msg, "no match")) {
	461	status = REF_STATUS_NONE;
	462	free(msg);
	463	msg = NULL;
	464	}
	465	else if (!strcmp(msg, "up to date")) {
	466	status = REF_STATUS_UPTODATE;
	467	free(msg);
	468	msg = NULL;
	469	}
	470	else if (!strcmp(msg, "non-fast forward")) {
	471	status = REF_STATUS_REJECT_NONFASTFORWARD;
	472	free(msg);
	473	msg = NULL;
	474	}
	475	}
	476
	477	if (ref)
	478	ref = find_ref_by_name(ref, refname);
	479	if (!ref)
	480	ref = find_ref_by_name(remote_refs, refname);
	481	if (!ref) {
	482	warning("helper reported unexpected status of %s", refname);
	483	continue;
	484	}
	485
	486	ref->status = status;
	487	ref->remote_status = msg;
	488	}
	489	strbuf_release(&buf);
	490	return 0;
	491	}
	492
f8ec9167 DB	493	static int has_attribute(const char attrs, const char attr) {
	494	int len;
	495	if (!attrs)
	496	return 0;
	497
	498	len = strlen(attr);
	499	for (;;) {
	500	const char *space = strchrnul(attrs, ' ');
	501	if (len == space - attrs && !strncmp(attrs, attr, len))
	502	return 1;
	503	if (!*space)
	504	return 0;
	505	attrs = space + 1;
	506	}
	507	}
	508
6eb996b5 DB	509	static struct ref get_refs_list(struct transport transport, int for_push)
6eb996b5 DB	510	{
292ce46b	511	struct helper_data *data = transport->data;
6eb996b5 DB	512	struct child_process *helper;
	513	struct ref *ret = NULL;
	514	struct ref **tail = &ret;
	515	struct ref *posn;
	516	struct strbuf buf = STRBUF_INIT;
6eb996b5 DB	517
6eb996b5 DB	518	helper = get_helper(transport);
2d14d65c	519
ae4efe19 SP	520	if (data->push && for_push)
	521	write_str_in_full(helper->in, "list for-push\n");
	522	else
	523	write_str_in_full(helper->in, "list\n");
6eb996b5	524
6eb996b5 DB	525	while (1) {
6eb996b5 DB	526	char eov, eon;
bf3c523c	527	recvline(data, &buf);
6eb996b5 DB	528
	529	if (!*buf.buf)
	530	break;
	531
	532	eov = strchr(buf.buf, ' ');
	533	if (!eov)
	534	die("Malformed response in ref list: %s", buf.buf);
	535	eon = strchr(eov + 1, ' ');
	536	*eov = '\0';
	537	if (eon)
	538	*eon = '\0';
	539	*tail = alloc_ref(eov + 1);
	540	if (buf.buf[0] == '@')
	541	(*tail)->symref = xstrdup(buf.buf + 1);
	542	else if (buf.buf[0] != '?')
	543	get_sha1_hex(buf.buf, (*tail)->old_sha1);
f8ec9167 DB	544	if (eon) {
	545	if (has_attribute(eon + 1, "unchanged")) {
	546	(*tail)->status \|= REF_STATUS_UPTODATE;
	547	read_ref((tail)->name, (tail)->old_sha1);
	548	}
	549	}
6eb996b5 DB	550	tail = &((*tail)->next);
6eb996b5 DB	551	}
bf3c523c IL	552	if (debug)
bf3c523c IL	553	fprintf(stderr, "Debug: Read ref listing.\n");
6eb996b5 DB	554	strbuf_release(&buf);
	555
	556	for (posn = ret; posn; posn = posn->next)
	557	resolve_remote_symref(posn, ret);
	558
	559	return ret;
	560	}
	561
c9e388bb	562	int transport_helper_init(struct transport transport, const char name)
6eb996b5 DB	563	{
6eb996b5 DB	564	struct helper_data data = xcalloc(sizeof(data), 1);
c9e388bb	565	data->name = name;
6eb996b5	566
bf3c523c IL	567	if (getenv("GIT_TRANSPORT_HELPER_DEBUG"))
	568	debug = 1;
	569
6eb996b5	570	transport->data = data;
ef08ef9e	571	transport->set_option = set_helper_option;
6eb996b5 DB	572	transport->get_refs_list = get_refs_list;
6eb996b5 DB	573	transport->fetch = fetch;
ae4efe19	574	transport->push_refs = push_refs;
f2a37151	575	transport->disconnect = release_helper;
6eb996b5 DB	576	return 0;
6eb996b5 DB	577	}