test: follow public realtime event contract
This commit is contained in:
@@ -655,8 +655,7 @@ describe('pm2 orchestrator e2e', () => {
|
|||||||
const ssePromise = waitForSseEvent({
|
const ssePromise = waitForSseEvent({
|
||||||
url: `${gameUrl}${eventsPath}`,
|
url: `${gameUrl}${eventsPath}`,
|
||||||
token: accessTokenRef.value ?? '',
|
token: accessTokenRef.value ?? '',
|
||||||
eventName: 'turnCompleted',
|
eventName: 'readModelInvalidated',
|
||||||
minAtMs: runStartMs,
|
|
||||||
timeoutMs: 30_000,
|
timeoutMs: 30_000,
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -664,7 +663,8 @@ describe('pm2 orchestrator e2e', () => {
|
|||||||
expect(runStatus.lastRunAt).toBeTruthy();
|
expect(runStatus.lastRunAt).toBeTruthy();
|
||||||
|
|
||||||
const realtimeEvent = await ssePromise;
|
const realtimeEvent = await ssePromise;
|
||||||
expect(realtimeEvent.type).toBe('turnCompleted');
|
expect(realtimeEvent.type).toBe('readModelInvalidated');
|
||||||
|
expect(realtimeEvent.invalidation).toBeTypeOf('object');
|
||||||
|
|
||||||
const gameDatabaseUrl = resolvePostgresConfigFromEnv({ schema: profile }).url;
|
const gameDatabaseUrl = resolvePostgresConfigFromEnv({ schema: profile }).url;
|
||||||
const connector = createGamePostgresConnector({ url: gameDatabaseUrl });
|
const connector = createGamePostgresConnector({ url: gameDatabaseUrl });
|
||||||
|
|||||||
Reference in New Issue
Block a user