1
1
import assert from 'node:assert/strict' ;
2
2
import { afterEach , beforeEach , suite , test } from 'node:test' ;
3
- import type { Event } from '../src /Event.js' ;
4
- import type { EventCandidate } from '../src /EventCandidate.js' ;
5
- import { EventSourcingDbContainer } from '../src /EventSourcingDbContainer.js' ;
3
+ import type { Event } from './Event.js' ;
4
+ import type { EventCandidate } from './EventCandidate.js' ;
5
+ import { EventSourcingDbContainer } from './EventSourcingDbContainer.js' ;
6
6
7
7
suite ( 'observeEvents' , { timeout : 30_000 } , ( ) => {
8
8
let container : EventSourcingDbContainer ;
@@ -67,18 +67,18 @@ suite('observeEvents', { timeout: 30_000 }, () => {
67
67
controller . abort ( ) ;
68
68
} , 100 ) ;
69
69
70
- const eventsRead : Event [ ] = [ ] ;
70
+ const eventsObserved : Event [ ] = [ ] ;
71
71
for await ( const event of client . observeEvents (
72
72
'/test' ,
73
73
{
74
74
recursive : false ,
75
75
} ,
76
76
controller . signal ,
77
77
) ) {
78
- eventsRead . push ( event ) ;
78
+ eventsObserved . push ( event ) ;
79
79
}
80
80
81
- assert . equal ( eventsRead . length , 2 ) ;
81
+ assert . equal ( eventsObserved . length , 2 ) ;
82
82
} ) ;
83
83
84
84
test ( 'observes recursively.' , async ( ) : Promise < void > => {
@@ -110,18 +110,18 @@ suite('observeEvents', { timeout: 30_000 }, () => {
110
110
controller . abort ( ) ;
111
111
} , 100 ) ;
112
112
113
- const eventsRead : Event [ ] = [ ] ;
113
+ const eventsObserved : Event [ ] = [ ] ;
114
114
for await ( const event of client . observeEvents (
115
115
'/' ,
116
116
{
117
117
recursive : true ,
118
118
} ,
119
119
controller . signal ,
120
120
) ) {
121
- eventsRead . push ( event ) ;
121
+ eventsObserved . push ( event ) ;
122
122
}
123
123
124
- assert . equal ( eventsRead . length , 2 ) ;
124
+ assert . equal ( eventsObserved . length , 2 ) ;
125
125
} ) ;
126
126
127
127
test ( 'observes with lower bound.' , async ( ) : Promise < void > => {
@@ -153,7 +153,7 @@ suite('observeEvents', { timeout: 30_000 }, () => {
153
153
controller . abort ( ) ;
154
154
} , 100 ) ;
155
155
156
- const eventsRead : Event [ ] = [ ] ;
156
+ const eventsObserved : Event [ ] = [ ] ;
157
157
for await ( const event of client . observeEvents (
158
158
'/test' ,
159
159
{
@@ -162,11 +162,11 @@ suite('observeEvents', { timeout: 30_000 }, () => {
162
162
} ,
163
163
controller . signal ,
164
164
) ) {
165
- eventsRead . push ( event ) ;
165
+ eventsObserved . push ( event ) ;
166
166
}
167
167
168
- assert . equal ( eventsRead . length , 1 ) ;
169
- assert . equal ( eventsRead [ 0 ] . data . value , 42 ) ;
168
+ assert . equal ( eventsObserved . length , 1 ) ;
169
+ assert . equal ( eventsObserved [ 0 ] . data . value , 42 ) ;
170
170
} ) ;
171
171
172
172
test ( 'observes from latest event.' , async ( ) : Promise < void > => {
@@ -198,7 +198,7 @@ suite('observeEvents', { timeout: 30_000 }, () => {
198
198
controller . abort ( ) ;
199
199
} , 100 ) ;
200
200
201
- const eventsRead : Event [ ] = [ ] ;
201
+ const eventsObserved : Event [ ] = [ ] ;
202
202
for await ( const event of client . observeEvents (
203
203
'/test' ,
204
204
{
@@ -211,10 +211,10 @@ suite('observeEvents', { timeout: 30_000 }, () => {
211
211
} ,
212
212
controller . signal ,
213
213
) ) {
214
- eventsRead . push ( event ) ;
214
+ eventsObserved . push ( event ) ;
215
215
}
216
216
217
- assert . equal ( eventsRead . length , 1 ) ;
218
- assert . equal ( eventsRead [ 0 ] . data . value , 42 ) ;
217
+ assert . equal ( eventsObserved . length , 1 ) ;
218
+ assert . equal ( eventsObserved [ 0 ] . data . value , 42 ) ;
219
219
} ) ;
220
220
} ) ;
0 commit comments