diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
commit | 36d22d82aa202bb199967e9512281e9a53db42c9 (patch) | |
tree | 105e8c98ddea1c1e4784a60a5a6410fa416be2de /remote/cdp/test/browser/io | |
parent | Initial commit. (diff) | |
download | firefox-esr-upstream.tar.xz firefox-esr-upstream.zip |
Adding upstream version 115.7.0esr.upstream/115.7.0esrupstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'remote/cdp/test/browser/io')
-rw-r--r-- | remote/cdp/test/browser/io/browser.ini | 16 | ||||
-rw-r--r-- | remote/cdp/test/browser/io/browser_close.js | 46 | ||||
-rw-r--r-- | remote/cdp/test/browser/io/browser_read.js | 166 | ||||
-rw-r--r-- | remote/cdp/test/browser/io/head.js | 20 |
4 files changed, 248 insertions, 0 deletions
diff --git a/remote/cdp/test/browser/io/browser.ini b/remote/cdp/test/browser/io/browser.ini new file mode 100644 index 0000000000..05046602b9 --- /dev/null +++ b/remote/cdp/test/browser/io/browser.ini @@ -0,0 +1,16 @@ +[DEFAULT] +tags = cdp +subsuite = remote +args = + --remote-debugging-port + --remote-allow-origins=null +prefs = # Bug 1600054: Make CDP Fission compatible + fission.bfcacheInParent=false + fission.webContentIsolationStrategy=0 +support-files = + !/remote/cdp/test/browser/chrome-remote-interface.js + !/remote/cdp/test/browser/head.js + head.js + +[browser_close.js] +[browser_read.js] diff --git a/remote/cdp/test/browser/io/browser_close.js b/remote/cdp/test/browser/io/browser_close.js new file mode 100644 index 0000000000..7436e2c45c --- /dev/null +++ b/remote/cdp/test/browser/io/browser_close.js @@ -0,0 +1,46 @@ +/* Any copyright is dedicated to the Public Domain. + * http://creativecommons.org/publicdomain/zero/1.0/ */ + +"use strict"; + +add_task(async function fileRemovedAfterClose({ client }) { + const { IO } = client; + const contents = "Lorem ipsum"; + const { handle, stream } = await registerFileStream(contents); + + await IO.close({ handle }); + ok( + !(await IOUtils.exists(stream.path)), + "Discarded the temporary backing storage" + ); +}); + +add_task(async function unknownHandle({ client }) { + const { IO } = client; + const handle = "1000000"; + + try { + await IO.close({ handle }); + ok(false, "Close shouldn't pass"); + } catch (e) { + ok( + e.message.startsWith(`Invalid stream handle`), + "Error contains expected message" + ); + } +}); + +add_task(async function invalidHandleTypes({ client }) { + const { IO } = client; + for (const handle of [null, true, 1, [], {}]) { + try { + await IO.close({ handle }); + ok(false, "Close shouldn't pass"); + } catch (e) { + ok( + e.message.startsWith(`handle: string value expected`), + "Error contains expected message" + ); + } + } +}); diff --git a/remote/cdp/test/browser/io/browser_read.js b/remote/cdp/test/browser/io/browser_read.js new file mode 100644 index 0000000000..cea9ab4a55 --- /dev/null +++ b/remote/cdp/test/browser/io/browser_read.js @@ -0,0 +1,166 @@ +/* Any copyright is dedicated to the Public Domain. + * http://creativecommons.org/publicdomain/zero/1.0/ */ + +"use strict"; + +add_task(async function seekByOffsets({ client }) { + const { IO } = client; + const contents = "Lorem ipsum"; + const { handle } = await registerFileStream(contents); + + for (const offset of [0, 5, 10, 100, 0, -1]) { + const result = await IO.read({ handle, offset }); + ok(result.base64Encoded, `Data for offset ${offset} is base64 encoded`); + ok(result.eof, `All data has been read for offset ${offset}`); + is( + atob(result.data), + contents.substring(offset >= 0 ? offset : 0), + `Found expected data for offset ${offset}` + ); + } +}); + +add_task(async function remembersOffsetAfterRead({ client }) { + const { IO } = client; + const contents = "Lorem ipsum"; + const { handle } = await registerFileStream(contents); + + let expectedOffset = 0; + const size = 3; + do { + const result = await IO.read({ handle, size }); + is( + atob(result.data), + contents.substring(expectedOffset, expectedOffset + size), + `Found expected data for expectedOffset ${expectedOffset}` + ); + ok( + result.base64Encoded, + `Data up to expected offset ${expectedOffset} is base64 encoded` + ); + + is( + result.eof, + expectedOffset + size >= contents.length, + `All data has been read up to expected offset ${expectedOffset}` + ); + + expectedOffset = Math.min(expectedOffset + size, contents.length); + } while (expectedOffset < contents.length); +}); + +add_task(async function readBySize({ client }) { + const { IO } = client; + const contents = "Lorem ipsum"; + const { handle } = await registerFileStream(contents); + + for (const size of [0, 5, 10, 100, 0, -1]) { + const result = await IO.read({ handle, offset: 0, size }); + ok(result.base64Encoded, `Data for size ${size} is base64 encoded`); + is( + result.eof, + size >= contents.length, + `All data has been read for size ${size}` + ); + is( + atob(result.data), + contents.substring(0, size), + `Found expected data for size ${size}` + ); + } +}); + +add_task(async function readAfterClose({ client }) { + const { IO } = client; + const contents = "Lorem ipsum"; + + // If we omit remove: false, then by the time the registered cleanup function + // runs we will have deleted our temp file (in the following call to IO.close) + // *but* another test will have created a file with the same name (due to the + // way IOUtils.createUniqueFile works). That file's stream will not be closed + // and so we won't be able to delete it, resulting in an exception and + // therefore a test failure. + const { handle, stream } = await registerFileStream(contents, { + remove: false, + }); + + await IO.close({ handle }); + + ok(!(await IOUtils.exists(stream.path)), "File should no longer exist"); + + try { + await IO.read({ handle }); + ok(false, "Read shouldn't pass"); + } catch (e) { + ok( + e.message.startsWith(`Invalid stream handle`), + "Error contains expected message" + ); + } +}); + +add_task(async function unknownHandle({ client }) { + const { IO } = client; + const handle = "1000000"; + + try { + await IO.read({ handle }); + ok(false, "Read shouldn't pass"); + } catch (e) { + ok( + e.message.startsWith(`Invalid stream handle`), + "Error contains expected message" + ); + } +}); + +add_task(async function invalidHandleTypes({ client }) { + const { IO } = client; + for (const handle of [null, true, 1, [], {}]) { + try { + await IO.read({ handle }); + ok(false, "Read shouldn't pass"); + } catch (e) { + ok( + e.message.startsWith(`handle: string value expected`), + "Error contains expected message" + ); + } + } +}); + +add_task(async function invalidOffsetTypes({ client }) { + const { IO } = client; + const contents = "Lorem ipsum"; + const { handle } = await registerFileStream(contents); + + for (const offset of [null, true, "1", [], {}]) { + try { + await IO.read({ handle, offset }); + ok(false, "Read shouldn't pass"); + } catch (e) { + ok( + e.message.startsWith(`offset: integer value expected`), + "Error contains expected message" + ); + } + } +}); + +add_task(async function invalidSizeTypes({ client }) { + const { IO } = client; + const contents = "Lorem ipsum"; + const { handle } = await registerFileStream(contents); + + for (const size of [null, true, "1", [], {}]) { + try { + await IO.read({ handle, size }); + ok(false, "Read shouldn't pass"); + } catch (e) { + ok( + e.message.startsWith(`size: integer value expected`), + "Error contains expected message" + ); + } + } +}); diff --git a/remote/cdp/test/browser/io/head.js b/remote/cdp/test/browser/io/head.js new file mode 100644 index 0000000000..4c6a67178e --- /dev/null +++ b/remote/cdp/test/browser/io/head.js @@ -0,0 +1,20 @@ +/* Any copyright is dedicated to the Public Domain. + * http://creativecommons.org/publicdomain/zero/1.0/ */ + +"use strict"; + +Services.scriptloader.loadSubScript( + "chrome://mochitests/content/browser/remote/cdp/test/browser/head.js", + this +); + +const { streamRegistry } = ChromeUtils.importESModule( + "chrome://remote/content/cdp/domains/parent/IO.sys.mjs" +); + +async function registerFileStream(contents, options) { + const stream = await createFileStream(contents, options); + const handle = streamRegistry.add(stream); + + return { handle, stream }; +} |