Dev be -> dev

.eslintrc.js

@@ -69,4 +69,12 @@ module.exports = {
       },
     ],
   },
+  overrides: [
+    {
+      files: ['**/*.spec.ts'],
+      rules: {
+        'max-lines-per-function': 'off',
+      },
+    },
+  ],
 };

.gitignore

@@ -57,3 +57,10 @@ report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
 
 # vscode setting
 .vscode
+
+# remote
+.remote
+
+# .zip, .mst
+*.zip
+*.mst

packages/backend/.gitignore

@@ -54,3 +54,7 @@ pids
 
 # Diagnostic reports (https://nodejs.org/api/report.html)
 report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+
+# backup file
+.backup
+.bak

packages/backend/package.json

@@ -17,19 +17,21 @@
     "test:watch": "jest --watch",
     "test:cov": "jest --coverage",
     "test:debug": "node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand",
-    "test:e2e": "jest --config ./test/jest-e2e.json"
+    "test:e2e": "jest --config ./test/jest-e2e.json",
+    "mem": "node ../../dist/main --inspect"
   },
   "dependencies": {
     "@nestjs/common": "^10.0.0",
     "@nestjs/config": "^3.3.0",
     "@nestjs/core": "^10.0.0",
     "@nestjs/passport": "^10.0.3",
     "@nestjs/platform-express": "^10.0.0",
-    "@nestjs/platform-socket.io": "^10.4.7",
+    "@nestjs/platform-socket.io": "^10.4.8",
     "@nestjs/schedule": "^4.1.1",
     "@nestjs/swagger": "^8.0.5",
     "@nestjs/typeorm": "^10.0.2",
-    "@nestjs/websockets": "^10.4.7",
+    "@nestjs/websockets": "^10.4.8",
+    "async-mutex": "^0.5.0",
     "axios": "^1.7.7",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.1",
@@ -39,13 +41,16 @@
     "nest-winston": "^1.9.7",
     "passport": "^0.7.0",
     "passport-google-oauth20": "^2.0.0",
+    "passport-local": "^1.0.0",
     "reflect-metadata": "^0.2.0",
     "rxjs": "^7.8.1",
     "socket.io": "^4.8.1",
     "typeorm": "^0.3.20",
     "unzipper": "^0.12.3",
+    "web-push": "^3.6.7",
     "winston": "^3.17.0",
-    "winston-daily-rotate-file": "^5.0.0"
+    "winston-daily-rotate-file": "^5.0.0",
+    "ws": "^8.18.0"
   },
   "devDependencies": {
     "@nestjs/cli": "^10.0.0",
@@ -56,8 +61,11 @@
     "@types/jest": "^29.5.2",
     "@types/node": "^20.3.1",
     "@types/passport-google-oauth20": "^2.0.16",
+    "@types/passport-local": "^1.0.38",
     "@types/supertest": "^6.0.0",
     "@types/unzipper": "^0.10.10",
+    "@types/web-push": "^3.6.4",
+    "@types/ws": "^8.5.13",
     "@typescript-eslint/eslint-plugin": "^8.0.0",
     "@typescript-eslint/parser": "^8.0.0",
     "cz-emoji-conventional": "^1.1.0",
@@ -68,6 +76,7 @@
     "supertest": "^7.0.0",
     "ts-jest": "^29.1.0",
     "ts-loader": "^9.4.3",
+    "ts-mockito": "^2.6.1",
     "ts-node": "^10.9.1",
     "tsconfig-paths": "^4.2.0",
     "typescript": "^5.1.3"

packages/backend/src/alarm/alarm.controller.ts

@@ -0,0 +1,174 @@
+import {
+  Controller,
+  Get,
+  Post,
+  Param,
+  Body,
+  Put,
+  Delete,
+  UseGuards,
+} from '@nestjs/common';
+import {
+  ApiBadRequestResponse,
+  ApiOkResponse,
+  ApiOperation,
+  ApiParam,
+  ApiResponse,
+} from '@nestjs/swagger';
+import { AlarmService } from './alarm.service';
+import { AlarmRequest } from './dto/alarm.request';
+import { AlarmResponse, AlarmSuccessResponse } from './dto/alarm.response';
+import SessionGuard from '@/auth/session/session.guard';
+import { GetUser } from '@/common/decorator/user.decorator';
+import { User } from '@/user/domain/user.entity';
+
+@Controller('alarm')
+export class AlarmController {
+  constructor(private readonly alarmService: AlarmService) {}
+
+  @Post()
+  @ApiOperation({
+    summary: '알림 생성',
+    description: '각 정보에 맞는 알림을 생성한다.',
+  })
+  @ApiResponse({
+    status: 201,
+    description: '알림 생성 완료',
+    type: AlarmResponse,
+  })
+  @ApiBadRequestResponse({
+    description: '유효하지 않은 알람 입력값으로 인해 예외가 발생했습니다.',
+    schema: {
+      type: 'object',
+      properties: {
+        statusCode: { type: 'number', example: 400 },
+        message: { type: 'string', example: '알람 조건을 다시 확인해주세요.' },
+        error: { type: 'string', example: 'Bad Request' },
+      },
+    },
+  })
+  @UseGuards(SessionGuard)
+  async create(
+    @Body() alarmRequest: AlarmRequest,
+    @GetUser() user: User,
+  ): Promise<AlarmResponse> {
+    const userId = user.id;
+
+    return await this.alarmService.create(alarmRequest, userId);
+  }
+
+  @Get('user')
+  @ApiOperation({
+    summary: '사용자별 알림 조회',
+    description: '사용자 아이디를 기준으로 모든 알림을 조회한다.',
+  })
+  @ApiOkResponse({
+    description: '사용자에게 등록되어 있는 모든 알림 조회',
+    type: [AlarmResponse],
+  })
+  @UseGuards(SessionGuard)
+  async getByUserId(@GetUser() user: User) {
+    const userId = user.id;
+
+    return await this.alarmService.findByUserId(userId);
+  }
+
+  @Get('stock/:stockId')
+  @ApiOperation({
+    summary: '주식별 알림 조회',
+    description: '주식 아이디를 기준으로 알림을 조회한다.',
+  })
+  @ApiOkResponse({
+    description:
+      '주식 아이디에 등록되어 있는 알림 중 유저에 해당하는 알림 조회',
+    type: [AlarmResponse],
+  })
+  @ApiParam({
+    name: 'id',
+    type: String,
+    description: '주식 아이디',
+    example: '005930',
+  })
+  @UseGuards(SessionGuard)
+  async getByStockId(@Param('id') stockId: string, @GetUser() user: User) {
+    const userId = user.id;
+
+    return await this.alarmService.findByStockId(stockId, userId);
+  }
+
+  @Get(':id')
+  @ApiOperation({
+    summary: '등록된 알림 확인',
+    description: '등록된 알림을 알림 아이디를 기준으로 찾을 수 있다.',
+  })
+  @ApiOkResponse({
+    description: '알림 아이디와 동일한 알림 찾음',
+    type: AlarmResponse,
+  })
+  @ApiParam({
+    name: 'id',
+    type: Number,
+    description: '알림 아이디',
+    example: 1,
+  })
+  @UseGuards(SessionGuard)
+  async findOne(@Param('id') alarmId: number): Promise<AlarmResponse> {
+    return this.alarmService.findOne(alarmId);
+  }
+
+  @Put(':id')
+  @ApiOperation({
+    summary: '등록된 알림 업데이트',
+    description: '알림 아이디 기준으로 업데이트를 할 수 있다.',
+  })
+  @ApiOkResponse({
+    description: '아이디와 동일한 알림 업데이트',
+    type: AlarmResponse,
+  })
+  @ApiParam({
+    name: 'id',
+    type: Number,
+    description: '알림 아이디',
+    example: 1,
+  })
+  @ApiBadRequestResponse({
+    description: '유효하지 않은 알람 입력값으로 인해 예외가 발생했습니다.',
+    schema: {
+      type: 'object',
+      properties: {
+        statusCode: { type: 'number', example: 400 },
+        message: { type: 'string', example: '알람 조건을 다시 확인해주세요.' },
+        error: { type: 'string', example: 'Bad Request' },
+      },
+    },
+  })
+  @UseGuards(SessionGuard)
+  async update(
+    @Param('id') alarmId: number,
+    @Body() updateData: AlarmRequest,
+  ): Promise<AlarmResponse> {
+    return this.alarmService.update(alarmId, updateData);
+  }
+
+  @Delete(':id')
+  @ApiParam({
+    name: 'id',
+    type: Number,
+    description: '알림 아이디',
+    example: 1,
+  })
+  @ApiOperation({
+    summary: '등록된 알림 삭제',
+    description: '알림 아이디 기준으로 삭제를 할 수 있다.',
+  })
+  @ApiOkResponse({
+    description: '아이디와 동일한 알림 삭제',
+    type: AlarmSuccessResponse,
+  })
+  @UseGuards(SessionGuard)
+  async delete(@Param('id') alarmId: number) {
+    await this.alarmService.delete(alarmId);
+
+    return new AlarmSuccessResponse('알림 삭제를 성공했습니다.');
+  }
+}

packages/backend/src/alarm/alarm.module.ts

@@ -0,0 +1,17 @@
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { AlarmController } from './alarm.controller';
+import { AlarmService } from './alarm.service';
+import { AlarmSubscriber } from './alarm.subscriber';
+import { Alarm } from './domain/alarm.entity';
+import { PushSubscription } from './domain/subscription.entity';
+import { PushController } from './push.controller';
+import { PushService } from './push.service';
+
+@Module({
+  imports: [TypeOrmModule.forFeature([Alarm, PushSubscription])],
+  controllers: [AlarmController, PushController],
+  providers: [AlarmService, PushService, AlarmSubscriber],
+  exports: [AlarmService],
+})
+export class AlarmModule {}