prgrms-web-devcourse-final-project
diff --git a/‎.gitignore‎
Lines changed: 7 additions & 0 deletions b/‎.gitignore‎
Lines changed: 7 additions & 0 deletions
diff --git a/‎Dockerfile‎
Lines changed: 20 additions & 0 deletions b/‎Dockerfile‎
Lines changed: 20 additions & 0 deletions
diff --git a/‎back/.env.default‎
Lines changed: 1 addition & 1 deletion b/‎back/.env.default‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎back/build.gradle.kts‎
Lines changed: 29 additions & 3 deletions b/‎back/build.gradle.kts‎
Lines changed: 29 additions & 3 deletions
diff --git a/‎back/src/main/java/com/back/domain/file/controller/VideoController.java‎
Lines changed: 34 additions & 0 deletions b/‎back/src/main/java/com/back/domain/file/controller/VideoController.java‎
Lines changed: 34 additions & 0 deletions
diff --git a/‎back/src/main/java/com/back/domain/file/entity/Video.java‎
Lines changed: 66 additions & 0 deletions b/‎back/src/main/java/com/back/domain/file/entity/Video.java‎
Lines changed: 66 additions & 0 deletions
diff --git a/‎back/src/main/java/com/back/domain/file/repository/VideoRepository.java‎
Lines changed: 12 additions & 0 deletions b/‎back/src/main/java/com/back/domain/file/repository/VideoRepository.java‎
Lines changed: 12 additions & 0 deletions
diff --git a/‎back/src/main/java/com/back/domain/file/service/VideoService.java‎
Lines changed: 112 additions & 0 deletions b/‎back/src/main/java/com/back/domain/file/service/VideoService.java‎
Lines changed: 112 additions & 0 deletions
diff --git a/‎back/src/main/java/com/back/domain/job/job/entity/Job.java‎
Lines changed: 34 additions & 0 deletions b/‎back/src/main/java/com/back/domain/job/job/entity/Job.java‎
Lines changed: 34 additions & 0 deletions
diff --git a/‎back/src/main/java/com/back/domain/job/job/entity/JobAlias.java‎
Lines changed: 25 additions & 0 deletions b/‎back/src/main/java/com/back/domain/job/job/entity/JobAlias.java‎
Lines changed: 25 additions & 0 deletions
@@ -41,3 +41,10 @@ out/
 CLAUDE.md
 db_dev.mv.db
 db_dev.trace.db
+
+cookies.txt
+
+.DS_Store
+
+### QueryDSL Q클래스 ###
+**/generated/
@@ -0,0 +1,20 @@
+FROM python:3.11-slim
+
+WORKDIR /app
+
+COPY requirements.txt .
+RUN apt-get update && apt-get install -y ffmpeg
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY consumer.py .
+
+ENV KAFKA_TOPIC=s3-events
+ENV KAFKA_BOOTSTRAP=kafka:9092
+ENV MINIO_ENDPOINT=http://minio:9000
+ENV MINIO_ACCESS_KEY=minioadmin
+ENV MINIO_SECRET_KEY=minioadmin
+ENV DOWNLOAD_DIR=/downloads
+
+VOLUME ["/downloads"]
+
+CMD ["python", "consumer.py"]
@@ -1 +1 @@
-CUSTOM__JWT__SECRET_KEY=NEED_TO_SET
+CUSTOM__JWT__SECRET_KEY=NEED_TO_SET
@@ -1,10 +1,12 @@
+import org.gradle.kotlin.dsl.implementation
+
 plugins {
 	java
 	id("org.springframework.boot") version "3.5.5"
 	id("io.spring.dependency-management") version "1.1.7"
 }
 
-group = "com.ll"
+group = "com"
 version = "0.0.1-SNAPSHOT"
 description = "back"
 
@@ -25,21 +27,45 @@ repositories {
 }
 
 dependencies {
+	// JWT
 	implementation("io.jsonwebtoken:jjwt-api:0.12.6")
 	runtimeOnly("io.jsonwebtoken:jjwt-impl:0.12.6")
 	runtimeOnly("io.jsonwebtoken:jjwt-jackson:0.12.6")
+
+	// Swagger
 	implementation("org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.9")
+	implementation("org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.13")
+
+	// Spring Boot
 	implementation("org.springframework.boot:spring-boot-starter-actuator")
 	implementation("org.springframework.boot:spring-boot-starter-data-jpa")
 	implementation("org.springframework.boot:spring-boot-starter-security")
 	implementation("org.springframework.boot:spring-boot-starter-web")
+	implementation ("org.springframework.boot:spring-boot-starter-data-redis")
+
+	// QueryDSL
+	implementation("com.querydsl:querydsl-jpa:5.0.0:jakarta")
+	annotationProcessor("com.querydsl:querydsl-apt:5.0.0:jakarta")
+	annotationProcessor("jakarta.persistence:jakarta.persistence-api:3.1.0")
+	annotationProcessor("jakarta.annotation:jakarta.annotation-api:2.1.1")
+
+	// Lombok
 	compileOnly("org.projectlombok:lombok")
-	developmentOnly("org.springframework.boot:spring-boot-devtools")
-	runtimeOnly("com.h2database:h2")
 	annotationProcessor("org.projectlombok:lombok")
+
+	// DB
+	runtimeOnly("com.h2database:h2")
+	runtimeOnly("com.mysql:mysql-connector-j")
+
+	// DevTools
+	developmentOnly("org.springframework.boot:spring-boot-devtools")
+
+	// Test
 	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> {
 
@@ -0,0 +1,34 @@
+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 bucket, @RequestParam String fileName) {
+        return videoService.generateUploadUrl(bucket, fileName);
+    }
+
+    // DASH 스트리밍용 URL
+    @GetMapping("/videos/dash-urls")
+    public Map<String, URL> getDashUrls(
+            @RequestParam String bucket,
+            @RequestParam String mpdFile,
+            @RequestParam List<String> segmentFiles
+    ) {
+        return videoService.generateDashUrls(bucket, mpdFile, segmentFiles);
+    }
+}
@@ -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();
+    }
+}
@@ -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);
+}
@@ -0,0 +1,112 @@
+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.NoSuchElementException;
+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 NoSuchElementException("존재하지 않는 비디오입니다."));
+    }
+
+    //HeadObjectRequest 고려
+    public URL generateUploadUrl(String bucket, String 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 NoSuchElementException("요청한 파일이 존재하지 않습니다: " + 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;
+        }
+    }
+}
@@ -0,0 +1,34 @@
+package com.back.domain.job.job.entity;
+
+import com.back.global.jpa.BaseEntity;
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.util.List;
+
+@Entity
+@Table(name = "job")
+@Getter @Setter
+@NoArgsConstructor
+public class Job extends BaseEntity {
+    @Column(name = "name", nullable = false, unique = true)
+    private String name;
+
+    @Column(name = "description", columnDefinition = "TEXT")
+    private String description;
+
+    @OneToMany(mappedBy = "job", cascade = CascadeType.ALL)
+    private List<JobAlias> aliases;
+
+    public Job(String name, String description) {
+        this.name = name;
+        this.description = description;
+    }
+
+    public void addAlias(JobAlias alias) {
+        aliases.add(alias);
+        alias.setJob(this);
+    }
+}
@@ -0,0 +1,25 @@
+package com.back.domain.job.job.entity;
+
+import com.back.global.jpa.BaseEntity;
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+@Entity
+@Table(name = "job_alias")
+@Getter @Setter
+@NoArgsConstructor
+public class JobAlias extends BaseEntity {
+    @Column(name = "name", nullable = false, unique = true)
+    private String name; // 사용자가 입력한 직군 이름
+
+    @ManyToOne(fetch = FetchType.LAZY)
+    @JoinColumn(name = "job_id")
+    private Job job; // 표준 Job 연결 (NULL이면 pending 상태)
+
+    public JobAlias(String name) {
+        this.name = name;
+        this.job = null; // 기본적으로 연결된 Job이 없음 (pending 상태)
+    }
+}
Original file line number	Diff line number	Diff line change
`@@ -1 +1 @@`
`1`		`-CUSTOM__JWT__SECRET_KEY=NEED_TO_SET`
	`1`	`+CUSTOM__JWT__SECRET_KEY=NEED_TO_SET`