feat/create-room

backend/package.json

@@ -14,7 +14,8 @@
     "dotenv": "^16.3.1",
     "fastify": "^4.25.2",
     "fastify-socket.io": "^5.0.0",
-    "socket.io": "^4.7.3"
+    "socket.io": "^4.7.3",
+    "@fastify/cors": "^8.5.0"
   },
   "devDependencies": {
     "@types/node": "^20.10.5",

backend/src/room.ts

@@ -0,0 +1,131 @@
+import { supabase } from "./server";
+
+let roomId: string | null = null;
+let roomQueue: string[] = [];
+
+export async function createRoom(
+  name: string,
+  code: string,
+  voteSkipping: boolean,
+  voteSkippingNeeded: number,
+  maxMusicPerUser: number,
+  maxMusicPerUserDuration: number,
+  serviceName: string,
+) {
+  let created_at = new Date();
+  let configurationId: string | null = null;
+  let hostUserProfileId: string | null = null;
+  let streamingServicesId: string | null = null;
+
+  const userProfileRes = await supabase
+    .from("user_profile")
+    .select("user_profile_id");
+
+  if (userProfileRes.error) {
+    console.error(userProfileRes.error);
+  } else {
+    hostUserProfileId = userProfileRes.data[0].user_profile_id;
+    console.log("Host user profile id retrieved");
+  }
+
+  const streamingServicesRes = await supabase
+    .from("streaming_services")
+    .select("*")
+    .eq("service_name", serviceName);
+
+  if (streamingServicesRes.error) {
+    console.error(streamingServicesRes.error);
+  } else {
+    streamingServicesId = streamingServicesRes.data[0].service_id;
+    console.log("Streaming services id retrieved");
+  }
+
+  const roomConfigRes = await supabase
+    .from("active_room_configurations")
+    .insert([
+      {
+        vote_skipping: voteSkipping,
+        vote_skipping_needed_percentage: voteSkippingNeeded,
+        max_music_count_in_queue_per_participant: maxMusicPerUser,
+        max_music_duration: maxMusicPerUserDuration,
+      },
+    ])
+    .select("id");
+
+  if (roomConfigRes.error) {
+    console.error(roomConfigRes.error);
+  } else {
+    configurationId = roomConfigRes.data[0].id;
+    console.log("Room configurations created");
+  }
+
+  const roomRes = await supabase
+    .from("active_rooms")
+    .insert([
+      {
+        name: name,
+        code: code,
+        created_at: created_at,
+        configuration_id: configurationId,
+        host_user_profile_id: hostUserProfileId,
+        service_id: streamingServicesId,
+      },
+    ])
+    .select("id");
+
+  if (roomRes.error) {
+    console.error(roomRes.error);
+  } else {
+    roomId = roomRes.data[0].id;
+    console.log("Room created");
+  }
+}
+
+export function endRoom(roomId: string) {
+  let ended_at = new Date();
+  let created_at: Date | null = null;
+  let configurationId: string | null = null;
+  let hostUserProfileId: string | null = null;
+
+  supabase
+    .from("active_rooms")
+    .delete()
+    .eq("id", roomId)
+    .select("*")
+    .then((res) => {
+      if (res.error) {
+        console.error(res.error);
+      } else {
+        created_at = res.data[0].created_at;
+        configurationId = res.data[0].configuration_id;
+        hostUserProfileId = res.data[0].host_user_profile_id;
+        console.log("Room ended");
+      }
+    });
+
+  supabase
+    .from("rooms")
+    .insert([
+      {
+        created_at: created_at,
+        ended_at: ended_at,
+        configuration_id: configurationId,
+        host_user_profile_id: hostUserProfileId,
+      },
+    ])
+    .then((res) => {
+      if (res.error) {
+        console.error(res.error);
+      } else {
+        console.log("Room added to rooms");
+      }
+    });
+}
+
+function addMusic(music: any) {
+  roomQueue.push(music);
+}
+
+function removeMusic(music: any) {
+  roomQueue.splice(roomQueue.indexOf(music), 1);
+}

backend/src/route/RoomPOST.ts

@@ -0,0 +1,35 @@
+import { FastifyReply, FastifyRequest } from "fastify";
+import { createRoom } from "../room";
+
+interface BodyParams {
+  name: string;
+  code: string;
+  service: string;
+  voteSkipping: boolean;
+  voteSkippingNeeded: number;
+  maxMusicPerUser: number;
+  maxMusicPerUserDuration: number;
+}
+
+export default function RoomPOST(req: FastifyRequest, reply: FastifyReply) {
+  const name = (req.body as BodyParams).name;
+  const code = (req.body as BodyParams).code;
+  const voteSkipping = (req.body as BodyParams).voteSkipping;
+  const voteSkippingNeeded = (req.body as BodyParams).voteSkippingNeeded;
+  const maxMusicPerUser = (req.body as BodyParams).maxMusicPerUser;
+  const maxMusicPerUserDuration = (req.body as BodyParams)
+    .maxMusicPerUserDuration;
+  const serviceName = (req.body as BodyParams).service;
+
+  createRoom(
+    name,
+    code,
+    voteSkipping,
+    voteSkippingNeeded,
+    maxMusicPerUser,
+    maxMusicPerUserDuration,
+    serviceName,
+  ).then(() => {
+    reply.send({ message: "Room created" });
+  });
+}

backend/src/server.ts

@@ -1,8 +1,10 @@
 import fastify from "fastify";
 import fastifyIO from "fastify-socket.io";
+import cors from "@fastify/cors";
 import { Server } from "socket.io";
 import HelloGet from "./route/HelloGET";
 import RoomsGET from "./route/RoomGET";
+import RoomPOST from "./route/RoomPOST";
 import { createClient } from "@supabase/supabase-js";
 import { config } from "dotenv";
 import path from "path";
@@ -23,15 +25,38 @@ if (!process.env.SUPABASE_URL || !process.env.SERVICE_ROLE) {
 
 export const supabase = createClient(
   process.env.SUPABASE_URL,
-  process.env.SERVICE_ROLE
+  process.env.SERVICE_ROLE,
 );
 
 server.register(fastifyIO);
 
+server.register(cors, {
+  origin: "*", // Allow all origins
+  methods: ["GET", "POST", "OPTIONS"],
+});
+
 server.get("/rooms", RoomsGET);
 
 server.get("/hello", HelloGet);
 
+const createRoomSchema = {
+  body: {
+    type: "object",
+    required: ["name", "code", "service"],
+    properties: {
+      name: { type: "string" },
+      code: { type: "string" },
+      service: { type: "string" },
+      voteSkipping: { type: "boolean" },
+      voteSkippingNeeded: { type: "number" },
+      maxMusicPerUser: { type: "number" },
+      maxMusicPerUserDuration: { type: "number" },
+    },
+  },
+};
+
+server.post("/createRoom", { schema: createRoomSchema }, RoomPOST);
+
 server.ready().then(() => {
   // we need to wait for the server to be ready, else `server.io` is undefined
   server.io.on("connection", (socket: any) => {

expo/app/(tabs)/Rooms.tsx

@@ -11,6 +11,9 @@ export default function TabsRooms() {
       <Link href="/AddMusic" asChild>
         Add Music
       </Link>
+        <Link href="/CreateRoom" >
+            Create Room
+        </Link>
     </View>
   );
 }