[DEV-56] Vod Processing Job 생성 API 구현

build.gradle

@@ -118,7 +118,9 @@ jacocoTestReport {
                     "ddingdong/ddingdongBE/*Response*",
                     "ddingdong/ddingdongBE/*Command*",
                     "ddingdong/ddingdongBE/*Query*",
-                    "ddingdong/ddingdongBE/*Dto*"
+                    "ddingdong/ddingdongBE/*Dto*",
+                    "ddingdong/ddingdongBE/*Controller*",
+                    "ddingdong/ddingdongBE/**/General*Service"
             ])
         }))
     }

src/main/java/ddingdong/ddingdongBE/common/config/SecurityConfig.java

@@ -46,7 +46,8 @@ public SecurityFilterChain filterChain(HttpSecurity http, JwtAuthService authSer
                     API_PREFIX + "/banners/**",
                     API_PREFIX + "/documents/**",
                     API_PREFIX + "/questions/**",
-                    API_PREFIX + "/feeds/**")
+                    API_PREFIX + "/feeds/**",
+                        API_PREFIX + "/internal/**")
                 .permitAll()
                 .requestMatchers("/v3/api-docs/**", "/swagger-ui/**", "/swagger-resources/**")
                 .permitAll()

src/main/java/ddingdong/ddingdongBE/domain/documents/service/DocumentServiceImpl.java → src/main/java/ddingdong/ddingdongBE/domain/documents/service/GeneralDocumentService.java

@@ -13,7 +13,7 @@
 @Service
 @Transactional(readOnly = true)
 @RequiredArgsConstructor
-public class DocumentServiceImpl implements DocumentService {
+public class GeneralDocumentService implements DocumentService {
 
     private final DocumentRepository documentRepository;
 

src/main/java/ddingdong/ddingdongBE/domain/feed/service/FacadeFeedService.java

@@ -19,25 +19,25 @@
 @Transactional(readOnly = true)
 public class FacadeFeedService {
 
-  private final FeedService feedService;
+  private final GeneralFeedService generalFeedService;
   private final FileInformationService fileInformationService;
 
   public List<FeedListQuery> getAllByClubId(Long clubId) {
-    List<Feed> feeds = feedService.getAllByClubId(clubId);
+    List<Feed> feeds = generalFeedService.getAllByClubId(clubId);
     return feeds.stream()
         .map(FeedListQuery::from)
         .toList();
   }
 
   public List<FeedListQuery> getNewestAll() {
-    List<Feed> feeds = feedService.getNewestAll();
+    List<Feed> feeds = generalFeedService.getNewestAll();
     return feeds.stream()
         .map(FeedListQuery::from)
         .toList();
   }
 
   public FeedQuery getById(Long feedId) {
-    Feed feed = feedService.getById(feedId);
+    Feed feed = generalFeedService.getById(feedId);
     ClubProfileQuery clubProfileQuery = extractClubInfo(feed.getClub());
     return FeedQuery.of(feed, clubProfileQuery);
   }

src/main/java/ddingdong/ddingdongBE/domain/feed/service/FeedService.java → src/main/java/ddingdong/ddingdongBE/domain/feed/service/GeneralFeedService.java

@@ -11,7 +11,7 @@
 @Service
 @RequiredArgsConstructor
 @Transactional(readOnly = true)
-public class FeedService {
+public class GeneralFeedService {
 
   private final FeedRepository feedRepository;
 

src/main/java/ddingdong/ddingdongBE/domain/fixzone/service/FixZoneServiceImpl.java → src/main/java/ddingdong/ddingdongBE/domain/fixzone/service/GeneralFixZoneService.java

@@ -11,7 +11,7 @@
 @Service
 @Transactional(readOnly = true)
 @RequiredArgsConstructor
-public class FixZoneServiceImpl implements FixZoneService {
+public class GeneralFixZoneService implements FixZoneService {
 
     private final FixZoneRepository fixZoneRepository;
 

src/main/java/ddingdong/ddingdongBE/domain/notice/service/FacadeAdminNoticeServiceImpl.java

@@ -14,7 +14,7 @@
 @Transactional(readOnly = true)
 public class FacadeAdminNoticeServiceImpl implements FacadeAdminNoticeService {
 
-    private final NoticeServiceImpl noticeService;
+    private final NoticeService noticeService;
     private final FileMetaDataService fileMetaDataService;
 
     @Transactional

src/main/java/ddingdong/ddingdongBE/domain/notice/service/FacadeNoticeServiceImpl.java

@@ -20,7 +20,7 @@
 @Transactional(readOnly = true)
 public class FacadeNoticeServiceImpl implements FacadeNoticeService {
 
-    private final NoticeServiceImpl noticeService;
+    private final NoticeService noticeService;
     private final FileMetaDataService fileMetaDataService;
     private final S3FileService s3FileService;
 

src/main/java/ddingdong/ddingdongBE/domain/notice/service/NoticeServiceImpl.java → src/main/java/ddingdong/ddingdongBE/domain/notice/service/GeneralNoticeService.java

@@ -11,7 +11,7 @@
 @Service
 @RequiredArgsConstructor
 @Transactional(readOnly = true)
-public class NoticeServiceImpl implements NoticeService {
+public class GeneralNoticeService implements NoticeService {
 
     public static final int NOTICE_COUNT_FOR_PAGE = 10;
 

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/controller/VodProcessingJobController.java

@@ -0,0 +1,22 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.controller;
+
+import ddingdong.ddingdongBE.domain.vodprocessing.controller.dto.request.CreatePendingVodProcessingJobRequest;
+import ddingdong.ddingdongBE.domain.vodprocessing.service.FacadeVodProcessingJobService;
+import io.swagger.v3.oas.annotations.Hidden;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Hidden
+@RestController("/server/internal/trigger/vod-processing-job")
+@RequiredArgsConstructor
+public class VodProcessingJobController {
+
+    private final FacadeVodProcessingJobService facadeVodProcessingJobService;
+
+    @PostMapping()
+    public void createPending(CreatePendingVodProcessingJobRequest request) {
+        facadeVodProcessingJobService.create(request.toCommand());
+    }
+
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/controller/dto/request/CreatePendingVodProcessingJobRequest.java

@@ -0,0 +1,14 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.controller.dto.request;
+
+import ddingdong.ddingdongBE.domain.vodprocessing.service.dto.command.CreatePendingVodProcessingJobCommand;
+
+public record CreatePendingVodProcessingJobRequest(
+        String convertJobId,
+        String userId
+) {
+
+    public CreatePendingVodProcessingJobCommand toCommand() {
+        return new CreatePendingVodProcessingJobCommand(convertJobId, userId);
+    }
+
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/entity/ConvertJobStatus.java

@@ -0,0 +1,5 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.entity;
+
+public enum ConvertJobStatus {
+    PENDING
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/entity/VodNotificationStatus.java

@@ -0,0 +1,4 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.entity;
+
+public enum VodNotificationStatus {
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/entity/VodProcessingJob.java

@@ -0,0 +1,50 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.entity;
+
+import ddingdong.ddingdongBE.common.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.FetchType;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.OneToOne;
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class VodProcessingJob extends BaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @OneToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "notification_id")
+    private VodProcessingNotification vodProcessingNotification;
+
+    @Column(nullable = false)
+    private String convertJobId;
+
+    @Column(nullable = false)
+    private String userId;
+
+    @Enumerated(EnumType.STRING)
+    private ConvertJobStatus convertJobStatus;
+
+    @Builder
+    private VodProcessingJob(Long id, VodProcessingNotification vodProcessingNotification, String convertJobId,
+                             String userId, ConvertJobStatus convertJobStatus) {
+        this.id = id;
+        this.vodProcessingNotification = vodProcessingNotification;
+        this.convertJobId = convertJobId;
+        this.userId = userId;
+        this.convertJobStatus = convertJobStatus;
+    }
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/entity/VodProcessingNotification.java

@@ -0,0 +1,36 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.entity;
+
+import ddingdong.ddingdongBE.common.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EnumType;
+import jakarta.persistence.Enumerated;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import java.time.LocalDateTime;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class VodProcessingNotification extends BaseEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    private LocalDateTime expiredAt;
+
+    private LocalDateTime sentAt;
+
+    @Column(nullable = false)
+    private int retryCount;
+
+    @Enumerated(EnumType.STRING)
+    @Column(name = "notification_status", nullable = false)
+    private VodNotificationStatus vodNotificationStatus;
+
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/repository/VodProcessingJobRepository.java

@@ -0,0 +1,13 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.repository;
+
+import ddingdong.ddingdongBE.domain.vodprocessing.entity.VodProcessingJob;
+import java.util.Optional;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface VodProcessingJobRepository extends JpaRepository<VodProcessingJob, Long> {
+
+    Optional<VodProcessingJob> findByConvertJobId(String convertJobId);
+
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/service/FacadeVodProcessingJobService.java

@@ -0,0 +1,9 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.service;
+
+import ddingdong.ddingdongBE.domain.vodprocessing.service.dto.command.CreatePendingVodProcessingJobCommand;
+
+public interface FacadeVodProcessingJobService {
+
+    Long create(CreatePendingVodProcessingJobCommand command);
+
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/service/FacadeVodProcessingJobServiceImpl.java

@@ -0,0 +1,20 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.service;
+
+import ddingdong.ddingdongBE.domain.vodprocessing.service.dto.command.CreatePendingVodProcessingJobCommand;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional(readOnly = true)
+@RequiredArgsConstructor
+public class FacadeVodProcessingJobServiceImpl implements FacadeVodProcessingJobService {
+
+    private final VodProcessingJobService vodProcessingJobService;
+
+
+    @Override
+    public Long create(CreatePendingVodProcessingJobCommand command) {
+        return vodProcessingJobService.save(command.toPendingVodProcessingJob());
+    }
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/service/GeneralVodProcessingJobService.java

@@ -0,0 +1,37 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.service;
+
+import ddingdong.ddingdongBE.common.exception.PersistenceException.ResourceNotFound;
+import ddingdong.ddingdongBE.domain.vodprocessing.entity.VodProcessingJob;
+import ddingdong.ddingdongBE.domain.vodprocessing.repository.VodProcessingJobRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional(readOnly = true)
+@RequiredArgsConstructor
+public class GeneralVodProcessingJobService implements VodProcessingJobService {
+
+    private final VodProcessingJobRepository vodProcessingJobRepository;
+
+    @Override
+    @Transactional
+    public Long save(VodProcessingJob vodProcessingJob) {
+        VodProcessingJob saveVodProcessingJob = vodProcessingJobRepository.save(vodProcessingJob);
+        return saveVodProcessingJob.getId();
+    }
+
+    @Override
+    public VodProcessingJob getById(Long vodProcessingJobId) {
+        return vodProcessingJobRepository.findById(vodProcessingJobId)
+                .orElseThrow(() -> new ResourceNotFound(
+                        "VodProcessingJob(vodProcessingJobId=" + vodProcessingJobId + ")를 찾을 수 없습니다."));
+    }
+
+    @Override
+    public VodProcessingJob getByConvertJobId(String convertJobId) {
+        return vodProcessingJobRepository.findByConvertJobId(convertJobId)
+                .orElseThrow(() -> new ResourceNotFound(
+                        "VodProcessingJob(convertJobId=" + convertJobId + ")를 찾을 수 없습니다."));
+    }
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/service/VodProcessingJobService.java

@@ -0,0 +1,13 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.service;
+
+import ddingdong.ddingdongBE.domain.vodprocessing.entity.VodProcessingJob;
+
+public interface VodProcessingJobService {
+
+    Long save(VodProcessingJob vodProcessingJob);
+
+    VodProcessingJob getById(Long vodProcessingJobId);
+
+    VodProcessingJob getByConvertJobId(String convertJobId);
+
+}

src/main/java/ddingdong/ddingdongBE/domain/vodprocessing/service/dto/command/CreatePendingVodProcessingJobCommand.java

@@ -0,0 +1,19 @@
+package ddingdong.ddingdongBE.domain.vodprocessing.service.dto.command;
+
+import ddingdong.ddingdongBE.domain.vodprocessing.entity.ConvertJobStatus;
+import ddingdong.ddingdongBE.domain.vodprocessing.entity.VodProcessingJob;
+
+public record CreatePendingVodProcessingJobCommand(
+        String convertJobId,
+        String userId
+) {
+
+    public VodProcessingJob toPendingVodProcessingJob() {
+        return VodProcessingJob.builder()
+                .convertJobId(convertJobId)
+                .userId(userId)
+                .convertJobStatus(ConvertJobStatus.PENDING)
+                .build();
+    }
+
+}

src/main/java/ddingdong/ddingdongBE/file/controller/S3FileController.java

@@ -24,7 +24,7 @@ public UploadUrlResponse getPreSignedUrl(PrincipalDetails principalDetails, Stri
         LocalDateTime now = LocalDateTime.now();
         GeneratePreSignedUrlRequestQuery query =
                 s3FileService.generatePresignedUrlRequest(
-                        new GeneratePreSignedUrlRequestCommand(now, user.getAuthId(), fileName));
+                        new GeneratePreSignedUrlRequestCommand(now, user.getId(), fileName));
         URL presingedUrl = s3FileService.getPresignedUrl(query.generatePresignedUrlRequest());
         return UploadUrlResponse.of(query, presingedUrl);
     }

src/main/java/ddingdong/ddingdongBE/file/service/S3FileService.java

@@ -92,6 +92,7 @@ public UploadedFileUrlAndNameQuery getUploadedFileUrlAndName(String key, String
         );
     }
 
+    //TODO: video 피드 조회 시 수정 필요
     public UploadedVideoUrlQuery getUploadedVideoUrl(String key) {
         String fileId = extractFileId(key);
         String region = amazonS3Client.getRegionName();
@@ -124,7 +125,7 @@ private String generateKey(ContentType contentType, GeneratePreSignedUrlRequestC
                 serverProfile,
                 contentType.getKeyMediaType(),
                 formatDate(command.generatedAt()),
-                command.authId(),
+                command.userId(),
                 uploadFileName.toString());
     }
 

src/main/java/ddingdong/ddingdongBE/file/service/dto/command/GeneratePreSignedUrlRequestCommand.java

@@ -4,7 +4,7 @@
 
 public record GeneratePreSignedUrlRequestCommand(
         LocalDateTime generatedAt,
-        String authId,
+        Long userId,
         String fileName
 ) {