wehub-resource-sync
128 lines
4.1 KiB
TypeScript
128 lines
4.1 KiB
TypeScript
import { beforeEach, describe, expect, it } from 'vitest';
|
|
import { RealtimePresenceService } from '../../src/services/realtime/realtime-presence.service';
|
|
|
|
describe('RealtimePresenceService', () => {
|
|
const service = RealtimePresenceService.getInstance();
|
|
|
|
beforeEach(() => {
|
|
service.clear();
|
|
});
|
|
|
|
it('tracks the first member in a room and returns the snapshot', () => {
|
|
const result = service.trackMember('realtime:chat:lobby', 'socket-1', {
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
joinedAt: '2026-04-26T00:00:00.000Z',
|
|
});
|
|
|
|
expect(result.joinedMember).toMatchObject({
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
});
|
|
expect(result.presence.members).toEqual([result.joinedMember!]);
|
|
});
|
|
|
|
it('deduplicates multiple sockets for the same user into one logical member', () => {
|
|
const first = service.trackMember('realtime:chat:lobby', 'socket-1', {
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
joinedAt: '2026-04-26T00:00:00.000Z',
|
|
});
|
|
|
|
const second = service.trackMember('realtime:chat:lobby', 'socket-2', {
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
joinedAt: '2026-04-26T00:01:00.000Z',
|
|
});
|
|
|
|
expect(first.joinedMember).toBeDefined();
|
|
expect(second.joinedMember).toBeUndefined();
|
|
expect(second.presence.members).toEqual([first.joinedMember!]);
|
|
});
|
|
|
|
it('tracks anonymous sockets independently when there is no human user identity', () => {
|
|
const first = service.trackMember('realtime:chat:lobby', 'socket-1', {
|
|
type: 'anonymous',
|
|
presenceId: 'socket-1',
|
|
joinedAt: '2026-04-26T00:00:00.000Z',
|
|
});
|
|
|
|
const second = service.trackMember('realtime:chat:lobby', 'socket-2', {
|
|
type: 'anonymous',
|
|
presenceId: 'socket-2',
|
|
joinedAt: '2026-04-26T00:01:00.000Z',
|
|
});
|
|
|
|
expect(first.joinedMember).toBeDefined();
|
|
expect(second.joinedMember).toBeDefined();
|
|
expect(second.presence.members).toEqual([
|
|
{
|
|
type: 'anonymous',
|
|
presenceId: 'socket-1',
|
|
joinedAt: first.joinedMember!.joinedAt,
|
|
},
|
|
{
|
|
type: 'anonymous',
|
|
presenceId: 'socket-2',
|
|
joinedAt: second.joinedMember!.joinedAt,
|
|
},
|
|
]);
|
|
});
|
|
|
|
it('does not emit a leave when another socket still represents the same member', () => {
|
|
service.trackMember('realtime:chat:lobby', 'socket-1', {
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
joinedAt: '2026-04-26T00:00:00.000Z',
|
|
});
|
|
service.trackMember('realtime:chat:lobby', 'socket-2', {
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
joinedAt: '2026-04-26T00:01:00.000Z',
|
|
});
|
|
|
|
const result = service.removeSocketFromRoom('realtime:chat:lobby', 'socket-1');
|
|
|
|
expect(result).toBeNull();
|
|
expect(service.getPresence('realtime:chat:lobby').members).toHaveLength(1);
|
|
expect(service.getPresence('realtime:chat:lobby').members[0]?.presenceId).toBe('user-1');
|
|
});
|
|
|
|
it('emits a leave when the final socket for a member disconnects', () => {
|
|
const join = service.trackMember('realtime:chat:lobby', 'socket-1', {
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
joinedAt: '2026-04-26T00:00:00.000Z',
|
|
});
|
|
|
|
const result = service.removeSocketFromRoom('realtime:chat:lobby', 'socket-1');
|
|
|
|
expect(join.joinedMember).toBeDefined();
|
|
expect(result).toEqual(join.joinedMember);
|
|
expect(service.getPresence('realtime:chat:lobby').members).toEqual([]);
|
|
});
|
|
|
|
it('removes a socket from every subscribed room during disconnect cleanup', () => {
|
|
service.trackMember('realtime:chat:lobby', 'socket-1', {
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
joinedAt: '2026-04-26T00:00:00.000Z',
|
|
});
|
|
service.trackMember('realtime:alerts', 'socket-1', {
|
|
type: 'user',
|
|
presenceId: 'user-1',
|
|
joinedAt: '2026-04-26T00:00:00.000Z',
|
|
});
|
|
|
|
const results = service.removeSocketFromAllRooms('socket-1');
|
|
|
|
expect(results).toHaveLength(2);
|
|
expect(results.map((result) => result.roomName).sort()).toEqual([
|
|
'realtime:alerts',
|
|
'realtime:chat:lobby',
|
|
]);
|
|
expect(service.getPresence('realtime:chat:lobby').members).toEqual([]);
|
|
expect(service.getPresence('realtime:alerts').members).toEqual([]);
|
|
});
|
|
});
|