Feat: Update end time when event host ended room (#197)

* feat: update event end time
* remove: draft query

app/(server)/api/rooms/[roomID]/end/route.ts

@@ -0,0 +1,83 @@
+import { getCurrentAuthenticated } from '@/(server)/_shared/utils/get-current-authenticated';
+import { eventRepo, roomRepo } from '@/(server)/api/_index';
+import { cookies } from 'next/headers';
+import { NextResponse } from 'next/server';
+import * as Sentry from '@sentry/nextjs';
+
+export async function POST({ params }: { params: { slugOrId: string } }) {
+  const slugOrId = params.slugOrId;
+  const cookieStore = cookies();
+  const requestToken = cookieStore.get('token');
+
+  try {
+    if (!requestToken) {
+      return NextResponse.json(
+        {
+          code: 401,
+          message: 'please check your authentication token',
+        },
+        { status: 401 }
+      );
+    }
+
+    const response = await getCurrentAuthenticated(requestToken?.value);
+    const user = response.data ? response.data : null;
+
+    if (!user) {
+      return NextResponse.json(
+        {
+          code: 401,
+          message: 'unauthorized',
+        },
+        { status: 401 }
+      );
+    }
+
+    const room = await roomRepo.getRoomById(slugOrId);
+
+    if (!room) {
+      return NextResponse.json(
+        {
+          code: 404,
+          message: 'room not found',
+        },
+        { status: 404 }
+      );
+    }
+
+    if (room?.meta.type === 'meeting') {
+      const event = await eventRepo.getByRoomID(room.id);
+      if (event) {
+        event.endTime = new Date();
+        const newEvent = await eventRepo.updateEvent(user.id, event.id, event);
+
+        return NextResponse.json(
+          {
+            code: 200,
+            message: 'event ended',
+            data: newEvent,
+          },
+          { status: 200 }
+        );
+      }
+    }
+
+    return NextResponse.json(
+      {
+        code: 200,
+        message: 'normal room ended',
+        data: room,
+      },
+      { status: 200 }
+    );
+  } catch (e) {
+    Sentry.captureException(e);
+    return NextResponse.json(
+      {
+        code: 500,
+        message: 'internal server error',
+      },
+      { status: 500 }
+    );
+  }
+}

app/(server)/api/rooms/[roomID]/register/route.ts

@@ -1,5 +1,6 @@
 import { roomService } from '@/(server)/api/_index';
 import { NextResponse, type NextRequest } from 'next/server';
+import * as Sentry from '@sentry/nextjs';
 
 interface RegisterClientRequest {
   uid?: string;
@@ -38,6 +39,8 @@ export async function POST(
       { status: 200 }
     );
   } catch (error) {
+    Sentry.captureException(error);
+
     if (error instanceof Error) {
       const response = {
         code: 500,

app/_features/room/components/button-leave.tsx

@@ -17,7 +17,7 @@ import { useMetadataContext } from '@/_features/room/contexts/metadata-context';
 import ArrowDownFillIcon from '@/_shared/components/icons/arrow-down-fill-icon';
 
 export default function ButtonLeave() {
-  const { clientID } = useClientContext();
+  const { clientID, roomID } = useClientContext();
   const { datachannels } = useDataChannelContext();
   const { streams } = useParticipantContext();
   const { isModerator, roomType } = useMetadataContext();
@@ -77,10 +77,14 @@ export default function ButtonLeave() {
               },
             })
           );
+
+          if (roomType === 'event') {
+            navigator.sendBeacon(`/api/rooms/${roomID}/end`);
+          }
         }
       }
     },
-    [clientID, datachannels, isModerator, roomType, streams]
+    [clientID, datachannels, isModerator, roomID, roomType, streams]
   );
 
   return (