Update app.py

app.py

@@ -1113,13 +1113,13 @@ class LibrarianCurve:
 class VoiceServicesModule(IModule):
     def __init__(self, hive_instance: "Hive"):
         super().__init__(hive_instance)
-        if _HAVE_VAD: # type: ignore
-            hive_instance.vad_service = VADService(aggressiveness=CFG["VOICE_VAD_AGGRESSIVENESS"])
-        hive_instance.asr_service = ASRService()
-        hive_instance.tts_service = TTSService()
-        hive_instance.video_service = VideoService()
 
     def start(self):
+        if _HAVE_VAD:
+            self.hive.vad_service = VADService(aggressiveness=CFG["VOICE_VAD_AGGRESSIVENESS"])
+        self.hive.asr_service = ASRService()
+        self.hive.tts_service = TTSService()
+        self.hive.video_service = VideoService(self.hive)
         if self.hive.video_service: self.hive.video_service.start()
 
     def stop(self):
@@ -1127,20 +1127,13 @@ class VoiceServicesModule(IModule):
 
 class VideoService(IModule):
     """Handles video capture from a webcam."""
-    def __init__(self, hive_instance: "Hive"):
-        super().__init__(hive_instance)
-        self.cap = None
-        self.stop_event = threading.Event()
-        self.frame_lock = threading.Lock()
-        self.latest_frame = None
-
     def start(self):
-        if not (_HAVE_CV and CFG["VIDEO_ENABLED"]): return
-        self.cap = cv2.VideoCapture(0)
-        if not self.cap.isOpened():
-            print("[VideoService] Could not open video device.")
-            self.cap = None
+        if self.hive.video_service: self.hive.video_service.start()
+
+    def stop(self):
+        if self.hive.video_service: self.hive.video_service.stop_event.set()
 
+class VideoService(IModule):
     def get_frame(self):
         if not self.cap: return None
         ret, frame = self.cap.read()
@@ -1154,6 +1147,18 @@ class PersistenceEngine(IModule):
     def start(self): pass
     def stop(self): pass
 
+class VADService:
+    def __init__(self, aggressiveness=2): pass
+    def process_stream(self, audio_chunk): yield audio_chunk
+
+class TTSService:
+    def synthesize(self, text, uid):
+        v = get_tts("en")
+        aud, _ = v.synthesize(text)
+        sr = v.sample_rate
+        outp=os.path.join(tempfile.gettempdir(), f"hive_tts_{int(time.time())}.wav")
+        sf.write(outp, aud if aud is not None else np.zeros(1), sr or 22050, subtype="PCM_16"); return outp
+
 # ----------- Hive core -----------
 
 # type: ignore
@@ -1213,6 +1218,18 @@ class CurveStoreModule(CurveStore, IModule): # type: ignore
     def start(self): pass
     def stop(self): pass
 
+class LibrarianModule(LibrarianCurve, IModule):
+    def __init__(self, hive_instance: "Hive"):
+        IModule.__init__(self, hive_instance)
+        LibrarianCurve.__init__(self, hive_instance.store, hive_instance.kstore)
+    def start(self): pass
+    def stop(self): pass
+
+class DialogueManager(IModule):
+    """Handles the core turn-taking logic of the chatbot."""
+    def start(self): self.model_bridge = ModelBridge(self.hive)
+    def stop(self): pass
+
 class EngineModule(EngineCurve, IModule):
     def __init__(self, hive_instance: "Hive"):
         IModule.__init__(self, hive_instance)
@@ -1494,22 +1511,29 @@ class Hive:
 
     def chat(self, message:str, effective_role:str, caller_id: Optional[str],
              k:int=None, max_new_tokens:int=256, temperature:float=None, prompt_override: Optional[str] = None) -> str: # type: ignore
-        temp = temperature if temperature is not None else (self.decoding_temperature if not self.lite_mode else 0.7)
+        temp = temperature if temperature is not None else (self.decoding_temperature if hasattr(self, 'decoding_temperature') else 0.7)
 
         if self.lite_mode:
             prompt = f"<|user|>\n{message}</s>\n<|assistant|>\n"
             full_reply = "".join(list(self.chat_stream(prompt, max_new_tokens, temp)))
             return full_reply
         
+        user_profile = self.persistence.load_json("users", caller_id or "guest", default={})
+        user_lang = user_profile.get("language", "en")
+        phonics_on = user_profile.get("phonics_on", False)
+
+        final_message, intent = self._prepare_chat_input(message, user_lang, phonics_on, prompt_override)
+
         kk = k if k is not None else (self.retrieval_k if hasattr(self, 'retrieval_k') else 6)
         snippets = self._get_retrieval_context(message, effective_role, caller_id, kk) # type: ignore
 
         prompt = self.compiler.compile( # type: ignore
-            final_message, 
-            snippets, 
-            token_budget=int(CFG["CTX_TOKENS"]), 
-            intent=intent, 
-            user_lang=user_lang
+            final_instruction=final_message,
+            snippets=snippets,
+            token_budget=int(CFG["CTX_TOKENS"]),
+            intent=intent,
+            user_prefs={"language": user_lang},
+            role=effective_role
         )
 
         full_output = "".join(list(self.chat_stream(prompt, max_new_tokens, temp))) # type: ignore