Compare commits

..

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

View File

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