From a39bad0f132f9fc62c7f1d942fd342fdeb966598 Mon Sep 17 00:00:00 2001
From: Reeverflow <serenereeverflow@gmail.com>
Date: Tue, 17 Feb 2026 21:42:55 +0100
Subject: [PATCH] Added video downloading from database url. Added
 findByStatus, any entry with NEW status in the db will have their url
 returned. Currently to add entries to the database POSTMAN or other apps need
 to be used.

---
 .../VideoDownloaderApplication.java           |  1 +
 .../repositories/VideoRepository.java         |  4 +++
 .../services/ProcessService.java              | 26 +++++++++++++++++--
 3 files changed, 29 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/example/video_downloader/VideoDownloaderApplication.java b/src/main/java/com/example/video_downloader/VideoDownloaderApplication.java
index 68beb82..3b61d97 100644
--- a/src/main/java/com/example/video_downloader/VideoDownloaderApplication.java
+++ b/src/main/java/com/example/video_downloader/VideoDownloaderApplication.java
@@ -7,6 +7,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 public class VideoDownloaderApplication {
 
 	public static void main(String[] args) {
+		SpringApplication.run(VideoDownloaderApplication.class, args);
 	}
 
 }
diff --git a/src/main/java/com/example/video_downloader/repositories/VideoRepository.java b/src/main/java/com/example/video_downloader/repositories/VideoRepository.java
index 77650f4..84405bb 100644
--- a/src/main/java/com/example/video_downloader/repositories/VideoRepository.java
+++ b/src/main/java/com/example/video_downloader/repositories/VideoRepository.java
@@ -1,9 +1,13 @@
 package com.example.video_downloader.repositories;
 
+import com.example.video_downloader.entity.StatusEnum;
 import com.example.video_downloader.entity.Video;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 @Repository
 public interface VideoRepository extends JpaRepository<Video, Long> {
+    List<Video> findUrlByStatus(StatusEnum status);
 }
diff --git a/src/main/java/com/example/video_downloader/services/ProcessService.java b/src/main/java/com/example/video_downloader/services/ProcessService.java
index ecec741..1a03298 100644
--- a/src/main/java/com/example/video_downloader/services/ProcessService.java
+++ b/src/main/java/com/example/video_downloader/services/ProcessService.java
@@ -1,5 +1,7 @@
 package com.example.video_downloader.services;
 
+import com.example.video_downloader.entity.StatusEnum;
+import com.example.video_downloader.entity.Video;
 import com.example.video_downloader.repositories.VideoRepository;
 import jakarta.annotation.PostConstruct;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -7,6 +9,7 @@ import org.springframework.stereotype.Service;
 
 import java.io.IOException;
 import java.nio.charset.StandardCharsets;
+import java.util.List;
 
 @Service
 public class ProcessService {
@@ -14,9 +17,28 @@ public class ProcessService {
     @Autowired
     private VideoRepository videoRepository;
 
+    @PostConstruct
+    public void validateVideos() throws IOException, InterruptedException {
+        List<Video> response = videoRepository.findUrlByStatus(StatusEnum.NEW);
+        for(Video video : response) {
+            if(video.getStatus().equals(StatusEnum.NEW)){
+                downloadVideo(video.getUrl());
+                video.setStatus(StatusEnum.SAVED);
+                videoRepository.save(video);
+            } else {
+                return;
+            }
+        }
+    }
+
     //@PostConstruct
-    public void init() throws InterruptedException, IOException {
-        execute("yt-dlp", "youtube:player_client=android", "");
+    public void downloadVideo(String url) throws InterruptedException, IOException {
+        try {
+            execute("yt-dlp", "youtube:player_client=android", url);
+        } catch (Exception e) {
+            System.out.println("Something went awry.");
+        }
+
     }
 
     public void execute(String... command) throws InterruptedException, IOException {