Merge pull request #327 from Podo-Store/develop

feat: 대본 열람 api 생성

Author: pipi-shortstocking

src/main/java/PodoeMarket/podoemarket/product/controller/ProductController.java

@@ -115,4 +115,19 @@ public ResponseEntity<?> productLike(@AuthenticationPrincipal UserEntity userInf
             return ResponseEntity.badRequest().body(resDTO);
         }
     }
+
+    @GetMapping("/view")
+    public ResponseEntity<StreamingResponseBody> scriptView(@RequestParam("script") UUID productId) {
+        try{
+            // 데이터베이스 작업 (트랜잭션 내에서 수행)
+            final ProductEntity product = productService.getProduct(productId);
+            final String s3Key = product.getFilePath();
+            final String preSignedURL = s3Service.generatePreSignedURL(s3Key);
+
+            return productService.generateFullScriptDirect(preSignedURL);
+        } catch(Exception e) {
+            ResponseDTO resDTO = ResponseDTO.builder().error(e.getMessage()).build();
+            return ResponseEntity.badRequest().body((StreamingResponseBody) resDTO);
+        }
+    }
 }

src/main/java/PodoeMarket/podoemarket/product/service/ProductService.java

@@ -13,7 +13,6 @@
 import PodoeMarket.podoemarket.product.dto.response.ScriptDetailResponseDTO;
 import PodoeMarket.podoemarket.product.dto.response.ScriptListResponseDTO;
 import PodoeMarket.podoemarket.product.type.SortType;
-import PodoeMarket.podoemarket.service.S3Service;
 import PodoeMarket.podoemarket.service.ViewCountService;
 import com.itextpdf.io.source.ByteArrayOutputStream;
 import com.itextpdf.kernel.pdf.PdfDocument;
@@ -36,7 +35,6 @@
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.InputStream;
-import java.io.UnsupportedEncodingException;
 import java.net.URI;
 import java.net.URLEncoder;
 import java.nio.charset.StandardCharsets;
@@ -191,6 +189,26 @@ public String toggleLike(UserEntity userInfo, UUID productId) {
         }
     }
 
+    public ResponseEntity<StreamingResponseBody> generateFullScriptDirect(String preSignedURL) {
+        StreamingResponseBody streamingResponseBody = outputStream -> {
+            try (InputStream inputStream = new URI(preSignedURL).toURL().openStream()) {
+                byte[] buffer = new byte[8192];
+                int bytesRead;
+                while ((bytesRead = inputStream.read(buffer)) != -1) {
+                    outputStream.write(buffer, 0, bytesRead);
+                    outputStream.flush();
+                }
+            } catch (Exception e) {
+                log.error("PDF 스트리밍 중 오류 발생: {}", e.getMessage());
+            }
+        };
+
+        return ResponseEntity.ok()
+                .contentType(MediaType.APPLICATION_PDF)
+                .body(streamingResponseBody);
+    }
+
+
     // ============== private (protected) method ===============
     private Sort createSort(SortType sortType) {
         return sortType.createSort();