feat(be): implement polygon tool upload

apps/backend/apps/admin/src/polygon/file/file.service.ts

@@ -0,0 +1,49 @@
+import { Injectable } from '@nestjs/common'
+import type { ToolType } from '@prisma/client'
+import type { FileUpload } from 'graphql-upload/processRequest.mjs'
+import { UnprocessableDataException } from '@libs/exception'
+import { PrismaService } from '@libs/prisma'
+
+const MAX_TOOL_FILE_SIZE = 10 * 1024 * 1024 // 10MB
+
+@Injectable()
+export class FileService {
+  constructor(private readonly prisma: PrismaService) {}
+
+  async uploadPolygonToolFile(
+    problemId: number,
+    toolType: ToolType,
+    file: FileUpload
+  ) {
+    const { filename, createReadStream } = file
+
+    //ReadStream → [chunk1, chunk2, chunk3, ...] → Buffer.concat
+    //→ 최종 Buffer로 변환해 → DB(PostgreSQL)에 저장
+    const chunks: Buffer[] = []
+    let total = 0
+    for await (const chunk of createReadStream()) {
+      total += chunk.length
+      if (total > MAX_TOOL_FILE_SIZE) {
+        throw new UnprocessableDataException('File size exceeds maximum limit')
+      }
+      chunks.push(chunk)
+    }
+    const fileContent = Buffer.concat(chunks).toString('utf-8')
+
+    // (problemId, toolType) unique — 재업로드 시 갱신
+    const tool = await this.prisma.polygonTool.upsert({
+      // eslint-disable-next-line @typescript-eslint/naming-convention
+      where: { problemId_toolType: { problemId, toolType } },
+      update: { fileName: filename, fileContent },
+      create: { problemId, toolType, fileName: filename, fileContent }
+    })
+    return tool
+  }
+
+  async deletePolygonFile(problemId: number, toolType: ToolType) {
+    return await this.prisma.polygonTool.delete({
+      // eslint-disable-next-line @typescript-eslint/naming-convention
+      where: { problemId_toolType: { problemId, toolType } }
+    })
+  }
+}

apps/backend/apps/admin/src/polygon/polygon.module.ts

@@ -1,10 +1,12 @@
 import { Module } from '@nestjs/common'
+import { AMQPModule } from '@libs/amqp'
 import { RolesModule } from '@libs/auth'
+import { FileService } from './file/file.service'
 import { PolygonResolver } from './polygon.resolver'
 import { PolygonService } from './polygon.service'
 
 @Module({
-  imports: [RolesModule],
-  providers: [PolygonResolver, PolygonService]
+  imports: [RolesModule, AMQPModule],
+  providers: [PolygonResolver, PolygonService, FileService]
 })
 export class PolygonModule {}

apps/backend/apps/admin/src/polygon/polygon.resolver.ts

@@ -1,10 +1,34 @@
-import { Resolver } from '@nestjs/graphql'
+import { Args, Int, Mutation, Resolver } from '@nestjs/graphql'
+import { ToolType } from '@prisma/client'
+import GraphQLUpload from 'graphql-upload/GraphQLUpload.mjs'
+import type { FileUpload } from 'graphql-upload/processRequest.mjs'
 import { UseDisableAdminGuard } from '@libs/auth'
-import { PolygonProblem } from '@admin/@generated'
+import { PolygonProblem, PolygonTool } from '@admin/@generated'
 import { PolygonService } from './polygon.service'
 
 @Resolver(() => PolygonProblem)
 @UseDisableAdminGuard()
 export class PolygonResolver {
   constructor(private readonly polygonService: PolygonService) {}
+
+  @Mutation(() => PolygonTool)
+  async uploadPolygonTool(
+    @Args('problemId', { type: () => Int }) problemId: number,
+    @Args('toolType', { type: () => ToolType }) toolType: ToolType,
+    @Args('file', { type: () => GraphQLUpload }) file: Promise<FileUpload>
+  ) {
+    return this.polygonService.uploadPolygonTool(
+      problemId,
+      toolType,
+      await file
+    )
+  }
+
+  @Mutation(() => PolygonTool)
+  async deletePolygonTool(
+    @Args('problemId', { type: () => Int }) problemId: number,
+    @Args('toolType', { type: () => ToolType }) toolType: ToolType
+  ) {
+    return this.polygonService.deletePolygonTool(problemId, toolType)
+  }
 }

apps/backend/apps/admin/src/polygon/polygon.service.ts

@@ -1,7 +1,40 @@
 import { Injectable } from '@nestjs/common'
+import { ToolType } from '@prisma/client'
+import type { FileUpload } from 'graphql-upload/processRequest.mjs'
+import { PolygonAMQPService } from '@libs/amqp'
 import { PrismaService } from '@libs/prisma'
+import { FileService } from './file/file.service'
 
 @Injectable()
 export class PolygonService {
-  constructor(private readonly prisma: PrismaService) {}
+  constructor(
+    private readonly prisma: PrismaService,
+    private readonly fileService: FileService,
+    private readonly polygonAMQPService: PolygonAMQPService
+  ) {}
+
+  async uploadPolygonTool(
+    problemId: number,
+    toolType: ToolType,
+    file: FileUpload
+  ) {
+    //DB에 파일 저장
+    const uploadedTool = await this.fileService.uploadPolygonToolFile(
+      problemId,
+      toolType,
+      file
+    )
+
+    //RabbitMQ 메시지 발행
+    await this.polygonAMQPService.publishPolygonToolUploadMessage(
+      uploadedTool.problemId,
+      uploadedTool.toolType
+    )
+
+    return uploadedTool
+  }
+
+  async deletePolygonTool(problemId: number, toolType: ToolType) {
+    return this.fileService.deletePolygonFile(problemId, toolType)
+  }
 }

apps/backend/libs/amqp/src/amqp.module.ts

@@ -2,7 +2,11 @@ import { Module } from '@nestjs/common'
 import { ConfigModule, ConfigService } from '@nestjs/config'
 import { RabbitMQModule } from '@golevelup/nestjs-rabbitmq'
 import { CONSUME_CHANNEL, PUBLISH_CHANNEL } from '@libs/constants'
-import { CheckAMQPService, JudgeAMQPService } from './amqp.service'
+import {
+  CheckAMQPService,
+  JudgeAMQPService,
+  PolygonAMQPService
+} from './amqp.service'
 
 @Module({
   imports: [
@@ -41,7 +45,7 @@ import { CheckAMQPService, JudgeAMQPService } from './amqp.service'
       inject: [ConfigService]
     })
   ],
-  providers: [JudgeAMQPService, CheckAMQPService],
-  exports: [JudgeAMQPService, CheckAMQPService]
+  providers: [JudgeAMQPService, CheckAMQPService, PolygonAMQPService],
+  exports: [JudgeAMQPService, CheckAMQPService, PolygonAMQPService]
 })
 export class AMQPModule {}

apps/backend/libs/constants/src/rabbitmq.constants.ts

@@ -33,3 +33,13 @@ export const CHECK_RESULT_KEY = 'check.result'
 export const CHECK_RESULT_QUEUE = 'plag.q.check.result'
 
 export const CHECK_MESSAGE_TYPE = 'check'
+
+/**
+ * Polygon Tool 업로드
+ */
+
+export const POLYGON_EXCHANGE = 'iris.e.direct.polygon'
+
+export const POLYGON_TOOL_KEY = 'polygon.tool'
+
+export const POLYGON_TOOL_MESSAGE_TYPE = 'polygonTool'

apps/backend/prisma/schema.prisma

@@ -1136,9 +1136,9 @@ model PolygonTool {
   problem   PolygonProblem @relation(fields: [problemId], references: [id], onDelete: Cascade)
   problemId Int            @map("problem_id")
 
-  toolType ToolType @map("tool_type") // 'generator' | 'validator' | 'checker'
-  fileName String   @map("file_name")
-  filePath String   @map("file_path") // S3 key
+  toolType    ToolType @map("tool_type") // 'generator' | 'validator' | 'checker'
+  fileName    String   @map("file_name")
+  fileContent String   @map("file_content")
 
   createTime DateTime @default(now()) @map("create_time")
   updateTime DateTime @updatedAt @map("update_time")