Merge pull request #86 from AI4WA/doc

Doc
AI4WA · Jul 26, 2024 · 902db50 · 902db50
2 parents 2263b0e + 8b10df9
commit 902db50
Show file tree

Hide file tree

Showing 29 changed files with 1,088 additions and 487 deletions.
diff --git a/API/api/settings.py b/API/api/settings.py
@@ -221,7 +221,9 @@
 STORAGE_SOLUTION_LOCAL = "local"
 STORAGE_SOLUTION_S3 = "s3"
 STORAGE_SOLUTION_VOLUME = "volume"
-STORAGE_SOLUTION = os.environ.get("STORAGE_SOLUTION", "s3")
+STORAGE_SOLUTION = os.environ.get("STORAGE_SOLUTION", STORAGE_SOLUTION_S3)
+if STORAGE_SOLUTION == "":
+    STORAGE_SOLUTION = STORAGE_SOLUTION_API
 
 # update this
 S3_BUCKET = "openomni"  # update this to your S3 bucket name

diff --git a/Client/Listener/api.py b/Client/Listener/api.py
@@ -224,7 +224,7 @@ def get_storage_solution(self):
             return None
         data = r.json()
         logger.info(data)
-        return data.get("storage_solution", "volume")
+        return data.get("storage_solution", "local")
 
     def upload_file(
         self,

diff --git a/Client/Listener/audios_acquire.py b/Client/Listener/audios_acquire.py
@@ -17,15 +17,15 @@
 
 class AudioAcquire:
     def __init__(
-        self,
-        api_domain: str = "",
-        token: str = "",
-        home_id: Optional[str] = "",
-        energy_threshold: int = 5000,
-        default_microphone: str = "pulse",
-        record_timeout: int = 30000,
-        sampling_time: float = 0.25,
-        track_cluster: Optional[str] = None,
+            self,
+            api_domain: str = "",
+            token: str = "",
+            home_id: Optional[str] = "",
+            energy_threshold: int = 5000,
+            default_microphone: str = "pulse",
+            record_timeout: int = 30000,
+            sampling_time: float = 0.25,
+            track_cluster: Optional[str] = None,
     ):
         """
         The audio acquire class
@@ -131,9 +131,9 @@ def record_callback(_, audio: sr.AudioData) -> None:
                 curr_audio_dir.mkdir(parents=True, exist_ok=True)
 
                 with open(
-                    curr_audio_dir
-                    / f"{self.audio_index}-{sample_time.strftime('%Y%m%d%H%M%S')}.wav",
-                    "wb",
+                        curr_audio_dir
+                        / f"{self.audio_index}-{sample_time.strftime('%Y%m%d%H%M%S')}.wav",
+                        "wb",
                 ) as file:
                     file.write(wav_data)
                 self.audio_index += 1
@@ -209,7 +209,7 @@ def main():
         "--default_microphone",
         default="pulse",
         help="Default microphone name for SpeechRecognition. "
-        "Run this with 'list' to view available Microphones.",
+             "Run this with 'list' to view available Microphones.",
         type=str,
     )
     parser.add_argument(

diff --git a/Client/Listener/storage.py b/Client/Listener/storage.py
@@ -98,7 +98,6 @@ def on_any_event(self, event):
                 "png",
             ]:
                 return None
-                return None
             try:
                 self.s3_client.upload_file(
                     event.src_path,
@@ -150,12 +149,12 @@ def on_any_event(self, event):
 
 class StorageHandler:
     def __init__(
-        self,
-        api_domain: str = "",
-        token: str = "",
-        home_id: int = None,
-        dest_dir: Optional[str] = None,
-        dest_password: Optional[str] = None,
+            self,
+            api_domain: str = "",
+            token: str = "",
+            home_id: int = None,
+            dest_dir: Optional[str] = None,
+            dest_password: Optional[str] = None,
     ):
         """
         Args:
@@ -199,6 +198,9 @@ def process_s3(self):
 
     def process_local_network(self):
         observer = Observer()
+        if not self.dest_dir:
+            logger.error("dest_dir is required for local network sync")
+            return
         local_handler = LocalSyncHandler(
             src_path=str(DATA_DIR),
             dest_path=self.dest_dir,