Hide_D
50068224c8
토너먼트 state의 stage 전이만 공용 실시간 채널에 발행하고 공개 invalidation으로 변환한다. 메인 dashboard store가 단계 값을 소유해 상단 문구와 메뉴 강조를 단일/다중 탭에서 함께 갱신한다. Redis 통합 테스트와 production Chromium 회귀 검증을 추가한다.
101 lines
4.0 KiB
TypeScript
101 lines
4.0 KiB
TypeScript
import { randomUUID } from 'node:crypto';
|
|
|
|
import { afterAll, beforeAll, describe, expect, it } from 'vitest';
|
|
import { createRedisConnector, resolveRedisConfigFromEnv, type RedisConnector } from '@sammo-ts/infra';
|
|
|
|
import { buildTournamentKeys } from '../src/tournament/keys.js';
|
|
import { TournamentStore } from '../src/tournament/store.js';
|
|
|
|
const integration = describe.skipIf(!process.env.REDIS_URL);
|
|
|
|
integration('TournamentStore Redis source revision', () => {
|
|
let connector: RedisConnector;
|
|
let subscriber: RedisConnector;
|
|
const profile = `test:tournament-revision:${randomUUID()}`;
|
|
const keys = buildTournamentKeys(profile);
|
|
const sourceMessages: string[] = [];
|
|
const realtimeMessages: string[] = [];
|
|
|
|
const waitForLength = async (values: readonly string[], length: number): Promise<void> => {
|
|
const deadline = Date.now() + 1_000;
|
|
while (values.length < length && Date.now() < deadline) {
|
|
await new Promise((resolve) => setTimeout(resolve, 5));
|
|
}
|
|
expect(values).toHaveLength(length);
|
|
};
|
|
|
|
beforeAll(async () => {
|
|
connector = createRedisConnector(resolveRedisConfigFromEnv());
|
|
subscriber = createRedisConnector(resolveRedisConfigFromEnv());
|
|
await connector.connect();
|
|
await subscriber.connect();
|
|
await subscriber.client.subscribe(keys.sourceRevisionChannel, (message) => sourceMessages.push(message));
|
|
await subscriber.client.subscribe(keys.realtimeEventChannel, (message) => realtimeMessages.push(message));
|
|
});
|
|
|
|
afterAll(async () => {
|
|
if (!connector) return;
|
|
await connector.client.del([
|
|
keys.stateKey,
|
|
keys.participantsKey,
|
|
keys.matchesKey,
|
|
keys.bettingKey,
|
|
keys.sourceRevisionKey,
|
|
]);
|
|
if (subscriber) {
|
|
await subscriber.client.unsubscribe(keys.sourceRevisionChannel);
|
|
await subscriber.client.unsubscribe(keys.realtimeEventChannel);
|
|
await subscriber.disconnect();
|
|
}
|
|
await connector.disconnect();
|
|
});
|
|
|
|
it('commits concurrent payload writes with unique monotonic revisions', async () => {
|
|
const store = new TournamentStore(connector.client, keys);
|
|
const revisions = await Promise.all(
|
|
Array.from({ length: 20 }, (_, index) =>
|
|
store.setMatches([
|
|
{ id: index + 1, stage: 7, roundIndex: index, attackerId: 1, defenderId: 2 },
|
|
])
|
|
)
|
|
);
|
|
|
|
expect(new Set(revisions).size).toBe(20);
|
|
await expect(store.getSourceRevision()).resolves.toBe('20');
|
|
await expect(store.getMatches()).resolves.toHaveLength(1);
|
|
});
|
|
|
|
it('publishes the main wake-up only when the atomic state write changes stage', async () => {
|
|
const store = new TournamentStore(connector.client, keys);
|
|
const sourceBefore = sourceMessages.length;
|
|
const realtimeBefore = realtimeMessages.length;
|
|
const baseState = {
|
|
stage: 1,
|
|
phase: 0,
|
|
type: 0 as const,
|
|
auto: true,
|
|
openYear: 185,
|
|
openMonth: 2,
|
|
termSeconds: 10,
|
|
nextAt: '2026-08-17T00:00:00.000Z',
|
|
};
|
|
|
|
await store.setState(baseState);
|
|
await waitForLength(sourceMessages, sourceBefore + 1);
|
|
await waitForLength(realtimeMessages, realtimeBefore + 1);
|
|
|
|
await store.setState({ ...baseState, phase: 1 });
|
|
await waitForLength(sourceMessages, sourceBefore + 2);
|
|
await new Promise<void>((resolve) => setImmediate(resolve));
|
|
expect(realtimeMessages).toHaveLength(realtimeBefore + 1);
|
|
|
|
await store.setState({ ...baseState, stage: 2, phase: 0 });
|
|
await waitForLength(sourceMessages, sourceBefore + 3);
|
|
await waitForLength(realtimeMessages, realtimeBefore + 2);
|
|
expect(realtimeMessages.slice(realtimeBefore)).toEqual([
|
|
JSON.stringify({ type: 'tournamentChanged' }),
|
|
JSON.stringify({ type: 'tournamentChanged' }),
|
|
]);
|
|
});
|
|
});
|