blob: 0c025fefe3117756b14bce484b463008e1a15525 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
let%test _ =
let open Relational_engine.Disk.Executor in
let stream: history = [{state = _EMPTY_SHA_HASH_; files = 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}] 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 *)
|
