| // META: global=window,worker,shadowrealm |
| |
| 'use strict'; |
| |
| const badChunks = [ |
| { |
| name: 'undefined', |
| value: undefined |
| }, |
| { |
| name: 'null', |
| value: null |
| }, |
| { |
| name: 'numeric', |
| value: 3.14 |
| }, |
| { |
| name: 'object, not BufferSource', |
| value: {} |
| }, |
| { |
| name: 'array', |
| value: [65] |
| }, |
| { |
| name: 'SharedArrayBuffer', |
| // Use a getter to postpone construction so that all tests don't fail where |
| // SharedArrayBuffer is not yet implemented. |
| get value() { |
| // See https://github.com/whatwg/html/issues/5380 for why not `new SharedArrayBuffer()` |
| return new WebAssembly.Memory({ shared:true, initial:1, maximum:1 }).buffer; |
| } |
| }, |
| { |
| name: 'shared Uint8Array', |
| get value() { |
| // See https://github.com/whatwg/html/issues/5380 for why not `new SharedArrayBuffer()` |
| return new Uint8Array(new WebAssembly.Memory({ shared:true, initial:1, maximum:1 }).buffer) |
| } |
| }, |
| { |
| name: 'invalid deflate bytes', |
| value: new Uint8Array([0, 156, 75, 173, 40, 72, 77, 46, 73, 77, 81, 200, 47, 45, 41, 40, 45, 1, 0, 48, 173, 6, 36]) |
| }, |
| { |
| name: 'invalid gzip bytes', |
| value: new Uint8Array([0, 139, 8, 0, 0, 0, 0, 0, 0, 3, 75, 173, 40, 72, 77, 46, 73, 77, 81, 200, 47, 45, 41, 40, 45, 1, 0, 176, 1, 57, 179, 15, 0, 0, 0]) |
| }, |
| ]; |
| |
| // Test Case Design |
| // We need to wait until after we close the writable stream to check if the decoded stream is valid. |
| // We can end up in a state where all reads/writes are valid, but upon closing the writable stream an error is detected. |
| // (Example: A zlib encoded chunk w/o the checksum). |
| |
| async function decompress(chunk, format, t) |
| { |
| const ds = new DecompressionStream(format); |
| const reader = ds.readable.getReader(); |
| const writer = ds.writable.getWriter(); |
| |
| writer.write(chunk.value).then(() => {}, () => {}); |
| reader.read().then(() => {}, () => {}); |
| |
| await promise_rejects_js(t, TypeError, writer.close(), 'writer.close() should reject'); |
| await promise_rejects_js(t, TypeError, writer.closed, 'write.closed should reject'); |
| |
| await promise_rejects_js(t, TypeError, reader.read(), 'reader.read() should reject'); |
| await promise_rejects_js(t, TypeError, reader.closed, 'read.closed should reject'); |
| } |
| |
| for (const chunk of badChunks) { |
| promise_test(async t => { |
| await decompress(chunk, 'gzip', t); |
| }, `chunk of type ${chunk.name} should error the stream for gzip`); |
| |
| promise_test(async t => { |
| await decompress(chunk, 'deflate', t); |
| }, `chunk of type ${chunk.name} should error the stream for deflate`); |
| |
| promise_test(async t => { |
| await decompress(chunk, 'deflate-raw', t); |
| }, `chunk of type ${chunk.name} should error the stream for deflate-raw`); |
| } |