let%test _ = let open Relational_engine.Disk.Executor in let stream : history = [ { state = _EMPTY_SHA_HASH_; files = StringMap.empty; references = StringMap.empty; schema = StringMap.empty }; ] in let locations : locations = StringMap.empty in let (new_commit, _), _ = Result.get_ok @@ write (List.hd stream) locations ~filename:"trash" @@ Bytes.of_string "abc" in let expected_state_hash = "bca39cc55b19274133ce57d0bea1ff794589f025d4bcf670c44d5d2811837830" in new_commit.state = expected_state_hash let%test _ = let open Relational_engine.Disk.Executor in let stream : history = [ { state = _EMPTY_SHA_HASH_; files = StringMap.empty; references = StringMap.empty; schema = StringMap.empty }; ] in let locations : locations = StringMap.empty in let (new_commit, new_locations), _ = Result.get_ok @@ write (List.hd stream) locations ~filename:"trash" @@ Bytes.of_string "abc" in let result_test = let open Relational_engine.Extensions.Option in let+ new_file_content = StringMap.find_opt "trash" new_commit.files in let { values; _ } : Hashes.t = List.hd new_file_content in StringMap.find_opt (List.hd values) new_locations in match result_test with | Some location -> print_endline @@ Location.show location; location.size = 3 && location.offset = 0L | None -> false (* let%test _ = let open Relational_engine.Planner in match Relational_engine.Relation.write_and_retrieve () with | Ok (last_commit::_, locations) -> begin let (first_names, last_names) = (Scan.execute last_commit locations "user/first-name", Scan.execute last_commit locations "user/last-name") in let tuples = Join.execute first_names last_names locations in let tuples = List.map (fun (a, b) -> Bytes.to_string a, Bytes.to_string b) tuples in List.iter (fun (a, b) -> print_endline (Printf.sprintf "(%s, %s)" a b)) tuples; true end | _ -> false *)