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}157158159160161fn 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}173174175176177fn 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}191192193194195fn test_a_restore_never_writes_through_a_symlinked_folder() {196 dir := temp_repo('link-in-way')197 outside := temp_repo('link-target')198 defer {199 os.rmdir_all(dir) or {}200 os.rmdir_all(outside) or {}201 }202 init_repo(dir)203 write(dir, 'docs/a.md', 'saved\n')204 first := run(dir, 'save', 'docs', '--json').out.all_after('"id":"')[..12]205 os.rmdir_all(os.join_path(dir, 'docs')) or { panic(err) }206 write(outside, 'a.md', 'precious\n')207 os.symlink(outside, os.join_path(dir, 'docs')) or { panic(err) }208 assert run(dir, 'save', 'docs is a link now').code == 0209 head := run(dir, 'status', '--json').out210 r := run(dir, 'load', first, '--yes')211 assert r.code == 1212 assert r.err.contains('docs')213 assert os.read_file(os.join_path(outside, 'a.md'))! == 'precious\n'214 assert run(dir, 'status', '--json').out == head215}216217218219220221fn test_a_restore_cut_short_points_at_revert() {222 dir := temp_repo('cut-short')223 defer {224 os.chmod(os.join_path(dir, 'ro'), 0o755) or {}225 os.rmdir_all(dir) or {}226 }227 init_repo(dir)228 write(dir, 'zero', '0\n')229 assert run(dir, 'save', 'zero').code == 0230 write(dir, 'ro/f', 'v1\n')231 write(dir, 'top', 'v1\n')232 assert run(dir, 'save', 'first').code == 0233 write(dir, 'ro/f', 'v2\n')234 write(dir, 'top', 'v2\n')235 assert run(dir, 'save', 'second').code == 0236 os.chmod(os.join_path(dir, 'ro'), 0o555)!237 assert run(dir, 'undo', '--yes').code == 1238 os.chmod(os.join_path(dir, 'ro'), 0o755)!239240 assert run(dir, 'status', '--json').out.contains('"restore_unfinished":true')241 for args in [['save', 'half'], ['checkpoint', 'half'], ['undo', '--yes']] {242 r := run(dir, ...args)243 assert r.code == 1244 assert r.err.contains('koh revert')245 }246 assert run(dir, 'revert', '--yes').code == 0247 assert os.read_file(os.join_path(dir, 'ro/f'))! == 'v1\n'248 assert os.read_file(os.join_path(dir, 'top'))! == 'v1\n'249 assert run(dir, 'status', '--json').out.contains('"restore_unfinished":false')250 write(dir, 'top', 'v3\n')251 assert run(dir, 'save', 'carry on').code == 0252}253254255256fn test_doctor_sweeps_only_old_peek_folders() {257 dir := temp_repo('peek-sweep')258 259 260 fresh := os.join_path(os.temp_dir(), 'koh-peek-fresh${os.getpid()}')261 old := os.join_path(os.temp_dir(), 'koh-peek-old${os.getpid()}')262 defer {263 os.rmdir_all(dir) or {}264 os.rmdir_all(fresh) or {}265 os.rmdir_all(old) or {}266 }267 init_repo(dir)268 write(dir, 'a.txt', 'one\n')269 assert run(dir, 'save', 'one').code == 0270 os.mkdir_all(fresh) or { panic(err) }271 os.mkdir_all(old) or { panic(err) }272 two_days_ago := time.now().unix() - 2 * 86400273 os.utime(old, two_days_ago, two_days_ago) or { panic(err) }274 assert run(dir, 'doctor', '--json').code == 0275 assert os.exists(fresh)276 assert !os.exists(old)277}278279280281282fn test_a_restore_never_overwrites_an_ignored_file() {283 dir := temp_repo('ignored-restore')284 defer { os.rmdir_all(dir) or {} }285 init_repo(dir)286 write(dir, '.env', 'KEY=saved long ago\n')287 first := run(dir, 'save', 'with env', '--json').out.all_after('"id":"')[..12]288 write(dir, '.kohignore', '.env\n')289 assert run(dir, 'save', 'ignore env').code == 0290 write(dir, '.env', 'KEY=never saved\n')291 assert run(dir, 'load', first, '--yes').code == 0292 assert os.read_file(os.join_path(dir, '.env'))! == 'KEY=never saved\n'293294 295 other := temp_repo('ignored-restore-missing')296 defer { os.rmdir_all(other) or {} }297 init_repo(other)298 write(other, '.env', 'KEY=saved long ago\n')299 again := run(other, 'save', 'with env', '--json').out.all_after('"id":"')[..12]300 write(other, '.kohignore', '.env\n')301 assert run(other, 'save', 'ignore env').code == 0302 os.rm(os.join_path(other, '.env')) or { panic(err) }303 assert run(other, 'load', again, '--yes').code == 0304 assert os.read_file(os.join_path(other, '.env'))! == 'KEY=saved long ago\n'305}306307308309fn test_a_going_back_preview_does_not_run_diff() {310 dir := temp_repo('preview-nodiff')311 home := temp_repo('preview-nodiff-home')312 defer {313 os.rmdir_all(dir) or {}314 os.rmdir_all(home) or {}315 }316 init_repo(dir)317 write(dir, 'a.txt', 'one\n')318 assert run_home(dir, home, 'save', 'one').code == 0319 write(dir, 'a.txt', 'two\n')320 assert run_home(dir, home, 'save', 'two').code == 0321 fake := os.join_path(home, 'bin')322 os.mkdir_all(fake) or { panic(err) }323 marker := os.join_path(home, 'diff-ran')324 os.write_file(os.join_path(fake, 'diff'), '#!/bin/sh\ntouch ${q(marker)}\nexit 2\n') or {325 panic(err)326 }327 os.chmod(os.join_path(fake, 'diff'), 0o755) or { panic(err) }328 assert run_home_with_path(dir, home, fake, 'undo', '--yes').code == 0329 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'one\n'330 assert !os.exists(marker)331}332333334335fn test_a_restore_leaves_unchanged_files_alone() {336 dir := temp_repo('restore-skip')337 defer { os.rmdir_all(dir) or {} }338 init_repo(dir)339 write(dir, 'a.txt', 'one\n')340 write(dir, 'same.txt', 'never changes\n')341 assert run(dir, 'save', 'one').code == 0342 write(dir, 'a.txt', 'two\n')343 assert run(dir, 'save', 'two').code == 0344 long_ago := i64(1700000000)345 os.utime(os.join_path(dir, 'same.txt'), long_ago, long_ago) or { panic(err) }346 assert run(dir, 'undo', '--yes').code == 0347 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'one\n'348 assert os.file_last_mod_unix(os.join_path(dir, 'same.txt')) == long_ago349}350351352353fn test_status_sees_an_executable_bit_change() {354 dir := temp_repo('chmod')355 defer { os.rmdir_all(dir) or {} }356 init_repo(dir)357 write(dir, 'run.sh', 'echo hi\n')358 assert run(dir, 'save', 'script').code == 0359 os.chmod(os.join_path(dir, 'run.sh'), 0o755) or { panic(err) }360 status := run(dir, 'status', '--json')361 assert status.out.contains('"dirty":true')362 assert status.out.contains('"modified":["run.sh"]')363}364365fn test_log_and_diff() {366 dir := temp_repo('history')367 defer { os.rmdir_all(dir) or {} }368 init_repo(dir)369 write(dir, 'a.txt', 'one\n')370 first := run(dir, 'save', 'one', '--session', 'alpha', '--json')371 id1 := first.out.all_after('"id":"')[..12]372 write(dir, 'a.txt', 'two\n')373 second := run(dir, 'save', 'two', '--session', 'beta', '--json')374 id2 := second.out.all_after('"id":"')[..12]375 cp := run(dir, 'checkpoint', 'checkpoint', '--json')376 assert cp.code == 0377 log := run(dir, 'log')378 assert log.code == 0379 assert log.out.contains('▸')380 assert log.out.contains('◐')381 lj := run(dir, 'log', '--json')382 assert lj.code == 0383 assert lj.out.contains('"head_id"')384 assert lj.out.contains('"saves"')385 assert run(dir, 'log', '--since', 'today').out.contains('two')386 session := run(dir, 'log', '--session', 'alpha')387 assert session.out.contains('one')388 assert !session.out.contains('two')389 write(dir, 'a.txt', 'three\n')390 d := run(dir, 'diff')391 assert d.code == 0392 assert d.out.contains('--- a/')393 assert d.out.contains('+++ b/')394 assert run(dir, 'diff', id1).code == 0395 assert run(dir, 'diff', id1, id2).code == 0396 dj := run(dir, 'diff', '--json')397 assert dj.code == 0398 assert dj.out.contains('"from"')399 assert dj.out.contains('"to"')400 assert dj.out.contains('"files"')401 assert dj.out.contains('"change":"modified"')402 assert run(dir, 'diff', 'not-a-real-id').code == 1403 assert run(dir, 'diff', id1, id2, 'third').code == 1404 write(dir, 'blob.bin', '\x00\x01\x02')405 diff_binary := run(dir, 'diff', '--json')406 assert diff_binary.out.contains('"binary":true')407 assert diff_binary.out.contains('Binary files differ')408}409410fn test_undo_revert_and_load() {411 dir := temp_repo('restore')412 defer { os.rmdir_all(dir) or {} }413 init_repo(dir)414 write(dir, 'a.txt', 'one\n')415 one := run(dir, 'save', 'one', '--json').out416 id1 := one.all_after('"id":"')[..12]417 write(dir, 'a.txt', 'two\n')418 write(dir, 'gone.txt', 'gone\n')419 second := run(dir, 'save', 'two', '--json').out420 id2 := second.all_after('"id":"')[..12]421 write(dir, 'a.txt', 'three\n')422 third := run(dir, 'save', 'three', '--json').out423 id3 := third.all_after('"id":"')[..12]424 425 426 write(dir, 'never.txt', 'keep me\n')427 log_before := run(dir, 'log').out428 for args in [['undo', '--yes'], ['load', id1, '--yes'], ['pluck', id2, '--yes']] {429 blocked := run(dir, ...args)430 assert blocked.code == 1431 assert blocked.err.contains('unsaved changes')432 }433 assert run(dir, 'log').out == log_before434 os.rm(os.join_path(dir, 'never.txt')) or { panic(err) }435 write(dir, 'a.txt', 'edited, never saved\n')436 assert run(dir, 'undo', '--yes').err.contains('unsaved changes')437 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'edited, never saved\n'438 write(dir, 'a.txt', 'three\n')439 os.rm(os.join_path(dir, 'gone.txt')) or { panic(err) }440 assert run(dir, 'load', id1, '--yes').err.contains('unsaved changes')441 write(dir, 'gone.txt', 'gone\n')442 undo := run(dir, 'undo', '--yes', '--json')443 assert undo.code == 0444 if !undo.out.contains(id2) {445 panic('undo JSON did not name ${id2}: ${undo.out}')446 }447 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'two\n'448 assert os.exists(os.join_path(dir, 'gone.txt'))449 assert run(dir, 'load', id3, '--yes').code == 0450 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'three\n'451 assert run(dir, 'undo', '2', '--yes').code == 0452 assert run(dir, 'load', id2, '--yes').code == 0453 assert run(dir, 'undo', '99', '--yes').err.contains('nothing before')454 write(dir, 'a.txt', 'dirty\n')455 before := run(dir, 'log')456 refuse := run(dir, 'revert')457 assert refuse.code == 1458 assert refuse.err.contains('needs --yes when not interactive')459 assert run(dir, 'log').out == before.out460 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'dirty\n'461 write(dir, 'untracked.txt', 'remove\n')462 rv := run(dir, 'revert', '--yes')463 assert rv.code == 0464 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'two\n'465 assert !os.exists(os.join_path(dir, 'untracked.txt'))466 assert run(dir, 'revert', '--yes').out.contains('working tree already matches')467 assert run(dir, 'load', '--checkpoint', '--yes').code == 0468 assert run(dir, 'load', id2, '--json').code == 1469 assert run(dir, 'load', id2, '--json').err.contains('error')470 assert run(dir, 'load').code == 2471 assert run(dir, 'load', 'unknown-id', '--yes').code == 1472}473474fn test_flag_and_flagged_log() {475 dir := temp_repo('flag')476 defer { os.rmdir_all(dir) or {} }477 init_repo(dir)478 write(dir, 'flag.txt', 'one\n')479 saved := run(dir, 'save', 'flag me', '--json')480 id := saved.out.all_after('"id":"')[..12]481 flagged := run(dir, 'flag', id, '--reason', 'unsafe', '--json')482 assert flagged.code == 0483 assert flagged.out.contains('"flagged":true')484 assert flagged.out.contains('"reason":"unsafe"')485 list := run(dir, 'flag', '--json')486 assert list.code == 0487 assert list.out.contains(id)488 assert list.out.contains('unsafe')489 assert run(dir, 'log').out.contains('⚑')490 assert run(dir, 'flag', '--clear', id).code == 0491 assert run(dir, 'flag').out.contains('nothing is flagged')492 assert run(dir, 'flag', 'unknown-id').code == 1493 assert run(dir, 'flag').code == 0494}495496fn test_pluck_forward_reverse_dry_run_and_conflict() {497 dir := temp_repo('pluck')498 defer { os.rmdir_all(dir) or {} }499 init_repo(dir)500 write(dir, 'a.txt', 'one\n')501 first := run(dir, 'save', 'one', '--json').out502 id1 := first.all_after('"id":"')[..12]503 write(dir, 'a.txt', 'two\n')504 second := run(dir, 'save', 'two', '--json').out505 id2 := second.all_after('"id":"')[..12]506 assert run(dir, 'load', id1, '--yes').code == 0507 dry := run(dir, 'pluck', id2, '--dry-run')508 assert dry.code == 0509 assert dry.out.contains('a.txt')510 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'one\n'511 assert run(dir, 'pluck', id2, '--yes').code == 0512 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'two\n'513 assert run(dir, 'pluck', '--reverse', id2, '--yes').code == 0514 assert os.read_file(os.join_path(dir, 'a.txt'))! == 'one\n'515 write(dir, 'a.txt', 'different\n')516 assert run(dir, 'pluck', id2, '--dry-run').code == 1517 assert run(dir, 'save', 'different').code == 0518 conflict := run(dir, 'pluck', id2, '--yes')519 assert conflict.code == 1520 assert conflict.err.contains('a.txt')521 assert run(dir, 'pluck').code == 2522 assert run(dir, 'pluck', 'unknown-id').code == 1523}524525fn test_peek_and_doctor() {526 dir := temp_repo('peek-doctor')527 defer { os.rmdir_all(dir) or {} }528 init_repo(dir)529 write(dir, 'peek.txt', 'peek me\n')530 assert run(dir, 'save', 'peekable').code == 0531 id := run(dir, 'log', '--json').out.all_after('"id":"')[..12]532 before_log := run(dir, 'log', '--json').out533 peek := run(dir, 'peek', id, '--json')534 assert peek.code == 0535 peek_path := peek.out.all_after('"path":"').before('"')536 assert peek.out.contains('"id":"${id}"')537 assert os.read_file(os.join_path(peek_path, 'peek.txt'))! == 'peek me\n'538 assert run(dir, 'status').out.contains('no changes')539 assert run(dir, 'log', '--json').out == before_log540 assert run(dir, 'peek').code == 2541 assert run(dir, 'peek', 'unknown-id').code == 1542 backup := os.join_path(dir, 'doctor.backup')543 healthy := run(dir, 'doctor')544 assert healthy.code == 0545 assert healthy.out.contains('is sound')546 report := run(dir, 'doctor', '--json')547 assert report.code == 0548 for key in ['problems', 'objects', 'saves', 'checkpoints', 'cached_files', 'peek_folders_removed',549 'backup'] {550 read_json_has(report.out, key)551 }552 backed := run(dir, 'doctor', '--backup', backup)553 assert backed.code == 0554 assert os.exists(backup)555 assert backed.out.contains(backup)556 assert run(dir, 'doctor', '--backup', backup).code == 1557 assert run(dir, 'peek', id, '--json').code == 0558 559 kept := run(dir, 'doctor', '--json')560 assert kept.code == 0561 assert os.exists(peek_path)562 os.rmdir_all(peek_path) or {}563}564565fn test_strip_refuses_without_terminal() {566 dir := temp_repo('strip')567 defer { os.rmdir_all(dir) or {} }568 init_repo(dir)569 write(dir, 'secret.txt', 'keep\n')570 assert run(dir, 'save', 'secret').code == 0571 before_log := run(dir, 'log', '--json').out572 refused := run(dir, 'strip', 'secret.txt')573 assert refused.code == 1574 assert refused.err.contains('needs a terminal')575 assert run(dir, 'log', '--json').out == before_log576 assert os.read_file(os.join_path(dir, 'secret.txt'))! == 'keep\n'577 assert run(dir, 'log', '--json').out.contains('secret')578}579580fn test_saves_and_checkpoints_aliases() {581 dir := temp_repo('aliases')582 defer { os.rmdir_all(dir) or {} }583 init_repo(dir)584 write(dir, 'alias.txt', 'one\n')585 assert run(dir, 'save', 'plain save').code == 0586 assert run(dir, 'checkpoint', 'checkpoint save').code == 0587 saves := run(dir, 'saves')588 assert saves.code == 0589 assert saves.out.contains('plain save')590 assert saves.out.contains('checkpoint save')591 checkpoints := run(dir, 'checkpoints')592 assert checkpoints.code == 0593 assert checkpoints.out.contains('checkpoint save')594 assert !checkpoints.out.contains('plain save')595 json_result := run(dir, 'checkpoints', '--json')596 assert json_result.code == 0597 assert json_result.out.contains('"head_id"')598 assert json_result.out.contains('"saves"')599 assert json_result.out.contains('"is_checkpoint":true')600 assert !json_result.out.contains('"is_checkpoint":false')601}602603fn test_remote_configuration_is_isolated_and_atomic() {604 dir := temp_repo('remote')605 home := temp_repo('remote-home')606 defer {607 os.rmdir_all(dir) or {}608 os.rmdir_all(home) or {}609 }610 empty := run_home(dir, home, 'remote', '--json')611 assert empty.code == 0612 assert empty.out.contains('"configured":false')613 target := os.join_path(home, 'remote-store')614 set := run_home(dir, home, 'remote', 'folder', target)615 assert set.code == 0616 assert os.is_dir(target)617 state := run_home(dir, home, 'remote', '--json')618 assert state.code == 0619 assert state.out.contains('"kind":"folder"')620 assert state.out.contains(target)621 assert run_home(dir, home, 'remote', 's3', 'http://127.0.0.1:1', 'bucket', 'region').code == 1622 assert run_home(dir, home, 'remote', '--json').out.contains(target)623 assert run_home(dir, home, 'remote', 's3', 'http://127.0.0.1:1', 'bucket', 'region').err.contains('KOH_ACCESS_KEY')624 assert run_home(dir, home, 'remote', '--forget').code == 0625 assert run_home(dir, home, 'remote', '--json').out.contains('"configured":false')626}627628629630fn test_a_renamed_clone_keeps_offering_to_its_repo() {631 syncroot := temp_repo('rename-clone')632 home := temp_repo('rename-clone-home')633 defer {634 os.rmdir_all(syncroot) or {}635 os.rmdir_all(home) or {}636 }637 remote := os.join_path(syncroot, 'remote')638 a := os.join_path(syncroot, 'A', 'proj')639 b_parent := os.join_path(syncroot, 'B')640 os.mkdir_all(a) or { panic(err) }641 os.mkdir_all(b_parent) or { panic(err) }642 init_repo(a)643 write(a, 'a.txt', 'from A\n')644 assert run_home(a, home, 'remote', 'folder', remote).code == 0645 assert run_home(a, home, 'save', 'A first').code == 0646 assert run_home(b_parent, home, 'steal', 'proj').code == 0647 renamed := os.join_path(b_parent, 'renamed')648 os.mv(os.join_path(b_parent, 'proj'), renamed) or { panic(err) }649 write(renamed, 'b.txt', 'from B\n')650 assert run_home(renamed, home, 'save', 'B first').code == 0651 assert !os.exists(os.join_path(remote, 'renamed'))652 assert run_home(a, home, 'steal').code == 0653 assert os.read_file(os.join_path(a, 'b.txt'))! == 'from B\n'654}655656fn test_offer_steal_folder_remote() {657 syncroot := temp_repo('sync')658 home := temp_repo('sync-home')659 defer {660 os.rmdir_all(syncroot) or {}661 os.rmdir_all(home) or {}662 }663 remote := os.join_path(syncroot, 'remote')664 a := os.join_path(syncroot, 'A', 'proj')665 b_parent := os.join_path(syncroot, 'B')666 os.mkdir_all(a) or { panic(err) }667 os.mkdir_all(b_parent) or { panic(err) }668 init_repo(a)669 write(a, 'a.txt', 'from A\n')670 assert run_home(a, home, 'remote', 'folder', remote).code == 0671 assert run_home(a, home, 'save', 'A first').code == 0672 clone := run_home(b_parent, home, 'steal', 'proj')673 assert clone.code == 0674 b := os.join_path(b_parent, 'proj')675 assert os.read_file(os.join_path(b, 'a.txt'))! == 'from A\n'676 write(b, 'b.txt', 'from B\n')677 assert run_home(b, home, 'save', 'B first').code == 0678 write(a, 'a2.txt', 'second\n')679 assert run_home(a, home, 'save', 'A second').code == 0680 assert run_home(a, home, 'steal').code == 0681 assert os.exists(os.join_path(a, 'b.txt'))682 assert run_home(b_parent, home, 'steal', '--list').out.contains('proj')683 write(a, 'clash.txt', 'base\n')684 assert run_home(a, home, 'save', 'clash base').code == 0685 assert run_home(b, home, 'steal').code == 0686 write(a, 'clash.txt', 'A version\n')687 assert run_home(a, home, 'save', 'A clash').code == 0688 write(b, 'clash.txt', 'B version\n')689 assert run_home(b, home, 'save', 'B clash').code == 0690 refused := run_home(b, home, 'steal')691 assert refused.code == 1692 assert refused.err.contains('--mine') || refused.err.contains('--theirs')693 assert run_home(b, home, 'steal', '--theirs').code == 0694 assert os.read_file(os.join_path(b, 'clash.txt'))! == 'A version\n'695 write(a, 'clash.txt', 'A second\n')696 assert run_home(a, home, 'save', 'A second clash').code == 0697 write(b, 'clash.txt', 'B second\n')698 assert run_home(b, home, 'save', 'B second clash').code == 0699 assert run_home(b, home, 'steal', '--mine').code == 0700 assert os.read_file(os.join_path(b, 'clash.txt'))! == 'B second\n'701 assert run_home(b, home, 'log').out.contains('combine: kept mine for')702}703704fn test_man_and_koh2_handoff() {705 dir := temp_repo('man')706 home := temp_repo('man-home')707 defer {708 os.rmdir_all(dir) or {}709 os.rmdir_all(home) or {}710 }711 whole := run_home(dir, home, 'man')712 assert whole.code == 0713 assert whole.out.contains('NAME')714 assert whole.out.contains('COMMANDS')715 strip := run_home(dir, home, 'man', 'strip')716 assert strip.code == 0717 assert strip.out.contains('strip')718 assert !strip.out.contains('koh save ')719 assert run_home(dir, home, 'man', 'nonsense').code == 2720 legacy := temp_repo('legacy')721 defer { os.rmdir_all(legacy) or {} }722 os.mkdir_all(os.join_path(legacy, '.koh')) or { panic(err) }723 fake := os.join_path(home, 'bin')724 os.mkdir_all(fake) or { panic(err) }725 fake_koh := os.join_path(fake, 'koh2')726 os.write_file(fake_koh, '#!/bin/sh\nprintf "handoff:%s\\n" "$*"\nexit 7\n') or { panic(err) }727 os.chmod(fake_koh, 0o755) or { panic(err) }728 handoff := run_home_with_path(legacy, home, fake, 'status', '--json')729 assert handoff.code == 7730 assert handoff.out.contains('handoff:status --json')731 732 assert handoff.err.contains('Koh 2 repo')733 assert handoff.err.trim_space().split_into_lines().len == 1734 assert handoff.out.trim_space() == 'handoff:status --json'735}736737fn run_home_with_path(repo string, home string, bin_dir string, args ...string) Result {738 stamp := '${os.getpid()}-${time.now().unix_nano()}'739 base := os.join_path(os.temp_dir(), 'koh3-cli-${stamp}')740 out_path := '${base}.out'741 err_path := '${base}.err'742 code_path := '${base}.code'743 mut command := 'HOME=${q(home)} PATH=${q(bin_dir + ':' + os.getenv('PATH'))} ${q(binary)}'744 for arg in args {745 command += ' ${q(arg)}'746 }747 shell := 'cd ${q(repo)} && ${command} </dev/null >${q(out_path)} 2>${q(err_path)}; printf "%s" $? >${q(code_path)}'748 result := os.execute(shell)749 if result.exit_code != 0 {750 panic('could not run test command: ${result.output}')751 }752 code := os.read_file(code_path) or { panic(err) }753 out := os.read_file(out_path) or { '' }754 err := os.read_file(err_path) or { '' }755 os.rm(out_path) or {}756 os.rm(err_path) or {}757 os.rm(code_path) or {}758 return Result{759 code: code.int()760 out: out761 err: err762 }763}764765766767fn koh2_binary() string {768 return os.find_abs_path_of_executable('koh') or { '' }769}770771772773fn run_koh2(dir string, command string) {774 os.execute('cd ${q(dir)} && ${command} >/dev/null 2>&1')775}776777fn save_ids(dir string) []string {778 mut ids := []string{}779 for name in os.ls(os.join_path(dir, '.koh', 'snapshots')) or { []string{} } {780 if name.ends_with('.json') {781 ids << name.trim_right('.json')782 }783 }784 ids.sort()785 return ids786}787788fn test_migrate_converts_a_koh2_repo_and_keeps_every_save() {789 koh2 := koh2_binary()790 if koh2 == '' {791 println('skipping the migration tests: koh (Koh 2) is not on PATH')792 return793 }794 dir := temp_repo('migrate')795 defer { os.rmdir_all(dir) or {} }796 home := temp_repo('migrate-home')797 defer { os.rmdir_all(home) or {} }798 run_koh2(dir, '${q(koh2)} init')799 800 write(dir, 'code.txt', 'x'.repeat(700))801 write(dir, 'tiny.txt', 'tiny\n')802 run_koh2(dir, '${q(koh2)} save "first save"')803 run_koh2(dir, '${q(koh2)} checkpoint "before something"')804 write(dir, 'code.txt', 'y'.repeat(700))805 run_koh2(dir, '${q(koh2)} save "second save"')806 original := save_ids(dir)807 assert original.len == 3808809 report := run_home(dir, home, 'migrate')810 assert report.code == 0811 assert report.out.contains('migrated 3 saves')812 813 assert os.is_file(os.join_path(dir, '.koh'))814 assert os.is_dir(os.join_path(dir, '.koh-v2'))815 assert os.is_file(os.join_path(dir, '.kohignore'))816 assert !os.exists(os.join_path(dir, '.koh-migrate'))817818 819 logged := run_home(dir, home, 'log', '--json')820 assert logged.code == 0821 for id in original {822 assert logged.out.contains(id)823 }824 assert run_home(dir, home, 'doctor').code == 0825 assert run_home(dir, home, 'status').code == 0826827 828 assert run_home(dir, home, 'migrate').code == 1829}830831fn test_migrate_refuses_a_tree_that_does_not_match_the_last_save() {832 koh2 := koh2_binary()833 if koh2 == '' {834 return835 }836 dir := temp_repo('migrate-dirty')837 defer { os.rmdir_all(dir) or {} }838 home := temp_repo('migrate-dirty-home')839 defer { os.rmdir_all(home) or {} }840 run_koh2(dir, '${q(koh2)} init')841 write(dir, 'code.txt', 'x'.repeat(700))842 run_koh2(dir, '${q(koh2)} save "only save"')843 write(dir, 'code.txt', 'unsaved change\n')844845 refused := run_home(dir, home, 'migrate')846 assert refused.code == 1847 assert refused.err.contains('save with koh2 first')848 849 assert os.is_dir(os.join_path(dir, '.koh'))850 assert !os.exists(os.join_path(dir, '.koh-v2'))851 assert !os.exists(os.join_path(dir, '.koh-migrate'))852}