[thirdparty/git.git] / t / helper / test-ref-store.c

#include "test-tool.h"
#include "cache.h"
#include "refs.h"
#include "worktree.h"
#include "object-store.h"
#include "repository.h"

struct flag_definition {
	const char *name;
	uint64_t mask;
};

#define FLAG_DEF(x)     \
	{               \
#x, (x) \
	}

static unsigned int parse_flags(const char *str, struct flag_definition *defs)
{
	struct string_list masks = STRING_LIST_INIT_DUP;
	int i = 0;
	unsigned int result = 0;

	if (!strcmp(str, "0"))
		return 0;

	string_list_split(&masks, str, ',', 64);
	for (; i < masks.nr; i++) {
		const char *name = masks.items[i].string;
		struct flag_definition *def = defs;
		int found = 0;
		while (def->name) {
			if (!strcmp(def->name, name)) {
				result |= def->mask;
				found = 1;
				break;
			}
			def++;
		}
		if (!found)
			die("unknown flag \"%s\"", name);
	}

	string_list_clear(&masks, 0);
	return result;
}

static struct flag_definition empty_flags[] = { { NULL, 0 } };

static const char *notnull(const char *arg, const char *name)
{
	if (!arg)
		die("%s required", name);
	return arg;
}

static unsigned int arg_flags(const char *arg, const char *name,
			      struct flag_definition *defs)
{
	return parse_flags(notnull(arg, name), defs);
}

static const char **get_store(const char **argv, struct ref_store **refs)
{
	const char *gitdir;

	if (!argv[0]) {
		die("ref store required");
	} else if (!strcmp(argv[0], "main")) {
		*refs = get_main_ref_store(the_repository);
	} else if (skip_prefix(argv[0], "submodule:", &gitdir)) {
		struct strbuf sb = STRBUF_INIT;
		int ret;

		ret = strbuf_git_path_submodule(&sb, gitdir, "objects/");
		if (ret)
			die("strbuf_git_path_submodule failed: %d", ret);
		add_to_alternates_memory(sb.buf);
		strbuf_release(&sb);

		*refs = get_submodule_ref_store(gitdir);
	} else if (skip_prefix(argv[0], "worktree:", &gitdir)) {
		struct worktree **p, **worktrees = get_worktrees();

		for (p = worktrees; *p; p++) {
			struct worktree *wt = *p;

			if (!wt->id) {
				/* special case for main worktree */
				if (!strcmp(gitdir, "main"))
					break;
			} else if (!strcmp(gitdir, wt->id))
				break;
		}
		if (!*p)
			die("no such worktree: %s", gitdir);

		*refs = get_worktree_ref_store(*p);
	} else
		die("unknown backend %s", argv[0]);

	if (!*refs)
		die("no ref store");

	/* consume store-specific optional arguments if needed */

	return argv + 1;
}

static struct flag_definition pack_flags[] = { FLAG_DEF(PACK_REFS_PRUNE),
					       FLAG_DEF(PACK_REFS_ALL),
					       { NULL, 0 } };

static int cmd_pack_refs(struct ref_store *refs, const char **argv)
{
	unsigned int flags = arg_flags(*argv++, "flags", pack_flags);

	return refs_pack_refs(refs, flags);
}

static int cmd_create_symref(struct ref_store *refs, const char **argv)
{
	const char *refname = notnull(*argv++, "refname");
	const char *target = notnull(*argv++, "target");
	const char *logmsg = *argv++;

	return refs_create_symref(refs, refname, target, logmsg);
}

static struct flag_definition transaction_flags[] = {
	FLAG_DEF(REF_NO_DEREF),
	FLAG_DEF(REF_FORCE_CREATE_REFLOG),
	FLAG_DEF(REF_SKIP_OID_VERIFICATION),
	FLAG_DEF(REF_SKIP_REFNAME_VERIFICATION),
	{ NULL, 0 }
};

static int cmd_delete_refs(struct ref_store *refs, const char **argv)
{
	unsigned int flags = arg_flags(*argv++, "flags", transaction_flags);
	const char *msg = *argv++;
	struct string_list refnames = STRING_LIST_INIT_NODUP;
	int result;

	while (*argv)
		string_list_append(&refnames, *argv++);

	result = refs_delete_refs(refs, msg, &refnames, flags);
	string_list_clear(&refnames, 0);
	return result;
}

static int cmd_rename_ref(struct ref_store *refs, const char **argv)
{
	const char *oldref = notnull(*argv++, "oldref");
	const char *newref = notnull(*argv++, "newref");
	const char *logmsg = *argv++;

	return refs_rename_ref(refs, oldref, newref, logmsg);
}

static int each_ref(const char *refname, const struct object_id *oid,
		    int flags, void *cb_data)
{
	printf("%s %s 0x%x\n", oid_to_hex(oid), refname, flags);
	return 0;
}

static int cmd_for_each_ref(struct ref_store *refs, const char **argv)
{
	const char *prefix = notnull(*argv++, "prefix");

	return refs_for_each_ref_in(refs, prefix, each_ref, NULL);
}

static int cmd_resolve_ref(struct ref_store *refs, const char **argv)
{
	struct object_id oid = *null_oid();
	const char *refname = notnull(*argv++, "refname");
	int resolve_flags = arg_flags(*argv++, "resolve-flags", empty_flags);
	int flags;
	const char *ref;
	int ignore_errno;

	ref = refs_resolve_ref_unsafe(refs, refname, resolve_flags,
				      &oid, &flags, &ignore_errno);
	printf("%s %s 0x%x\n", oid_to_hex(&oid), ref ? ref : "(null)", flags);
	return ref ? 0 : 1;
}

static int cmd_verify_ref(struct ref_store *refs, const char **argv)
{
	const char *refname = notnull(*argv++, "refname");
	struct strbuf err = STRBUF_INIT;
	int ret;

	ret = refs_verify_refname_available(refs, refname, NULL, NULL, &err);
	if (err.len)
		puts(err.buf);
	return ret;
}

static int cmd_for_each_reflog(struct ref_store *refs, const char **argv)
{
	return refs_for_each_reflog(refs, each_ref, NULL);
}

static int each_reflog(struct object_id *old_oid, struct object_id *new_oid,
		       const char *committer, timestamp_t timestamp,
		       int tz, const char *msg, void *cb_data)
{
	printf("%s %s %s %" PRItime " %+05d%s%s", oid_to_hex(old_oid),
	       oid_to_hex(new_oid), committer, timestamp, tz,
	       *msg == '\n' ? "" : "\t", msg);
	return 0;
}

static int cmd_for_each_reflog_ent(struct ref_store *refs, const char **argv)
{
	const char *refname = notnull(*argv++, "refname");

	return refs_for_each_reflog_ent(refs, refname, each_reflog, refs);
}

static int cmd_for_each_reflog_ent_reverse(struct ref_store *refs, const char **argv)
{
	const char *refname = notnull(*argv++, "refname");

	return refs_for_each_reflog_ent_reverse(refs, refname, each_reflog, refs);
}

static int cmd_reflog_exists(struct ref_store *refs, const char **argv)
{
	const char *refname = notnull(*argv++, "refname");

	return !refs_reflog_exists(refs, refname);
}

static int cmd_create_reflog(struct ref_store *refs, const char **argv)
{
	const char *refname = notnull(*argv++, "refname");
	struct strbuf err = STRBUF_INIT;
	int ret;

	ret = refs_create_reflog(refs, refname, &err);
	if (err.len)
		puts(err.buf);
	return ret;
}

static int cmd_delete_reflog(struct ref_store *refs, const char **argv)
{
	const char *refname = notnull(*argv++, "refname");

	return refs_delete_reflog(refs, refname);
}

static int cmd_reflog_expire(struct ref_store *refs, const char **argv)
{
	die("not supported yet");
}

static int cmd_delete_ref(struct ref_store *refs, const char **argv)
{
	const char *msg = notnull(*argv++, "msg");
	const char *refname = notnull(*argv++, "refname");
	const char *sha1_buf = notnull(*argv++, "old-sha1");
	unsigned int flags = arg_flags(*argv++, "flags", transaction_flags);
	struct object_id old_oid;

	if (get_oid_hex(sha1_buf, &old_oid))
		die("not sha-1");

	return refs_delete_ref(refs, msg, refname, &old_oid, flags);
}

static int cmd_update_ref(struct ref_store *refs, const char **argv)
{
	const char *msg = notnull(*argv++, "msg");
	const char *refname = notnull(*argv++, "refname");
	const char *new_sha1_buf = notnull(*argv++, "new-sha1");
	const char *old_sha1_buf = notnull(*argv++, "old-sha1");
	unsigned int flags = arg_flags(*argv++, "flags", transaction_flags);
	struct object_id old_oid;
	struct object_id new_oid;

	if (get_oid_hex(old_sha1_buf, &old_oid) ||
	    get_oid_hex(new_sha1_buf, &new_oid))
		die("not sha-1");

	return refs_update_ref(refs, msg, refname,
			       &new_oid, &old_oid,
			       flags, UPDATE_REFS_DIE_ON_ERR);
}

struct command {
	const char *name;
	int (*func)(struct ref_store *refs, const char **argv);
};

static struct command commands[] = {
	{ "pack-refs", cmd_pack_refs },
	{ "create-symref", cmd_create_symref },
	{ "delete-refs", cmd_delete_refs },
	{ "rename-ref", cmd_rename_ref },
	{ "for-each-ref", cmd_for_each_ref },
	{ "resolve-ref", cmd_resolve_ref },
	{ "verify-ref", cmd_verify_ref },
	{ "for-each-reflog", cmd_for_each_reflog },
	{ "for-each-reflog-ent", cmd_for_each_reflog_ent },
	{ "for-each-reflog-ent-reverse", cmd_for_each_reflog_ent_reverse },
	{ "reflog-exists", cmd_reflog_exists },
	{ "create-reflog", cmd_create_reflog },
	{ "delete-reflog", cmd_delete_reflog },
	{ "reflog-expire", cmd_reflog_expire },
	/*
	 * backend transaction functions can't be tested separately
	 */
	{ "delete-ref", cmd_delete_ref },
	{ "update-ref", cmd_update_ref },
	{ NULL, NULL }
};

int cmd__ref_store(int argc, const char **argv)
{
	struct ref_store *refs;
	const char *func;
	struct command *cmd;

	setup_git_directory();

	argv = get_store(argv + 1, &refs);

	func = *argv++;
	if (!func)
		die("ref function required");
	for (cmd = commands; cmd->name; cmd++) {
		if (!strcmp(func, cmd->name))
			return cmd->func(refs, argv);
	}
	die("unknown function %s", func);
	return 0;
}
Commit	Line	Data
65370d81	1	#include "test-tool.h"
80f2a609 NTND	2	#include "cache.h"
80f2a609 NTND	3	#include "refs.h"
fa099d23	4	#include "worktree.h"
0d4a1321	5	#include "object-store.h"
23a3f0cb	6	#include "repository.h"
80f2a609	7
cd2d40fb HWN	8	struct flag_definition {
	9	const char *name;
	10	uint64_t mask;
	11	};
	12
	13	#define FLAG_DEF(x) \
	14	{ \
	15	#x, (x) \
	16	}
	17
	18	static unsigned int parse_flags(const char str, struct flag_definition defs)
	19	{
	20	struct string_list masks = STRING_LIST_INIT_DUP;
	21	int i = 0;
	22	unsigned int result = 0;
	23
	24	if (!strcmp(str, "0"))
	25	return 0;
	26
	27	string_list_split(&masks, str, ',', 64);
	28	for (; i < masks.nr; i++) {
	29	const char *name = masks.items[i].string;
	30	struct flag_definition *def = defs;
	31	int found = 0;
	32	while (def->name) {
	33	if (!strcmp(def->name, name)) {
	34	result \|= def->mask;
	35	found = 1;
	36	break;
	37	}
	38	def++;
	39	}
	40	if (!found)
	41	die("unknown flag \"%s\"", name);
	42	}
	43
	44	string_list_clear(&masks, 0);
	45	return result;
	46	}
	47
	48	static struct flag_definition empty_flags[] = { { NULL, 0 } };
	49
80f2a609 NTND	50	static const char notnull(const char arg, const char *name)
	51	{
	52	if (!arg)
	53	die("%s required", name);
	54	return arg;
	55	}
	56
cd2d40fb HWN	57	static unsigned int arg_flags(const char arg, const char name,
cd2d40fb HWN	58	struct flag_definition *defs)
80f2a609	59	{
cd2d40fb	60	return parse_flags(notnull(arg, name), defs);
80f2a609 NTND	61	}
	62
	63	static const char get_store(const char argv, struct ref_store **refs)
	64	{
	65	const char *gitdir;
	66
	67	if (!argv[0]) {
	68	die("ref store required");
	69	} else if (!strcmp(argv[0], "main")) {
23a3f0cb	70	*refs = get_main_ref_store(the_repository);
80f2a609 NTND	71	} else if (skip_prefix(argv[0], "submodule:", &gitdir)) {
	72	struct strbuf sb = STRBUF_INIT;
	73	int ret;
	74
	75	ret = strbuf_git_path_submodule(&sb, gitdir, "objects/");
	76	if (ret)
	77	die("strbuf_git_path_submodule failed: %d", ret);
	78	add_to_alternates_memory(sb.buf);
	79	strbuf_release(&sb);
	80
	81	*refs = get_submodule_ref_store(gitdir);
fa099d23	82	} else if (skip_prefix(argv[0], "worktree:", &gitdir)) {
03f2465b	83	struct worktree p, worktrees = get_worktrees();
fa099d23 NTND	84
	85	for (p = worktrees; *p; p++) {
	86	struct worktree wt = p;
	87
	88	if (!wt->id) {
	89	/* special case for main worktree */
	90	if (!strcmp(gitdir, "main"))
	91	break;
	92	} else if (!strcmp(gitdir, wt->id))
	93	break;
	94	}
	95	if (!*p)
	96	die("no such worktree: %s", gitdir);
	97
	98	refs = get_worktree_ref_store(p);
80f2a609 NTND	99	} else
	100	die("unknown backend %s", argv[0]);
	101
	102	if (!*refs)
	103	die("no ref store");
	104
	105	/* consume store-specific optional arguments if needed */
	106
	107	return argv + 1;
	108	}
	109
cd2d40fb HWN	110	static struct flag_definition pack_flags[] = { FLAG_DEF(PACK_REFS_PRUNE),
	111	FLAG_DEF(PACK_REFS_ALL),
	112	{ NULL, 0 } };
80f2a609 NTND	113
	114	static int cmd_pack_refs(struct ref_store refs, const char *argv)
	115	{
cd2d40fb	116	unsigned int flags = arg_flags(*argv++, "flags", pack_flags);
80f2a609 NTND	117
	118	return refs_pack_refs(refs, flags);
	119	}
	120
80f2a609 NTND	121	static int cmd_create_symref(struct ref_store refs, const char *argv)
	122	{
	123	const char refname = notnull(argv++, "refname");
	124	const char target = notnull(argv++, "target");
	125	const char logmsg = argv++;
	126
	127	return refs_create_symref(refs, refname, target, logmsg);
	128	}
	129
cd2d40fb HWN	130	static struct flag_definition transaction_flags[] = {
	131	FLAG_DEF(REF_NO_DEREF),
	132	FLAG_DEF(REF_FORCE_CREATE_REFLOG),
e9706a18	133	FLAG_DEF(REF_SKIP_OID_VERIFICATION),
3c966c7b	134	FLAG_DEF(REF_SKIP_REFNAME_VERIFICATION),
cd2d40fb HWN	135	{ NULL, 0 }
	136	};
	137
80f2a609 NTND	138	static int cmd_delete_refs(struct ref_store refs, const char *argv)
80f2a609 NTND	139	{
cd2d40fb	140	unsigned int flags = arg_flags(*argv++, "flags", transaction_flags);
64da4199	141	const char msg = argv++;
80f2a609	142	struct string_list refnames = STRING_LIST_INIT_NODUP;
df25a19d	143	int result;
80f2a609 NTND	144
	145	while (*argv)
	146	string_list_append(&refnames, *argv++);
	147
df25a19d HWN	148	result = refs_delete_refs(refs, msg, &refnames, flags);
	149	string_list_clear(&refnames, 0);
	150	return result;
80f2a609 NTND	151	}
	152
	153	static int cmd_rename_ref(struct ref_store refs, const char *argv)
	154	{
	155	const char oldref = notnull(argv++, "oldref");
	156	const char newref = notnull(argv++, "newref");
	157	const char logmsg = argv++;
	158
	159	return refs_rename_ref(refs, oldref, newref, logmsg);
	160	}
	161
	162	static int each_ref(const char refname, const struct object_id oid,
	163	int flags, void *cb_data)
	164	{
	165	printf("%s %s 0x%x\n", oid_to_hex(oid), refname, flags);
	166	return 0;
	167	}
	168
	169	static int cmd_for_each_ref(struct ref_store refs, const char *argv)
	170	{
	171	const char prefix = notnull(argv++, "prefix");
	172
	173	return refs_for_each_ref_in(refs, prefix, each_ref, NULL);
	174	}
	175
	176	static int cmd_resolve_ref(struct ref_store refs, const char *argv)
	177	{
0221eb86	178	struct object_id oid = *null_oid();
80f2a609	179	const char refname = notnull(argv++, "refname");
cd2d40fb	180	int resolve_flags = arg_flags(*argv++, "resolve-flags", empty_flags);
80f2a609 NTND	181	int flags;
80f2a609 NTND	182	const char *ref;
6846f724	183	int ignore_errno;
80f2a609	184
f1da24ca	185	ref = refs_resolve_ref_unsafe(refs, refname, resolve_flags,
6846f724	186	&oid, &flags, &ignore_errno);
e7e456f5	187	printf("%s %s 0x%x\n", oid_to_hex(&oid), ref ? ref : "(null)", flags);
80f2a609 NTND	188	return ref ? 0 : 1;
	189	}
	190
	191	static int cmd_verify_ref(struct ref_store refs, const char *argv)
	192	{
	193	const char refname = notnull(argv++, "refname");
	194	struct strbuf err = STRBUF_INIT;
	195	int ret;
	196
	197	ret = refs_verify_refname_available(refs, refname, NULL, NULL, &err);
	198	if (err.len)
	199	puts(err.buf);
	200	return ret;
	201	}
	202
	203	static int cmd_for_each_reflog(struct ref_store refs, const char *argv)
	204	{
	205	return refs_for_each_reflog(refs, each_ref, NULL);
	206	}
	207
	208	static int each_reflog(struct object_id old_oid, struct object_id new_oid,
dddbad72	209	const char *committer, timestamp_t timestamp,
80f2a609 NTND	210	int tz, const char msg, void cb_data)
80f2a609 NTND	211	{
3474b602 HWN	212	printf("%s %s %s %" PRItime " %+05d%s%s", oid_to_hex(old_oid),
	213	oid_to_hex(new_oid), committer, timestamp, tz,
	214	*msg == '\n' ? "" : "\t", msg);
80f2a609 NTND	215	return 0;
	216	}
	217
	218	static int cmd_for_each_reflog_ent(struct ref_store refs, const char *argv)
	219	{
	220	const char refname = notnull(argv++, "refname");
	221
	222	return refs_for_each_reflog_ent(refs, refname, each_reflog, refs);
	223	}
	224
	225	static int cmd_for_each_reflog_ent_reverse(struct ref_store refs, const char *argv)
	226	{
	227	const char refname = notnull(argv++, "refname");
	228
	229	return refs_for_each_reflog_ent_reverse(refs, refname, each_reflog, refs);
	230	}
	231
	232	static int cmd_reflog_exists(struct ref_store refs, const char *argv)
	233	{
	234	const char refname = notnull(argv++, "refname");
	235
	236	return !refs_reflog_exists(refs, refname);
	237	}
	238
	239	static int cmd_create_reflog(struct ref_store refs, const char *argv)
	240	{
	241	const char refname = notnull(argv++, "refname");
80f2a609 NTND	242	struct strbuf err = STRBUF_INIT;
	243	int ret;
	244
7b089120	245	ret = refs_create_reflog(refs, refname, &err);
80f2a609 NTND	246	if (err.len)
	247	puts(err.buf);
	248	return ret;
	249	}
	250
	251	static int cmd_delete_reflog(struct ref_store refs, const char *argv)
	252	{
	253	const char refname = notnull(argv++, "refname");
	254
	255	return refs_delete_reflog(refs, refname);
	256	}
	257
	258	static int cmd_reflog_expire(struct ref_store refs, const char *argv)
	259	{
	260	die("not supported yet");
	261	}
	262
	263	static int cmd_delete_ref(struct ref_store refs, const char *argv)
	264	{
	265	const char msg = notnull(argv++, "msg");
	266	const char refname = notnull(argv++, "refname");
	267	const char sha1_buf = notnull(argv++, "old-sha1");
cd2d40fb	268	unsigned int flags = arg_flags(*argv++, "flags", transaction_flags);
2616a5e5	269	struct object_id old_oid;
80f2a609	270
2616a5e5	271	if (get_oid_hex(sha1_buf, &old_oid))
80f2a609 NTND	272	die("not sha-1");
80f2a609 NTND	273
2616a5e5	274	return refs_delete_ref(refs, msg, refname, &old_oid, flags);
80f2a609 NTND	275	}
	276
	277	static int cmd_update_ref(struct ref_store refs, const char *argv)
	278	{
	279	const char msg = notnull(argv++, "msg");
	280	const char refname = notnull(argv++, "refname");
3c27e2e0	281	const char new_sha1_buf = notnull(argv++, "new-sha1");
80f2a609	282	const char old_sha1_buf = notnull(argv++, "old-sha1");
cd2d40fb	283	unsigned int flags = arg_flags(*argv++, "flags", transaction_flags);
ae077771	284	struct object_id old_oid;
ae077771	285	struct object_id new_oid;
80f2a609	286
ae077771	287	if (get_oid_hex(old_sha1_buf, &old_oid) \|\|
ae077771	288	get_oid_hex(new_sha1_buf, &new_oid))
80f2a609 NTND	289	die("not sha-1");
	290
	291	return refs_update_ref(refs, msg, refname,
ae077771	292	&new_oid, &old_oid,
80f2a609 NTND	293	flags, UPDATE_REFS_DIE_ON_ERR);
	294	}
	295
	296	struct command {
	297	const char *name;
	298	int (func)(struct ref_store refs, const char **argv);
	299	};
	300
	301	static struct command commands[] = {
	302	{ "pack-refs", cmd_pack_refs },
80f2a609 NTND	303	{ "create-symref", cmd_create_symref },
	304	{ "delete-refs", cmd_delete_refs },
	305	{ "rename-ref", cmd_rename_ref },
	306	{ "for-each-ref", cmd_for_each_ref },
	307	{ "resolve-ref", cmd_resolve_ref },
	308	{ "verify-ref", cmd_verify_ref },
	309	{ "for-each-reflog", cmd_for_each_reflog },
	310	{ "for-each-reflog-ent", cmd_for_each_reflog_ent },
	311	{ "for-each-reflog-ent-reverse", cmd_for_each_reflog_ent_reverse },
	312	{ "reflog-exists", cmd_reflog_exists },
	313	{ "create-reflog", cmd_create_reflog },
	314	{ "delete-reflog", cmd_delete_reflog },
	315	{ "reflog-expire", cmd_reflog_expire },
	316	/*
	317	* backend transaction functions can't be tested separately
	318	*/
	319	{ "delete-ref", cmd_delete_ref },
	320	{ "update-ref", cmd_update_ref },
	321	{ NULL, NULL }
	322	};
	323
65370d81	324	int cmd__ref_store(int argc, const char **argv)
80f2a609 NTND	325	{
	326	struct ref_store *refs;
	327	const char *func;
	328	struct command *cmd;
	329
	330	setup_git_directory();
	331
	332	argv = get_store(argv + 1, &refs);
	333
	334	func = *argv++;
	335	if (!func)
	336	die("ref function required");
	337	for (cmd = commands; cmd->name; cmd++) {
	338	if (!strcmp(func, cmd->name))
	339	return cmd->func(refs, argv);
	340	}
	341	die("unknown function %s", func);
	342	return 0;
	343	}