93 lines
3.0 KiB
JavaScript
93 lines
3.0 KiB
JavaScript
import { describe, it, expect, beforeEach } from 'vitest'
|
|
import {
|
|
createSession,
|
|
getLiveSession,
|
|
updateLiveSession,
|
|
deleteLiveSession,
|
|
getActiveSessions,
|
|
getActiveSessionByUserId,
|
|
clearSessions,
|
|
} from '../../../server/utils/liveSessions.js'
|
|
|
|
describe('liveSessions', () => {
|
|
let sessionId
|
|
|
|
beforeEach(() => {
|
|
clearSessions()
|
|
sessionId = createSession('test-user', 'Test Session').id
|
|
})
|
|
|
|
it('creates a session with WebRTC fields', () => {
|
|
const session = getLiveSession(sessionId)
|
|
expect(session).toBeDefined()
|
|
expect(session.id).toBe(sessionId)
|
|
expect(session.userId).toBe('test-user')
|
|
expect(session.label).toBe('Test Session')
|
|
expect(session.routerId).toBeNull()
|
|
expect(session.producerId).toBeNull()
|
|
expect(session.transportId).toBeNull()
|
|
})
|
|
|
|
it('updates location', () => {
|
|
updateLiveSession(sessionId, { lat: 37.7, lng: -122.4 })
|
|
const session = getLiveSession(sessionId)
|
|
expect(session.lat).toBe(37.7)
|
|
expect(session.lng).toBe(-122.4)
|
|
})
|
|
|
|
it('updates WebRTC fields', () => {
|
|
updateLiveSession(sessionId, { routerId: 'router-1', producerId: 'producer-1', transportId: 'transport-1' })
|
|
const session = getLiveSession(sessionId)
|
|
expect(session.routerId).toBe('router-1')
|
|
expect(session.producerId).toBe('producer-1')
|
|
expect(session.transportId).toBe('transport-1')
|
|
})
|
|
|
|
it('returns hasStream instead of hasSnapshot', async () => {
|
|
updateLiveSession(sessionId, { producerId: 'producer-1' })
|
|
const active = await getActiveSessions()
|
|
const session = active.find(s => s.id === sessionId)
|
|
expect(session).toBeDefined()
|
|
expect(session.hasStream).toBe(true)
|
|
})
|
|
|
|
it('returns hasStream false when no producer', async () => {
|
|
const active = await getActiveSessions()
|
|
const session = active.find(s => s.id === sessionId)
|
|
expect(session).toBeDefined()
|
|
expect(session.hasStream).toBe(false)
|
|
})
|
|
|
|
it('deletes a session', () => {
|
|
deleteLiveSession(sessionId)
|
|
const session = getLiveSession(sessionId)
|
|
expect(session).toBeUndefined()
|
|
})
|
|
|
|
it('getActiveSessionByUserId returns session for same user when active', () => {
|
|
const found = getActiveSessionByUserId('test-user')
|
|
expect(found).toBeDefined()
|
|
expect(found.id).toBe(sessionId)
|
|
})
|
|
|
|
it('getActiveSessionByUserId returns undefined for unknown user', () => {
|
|
const found = getActiveSessionByUserId('other-user')
|
|
expect(found).toBeUndefined()
|
|
})
|
|
|
|
it('getActiveSessionByUserId returns undefined for expired session', () => {
|
|
const session = getLiveSession(sessionId)
|
|
session.updatedAt = Date.now() - 120_000
|
|
const found = getActiveSessionByUserId('test-user')
|
|
expect(found).toBeUndefined()
|
|
})
|
|
|
|
it('getActiveSessions removes expired sessions', async () => {
|
|
const session = getLiveSession(sessionId)
|
|
session.updatedAt = Date.now() - 120_000
|
|
const active = await getActiveSessions()
|
|
expect(active.find(s => s.id === sessionId)).toBeUndefined()
|
|
expect(getLiveSession(sessionId)).toBeUndefined()
|
|
})
|
|
})
|