summaryrefslogtreecommitdiffstats
path: root/remote/cdp/test/browser/io
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--remote/cdp/test/browser/io/browser.ini16
-rw-r--r--remote/cdp/test/browser/io/browser_close.js46
-rw-r--r--remote/cdp/test/browser/io/browser_read.js166
-rw-r--r--remote/cdp/test/browser/io/head.js20
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 };
+}
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-03 20:21:25 +0000