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/interface/polygonToolRequest.interface.ts

@@ -0,0 +1,15 @@
+export interface GeneratorRequest {
+  problemId: number
+  generatorLanguage: string
+  generatorCode: string
+  generatorArgs: string[]
+  solutionLanguage: string
+  solutionCode: string
+  testCaseCount: number
+}
+
+export interface ValidatorRequest {
+  problemId: number
+  language: string
+  validatorCode: string
+}

apps/backend/apps/admin/src/polygon/interface/polygonToolResult.interface.ts

@@ -0,0 +1,23 @@
+export interface GeneratorResultMessage {
+  submissionId: number
+  resultCode: number
+  judgeResult: {
+    generatedTestCases: number
+    totalTestCases: number
+  }
+  error: string
+}
+
+export interface ValidatorResultMessage {
+  submissionId: number
+  resultCode: number
+  judgeResult: {
+    isValid: boolean
+    testcaseCount: number
+    results: Array<{
+      id: number
+      isValid: boolean
+    }>
+  }
+  error: string
+}

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

@@ -0,0 +1,55 @@
+import { Language, ToolType } from '@prisma/client'
+import type { PolygonAMQPService } from '@libs/amqp'
+import type { PrismaService } from '@libs/prisma'
+
+export class PolygonPublicationService {
+  constructor(
+    private readonly prisma: PrismaService,
+    private readonly amqpService: PolygonAMQPService
+  ) {}
+
+  async publishGeneratorMessage(
+    problemId: number,
+    generatorArgs: string[],
+    testCaseCount: number
+  ) {
+    //DB에서 generator, solution 조회
+    const [generator, solution] = await Promise.all([
+      this.prisma.polygonTool.findUniqueOrThrow({
+        where: {
+          // eslint-disable-next-line @typescript-eslint/naming-convention
+          problemId_toolType: { problemId, toolType: ToolType.Generator }
+        }
+      }),
+      this.prisma.polygonSolution.findUniqueOrThrow({
+        where: { problemId }
+      })
+    ])
+
+    //실행 요청 메시지 publish
+    await this.amqpService.publishGeneratorMessage({
+      problemId,
+      generatorLanguage: Language.Cpp,
+      generatorCode: generator.fileContent,
+      generatorArgs,
+      solutionLanguage: solution.language,
+      solutionCode: solution.fileContent,
+      testCaseCount
+    })
+  }
+
+  async publishValidatorMessage(problemId: number) {
+    const validator = await this.prisma.polygonTool.findUniqueOrThrow({
+      where: {
+        // eslint-disable-next-line @typescript-eslint/naming-convention
+        problemId_toolType: { problemId, toolType: ToolType.Validator }
+      }
+    })
+
+    await this.amqpService.publishValidatorMessage({
+      problemId,
+      language: Language.Cpp,
+      validatorCode: validator.fileContent
+    })
+  }
+}

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,47 @@
 import { Injectable } from '@nestjs/common'
+import { ToolType } from '@prisma/client'
+import type { FileUpload } from 'graphql-upload/processRequest.mjs'
 import { PrismaService } from '@libs/prisma'
+import { FileService } from './file/file.service'
+import { PolygonPublicationService } from './polygon-pub.service'
 
 @Injectable()
 export class PolygonService {
-  constructor(private readonly prisma: PrismaService) {}
+  constructor(
+    private readonly prisma: PrismaService,
+    private readonly fileService: FileService,
+    private readonly publicationService: PolygonPublicationService
+  ) {}
+
+  async uploadPolygonTool(
+    problemId: number,
+    toolType: ToolType,
+    file: FileUpload
+  ) {
+    //DB에 파일 저장
+    await this.fileService.uploadPolygonToolFile(problemId, toolType, file)
+  }
+
+  async deletePolygonTool(problemId: number, toolType: ToolType) {
+    return this.fileService.deletePolygonFile(problemId, toolType)
+  }
+
+  //파일 실행
+  async runGenerator(
+    problemId: number,
+    generatorArgs: string[],
+    testCaseCount: number
+  ) {
+    await this.publicationService.publishGeneratorMessage(
+      problemId,
+      generatorArgs,
+      testCaseCount
+    )
+  }
+
+  async runValidator(problemId: number) {
+    await this.publicationService.publishValidatorMessage(problemId)
+  }
+
+  //테스트케이스 저장
 }

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 {}