Fix/fd 1600

lib/session/call-session.js

@@ -78,7 +78,7 @@ class CallSession extends Emitter {
     this.callGone = false;
     this.notifiedComplete = false;
     this.rootSpan = rootSpan;
-    this.stickyEventEmitter = new StickyEventEmitter();
+    this.stickyEventEmitter = new StickyEventEmitter(logger);
     this.stickyEventEmitter.onSuccess = () => {
       this.taskInProgress = null;
       this.stickyEventEmitter.destroy();

lib/tasks/play.js

@@ -67,6 +67,9 @@ class TaskPlay extends Task {
               this.logger.debug(`Play got kill-playback, executing uuid_break, taskId: ${t?.taskId}`);
               this.ep.api('uuid_break', this.ep.uuid).catch((err) => this.logger.info(err, 'Error killing audio'));
               this.notifyStatus({event: 'kill-playback'});
+            } else {
+              this.logger.debug(
+                `Play received uuid_break for different taskId: ${t?.taskId}, current taskId: ${this.taskId}`);
             }
           });
         });

lib/utils/sticky-event-emitter.js

@@ -13,10 +13,11 @@ const EventEmitter = require('events');
  * - Maintains compatibility with Node's EventEmitter interface
  */
 class StickyEventEmitter extends EventEmitter {
-  constructor() {
+  constructor(logger) {
     super();
     this._eventCache = new Map();
     this._onceListeners = new Map(); // For storing once listeners if needed
+    this.logger = logger;
   }
   destroy() {
     this._eventCache.clear();
@@ -28,12 +29,14 @@ class StickyEventEmitter extends EventEmitter {
     this._eventCache.set(event, args);
 
     // If there are any 'once' listeners waiting, call them
+    this.logger.debug(`StickyEventEmitter emitting event: ${event} with args: ${JSON.stringify(args)}`);
     if (this._onceListeners.has(event)) {
       const listeners = this._onceListeners.get(event);
       for (const listener of listeners) {
         listener(...args);
       }
       if (this.onSuccess) {
+        this.logger.debug(`StickyEventEmitter calling onSuccess for event: ${event}`);
         this.onSuccess();
       }
       this._onceListeners.delete(event);

lib/utils/tts-streaming-buffer.js

@@ -193,10 +193,7 @@ class TtsStreamingBuffer extends Emitter {
         this.logger.debug('TtsStreamingBuffer:_feedQueue TTS stream is not open or no endpoint available');
         return;
       }
-      if (
-        this._connectionStatus === TtsStreamingConnectionStatus.NotConnected ||
-        this._connectionStatus === TtsStreamingConnectionStatus.Failed
-      ) {
+      if (this._connectionStatus !== TtsStreamingConnectionStatus.Connected) {
         this.logger.debug('TtsStreamingBuffer:_feedQueue TTS stream is not connected');
         return;
       }