@@ -112,132 +112,6 @@ module(basename(__filename), function () {
112
112
console . log ( 'moduleStart: ' + name ) ;
113
113
} ) ;
114
114
115
- async function expectEvent < T > ( {
116
- assert,
117
- expected,
118
- expectedNumberOfEvents,
119
- onEvents,
120
- callback,
121
- matrixClient,
122
- } : {
123
- assert : Assert ;
124
- expected ?: Record < string , any > [ ] ;
125
- expectedNumberOfEvents ?: number ;
126
- onEvents ?: ( events : Record < string , any > [ ] ) => void ;
127
- callback : ( ) => Promise < T > ;
128
- matrixClient : MatrixClient ;
129
- } ) : Promise < T > {
130
- let defer = new Deferred < Record < string , any > [ ] > ( ) ;
131
- let events : Record < string , any > [ ] = [ ] ;
132
- let maybeNumEvents = expected ?. length ?? expectedNumberOfEvents ;
133
- if ( maybeNumEvents == null ) {
134
- throw new Error (
135
- `expectEvent() must specify either 'expected' or 'expectedNumberOfEvents'` ,
136
- ) ;
137
- }
138
- let numEvents = maybeNumEvents ;
139
-
140
- console . log ( 'before callback' ) ;
141
- let result = await callback ( ) ;
142
- console . log ( 'after callback' ) ;
143
-
144
- let timeout = setTimeout ( ( ) => {
145
- defer . reject (
146
- new Error (
147
- `expectEvent timed out, saw events ${ JSON . stringify ( events ) } ` ,
148
- ) ,
149
- ) ;
150
- } , 5000 ) ;
151
-
152
- console . log ( 'after timeout, before eventSource' ) ;
153
-
154
- let actualEventSource : eventSource ;
155
- try {
156
- actualEventSource = new eventSource ( `${ testRealmHref } _message` ) ;
157
- } catch ( e ) {
158
- console . log ( 'error creating eventSource' , e ) ;
159
- }
160
-
161
- console . log ( 'hello' ) ;
162
-
163
- console . log (
164
- 'calling getJoinedRooms, logged in?' ,
165
- matrixClient . isLoggedIn ( ) ,
166
- ) ;
167
-
168
- let joinedRooms = await matrixClient . getJoinedRooms ( ) ;
169
- console . log (
170
- 'joinedRooms for client ' + matrixClient . getUserId ( ) ,
171
- joinedRooms ,
172
- ) ;
173
-
174
- let roomId = joinedRooms . joined_rooms [ 0 ] ;
175
-
176
- if ( roomId ) {
177
- console . log ( 'roomId' , roomId ) ;
178
- let messages = await matrixClient . roomMessages ( roomId ) ;
179
- let messagesAfterSentinel = messages . slice (
180
- 0 ,
181
- messages . findIndex (
182
- ( m ) => m . content . msgtype === 'app.boxel.test.sentinel' ,
183
- ) ,
184
- ) ;
185
- console . log ( 'messages' , messagesAfterSentinel ) ;
186
-
187
- let events = messagesAfterSentinel . map ( ( m ) =>
188
- JSON . parse ( m . content . body ) ,
189
- ) ;
190
-
191
- defer . fulfill ( events ) ;
192
-
193
- assert . deepEqual ( events , expected ) ;
194
-
195
- console . log ( 'expectEvent deepEqual done' ) ;
196
-
197
- if ( onEvents ) {
198
- console . log ( 'calling onEvents' ) ;
199
- onEvents ( events ) ;
200
- } else {
201
- console . log ( 'no onEvents' ) ;
202
- }
203
- } else {
204
- console . log ( 'no roomId' ) ;
205
- }
206
- clearTimeout ( timeout ) ;
207
-
208
- actualEventSource . close ( ) ;
209
-
210
- return result ;
211
-
212
- // let es = new eventSource(`${testRealmHref}_message`);
213
- // es.addEventListener('index', (ev: MessageEvent) => {
214
- // events.push(JSON.parse(ev.data));
215
- // if (events.length >= numEvents) {
216
- // defer.fulfill(events);
217
- // }
218
- // });
219
- // es.onerror = (err: Event) => defer.reject(err);
220
- // let timeout = setTimeout(() => {
221
- // defer.reject(
222
- // new Error(
223
- // `expectEvent timed out, saw events ${JSON.stringify(events)}`,
224
- // ),
225
- // );
226
- // }, 5000);
227
- // await new Promise((resolve) => es.addEventListener('open', resolve));
228
- // let result = await callback();
229
- // let actualEvents = await defer.promise;
230
- // if (expected) {
231
- // assert.deepEqual(actualEvents, expected);
232
- // }
233
- // if (onEvents) {
234
- // onEvents(actualEvents);
235
- // }
236
- // clearTimeout(timeout);
237
- // es.close();
238
- // return result;
239
- }
240
-
241
115
let testRealm : Realm ;
242
116
let testRealmPath : string ;
243
117
let testRealmHttpServer : Server ;
0 commit comments