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 +24 -9
2 changed files with 24 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit c248845101 - Show all commits

1
.gitignore vendored
View File

@ -2,3 +2,4 @@ list.sh
config_python.py config_python.py
config_list.sh config_list.sh
__pycache__ __pycache__
.vscode

28
daemon.py
View File

@ -2,10 +2,12 @@
# база со стримерами в json файле # база со стримерами в json файле
import os
from threading import Thread from threading import Thread
import json import json
import config_python import config_python
locked_streams = list()
def startRecord(i): def startRecord(i):
''' '''
@ -20,10 +22,12 @@ def recorder(i):
''' '''
print("Записываем стрим %s\n" % i) print("Записываем стрим %s\n" % i)
# FIXME: пофиксить абсолютный путь # FIXME: пофиксить абсолютный путь
cmdline = ["/home/losted/.local/bin/youtube-dl","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")
print("lock файл удален")
def checkAlive(streamers, client_id): def checkAlive(streamers, client_id):
''' '''
@ -31,20 +35,30 @@ def checkAlive(streamers, client_id):
1.1 Если нет - удалить lock файл, если он есть 1.1 Если нет - удалить lock файл, если он есть
1.2 Если есть - создать lock файл, запустить записывалку 1.2 Если есть - создать lock файл, запустить записывалку
''' '''
from twitch import TwitchClient from twitch import TwitchClient
client = TwitchClient(client_id=client_id) client = TwitchClient(client_id=client_id)
for i in streamers: for i in streamers:
# Если есть такой стример - проверяем, идет ли стрим # Путь до диры со стримами
path = config_python.path + "/"+ i
# Создаем путь, если его нет
if not (os.path.exists(config_python.path+"/"+i)):
os.makedirs(path)
# TODO: Сделать проверку на наличие стримера
user_id=client.users.translate_usernames_to_ids(i)[0]['id'] # Получить ID по нику user_id=client.users.translate_usernames_to_ids(i)[0]['id'] # Получить ID по нику
# Это зачем проверка? # Если стрим идет, то идем дальше
if client.streams.get_stream_by_user(user_id): if client.streams.get_stream_by_user(user_id):
# Если стрим идет то записываем # Если стрим идет и лок файла нет, то записываем и ставим лок
if client.streams.get_stream_by_user(user_id).stream_type == 'live': if (client.streams.get_stream_by_user(user_id).stream_type == 'live') and not (os.path.exists(config_python.path+"/"+i+"/pid")):
print(i+" стримит")
startRecord(i) startRecord(i)
os.system("touch "+path+"/pid")
else: else:
print(i+" Уже стримит")
else:
# Если стрим не идет, то пишем об этом и убираем его из залоченных
print(i+" Не стримит") print(i+" Не стримит")
os.system("rm "+path+"/pid")
def removeOldStreams(): def removeOldStreams():
pass pass