conversation auth token update propagates to translation service connection

src/common.speech/CognitiveTokenAuthentication.ts

@@ -6,7 +6,7 @@ import { AuthInfo, IAuthentication } from "./IAuthentication";
 import { HeaderNames } from "./HeaderNames";
 
 export class CognitiveTokenAuthentication implements IAuthentication {
-    private static privTokenPrefix: string = "bearer ";
+    private static privTokenPrefix: string = "Bearer ";
     private privFetchCallback: (authFetchEventId: string) => Promise<string>;
     private privFetchOnExpiryCallback: (authFetchEventId: string) => Promise<string>;
 

src/common.speech/ServiceRecognizerBase.ts

@@ -279,7 +279,7 @@ export abstract class ServiceRecognizerBase implements IDisposable {
     }
 
     public set authentication(auth: IAuthentication) {
-        this.privAuthentication = this.authentication;
+        this.privAuthentication = auth;
     }
 
     public isDisposed(): boolean {

src/common.speech/Transcription/ConversationServiceAdapter.ts

@@ -412,6 +412,7 @@ export class ConversationServiceAdapter extends ServiceRecognizerBase {
                                         return Promise.resolve(authorizationToken);
                                     });
                                 this.authentication = token;
+                                this.privConversationServiceConnector.onToken(token);
 
                                 break;
 

src/common.speech/Transcription/ConversationTranslatorConnectionFactory.ts

@@ -121,7 +121,7 @@ export class ConversationTranslatorConnectionFactory extends ConnectionFactoryBa
 
         headers[HeaderNames.ConnectionId] = connectionId;
         headers[RestConfigBase.configParams.token] = convInfo.token;
-        if (authInfo.token) {
+        if (!!authInfo.token) {
             headers[authInfo.headerName] = authInfo.token;
         }
 

src/common.speech/Transcription/ConversationTranslatorRecognizer.ts

@@ -12,7 +12,7 @@ import {
 import {
     BackgroundEvent,
     Events,
-    Timeout
+    Timeout,
 } from "../../common/Exports";
 import { AudioConfigImpl } from "../../sdk/Audio/AudioConfig";
 import { Contracts } from "../../sdk/Contracts";
@@ -207,6 +207,13 @@ export class ConversationTranslatorRecognizer extends Recognizer implements Conv
         }
     }
 
+    /**
+     * Handle update of service auth token (#694)
+     */
+    public onToken(token: IAuthentication): void {
+        this.privConversation.onToken(token);
+    }
+
     /**
      * Close and dispose the recognizer
      */

src/sdk/Transcription/Conversation.ts

@@ -12,6 +12,7 @@ import {
     ConversationRecognizerFactory,
     ConversationTranslatorCommandTypes,
     ConversationTranslatorMessageTypes,
+    IAuthentication,
     IInternalConversation,
     IInternalParticipant,
     InternalParticipants,
@@ -323,6 +324,9 @@ export class ConversationImpl extends Conversation implements IDisposable {
         this.privConversationTranslator = conversationTranslator;
     }
 
+    public onToken(token: IAuthentication): void {
+        this.privConversationTranslator.onToken(token);
+    }
 
     /**
      * Create a new conversation as Host

src/sdk/Transcription/ConversationTranslator.ts

@@ -6,6 +6,7 @@
 
 import {
     ConversationConnectionConfig,
+    IAuthentication,
     ServicePropertiesPropertyName,
 } from "../../common.speech/Exports";
 import { ConversationTranslatorConnectionFactory } from "../../common.speech/Transcription/ConversationTranslatorConnectionFactory";
@@ -108,6 +109,11 @@ class ConversationTranslationRecognizer extends TranslationRecognizer {
         this.privSpeechState = newState;
     }
 
+    public set authentication(token: IAuthentication) {
+        this.privReco.authentication = token;
+    }
+
+
     public onConnection(): void {
         this.privSpeechState = SpeechState.Connected;
     }
@@ -219,6 +225,10 @@ export class ConversationTranslator extends ConversationCommon implements IConve
         return true;
     }
 
+    public onToken(token: IAuthentication): void {
+        this.privCTRecognizer.authentication = token;
+    }
+
     public setServiceProperty(name: string, value: string): void {
         const currentProperties: IStringDictionary<string> = JSON.parse(this.privProperties.getProperty(ServicePropertiesPropertyName, "{}")) as IStringDictionary<string>;