From 35465ca78ce6989e79c190f60a12dc2528c49262 Mon Sep 17 00:00:00 2001
From: data <data@data-it-solution.de>
Date: Wed, 4 Jun 2025 21:20:00 +0200
Subject: [PATCH] Neuer Branch gpu-encode

---
 app/class_file_convert.py | 25 +++++++++++++++----------
 app/main_server.py        |  3 +--
 2 files changed, 16 insertions(+), 12 deletions(-)

diff --git a/app/class_file_convert.py b/app/class_file_convert.py
index 0000f30..efd8a17 100755
--- a/app/class_file_convert.py
+++ b/app/class_file_convert.py
@@ -52,8 +52,6 @@ class Convert:
         result = None
 
         logging.info(f"Starte Konvertierung: {command}")
-        await self.obj_websocket.send_websocket(self.obj_path.active_path_to_dict())
-        await self.obj_websocket.send_websocket(self.obj_path.queue_path_to_dict())
 
         try:
             # Starte den Subprozess asynchron
@@ -65,6 +63,8 @@ class Convert:
 
             self.active_process.add(obj)
             obj.process_start = time.time()
+            await self.obj_websocket.send_websocket(self.obj_path.active_path_to_dict())
+            await self.obj_websocket.send_websocket(self.obj_path.queue_path_to_dict())
 
             await obj_process.read_out(obj)
             await obj.process.wait()
@@ -93,16 +93,21 @@ class Convert:
 
     def convert_cmd(self, obj):
         command_convert = [
-            "ffmpeg", "-y", "-i", obj.source_file,
-            # "-init_hw_device", "vaapi=va:/dev/dri/renderD128",
+            "ffmpeg", "-y",
+            "-init_hw_device", "vaapi=intel:/dev/dri/renderD128",
+            "-hwaccel", "vaapi",
+            "-hwaccel_device", "intel",
+             "-i", obj.source_file,
             "-map", "0:0",
-            "-c:v", "libsvtav1",
-            #"-c:v", "av1_qsv",
-            "-preset", "5",
-            "-crf", "30",
+            #"-c:v", "libsvtav1",
+            "-c:v", "av1_vaapi",
+            #"-preset", "5",
+            #"-crf", "30",
+            "-qp", "30",
             "-g", "240",
-            "-pix_fmt", "yuv420p10le",
-            "-svtav1-params", "tune=0:film-grain=8",
+            #"-pix_fmt", "yuv420p10le",
+            "-vf", "format=nv12,hwupload",
+            #"-svtav1-params", "tune=0:film-grain=8",
         ]
 
         if len(obj.streams_audio):
diff --git a/app/main_server.py b/app/main_server.py
index c2d20fb..3e95018 100755
--- a/app/main_server.py
+++ b/app/main_server.py
@@ -64,10 +64,9 @@ class Server:
 
                 if data.get("data_path"):
                     self.obj_path.receive_paths(data.get("data_path"))
+                    await self.start_convert()
                     await self.send_websocket(self.obj_path.active_path_to_dict())
                     await self.send_websocket(self.obj_path.queue_path_to_dict())
-                    await self.start_convert()
-
                 elif data.get("data_command"):
                     if data["data_command"]["cmd"] == "delete":
                         self.obj_path.delete_path(data["data_command"]["id"])