From: Andrew Gundersen <gundersena@xavier.edu>
Date: Mon, 1 Feb 2021 21:42:54 +0000 (-0600)
Subject: ws loop
X-Git-Tag: v0.9~112
X-Git-Url: https://andrewgundersen.net/repos?a=commitdiff_plain;h=e2dc3bad20731fb3f035531dbd3e257dab245948;p=mime-chat

ws loop
---

diff --git a/ws.py b/ws.py
index 57751f3..7dd8027 100644
--- a/ws.py
+++ b/ws.py
@@ -19,7 +19,9 @@ config = speech.RecognitionConfig(
 )
 
 streaming_config = speech.StreamingRecognitionConfig(config=config)
-def test(stream):
+
+def transcribe(stream):
+
     requests = (
         speech.StreamingRecognizeRequest(audio_content=chunk) for chunk in stream
     )
@@ -44,14 +46,22 @@ def test(stream):
                     print(u"Transcript: {}".format(alternative.transcript))
 
 
-stream = []
-async def hello(websocket, path):
-    chunk = await websocket.recv()
-    print(chunk)
 
+async def session(websocket, path):
+    buf = []
+
+    while True:
+        chunk = await websocket.recv()
+
+        if chunk == "stop":
+            break
+
+        buf.append(chunk)
+
+    transcribe(buf)
 
-start_server = websockets.serve(hello, "localhost", 8080)
 
+start_server = websockets.serve(session, "localhost", 8080)
 asyncio.get_event_loop().run_until_complete(start_server)
 asyncio.get_event_loop().run_forever()