-
Notifications
You must be signed in to change notification settings - Fork 0
/
Transcode.py
114 lines (103 loc) · 4.03 KB
/
Transcode.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
import os
import subprocess
import time
import shutil
import threading
from Directories import Directories
class Transcode:
def __init__(self, slot):
input_file = None
slot_list = os.listdir(slot)
if not os.listdir(slot) and Directories().queued_directory_list:
file_in_que = f"{Directories().queued_directory}{Directories().queued_directory_list[0]}"
shutil.move(file_in_que, slot)
target_file = Directories().get_directory_size(slot)
target_file_size = float(target_file[:-3])
input_file = None
slot_list = os.listdir(slot)
for file in os.listdir(f"{slot}/{slot_list[0]}"):
if file.endswith(".mkv"):
input_file = f"{slot}/{slot_list[0]}/{file}"
output_file = f"{slot}/{slot_list[0]}/{slot_list[0]}.mkv"
command = [
"HandBrakeCLI.exe",
"--preset-import-file",
"profile.json",
"-Z",
"PLEX",
"-i",
input_file,
"-o",
output_file,
]
if target_file_size < 20:
os.rename(input_file, output_file)
else:
subprocess.run(
command,
shell=True,
stdout=subprocess.DEVNULL,
stderr=subprocess.DEVNULL,
)
os.remove(f"{input_file}")
shutil.move(
f"{slot}/{slot_list[0]}", Directories().completed_directory
)
else:
input_file = None
output_file = None
self.slot = slot
self.movie_name = slot_list[0]
self.input_file = input_file
self.output_file = output_file
def Transcode_Testing():
def SLOT_1():
while True:
if Directories().queued_directory_list:
slot = Directories().transcoding_slot_1
slot1 = Transcode(slot)
print(
"Transcode on Slot 1 completed successfully :\n",
f"Slot : {slot1.slot}",
f"File Name : {slot1.movie_name}\n",
f"Input File : {slot1.input_file}\n",
f"Output File : {slot1.output_file}\n",
)
else:
time.sleep(10)
threading.Thread(target=SLOT_1).start()
time.sleep(3)
def SLOT_2():
while True:
if Directories().queued_directory_list:
slot = Directories().transcoding_slot_2
slot2 = Transcode(slot)
print(
"Transcode on Slot 2 completed successfully :\n",
f"Slot : {slot2.slot}\n",
f"File Name : {slot2.movie_name}\n",
f"Input File : {slot2.input_file}\n",
f"Output File : {slot2.output_file}\n",
)
else:
time.sleep(10)
threading.Thread(target=SLOT_2).start()
time.sleep(3)
def SLOT_3():
while True:
if Directories().queued_directory_list:
slot = Directories().transcoding_slot_3
slot3 = Transcode(slot)
print(
"Transcode on Slot 3 completed successfully :\n",
f"Slot : {slot3.slot}\n",
f"File Name : {slot3.movie_name}\n",
f"Input File : {slot3.input_file}\n",
f"Output File : {slot3.output_file}\n",
)
else:
time.sleep(10)
threading.Thread(target=SLOT_3).start()
time.sleep(10)
if __name__ == "__main__":
Transcode_Testing()