fix: Add test user to backend test setup to satisfy foreign key const…

packages/backend/src/__tests__/climb-queries.test.ts

@@ -4,10 +4,12 @@ import type { ParsedBoardRouteParameters, ClimbSearchParams } from '../db/querie
 import { getSizeEdges } from '../db/queries/util/product-sizes-data.js';
 
 describe('Climb Query Functions', () => {
+  // Use valid size_id for kilter (7 = 12x14 Commercial)
+  // See packages/backend/src/db/queries/util/product-sizes-data.ts for valid IDs
   const testParams: ParsedBoardRouteParameters = {
     board_name: 'kilter',
     layout_id: 1,
-    size_id: 1,
+    size_id: 7,
     set_ids: [1, 2],
     angle: 40,
   };
@@ -231,7 +233,7 @@ describe('Climb Query Functions', () => {
       const result = await getClimbByUuid({
         board_name: 'kilter',
         layout_id: 1,
-        size_id: 1,
+        size_id: 7, // Valid kilter size_id
         angle: 40,
         climb_uuid: 'non-existent-uuid-12345',
       });
@@ -240,16 +242,16 @@ describe('Climb Query Functions', () => {
     });
 
     it('should handle different board names', async () => {
-      // Test with kilter
+      // Test with kilter (size_id 7 = 12x14 Commercial)
       const kilterResult = await getClimbByUuid({
         board_name: 'kilter',
         layout_id: 1,
-        size_id: 1,
+        size_id: 7,
         angle: 40,
         climb_uuid: 'test-uuid',
       });
 
-      // Test with tension
+      // Test with tension (size_id 1 = Full Wall)
       const tensionResult = await getClimbByUuid({
         board_name: 'tension',
         layout_id: 1,

packages/backend/src/__tests__/integration.test.ts

@@ -1,6 +1,7 @@
 import { describe, it, expect, beforeAll, afterAll, afterEach } from 'vitest';
 import { createClient, Client } from 'graphql-ws';
 import WebSocket from 'ws';
+import { v4 as uuidv4 } from 'uuid';
 import { startServer } from '../server.js';
 import type { ClimbQueueItem } from '@boardsesh/shared-schema';
 
@@ -12,12 +13,14 @@
 let testCounter = 0;
 const createTestSessionId = () => `test-session-${Date.now()}-${testCounter++}`;
 
-const createTestClimb = (uuid: string): ClimbQueueItem => ({
-  uuid,
+// Creates a test climb with valid UUIDs
+// The label parameter is just for debugging/naming, not used as UUID
+const createTestClimb = (label: string): ClimbQueueItem => ({
+  uuid: uuidv4(),
   climb: {
-    uuid: `climb-${uuid}`,
+    uuid: uuidv4(),
     setter_username: 'test-setter',
-    name: `Test Climb ${uuid}`,
+    name: `Test Climb ${label}`,
     description: 'A test climb',
     frames: 'test-frames',
     angle: 40,
@@ -49,7 +52,7 @@
       next: (data) => {
         if (data.errors) {
           console.error('GraphQL errors:', JSON.stringify(data.errors, null, 2));
           reject(new Error(data.errors[0].message));
           return;
         }
         result = data.data as T;
@@ -285,7 +288,7 @@
         variables: { item: testClimb },
       });
 
       expect(result.addQueueItem.uuid).toBe('test-climb-1');
       expect(result.addQueueItem.climb.name).toBe('Test Climb test-climb-1');
     });
 
@@ -309,7 +312,7 @@
         variables: { item: testClimb },
       });
 
       expect(result.setCurrentClimb.uuid).toBe('current-test');
     });
 
     it('should mirror current climb successfully', async () => {
@@ -333,7 +336,7 @@
         query: `mutation { mirrorCurrentClimb(mirrored: true) { uuid climb { mirrored } } }`,
       });
 
       expect(result.mirrorCurrentClimb.climb.mirrored).toBe(true);
     });
 
     it('should remove a queue item', async () => {
@@ -436,7 +439,7 @@
       // First event should be FullSync, second should be QueueItemAdded
       expect(events[0].__typename).toBe('FullSync');
       expect(events[1].__typename).toBe('QueueItemAdded');
       expect(events[1].item.uuid).toBe('sync-test');
     });
 
     it('should sync current climb changes across clients', async () => {
@@ -470,7 +473,7 @@
       const events = await eventPromise;
 
       expect(events[1].__typename).toBe('CurrentClimbChanged');
       expect(events[1].item.uuid).toBe('current-sync');
     });
 
     it('should sync queue reordering across clients', async () => {
@@ -761,7 +764,7 @@
         query: `query { session(sessionId: "${sessionId}") { queueState { queue { uuid } } users { id } } }`,
       });
 
       expect(result.session.queueState.queue).toHaveLength(1);
       expect(result.session.queueState.queue[0].uuid).toBe('persist-test');
       expect(result.session.users).toHaveLength(1); // Only client2 remains
     });

packages/backend/src/__tests__/session-persistence.test.ts

@@ -155,6 +155,17 @@ const createTestClimb = (): ClimbQueueItem => ({
   suggested: false,
 });
 
+// Helper to register client and join session
+const registerAndJoin = async (
+  clientId: string,
+  sessionId: string,
+  boardPath: string,
+  username: string
+) => {
+  roomManager.registerClient(clientId);
+  return roomManager.joinSession(clientId, sessionId, boardPath, username);
+};
+
 describe('Session Persistence - Hybrid Redis + Postgres', () => {
   let mockRedis: Redis;
 
@@ -177,7 +188,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const boardPath = '/kilter/1/2/3/40';
 
       // Create and join session
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
 
       // Verify active status
       let session = await db
@@ -207,7 +218,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const boardPath = '/kilter/1/2/3/40';
 
       // Create session, join, and leave
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       await roomManager.leaveSession('client-1');
 
       // Verify inactive
@@ -219,7 +230,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       expect(session[0]?.status).toBe('inactive');
 
       // Rejoin
-      await roomManager.joinSession('client-2', sessionId, boardPath, 'User2');
+      await registerAndJoin('client-2', sessionId, boardPath, 'User2');
 
       // Verify back to active
       session = await db
@@ -235,7 +246,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const boardPath = '/kilter/1/2/3/40';
 
       // Create session
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
 
       // End session
       await roomManager.endSession(sessionId);
@@ -260,7 +271,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const climb = createTestClimb();
 
       // Create session and add climb to queue
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       const currentState = await roomManager.getQueueState(sessionId);
       await roomManager.updateQueueState(sessionId, [climb], null, currentState.version);
 
@@ -272,7 +283,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       await roomManager.initialize(mockRedis);
 
       // Rejoin should restore from Redis
-      const result = await roomManager.joinSession('client-2', sessionId, boardPath, 'User2');
+      const result = await registerAndJoin('client-2', sessionId, boardPath, 'User2');
 
       // Verify queue was restored from Redis
       expect(result.queue).toHaveLength(1);
@@ -284,7 +295,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const boardPath = '/kilter/1/2/3/40';
 
       // Create session and make it inactive
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       await roomManager.leaveSession('client-1');
 
       // Clear in-memory state
@@ -293,9 +304,9 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
 
       // Multiple users join concurrently
       const results = await Promise.all([
-        roomManager.joinSession('client-2', sessionId, boardPath, 'User2'),
-        roomManager.joinSession('client-3', sessionId, boardPath, 'User3'),
-        roomManager.joinSession('client-4', sessionId, boardPath, 'User4'),
+        registerAndJoin('client-2', sessionId, boardPath, 'User2'),
+        registerAndJoin('client-3', sessionId, boardPath, 'User3'),
+        registerAndJoin('client-4', sessionId, boardPath, 'User4'),
       ]);
 
       // Verify all joined successfully
@@ -312,7 +323,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const climb = createTestClimb();
 
       // Create session and add climb to queue
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       const currentState = await roomManager.getQueueState(sessionId);
       await roomManager.updateQueueState(sessionId, [climb], null, currentState.version);
 
@@ -330,7 +341,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       await roomManager.initialize(mockRedis);
 
       // Rejoin should restore from Postgres
-      const result = await roomManager.joinSession('client-2', sessionId, boardPath, 'User2');
+      const result = await registerAndJoin('client-2', sessionId, boardPath, 'User2');
 
       // Verify queue was restored from Postgres
       expect(result.queue).toHaveLength(1);
@@ -342,15 +353,15 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const boardPath = '/kilter/1/2/3/40';
 
       // Create and end session
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       await roomManager.endSession(sessionId);
 
       // Clear in-memory state
       roomManager.reset();
       await roomManager.initialize(mockRedis);
 
       // Try to rejoin ended session - should create a new session instead of restoring
-      const result = await roomManager.joinSession('client-2', sessionId, boardPath, 'User2');
+      const result = await registerAndJoin('client-2', sessionId, boardPath, 'User2');
 
       // Session should be created fresh (empty queue)
       expect(result.queue).toHaveLength(0);
@@ -373,7 +384,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const climb2 = createTestClimb();
 
       // Create session
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
 
       // Add multiple climbs rapidly
       let currentState = await roomManager.getQueueState(sessionId);
@@ -414,7 +425,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const climb = createTestClimb();
 
       // Create session and update queue
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       const currentState = await roomManager.getQueueState(sessionId);
       await roomManager.updateQueueState(sessionId, [climb], null, currentState.version);
 
@@ -439,7 +450,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const climb2 = createTestClimb();
 
       // Create session
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
 
       // First update
       let currentState = await roomManager.getQueueState(sessionId);
@@ -496,7 +507,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
         'Test Session'
       );
 
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
 
       // Query nearby sessions
       const nearby = await roomManager.findNearbySessions(37.7749, -122.4194, 10000);
@@ -520,7 +531,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
         'Test Session'
       );
 
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       await roomManager.leaveSession('client-1');
 
       // Clear in-memory state but Redis still has it
@@ -549,7 +560,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
         'Test Session'
       );
 
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       await roomManager.leaveSession('client-1');
 
       // Clear both in-memory and Redis (simulate TTL expiry)
@@ -581,7 +592,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
         'Test Session'
       );
 
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       await roomManager.endSession(sessionId);
 
       // Query nearby sessions
@@ -603,7 +614,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const climb = createTestClimb();
 
       // Should still work
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       const currentState = await roomManager.getQueueState(sessionId);
       await roomManager.updateQueueState(sessionId, [climb], null, currentState.version);
 
@@ -633,15 +644,15 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const boardPath = '/kilter/1/2/3/40';
 
       // Create session and leave
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       await roomManager.leaveSession('client-1');
 
       // Reset (simulate server restart)
       roomManager.reset();
       await roomManager.initialize();
 
       // Try to rejoin - should create new session (no restoration in Postgres-only mode)
-      const result = await roomManager.joinSession('client-2', sessionId, boardPath, 'User2');
+      const result = await registerAndJoin('client-2', sessionId, boardPath, 'User2');
 
       // Should be fresh session
       expect(result.queue).toHaveLength(0);
@@ -655,7 +666,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const climb = createTestClimb();
 
       // Create session and update queue
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       const currentState = await roomManager.getQueueState(sessionId);
       await roomManager.updateQueueState(sessionId, [climb], null, currentState.version);
 
@@ -681,8 +692,8 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const boardPath = '/kilter/1/2/3/40';
 
       // Create session
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
-      await roomManager.joinSession('client-2', sessionId, boardPath, 'User2');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-2', sessionId, boardPath, 'User2');
 
       // Verify users in Redis
       const redisHashes = (mockRedis as any)._hashes as Map<string, Record<string, string>>;
@@ -700,7 +711,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
       const sessionId = uuidv4();
       const boardPath = '/kilter/1/2/3/40';
 
-      await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+      await registerAndJoin('client-1', sessionId, boardPath, 'User1');
 
       // Simulate concurrent updates with same version
       const currentState = await roomManager.getQueueState(sessionId);
@@ -733,7 +744,7 @@ describe('Session Persistence - Hybrid Redis + Postgres', () => {
 
       // Should not crash, might fall back to Postgres-only behavior
       await expect(async () => {
-        await roomManager.joinSession('client-1', sessionId, boardPath, 'User1');
+        await registerAndJoin('client-1', sessionId, boardPath, 'User1');
       }).rejects.toThrow();
     });
   });