feat: enhance stream and transcribe message handling for additional config status types

Author: markitosha

src/custom/stream/CustomStream.ts

@@ -9,7 +9,6 @@ import { parseStreamResponseType } from "./parseStreamResponseType.js";
 const STREAM_CONFIG_REJECTION_TYPES: readonly string[] = [
     Corti.StreamConfigStatusMessageType.ConfigDenied,
     Corti.StreamConfigStatusMessageType.ConfigMissing,
-    Corti.StreamConfigStatusMessageType.ConfigTimeout,
     Corti.StreamConfigStatusMessageType.ConfigNotProvided,
 ];
 
@@ -126,7 +125,11 @@ export class CustomStream extends StreamClient {
         socket.socket.addEventListener("message", (event) => {
             const type = parseStreamResponseType(event.data);
 
-            if (type == null || type === Corti.StreamConfigStatusMessageType.ConfigAccepted) {
+            if (
+                type == null ||
+                type === Corti.StreamConfigStatusMessageType.ConfigAccepted ||
+                type === Corti.StreamConfigStatusMessageType.ConfigAlreadyReceived
+            ) {
                 return;
             }
 
@@ -158,7 +161,10 @@ export class CustomStream extends StreamClient {
                 const type = parseStreamResponseType(event.data);
                 if (type == null) return;
 
-                if (type === Corti.StreamConfigStatusMessageType.ConfigAccepted) {
+                if (
+                    type === Corti.StreamConfigStatusMessageType.ConfigAccepted ||
+                    type === Corti.StreamConfigStatusMessageType.ConfigAlreadyReceived
+                ) {
                     cleanup();
                     resolve();
                 } else if (STREAM_CONFIG_REJECTION_TYPES.includes(type)) {

src/custom/transcribe/CustomTranscribe.ts

@@ -9,6 +9,7 @@ import { parseTranscribeResponseType } from "./parseTranscribeResponseType.js";
 const TRANSCRIBE_CONFIG_REJECTION_TYPES: readonly string[] = [
     Corti.TranscribeConfigStatusMessageType.ConfigDenied,
     Corti.TranscribeConfigStatusMessageType.ConfigTimeout,
+    Corti.TranscribeConfigStatusMessageType.ConfigMissing,
 ];
 
 export type CustomTranscribeConnectArgs = {
@@ -123,7 +124,11 @@ export class CustomTranscribe extends TranscribeClient {
         socket.socket.addEventListener("message", (event) => {
             const type = parseTranscribeResponseType(event.data);
 
-            if (type == null || type === Corti.TranscribeConfigStatusMessageType.ConfigAccepted) {
+            if (
+                type == null ||
+                type === Corti.TranscribeConfigStatusMessageType.ConfigAccepted ||
+                type === Corti.TranscribeConfigStatusMessageType.ConfigAlreadyReceived
+            ) {
                 return;
             }
 
@@ -155,7 +160,10 @@ export class CustomTranscribe extends TranscribeClient {
                 const type = parseTranscribeResponseType(event.data);
                 if (type == null) return;
 
-                if (type === Corti.TranscribeConfigStatusMessageType.ConfigAccepted) {
+                if (
+                    type === Corti.TranscribeConfigStatusMessageType.ConfigAccepted ||
+                    type === Corti.TranscribeConfigStatusMessageType.ConfigAlreadyReceived
+                ) {
                     cleanup();
                     resolve();
                 } else if (TRANSCRIBE_CONFIG_REJECTION_TYPES.includes(type)) {