뉴스, 댓글, 업로드/다운로드용 PresignedURL발급메서드 작성완료

back/build.gradle.kts

@@ -43,6 +43,8 @@ dependencies {
 	testImplementation("org.springframework.boot:spring-boot-starter-test")
 	testImplementation("org.springframework.security:spring-security-test")
 	testRuntimeOnly("org.junit.platform:junit-platform-launcher")
+
+	implementation ("software.amazon.awssdk:s3:2.25.0")
 }
 
 tasks.withType<Test> {

back/src/main/java/com/back/domain/file/controller/VideoController.java

@@ -0,0 +1,33 @@
+package com.back.domain.file.controller;
+
+import com.back.domain.file.service.VideoService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.net.URL;
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@RequiredArgsConstructor
+public class VideoController {
+
+    private final VideoService videoService;
+
+    // 업로드용 Presigned URL
+    @GetMapping("/videos/upload-url")
+    public URL getUploadUrl(@RequestParam String fileName) {
+        return videoService.generateUploadUrl("test-bucket", fileName);
+    }
+
+    // DASH 스트리밍용 URL
+    @GetMapping("/videos/dash-urls")
+    public Map<String, URL> getDashUrls(
+            @RequestParam String mpdFile,
+            @RequestParam List<String> segmentFiles
+    ) {
+        return videoService.generateDashUrls("test-bucket", mpdFile, segmentFiles);
+    }
+}

back/src/main/java/com/back/domain/file/entity/Video.java

@@ -0,0 +1,66 @@
+package com.back.domain.file.entity;
+
+import com.back.global.jpa.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.hibernate.annotations.JdbcTypeCode;
+import org.hibernate.type.SqlTypes;
+
+@Getter
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class Video extends BaseEntity {
+    @Column(unique = true)
+    private String uuid;
+
+    @JdbcTypeCode(SqlTypes.JSON)
+    @Column(name = "transcoding_results")
+    private String transcodingResults;
+
+    private String originalPath;
+
+    private Integer views;
+
+    private String originalFileName;
+
+    private Integer duration;
+
+    private Long fileSize;
+
+    @Builder(access = AccessLevel.PRIVATE)
+    private Video(String uuid, String transcodingResults, String originalPath, Integer views, String originalFileName, Integer duration, Long fileSize) {
+        this.uuid = uuid;
+        this.transcodingResults = transcodingResults;
+        this.originalPath = originalPath;
+        this.views = views;
+        this.originalFileName = originalFileName;
+        this.duration = duration;
+        this.fileSize = fileSize;
+    }
+
+    public static Video create(String uuid, String transcodingResults, String originalPath, String originalFileName, Integer duration, Long fileSize) {
+        if (uuid == null || uuid.isBlank()) {
+            throw new IllegalArgumentException("uuid cannot be null or empty");
+        }
+        if (originalPath == null || originalPath.isBlank()) {
+            throw new IllegalArgumentException("originalPath cannot be null or empty");
+        }
+        if (originalFileName == null || originalFileName.isBlank()) {
+            throw new IllegalArgumentException("originalFileName cannot be null or empty");
+        }
+
+        return Video.builder()
+                .uuid(uuid)
+                .transcodingResults(transcodingResults)
+                .originalPath(originalPath)
+                .views(0)
+                .originalFileName(originalFileName)
+                .duration(duration)
+                .fileSize(fileSize)
+                .build();
+    }
+}

back/src/main/java/com/back/domain/file/repository/VideoRepository.java

@@ -0,0 +1,12 @@
+package com.back.domain.file.repository;
+
+import com.back.domain.file.entity.Video;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.Optional;
+
+@Repository
+public interface VideoRepository extends JpaRepository<Video, Integer> {
+    Optional<Video> findByUuid(String uuid);
+}

back/src/main/java/com/back/domain/file/service/VideoService.java

@@ -0,0 +1,115 @@
+package com.back.domain.file.service;
+
+import com.back.domain.file.entity.Video;
+import com.back.domain.file.repository.VideoRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import software.amazon.awssdk.services.s3.S3Client;
+import software.amazon.awssdk.services.s3.model.GetObjectRequest;
+import software.amazon.awssdk.services.s3.model.HeadObjectRequest;
+import software.amazon.awssdk.services.s3.model.PutObjectRequest;
+import software.amazon.awssdk.services.s3.model.S3Exception;
+import software.amazon.awssdk.services.s3.presigner.S3Presigner;
+import software.amazon.awssdk.services.s3.presigner.model.PresignedGetObjectRequest;
+import software.amazon.awssdk.services.s3.presigner.model.PresignedPutObjectRequest;
+
+import java.net.URL;
+import java.time.Duration;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+public class VideoService {
+    private final VideoRepository videoRepository;
+    private final S3Presigner presigner;
+    private final S3Client s3Client;
+
+    public Video createVideo(String transcodingStatus, String originalPath, String originalFilename, Integer duration, Long fileSize) {
+        String uuid = UUID.randomUUID().toString();
+        Video video = Video.create(uuid, transcodingStatus, originalPath, originalFilename, duration, fileSize);
+        return videoRepository.save(video);
+    }
+
+    public Video getNewsByUuid(String uuid) {
+        return videoRepository.findByUuid(uuid)
+                .orElseThrow(() -> new IllegalArgumentException("존재하지 않는 비디오입니다."));
+    }
+
+    //HeadObjectRequest 고려
+    public URL generateUploadUrl(String bucket, String objectKey) {
+        if(!isExist(bucket, objectKey)){
+            throw new RuntimeException("요청한 파일이 존재하지 않습니다: " + objectKey);
+        }
+
+        PutObjectRequest request = PutObjectRequest.builder()
+                .bucket(bucket)
+                .key(objectKey)
+                .build();
+
+        PresignedPutObjectRequest presignedRequest =
+                presigner.presignPutObject(builder -> builder
+                        .signatureDuration(Duration.ofMinutes(30))
+                        .putObjectRequest(request));
+
+        URL url = presignedRequest.url();
+        if (url == null) {
+            throw new RuntimeException("Presigned URL 생성 실패");
+        }
+
+        return url;
+    }
+
+    public URL generateDownloadUrl(String bucket, String objectKey) {
+        if(!isExist(bucket, objectKey)){
+            throw new RuntimeException("요청한 파일이 존재하지 않습니다: " + objectKey);
+        }
+
+        GetObjectRequest request = GetObjectRequest.builder()
+                .bucket(bucket)
+                .key(objectKey)
+                .build();
+
+        PresignedGetObjectRequest presignedRequest =
+                presigner.presignGetObject(builder -> builder
+                        .signatureDuration(Duration.ofHours(1))
+                        .getObjectRequest(request));
+
+        URL url = presignedRequest.url();
+        if (url == null) {
+            throw new RuntimeException("Presigned URL 생성 실패");
+        }
+
+        return url;
+    }
+
+    // DASH용 인덱스 + 세그먼트 URL 발급
+    public Map<String, URL> generateDashUrls(String bucket, String mpdFile, List<String> segmentFiles) {
+        // MPD 파일 URL
+        URL mpdUrl = generateDownloadUrl(bucket, mpdFile);
+
+        // 각 세그먼트 파일 URL
+        Map<String, URL> segmentUrls = segmentFiles.stream()
+                .collect(Collectors.toMap(f -> f, f -> generateDownloadUrl(bucket, f)));
+
+        // MPD 포함 합쳐서 반환
+        segmentUrls.put("mpd", mpdUrl);
+        return segmentUrls;
+    }
+
+    public boolean isExist(String bucket, String objectKey) {
+        try {
+            HeadObjectRequest headRequest = HeadObjectRequest.builder()
+                    .bucket(bucket)
+                    .key(objectKey)
+                    .build();
+
+            s3Client.headObject(headRequest);
+            return true;
+        } catch (S3Exception e) {
+            return false;
+        }
+    }
+}

back/src/main/java/com/back/domain/news/comment/controller/CommentController.java

@@ -0,0 +1,71 @@
+package com.back.domain.news.comment.controller;
+
+import com.back.domain.member.member.entity.Member;
+import com.back.domain.news.comment.dto.CommentCreateRequest;
+import com.back.domain.news.comment.dto.CommentResponse;
+import com.back.domain.news.comment.dto.CommentUpdateRequest;
+import com.back.domain.news.comment.entity.Comment;
+import com.back.domain.news.comment.service.CommentService;
+import com.back.domain.news.news.entity.News;
+import com.back.domain.news.news.service.NewsService;
+import com.back.global.rq.Rq;
+import com.back.global.rsData.RsData;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+@RestController
+@RequestMapping("/news/{newsId}/comment")
+@RequiredArgsConstructor
+public class CommentController {
+    private final NewsService newsService;
+    private final CommentService commentService;
+    private final Rq rq;
+
+    @GetMapping
+    public RsData<List<CommentResponse>> getComments(@PathVariable Long newsId) {
+        News news = newsService.getNewsById(newsId);
+        List<Comment> comments = commentService.getComments(news);
+        List<CommentResponse> commentResponses = comments.stream()
+                .map(CommentResponse::new)
+                .collect(Collectors.toList());
+        return new RsData<>("200", "댓글 목록 불러오기 완료", commentResponses);
+    }
+
+    @PostMapping
+    public RsData<CommentResponse> createComment(@PathVariable Long newsId, @RequestBody CommentCreateRequest request) {
+        Member member = rq.getActor();
+        if (member == null) {
+            return new RsData<>("401", "로그인이 필요합니다.");
+        }
+        News news = newsService.getNewsById(newsId);
+        Comment comment = commentService.createComment(member, news, request.content());
+        CommentResponse commentResponse = new CommentResponse(comment);
+        return new RsData<>("201", "댓글 생성 완료", commentResponse);
+    }
+
+    @PutMapping("/{commentId}")
+    public RsData<CommentResponse> updateComment(@PathVariable Long newsId, @PathVariable Long commentId, @RequestBody CommentUpdateRequest request) {
+        Member member = rq.getActor();
+        if (member == null) {
+            return new RsData<>("401", "로그인이 필요합니다.");
+        }
+        News news = newsService.getNewsById(newsId);
+        Comment updatedComment = commentService.updateComment(member, news, commentId, request.content());
+        CommentResponse commentResponse = new CommentResponse(updatedComment);
+        return new RsData<>("200", "댓글 수정 완료", commentResponse);
+    }
+
+    @DeleteMapping("/{commentId}")
+    public RsData<Void> deleteComment(@PathVariable Long newsId, @PathVariable Long commentId) {
+        Member member = rq.getActor();
+        if (member == null) {
+            return new RsData<>("401", "로그인이 필요합니다.");
+        }
+        News news = newsService.getNewsById(newsId);
+        commentService.deleteComment(member, news, commentId);
+        return new RsData<>("200", "댓글 삭제 완료");
+    }
+}

back/src/main/java/com/back/domain/news/comment/dto/CommentCreateRequest.java

@@ -0,0 +1,4 @@
+package com.back.domain.news.comment.dto;
+
+public record CommentCreateRequest(String content) {
+}

back/src/main/java/com/back/domain/news/comment/dto/CommentResponse.java

@@ -0,0 +1,23 @@
+package com.back.domain.news.comment.dto;
+
+import com.back.domain.news.comment.entity.Comment;
+import lombok.Getter;
+
+import java.time.LocalDateTime;
+
+@Getter
+public class CommentResponse {
+    private final Long id;
+    private final String content;
+    private final String author;
+    private final LocalDateTime createdDate;
+    private final LocalDateTime modifiedDate;
+
+    public CommentResponse(Comment comment) {
+        this.id = comment.getId();
+        this.content = comment.getContent();
+        this.author = comment.getMember().getName();
+        this.createdDate = comment.getCreateDate();
+        this.modifiedDate = comment.getModifyDate();
+    }
+}

back/src/main/java/com/back/domain/news/comment/dto/CommentUpdateRequest.java

@@ -0,0 +1,4 @@
+package com.back.domain.news.comment.dto;
+
+public record CommentUpdateRequest(String content) {
+}