session routes api created

backend/package.json

@@ -13,6 +13,7 @@
   "license": "ISC",
   "dependencies": {
     "@clerk/express": "^1.7.41",
+    "@stream-io/node-sdk": "^0.7.12",
     "codemeet": "file:..",
     "cors": "^2.8.5",
     "dotenv": "^17.2.3",

backend/src/controllers/sessionController.js

@@ -0,0 +1,155 @@
+import Session from "../models/Session.js";
+import { chatClient, streamClient } from "../lib/stream.js";
+
+export async function createSession(req, res) {
+  try {
+    const { problem, difficulty } = req.body;
+    const userId = req.user._id;
+    const clerkId = req.user.clerkId;
+    if (!problem || !difficulty) {
+      return res
+        .status(400)
+        .json({ msg: "Problem and difficulty are required" });
+    }
+
+    //generate a unique call id for stream video
+    const callId = `session-${Date.now()}_${Math.random().toString(36).substring(7)}`;
+
+    //create session in db
+    const session = await Session.create({
+      problem,
+      difficulty,
+      host: userId,
+      callId,
+    });
+
+    //create stream video call
+    await streamClient.video.call("default", callId).getOrCreate({
+      data: {
+        created_by_id: clerkId,
+        custom: { problem, difficulty, sessionId: session._id.toString() },
+      },
+    });
+
+    //chat messaging
+    const channel = chatClient.channel("messaging", callId, {
+      name: `${problem} Session`,
+      created_by_id: clerkId,
+      members: [clerkId],
+    });
+
+    await channel.create();
+
+    res.status(201).json({ session });
+  } catch (error) {
+    console.error("Error createSession controller:", error.message);
+    res.status(500).json({ msg: "Internal server error" });
+  }
+}
+
+export async function getActiveSessions(_, res) {
+  try {
+    const sessions = await Session.find({ status: "active" })
+      .populate("host", "name profileImage email clerkId")
+      .sort({ createdAt: -1 })
+      .limit(20);
+    res.status(200).json({ sessions });
+  } catch (error) {
+    console.error("Error getActiveSessions controller:", error.message);
+    res.status(500).json({ msg: "Internal server error" });
+  }
+}
+
+export async function getMyRecentSessions(req, res) {
+  try {
+    const userId = req.user._id;
+    //where user is eigther host or pwrticipant
+    const sessions = await Session.find({
+      status: "completed",
+      $or: [{ host: userId }, { participant: userId }],
+    })
+      .sort({ createdAt: -1 })
+      .limit(20);
+
+    res.status(200).json({ sessions });
+  } catch (error) {
+    console.error("Error getMyRecentSessions controller:", error.message);
+    res.status(500).json({ msg: "Internal server error" });
+  }
+}
+
+export async function getSessionById(req, res) {
+  try {
+    const { id } = req.params;
+    const session = await Session.findById(id)
+      .populate("host", "name email profileImage clerkId")
+      .populate("participant", "name email profileImage clerkId");
+
+    if (!session) return res.status(404).json({ msg: "Session not found" });
+
+    res.status(200).json({ session });
+  } catch (error) {
+    console.error("Error getSessionById controller:", error.message);
+    res.status(500).json({ msg: "Internal server error" });
+  }
+}
+
+export async function joinSession(req, res) {
+  try {
+    const { id } = req.params;
+    const userId = req.user._id;
+    const clerkId = req.user.clerkId;
+
+    const session = await Session.findById(id);
+    if (!session) return res.status(404).json({ msg: "Session not found" });
+    //check if session is already full
+    if (session.participant)
+      return res.status(400).json({ msg: "Session is already full" });
+    session.participant = userId;
+    await session.save();
+
+    const channel = chatClient.channel("messaging", session.callId);
+    await channel.addMembers([clerkId]);
+    res.status(200).json({ session });
+  } catch (error) {
+    console.error("Error joinSession controller:", error.message);
+    res.status(500).json({ msg: "Internal server error" });
+  }
+}
+
+export async function endSession(req, res) {
+  try {
+    const { id } = req.params;
+    const userId = req.user._id;
+
+    const session = await Session.findById(id);
+    if (!session) return res.status(404).json({ msg: "Session not found" });
+
+    //check if you are the host or not
+    if (session.host.toString() !== userId.toString()) {
+      return res.status(403).json({ msg: "Only The host can end the session" });
+    }
+
+    //check if session is already completed
+    if (session.status === "completed") {
+      return res.status(400).json({ msg: "Session is already completed" });
+    }
+
+    session.status = "completed";
+    await session.save();
+
+    //delete stream video call
+    const call = streamClient.video.call("default", session.callId);
+    await call.delete({ hard: true });
+
+    //delete stream chat channel
+    const channel = chatClient.channel("messaging", session.callId);
+    await channel.delete();
+
+    res.status(200).json({ msg: "Session ended successfully" });
+  } catch (error) {
+    console.error("Error endSession controller:", error.message);
+    res.status(500).json({ msg: "Internal server error" });
+  }
+}
+//idkd

backend/src/lib/inngest.js

@@ -27,6 +27,8 @@ const syncUser = inngest.createFunction(
       name: newUser.name,
       image: newUser.profileImage,
     });
+
+    //Send a Welcome email ro the user in future
   },
 );
 

backend/src/lib/stream.js

@@ -1,4 +1,5 @@
 import { StreamChat } from "stream-chat";
+import { StreamClient } from "@stream-io/node-sdk";
 import { ENV } from "./env.js";
 
 const apiKey = ENV.STREAM_API_KEY;
@@ -8,7 +9,8 @@ if (!apiKey || !apiSecret) {
   console.log("STREAM_API_KEY or STREAM_API_SECRET is missing");
 }
 
-export const chatClient = StreamChat.getInstance(apiKey, apiSecret);
+export const chatClient = StreamChat.getInstance(apiKey, apiSecret); //this is for chat features
+export const streamClient = new StreamClient(apiKey, apiSecret); //used for video calls
 
 export const upsertStreamUser = async (userData) => {
   try {

backend/src/models/Session.js

@@ -0,0 +1,39 @@
+import mongoose from "mongoose";
+
+const sessionSchema = new mongoose.Schema(
+  {
+    problem: {
+      type: String,
+      required: true,
+    },
+    difficulty: {
+      type: String,
+      enum: ["easy", "medium", "hard"],
+      required: true,
+    },
+    host: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "User",
+      required: true,
+    },
+    participant: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "User",
+      default: null,
+    },
+    status: {
+      type: String,
+      enum: ["active", "completed"],
+      default: "active",
+    },
+    callId: {
+      type: String,
+      default: "",
+    },
+  },
+  { timestamps: true },
+);
+
+const Session = mongoose.model("Session", sessionSchema);
+
+export default Session;

backend/src/routes/sessionRoute.js

@@ -0,0 +1,21 @@
+import express from "express";
+import { protectRoute } from "../middleware/protectRoute.js";
+import {
+  createSession,
+  getActiveSessions,
+  getMyRecentSessions,
+  getSessionById,
+  joinSession,
+  endSession,
+} from "../controllers/sessionController.js";
+
+const router = express.Router();
+
+router.post("/", protectRoute, createSession);
+router.get("/active", protectRoute, getActiveSessions);
+router.get("/my-recent", protectRoute, getMyRecentSessions);
+router.get("/:id", protectRoute, getSessionById);
+router.post("/:id/join", protectRoute, joinSession);
+router.post("/:id/end", protectRoute, endSession);
+
+export default router;

backend/src/server.js

@@ -8,6 +8,7 @@ import { ENV } from "./lib/env.js";
 import { connectDB } from "./lib/db.js";
 import { inngest, functions } from "./lib/inngest.js";
 import chatRoutes from "./routes/chatRoutes.js";
+import sessionRoutes from "./routes/sessionRoute.js";
 
 const app = express();
 
@@ -23,6 +24,7 @@ app.use("/api/inngest", serve({ client: inngest, functions }));
 
 app.use(clerkMiddleware()); //this will add auth object to the request if the user is authenticated, which we can use in our routes
 app.use("/api/chat", chatRoutes);
+app.use("/api/sessions", sessionRoutes);
 
 app.get("/health", (req, res) => {
   res.status(200).json({ msg: "success api is running" });