Compare commits

..

No commits in common. "e5f99b7137e0f194921eb4f730e66dd562f3cc8f" and "b31f2ebcf7290b743473cfb662d99b0edac27e8c" have entirely different histories.

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 check_installed_tools(): def checkTools():
""" """
Проверяет, установлены ли необходимые утилиты Проверяет, установлены ли необходимые утилиты
""" """
@ -67,7 +67,7 @@ def check_installed_tools():
return True return True
def start_recording(i): def startRecord(i):
""" """
Функция, которая запускает в отдельном потоке запись стрима - recorder(i) Функция, которая запускает в отдельном потоке запись стрима - recorder(i)
""" """
@ -92,14 +92,14 @@ def recorder(i):
log.info("lock файл удален") log.info("lock файл удален")
def check_stream(): def checkAlive():
# FIXME: Распилить на более мелкие функции # FIXME: Распилить ну более мелкие функции
""" """
1. Проверка на наличие стрима 1. Проверка на наличие стрима
1.1 Если нет - удалить lock файл, если он есть 1.1 Если нет - удалить lock файл, если он есть
1.2 Если есть - создать lock файл, запустить записывалку 1.2 Если есть - создать lock файл, запустить записывалку
""" """
for i in config['twitch']['streamers'].split(','): for i in config['twitch']['streamers']:
# Путь до диры со стримами # Путь до диры со стримами
path = config['app']['path'] + "/" + i path = config['app']['path'] + "/" + i
# Получаем инфо о стримере, если не получается, выходим с ошибкой # Получаем инфо о стримере, если не получается, выходим с ошибкой
@ -127,7 +127,7 @@ def check_stream():
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 + " стримит")
start_recording(i) startRecord(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 check_stream():
os.remove(path + "/pid") os.remove(path + "/pid")
def remove_old_streams(): def removeOldStreams():
# 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 check_installed_tools(): if not checkTools():
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(check_stream) schedule.every(int(config['app']['check_period'])).seconds.do(checkAlive)
# Каждый час удалять старые стримы # Каждый час удалять старые стримы
schedule.every(1).hours.do(remove_old_streams) schedule.every(1).hours.do(removeOldStreams)
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: