feat: implement AudioWorkletNode's onprocessorerror

src/audio-nodes/audio-worklet-node.ts

@@ -27,6 +27,7 @@ import {
     TAudioParamMap,
     TChannelCountMode,
     TChannelInterpretation,
+    TProcessorErrorEventHandler,
     TUnpatchedAudioContext,
     TUnpatchedOfflineAudioContext
 } from '../types';
@@ -123,13 +124,12 @@ export class AudioWorkletNode extends NoneAudioDestinationNode<INativeAudioWorkl
         }
     }
 
-    get onprocessorstatechange () {
-        // @todo No browser does implement the processorState property yet.
-        return null;
+    public get onprocessorerror () {
+        return <TProcessorErrorEventHandler> (<any> this._nativeNode.onprocessorerror);
     }
 
-    set onprocessorstatechange (value) {
-        this._nativeNode.onprocessorstatechange = <any> value;
+    public set onprocessorerror (value) {
+        this._nativeNode.onprocessorerror = <any> value;
     }
 
     get parameters (): TAudioParamMap {
@@ -144,13 +144,4 @@ export class AudioWorkletNode extends NoneAudioDestinationNode<INativeAudioWorkl
         return this._nativeNode.port;
     }
 
-    get processorState () {
-        // @todo Chrome Canary does not implement the processorState property.
-        if (this._nativeNode.processorState === undefined) {
-            return 'pending';
-        }
-
-        return this._nativeNode.processorState;
-    }
-
 }

src/fakers/audio-worklet-node.ts

@@ -3,10 +3,11 @@ import { createNativeConstantSourceNode } from '../helpers/create-native-constan
 import {
     IAudioWorkletNodeOptions,
     IAudioWorkletProcessorConstructor,
+    INativeAudioWorkletNode,
     INativeAudioWorkletNodeFaker
 } from '../interfaces';
 import { ReadOnlyMap } from '../read-only-map';
-import { TNativeAudioParam, TUnpatchedAudioContext, TUnpatchedOfflineAudioContext } from '../types';
+import { TNativeAudioParam, TProcessorErrorEventHandler, TUnpatchedAudioContext, TUnpatchedOfflineAudioContext } from '../types';
 import { ChannelMergerNodeWrapper } from '../wrappers/channel-merger-node';
 import { ChannelSplitterNodeWrapper } from '../wrappers/channel-splitter-node';
 
@@ -108,6 +109,9 @@ export class AudioWorkletNodeFaker {
             outputChannelSplitterNode.connect(outputChannelMergerNode, i, i);
         }
 
+        let isActive = true;
+        let onprocessorerror: null | TProcessorErrorEventHandler = null;
+
         scriptProcessorNode.onaudioprocess = ({ inputBuffer, outputBuffer }: AudioProcessingEvent) => {
             for (let i = 0; i < bufferSize; i += 128) {
                 // @todo Handle multiple inputs ...
@@ -128,15 +132,31 @@ export class AudioWorkletNodeFaker {
                     parameters[ name ].set(slicedInputBuffer);
                 });
 
-                /* @todo const result = */audioWorkletProcessor.process(inputs, outputs, parameters);
+                try {
+                    const activeSourceFlag = audioWorkletProcessor.process(inputs, outputs, parameters);
 
-                // @todo Handle multiple outputs ...
-                for (let j = 0; j < numberOfChannels; j += 1) {
-                    // Bug #5: Safari does not support copyToChannel().
+                    isActive = activeSourceFlag;
 
-                    outputBuffer
-                        .getChannelData(j)
-                        .set(outputs[0][j], i);
+                    // @todo Handle multiple outputs ...
+                    for (let j = 0; j < numberOfChannels; j += 1) {
+                        // Bug #5: Safari does not support copyToChannel().
+
+                        outputBuffer
+                            .getChannelData(j)
+                            .set(outputs[0][j], i);
+                    }
+                } catch (err) {
+                    isActive = false;
+
+                    if (onprocessorerror !== null) {
+                        onprocessorerror.call(<any> null, new ErrorEvent('processorerror'));
+                    }
+                }
+
+                if (!isActive) {
+                    scriptProcessorNode.onaudioprocess = <any> null;
+
+                    break;
                 }
             }
         };
@@ -166,19 +186,22 @@ export class AudioWorkletNodeFaker {
             get numberOfOutputs () {
                 return gainNode.numberOfOutputs;
             },
-            get onprocessorstatechange () {
-                return null;
+            get onprocessorerror () {
+                return <INativeAudioWorkletNode['onprocessorerror']> onprocessorerror;
+            },
+            set onprocessorerror (value) {
+                if (value === null || typeof value === 'function') {
+                    onprocessorerror = <any> value;
+                } else {
+                    onprocessorerror = null;
+                }
             },
             get parameters () {
                 return parameterMap;
             },
             get port () {
                 return messageChannel.port2;
             },
-            get processorState () {
-                // @todo Implement processorState.
-                return <any> 'pending';
-            },
             addEventListener (...args: any[]) {
                 return gainNode.addEventListener(args[0], args[1], args[2]);
             },

src/interfaces/audio-worklet-node.ts

@@ -1,14 +1,12 @@
-import { TAudioParamMap, TAudioWorkletProcessorState, TProcessorStateChangeEventHandler } from '../types';
+import { TAudioParamMap, TProcessorErrorEventHandler } from '../types';
 import { IAudioNode } from './audio-node';
 
 export interface IAudioWorkletNode extends IAudioNode {
 
-    onprocessorstatechange: null | TProcessorStateChangeEventHandler;
+    onprocessorerror: null | TProcessorErrorEventHandler;
 
     readonly parameters: TAudioParamMap;
 
     readonly port: MessagePort;
 
-    readonly processorState: TAudioWorkletProcessorState;
-
 }

src/interfaces/native-audio-worklet-node.ts

@@ -1,14 +1,12 @@
-import { TNativeAudioNode, TNativeAudioParamMap, TNativeAudioWorkletProcessorState } from '../types';
+import { TNativeAudioNode, TNativeAudioParamMap } from '../types';
 
 // @todo Since there are no native types yet they need to be crafted.
 export interface INativeAudioWorkletNode extends TNativeAudioNode {
 
-    onprocessorstatechange: null | ((this: INativeAudioWorkletNode, event: Event) => any);
+    onprocessorerror: null | ((this: INativeAudioWorkletNode, event: Event) => any);
 
     readonly parameters: TNativeAudioParamMap;
 
     readonly port: MessagePort;
 
-    readonly processorState: TNativeAudioWorkletProcessorState;
-
 }

src/renderers/audio-worklet-node.ts

@@ -202,7 +202,19 @@ export class AudioWorkletNodeRenderer extends AudioNodeRenderer {
 
             // @todo slice the parameters ...
 
-            /* @todo const result = */audioWorkletProcessor.process(inputs, outputs, parameters);
+            try {
+                const activeSourceFlag = audioWorkletProcessor.process(inputs, outputs, parameters);
+
+                if (!activeSourceFlag) {
+                    break;
+                }
+            } catch (err) {
+                if (this._proxy.onprocessorerror !== null) {
+                    this._proxy.onprocessorerror.call(<any> null, new ErrorEvent('processorerror'));
+                }
+
+                break;
+            }
 
             // @todo Handle multiple outputs ...
             for (let j = 0; j < numberOfChannels; j += 1) {

src/types/index.ts

@@ -1,7 +1,6 @@
 export * from './audio-context-latency-category';
 export * from './audio-context-state';
 export * from './audio-param-map';
-export * from './audio-worklet-processor-state';
 export * from './automation';
 export * from './biquad-filter-type';
 export * from './channel-count-mode';
@@ -18,7 +17,6 @@ export * from './native-audio-param';
 export * from './native-audio-param-map';
 export * from './native-audio-worklet';
 export * from './native-audio-worklet-node-options';
-export * from './native-audio-worklet-processor-state';
 export * from './native-biquad-filter-node';
 export * from './native-channel-merger-node';
 export * from './native-channel-splitter-node';
@@ -28,7 +26,7 @@ export * from './native-media-element-audio-source-node';
 export * from './native-media-stream-audio-source-node';
 export * from './native-oscillator-node';
 export * from './oscillator-type';
-export * from './processor-state-change-event-handler';
+export * from './processor-error-event-handler';
 export * from './state-change-event-handler';
 export * from './typed-array';
 export * from './unpatched-audio-context';

src/types/processor-error-event-handler.ts

@@ -0,0 +1,3 @@
+import { IAudioWorkletNode } from '../interfaces';
+
+export type TProcessorErrorEventHandler = (this: IAudioWorkletNode, event: Event) => any;

test/fixtures/failing-processor.js

@@ -0,0 +1,17 @@
+class FailingProcessor extends AudioWorkletProcessor { // eslint-disable-line no-undef
+
+    constructor () {
+        super();
+    }
+
+    process () { // eslint-disable-line class-methods-use-this
+        throw new Error('This is an error thrown inside the process() method.');
+
+        return true;
+    }
+
+}
+
+FailingProcessor.parameterDescriptors = [ ];
+
+registerProcessor('failing-processor', FailingProcessor); // eslint-disable-line no-undef