merge develop -> main

app/api/record/start/route.ts

@@ -1,10 +1,11 @@
-import { EgressClient, EncodedFileOutput, S3Upload } from 'livekit-server-sdk';
+import { EgressClient, EncodedFileOutput, RoomServiceClient, S3Upload } from 'livekit-server-sdk';
 import { NextRequest, NextResponse } from 'next/server';
 
 export async function GET(req: NextRequest) {
   try {
     const roomName = req.nextUrl.searchParams.get('roomName');
     const now = req.nextUrl.searchParams.get('now');
+    const identity = req.nextUrl.searchParams.get('identity');
 
     // new Date(Date.now()).toISOString();
     /**
@@ -68,6 +69,11 @@ export async function GET(req: NextRequest) {
         layout: 'speaker',
       },
     );
+    const roomClient = new RoomServiceClient(hostURL.origin, LIVEKIT_API_KEY, LIVEKIT_API_SECRET);
+    await roomClient.updateRoomMetadata(
+      roomName,
+      JSON.stringify({ recording: { isRecording: true, recorder: identity } }),
+    );
 
     if (RUNNER_URL && RUNNER_SECRET) {
       post_runner(RUNNER_URL, RUNNER_SECRET, filepath);
@@ -76,6 +82,7 @@ export async function GET(req: NextRequest) {
     return new NextResponse(null, { status: 200 });
   } catch (error) {
     if (error instanceof Error) {
+      console.log({ error });
       return new NextResponse(error.message, { status: 500 });
     }
   }

app/api/record/stop/route.ts

@@ -1,9 +1,10 @@
-import { EgressClient } from 'livekit-server-sdk';
+import { EgressClient, RoomServiceClient } from 'livekit-server-sdk';
 import { NextRequest, NextResponse } from 'next/server';
 
 export async function GET(req: NextRequest) {
   try {
     const roomName = req.nextUrl.searchParams.get('roomName');
+    const identity = req.nextUrl.searchParams.get('identity');
 
     /**
      * CAUTION:
@@ -22,13 +23,18 @@ export async function GET(req: NextRequest) {
     hostURL.protocol = 'https:';
 
     const egressClient = new EgressClient(hostURL.origin, LIVEKIT_API_KEY, LIVEKIT_API_SECRET);
+    const roomClient = new RoomServiceClient(hostURL.origin, LIVEKIT_API_KEY, LIVEKIT_API_SECRET);
     const activeEgresses = (await egressClient.listEgress({ roomName })).filter(
       (info) => info.status < 2,
     );
     if (activeEgresses.length === 0) {
       return new NextResponse('No active recording found', { status: 404 });
     }
     await Promise.all(activeEgresses.map((info) => egressClient.stopEgress(info.egressId)));
+    await roomClient.updateRoomMetadata(
+      roomName,
+      JSON.stringify({ recording: { isRecording: false, recorder: identity } }),
+    );
 
     return new NextResponse(null, { status: 200 });
   } catch (error) {

app/contexts/layout-context.tsx

@@ -0,0 +1,61 @@
+import { createContext, useContext } from 'react';
+
+type LayoutContextType = {
+  // isSettingsOpen: SettingsContextType,
+  isChatOpen: ChatContextType;
+  isParticipantsListOpen: ParticipantsListContextType;
+};
+
+export const CustomLayoutContext = createContext<LayoutContextType | undefined>(undefined);
+
+export function useCustomLayoutContext(): LayoutContextType {
+  const customLayoutContext = useContext(CustomLayoutContext);
+  if (!customLayoutContext) {
+    throw Error('Tried to access LayoutContext context outside a LayoutContextProvider provider.');
+  }
+  return customLayoutContext;
+}
+
+interface CustomLayoutContextProviderProps {
+  layoutContextValue: LayoutContextType;
+  children: React.ReactNode;
+}
+
+export function CustomLayoutContextProvider({
+  layoutContextValue,
+  children,
+}: CustomLayoutContextProviderProps) {
+  return (
+    <CustomLayoutContext.Provider value={layoutContextValue}>
+      {' '}
+      {children}{' '}
+    </CustomLayoutContext.Provider>
+  );
+}
+
+export type SettingsAction = {
+  msg: 'toggle_settings';
+};
+
+export type SettingsContextType = {
+  dispatch?: React.Dispatch<SettingsAction>;
+  state?: boolean;
+};
+
+export type ChatAction = {
+  msg: 'toggle_chat';
+};
+
+export type ChatContextType = {
+  dispatch?: React.Dispatch<ChatAction>;
+  state?: boolean;
+};
+
+export type ParticipantsListAction = {
+  msg: 'toggle_participants_list';
+};
+
+export type ParticipantsListContextType = {
+  dispatch?: React.Dispatch<ParticipantsListAction>;
+  state?: boolean;
+};