From 085ed7c25925f7a05b690cb3b5926f105975d690 Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 00:29:41 +0900
Subject: [PATCH 01/10] =?UTF-8?q?CLAP-283=20Chore:=20clamAV=20=EC=9D=98?=
 =?UTF-8?q?=EC=A1=B4=EC=84=B1=20=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #328
---
 build.gradle | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/build.gradle b/build.gradle
index 5d38b838..adafc73b 100644
--- a/build.gradle
+++ b/build.gradle
@@ -107,6 +107,10 @@ dependencies {
     implementation 'org.apache.tika:tika-core:2.9.0'
     implementation 'org.apache.tika:tika-parsers:2.9.0'
 
+    // Clam AV
+    implementation group: 'xyz.capybara', name: 'clamav-client', version: '2.1.2'
+
+
 }
 
 tasks.named('test') {

From 207275d17cea1088a5287f747b137b179b2b24ce Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 00:31:04 +0900
Subject: [PATCH 02/10] =?UTF-8?q?CLAP-283=20Chore:=20ClamAVConfig=20?=
 =?UTF-8?q?=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #328
---
 .../server/config/clamav/ClamAVConfig.java    | 20 +++++++++++++++++++
 src/main/resources/clamav.yml                 |  3 +++
 2 files changed, 23 insertions(+)
 create mode 100644 src/main/java/clap/server/config/clamav/ClamAVConfig.java
 create mode 100644 src/main/resources/clamav.yml

diff --git a/src/main/java/clap/server/config/clamav/ClamAVConfig.java b/src/main/java/clap/server/config/clamav/ClamAVConfig.java
new file mode 100644
index 00000000..fe59e087
--- /dev/null
+++ b/src/main/java/clap/server/config/clamav/ClamAVConfig.java
@@ -0,0 +1,20 @@
+package clap.server.config.clamav;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import xyz.capybara.clamav.ClamavClient;
+
+@Configuration
+public class ClamAVConfig {
+    @Value("${clamav.host}")
+    private String host;
+    
+    @Value("${clamav.port}")
+    private int port;
+    
+    @Bean
+    public ClamavClient clamavClient() {
+        return new ClamavClient(host, port);
+    }
+}
diff --git a/src/main/resources/clamav.yml b/src/main/resources/clamav.yml
new file mode 100644
index 00000000..09232cfc
--- /dev/null
+++ b/src/main/resources/clamav.yml
@@ -0,0 +1,3 @@
+clamav:
+  host: localhost
+  port: 3310
\ No newline at end of file

From 9463bd3cf19fe1471b34991628d30a3030ae8c31 Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 00:32:18 +0900
Subject: [PATCH 03/10] =?UTF-8?q?CLAP-283=20Chore:=20clam=20=EB=B9=84?=
 =?UTF-8?q?=EB=8F=99=EA=B8=B0=20=EC=84=A4=EC=A0=95=20=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #328
---
 .../java/clap/server/config/async/AsyncConfig.java | 14 ++++++++++++--
 1 file changed, 12 insertions(+), 2 deletions(-)

diff --git a/src/main/java/clap/server/config/async/AsyncConfig.java b/src/main/java/clap/server/config/async/AsyncConfig.java
index 8671f0eb..46f7edd4 100644
--- a/src/main/java/clap/server/config/async/AsyncConfig.java
+++ b/src/main/java/clap/server/config/async/AsyncConfig.java
@@ -8,8 +8,6 @@
 @Configuration
 @EnableAsync
 public class AsyncConfig {
-
-
     @Bean(name = "notificationExecutor")
     public ThreadPoolTaskExecutor taskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
@@ -26,4 +24,16 @@ public ThreadPoolTaskExecutor taskExecutor() {
         executor.initialize();
         return executor;
     }
+
+    @Bean(name = "clamavExecutor")
+    public ThreadPoolTaskExecutor clamavExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(10);
+        executor.setMaxPoolSize(50);
+        executor.setQueueCapacity(500);
+        executor.setThreadNamePrefix("clamav-scan-");
+        executor.setKeepAliveSeconds(120);
+        executor.initialize();
+        return executor;
+    }
 }

From cec4d0bc9948875aa4d9d96e493662544acca952 Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 00:32:48 +0900
Subject: [PATCH 04/10] =?UTF-8?q?CLAP-283=20Config:=20clamAV=20=EC=9D=98?=
 =?UTF-8?q?=EC=A1=B4=EC=84=B1=20=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #328
---
 src/main/resources/application.yml | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index d8331c82..1bc18d13 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -10,6 +10,7 @@ spring:
       - elasticsearch.yml
       - s3.yml
       - notifications.yml
+      - clamav.yml
   application:
     name: taskflow
   web.resources.add-mappings: false
@@ -34,19 +35,20 @@ web:
 local: ${TASKFLOW_LOCAL_WEB:127.0.0.1:5173}
 service: ${TASKFLOW_SERVICE_WEB:127.0.0.1:5173}
 
-#logging:
-#  level:
-#    root: INFO
-#    taskflow.clap.server: ERROR
+logging:
+  level:
+    root: INFO
+    taskflow.clap.server: DEBUG
 #    org:
 #      springframework: DEBUG
 
+
 ---
 spring.config.activate.on-profile: local
 logging:
   level:
     root: INFO
-    taskflow.clap.server: ERROR
+    taskflow.clap.server: DEBUG
 #    org:
 #      springframework: DEBUG
 

From d76f96d5859add36f8830df93212fc4029c3b9a5 Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 00:34:33 +0900
Subject: [PATCH 05/10] =?UTF-8?q?CLAP-283=20Config:=20ClamAVScanner=20?=
 =?UTF-8?q?=EA=B5=AC=ED=98=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #328
---
 .../infrastructure/clamav/ClamAVScanner.java  | 76 +++++++++++++++++++
 .../clamav/FileVirusScanner.java              | 71 +++++++++++++++++
 .../clamav/FileVirusScannerPort.java          |  9 +++
 .../service/task/CreateTaskService.java       | 12 ++-
 .../server/exception/code/FileErrorcode.java  |  4 +-
 5 files changed, 167 insertions(+), 5 deletions(-)
 create mode 100644 src/main/java/clap/server/adapter/outbound/infrastructure/clamav/ClamAVScanner.java
 create mode 100644 src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScanner.java
 create mode 100644 src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScannerPort.java

diff --git a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/ClamAVScanner.java b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/ClamAVScanner.java
new file mode 100644
index 00000000..ae32e831
--- /dev/null
+++ b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/ClamAVScanner.java
@@ -0,0 +1,76 @@
+package clap.server.adapter.outbound.infrastructure.clamav;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+import org.springframework.stereotype.Component;
+import xyz.capybara.clamav.ClamavClient;
+import xyz.capybara.clamav.ClamavException;
+import xyz.capybara.clamav.commands.scan.result.ScanResult;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.nio.file.StandardCopyOption;
+import java.util.UUID;
+import java.util.concurrent.CompletableFuture;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class ClamAVScanner {
+    private final ClamavClient client;
+    private final ThreadPoolTaskExecutor clamavExecutor;
+
+    public CompletableFuture<Boolean> scanFileAsync(String filePath) {
+        return CompletableFuture.supplyAsync(() -> {
+            Path originalPath = Paths.get(filePath);
+            Path tempPath = null;
+            try {
+                String originalFileName = originalPath.getFileName().toString();
+                String fileExtension = getFileExtension(originalFileName);
+                String tempFileName = "scan_" + UUID.randomUUID() + fileExtension;
+                tempPath = Files.createTempFile("scan_", tempFileName);
+
+                Files.copy(originalPath, tempPath, StandardCopyOption.REPLACE_EXISTING);
+
+                ScanResult result = client.scan(tempPath);
+                if (result instanceof ScanResult.OK) {
+                    log.info("파일이 안전합니다: {}", originalFileName);
+                    return true;
+                } else if (result instanceof ScanResult.VirusFound virusFound) {
+                    log.warn("바이러스 발견: {} in {}", virusFound.getFoundViruses(), originalFileName);
+                    return false;
+                }
+                log.warn("알 수 없는 스캔 결과 타입: {}", result.getClass().getName());
+                return false;
+            } catch (IOException e) {
+                log.error("파일 처리 중 오류 발생: {}", filePath, e);
+                return false;
+            } catch (ClamavException e) {
+                log.error("ClamAV 스캔 중 오류 발생: {}", filePath, e);
+                return false;
+            } catch (Exception e) {
+                log.error("예상치 못한 오류 발생: {}", filePath, e);
+                return false;
+            } finally {
+                if (tempPath != null) {
+                    try {
+                        Files.deleteIfExists(tempPath);
+                    } catch (IOException e) {
+                        log.warn("임시 파일 삭제 실패: {}", tempPath, e);
+                    }
+                }
+            }
+        }, clamavExecutor);
+    }
+
+    private String getFileExtension(String fileName) {
+        int lastIndexOf = fileName.lastIndexOf(".");
+        if (lastIndexOf == -1) {
+            return ""; // 확장자가 없는 경우
+        }
+        return fileName.substring(lastIndexOf);
+    }
+}
diff --git a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScanner.java b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScanner.java
new file mode 100644
index 00000000..7d56aad0
--- /dev/null
+++ b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScanner.java
@@ -0,0 +1,71 @@
+package clap.server.adapter.outbound.infrastructure.clamav;
+
+import clap.server.exception.AdapterException;
+import clap.server.exception.code.FileErrorcode;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.StandardCopyOption;
+import java.util.List;
+import java.util.Objects;
+import java.util.concurrent.CompletableFuture;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class FileVirusScanner implements FileVirusScannerPort {
+    private final ClamAVScanner clamAVScanner;
+
+    public List<MultipartFile> scanFiles(List<MultipartFile> files) {
+        List<CompletableFuture<MultipartFile>> scanResults = files.stream()
+                .map(this::scanFile)
+                .toList();
+
+        CompletableFuture.allOf(scanResults.toArray(new CompletableFuture[0])).join();
+
+        return scanResults.stream()
+                .map(CompletableFuture::join)
+                .filter(Objects::nonNull)
+                .collect(Collectors.toList());
+    }
+
+    @Async("clamavExecutor")
+    protected CompletableFuture<MultipartFile> scanFile(MultipartFile file) {
+        return CompletableFuture.supplyAsync(() -> {
+            Path tempPath = null;
+            try {
+                tempPath = Files.createTempFile("scan_", "_" + file.getOriginalFilename());
+                try (InputStream inputStream = file.getInputStream()) {
+                    Files.copy(inputStream, tempPath, StandardCopyOption.REPLACE_EXISTING);
+                }
+
+                boolean isSafe = clamAVScanner.scanFileAsync(tempPath.toString()).get();
+                if (isSafe) {
+                    return file;
+                } else {
+                    log.warn("Virus detected in file: {}", file.getOriginalFilename());
+                    throw new AdapterException(FileErrorcode.VIRUS_FILE_DETECTED);
+                }
+            } catch (Exception e) {
+                log.error("Failed to scan file: {}", file.getOriginalFilename(), e);
+                return null;
+            } finally {
+                if (tempPath != null) {
+                    try {
+                        Files.deleteIfExists(tempPath);
+                    } catch (IOException e) {
+                        log.error("Failed to delete temp file: {}", tempPath, e);
+                    }
+                }
+            }
+        });
+    }
+}
diff --git a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScannerPort.java b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScannerPort.java
new file mode 100644
index 00000000..fbdfdf6e
--- /dev/null
+++ b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScannerPort.java
@@ -0,0 +1,9 @@
+package clap.server.adapter.outbound.infrastructure.clamav;
+
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+
+public interface FileVirusScannerPort {
+    List<MultipartFile> scanFiles(List<MultipartFile> files);
+}
diff --git a/src/main/java/clap/server/application/service/task/CreateTaskService.java b/src/main/java/clap/server/application/service/task/CreateTaskService.java
index 3601aed0..8318411d 100644
--- a/src/main/java/clap/server/application/service/task/CreateTaskService.java
+++ b/src/main/java/clap/server/application/service/task/CreateTaskService.java
@@ -2,7 +2,7 @@
 
 import clap.server.adapter.inbound.web.dto.task.request.CreateTaskRequest;
 import clap.server.adapter.inbound.web.dto.task.response.CreateTaskResponse;
-
+import clap.server.adapter.outbound.infrastructure.clamav.FileVirusScannerPort;
 import clap.server.adapter.outbound.persistense.entity.member.constant.MemberRole;
 import clap.server.adapter.outbound.persistense.entity.notification.constant.NotificationType;
 import clap.server.application.mapper.AttachmentMapper;
@@ -15,15 +15,16 @@
 import clap.server.application.port.outbound.task.CommandTaskPort;
 import clap.server.application.service.webhook.SendNotificationService;
 import clap.server.common.annotation.architecture.ApplicationService;
-import clap.server.domain.policy.attachment.FilePathPolicy;
 import clap.server.domain.model.member.Member;
 import clap.server.domain.model.task.Attachment;
 import clap.server.domain.model.task.Category;
 import clap.server.domain.model.task.Task;
+import clap.server.domain.policy.attachment.FilePathPolicy;
 import lombok.RequiredArgsConstructor;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
 
+import java.util.ArrayList;
 import java.util.List;
 
 
@@ -37,6 +38,7 @@ public class CreateTaskService implements CreateTaskUsecase {
     private final CommandAttachmentPort commandAttachmentPort;
     private final S3UploadPort s3UploadPort;
     private final SendNotificationService sendNotificationService;
+    private final FileVirusScannerPort fileVirusScannerPort;
 
     @Override
     @Transactional
@@ -44,12 +46,14 @@ public CreateTaskResponse createTask(Long requesterId, CreateTaskRequest createT
         Member member = memberService.findActiveMember(requesterId);
         Category category = categoryService.findById(createTaskRequest.categoryId());
         Task task = Task.createTask(member, category, createTaskRequest.title(), createTaskRequest.description());
+        List<MultipartFile> scannedFiles = (files != null && !files.isEmpty()) ? fileVirusScannerPort.scanFiles(files) : new ArrayList<>();
         Task savedTask = commandTaskPort.save(task);
         savedTask.setInitialProcessorOrder();
         commandTaskPort.save(savedTask);
 
-        if (files != null) {
-            saveAttachments(files, savedTask);}
+        if (!scannedFiles.isEmpty()) {
+            saveAttachments(scannedFiles, savedTask);
+        }
         publishNotification(savedTask);
         return TaskResponseMapper.toCreateTaskResponse(savedTask);
     }
diff --git a/src/main/java/clap/server/exception/code/FileErrorcode.java b/src/main/java/clap/server/exception/code/FileErrorcode.java
index dae4869f..02887e79 100644
--- a/src/main/java/clap/server/exception/code/FileErrorcode.java
+++ b/src/main/java/clap/server/exception/code/FileErrorcode.java
@@ -8,7 +8,9 @@
 @RequiredArgsConstructor
 public enum FileErrorcode implements BaseErrorCode {
     FILE_UPLOAD_REQUEST_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "FILE_001", "파일 업로드에 실패하였습니다."),
-    UNSUPPORTED_FILE_TYPE(HttpStatus.BAD_REQUEST, "FILE_002", "유효하지 않은 파일 유형입니다."),;
+    UNSUPPORTED_FILE_TYPE(HttpStatus.BAD_REQUEST, "FILE_002", "유효하지 않은 파일 유형입니다."),
+    VIRUS_FILE_DETECTED(HttpStatus.BAD_REQUEST, "FILE_003", "안전하지 않은 파일이 감지되었습니다.")
+    ;
 
     private final HttpStatus httpStatus;
     private final String customCode;

From 2d284673d5621182e0774a3807ec1b3c2fc257cf Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 02:00:51 +0900
Subject: [PATCH 06/10] =?UTF-8?q?CLAP-310=20Feat:=20=ED=8C=8C=EC=9D=BC=20?=
 =?UTF-8?q?=EC=8A=A4=EC=BA=94=20=EA=B8=B0=EB=8A=A5=EC=9D=84=20=ED=8F=AC?=
 =?UTF-8?q?=ED=95=A8=ED=95=9C=20=EC=9A=94=EC=B2=AD=20=EC=83=9D=EC=84=B1=20?=
 =?UTF-8?q?api=20v2=20=EA=B5=AC=ED=98=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #380
---
 .../inbound/web/task/ManagementTaskController.java | 11 +++++++++++
 .../port/inbound/task/CreateTaskUsecase.java       |  2 ++
 .../service/task/CreateTaskService.java            | 14 ++++++++++++++
 3 files changed, 27 insertions(+)

diff --git a/src/main/java/clap/server/adapter/inbound/web/task/ManagementTaskController.java b/src/main/java/clap/server/adapter/inbound/web/task/ManagementTaskController.java
index be475dd8..361a74e7 100644
--- a/src/main/java/clap/server/adapter/inbound/web/task/ManagementTaskController.java
+++ b/src/main/java/clap/server/adapter/inbound/web/task/ManagementTaskController.java
@@ -43,6 +43,17 @@ public ResponseEntity<CreateTaskResponse> createTask(
             return ResponseEntity.ok(createTaskUsecase.createTask(userInfo.getUserId(), createTaskRequest, attachments));
     }
 
+    @Operation(summary = "작업 요청 생성, 파일 스캔 기능 추가")
+    @PostMapping(value = "/v2", consumes = {MediaType.MULTIPART_FORM_DATA_VALUE, MediaType.APPLICATION_JSON_VALUE})
+    @Secured({"ROLE_MANAGER", "ROLE_USER"})
+    public ResponseEntity<CreateTaskResponse> createTaskWithScanner(
+            @RequestPart(name = "taskInfo") @Valid CreateTaskRequest createTaskRequest,
+            @RequestPart(name = "attachment", required = false) List<MultipartFile> attachments,
+            @AuthenticationPrincipal SecurityUserDetails userInfo
+    ){
+        return ResponseEntity.ok(createTaskUsecase.createTaskWithScanner(userInfo.getUserId(), createTaskRequest, attachments));
+    }
+
     @Operation(summary = "작업 수정")
     @PatchMapping(value = "/{taskId}", consumes = {MediaType.MULTIPART_FORM_DATA_VALUE, MediaType.APPLICATION_JSON_VALUE})
     @Secured({"ROLE_MANAGER", "ROLE_USER"})
diff --git a/src/main/java/clap/server/application/port/inbound/task/CreateTaskUsecase.java b/src/main/java/clap/server/application/port/inbound/task/CreateTaskUsecase.java
index 385c579d..e6c07959 100644
--- a/src/main/java/clap/server/application/port/inbound/task/CreateTaskUsecase.java
+++ b/src/main/java/clap/server/application/port/inbound/task/CreateTaskUsecase.java
@@ -8,4 +8,6 @@
 
 public interface CreateTaskUsecase {
     CreateTaskResponse createTask(Long requesterId, CreateTaskRequest createTaskRequest, List<MultipartFile> files);
+
+    CreateTaskResponse createTaskWithScanner(Long requesterId, CreateTaskRequest createTaskRequest, List<MultipartFile> files);
 }
diff --git a/src/main/java/clap/server/application/service/task/CreateTaskService.java b/src/main/java/clap/server/application/service/task/CreateTaskService.java
index 8318411d..21a14051 100644
--- a/src/main/java/clap/server/application/service/task/CreateTaskService.java
+++ b/src/main/java/clap/server/application/service/task/CreateTaskService.java
@@ -43,6 +43,20 @@ public class CreateTaskService implements CreateTaskUsecase {
     @Override
     @Transactional
     public CreateTaskResponse createTask(Long requesterId, CreateTaskRequest createTaskRequest, List<MultipartFile> files) {
+        Member member = memberService.findActiveMember(requesterId);
+        Category category = categoryService.findById(createTaskRequest.categoryId());
+        Task task = Task.createTask(member, category, createTaskRequest.title(), createTaskRequest.description());
+        Task savedTask = commandTaskPort.save(task);
+        savedTask.setInitialProcessorOrder();
+        commandTaskPort.save(savedTask);
+
+        if (files != null) {saveAttachments(files, savedTask);}
+        publishNotification(savedTask);
+        return TaskResponseMapper.toCreateTaskResponse(savedTask);
+    }
+
+    @Override
+    public CreateTaskResponse createTaskWithScanner(Long requesterId, CreateTaskRequest createTaskRequest, List<MultipartFile> files) {
         Member member = memberService.findActiveMember(requesterId);
         Category category = categoryService.findById(createTaskRequest.categoryId());
         Task task = Task.createTask(member, category, createTaskRequest.title(), createTaskRequest.description());

From 08d46858bcf970bdcab4246c90e086819bf802f7 Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 10:47:49 +0900
Subject: [PATCH 07/10] =?UTF-8?q?CLAP-310=20Style:=20task=20=EC=B2=A8?=
 =?UTF-8?q?=EB=B6=80=ED=8C=8C=EC=9D=BC=20=EA=B2=BD=EB=A1=9C=20=EC=9E=AC?=
 =?UTF-8?q?=EC=84=A4=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #380
---
 .../server/application/service/task/UpdateTaskService.java     | 2 +-
 .../clap/server/domain/policy/attachment/FilePathPolicy.java   | 3 +--
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/main/java/clap/server/application/service/task/UpdateTaskService.java b/src/main/java/clap/server/application/service/task/UpdateTaskService.java
index 358ed8cf..33c23113 100644
--- a/src/main/java/clap/server/application/service/task/UpdateTaskService.java
+++ b/src/main/java/clap/server/application/service/task/UpdateTaskService.java
@@ -125,7 +125,7 @@ private void updateAttachments(List<Long> attachmentIdsToDelete, List<MultipartF
         attachmentsToDelete.forEach(Attachment::softDelete);
 
         if (files != null) {
-            List<String> fileUrls = s3UploadPort.uploadFiles(FilePathPolicy.TASK_IMAGE, files);
+            List<String> fileUrls = s3UploadPort.uploadFiles(FilePathPolicy.TASK_FILE, files);
             List<Attachment> attachments = AttachmentMapper.toTaskAttachments(task, files, fileUrls);
             commandAttachmentPort.saveAll(attachments);
         }
diff --git a/src/main/java/clap/server/domain/policy/attachment/FilePathPolicy.java b/src/main/java/clap/server/domain/policy/attachment/FilePathPolicy.java
index 8d15a9b9..26959572 100644
--- a/src/main/java/clap/server/domain/policy/attachment/FilePathPolicy.java
+++ b/src/main/java/clap/server/domain/policy/attachment/FilePathPolicy.java
@@ -6,8 +6,7 @@
 @Getter
 @RequiredArgsConstructor
 public enum FilePathPolicy {
-    TASK_IMAGE("task/image"),
-    TASK_DOCUMENT("task/docs"),
+    TASK_FILE("task"),
     TASK_COMMENT("task/comments"),
     MEMBER_IMAGE("member"),
     ;

From ee030f28f594fa8539a4afcaa9eb0fb21e6710ba Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 10:49:48 +0900
Subject: [PATCH 08/10] =?UTF-8?q?CLAP-310=20Fix:=20@Transactional=20?=
 =?UTF-8?q?=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #380
---
 .../application/service/webhook/SendNotificationService.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/main/java/clap/server/application/service/webhook/SendNotificationService.java b/src/main/java/clap/server/application/service/webhook/SendNotificationService.java
index 473a37b5..ef0c842f 100644
--- a/src/main/java/clap/server/application/service/webhook/SendNotificationService.java
+++ b/src/main/java/clap/server/application/service/webhook/SendNotificationService.java
@@ -9,6 +9,7 @@
 import clap.server.domain.model.task.Task;
 import lombok.RequiredArgsConstructor;
 import org.springframework.scheduling.annotation.Async;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.concurrent.CompletableFuture;
 
@@ -75,6 +76,7 @@ public void sendPushNotification(Member receiver, NotificationType notificationT
     }
 
     @Async("notificationExecutor")
+    @Transactional
     public void sendAgitNotification(NotificationType notificationType,
                                      Task task, String message, String commenterName) {
         PushNotificationTemplate pushNotificationTemplate = new PushNotificationTemplate(

From a16da66c9d95582ffc442f2c537bb225a676db5b Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 11:04:22 +0900
Subject: [PATCH 09/10] =?UTF-8?q?CLAP-310=20Docs:=20=ED=8C=8C=EC=9D=BC=20?=
 =?UTF-8?q?=EA=B0=9C=EC=88=98=20=EC=A0=9C=ED=95=9C=20=EB=AA=85=EC=84=B8=20?=
 =?UTF-8?q?=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #380
---
 .../inbound/web/task/ManagementTaskController.java       | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/main/java/clap/server/adapter/inbound/web/task/ManagementTaskController.java b/src/main/java/clap/server/adapter/inbound/web/task/ManagementTaskController.java
index 361a74e7..f91bb735 100644
--- a/src/main/java/clap/server/adapter/inbound/web/task/ManagementTaskController.java
+++ b/src/main/java/clap/server/adapter/inbound/web/task/ManagementTaskController.java
@@ -4,10 +4,11 @@
 import clap.server.adapter.inbound.web.dto.task.request.CreateTaskRequest;
 import clap.server.adapter.inbound.web.dto.task.request.UpdateTaskRequest;
 import clap.server.adapter.inbound.web.dto.task.response.CreateTaskResponse;
-import clap.server.adapter.inbound.web.dto.task.response.UpdateTaskResponse;
-import clap.server.application.port.inbound.task.*;
+import clap.server.application.port.inbound.task.CreateTaskUsecase;
+import clap.server.application.port.inbound.task.UpdateTaskUsecase;
 import clap.server.common.annotation.architecture.WebAdapter;
 import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.media.Schema;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.validation.Valid;
 import jakarta.validation.constraints.NotNull;
@@ -37,7 +38,7 @@ public class ManagementTaskController {
     @Secured({"ROLE_MANAGER", "ROLE_USER"})
     public ResponseEntity<CreateTaskResponse> createTask(
             @RequestPart(name = "taskInfo") @Valid CreateTaskRequest createTaskRequest,
-            @RequestPart(name = "attachment", required = false) List<MultipartFile> attachments,
+            @Schema(description = "파일은 5개 이하만 업로드 가능합니다.") @RequestPart(name = "attachment", required = false) List<MultipartFile> attachments,
             @AuthenticationPrincipal SecurityUserDetails userInfo
             ){
             return ResponseEntity.ok(createTaskUsecase.createTask(userInfo.getUserId(), createTaskRequest, attachments));
@@ -48,7 +49,7 @@ public ResponseEntity<CreateTaskResponse> createTask(
     @Secured({"ROLE_MANAGER", "ROLE_USER"})
     public ResponseEntity<CreateTaskResponse> createTaskWithScanner(
             @RequestPart(name = "taskInfo") @Valid CreateTaskRequest createTaskRequest,
-            @RequestPart(name = "attachment", required = false) List<MultipartFile> attachments,
+            @Schema(description = "파일은 5개 이하만 업로드 가능합니다.") @RequestPart(name = "attachment", required = false) List<MultipartFile> attachments,
             @AuthenticationPrincipal SecurityUserDetails userInfo
     ){
         return ResponseEntity.ok(createTaskUsecase.createTaskWithScanner(userInfo.getUserId(), createTaskRequest, attachments));

From 941443ffc677a36d6413c2c8e29d3f2c7cc32fbe Mon Sep 17 00:00:00 2001
From: joowojr <joowojr@gmail.com>
Date: Fri, 7 Feb 2025 11:05:12 +0900
Subject: [PATCH 10/10] =?UTF-8?q?CLAP-310=20Refactor:=20=EC=98=88=EC=99=B8?=
 =?UTF-8?q?=20=EC=B2=98=EB=A6=AC=20=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- 관련: #380
---
 .../infrastructure/clamav/ClamAVScanner.java  | 24 +++++++++----------
 .../clamav/FileVirusScanner.java              | 19 ++++++++-------
 .../clamav/FileVirusScannerPort.java          |  2 ++
 .../service/task/CreateTaskService.java       |  3 ++-
 .../server/exception/ClamAVException.java     | 13 ++++++++++
 .../server/exception/code/FileErrorcode.java  |  3 ++-
 6 files changed, 42 insertions(+), 22 deletions(-)
 create mode 100644 src/main/java/clap/server/exception/ClamAVException.java

diff --git a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/ClamAVScanner.java b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/ClamAVScanner.java
index ae32e831..64d3b6bd 100644
--- a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/ClamAVScanner.java
+++ b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/ClamAVScanner.java
@@ -1,5 +1,7 @@
 package clap.server.adapter.outbound.infrastructure.clamav;
 
+import clap.server.exception.ClamAVException;
+import clap.server.exception.code.FileErrorcode;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
@@ -20,10 +22,10 @@
 @Component
 @RequiredArgsConstructor
 public class ClamAVScanner {
-    private final ClamavClient client;
+    private final ClamavClient clamavClient;
     private final ThreadPoolTaskExecutor clamavExecutor;
 
-    public CompletableFuture<Boolean> scanFileAsync(String filePath) {
+    public CompletableFuture<Void> scanFileAsync(String filePath) {
         return CompletableFuture.supplyAsync(() -> {
             Path originalPath = Paths.get(filePath);
             Path tempPath = null;
@@ -35,25 +37,23 @@ public CompletableFuture<Boolean> scanFileAsync(String filePath) {
 
                 Files.copy(originalPath, tempPath, StandardCopyOption.REPLACE_EXISTING);
 
-                ScanResult result = client.scan(tempPath);
+                ScanResult result = clamavClient.scan(tempPath);
                 if (result instanceof ScanResult.OK) {
                     log.info("파일이 안전합니다: {}", originalFileName);
-                    return true;
                 } else if (result instanceof ScanResult.VirusFound virusFound) {
                     log.warn("바이러스 발견: {} in {}", virusFound.getFoundViruses(), originalFileName);
-                    return false;
+                    throw new ClamAVException(FileErrorcode.VIRUS_FILE_DETECTED);
+                } else {
+                    log.warn("알 수 없는 스캔 결과 타입: {}", result.getClass().getName());
+                    throw new ClamAVException(FileErrorcode.FILE_SCAN_FAILED);
                 }
-                log.warn("알 수 없는 스캔 결과 타입: {}", result.getClass().getName());
-                return false;
+                return null;
             } catch (IOException e) {
                 log.error("파일 처리 중 오류 발생: {}", filePath, e);
-                return false;
+                throw new ClamavException(e);
             } catch (ClamavException e) {
                 log.error("ClamAV 스캔 중 오류 발생: {}", filePath, e);
-                return false;
-            } catch (Exception e) {
-                log.error("예상치 못한 오류 발생: {}", filePath, e);
-                return false;
+                throw new ClamavException(e);
             } finally {
                 if (tempPath != null) {
                     try {
diff --git a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScanner.java b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScanner.java
index 7d56aad0..40e38420 100644
--- a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScanner.java
+++ b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScanner.java
@@ -1,6 +1,7 @@
 package clap.server.adapter.outbound.infrastructure.clamav;
 
 import clap.server.exception.AdapterException;
+import clap.server.exception.ClamAVException;
 import clap.server.exception.code.FileErrorcode;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -16,6 +17,7 @@
 import java.util.List;
 import java.util.Objects;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
 import java.util.stream.Collectors;
 
 @Slf4j
@@ -37,6 +39,10 @@ public List<MultipartFile> scanFiles(List<MultipartFile> files) {
                 .collect(Collectors.toList());
     }
 
+    public MultipartFile scanSingleFile(MultipartFile file) throws ExecutionException, InterruptedException {
+        return scanFile(file).get();
+    }
+
     @Async("clamavExecutor")
     protected CompletableFuture<MultipartFile> scanFile(MultipartFile file) {
         return CompletableFuture.supplyAsync(() -> {
@@ -46,14 +52,11 @@ protected CompletableFuture<MultipartFile> scanFile(MultipartFile file) {
                 try (InputStream inputStream = file.getInputStream()) {
                     Files.copy(inputStream, tempPath, StandardCopyOption.REPLACE_EXISTING);
                 }
-
-                boolean isSafe = clamAVScanner.scanFileAsync(tempPath.toString()).get();
-                if (isSafe) {
-                    return file;
-                } else {
-                    log.warn("Virus detected in file: {}", file.getOriginalFilename());
-                    throw new AdapterException(FileErrorcode.VIRUS_FILE_DETECTED);
-                }
+                clamAVScanner.scanFileAsync(tempPath.toString()).get();
+                return file;
+            } catch (ClamAVException e) {
+                log.warn("Virus detected in file: {}", file.getOriginalFilename());
+                throw new AdapterException(FileErrorcode.FILE_SCAN_FAILED);
             } catch (Exception e) {
                 log.error("Failed to scan file: {}", file.getOriginalFilename(), e);
                 return null;
diff --git a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScannerPort.java b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScannerPort.java
index fbdfdf6e..b5d5490d 100644
--- a/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScannerPort.java
+++ b/src/main/java/clap/server/adapter/outbound/infrastructure/clamav/FileVirusScannerPort.java
@@ -3,7 +3,9 @@
 import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 public interface FileVirusScannerPort {
     List<MultipartFile> scanFiles(List<MultipartFile> files);
+    MultipartFile scanSingleFile(MultipartFile file) throws ExecutionException, InterruptedException;
 }
diff --git a/src/main/java/clap/server/application/service/task/CreateTaskService.java b/src/main/java/clap/server/application/service/task/CreateTaskService.java
index 21a14051..d8a55567 100644
--- a/src/main/java/clap/server/application/service/task/CreateTaskService.java
+++ b/src/main/java/clap/server/application/service/task/CreateTaskService.java
@@ -56,6 +56,7 @@ public CreateTaskResponse createTask(Long requesterId, CreateTaskRequest createT
     }
 
     @Override
+    @Transactional
     public CreateTaskResponse createTaskWithScanner(Long requesterId, CreateTaskRequest createTaskRequest, List<MultipartFile> files) {
         Member member = memberService.findActiveMember(requesterId);
         Category category = categoryService.findById(createTaskRequest.categoryId());
@@ -73,7 +74,7 @@ public CreateTaskResponse createTaskWithScanner(Long requesterId, CreateTaskRequ
     }
 
     private void saveAttachments(List<MultipartFile> files, Task task) {
-        List<String> fileUrls = s3UploadPort.uploadFiles(FilePathPolicy.TASK_IMAGE, files);
+        List<String> fileUrls = s3UploadPort.uploadFiles(FilePathPolicy.TASK_FILE, files);
         List<Attachment> attachments = AttachmentMapper.toTaskAttachments(task, files, fileUrls);
         commandAttachmentPort.saveAll(attachments);
     }
diff --git a/src/main/java/clap/server/exception/ClamAVException.java b/src/main/java/clap/server/exception/ClamAVException.java
new file mode 100644
index 00000000..b0c54844
--- /dev/null
+++ b/src/main/java/clap/server/exception/ClamAVException.java
@@ -0,0 +1,13 @@
+package clap.server.exception;
+
+import clap.server.exception.code.BaseErrorCode;
+
+public class ClamAVException extends BaseException {
+    public ClamAVException(BaseErrorCode code) {
+        super(code);
+    }
+
+    public BaseErrorCode getErrorCode() {
+        return (BaseErrorCode)super.getCode();
+    }
+}
\ No newline at end of file
diff --git a/src/main/java/clap/server/exception/code/FileErrorcode.java b/src/main/java/clap/server/exception/code/FileErrorcode.java
index 02887e79..3d193292 100644
--- a/src/main/java/clap/server/exception/code/FileErrorcode.java
+++ b/src/main/java/clap/server/exception/code/FileErrorcode.java
@@ -9,7 +9,8 @@
 public enum FileErrorcode implements BaseErrorCode {
     FILE_UPLOAD_REQUEST_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "FILE_001", "파일 업로드에 실패하였습니다."),
     UNSUPPORTED_FILE_TYPE(HttpStatus.BAD_REQUEST, "FILE_002", "유효하지 않은 파일 유형입니다."),
-    VIRUS_FILE_DETECTED(HttpStatus.BAD_REQUEST, "FILE_003", "안전하지 않은 파일이 감지되었습니다.")
+    VIRUS_FILE_DETECTED(HttpStatus.BAD_REQUEST, "FILE_003", "안전하지 않은 파일이 감지되었습니다."),
+    FILE_SCAN_FAILED(HttpStatus.INTERNAL_SERVER_ERROR, "FILE_004", "파일 스캔에 실패하였습니다.")
     ;
 
     private final HttpStatus httpStatus;