Update /api/listen-for-wake to enable/disable wake word

CHANGELOG

@@ -1,3 +1,9 @@
+## [2.4.18] - Unreleased
+
+### Added
+
+- /api/listen-for-wake accepts "on" and "off" as POST data to enable/disable wake word
+
 ## [2.4.17] - 2020 Jan 21
 
 ### Added

VERSION

@@ -1 +1 @@
-2.4.17
+2.4.18

app.py

@@ -269,8 +269,11 @@ async def api_speakers() -> Response:
 async def api_listen_for_wake() -> str:
     """Make Rhasspy listen for a wake word"""
     assert core is not None
-    core.listen_for_wake()
-    return "OK"
+    enabled_str = (await request.data).decode().strip().lower()
+    enabled = enabled_str not in ["false", "off"]
+    core.listen_for_wake(enabled)
+
+    return str(enabled)
 
 
 # -----------------------------------------------------------------------------

docs/reference.md

@@ -53,7 +53,8 @@ Application authors may want to use the [rhasspy-client](https://pypi.org/projec
     * `?timeout=<seconds>` - override default command timeout
     * `?entity=<entity>&value=<value>` - set custom entity/value in recognized intent
 * `/api/listen-for-wake-word`
-    * POST to wake Rhasspy up and return immediately
+    * POST "on" to have Rhasspy listen for a wake word
+    * POST "off" to disable wake word
 * `/api/lookup`
     * POST word as plain text to look up or guess pronunciation
     * `?n=<number>` - return at most `n` guessed pronunciations

rhasspy/core.py

@@ -39,6 +39,7 @@
     SentenceSpoken,
     SpeakSentence,
     SpeakWord,
+    StopListeningForWakeWord,
     StartRecordingToBuffer,
     StopRecordingToBuffer,
     TestMicrophones,
@@ -162,10 +163,14 @@ async def get_speakers(self, system: Optional[str] = None) -> Dict[Any, Any]:
 
     # -------------------------------------------------------------------------
 
-    def listen_for_wake(self) -> None:
+    def listen_for_wake(self, enabled: bool = True) -> None:
         """Tell Rhasspy to start listening for a wake word."""
         assert self.actor_system is not None
-        self.actor_system.tell(self.dialogue_manager, ListenForWakeWord())
+
+        if enabled:
+            self.actor_system.tell(self.dialogue_manager, ListenForWakeWord())
+        else:
+            self.actor_system.tell(self.dialogue_manager, StopListeningForWakeWord())
 
     async def listen_for_command(
         self,

rhasspy/dialogue.py

@@ -732,6 +732,9 @@ def handle_any(self, message: Any, sender: RhasspyActor) -> None:
         elif isinstance(message, GetProblems):
             # Report problems from child actors
             self.send(sender, Problems(self.problems))
+        elif isinstance(message, (ListenForWakeWord, StopListeningForWakeWord)):
+            # Forward to wake actor
+            self.send(self.wake, message)
         else:
             self.handle_forward(message, sender)
 

rhasspy/wake.py

@@ -232,6 +232,7 @@ def load_decoder(self) -> None:
             with open(dict_path, "r") as dict_file:
                 word_dict = read_dict(dict_file)
 
+            # TODO: Use dictionary_casing instead
             dict_upper = self.profile.get("speech_to_text.dictionary_upper", False)
             for word in keyphrase_words:
                 if dict_upper:
@@ -570,7 +571,9 @@ def in_listening(self, message: Any, sender: RhasspyActor) -> None:
                     self.prediction_sem = threading.Semaphore()
                     for _ in range(num_chunks):
                         chunk = self.audio_buffer[: self.chunk_size]
-                        self.stream.write(chunk)
+                        if chunk:
+                            self.stream.write(chunk)
+
                         self.audio_buffer = self.audio_buffer[self.chunk_size :]
 
                     if self.send_not_detected: