Merge pull request #119 from CommitField/Feature/89

Feature/89

Author: skyeong42

src/main/java/cmf/commitField/domain/chat/chatRoom/controller/ChatRoomController.java

@@ -7,6 +7,7 @@
 import cmf.commitField.domain.chat.chatRoom.dto.ChatRoomUserDto;
 import cmf.commitField.domain.chat.chatRoom.service.ChatRoomService;
 import cmf.commitField.domain.user.entity.CustomOAuth2User;
+import cmf.commitField.global.aws.s3.S3Service;
 import cmf.commitField.global.error.ErrorCode;
 import cmf.commitField.global.globalDto.GlobalResponse;
 import cmf.commitField.global.security.LoginCheck;
@@ -28,25 +29,25 @@
 @RequestMapping("/chat")
 public class ChatRoomController {
     private final ChatRoomService chatRoomService;
-    private final FileService fileService;
+    private final S3Service s3Service; // S3 파일 저장을 위한 서비스
+    private final FileService fileService; //local file 저장을 위한 서비스
 
     // 채팅방 생성 (파일 업로드 포함)
     @PostMapping(value = "/room", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
     public GlobalResponse<Object> createRoom(
             @ModelAttribute @Valid ChatRoomRequest chatRoomRequest) throws IOException {
 
-
         // 인증 확인
         Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
 
         if (authentication instanceof OAuth2AuthenticationToken) {
             CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
-            Long userId = principal.getId();  // getId()를 통해 userId를 추출
+            Long userId = principal.getId();  // getId()를 통해 userId 추출
 
             // 파일 업로드 처리
             String imageUrl = null;
             if (chatRoomRequest.getFile() != null && !chatRoomRequest.getFile().isEmpty()) {
-                imageUrl = fileService.saveFile(chatRoomRequest.getFile());  // 파일 저장
+                imageUrl = s3Service.uploadFile(chatRoomRequest.getFile(), "chat-room"); // S3에 업로드
             }
 
             // 채팅방 생성 서비스 호출 (이미지 URL 포함)
@@ -58,6 +59,7 @@ public GlobalResponse<Object> createRoom(
         }
     }
 
+
     //채팅방 입장
     @PostMapping("/room/join/{roomId}")
     public GlobalResponse<Object> joinRoom(@PathVariable Long roomId, @RequestBody ChatRoomRequest chatRoomRequest) {
@@ -253,8 +255,33 @@ public GlobalResponse<Object> searchRoomName(
         }
     }
 
-
-
+//    // 채팅방 생성 (파일 업로드 포함)
+//    @PostMapping(value = "/room", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
+//    public GlobalResponse<Object> createRoom(
+//            @ModelAttribute @Valid ChatRoomRequest chatRoomRequest) throws IOException {
+//
+//
+//        // 인증 확인
+//        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
+//
+//        if (authentication instanceof OAuth2AuthenticationToken) {
+//            CustomOAuth2User principal = (CustomOAuth2User) authentication.getPrincipal();
+//            Long userId = principal.getId();  // getId()를 통해 userId를 추출
+//
+//            // 파일 업로드 처리
+//            String imageUrl = null;
+//            if (chatRoomRequest.getFile() != null && !chatRoomRequest.getFile().isEmpty()) {
+//                imageUrl = fileService.saveFile(chatRoomRequest.getFile());  // 파일 저장
+//            }
+//
+//            // 채팅방 생성 서비스 호출 (이미지 URL 포함)
+//            chatRoomService.createRoom(chatRoomRequest, userId, imageUrl);
+//
+//            return GlobalResponse.success("채팅방을 생성하였습니다.");
+//        } else {
+//            throw new IllegalArgumentException("로그인 후에 이용해 주세요.");
+//        }
+//    }
 
 
 }

src/main/java/cmf/commitField/domain/chat/chatRoom/controller/response/ChatRoomResponse.java

@@ -1,4 +1,4 @@
-//package cmf.commitField.domain.chat.chatRoom.controller.response;
-//
-//public class ChatRoomResponse {
-//}
+package cmf.commitField.domain.chat.chatRoom.controller.response;
+
+public class ChatRoomResponse {
+}

src/main/java/cmf/commitField/global/aws/s3/S3Cleaner.java

@@ -1,11 +1,7 @@
 package cmf.commitField.global.aws.s3;
 
-import jakarta.annotation.PreDestroy;
 import org.springframework.stereotype.Component;
 import software.amazon.awssdk.services.s3.S3Client;
-import software.amazon.awssdk.services.s3.model.ListObjectsV2Request;
-import software.amazon.awssdk.services.s3.model.ListObjectsV2Response;
-import software.amazon.awssdk.services.s3.model.S3Object;
 
 @Component
 public class S3Cleaner {
@@ -17,21 +13,21 @@ public S3Cleaner(S3Client s3Client) {
         this.s3Client = s3Client;
     }
 
-    @PreDestroy
-    public void cleanup() {
-        // S3에서 테스트 파일 삭제
-        ListObjectsV2Request listObjects = ListObjectsV2Request.builder()
-                .bucket(bucketName)
-                .build();
-
-        // 파일 목록을 가져옵니다.
-        ListObjectsV2Response listObjectsResponse = s3Client.listObjectsV2(listObjects);
-
-        // 각 파일을 삭제합니다.
-        for (S3Object s3Object : listObjectsResponse.contents()) {
-            s3Client.deleteObject(builder -> builder.bucket(bucketName).key(s3Object.key()));
-        }
-
-        System.out.println("S3에 있는 테스트 파일들을 삭제했습니다.");
-    }
+//    @PreDestroy
+//    public void cleanup() {
+//        // S3에서 테스트 파일 삭제
+//        ListObjectsV2Request listObjects = ListObjectsV2Request.builder()
+//                .bucket(bucketName)
+//                .build();
+//
+//        // 파일 목록을 가져옵니다.
+//        ListObjectsV2Response listObjectsResponse = s3Client.listObjectsV2(listObjects);
+//
+//        // 각 파일을 삭제합니다.
+//        for (S3Object s3Object : listObjectsResponse.contents()) {
+//            s3Client.deleteObject(builder -> builder.bucket(bucketName).key(s3Object.key()));
+//        }
+//
+//        System.out.println("S3에 있는 테스트 파일들을 삭제했습니다.");
+//    }
 }

src/main/java/cmf/commitField/global/aws/s3/S3Service.java

@@ -25,6 +25,7 @@ public String uploadFile(MultipartFile file, String dirName) throws IOException
                 .bucket(BUCKET_NAME)
                 .key(fileName)
                 .contentType(file.getContentType())
+//                .acl(ObjectCannedACL.PUBLIC_READ) // Public Read 권한 추가
                 .build();
 
         s3Client.putObject(putObjectRequest,