27 lines
782 B
Python
27 lines
782 B
Python
from fastapi import FastAPI
|
||
import redis
|
||
import os
|
||
|
||
app = FastAPI()
|
||
|
||
redis_host = os.getenv("REDIS_HOST", "localhost")
|
||
redis_port = int(os.getenv("REDIS_PORT", 6379))
|
||
r = redis.Redis(host=redis_host, port=redis_port, decode_responses=True)
|
||
|
||
@app.get("/health")
|
||
async def health():
|
||
return {"status": "ok", "service": "vad"}
|
||
|
||
@app.websocket("/audio-stream")
|
||
async def audio_stream(websocket):
|
||
await websocket.accept()
|
||
print("Client connected to VAD")
|
||
try:
|
||
while True:
|
||
data = await websocket.receive_bytes()
|
||
# Пока ничего не делаем с данными
|
||
# В будущем здесь будет VAD-обработка
|
||
pass
|
||
except Exception as e:
|
||
print(f"VAD connection closed: {e}")
|