1 files changed, 54 insertions, 0 deletions
diff --git a/testing/web-platform/tests/webaudio/the-audio-api/the-audioworklet-interface/processors/active-processing.js b/testing/web-platform/tests/webaudio/the-audio-api/the-audioworklet-interface/processors/active-processing.js
new file mode 100644
index 0000000000..ef497733ca
--- /dev/null
+++ b/testing/web-platform/tests/webaudio/the-audio-api/the-audioworklet-interface/processors/active-processing.js
@@ -0,0 +1,54 @@
+/**
+ * @class ActiveProcessingTester
+ * @extends AudioWorkletProcessor
+ *
+ * This processor class sends a message to its AudioWorkletNodew whenever the
+ * number of channels on the input changes.  The message includes the actual
+ * number of channels, the context time at which this occurred, and whether
+ * we're done processing or not.
+ */
+class ActiveProcessingTester extends AudioWorkletProcessor {
+  constructor(options) {
+    super(options);
+    this._lastChannelCount = 0;
+
+    // See if user specified a value for test duration.
+    if (options.hasOwnProperty('processorOptions') &&
+        options.processorOptions.hasOwnProperty('testDuration')) {
+      this._testDuration = options.processorOptions.testDuration;
+    } else {
+      this._testDuration = 5;
+    }
+
+    // Time at which we'll signal we're done, based on the requested
+    // |testDuration|
+    this._endTime = currentTime + this._testDuration;
+  }
+
+  process(inputs, outputs) {
+    const input = inputs[0];
+    const output = outputs[0];
+    const inputChannelCount = input.length;
+    const isFinished = currentTime > this._endTime;
+
+    // Send a message if we're done or the count changed.
+    if (isFinished || (inputChannelCount != this._lastChannelCount)) {
+      this.port.postMessage({
+        channelCount: inputChannelCount,
+        finished: isFinished,
+        time: currentTime
+      });
+      this._lastChannelCount = inputChannelCount;
+    }
+
+    // Just copy the input to the output for no particular reason.
+    for (let channel = 0; channel < input.length; ++channel) {
+      output[channel].set(input[channel]);
+    }
+
+    // When we're finished, this method no longer needs to be called.
+    return !isFinished;
+  }
+}
+
+registerProcessor('active-processing-tester', ActiveProcessingTester);