what the sigma

Author: TanPingZhi

collab-service/.gitignore

@@ -0,0 +1 @@
+node_modules

collab-service/Dockerfile

@@ -0,0 +1,25 @@
+# Base image
+FROM node:20-alpine AS base
+WORKDIR /app
+COPY package*.json ./
+
+# Development stage
+FROM base AS dev
+RUN npm install
+COPY . .
+# Run the TypeScript code directly in dev mode (useful for hot-reloading)
+CMD ["npm", "run", "dev"]
+
+# Build stage
+FROM base AS build
+RUN npm install
+COPY . .
+RUN npm run build
+
+# Production stage
+FROM node:20-alpine AS prod
+WORKDIR /app
+COPY --from=build /app/dist ./dist
+COPY package*.json ./
+RUN npm ci --only=production
+CMD ["node", "dist/index.js"]

collab-service/app/controller/collab-controller.ts

@@ -0,0 +1,14 @@
+import { Request } from 'express';
+
+interface CreateRoomRequestBody {
+    user1: string;
+    user2: string;
+}
+
+export async function create_room(req: Request<{}, {}, CreateRoomRequestBody>, res) {
+    // this function is to create a connection between two users
+    // the connection is store in mongodb
+
+    const { user1, user2 } = req.body;
+
+}

collab-service/app/index.ts

@@ -0,0 +1,58 @@
+import express, { Application, Request, Response, NextFunction } from 'express';
+import cors from 'cors';
+import collabRoutes from './routes/collab-routes';
+
+const app: Application = express();
+
+app.use(express.urlencoded({ extended: true }));
+app.use(express.json());
+app.use(cors()); // config cors so that front-end can use
+app.options("*", cors());
+
+
+// To handle CORS Errors
+app.use((req, res, next) => {
+    res.header("Access-Control-Allow-Origin", "*"); // "*" -> Allow all links to access
+  
+    res.header(
+      "Access-Control-Allow-Headers",
+      "Origin, X-Requested-With, Content-Type, Accept, Authorization",
+    );
+  
+    // Browsers usually send this before PUT or POST Requests
+    if (req.method === "OPTIONS") {
+      res.header("Access-Control-Allow-Methods", "GET, POST, DELETE, PUT, PATCH");
+      return res.status(200).json({});
+    }
+  
+    // Continue Route Processing
+    next();
+  });
+
+
+  app.get("/", (req, res, next) => {
+    console.log("Sending Greetings!");
+    res.json({
+      message: "Hello World from collab-service",
+    });
+  });
+  
+  // Handle When No Route Match Is Found
+  app.use((req, res, next) => {
+    const error: any = new Error("Route Not Found");
+    error.status = 404;
+    next(error);
+  });
+  
+  app.use((error, req, res, next) => {
+    res.status(error.status || 500);
+    res.json({
+      error: {
+        message: error.message,
+      },
+    });
+  });
+
+  app.use("/collab", collabRoutes);
+
+export default app;

collab-service/app/model/repository.ts

@@ -0,0 +1,33 @@
+import { connect } from 'mongoose';
+import UsersSession from './usersSession-model';
+import mongoose from 'mongoose';
+
+export async function connectToMongo() {
+    await connect('mongodb+srv://admin:[email protected]/');
+}
+
+export async function createRoom(user1: string, user2: string, roomId: string) {
+    try {
+        const newRoom = new UsersSession({
+            users: [user1, user2],
+            roomId: new mongoose.Types.ObjectId().toString(), // Generate a unique room ID
+            lastUpdated: new Date()
+        });
+
+        const savedRoom = await newRoom.save();
+        return savedRoom;
+    } catch (error) {
+        console.error('Error creating room:', error);
+        return null;
+    }
+}
+
+export async function get_roomID(user: string): Promise<mongoose.Document | null> {
+    try {
+        const room = await UsersSession.findOne({ users: user });
+        return room;
+    } catch (error) {
+        console.error('Error finding room for ${user}:', error);
+        return null;
+    }
+}

collab-service/app/model/usersSession-model.ts

@@ -0,0 +1,21 @@
+import mongoose from 'mongoose';
+
+const Schema = mongoose.Schema;
+
+const usersSessionSchema = new Schema({
+    users: {
+        type: [String],
+        required: true
+    },
+    roomId: {
+        type: String,
+        required: true
+    },
+    lastUpdated: {
+        type: Date,
+        required: true,
+        default: Date.now
+    }
+});
+
+export default mongoose.model('UsersSession', usersSessionSchema);

collab-service/app/routes/collab-routes.ts

@@ -0,0 +1,9 @@
+import express from "express";
+
+import { create_room } from "../controller/collab-controller";
+
+const router = express.Router();
+
+router.post("/create-room", create_room);
+
+export default router;

collab-service/app/server.ts

@@ -0,0 +1,5 @@
+import { connectToMongo } from "./model/repository";
+import http from "http";
+import { index } from "./index.ts";
+const PORT = process.env.PORT || 5000;
+const server = http.createServer(index);