Merge branch 'main' of https://github.com/swasthikshetty10/hackoverflow

Author: nagarajpandith

package-lock.json

@@ -27,6 +27,7 @@
     "livekit-server-sdk": "^1.1.0",
     "next": "^13.2.1",
     "next-auth": "^4.19.0",
+    "openai": "^3.2.1",
     "pusher": "^5.1.2",
     "pusher-js": "^8.0.1",
     "react": "18.2.0",

package.json

@@ -57,6 +57,7 @@ model User {
   sessions      Session[]
   Room          Room[]
   Participant   Participant[]
+  Transcript    Transcript[]
 }
 
 model VerificationToken {
@@ -72,14 +73,30 @@ model Room {
   updatedAt   DateTime      @updatedAt
   name        String        @id @unique @default(cuid())
   metadata    String?       @db.Text
+  slug        String?
   OwnerId     String
   Owner       User          @relation(fields: [OwnerId], references: [id], onDelete: Cascade)
   summary     String?       @db.Text
   Participant Participant[]
+  transcripts Transcript[]
 
   @@index([OwnerId])
 }
 
+model Transcript {
+  id        String   @id @default(cuid())
+  createdAt DateTime @default(now())
+  updatedAt DateTime @updatedAt
+  RoomName  String
+  Room      Room     @relation(fields: [RoomName], references: [name], onDelete: Cascade)
+  text      String   @db.Text
+  UserId    String
+  User      User     @relation(fields: [UserId], references: [id], onDelete: Cascade)
+
+  @@index([RoomName])
+  @@index([UserId])
+}
+
 model Participant {
   id        String   @id @default(cuid())
   createdAt DateTime @default(now())

prisma/schema.prisma

@@ -18,8 +18,6 @@ import Pusher from "pusher-js";
 import useTranscribe from "~/hooks/useTranscribe";
 import Captions from "~/components/captions";
 
-// THis is join room page, provide room name to join as a participant
-
 const Home: NextPage = () => {
   const router = useRouter();
   const { name: roomName } = router.query;

src/pages/rooms/[name].tsx

@@ -27,6 +27,19 @@ export const pusherRouter = createTRPCRouter({
           senderId: user.id,
         }
       );
+      ctx.prisma.room.update({
+        where: {
+          name: input.roomName,
+        },
+        data: {
+          transcripts: {
+            create: {
+              text: message,
+              UserId: user.id,
+            },
+          },
+        },
+      });
       return response;
     }),
 });

src/server/api/routers/pusher.ts

@@ -24,6 +24,11 @@ import {
 import { TokenResult } from "~/lib/type";
 import { CreateRoomRequest } from "livekit-server-sdk/dist/proto/livekit_room";
 const roomClient = new RoomServiceClient(apiHost, apiKey, apiSecret);
+const configuration = new Configuration({
+  apiKey: process.env.OPEN_API_SECRET,
+});
+import { Configuration, OpenAIApi } from "openai";
+const openai = new OpenAIApi(configuration);
 export const roomsRouter = createTRPCRouter({
   joinRoom: protectedProcedure
     .input(
@@ -49,6 +54,24 @@ export const roomsRouter = createTRPCRouter({
         identity,
         accessToken: token,
       };
+      try {
+        ctx.prisma.participant.create({
+          data: {
+            User: {
+              connect: {
+                id: ctx.session.user.id,
+              },
+            },
+            Room: {
+              connect: {
+                name: roomName,
+              },
+            },
+          },
+        });
+      } catch (error) {
+        console.log(error);
+      }
 
       return result;
     }),
@@ -82,4 +105,65 @@ export const roomsRouter = createTRPCRouter({
 
     return result;
   }),
+  getRoomsByUser: protectedProcedure.query(async ({ ctx }) => {
+    const rooms = await ctx.prisma.room.findMany({
+      where: {
+        OR: [
+          {
+            Owner: {
+              id: ctx.session.user.id,
+            },
+          },
+          {
+            Participant: {
+              some: {
+                User: {
+                  id: ctx.session.user.id,
+                },
+              },
+            },
+          },
+        ],
+      },
+    });
+
+    return rooms;
+  }),
+  getRoomSummary: protectedProcedure
+    .input(
+      z.object({
+        roomName: z.string(),
+      })
+    )
+    .query(async ({ input, ctx }) => {
+      // order all transcripts by createdAt in ascending order
+      const transcripts = await ctx.prisma.transcript.findMany({
+        where: {
+          Room: {
+            name: input.roomName,
+          },
+        },
+        include: {
+          User: true,
+        },
+        orderBy: {
+          createdAt: "asc",
+        },
+      });
+      const chatLog = transcripts
+        .map((transcript) => `${transcript.User.name} : ${transcript.text}`)
+        .join("\n");
+      const prompt = `generate a summarization of the transcript of a meeting conversation below in english:\n${chatLog}`;
+      const completion = await openai.createCompletion({
+        model: "text-davinci-002",
+        prompt: prompt,
+        temperature: 0.7,
+        top_p: 1,
+        frequency_penalty: 0,
+        presence_penalty: 0,
+        max_tokens: 256,
+      });
+      console.log(completion);
+      return completion;
+    }),
 });