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

Фикс конфига и рефактор названий (CamelCase -> snake_case)

Browse Source
This commit is contained in:
lulzette 2023-06-01 23:26:30 +03:00
commit e5f99b7137
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
daemon.py
View File

@ -34,7 +34,7 @@ def set_config():
config["twitch"] = { config["twitch"] = {
"app_id": "", "app_id": "",
"app_secret": "", "app_secret": "",
"streamers": ("asdf", "qqqqq") "streamers": "asdf,qqqqq"
} }
with open('cfg_file.ini', 'w') as cfg_file: with open('cfg_file.ini', 'w') as cfg_file:
config.write(cfg_file) config.write(cfg_file)
@ -55,7 +55,7 @@ def which(command):
return False return False
def checkTools(): def check_installed_tools():
""" """
Проверяет, установлены ли необходимые утилиты Проверяет, установлены ли необходимые утилиты
""" """
@ -67,7 +67,7 @@ def checkTools():
return True return True
def startRecord(i): def start_recording(i):
""" """
Функция, которая запускает в отдельном потоке запись стрима - recorder(i) Функция, которая запускает в отдельном потоке запись стрима - recorder(i)
""" """
@ -92,14 +92,14 @@ def recorder(i):
log.info("lock файл удален") log.info("lock файл удален")
def checkAlive(): def check_stream():
# FIXME: Распилить ну более мелкие функции # FIXME: Распилить на более мелкие функции
""" """
1. Проверка на наличие стрима 1. Проверка на наличие стрима
1.1 Если нет - удалить lock файл, если он есть 1.1 Если нет - удалить lock файл, если он есть
1.2 Если есть - создать lock файл, запустить записывалку 1.2 Если есть - создать lock файл, запустить записывалку
""" """
for i in config['twitch']['streamers']: for i in config['twitch']['streamers'].split(','):
# Путь до диры со стримами # Путь до диры со стримами
path = config['app']['path'] + "/" + i path = config['app']['path'] + "/" + i
# Получаем инфо о стримере, если не получается, выходим с ошибкой # Получаем инфо о стримере, если не получается, выходим с ошибкой
@ -127,7 +127,7 @@ def checkAlive():
if (user_stream['data'][0]['type'] == 'live') and not ( if (user_stream['data'][0]['type'] == 'live') and not (
os.path.exists(config['app']['path'] + "/" + i + "/pid")): os.path.exists(config['app']['path'] + "/" + i + "/pid")):
log.info(i + " стримит") log.info(i + " стримит")
startRecord(i) start_recording(i)
open(config['app']['path'] + "/pid", 'w').close open(config['app']['path'] + "/pid", 'w').close
else: else:
log.info( log.info(
@ -145,7 +145,7 @@ def checkAlive():
os.remove(path + "/pid") os.remove(path + "/pid")
def removeOldStreams(): def remove_old_streams():
# https://clck.ru/WHh32 # https://clck.ru/WHh32
records_path = config['app']['path'] records_path = config['app']['path']
# По каждой папке со стримерами # По каждой папке со стримерами
@ -188,7 +188,7 @@ def get_logger(logger_name):
if __name__ == "__main__": if __name__ == "__main__":
# Проверить, установлены ли нужные утилиты # Проверить, установлены ли нужные утилиты
if not checkTools(): if not check_installed_tools():
exit() exit()
# Set config # Set config
@ -199,9 +199,9 @@ if __name__ == "__main__":
log.info("Запущен") log.info("Запущен")
# Проверять стримы раз в check_period # Проверять стримы раз в check_period
schedule.every(int(config['app']['check_period'])).seconds.do(checkAlive) schedule.every(int(config['app']['check_period'])).seconds.do(check_stream)
# Каждый час удалять старые стримы # Каждый час удалять старые стримы
schedule.every(1).hours.do(removeOldStreams) schedule.every(1).hours.do(remove_old_streams)
twitch_client = Twitch(config['twitch']['app_id'], config['twitch']['app_secret']) twitch_client = Twitch(config['twitch']['app_id'], config['twitch']['app_secret'])
while True: while True: