Merge pull request #55 from Clement-mim/master

Add sendResult method

Author: ccoreilly

lib/src/interfaces.ts

@@ -36,6 +36,11 @@ export interface ClientMessageCreateRecognizer {
   grammar?: string;
 }
 
+export interface ClientMessageRetrieveFinalResult {
+  action: "retrieveFinalResult";
+  recognizerId: string;
+}
+
 export interface ClientMessageRemoveRecognizer {
   action: "remove";
   recognizerId: string;
@@ -47,6 +52,7 @@ export type ClientMessage =
   | ClientMessageCreateRecognizer
   | ClientMessageAudioChunk
   | ClientMessageSet
+  | ClientMessageRetrieveFinalResult
   | ClientMessageRemoveRecognizer;
 
 export namespace ClientMessage {
@@ -80,6 +86,12 @@ export namespace ClientMessage {
     return message?.action === "create";
   }
 
+  export function isRecognizerRetrieveFinalResultMessage(
+    message: ClientMessage
+  ): message is ClientMessageRetrieveFinalResult {
+    return message?.action === "retrieveFinalResult";
+  }
+
   export function isRecognizerRemoveMessage(
     message: ClientMessage
   ): message is ClientMessageRemoveRecognizer {

lib/src/model.ts

@@ -8,12 +8,12 @@ import {
   ClientMessageTerminate,
   ClientMessageLoad,
   ClientMessageRemoveRecognizer,
+  ClientMessageCreateRecognizer,
+  ClientMessageRetrieveFinalResult,
   ModelMessage,
   RecognizerEvent,
   RecognizerMessage,
   ServerMessage,
-  ServerMessageLoadResult,
-  ClientMessageCreateRecognizer,
 } from "./interfaces";
 import { Logger } from "./utils/logging";
 
@@ -211,6 +211,13 @@ export class Model extends EventTarget {
         );
       }
 
+      public retrieveFinalResult(): void {
+        model.postMessage<ClientMessageRetrieveFinalResult>({
+          action: "retrieveFinalResult",
+          recognizerId: this.id,
+        });
+      }
+
       public remove(): void {
         model.unregisterRecognizer(this.id);
 

lib/src/worker.ts

@@ -92,6 +92,15 @@ export class RecognizerWorker {
       return;
     }
 
+    if (ClientMessage.isRecognizerRetrieveFinalResultMessage(message)) {
+      this.retrieveFinalResult(message.recognizerId)
+        .then((result) => {
+          ctx.postMessage(result);
+        })
+        .catch((error) => ctx.postMessage({ event: "error", recognizerId: message.recognizerId, error: error.message }));
+      return;
+    }
+
     if (ClientMessage.isTerminateMessage(message)) {
       this.terminate();
       return;
@@ -301,6 +310,22 @@ export class RecognizerWorker {
     }
   }
 
+  private async retrieveFinalResult(recognizerId: string) {
+    if (!this.recognizers.has(recognizerId)) {
+      throw new Error(
+        `Recognizer (id: ${recognizerId}): Does not exist or has already been deleted`
+      );
+    }
+    const recognizer = this.recognizers.get(recognizerId)!;
+    const finalResult = recognizer.recognizer.FinalResult();
+
+    return {
+      event: "result",
+      recognizerId,
+      result: JSON.parse(finalResult),
+    };
+  }
+
   private async removeRecognizer(recognizerId: string) {
     if (!this.recognizers.has(recognizerId)) {
       throw new Error(