From 0efc87352ce7d3903dbdedbfa5d01ca5e1cb19e7 Mon Sep 17 00:00:00 2001
From: Shi Xian <40013335+R1ckShi@users.noreply.github.com>
Date: 星期四, 05 十二月 2024 15:15:38 +0800
Subject: [PATCH] Merge pull request #2267 from modelscope/dev_sx2
---
runtime/python/websocket/funasr_wss_server.py | 13 ++++++++++++-
1 files changed, 12 insertions(+), 1 deletions(-)
diff --git a/runtime/python/websocket/funasr_wss_server.py b/runtime/python/websocket/funasr_wss_server.py
index 1ff5856..9de120e 100644
--- a/runtime/python/websocket/funasr_wss_server.py
+++ b/runtime/python/websocket/funasr_wss_server.py
@@ -187,7 +187,7 @@
websocket.status_dict_vad["chunk_size"] = int(
websocket.status_dict_asr_online["chunk_size"][1] * 60 / websocket.chunk_interval
)
- if len(frames_asr_online) > 0 or len(frames_asr) > 0 or not isinstance(message, str):
+ if len(frames_asr_online) > 0 or len(frames_asr) >= 0 or not isinstance(message, str):
if not isinstance(message, str):
frames.append(message)
duration_ms = len(message) // 32
@@ -291,6 +291,17 @@
)
await websocket.send(message)
+ else:
+ mode = "2pass-offline" if "2pass" in websocket.mode else websocket.mode
+ message = json.dumps(
+ {
+ "mode": mode,
+ "text": "",
+ "wav_name": websocket.wav_name,
+ "is_final": websocket.is_speaking,
+ }
+ )
+ await websocket.send(message)
async def async_asr_online(websocket, audio_in):
if len(audio_in) > 0:
--
Gitblit v1.9.1