daemon.py

@@ -1,9 +1,8 @@
 #!/usr/bin/python3
 
-# TODO: Сделать проверку на наличие стримера
 # FIXME: не создавать папки для несуществующих стримеров
 # TODO: Сделать нормальную конфигурацию
-# TODO: сделать возможность добавлять свои параметры в cmdline к команде записи
+# TODO: Автоматически удалять старые стримы
 
 import os
 from threading import Thread
@@ -12,8 +11,6 @@ import schedule
 from twitch import TwitchClient
 import subprocess
 import time
-streamers = config_python.streamers
-client_id = config_python.twitchid
 
 
 def which(command):
@@ -53,6 +50,7 @@ def recorder(i):
     path = config_python.path + "/"+ i
     print("Записываем стрим %s\n" % i)
     # cmdline для запуска youtube-dl 
+    # TODO: сделать возможность добавлять свои параметры
     cmdline = ["youtube-dl","https://twitch.tv/"+i]
     s = subprocess.call(cmdline, stdout=subprocess.DEVNULL)
     print("Запись стрима %s закончена\n" % i)
@@ -61,6 +59,8 @@ def recorder(i):
         print("lock файл удален")
 
 def checkAlive():
+    streamers = config_python.streamers
+    client_id = config_python.twitchid
     '''
     1. Проверка на наличие стрима
     1.1 Если нет - удалить lock файл, если он есть
@@ -71,8 +71,9 @@ def checkAlive():
         # Путь до диры со стримами
         path = config_python.path + "/"+ i
         # Создаем путь до диры со стримером, если его нет
-        if not (os.path.exists(path)):
+        if not (os.path.exists(config_python.path+"/"+i)):
             os.makedirs(path)
+        # TODO: Сделать проверку на наличие стримера
         user_id=client.users.translate_usernames_to_ids(i)[0]['id'] # Получить ID по нику
         # Если стрим идет, то идем дальше
         if client.streams.get_stream_by_user(user_id):
@@ -93,24 +94,11 @@ def checkAlive():
 
 def removeOldStreams():
     # https://clck.ru/WHh32
-    records_path = config_python.path
+    pass
-    # По каждой папке со стримерами
-    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)
 
 if __name__ == "__main__":
-    # Проверить, установлены ли нужные утилиты
     if not checkTools(): exit()
-    # Проверять стримы раз в check_period
+    schedule.every(config_python.period).minutes.do(checkAlive)
-    schedule.every(config_python.check_period).minutes.do(checkAlive)
-    # Каждый час удалять старые стримы
-    schedule.every(1).hours.do(removeOldStreams)
     while True:
         schedule.run_pending()
         time.sleep(1)