chore: cleanup livekit api routes

src/app/(protected)/api/livekit/broadcasterToken/route.ts

@@ -1,102 +0,0 @@
-import { validateRequest } from '@/lib/auth';
-import prisma from '@/lib/db';
-import { Track, VideoQuality } from 'livekit-client';
-import { IngressAudioEncodingPreset, IngressAudioOptions, IngressInput, IngressVideoEncodingPreset, IngressVideoOptions, TrackSource, VideoCodec } from 'livekit-server-sdk';
-
-export async function POST(request: Request) {
-  const { ingressClient, roomService } = await import('@/lib/services/livekit');
-  try {
-    const { user } = await validateRequest();
-    if (!user) {
-      return new Response('Unauthorized', { status: 401 });
-    }
-
-    const body = await request.json();
-    const { channel } = body;
-
-    const channelInfo = await prisma.channel.findUnique({
-      where: { name: channel },
-      include: {
-        owner: true,
-        managers: true
-      }
-    });
-
-    if (!channelInfo) {
-      return new Response('Channel not found', { status: 404 });
-    }
-
-    const isBroadcaster = 
-      channelInfo.ownerId === user.id || 
-      channelInfo.managers.some(m => m.id === user.id);
-
-    if (!isBroadcaster) {
-      return new Response('Unauthorized', { status: 401 });
-    }
-
-    // clean up existing resources
-    const ingresses = await ingressClient.listIngress();
-    const channelIngresses = ingresses.filter(ingress => ingress.name === channel);
-    
-    for (const ingress of channelIngresses) {
-      await ingressClient.deleteIngress(ingress.ingressId);
-    }
-
-    // reset and create room
-    const existingRoom = await roomService.listRooms()
-      .then(rooms => rooms.find(r => r.name === channel));
-
-    if (existingRoom) {
-      await roomService.deleteRoom(existingRoom.name);
-    }
-    
-    await roomService.createRoom({ name: channel });
-
-    // create new ingress
-    const ingress = await ingressClient.createIngress(IngressInput.RTMP_INPUT, {
-      name: channel,
-      roomName: channel,
-      participantIdentity: 'streamer',
-      video: new IngressVideoOptions({
-        source: TrackSource.CAMERA,
-        encodingOptions: {
-          case: 'options',
-          value: {
-            videoCodec: VideoCodec.H264_BASELINE,
-            frameRate: 30,
-            layers: [
-              {
-                quality: VideoQuality.MEDIUM, 
-                width: 1280,
-                height: 720,
-                bitrate: 2_500_000, // 2.5 mbps
-              },
-              {
-                quality: VideoQuality.LOW, 
-                width: 640,
-                height: 360,
-                bitrate: 500_000, // 500 kbps
-              }
-            ]
-          }
-        },
-      }),
-      audio: new IngressAudioOptions({
-        source: TrackSource.MICROPHONE,
-        encodingOptions: {
-          case: 'preset',
-          value: IngressAudioEncodingPreset.OPUS_STEREO_96KBPS,
-        }
-      })
-    });
-
-    return Response.json({ 
-      key: ingress.streamKey,
-      url: ingress.url 
-    });
-
-  } catch (error) {
-    console.error('Broadcaster token error:', error);
-    return new Response('Internal Server Error', { status: 500 });
-  }
-}

src/app/(protected)/api/livekit/viewerToken/route.ts

@@ -1,34 +0,0 @@
-import { validateRequest } from '@/lib/auth';
-import { getPersonalChannel } from '@/lib/auth/personalChannel';
-import { AccessToken } from 'livekit-server-sdk';
-import { NextRequest } from 'next/server';
-import { randomString } from 'util-utils';
-
-export async function GET(request: NextRequest) {
-  const { user } = await validateRequest();
-  const personalChannel = await getPersonalChannel();
-  const userSalt = randomString(8);
-  const room = request.nextUrl.searchParams.get('room');
-  if (!room) {
-    return new Response('Room is required', { status: 400 });
-  }
-  if (!user) {
-    return new Response('Unauthorized', { status: 401 });
-  }
-
-  const at = new AccessToken(process.env.LIVEKIT_API_KEY, process.env.LIVEKIT_SECRET, {
-    identity: `${user.id}-${userSalt}`,
-    name: `${personalChannel!.name}-${userSalt}`,
-    ttl: 3600,
-  });
-
-  at.addGrant({
-    room,
-    roomJoin: true,
-    canSubscribe: true,
-    canPublish: false,
-    canPublishData: false,
-  });
-
-  return Response.json({ token: await at.toJwt() });
-}