cli_test.v

1module tests23import os4import time56const root = @VMODROOT7const binary = os.join_path(root, 'build', 'koh3')89struct Result {10mut:11	code int12	out  string13	err  string14}1516fn testsuite_begin() {17	os.mkdir_all(os.join_path(root, 'build')) or { panic(err) }18	build := os.execute('v -o ${q(binary)} ${q(os.join_path(root, 'src', 'koh3.v'))}')19	if build.exit_code != 0 {20		panic('could not build koh3: ${build.output}')21	}22}2324fn q(s string) string {25	return "'${s.replace("'", "'\\''")}'"26}2728fn temp_repo(name string) string {29	dir := os.join_path(os.temp_dir(), 'koh3-cli-${name}-${time.now().unix_nano()}')30	os.mkdir_all(dir) or { panic(err) }31	return dir32}3334fn run(repo string, args ...string) Result {35	home := temp_repo('home')36	defer { os.rmdir_all(home) or {} }37	return run_home(repo, home, ...args)38}3940fn run_home(repo string, home string, args ...string) Result {41	stamp := '${os.getpid()}-${time.now().unix_nano()}'42	base := os.join_path(os.temp_dir(), 'koh3-cli-${stamp}')43	out_path := '${base}.out'44	err_path := '${base}.err'45	code_path := '${base}.code'46	mut command := 'HOME=${q(home)} ${q(binary)}'47	for arg in args {48		command += ' ${q(arg)}'49	}50	shell := 'cd ${q(repo)} && ${command} </dev/null >${q(out_path)} 2>${q(err_path)}; printf "%s" $? >${q(code_path)}'51	result := os.execute(shell)52	if result.exit_code != 0 {53		panic('could not run test command: ${result.output}')54	}55	code := os.read_file(code_path) or { panic(err) }56	out := os.read_file(out_path) or { '' }57	err := os.read_file(err_path) or { '' }58	os.rm(out_path) or {}59	os.rm(err_path) or {}60	os.rm(code_path) or {}61	return Result{62		code: code.int()63		out:  out64		err:  err65	}66}6768fn init_repo(repo string) {69	r := run(repo, 'init')70	assert r.code == 071	assert os.exists(os.join_path(repo, '.koh'))72	assert os.exists(os.join_path(repo, '.kohignore'))73}7475fn write(repo string, path string, text string) {76	full := os.join_path(repo, path)77	os.mkdir_all(os.dir(full)) or { panic(err) }78	os.write_file(full, text) or { panic(err) }79}8081fn read_json_has(text string, key string) {82	if !text.contains(key) {83		panic('missing JSON key ${key}: ${text}')84	}85}8687fn test_init_and_usage() {88	dir := temp_repo('init')89	defer { os.rmdir_all(dir) or {} }90	r := run(dir, 'init', '--json')91	assert r.code == 092	read_json_has(r.out, 'repo')93	read_json_has(r.out, 'ignore_created')94	assert run(dir, 'init').code == 195	assert run(dir, 'unknown-command').code == 296	assert run(dir, 'unknown-command').err.contains('unknown command')97}9899fn test_save_checkpoint_and_status() {100	dir := temp_repo('save')101	defer { os.rmdir_all(dir) or {} }102	init_repo(dir)103	write(dir, 'tracked.txt', 'one\n')104	r := run(dir, 'save', 'first message', '--agent', 'agent-7', '--session', 'session-a', '--json')105	assert r.code == 0106	for key in ['id', 'parent', 'message', 'created_at', 'machine', 'is_checkpoint', 'agent',107		'session', 'files', 'size_bytes'] {108		read_json_has(r.out, key)109	}110	assert r.out.contains('"message":"first message"')111	assert r.out.contains('"agent":"agent-7"')112	assert r.out.contains('"session":"session-a"')113	assert r.out.contains('"is_checkpoint":false')114	assert run(dir, 'save', 'again').code == 1115	assert run(dir, 'save', 'again').err.contains('nothing has changed since the last save')116	assert run(dir, 'save').code == 2117	assert run(dir, 'save', 'x', '--bogus').code == 2118	cp := run(dir, 'checkpoint', 'still first', '--json')119	assert cp.code == 0120	assert cp.out.contains('"is_checkpoint":true')121	assert cp.out.contains('"parent":')122	clean := run(dir, 'status')123	assert clean.code == 0124	assert clean.out.contains('no changes')125	write(dir, 'tracked.txt', 'two\n')126	write(dir, 'new.txt', 'new\n')127	os.rm(os.join_path(dir, 'tracked.txt')) or { panic(err) }128	write(dir, '.kohignore', '*.log\n')129	status := run(dir, 'status')130	assert status.code == 0131	assert status.out.contains('+')132	assert status.out.contains('~') || status.out.contains('-')133	assert status.out.contains('added')134	js := run(dir, 'status', '--json')135	assert js.code == 0136	for key in ['head_id', 'head_msg', 'dirty', 'modified', 'added', 'deleted', 'ignore_changed'] {137		read_json_has(js.out, key)138	}139	assert js.out.contains('"ignore_changed":true')140}141142fn test_status_requires_repo_and_ignore_rules() {143	dir := temp_repo('status')144	defer { os.rmdir_all(dir) or {} }145	assert run(dir, 'status').code == 1146	init_repo(dir)147	write(dir, '.kohignore', '*.log\nbuild/\n')148	write(dir, 'keep.txt', 'keep\n')149	write(dir, 'ignored.log', 'ignore\n')150	write(dir, 'build/output.txt', 'ignore\n')151	assert run(dir, 'save', 'keep').code == 0152	assert run(dir, 'status').out.contains('no changes')153	assert !run(dir, 'status').out.contains('ignored.log')154	assert !run(dir, 'status').out.contains('build/output.txt')155	assert !run(dir, 'status').out.contains('LOG.md')156}157158// LOG.md is a convenience written after the save commits. If it cannot be159// written, the save still happened, and an agent that retried on a failure160// would only be told nothing had changed.161fn test_a_save_succeeds_when_log_md_cannot_be_written() {162	dir := temp_repo('logmd')163	defer { os.rmdir_all(dir) or {} }164	init_repo(dir)165	os.mkdir_all(os.join_path(dir, 'LOG.md')) or { panic(err) }166	write(dir, 'a.txt', 'one\n')167	r := run(dir, 'save', 'first', '--json')168	assert r.code == 0169	assert r.out.starts_with('{')170	assert r.err.contains('LOG.md')171	assert run(dir, 'log', '--json').out.contains('"message":"first"')172}173174// A folder of ignored files can sit where a restored file should go. Koh175// never touches ignored files, so the restore must stop and say so, not drop176// the file inside the folder under a temporary name.177fn test_a_restore_refuses_a_folder_of_ignored_files_in_the_way() {178	dir := temp_repo('dir-in-way')179	defer { os.rmdir_all(dir) or {} }180	init_repo(dir)181	write(dir, 'out', 'a file\n')182	first := run(dir, 'save', 'out is a file', '--json').out.all_after('"id":"')[..12]183	os.rm(os.join_path(dir, 'out')) or { panic(err) }184	write(dir, 'out/build.log', 'ignored\n')185	assert run(dir, 'save', 'out is gone').code == 0186	r := run(dir, 'load', first, '--yes')187	assert r.code == 1188	assert r.err.contains('out')189	assert os.ls(os.join_path(dir, 'out'))! == ['build.log']190}191192// Doctor clears peek folders left from earlier days, never one somebody may193// be reading right now.194fn test_doctor_sweeps_only_old_peek_folders() {195	dir := temp_repo('peek-sweep')196	// V's temp_dir is /tmp on macOS whatever TMPDIR says, so these live in197	// the real temp directory under names no save could have.198	fresh := os.join_path(os.temp_dir(), 'koh-peek-fresh${os.getpid()}')199	old := os.join_path(os.temp_dir(), 'koh-peek-old${os.getpid()}')200	defer {201		os.rmdir_all(dir) or {}202		os.rmdir_all(fresh) or {}203		os.rmdir_all(old) or {}204	}205	init_repo(dir)206	write(dir, 'a.txt', 'one\n')207	assert run(dir, 'save', 'one').code == 0208	os.mkdir_all(fresh) or { panic(err) }209	os.mkdir_all(old) or { panic(err) }210	two_days_ago := time.now().unix() - 2 * 86400211	os.utime(old, two_days_ago, two_days_ago) or { panic(err) }212	assert run(dir, 'doctor', '--json').code == 0213	assert os.exists(fresh)214	assert !os.exists(old)215}216217// A file saved long ago and ignored since holds work no save has. Loading the218// old save must not write over it; the document says a restore never touches219// ignored files.220fn test_a_restore_never_overwrites_an_ignored_file() {221	dir := temp_repo('ignored-restore')222	defer { os.rmdir_all(dir) or {} }223	init_repo(dir)224	write(dir, '.env', 'KEY=saved long ago\n')225	first := run(dir, 'save', 'with env', '--json').out.all_after('"id":"')[..12]226	write(dir, '.kohignore', '.env\n')227	assert run(dir, 'save', 'ignore env').code == 0228	write(dir, '.env', 'KEY=never saved\n')229	assert run(dir, 'load', first, '--yes').code == 0230	assert os.read_file(os.join_path(dir, '.env'))! == 'KEY=never saved\n'231232	// Where the ignored file is missing, the restore still brings it back.233	other := temp_repo('ignored-restore-missing')234	defer { os.rmdir_all(other) or {} }235	init_repo(other)236	write(other, '.env', 'KEY=saved long ago\n')237	again := run(other, 'save', 'with env', '--json').out.all_after('"id":"')[..12]238	write(other, '.kohignore', '.env\n')239	assert run(other, 'save', 'ignore env').code == 0240	os.rm(os.join_path(other, '.env')) or { panic(err) }241	assert run(other, 'load', again, '--yes').code == 0242	assert os.read_file(os.join_path(other, '.env'))! == 'KEY=saved long ago\n'243}244245// A going-back preview lists paths only. Running diff(1) per file to draw it246// cost 27 s for 5,000 changed files, so it must not run diff at all.247fn test_a_going_back_preview_does_not_run_diff() {248	dir := temp_repo('preview-nodiff')249	home := temp_repo('preview-nodiff-home')250	defer {251		os.rmdir_all(dir) or {}252		os.rmdir_all(home) or {}253	}254	init_repo(dir)255	write(dir, 'a.txt', 'one\n')256	assert run_home(dir, home, 'save', 'one').code == 0257	write(dir, 'a.txt', 'two\n')258	assert run_home(dir, home, 'save', 'two').code == 0259	fake := os.join_path(home, 'bin')260	os.mkdir_all(fake) or { panic(err) }261	marker := os.join_path(home, 'diff-ran')262	os.write_file(os.join_path(fake, 'diff'), '#!/bin/sh\ntouch ${q(marker)}\nexit 2\n') or {263		panic(err)264	}265	os.chmod(os.join_path(fake, 'diff'), 0o755) or { panic(err) }266	assert run_home_with_path(dir, home, fake, 'undo', '--yes').code == 0267	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'one\n'268	assert !os.exists(marker)269}270271// `save` records the executable bit, so `status` has to see it too, or a272// chmod would be invisible until it turned up in a save.273fn test_status_sees_an_executable_bit_change() {274	dir := temp_repo('chmod')275	defer { os.rmdir_all(dir) or {} }276	init_repo(dir)277	write(dir, 'run.sh', 'echo hi\n')278	assert run(dir, 'save', 'script').code == 0279	os.chmod(os.join_path(dir, 'run.sh'), 0o755) or { panic(err) }280	status := run(dir, 'status', '--json')281	assert status.out.contains('"dirty":true')282	assert status.out.contains('"modified":["run.sh"]')283}284285fn test_log_and_diff() {286	dir := temp_repo('history')287	defer { os.rmdir_all(dir) or {} }288	init_repo(dir)289	write(dir, 'a.txt', 'one\n')290	first := run(dir, 'save', 'one', '--session', 'alpha', '--json')291	id1 := first.out.all_after('"id":"')[..12]292	write(dir, 'a.txt', 'two\n')293	second := run(dir, 'save', 'two', '--session', 'beta', '--json')294	id2 := second.out.all_after('"id":"')[..12]295	cp := run(dir, 'checkpoint', 'checkpoint', '--json')296	assert cp.code == 0297	log := run(dir, 'log')298	assert log.code == 0299	assert log.out.contains('▸')300	assert log.out.contains('◐')301	lj := run(dir, 'log', '--json')302	assert lj.code == 0303	assert lj.out.contains('"head_id"')304	assert lj.out.contains('"saves"')305	assert run(dir, 'log', '--since', 'today').out.contains('two')306	session := run(dir, 'log', '--session', 'alpha')307	assert session.out.contains('one')308	assert !session.out.contains('two')309	write(dir, 'a.txt', 'three\n')310	d := run(dir, 'diff')311	assert d.code == 0312	assert d.out.contains('--- a/')313	assert d.out.contains('+++ b/')314	assert run(dir, 'diff', id1).code == 0315	assert run(dir, 'diff', id1, id2).code == 0316	dj := run(dir, 'diff', '--json')317	assert dj.code == 0318	assert dj.out.contains('"from"')319	assert dj.out.contains('"to"')320	assert dj.out.contains('"files"')321	assert dj.out.contains('"change":"modified"')322	assert run(dir, 'diff', 'not-a-real-id').code == 1323	assert run(dir, 'diff', id1, id2, 'third').code == 1324	write(dir, 'blob.bin', '\x00\x01\x02')325	diff_binary := run(dir, 'diff', '--json')326	assert diff_binary.out.contains('"binary":true')327	assert diff_binary.out.contains('Binary files differ')328}329330fn test_undo_revert_and_load() {331	dir := temp_repo('restore')332	defer { os.rmdir_all(dir) or {} }333	init_repo(dir)334	write(dir, 'a.txt', 'one\n')335	one := run(dir, 'save', 'one', '--json').out336	id1 := one.all_after('"id":"')[..12]337	write(dir, 'a.txt', 'two\n')338	write(dir, 'gone.txt', 'gone\n')339	second := run(dir, 'save', 'two', '--json').out340	id2 := second.all_after('"id":"')[..12]341	write(dir, 'a.txt', 'three\n')342	third := run(dir, 'save', 'three', '--json').out343	id3 := third.all_after('"id":"')[..12]344	// Unsaved work — here a file never saved — blocks every going-back but345	// revert, as in Koh 2: a restore must never overwrite what only the disk has.346	write(dir, 'never.txt', 'keep me\n')347	log_before := run(dir, 'log').out348	for args in [['undo', '--yes'], ['load', id1, '--yes'], ['pluck', id2, '--yes']] {349		blocked := run(dir, ...args)350		assert blocked.code == 1351		assert blocked.err.contains('unsaved changes')352	}353	assert run(dir, 'log').out == log_before354	os.rm(os.join_path(dir, 'never.txt')) or { panic(err) }355	write(dir, 'a.txt', 'edited, never saved\n')356	assert run(dir, 'undo', '--yes').err.contains('unsaved changes')357	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'edited, never saved\n'358	write(dir, 'a.txt', 'three\n')359	os.rm(os.join_path(dir, 'gone.txt')) or { panic(err) }360	assert run(dir, 'load', id1, '--yes').err.contains('unsaved changes')361	write(dir, 'gone.txt', 'gone\n')362	undo := run(dir, 'undo', '--yes', '--json')363	assert undo.code == 0364	if !undo.out.contains(id2) {365		panic('undo JSON did not name ${id2}: ${undo.out}')366	}367	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'two\n'368	assert os.exists(os.join_path(dir, 'gone.txt'))369	assert run(dir, 'load', id3, '--yes').code == 0370	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'three\n'371	assert run(dir, 'undo', '2', '--yes').code == 0372	assert run(dir, 'load', id2, '--yes').code == 0373	assert run(dir, 'undo', '99', '--yes').err.contains('nothing before')374	write(dir, 'a.txt', 'dirty\n')375	before := run(dir, 'log')376	refuse := run(dir, 'revert')377	assert refuse.code == 1378	assert refuse.err.contains('needs --yes when not interactive')379	assert run(dir, 'log').out == before.out380	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'dirty\n'381	write(dir, 'untracked.txt', 'remove\n')382	rv := run(dir, 'revert', '--yes')383	assert rv.code == 0384	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'two\n'385	assert !os.exists(os.join_path(dir, 'untracked.txt'))386	assert run(dir, 'revert', '--yes').out.contains('working tree already matches')387	assert run(dir, 'load', '--checkpoint', '--yes').code == 0388	assert run(dir, 'load', id2, '--json').code == 1389	assert run(dir, 'load', id2, '--json').err.contains('error')390	assert run(dir, 'load').code == 2391	assert run(dir, 'load', 'unknown-id', '--yes').code == 1392}393394fn test_flag_and_flagged_log() {395	dir := temp_repo('flag')396	defer { os.rmdir_all(dir) or {} }397	init_repo(dir)398	write(dir, 'flag.txt', 'one\n')399	saved := run(dir, 'save', 'flag me', '--json')400	id := saved.out.all_after('"id":"')[..12]401	flagged := run(dir, 'flag', id, '--reason', 'unsafe', '--json')402	assert flagged.code == 0403	assert flagged.out.contains('"flagged":true')404	assert flagged.out.contains('"reason":"unsafe"')405	list := run(dir, 'flag', '--json')406	assert list.code == 0407	assert list.out.contains(id)408	assert list.out.contains('unsafe')409	assert run(dir, 'log').out.contains('⚑')410	assert run(dir, 'flag', '--clear', id).code == 0411	assert run(dir, 'flag').out.contains('nothing is flagged')412	assert run(dir, 'flag', 'unknown-id').code == 1413	assert run(dir, 'flag').code == 0414}415416fn test_pluck_forward_reverse_dry_run_and_conflict() {417	dir := temp_repo('pluck')418	defer { os.rmdir_all(dir) or {} }419	init_repo(dir)420	write(dir, 'a.txt', 'one\n')421	first := run(dir, 'save', 'one', '--json').out422	id1 := first.all_after('"id":"')[..12]423	write(dir, 'a.txt', 'two\n')424	second := run(dir, 'save', 'two', '--json').out425	id2 := second.all_after('"id":"')[..12]426	assert run(dir, 'load', id1, '--yes').code == 0427	dry := run(dir, 'pluck', id2, '--dry-run')428	assert dry.code == 0429	assert dry.out.contains('a.txt')430	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'one\n'431	assert run(dir, 'pluck', id2, '--yes').code == 0432	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'two\n'433	assert run(dir, 'pluck', '--reverse', id2, '--yes').code == 0434	assert os.read_file(os.join_path(dir, 'a.txt'))! == 'one\n'435	write(dir, 'a.txt', 'different\n')436	assert run(dir, 'pluck', id2, '--dry-run').code == 1437	assert run(dir, 'save', 'different').code == 0438	conflict := run(dir, 'pluck', id2, '--yes')439	assert conflict.code == 1440	assert conflict.err.contains('a.txt')441	assert run(dir, 'pluck').code == 2442	assert run(dir, 'pluck', 'unknown-id').code == 1443}444445fn test_peek_and_doctor() {446	dir := temp_repo('peek-doctor')447	defer { os.rmdir_all(dir) or {} }448	init_repo(dir)449	write(dir, 'peek.txt', 'peek me\n')450	assert run(dir, 'save', 'peekable').code == 0451	id := run(dir, 'log', '--json').out.all_after('"id":"')[..12]452	before_log := run(dir, 'log', '--json').out453	peek := run(dir, 'peek', id, '--json')454	assert peek.code == 0455	peek_path := peek.out.all_after('"path":"').before('"')456	assert peek.out.contains('"id":"${id}"')457	assert os.read_file(os.join_path(peek_path, 'peek.txt'))! == 'peek me\n'458	assert run(dir, 'status').out.contains('no changes')459	assert run(dir, 'log', '--json').out == before_log460	assert run(dir, 'peek').code == 2461	assert run(dir, 'peek', 'unknown-id').code == 1462	backup := os.join_path(dir, 'doctor.backup')463	healthy := run(dir, 'doctor')464	assert healthy.code == 0465	assert healthy.out.contains('is sound')466	report := run(dir, 'doctor', '--json')467	assert report.code == 0468	for key in ['problems', 'objects', 'saves', 'checkpoints', 'cached_files', 'peek_folders_removed',469		'backup'] {470		read_json_has(report.out, key)471	}472	backed := run(dir, 'doctor', '--backup', backup)473	assert backed.code == 0474	assert os.exists(backup)475	assert backed.out.contains(backup)476	assert run(dir, 'doctor', '--backup', backup).code == 1477	assert run(dir, 'peek', id, '--json').code == 0478	// A peek made today is left for whoever is reading it.479	kept := run(dir, 'doctor', '--json')480	assert kept.code == 0481	assert os.exists(peek_path)482	os.rmdir_all(peek_path) or {}483}484485fn test_strip_refuses_without_terminal() {486	dir := temp_repo('strip')487	defer { os.rmdir_all(dir) or {} }488	init_repo(dir)489	write(dir, 'secret.txt', 'keep\n')490	assert run(dir, 'save', 'secret').code == 0491	before_log := run(dir, 'log', '--json').out492	refused := run(dir, 'strip', 'secret.txt')493	assert refused.code == 1494	assert refused.err.contains('needs a terminal')495	assert run(dir, 'log', '--json').out == before_log496	assert os.read_file(os.join_path(dir, 'secret.txt'))! == 'keep\n'497	assert run(dir, 'log', '--json').out.contains('secret')498}499500fn test_saves_and_checkpoints_aliases() {501	dir := temp_repo('aliases')502	defer { os.rmdir_all(dir) or {} }503	init_repo(dir)504	write(dir, 'alias.txt', 'one\n')505	assert run(dir, 'save', 'plain save').code == 0506	assert run(dir, 'checkpoint', 'checkpoint save').code == 0507	saves := run(dir, 'saves')508	assert saves.code == 0509	assert saves.out.contains('plain save')510	assert saves.out.contains('checkpoint save')511	checkpoints := run(dir, 'checkpoints')512	assert checkpoints.code == 0513	assert checkpoints.out.contains('checkpoint save')514	assert !checkpoints.out.contains('plain save')515	json_result := run(dir, 'checkpoints', '--json')516	assert json_result.code == 0517	assert json_result.out.contains('"head_id"')518	assert json_result.out.contains('"saves"')519	assert json_result.out.contains('"is_checkpoint":true')520	assert !json_result.out.contains('"is_checkpoint":false')521}522523fn test_remote_configuration_is_isolated_and_atomic() {524	dir := temp_repo('remote')525	home := temp_repo('remote-home')526	defer {527		os.rmdir_all(dir) or {}528		os.rmdir_all(home) or {}529	}530	empty := run_home(dir, home, 'remote', '--json')531	assert empty.code == 0532	assert empty.out.contains('"configured":false')533	target := os.join_path(home, 'remote-store')534	set := run_home(dir, home, 'remote', 'folder', target)535	assert set.code == 0536	assert os.is_dir(target)537	state := run_home(dir, home, 'remote', '--json')538	assert state.code == 0539	assert state.out.contains('"kind":"folder"')540	assert state.out.contains(target)541	assert run_home(dir, home, 'remote', 's3', 'http://127.0.0.1:1', 'bucket', 'region').code == 1542	assert run_home(dir, home, 'remote', '--json').out.contains(target)543	assert run_home(dir, home, 'remote', 's3', 'http://127.0.0.1:1', 'bucket', 'region').err.contains('KOH_ACCESS_KEY')544	assert run_home(dir, home, 'remote', '--forget').code == 0545	assert run_home(dir, home, 'remote', '--json').out.contains('"configured":false')546}547548// A clone belongs to the repo it was stolen from, whatever its folder is549// called later: renaming it must not start a second repo on the remote.550fn test_a_renamed_clone_keeps_offering_to_its_repo() {551	syncroot := temp_repo('rename-clone')552	home := temp_repo('rename-clone-home')553	defer {554		os.rmdir_all(syncroot) or {}555		os.rmdir_all(home) or {}556	}557	remote := os.join_path(syncroot, 'remote')558	a := os.join_path(syncroot, 'A', 'proj')559	b_parent := os.join_path(syncroot, 'B')560	os.mkdir_all(a) or { panic(err) }561	os.mkdir_all(b_parent) or { panic(err) }562	init_repo(a)563	write(a, 'a.txt', 'from A\n')564	assert run_home(a, home, 'remote', 'folder', remote).code == 0565	assert run_home(a, home, 'save', 'A first').code == 0566	assert run_home(b_parent, home, 'steal', 'proj').code == 0567	renamed := os.join_path(b_parent, 'renamed')568	os.mv(os.join_path(b_parent, 'proj'), renamed) or { panic(err) }569	write(renamed, 'b.txt', 'from B\n')570	assert run_home(renamed, home, 'save', 'B first').code == 0571	assert !os.exists(os.join_path(remote, 'renamed'))572	assert run_home(a, home, 'steal').code == 0573	assert os.read_file(os.join_path(a, 'b.txt'))! == 'from B\n'574}575576fn test_offer_steal_folder_remote() {577	syncroot := temp_repo('sync')578	home := temp_repo('sync-home')579	defer {580		os.rmdir_all(syncroot) or {}581		os.rmdir_all(home) or {}582	}583	remote := os.join_path(syncroot, 'remote')584	a := os.join_path(syncroot, 'A', 'proj')585	b_parent := os.join_path(syncroot, 'B')586	os.mkdir_all(a) or { panic(err) }587	os.mkdir_all(b_parent) or { panic(err) }588	init_repo(a)589	write(a, 'a.txt', 'from A\n')590	assert run_home(a, home, 'remote', 'folder', remote).code == 0591	assert run_home(a, home, 'save', 'A first').code == 0592	clone := run_home(b_parent, home, 'steal', 'proj')593	assert clone.code == 0594	b := os.join_path(b_parent, 'proj')595	assert os.read_file(os.join_path(b, 'a.txt'))! == 'from A\n'596	write(b, 'b.txt', 'from B\n')597	assert run_home(b, home, 'save', 'B first').code == 0598	write(a, 'a2.txt', 'second\n')599	assert run_home(a, home, 'save', 'A second').code == 0600	assert run_home(a, home, 'steal').code == 0601	assert os.exists(os.join_path(a, 'b.txt'))602	assert run_home(b_parent, home, 'steal', '--list').out.contains('proj')603	write(a, 'clash.txt', 'base\n')604	assert run_home(a, home, 'save', 'clash base').code == 0605	assert run_home(b, home, 'steal').code == 0606	write(a, 'clash.txt', 'A version\n')607	assert run_home(a, home, 'save', 'A clash').code == 0608	write(b, 'clash.txt', 'B version\n')609	assert run_home(b, home, 'save', 'B clash').code == 0610	refused := run_home(b, home, 'steal')611	assert refused.code == 1612	assert refused.err.contains('--mine') || refused.err.contains('--theirs')613	assert run_home(b, home, 'steal', '--theirs').code == 0614	assert os.read_file(os.join_path(b, 'clash.txt'))! == 'A version\n'615	write(a, 'clash.txt', 'A second\n')616	assert run_home(a, home, 'save', 'A second clash').code == 0617	write(b, 'clash.txt', 'B second\n')618	assert run_home(b, home, 'save', 'B second clash').code == 0619	assert run_home(b, home, 'steal', '--mine').code == 0620	assert os.read_file(os.join_path(b, 'clash.txt'))! == 'B second\n'621	assert run_home(b, home, 'log').out.contains('combine: kept mine for')622}623624fn test_man_and_koh2_handoff() {625	dir := temp_repo('man')626	home := temp_repo('man-home')627	defer {628		os.rmdir_all(dir) or {}629		os.rmdir_all(home) or {}630	}631	whole := run_home(dir, home, 'man')632	assert whole.code == 0633	assert whole.out.contains('NAME')634	assert whole.out.contains('COMMANDS')635	strip := run_home(dir, home, 'man', 'strip')636	assert strip.code == 0637	assert strip.out.contains('strip')638	assert !strip.out.contains('koh save ')639	assert run_home(dir, home, 'man', 'nonsense').code == 2640	legacy := temp_repo('legacy')641	defer { os.rmdir_all(legacy) or {} }642	os.mkdir_all(os.join_path(legacy, '.koh')) or { panic(err) }643	fake := os.join_path(home, 'bin')644	os.mkdir_all(fake) or { panic(err) }645	fake_koh := os.join_path(fake, 'koh2')646	os.write_file(fake_koh, '#!/bin/sh\nprintf "handoff:%s\\n" "$*"\nexit 7\n') or { panic(err) }647	os.chmod(fake_koh, 0o755) or { panic(err) }648	handoff := run_home_with_path(legacy, home, fake, 'status', '--json')649	assert handoff.code == 7650	assert handoff.out.contains('handoff:status --json')651	// One notice line, on stderr, so koh2's own output stays as it was.652	assert handoff.err.contains('Koh 2 repo')653	assert handoff.err.trim_space().split_into_lines().len == 1654	assert handoff.out.trim_space() == 'handoff:status --json'655}656657fn run_home_with_path(repo string, home string, bin_dir string, args ...string) Result {658	stamp := '${os.getpid()}-${time.now().unix_nano()}'659	base := os.join_path(os.temp_dir(), 'koh3-cli-${stamp}')660	out_path := '${base}.out'661	err_path := '${base}.err'662	code_path := '${base}.code'663	mut command := 'HOME=${q(home)} PATH=${q(bin_dir + ':' + os.getenv('PATH'))} ${q(binary)}'664	for arg in args {665		command += ' ${q(arg)}'666	}667	shell := 'cd ${q(repo)} && ${command} </dev/null >${q(out_path)} 2>${q(err_path)}; printf "%s" $? >${q(code_path)}'668	result := os.execute(shell)669	if result.exit_code != 0 {670		panic('could not run test command: ${result.output}')671	}672	code := os.read_file(code_path) or { panic(err) }673	out := os.read_file(out_path) or { '' }674	err := os.read_file(err_path) or { '' }675	os.rm(out_path) or {}676	os.rm(err_path) or {}677	os.rm(code_path) or {}678	return Result{679		code: code.int()680		out:  out681		err:  err682	}683}684685// --- migration -------------------------------------------------------------686687fn koh2_binary() string {688	return os.find_abs_path_of_executable('koh') or { '' }689}690691// run_koh2 runs the Koh 2 binary in a fixture; its own output is not under692// test here.693fn run_koh2(dir string, command string) {694	os.execute('cd ${q(dir)} && ${command} >/dev/null 2>&1')695}696697fn save_ids(dir string) []string {698	mut ids := []string{}699	for name in os.ls(os.join_path(dir, '.koh', 'snapshots')) or { []string{} } {700		if name.ends_with('.json') {701			ids << name.trim_right('.json')702		}703	}704	ids.sort()705	return ids706}707708fn test_migrate_converts_a_koh2_repo_and_keeps_every_save() {709	koh2 := koh2_binary()710	if koh2 == '' {711		println('skipping the migration tests: koh (Koh 2) is not on PATH')712		return713	}714	dir := temp_repo('migrate')715	defer { os.rmdir_all(dir) or {} }716	home := temp_repo('migrate-home')717	defer { os.rmdir_all(home) or {} }718	run_koh2(dir, '${q(koh2)} init')719	// One file large enough to be an object, one small enough to be inlined.720	write(dir, 'code.txt', 'x'.repeat(700))721	write(dir, 'tiny.txt', 'tiny\n')722	run_koh2(dir, '${q(koh2)} save "first save"')723	run_koh2(dir, '${q(koh2)} checkpoint "before something"')724	write(dir, 'code.txt', 'y'.repeat(700))725	run_koh2(dir, '${q(koh2)} save "second save"')726	original := save_ids(dir)727	assert original.len == 3728729	report := run_home(dir, home, 'migrate')730	assert report.code == 0731	assert report.out.contains('migrated 3 saves')732	// The swap: `.koh` is a file, the old data is archived, nothing is staging.733	assert os.is_file(os.join_path(dir, '.koh'))734	assert os.is_dir(os.join_path(dir, '.koh-v2'))735	assert os.is_file(os.join_path(dir, '.kohignore'))736	assert !os.exists(os.join_path(dir, '.koh-migrate'))737738	// Every save kept its original ID, and the new repo is sound.739	logged := run_home(dir, home, 'log', '--json')740	assert logged.code == 0741	for id in original {742		assert logged.out.contains(id)743	}744	assert run_home(dir, home, 'doctor').code == 0745	assert run_home(dir, home, 'status').code == 0746747	// Migrating again has nothing to convert.748	assert run_home(dir, home, 'migrate').code == 1749}750751fn test_migrate_refuses_a_tree_that_does_not_match_the_last_save() {752	koh2 := koh2_binary()753	if koh2 == '' {754		return755	}756	dir := temp_repo('migrate-dirty')757	defer { os.rmdir_all(dir) or {} }758	home := temp_repo('migrate-dirty-home')759	defer { os.rmdir_all(home) or {} }760	run_koh2(dir, '${q(koh2)} init')761	write(dir, 'code.txt', 'x'.repeat(700))762	run_koh2(dir, '${q(koh2)} save "only save"')763	write(dir, 'code.txt', 'unsaved change\n')764765	refused := run_home(dir, home, 'migrate')766	assert refused.code == 1767	assert refused.err.contains('save with koh2 first')768	// Nothing moved: still Koh 2, no archive, no staging file.769	assert os.is_dir(os.join_path(dir, '.koh'))770	assert !os.exists(os.join_path(dir, '.koh-v2'))771	assert !os.exists(os.join_path(dir, '.koh-migrate'))772}