Some work in progress on running the web-platform-tests suite for WebAudio

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "wpt"]
+	path = wpt
+	url = git@github.com:orottier/wpt.git

Cargo.toml

@@ -10,9 +10,9 @@ version = "0.14.0"
 crate-type = ["cdylib"]
 
 [dependencies]
-napi = {version="2.13", features=["napi6"]}
+napi = {version="2.13", features=["napi6", "tokio_rt"]}
 napi-derive = "2.13"
-web-audio-api = "0.38"
+web-audio-api = "0.39"
 # web-audio-api = { path = "../web-audio-api-rs" }
 
 [target.'cfg(all(any(windows, unix), target_arch = "x86_64", not(target_env = "musl")))'.dependencies]

README.md

@@ -129,6 +129,26 @@ The npm `postversion` script rely on [`cargo-bump`](https://crates.io/crates/car
 cargo install cargo-bump
 ```
 
+## Running the web-platform-test suite
+
+Follow the steps for 'Manual Build' first. Then checkout the web-platform-tests submodule with:
+
+```
+git submodule init
+git submodule update
+```
+
+Then run:
+
+```
+npm run wpt                      # build in debug mode and run all wpt test
+npm run wpt:only                 # run all wpt test without build
+npm run wpt -- --list            # list all wpt test files
+npm run wpt -- --filter <string> # apply <string> filter on executed/listed wpt tests 
+```
+
+Avai
+
 ## License
 
 [BSD-3-Clause](./LICENSE)

bin/wpt-harness.mjs

@@ -0,0 +1,105 @@
+import path from 'path';
+import wptRunner from 'wpt-runner';
+import chalk from 'chalk';
+import { program } from 'commander';
+
+import * as nodeWebAudioAPI from '../index.mjs';
+
+program
+  .option('--list', 'List the name of the test files')
+  .option('--with_crashtests', 'Also run crashtests')
+  .option('--filter <string>', 'Filter executed OR listed test files', '.*');
+
+program.parse(process.argv);
+
+const options = program.opts();
+
+// -------------------------------------------------------
+// Some helpers
+// -------------------------------------------------------
+const INDENT_SIZE = 2;
+
+function indent(string, times) {
+  const prefix = " ".repeat(times);
+  return string.split("\n").map(l => prefix + l).join("\n");
+}
+
+// -------------------------------------------------------
+// WPT Runner configuration options
+// -------------------------------------------------------
+const testsPath = 'wpt/webaudio';
+const rootURL = 'webaudio';
+
+// monkey patch `window` with our web audio API
+const setup = window => {
+  Object.assign(window, nodeWebAudioAPI);
+
+  // seems required (weirdly...), cf. `the-audiobuffer-interface/audiobuffer.html`
+  window.Float32Array = Float32Array;
+}
+
+const filterRe = new RegExp(`${options.filter}`);
+
+const filter = (name) => {
+  if (!options.with_crashtests && name.includes('/crashtests/')) {
+      return false;
+  }
+  if (name.includes('/resources/')) {
+      return false;
+  }
+  if (filterRe.test(name)) {
+    if (options.list) {
+      console.log(name);
+      return false;
+    } else {
+      return true;
+    }
+  } else {
+    return false;
+  }
+};
+
+// reporter, adapted from default console reporter
+// https://github.com/domenic/wpt-runner/blob/master/lib/console-reporter.js
+let numPass = 0;
+let numFail = 0;
+let typeErrorFail = 0;
+
+const reporter = {
+  startSuite: name => {
+    console.log(`\n  ${chalk.bold.underline(path.join(testsPath, name))}\n`);
+  },
+  pass: message => {
+    numPass += 1;
+    console.log(chalk.dim(indent(chalk.green("√ ") + message, INDENT_SIZE)));
+  },
+  fail: message => {
+    if (/threw "Error" instead of/.test(message)) {
+      typeErrorFail += 1;
+      console.log(chalk.bold.yellow(indent(`| ${message}`, INDENT_SIZE)));
+    } else {
+      numFail += 1;
+      console.log(chalk.bold.red(indent(`\u00D7 ${message}`, INDENT_SIZE)));
+    }
+  },
+  reportStack: stack => {
+    // console.log(chalk.dim(indent(stack, INDENT_SIZE * 2)))
+  },
+};
+
+// -------------------------------------------------------
+// Run test suite
+// -------------------------------------------------------
+try {
+  const failures = await wptRunner(testsPath, { rootURL, setup, filter, reporter });
+
+  console.log(`\n  ${chalk.bold.underline('RESULTS:')}`);
+  console.log(chalk.bold(`  - # pass: ${numPass}`));
+  console.log(chalk.bold(`  - # fail: ${numFail}`));
+  console.log(chalk.bold(`  - # type error issues: ${typeErrorFail}`));
+
+  process.exit(failures);
+} catch (e) {
+  console.error(e.stack);
+  process.exit(1);
+}

examples/offline.mjs

@@ -1,23 +1,55 @@
 import { AudioContext, OfflineAudioContext } from '../index.mjs';
 
-const offline = new OfflineAudioContext(1, 44100, 44100);
+const offline = new OfflineAudioContext(1, 48000, 48000);
 
-const osc = offline.createOscillator();
-osc.connect(offline.destination);
-osc.frequency.value = 220;
-osc.start(0);
-osc.stop(1);
+offline.suspend(128 / 48000).then(() => {
+  console.log("suspend");
+
+  const osc = offline.createOscillator();
+  osc.connect(offline.destination);
+  osc.frequency.value = 220;
+  osc.start(0);
+
+  console.log("resume");
+  offline.resume();
+});
 
 const buffer = await offline.startRendering();
+console.log("buffer duration:", buffer.duration);
+
+// dirty check the audio buffer
+const channelData = buffer.getChannelData(0);
+
+for (let i = 0; i < 48000; i++) {
+  // before suspend the graph is empty
+  if (i < 128) {
+    if (channelData[i] !== 0) {
+      throw new Error('should be zero')
+    }
+  // first sine sample is zero
+  } else if (i === 128) {
+    if (channelData[i] !== 0) {
+      throw new Error('should be zero')
+    }
+  } else {
+    // should ha ve a sine wave, hopefully without zero values :)
+    if (channelData[i] === 0) {
+      throw new Error(`should not be zero ${i}`);
+      console.log(channelData[i])
+    }
+  }
+}
 
 const latencyHint = process.env.WEB_AUDIO_LATENCY === 'playback' ? 'playback' : 'interactive';
 const online = new AudioContext({ latencyHint });
 
 const src = online.createBufferSource();
+// src.loop = true;
 src.buffer = buffer;
+src.loop = true;
 src.connect(online.destination);
 src.start();
 
-await new Promise(resolve => setTimeout(resolve, 1000));
+await new Promise(resolve => setTimeout(resolve, 2000));
 
 await online.close();