Compare commits
No commits in common. "e5f99b7137e0f194921eb4f730e66dd562f3cc8f" and "b31f2ebcf7290b743473cfb662d99b0edac27e8c" have entirely different histories.
e5f99b7137
...
b31f2ebcf7
22
daemon.py
22
daemon.py
@ -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:
|
||||||
|
Loading…
Reference in New Issue
Block a user