fix: fix ws

src/asr/provider/funasr/ws.ts

@@ -1,4 +1,5 @@
 // import WebSocket from 'ws';
+import { EventEmitter } from 'eventemitter3';
 import { WSServer, WSSOptions } from '../../provider/ws-server.ts';
 
 export type VideoWSOptions = {
@@ -9,6 +10,7 @@ export type VideoWSOptions = {
   isFile?: boolean;
   onConnect?: () => void;
   wav_format?: string;
+  emitter?: EventEmitter;
 } & {
   wsOptions?: WSSOptions['wsOptions'];
 };
@@ -29,7 +31,7 @@ type OpenRequest = {
   // '2pass' - 双通道模式, 'online' - 在线模式, 'offline' - 离线模式
   mode: VideoWsMode;
   // 音频格式:
-  wav_format?: string;
+  wav_format?: string; // 'wav' - PCM格式, 'mp3' - MP3格式等
   // 音频采样率(单位: Hz):
   audio_fs?: number;
   // 热词列表:
@@ -74,8 +76,6 @@ export class VideoWS extends WSServer {
       request.wav_format = 'PCM';
       request.audio_fs = file_sample_rate;
     }
-    console.log('request', request);
-
     this.ws.send(JSON.stringify(request));
   }
   async stop() {
@@ -119,7 +119,11 @@ export class VideoWS extends WSServer {
     const data = event.data;
     try {
       const result = JSON.parse(data.toString());
-      console.log('result', result);
+      if (result?.is_final !== undefined && result?.text) {
+        // console.log('result', result, typeof result);
+        this.emitter.emit('result', result);
+      }
+      console.log('onMessage-result', result);
     } catch (error) {
       console.log('error', error);
     }

src/asr/provider/ws-server.ts

@@ -45,7 +45,7 @@ export class WSServer {
    */
   async onOpen() {
     this.connected = true;
-    this.onConnect();
+    this?.onConnect?.();
     this.emitter.emit('open');
   }
   /**