start afresh on new audio in worklet

Author: francamps

packages/react/src/lib/useSoundPlayer.ts

@@ -87,40 +87,28 @@ export const useSoundPlayer = (props: {
     }
   }, []);
 
-  const addToQueue = useCallback(
-    async (message: AudioOutputMessage) => {
-      if (!isInitialized.current || !audioContext.current) {
-        onError.current('Audio player has not been initialized');
-        return;
-      }
+  const addToQueue = useCallback(async (message: AudioOutputMessage) => {
+    if (!isInitialized.current || !audioContext.current) {
+      onError.current('Audio player has not been initialized');
+      return;
+    }
 
-      try {
-        const blob = convertBase64ToBlob(message.data);
-        const arrayBuffer = await blob.arrayBuffer();
-        const audioBuffer =
-          await audioContext.current.decodeAudioData(arrayBuffer);
-
-        const pcmData = audioBuffer.getChannelData(0);
-        workletNode.current?.port.postMessage({ type: 'audio', data: pcmData });
-
-        if (gainNode.current) {
-          const now = audioContext.current.currentTime;
-          gainNode.current.gain.cancelScheduledValues(now);
-          gainNode.current.gain.setValueAtTime(
-            isAudioMuted ? 0 : volume,
-            audioContext.current.currentTime,
-          );
-        }
+    try {
+      const blob = convertBase64ToBlob(message.data);
+      const arrayBuffer = await blob.arrayBuffer();
+      const audioBuffer =
+        await audioContext.current.decodeAudioData(arrayBuffer);
 
-        setIsPlaying(true);
-        onPlayAudio.current(message.id);
-      } catch (e) {
-        const eMessage = e instanceof Error ? e.message : 'Unknown error';
-        onError.current(`Failed to add clip to queue: ${eMessage}`);
-      }
-    },
-    [isAudioMuted, volume],
-  );
+      const pcmData = audioBuffer.getChannelData(0);
+      workletNode.current?.port.postMessage({ type: 'audio', data: pcmData });
+
+      setIsPlaying(true);
+      onPlayAudio.current(message.id);
+    } catch (e) {
+      const eMessage = e instanceof Error ? e.message : 'Unknown error';
+      onError.current(`Failed to add clip to queue: ${eMessage}`);
+    }
+  }, []);
 
   const stopAll = useCallback(() => {
     isInitialized.current = false;

packages/react/src/worklets/audio-worklet.js

@@ -81,6 +81,10 @@ class AudioStreamProcessor extends AudioWorkletProcessor {
       switch (e.data?.type) {
         case 'audio':
           this._bq.push(new Float32Array(e.data.data));
+          if (this._fadeOutActive) {
+            this._fadeOutActive = false;
+            this._fadeOutCounter = 0;
+          }
           break;
         case 'end':
           this._shouldStop = true;