lulzette/twitch-autosave
1
1
Fork 0
Code Issues 5 Pull Requests Releases 2 Wiki Activity

Переход от месива из баш скриптов к нормальному питоновскому коду #5

Merged
lulzette merged 32 commits from move-to-python into master 2022-11-13 12:45:18 +03:00
Conversation 0 Commits 32 Files Changed 9 +8 -4
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit bff6249173 - Show all commits

12
daemon.py
View File

@ -20,14 +20,16 @@ def recorder(i):
''' '''
Функция, которая запускает youtube-dl, фактически записывает стрим Функция, которая запускает youtube-dl, фактически записывает стрим
''' '''
path = config_python.path + "/"+ i
print("Записываем стрим %s\n" % i) print("Записываем стрим %s\n" % i)
# FIXME: пофиксить абсолютный путь # FIXME: пофиксить абсолютный путь
cmdline = ["/home/losted/.local/bin/youtube-dl","https://twitch.tv/"+i] cmdline = ["/home/losted/.local/bin/youtube-dl","https://twitch.tv/"+i]
import subprocess import subprocess
s = subprocess.call(cmdline, stdout=subprocess.DEVNULL) s = subprocess.call(cmdline, stdout=subprocess.DEVNULL)
print("Запись стрима %s закончена\n" % i) print("Запись стрима %s закончена\n" % i)
os.system("rm "+config_python.path + "/"+i+"/pid") if (os.path.exists(path+"/pid")):
print("lock файл удален") os.system("rm "+path+"/pid")
print("lock файл удален")
def checkAlive(streamers, client_id): def checkAlive(streamers, client_id):
''' '''
@ -40,7 +42,7 @@ def checkAlive(streamers, client_id):
for i in streamers: for i in streamers:
# Путь до диры со стримами # Путь до диры со стримами
path = config_python.path + "/"+ i path = config_python.path + "/"+ i
# Создаем путь, если его нет # Создаем путь до диры со стримером, если его нет
if not (os.path.exists(config_python.path+"/"+i)): if not (os.path.exists(config_python.path+"/"+i)):
os.makedirs(path) os.makedirs(path)
# TODO: Сделать проверку на наличие стримера # TODO: Сделать проверку на наличие стримера
@ -57,7 +59,9 @@ def checkAlive(streamers, client_id):
else: else:
# Если стрим не идет, то пишем об этом и убираем его из залоченных # Если стрим не идет, то пишем об этом и убираем его из залоченных
print(i+" Не стримит") print(i+" Не стримит")
os.system("rm "+path+"/pid") # Если есть лок, то удаляем
if (os.path.exists(path+"/pid")):
os.system("rm "+path+"/pid")
def removeOldStreams(): def removeOldStreams():