1module remote23import os45fn scratch(name string) !string {6 dir := os.join_path(os.temp_dir(), 'koh3_remote_${os.getpid()}_${name}')7 os.rmdir_all(dir) or {}8 os.mkdir_all(dir, os.MkdirParams{})!9 return dir10}1112fn test_a_missing_key_is_not_an_error() {13 base := scratch('missing')!14 defer {15 os.rmdir_all(base) or {}16 }17 mut backend := new_folder(base)!18 object := backend.get('repo/nothing')!19 assert !object.found20 assert object.body.len == 021}2223fn test_put_if_absent_refuses_a_second_write() {24 base := scratch('absent')!25 defer {26 os.rmdir_all(base) or {}27 }28 mut backend := new_folder(base)!29 assert backend.put_if_absent('repo/objects/abc', 'first'.bytes())!30 assert !backend.put_if_absent('repo/objects/abc', 'second'.bytes())!31 object := backend.get('repo/objects/abc')!32 assert object.body == 'first'.bytes()33 assert object.tag == tag_of('first'.bytes())34}3536fn test_put_if_match_only_swaps_the_version_that_was_read() {37 base := scratch('match')!38 defer {39 os.rmdir_all(base) or {}40 }41 mut backend := new_folder(base)!42 backend.put_if_absent('repo/head', 'one'.bytes())!43 tag := backend.get('repo/head')!.tag4445 46 assert !backend.put_if_match('repo/head', 'two'.bytes(), 'a-stale-tag')!47 assert backend.get('repo/head')!.body == 'one'.bytes()4849 50 assert backend.put_if_match('repo/head', 'two'.bytes(), tag)!51 assert backend.get('repo/head')!.body == 'two'.bytes()5253 54 assert !backend.put_if_match('repo/fresh', 'x'.bytes(), tag)!55 assert backend.put_if_match('repo/created', 'x'.bytes(), '')!56 assert backend.get('repo/created')!.found57}5859fn test_list_walks_the_prefix() {60 base := scratch('list')!61 defer {62 os.rmdir_all(base) or {}63 }64 mut backend := new_folder(base)!65 backend.put_if_absent('repo/saves/aaa', 'a'.bytes())!66 backend.put_if_absent('repo/saves/bbb', 'b'.bytes())!67 backend.put_if_absent('repo/objects/ccc', 'c'.bytes())!68 assert backend.list('repo/saves')! == ['repo/saves/aaa', 'repo/saves/bbb']69 assert backend.list('repo/nothing')!.len == 070}7172fn test_delete_removes_the_key() {73 base := scratch('delete')!74 defer {75 os.rmdir_all(base) or {}76 }77 mut backend := new_folder(base)!78 backend.put_if_absent('repo/objects/abc', 'gone'.bytes())!79 backend.delete('repo/objects/abc')!80 assert !backend.get('repo/objects/abc')!.found81}8283fn test_check_passes_on_a_working_remote_and_leaves_nothing_behind() {84 base := scratch('check')!85 defer {86 os.rmdir_all(base) or {}87 }88 mut backend := new_folder(base)!89 check(mut backend)!90 assert !backend.get(probe_key)!.found91}