'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 required exports', async (t) => {
const requiredExports = [
'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_set_lenient_version',
'llhttp_set_lenient_data_after_close',
'llhttp_set_lenient_optional_lf_after_cr',
'llhttp_set_lenient_optional_crlf_after_chunk',
'llhttp_set_lenient_optional_cr_before_lf',
'llhttp_set_lenient_spaces_after_chunk_size',
'llhttp_message_needs_eof'
]
t = tspl(t, { plan: requiredExports.length })
for (const key of requiredExports) {
t.ok(key in instance.exports, `${key} is exported`)
}
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')
})
})
})
})