blob: fd0e496f8d959db3ef746bd7c815ac1eb13186b5 (
plain)
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
(* Event Log Tests - Eio-based event persistence testing
*
* Tests:
* 1. Basic append and read
* 2. Jam/cue roundtrip through event log
* 3. Replay functionality
* 4. Multiple events in sequence
*)
open Nock_lib
let test_basic_append env =
Printf.printf "Test: Basic append and read...\n";
Eio.Switch.run @@ fun sw ->
let fs = Eio.Stdenv.fs env in
(* Create event log in tmp directory *)
let log = Eventlog.create ~sw ~fs "tmp/test_eventlog" in
(* Create a simple noun *)
let noun1 = Noun.atom 42 in
(* Append event *)
let event_num = Eventlog.append log ~sw noun1 in
Printf.printf " Appended event %Ld\n" event_num;
(* Read it back *)
let noun2 = Eventlog.read_event log event_num in
Printf.printf " Read back event %Ld\n" event_num;
(* Verify they match *)
if noun1 = noun2 then
Printf.printf " ✓ Basic append/read works!\n\n"
else
failwith "Noun mismatch!"
let test_jam_cue_roundtrip env =
Printf.printf "Test: Jam/cue roundtrip through event log...\n";
Eio.Switch.run @@ fun sw ->
let fs = Eio.Stdenv.fs env in
(* Create event log *)
let log = Eventlog.create ~sw ~fs "tmp/test_eventlog_jam" in
(* Create various nouns *)
let test_cases = [
("atom 0", Noun.atom 0);
("atom 42", Noun.atom 42);
("atom 1000000", Noun.atom 1000000);
("cell [1 2]", Noun.cell (Noun.atom 1) (Noun.atom 2));
("nested [[1 2] [3 4]]",
Noun.cell
(Noun.cell (Noun.atom 1) (Noun.atom 2))
(Noun.cell (Noun.atom 3) (Noun.atom 4)));
] in
List.iter (fun (name, noun) ->
let event_num = Eventlog.append log ~sw noun in
let recovered = Eventlog.read_event log event_num in
if noun = recovered then
Printf.printf " ✓ %s: roundtrip OK (event %Ld)\n" name event_num
else
failwith (Printf.sprintf "%s: roundtrip FAILED" name)
) test_cases;
Printf.printf "\n"
let test_replay env =
Printf.printf "Test: Event replay...\n";
Eio.Switch.run @@ fun sw ->
let fs = Eio.Stdenv.fs env in
(* Create event log *)
let log = Eventlog.create ~sw ~fs "tmp/test_eventlog_replay" in
(* Append several events *)
let nouns = [
Noun.atom 1;
Noun.atom 2;
Noun.atom 3;
Noun.cell (Noun.atom 4) (Noun.atom 5);
] in
List.iter (fun noun ->
let _ = Eventlog.append log ~sw noun in
()
) nouns;
Printf.printf " Appended %d events\n" (List.length nouns);
(* Create new log instance to test replay *)
let log2 = Eventlog.create ~sw ~fs "tmp/test_eventlog_replay" in
(* Replay events *)
let replayed = ref [] in
Eventlog.replay log2 ~sw (fun num noun ->
Printf.printf " Replayed event %Ld\n" num;
replayed := noun :: !replayed
);
let replayed_list = List.rev !replayed in
(* Verify all events were replayed correctly *)
if List.length replayed_list = List.length nouns then
Printf.printf " ✓ Replayed %d events correctly\n" (List.length nouns)
else
failwith (Printf.sprintf "Expected %d events, got %d"
(List.length nouns) (List.length replayed_list));
(* Verify content matches *)
List.iter2 (fun original replayed ->
if original <> replayed then
failwith "Replayed noun doesn't match original"
) nouns replayed_list;
Printf.printf " ✓ All replayed events match originals\n\n"
let test_event_count env =
Printf.printf "Test: Event counting...\n";
Eio.Switch.run @@ fun sw ->
let fs = Eio.Stdenv.fs env in
let log = Eventlog.create ~sw ~fs "tmp/test_eventlog_count" in
(* Initially should have 0 events *)
let count0 = Eventlog.event_count log in
Printf.printf " Initial count: %d\n" count0;
(* Append 5 events *)
for i = 1 to 5 do
let _ = Eventlog.append log ~sw (Noun.atom i) in
()
done;
let count5 = Eventlog.event_count log in
Printf.printf " After 5 appends: %d\n" count5;
if count5 = 5 then
Printf.printf " ✓ Event count correct\n\n"
else
failwith (Printf.sprintf "Expected 5 events, got %d" count5)
let () =
Eio_main.run @@ fun env ->
Printf.printf "\n=== Event Log Tests (Eio-based) ===\n\n";
(* Clean up old test directories *)
(try Unix.system "rm -rf tmp/test_eventlog*" |> ignore with _ -> ());
test_basic_append env;
test_jam_cue_roundtrip env;
test_replay env;
test_event_count env;
Printf.printf "=== All tests passed! ✓ ===\n"
|
