4 files changed, 240 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..7d6ced51ad
--- /dev/null
+++ b/remote/cdp/test/browser/io/browser.ini
@@ -0,0 +1,16 @@
+[DEFAULT]
+tags = remote
+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..fc3fc382d7
--- /dev/null
+++ b/remote/cdp/test/browser/io/browser_close.js
@@ -0,0 +1,43 @@
+/* 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, path } = await registerFileStream(contents);
+
+  await IO.close({ handle });
+  ok(!(await OS.File.exists(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..1692e45e90
--- /dev/null
+++ b/remote/cdp/test/browser/io/browser_read.js
@@ -0,0 +1,155 @@
+/* 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";
+  const { handle } = await registerFileStream(contents);
+
+  await IO.close({ handle });
+
+  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..dc9cc7cef8
--- /dev/null
+++ b/remote/cdp/test/browser/io/head.js
@@ -0,0 +1,26 @@
+/* Any copyright is dedicated to the Public Domain.
+ * http://creativecommons.org/publicdomain/zero/1.0/ */
+
+"use strict";
+
+/* import-globals-from ../head.js */
+
+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 = {}) {
+  // Any file as registered with the stream registry will be automatically
+  // deleted during the shutdown of Firefox.
+  options.remove = false;
+
+  const { file, path } = await createFile(contents, options);
+  const handle = streamRegistry.add(file);
+
+  return { handle, path };
+}