test: add test for llhttp wasm (#3068)

test/client-wasm.js

@@ -0,0 +1,359 @@
+'use strict'
+
+const { tspl } = require('@matteo.collina/tspl')
+const { describe, test } = require('node:test')
+
+  ;[
+  ['generic', require('../lib/llhttp/llhttp-wasm.js')],
+  ['simd', require('../lib/llhttp/llhttp_simd-wasm.js')]
+].forEach(([name, llhttp]) => {
+  describe(name, () => {
+    test('can compile the wasm code', async () => {
+      await WebAssembly.compile(llhttp)
+    })
+
+    test('can instantiate the wasm code', async () => {
+      const mod = await WebAssembly.compile(llhttp)
+      await WebAssembly.instantiate(mod, {
+        env: {
+          wasm_on_url: () => { },
+          wasm_on_status: () => { },
+          wasm_on_message_begin: () => { },
+          wasm_on_header_field: () => { },
+          wasm_on_header_value: () => { },
+          wasm_on_headers_complete: () => { },
+          wasm_on_body: () => { },
+          wasm_on_message_complete: () => { }
+        }
+      })
+    })
+
+    describe('exports', async () => {
+      const mod = await WebAssembly.compile(llhttp)
+      const instance = await WebAssembly.instantiate(mod, {
+        env: {
+          wasm_on_url: () => { },
+          wasm_on_status: () => { },
+          wasm_on_message_begin: () => { },
+          wasm_on_header_field: () => { },
+          wasm_on_header_value: () => { },
+          wasm_on_headers_complete: () => { },
+          wasm_on_body: () => { },
+          wasm_on_message_complete: () => { }
+        }
+      })
+
+      test('has the right amount of exports', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(instance.exports, 'exports are present')
+        t.deepStrictEqual(Object.keys(instance.exports), [
+          'memory',
+          '_initialize',
+          '__indirect_function_table',
+          'llhttp_init',
+          'llhttp_should_keep_alive',
+          'llhttp_alloc',
+          'malloc',
+          'llhttp_free',
+          'free',
+          'llhttp_get_type',
+          'llhttp_get_http_major',
+          'llhttp_get_http_minor',
+          'llhttp_get_method',
+          'llhttp_get_status_code',
+          'llhttp_get_upgrade',
+          'llhttp_reset',
+          'llhttp_execute',
+          'llhttp_settings_init',
+          'llhttp_finish',
+          'llhttp_pause',
+          'llhttp_resume',
+          'llhttp_resume_after_upgrade',
+          'llhttp_get_errno',
+          'llhttp_get_error_reason',
+          'llhttp_set_error_reason',
+          'llhttp_get_error_pos',
+          'llhttp_errno_name',
+          'llhttp_method_name',
+          'llhttp_status_name',
+          'llhttp_set_lenient_headers',
+          'llhttp_set_lenient_chunked_length',
+          'llhttp_set_lenient_keep_alive',
+          'llhttp_set_lenient_transfer_encoding',
+          'llhttp_message_needs_eof'
+        ])
+        await t.completed
+      })
+
+      test('instance.exports.memory', async (t) => {
+        t = tspl(t, { plan: 1 })
+
+        t.ok(instance.exports.memory instanceof WebAssembly.Memory, 'memory is present')
+      })
+
+      // _initialize
+      test('instance.exports._initialize', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports._initialize === 'function', '_initialize is present')
+        t.strictEqual(instance.exports._initialize.length, 0, '_initialize has the right number of arguments')
+      })
+
+      // __indirect_function_table
+      test('instance.exports.__indirect_function_table', async (t) => {
+        t = tspl(t, { plan: 1 })
+
+        t.ok(instance.exports.__indirect_function_table instanceof WebAssembly.Table, '__indirect_function_table is present')
+      })
+
+      // malloc
+      test('instance.exports.malloc', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.malloc === 'function', 'malloc is present')
+        t.strictEqual(instance.exports.malloc.length, 1, 'malloc has the right number of arguments')
+      })
+
+      // free
+      test('instance.exports.free', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.free === 'function', 'free is present')
+        t.strictEqual(instance.exports.free.length, 1, 'free has the right number of arguments')
+      })
+
+      // llhttp_init
+      test('instance.exports.llhttp_init', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_init === 'function', 'llhttp_init is present')
+        t.strictEqual(instance.exports.llhttp_init.length, 3, 'llhttp_init has the right number of arguments')
+      })
+
+      // llhttp_alloc
+      test('instance.exports.llhttp_alloc', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_alloc === 'function', 'llhttp_alloc is present')
+        t.strictEqual(instance.exports.llhttp_alloc.length, 1, 'llhttp_alloc has the right number of arguments')
+      })
+
+      // llhttp_free
+      test('instance.exports.llhttp_free', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_free === 'function', 'llhttp_free is present')
+        t.strictEqual(instance.exports.llhttp_free.length, 1, 'llhttp_free has the right number of arguments')
+      })
+
+      // llhttp_get_type
+      test('instance.exports.llhttp_get_type', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_type === 'function', 'llhttp_get_type is present')
+        t.strictEqual(instance.exports.llhttp_get_type.length, 1, 'llhttp_get_type has the right number of arguments')
+      })
+
+      // llhttp_should_keep_alive
+      test('instance.exports.llhttp_should_keep_alive', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_should_keep_alive === 'function', 'llhttp_should_keep_alive is present')
+        t.strictEqual(instance.exports.llhttp_should_keep_alive.length, 1, 'llhttp_should_keep_alive has the right number of arguments')
+      })
+
+      // llhttp_get_http_major
+      test('instance.exports.llhttp_get_http_major', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_http_major === 'function', 'llhttp_get_http_major is present')
+        t.strictEqual(instance.exports.llhttp_get_http_major.length, 1, 'llhttp_get_http_major has the right number of arguments')
+      })
+
+      // llhttp_get_http_minor
+      test('instance.exports.llhttp_get_http_minor', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_http_minor === 'function', 'llhttp_get_http_minor is present')
+        t.strictEqual(instance.exports.llhttp_get_http_minor.length, 1, 'llhttp_get_http_minor has the right number of arguments')
+      })
+
+      // llhttp_get_method
+      test('instance.exports.llhttp_get_method', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_method === 'function', 'llhttp_get_method is present')
+        t.strictEqual(instance.exports.llhttp_get_method.length, 1, 'llhttp_get_method has the right number of arguments')
+      })
+
+      // llhttp_get_status_code
+      test('instance.exports.llhttp_get_status_code', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_status_code === 'function', 'llhttp_get_status_code is present')
+        t.strictEqual(instance.exports.llhttp_get_status_code.length, 1, 'llhttp_get_status_code has the right number of arguments')
+      })
+
+      // llhttp_get_upgrade
+      test('instance.exports.llhttp_get_upgrade', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_upgrade === 'function', 'llhttp_get_upgrade is present')
+        t.strictEqual(instance.exports.llhttp_get_upgrade.length, 1, 'llhttp_get_upgrade has the right number of arguments')
+      })
+
+      // llhttp_reset
+      test('instance.exports.llhttp_reset', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_reset === 'function', 'llhttp_reset is present')
+        t.strictEqual(instance.exports.llhttp_reset.length, 1, 'llhttp_reset has the right number of arguments')
+      })
+
+      // llhttp_execute
+      test('instance.exports.llhttp_execute', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_execute === 'function', 'llhttp_execute is present')
+        t.strictEqual(instance.exports.llhttp_execute.length, 3, 'llhttp_execute has the right number of arguments')
+      })
+
+      // llhttp_settings_init
+      test('instance.exports.llhttp_settings_init', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_settings_init === 'function', 'llhttp_settings_init is present')
+        t.strictEqual(instance.exports.llhttp_settings_init.length, 1, 'llhttp_settings_init has the right number of arguments')
+      })
+
+      // llhttp_finish
+      test('instance.exports.llhttp_finish', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_finish === 'function', 'llhttp_finish is present')
+        t.strictEqual(instance.exports.llhttp_finish.length, 1, 'llhttp_finish has the right number of arguments')
+      })
+
+      // llhttp_pause
+      test('instance.exports.llhttp_pause', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_pause === 'function', 'llhttp_pause is present')
+        t.strictEqual(instance.exports.llhttp_pause.length, 1, 'llhttp_pause has the right number of arguments')
+      })
+
+      // llhttp_resume
+      test('instance.exports.llhttp_resume', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_resume === 'function', 'llhttp_resume is present')
+        t.strictEqual(instance.exports.llhttp_resume.length, 1, 'llhttp_resume has the right number of arguments')
+      })
+
+      // llhttp_resume_after_upgrade
+      test('instance.exports.llhttp_resume_after_upgrade', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_resume_after_upgrade === 'function', 'llhttp_resume_after_upgrade is present')
+        t.strictEqual(instance.exports.llhttp_resume_after_upgrade.length, 1, 'llhttp_resume_after_upgrade has the right number of arguments')
+      })
+
+      // llhttp_get_errno
+      test('instance.exports.llhttp_get_errno', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_errno === 'function', 'llhttp_get_errno is present')
+        t.strictEqual(instance.exports.llhttp_get_errno.length, 1, 'llhttp_get_errno has the right number of arguments')
+      })
+
+      // llhttp_get_error_reason
+      test('instance.exports.llhttp_get_error_reason', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_error_reason === 'function', 'llhttp_get_error_reason is present')
+        t.strictEqual(instance.exports.llhttp_get_error_reason.length, 1, 'llhttp_get_error_reason has the right number of arguments')
+      })
+
+      // llhttp_set_error_reason
+      test('instance.exports.llhttp_set_error_reason', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_set_error_reason === 'function', 'llhttp_set_error_reason is present')
+        t.strictEqual(instance.exports.llhttp_set_error_reason.length, 2, 'llhttp_set_error_reason has the right number of arguments')
+      })
+
+      // llhttp_get_error_pos
+      test('instance.exports.llhttp_get_error_pos', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_get_error_pos === 'function', 'llhttp_get_error_pos is present')
+        t.strictEqual(instance.exports.llhttp_get_error_pos.length, 1, 'llhttp_get_error_pos has the right number of arguments')
+      })
+
+      // llhttp_errno_name
+      test('instance.exports.llhttp_errno_name', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_errno_name === 'function', 'llhttp_errno_name is present')
+        t.strictEqual(instance.exports.llhttp_errno_name.length, 1, 'llhttp_errno_name has the right number of arguments')
+      })
+
+      // llhttp_method_name
+      test('instance.exports.llhttp_method_name', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_method_name === 'function', 'llhttp_method_name is present')
+        t.strictEqual(instance.exports.llhttp_method_name.length, 1, 'llhttp_method_name has the right number of arguments')
+      })
+
+      // llhttp_status_name
+      test('instance.exports.llhttp_status_name', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_status_name === 'function', 'llhttp_status_name is present')
+        t.strictEqual(instance.exports.llhttp_status_name.length, 1, 'llhttp_status_name has the right number of arguments')
+      })
+
+      // llhttp_set_lenient_headers
+      test('instance.exports.llhttp_set_lenient_headers', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_set_lenient_headers === 'function', 'llhttp_set_lenient_headers is present')
+        t.strictEqual(instance.exports.llhttp_set_lenient_headers.length, 2, 'llhttp_set_lenient_headers has the right number of arguments')
+      })
+
+      // llhttp_set_lenient_chunked_length
+      test('instance.exports.llhttp_set_lenient_chunked_length', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_set_lenient_chunked_length === 'function', 'llhttp_set_lenient_chunked_length is present')
+        t.strictEqual(instance.exports.llhttp_set_lenient_chunked_length.length, 2, 'llhttp_set_lenient_chunked_length has the right number of arguments')
+      })
+
+      // llhttp_set_lenient_keep_alive
+      test('instance.exports.llhttp_set_lenient_keep_alive', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_set_lenient_keep_alive === 'function', 'llhttp_set_lenient_keep_alive is present')
+        t.strictEqual(instance.exports.llhttp_set_lenient_keep_alive.length, 2, 'llhttp_set_lenient_keep_alive has the right number of arguments')
+      })
+
+      // llhttp_set_lenient_transfer_encoding
+      test('instance.exports.llhttp_set_lenient_transfer_encoding', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_set_lenient_transfer_encoding === 'function', 'llhttp_set_lenient_transfer_encoding is present')
+        t.strictEqual(instance.exports.llhttp_set_lenient_transfer_encoding.length, 2, 'llhttp_set_lenient_transfer_encoding has the right number of arguments')
+      })
+
+      // llhttp_message_needs_eof
+      test('instance.exports.llhttp_message_needs_eof', async (t) => {
+        t = tspl(t, { plan: 2 })
+
+        t.ok(typeof instance.exports.llhttp_message_needs_eof === 'function', 'llhttp_message_needs_eof is present')
+        t.strictEqual(instance.exports.llhttp_message_needs_eof.length, 1, 'llhttp_message_needs_eof has the right number of arguments')
+      })
+    })
+  })
+})