+
+
{#if loading}
-
Loading room details...
+
Connecting to room...
{:else if error}
{error}
-
+
+ {:else if isCompetitionActive}
+
+
+
+
+
+
+
+
+ Competition Streams
+
+
+
+
+
+
+
+
+
+ {#each Object.entries(remoteUsers) as [uid, _]}
+
+
+
+ {participants.find((p) => p.userId === uid)?.name || 'Participant'}
+
+
+ {/each}
+
+
+ {#if Object.keys(remoteUsers).length < 3}
+
+ {#each Array(3 - Object.keys(remoteUsers).length) as _}
+
+
Waiting for participant...
+
+ {/each}
+ {/if}
+
+
+
+
+
+
+
{:else}
+
- {room?.name || 'Competition Room'}
+ Competition Room
Room ID: {roomId}
@@ -158,9 +399,9 @@
- {#if participant.user.image}
+ {#if participant.image}
-
+
@@ -172,8 +413,8 @@
diff --git a/src/routes/(app)/compete/[roomId]/play/+page.svelte b/src/routes/(app)/compete/[roomId]/play/+page.svelte
deleted file mode 100644
index 4d8b451..0000000
--- a/src/routes/(app)/compete/[roomId]/play/+page.svelte
+++ /dev/null
@@ -1,555 +0,0 @@
-
-
-
- {#if loading}
-
-
-
-
Setting up competition room...
-
-
- {:else if error}
-
- {error}
-
-
-
-
- {:else}
-
-
Live Competition
-
-
-
-
-
- {#if localStream}
-
-
- You (Live) - Score: {participantScores[$session.data?.user.id || ''] || 0}
-
- {:else}
-
- {/if}
-
-
-
-
-
Leaderboard
-
-
-
- {#each getSortedParticipants() as participant, index}
- {#if participant.user.id !== $session.data?.user.id}
-
-
-
- {#if index < 3}
-
- {:else}
- {index + 1}
- {/if}
-
-
-
- {#if participant.user.image}
-
- {:else}
-
- {participant.user.name?.charAt(0) || '?'}
-
- {/if}
-
-
-
- {participant.user.name}
- Score: {participantScores[participant.user.id] || 0}
-
-
-
-
- {#if remoteStreams[participant.user.id]}
-
-
-
-
-
- {#if connectionStates[participant.user.id] === 'connected' || connectionStates[participant.user.id] === 'completed'}
-
-
- Connected
-
- {:else if connectionStates[participant.user.id] === 'disconnected'}
-
-
- Reconnecting...
-
- {:else if connectionStates[participant.user.id] === 'failed'}
-
-
- Connection failed
-
- {:else}
-
-
- {connectionStates[participant.user.id] || 'Connecting'}
-
- {/if}
-
-
-
- {#if streamInfo[participant.user.id]}
-
- V: {streamInfo[participant.user.id].videoTracks}
- A: {streamInfo[participant.user.id].audioTracks}
-
- {/if}
-
- {:else}
-
-
- {connectionStates[participant.user.id] === 'checking'
- ? 'Connecting...'
- : connectionStates[participant.user.id] === 'failed'
- ? 'Connection failed'
- : connectionStates[participant.user.id] === 'disconnected'
- ? 'Reconnecting...'
- : 'Waiting for connection'}
-
-
- {/if}
-
- {/if}
- {/each}
-
-
- {/if}
-
diff --git a/src/routes/api/rooms/+server.ts b/src/routes/api/rooms/+server.ts
deleted file mode 100644
index bde1084..0000000
--- a/src/routes/api/rooms/+server.ts
+++ /dev/null
@@ -1,80 +0,0 @@
-import { json } from '@sveltejs/kit';
-import prisma from '$lib/prisma';
-import type { RequestHandler } from './$types';
-import { auth } from '$lib/auth';
-
-export const POST: RequestHandler = async ({ request }) => {
- try {
- const session = await auth.api.getSession({
- headers: request.headers
- });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const { name } = await request.json();
-
- const room = await prisma.room.create({
- data: {
- name: name || null,
- creatorId: session.user.id,
- participants: {
- create: {
- userId: session.user.id
- }
- },
- status: 'STARTING'
- }
- });
-
- return json(room);
- } catch (error) {
- console.error('Error creating room:', error);
- return json({ message: 'Failed to create room' }, { status: 500 });
- }
-};
-
-export const GET: RequestHandler = async ({ request }) => {
- try {
- const session = await auth.api.getSession({
- headers: request.headers
- });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const rooms = await prisma.room.findMany({
- where: {
- participants: {
- some: {
- userId: session.user.id
- }
- }
- },
- include: {
- creator: {
- select: {
- id: true,
- name: true,
- image: true
- }
- },
- _count: {
- select: {
- participants: true
- }
- }
- },
- orderBy: {
- createdAt: 'desc'
- }
- });
-
- return json({ rooms });
- } catch (error) {
- console.error('Error fetching rooms:', error);
- return json({ message: 'Failed to fetch rooms' }, { status: 500 });
- }
-};
diff --git a/src/routes/api/rooms/[roomId]/+server.ts b/src/routes/api/rooms/[roomId]/+server.ts
deleted file mode 100644
index 7b890ab..0000000
--- a/src/routes/api/rooms/[roomId]/+server.ts
+++ /dev/null
@@ -1,102 +0,0 @@
-import { json } from '@sveltejs/kit';
-import prisma from '$lib/prisma';
-import type { RequestHandler } from './$types';
-import { auth } from '$lib/auth';
-
-export const GET: RequestHandler = async ({ request, params }) => {
- try {
- const session = await auth.api.getSession({
- headers: request.headers
- });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const roomId = params.roomId;
-
- const room = await prisma.room.findUnique({
- where: {
- id: roomId
- },
- include: {
- creator: {
- select: {
- id: true,
- name: true,
- image: true
- }
- }
- }
- });
-
- if (!room) {
- return json({ message: 'Room not found' }, { status: 404 });
- }
-
- const participants = await prisma.roomParticipant.findMany({
- where: {
- roomId,
- },
- include: {
- user: {
- select: {
- id: true,
- name: true,
- image: true
- }
- }
- },
- orderBy: {
- joinedAt: 'asc'
- }
- });
-
- return json({ room, participants });
- } catch (error) {
- console.error('Error fetching room details:', error);
- return json({ message: 'Failed to fetch room details' }, { status: 500 });
- }
-};
-
-export const DELETE: RequestHandler = async ({ request, params }) => {
- try {
- const session = await auth.api.getSession({
- headers: request.headers
- });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const roomId = params.roomId;
-
- const room = await prisma.room.findUnique({
- where: {
- id: roomId
- }
- });
-
- if (!room) {
- return json({ message: 'Room not found' }, { status: 404 });
- }
-
- if (room.creatorId !== session.user.id) {
- return json({ message: 'Only the room creator can delete this room' }, { status: 403 });
- }
-
- await prisma.room.update({
- where: {
- id: roomId
- },
- data: {
- status: 'CLOSED'
- }
- });
-
- return json({ message: 'Room successfully deleted' });
- } catch (error) {
- console.error('Error deleting room:', error);
- return json({ message: 'Failed to delete room' }, { status: 500 });
- }
-};
diff --git a/src/routes/api/rooms/[roomId]/join/+server.ts b/src/routes/api/rooms/[roomId]/join/+server.ts
deleted file mode 100644
index d5bec9f..0000000
--- a/src/routes/api/rooms/[roomId]/join/+server.ts
+++ /dev/null
@@ -1,56 +0,0 @@
-import { auth } from '$lib/auth';
-import prisma from '$lib/prisma';
-import { json } from '@sveltejs/kit';
-import type { RequestHandler } from './$types';
-
-export const POST: RequestHandler = async ({ request, params }) => {
- try {
- const session = await auth.api.getSession({
- headers: request.headers
- });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const roomId = params.roomId;
-
- const room = await prisma.room.findUnique({
- where: {
- id: roomId,
- status: 'STARTING'
- }
- });
-
- if (!room) {
- return json({ message: 'Room not found or inactive' }, { status: 404 });
- }
-
- // Check if user is already a participant
- const existingParticipant = await prisma.roomParticipant.findUnique({
- where: {
- roomId_userId: {
- roomId,
- userId: session.user.id
- }
- }
- });
-
- if (existingParticipant) {
- return json({ message: 'You are already in this room' });
- }
-
- // Create new participant
- await prisma.roomParticipant.create({
- data: {
- roomId,
- userId: session.user.id
- }
- });
-
- return json({ message: 'Joined room successfully' });
- } catch (error) {
- console.error('Error joining room:', error);
- return json({ message: 'Failed to join room' }, { status: 500 });
- }
-};
diff --git a/src/routes/api/rooms/[roomId]/leave/+server.ts b/src/routes/api/rooms/[roomId]/leave/+server.ts
deleted file mode 100644
index 9ad26e6..0000000
--- a/src/routes/api/rooms/[roomId]/leave/+server.ts
+++ /dev/null
@@ -1,65 +0,0 @@
-import { json } from '@sveltejs/kit';
-import prisma from '$lib/prisma';
-import type { RequestHandler } from './$types';
-import { auth } from '$lib/auth';
-
-export const POST: RequestHandler = async ({ request, params }) => {
- try {
- const session = await auth.api.getSession({ headers: request.headers });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const roomId = params.roomId;
-
- const participant = await prisma.roomParticipant.findUnique({
- where: {
- roomId_userId: {
- roomId,
- userId: session.user.id
- }
- }
- });
-
- if (!participant) {
- return json({ message: 'You are not a participant in this room' }, { status: 404 });
- }
-
- // Check if user is the creator
- const room = await prisma.room.findUnique({
- where: {
- id: roomId
- }
- });
-
- if (room?.creatorId === session.user.id) {
- // If creator is leaving, mark the room as inactive
- await prisma.room.update({
- where: {
- id: roomId
- },
- data: {
- status: 'CLOSED'
- }
- });
-
- // Mark all participants as inactive
- await prisma.roomParticipant.deleteMany({
- where: { roomId }
- });
-
- return json({ message: 'Room closed successfully' });
- } else {
- // Just mark this participant as inactive
- await prisma.roomParticipant.delete({
- where: { id: participant.id }
- });
-
- return json({ message: 'Left room successfully' });
- }
- } catch (error) {
- console.error('Error leaving room:', error);
- return json({ message: 'Failed to leave room' }, { status: 500 });
- }
-};
diff --git a/src/routes/api/rooms/[roomId]/signaling/+server.ts b/src/routes/api/rooms/[roomId]/signaling/+server.ts
deleted file mode 100644
index b90ad67..0000000
--- a/src/routes/api/rooms/[roomId]/signaling/+server.ts
+++ /dev/null
@@ -1,122 +0,0 @@
-import { json } from '@sveltejs/kit';
-import prisma from '$lib/prisma';
-import type { RequestHandler } from './$types';
-import { auth } from '$lib/auth';
-
-// In-memory store for pending messages
-// In a production app, you'd use Redis or another solution
-// eslint-disable-next-line @typescript-eslint/no-explicit-any
-const messageQueues: Record
= {};
-
-export const GET: RequestHandler = async ({ request, params }) => {
- try {
- const session = await auth.api.getSession({
- headers: request.headers
- });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const roomId = params.roomId;
- const userId = session.user.id;
-
- // Check if user is a participant
- const participant = await prisma.roomParticipant.findUnique({
- where: {
- roomId_userId: {
- roomId,
- userId
- }
- }
- });
-
- if (!participant) {
- return json({ message: 'You are not a participant in this room' }, { status: 404 });
- }
-
- // Set up SSE response
- const headers = new Headers({
- 'Content-Type': 'text/event-stream',
- 'Cache-Control': 'no-cache',
- Connection: 'keep-alive'
- });
-
- const stream = new ReadableStream({
- start(controller) {
- // Initialize message queue for this user
- if (!messageQueues[userId]) {
- messageQueues[userId] = [];
- }
-
- const intervalId = setInterval(() => {
- if (messageQueues[userId] && messageQueues[userId].length > 0) {
- const message = messageQueues[userId].shift();
- const data = `data: ${JSON.stringify(message)}\n\n`;
- controller.enqueue(new TextEncoder().encode(data));
- }
- }, 100);
-
- // Clean up when connection closes
- request.signal.addEventListener('abort', () => {
- clearInterval(intervalId);
- });
- }
- });
-
- return new Response(stream, { headers });
- } catch (error) {
- console.error('Error in signaling:', error);
- return json({ message: 'Failed to establish signaling' }, { status: 500 });
- }
-};
-
-export const POST: RequestHandler = async ({ request, params }) => {
- try {
- const session = await auth.api.getSession({
- headers: request.headers
- });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const roomId = params.roomId;
- const userId = session.user.id;
-
- // Check if user is a participant
- const participant = await prisma.roomParticipant.findUnique({
- where: {
- roomId_userId: {
- roomId,
- userId
- }
- }
- });
-
- if (!participant) {
- return json({ message: 'You are not a participant in this room' }, { status: 404 });
- }
-
- const message = await request.json();
-
- // Validate message
- if (!message.to || !message.type) {
- return json({ message: 'Invalid signaling message' }, { status: 400 });
- }
-
- // Add sender info
- message.from = userId;
-
- // Queue message for recipient
- if (!messageQueues[message.to]) {
- messageQueues[message.to] = [];
- }
- messageQueues[message.to].push(message);
-
- return json({ success: true });
- } catch (error) {
- console.error('Error in signaling:', error);
- return json({ message: 'Failed to send signaling message' }, { status: 500 });
- }
-};
diff --git a/src/routes/api/rooms/[roomId]/start/+server.ts b/src/routes/api/rooms/[roomId]/start/+server.ts
deleted file mode 100644
index 5ea1804..0000000
--- a/src/routes/api/rooms/[roomId]/start/+server.ts
+++ /dev/null
@@ -1,49 +0,0 @@
-import { json } from '@sveltejs/kit';
-import prisma from '$lib/prisma';
-import type { RequestHandler } from './$types';
-import { auth } from '$lib/auth';
-
-export const POST: RequestHandler = async ({ request, params }) => {
- try {
- const session = await auth.api.getSession({
- headers: request.headers
- });
-
- if (!session) {
- return json({ message: 'Unauthorized' }, { status: 401 });
- }
-
- const roomId = params.roomId;
-
- // Check if the user is the room creator
- const room = await prisma.room.findUnique({
- where: {
- id: roomId,
- status: 'STARTING'
- }
- });
-
- if (!room) {
- return json({ message: 'Room not found' }, { status: 404 });
- }
-
- if (room.creatorId !== session.user.id) {
- return json({ message: 'Only the room creator can start the competition' }, { status: 403 });
- }
-
- // Update room status to indicate competition has started
- await prisma.room.update({
- where: {
- id: roomId
- },
- data: {
- status: 'ACTIVE'
- }
- });
-
- return json({ message: 'Competition started successfully' });
- } catch (error) {
- console.error('Error starting competition:', error);
- return json({ message: 'Failed to start competition' }, { status: 500 });
- }
-};