Update app.py

app.py

@@ -41,17 +41,18 @@ def text_to_pcm_array(text: str) -> str:
 
 
 # ---------- ENDPOINT ----------
-@app.post("/send_message_recive_pcm", response_class=PlainTextResponse)
-async def send_message_recive_pcm(message: str = Form(...)):
-    pcm_array = text_to_pcm_array(message)
-    return pcm_array
-
-# from pydantic import BaseModel
+# @app.post("/send_message_recive_pcm", response_class=PlainTextResponse)
+# async def send_message_recive_pcm(message: str = Form(...)):
+#     pcm_array = text_to_pcm_array(message)
+#     return pcm_array
 
-# class Request(BaseModel):
-#     message: str
+from fastapi.responses import StreamingResponse
+import io
 
-# @app.post("/send_message_recive_pcm", response_class=PlainTextResponse)
-# async def send_message_recive_pcm(req: Request):
-#     pcm_array = text_to_pcm_array(req.message)
-#     return pcm_array
+@app.post("/send_message_recive_pcm")
+async def send_message_recive_pcm(message: str = Form(...)):
+    pcm_array = text_to_pcm_array(message)  # numpy array dtype=int16
+    buf = io.BytesIO()
+    buf.write(pcm_array.tobytes())
+    buf.seek(0)
+    return StreamingResponse(buf, media_type="application/octet-stream")