diff --git a/jbot/views.py b/jbot/views.py index d5b1f35..ac4cc95 100644 --- a/jbot/views.py +++ b/jbot/views.py @@ -311,19 +311,20 @@ def _do_asr(audio_bytes: bytes, mime_type: str = 'audio/webm') -> str: 'end_window_size': 800, }, }).encode() - ws.send_binary(_asr_pack(_ASR_MT_FULL_CLIENT, _FLAG_NO_SEQ, - _SER_JSON, _CMP_GZIP, gzip.compress(config))) + ws.send(_asr_pack(_ASR_MT_FULL_CLIENT, _FLAG_NO_SEQ, + _SER_JSON, _CMP_GZIP, gzip.compress(config)), + ws_module.ABNF.OPCODE_BINARY) CHUNK = 6400 pcm_data = pcm for off in range(0, len(pcm_data), CHUNK): chunk = pcm_data[off:off + CHUNK] is_last = (off + CHUNK >= len(pcm_data)) - ws.send_binary(_asr_pack( + ws.send(_asr_pack( _ASR_MT_AUDIO_ONLY, _FLAG_LAST_NO if is_last else _FLAG_NO_SEQ, _SER_NONE, _CMP_GZIP, gzip.compress(chunk), - )) + ), ws_module.ABNF.OPCODE_BINARY) def on_message(ws, data): try: