summaryrefslogtreecommitdiff
path: root/src/home/media
diff options
context:
space:
mode:
Diffstat (limited to 'src/home/media')
-rw-r--r--src/home/media/node_client.py6
-rw-r--r--src/home/media/record.py6
-rw-r--r--src/home/media/record_client.py18
-rw-r--r--src/home/media/storage.py4
4 files changed, 17 insertions, 17 deletions
diff --git a/src/home/media/node_client.py b/src/home/media/node_client.py
index 4430962..eb39898 100644
--- a/src/home/media/node_client.py
+++ b/src/home/media/node_client.py
@@ -2,7 +2,7 @@ import requests
import shutil
import logging
-from typing import Optional, Union
+from typing import Optional, Union, List
from .storage import RecordFile
from ..util import Addr
from ..api.errors import ApiResponseError
@@ -25,7 +25,7 @@ class MediaNodeClient:
def record_download(self, record_id: int, output: str):
return self._call(f'record/download/{record_id}/', save_to=output)
- def storage_list(self, extended=False, as_objects=False) -> Union[list[str], list[dict], list[RecordFile]]:
+ def storage_list(self, extended=False, as_objects=False) -> Union[List[str], List[dict], List[RecordFile]]:
r = self._call('storage/list/', params={'extended': int(extended)})
files = r['files']
if as_objects:
@@ -33,7 +33,7 @@ class MediaNodeClient:
return files
@staticmethod
- def record_list_from_serialized(files: Union[list[str], list[dict]]):
+ def record_list_from_serialized(files: Union[List[str], List[dict]]):
new_files = []
for f in files:
kwargs = {'remote': True}
diff --git a/src/home/media/record.py b/src/home/media/record.py
index fdb8382..cd7447a 100644
--- a/src/home/media/record.py
+++ b/src/home/media/record.py
@@ -5,7 +5,7 @@ import time
import subprocess
import signal
-from typing import Optional
+from typing import Optional, List, Dict
from ..util import find_child_processes, Addr
from ..config import config
from .storage import RecordFile, RecordStorage
@@ -22,7 +22,7 @@ class RecordHistoryItem:
request_time: float
start_time: float
stop_time: float
- relations: list[int]
+ relations: List[int]
status: RecordStatus
error: Optional[Exception]
file: Optional[RecordFile]
@@ -76,7 +76,7 @@ class RecordingNotFoundError(Exception):
class RecordHistory:
- history: dict[int, RecordHistoryItem]
+ history: Dict[int, RecordHistoryItem]
def __init__(self):
self.history = {}
diff --git a/src/home/media/record_client.py b/src/home/media/record_client.py
index f264155..322495c 100644
--- a/src/home/media/record_client.py
+++ b/src/home/media/record_client.py
@@ -7,7 +7,7 @@ from tempfile import gettempdir
from .record import RecordStatus
from .node_client import SoundNodeClient, MediaNodeClient, CameraNodeClient
from ..util import Addr
-from typing import Optional, Callable
+from typing import Optional, Callable, Dict
class RecordClient:
@@ -15,14 +15,14 @@ class RecordClient:
interrupted: bool
logger: logging.Logger
- clients: dict[str, MediaNodeClient]
- awaiting: dict[str, dict[int, Optional[dict]]]
+ clients: Dict[str, MediaNodeClient]
+ awaiting: Dict[str, Dict[int, Optional[dict]]]
error_handler: Optional[Callable]
finished_handler: Optional[Callable]
download_on_finish: bool
def __init__(self,
- nodes: dict[str, Addr],
+ nodes: Dict[str, Addr],
error_handler: Optional[Callable] = None,
finished_handler: Optional[Callable] = None,
download_on_finish=False):
@@ -50,7 +50,7 @@ class RecordClient:
self.stop()
self.logger.exception(exc)
- def make_clients(self, nodes: dict[str, Addr]):
+ def make_clients(self, nodes: Dict[str, Addr]):
pass
def stop(self):
@@ -148,9 +148,9 @@ class RecordClient:
class SoundRecordClient(RecordClient):
DOWNLOAD_EXTENSION = 'mp3'
- # clients: dict[str, SoundNodeClient]
+ # clients: Dict[str, SoundNodeClient]
- def make_clients(self, nodes: dict[str, Addr]):
+ def make_clients(self, nodes: Dict[str, Addr]):
for node, addr in nodes.items():
self.clients[node] = SoundNodeClient(addr)
self.awaiting[node] = {}
@@ -158,9 +158,9 @@ class SoundRecordClient(RecordClient):
class CameraRecordClient(RecordClient):
DOWNLOAD_EXTENSION = 'mp4'
- # clients: dict[str, CameraNodeClient]
+ # clients: Dict[str, CameraNodeClient]
- def make_clients(self, nodes: dict[str, Addr]):
+ def make_clients(self, nodes: Dict[str, Addr]):
for node, addr in nodes.items():
self.clients[node] = CameraNodeClient(addr)
self.awaiting[node] = {} \ No newline at end of file
diff --git a/src/home/media/storage.py b/src/home/media/storage.py
index 08ba06a..dd74ff8 100644
--- a/src/home/media/storage.py
+++ b/src/home/media/storage.py
@@ -3,7 +3,7 @@ import re
import shutil
import logging
-from typing import Optional, Union
+from typing import Optional, Union, List
from datetime import datetime
from ..util import strgen
@@ -149,7 +149,7 @@ class RecordStorage:
self.root = root
- def getfiles(self, as_objects=False) -> Union[list[str], list[RecordFile]]:
+ def getfiles(self, as_objects=False) -> Union[List[str], List[RecordFile]]:
files = []
for name in os.listdir(self.root):
path = os.path.join(self.root, name)