2021-07-18 03:06:08 +03:00
|
|
|
|
#!/usr/bin/python3
|
|
|
|
|
|
2021-07-23 02:28:08 +03:00
|
|
|
|
# TODO: Сделать проверку на наличие стримера
|
2021-07-22 08:30:37 +03:00
|
|
|
|
# FIXME: не создавать папки для несуществующих стримеров
|
|
|
|
|
# TODO: Сделать нормальную конфигурацию
|
2021-07-23 02:28:08 +03:00
|
|
|
|
# TODO: сделать возможность добавлять свои параметры в cmdline к команде записи
|
2021-07-18 03:06:08 +03:00
|
|
|
|
|
2021-07-18 05:39:06 +03:00
|
|
|
|
import os
|
2021-07-18 03:06:08 +03:00
|
|
|
|
from threading import Thread
|
|
|
|
|
import config_python
|
2021-07-23 02:04:09 +03:00
|
|
|
|
import schedule
|
|
|
|
|
from twitch import TwitchClient
|
|
|
|
|
import subprocess
|
|
|
|
|
import time
|
2021-07-23 02:28:08 +03:00
|
|
|
|
streamers = config_python.streamers
|
|
|
|
|
client_id = config_python.twitchid
|
2021-07-23 02:04:09 +03:00
|
|
|
|
|
2021-07-18 03:06:08 +03:00
|
|
|
|
|
2021-07-22 09:13:13 +03:00
|
|
|
|
def which(command):
|
|
|
|
|
# Пиздец, почему нет нормального аналога which из bash???
|
2021-07-23 02:20:32 +03:00
|
|
|
|
'''
|
|
|
|
|
Мой аналог which из bash'а, который отдает true или false при наличии или отсутствии утилиты
|
|
|
|
|
'''
|
2021-07-22 09:13:13 +03:00
|
|
|
|
for dirs in os.get_exec_path():
|
|
|
|
|
if command in os.listdir(dirs):
|
|
|
|
|
# Если что-нибудь нашли, то True
|
|
|
|
|
return True
|
2021-07-23 02:20:32 +03:00
|
|
|
|
# Если ничего не нашли во всех дирах, то выходим с False
|
2021-07-22 09:13:13 +03:00
|
|
|
|
return False
|
|
|
|
|
|
2021-07-22 09:22:21 +03:00
|
|
|
|
def checkTools():
|
|
|
|
|
'''
|
|
|
|
|
Проверяет, установлены ли необходимые утилиты
|
|
|
|
|
'''
|
|
|
|
|
tools = ('youtube-dl', 'ffmpeg')
|
|
|
|
|
for i in tools:
|
|
|
|
|
if not which(i):
|
|
|
|
|
print(i + " не установлен")
|
|
|
|
|
return False
|
|
|
|
|
return True
|
|
|
|
|
|
2021-07-18 03:06:08 +03:00
|
|
|
|
def startRecord(i):
|
|
|
|
|
'''
|
|
|
|
|
Функция, которая запускает в отдельном потоке запись стрима - recorder(i)
|
|
|
|
|
'''
|
|
|
|
|
th = Thread(target=recorder, args=(i, ))
|
|
|
|
|
th.start()
|
|
|
|
|
|
|
|
|
|
def recorder(i):
|
|
|
|
|
'''
|
|
|
|
|
Функция, которая запускает youtube-dl, фактически записывает стрим
|
|
|
|
|
'''
|
2021-07-18 22:16:03 +03:00
|
|
|
|
path = config_python.path + "/"+ i
|
2021-07-18 03:06:08 +03:00
|
|
|
|
print("Записываем стрим %s\n" % i)
|
2021-07-23 02:20:32 +03:00
|
|
|
|
# cmdline для запуска youtube-dl
|
2021-07-31 14:41:35 +03:00
|
|
|
|
cmdline = ["youtube-dl", "-q",
|
|
|
|
|
"-o", path + "/%(upload_date)s_%(title)s__%(timestamp)s_%(id)s.%(ext)s",
|
|
|
|
|
"https://twitch.tv/"+i]
|
|
|
|
|
s = subprocess.call(cmdline)
|
2021-07-18 03:06:08 +03:00
|
|
|
|
print("Запись стрима %s закончена\n" % i)
|
2021-07-18 22:16:03 +03:00
|
|
|
|
if (os.path.exists(path+"/pid")):
|
|
|
|
|
os.system("rm "+path+"/pid")
|
|
|
|
|
print("lock файл удален")
|
2021-07-18 03:06:08 +03:00
|
|
|
|
|
2021-07-23 02:04:09 +03:00
|
|
|
|
def checkAlive():
|
2021-07-18 03:06:08 +03:00
|
|
|
|
'''
|
|
|
|
|
1. Проверка на наличие стрима
|
|
|
|
|
1.1 Если нет - удалить lock файл, если он есть
|
|
|
|
|
1.2 Если есть - создать lock файл, запустить записывалку
|
|
|
|
|
'''
|
|
|
|
|
client = TwitchClient(client_id=client_id)
|
|
|
|
|
for i in streamers:
|
2021-07-18 05:39:06 +03:00
|
|
|
|
# Путь до диры со стримами
|
|
|
|
|
path = config_python.path + "/"+ i
|
2021-07-18 22:16:03 +03:00
|
|
|
|
# Создаем путь до диры со стримером, если его нет
|
2021-07-23 02:28:56 +03:00
|
|
|
|
if not (os.path.exists(path)):
|
2021-07-18 05:39:06 +03:00
|
|
|
|
os.makedirs(path)
|
|
|
|
|
user_id=client.users.translate_usernames_to_ids(i)[0]['id'] # Получить ID по нику
|
|
|
|
|
# Если стрим идет, то идем дальше
|
2021-07-18 03:06:08 +03:00
|
|
|
|
if client.streams.get_stream_by_user(user_id):
|
2021-07-18 05:39:06 +03:00
|
|
|
|
# Если стрим идет и лок файла нет, то записываем и ставим лок
|
|
|
|
|
if (client.streams.get_stream_by_user(user_id).stream_type == 'live') and not (os.path.exists(config_python.path+"/"+i+"/pid")):
|
|
|
|
|
print(i+" стримит")
|
2021-07-18 03:06:08 +03:00
|
|
|
|
startRecord(i)
|
2021-07-18 05:39:06 +03:00
|
|
|
|
os.system("touch "+path+"/pid")
|
|
|
|
|
else:
|
2021-07-31 14:41:35 +03:00
|
|
|
|
print(i+" Идет запись")
|
2021-07-18 03:06:08 +03:00
|
|
|
|
else:
|
2021-07-18 05:39:06 +03:00
|
|
|
|
# Если стрим не идет, то пишем об этом и убираем его из залоченных
|
2021-07-18 03:06:08 +03:00
|
|
|
|
print(i+" Не стримит")
|
2021-07-18 22:16:03 +03:00
|
|
|
|
# Если есть лок, то удаляем
|
|
|
|
|
if (os.path.exists(path+"/pid")):
|
|
|
|
|
os.system("rm "+path+"/pid")
|
2021-07-18 05:39:06 +03:00
|
|
|
|
|
2021-07-18 03:06:08 +03:00
|
|
|
|
|
2021-07-18 03:32:01 +03:00
|
|
|
|
def removeOldStreams():
|
2021-07-22 08:30:37 +03:00
|
|
|
|
# https://clck.ru/WHh32
|
2021-07-23 04:07:53 +03:00
|
|
|
|
records_path = config_python.path
|
|
|
|
|
# По каждой папке со стримерами
|
|
|
|
|
for i in streamers:
|
|
|
|
|
if len(os.listdir(records_path+i)) > config_python.max_files:
|
|
|
|
|
# Получаем список файлов
|
|
|
|
|
# и смотрим, превышает ли кол-во mp4 файлов заданное в конфиге
|
|
|
|
|
# Если превышает - удаляем старейший
|
|
|
|
|
oldest = min(os.listdir(records_path+i), key=os.path.getctime)
|
|
|
|
|
os.unlink(oldest)
|
|
|
|
|
print("Удален файл: " + oldest)
|
2021-07-18 03:06:08 +03:00
|
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
2021-07-23 04:07:53 +03:00
|
|
|
|
# Проверить, установлены ли нужные утилиты
|
2021-07-23 02:20:32 +03:00
|
|
|
|
if not checkTools(): exit()
|
2021-07-23 04:07:53 +03:00
|
|
|
|
# Проверять стримы раз в check_period
|
2021-07-31 14:41:35 +03:00
|
|
|
|
schedule.every(config_python.check_period).seconds.do(checkAlive)
|
2021-07-23 04:07:53 +03:00
|
|
|
|
# Каждый час удалять старые стримы
|
|
|
|
|
schedule.every(1).hours.do(removeOldStreams)
|
2021-07-23 02:04:09 +03:00
|
|
|
|
while True:
|
|
|
|
|
schedule.run_pending()
|
|
|
|
|
time.sleep(1)
|