Merge pull request #123 from boostcampwm-2024/dev

[Deploy] 3주차 스프린트 배포

Author: ShipFriend0516

backend/package.json

@@ -25,6 +25,8 @@
     "@nestjs/platform-express": "^10.0.0",
     "@nestjs/platform-socket.io": "^10.4.6",
     "@nestjs/websockets": "^10.4.6",
+    "dotenv": "^16.4.5",
+    "ioredis": "^5.4.1",
     "reflect-metadata": "^0.2.0",
     "rxjs": "^7.8.1",
     "socket.io": "^4.8.1"

backend/src/app.module.ts

@@ -1,10 +1,14 @@
 import { Module } from "@nestjs/common";
 import { AppController } from "./app.controller";
 import { AppService } from "./app.service";
-import { SocketModule } from "./socket/socket.module";
+import { SocketModule } from "./signaling-server/socket.module";
+import { RoomModule } from "./room/room.module";
+import { RedisModule } from "./redis/redis.module";
+
+import "dotenv/config";
 
 @Module({
-    imports: [SocketModule],
+    imports: [SocketModule, RoomModule, RedisModule],
     controllers: [AppController],
     providers: [AppService],
 })

backend/src/config/redis.config.ts

@@ -0,0 +1,7 @@
+import "dotenv/config";
+
+export const redisConfig = {
+    host: process.env.REDIS_HOST,
+    port: parseInt(process.env.REDIS_PORT),
+    password: process.env.REDIS_PASSWORD,
+};

backend/src/redis/redis.module.ts

@@ -0,0 +1,7 @@
+import { Module } from "@nestjs/common";
+import { RedisService } from "./redis.service";
+
+@Module({
+    providers: [RedisService],
+})
+export class RedisModule {}

backend/src/redis/redis.service.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from "@nestjs/testing";
+import { RedisService } from "./redis.service";
+
+describe("RedisService", () => {
+    let service: RedisService;
+
+    beforeEach(async () => {
+        const module: TestingModule = await Test.createTestingModule({
+            providers: [RedisService],
+        }).compile();
+
+        service = module.get<RedisService>(RedisService);
+    });
+
+    it("should be defined", () => {
+        expect(service).toBeDefined();
+    });
+});

backend/src/redis/redis.service.ts

@@ -0,0 +1,79 @@
+import { Injectable } from "@nestjs/common";
+import Redis from "ioredis";
+import { redisConfig } from "../config/redis.config";
+import { stringify } from "ts-jest";
+
+@Injectable()
+export class RedisService {
+    private readonly client: Redis = new Redis({
+        host: redisConfig.host,
+        port: redisConfig.port,
+        password: redisConfig.password,
+    });
+
+    async set(key: string, value: any, ttl: number = 0) {
+        if (typeof value === "object") value = JSON.stringify(value);
+
+        await this.client.set(key, value, "KEEPTTL");
+        await this.client.expire(key, ttl);
+    }
+
+    async get(key: string) {
+        return this.client.get(key);
+    }
+
+    async getTTL(key: string) {
+        return this.client.ttl(key);
+    }
+
+    async getKeys(query: string) {
+        const keys: string[] = [];
+        let cursor = "0";
+
+        do {
+            const [nextCursor, matchedKeys] = await this.client.scan(
+                cursor,
+                "MATCH",
+                query,
+                "COUNT",
+                "100"
+            );
+            cursor = nextCursor;
+            keys.push(...matchedKeys);
+        } while (cursor !== "0");
+        return keys;
+    }
+
+    async getHashValueByField(key: string, field: string) {
+        return this.client.hget(key, field);
+    }
+
+    async setHashValueByField(key: string, field: string, value: any) {
+        if (typeof value !== "string") value = stringify(value);
+        return this.client.hset(key, field, value);
+    }
+
+    async delete(...keys: string[]) {
+        return this.client.del(...keys);
+    }
+
+    async getValues(query: string) {
+        const keys = await this.getKeys(query);
+        if (!keys.length) return null;
+        return this.client.mget(keys);
+    }
+
+    async getMap(query: string, valueType: "object" | "primitive" = "object") {
+        const keys = await this.getKeys(query);
+        const values = await this.getValues(query);
+        if (!values) return null;
+
+        return keys.reduce((acc, key, index) => {
+            acc[key] =
+                valueType === "object"
+                    ? JSON.parse(values[index])
+                    : values[index];
+            return acc;
+        }, {});
+    }
+}

backend/src/room/dto/create-room.dto.ts

@@ -0,0 +1,7 @@
+export interface CreateRoomDto {
+    title: string;
+    status: "PUBLIC" | "PRIVATE";
+    nickname: string;
+    socketId: string;
+    maxParticipants?: number;
+}

backend/src/room/room.controller.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from "@nestjs/testing";
+import { RoomController } from "./room.controller";
+
+describe("RoomController", () => {
+    let controller: RoomController;
+
+    beforeEach(async () => {
+        const module: TestingModule = await Test.createTestingModule({
+            controllers: [RoomController],
+        }).compile();
+
+        controller = module.get<RoomController>(RoomController);
+    });
+
+    it("should be defined", () => {
+        expect(controller).toBeDefined();
+    });
+});

backend/src/room/room.controller.ts

@@ -0,0 +1,12 @@
+import { Controller, Get } from "@nestjs/common";
+import { RoomService } from "./room.service";
+
+@Controller("rooms")
+export class RoomController {
+    constructor(private readonly roomService: RoomService) {}
+
+    @Get()
+    getPublicRooms() {
+        return this.roomService.getPublicRoom();
+    }
+}

backend/src/room/room.gateway.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from "@nestjs/testing";
+import { RoomGateway } from "./room.gateway";
+
+describe("RoomGateway", () => {
+    let gateway: RoomGateway;
+
+    beforeEach(async () => {
+        const module: TestingModule = await Test.createTestingModule({
+            providers: [RoomGateway],
+        }).compile();
+
+        gateway = module.get<RoomGateway>(RoomGateway);
+    });
+
+    it("should be defined", () => {
+        expect(gateway).toBeDefined();
+    });
+});