1 files changed, 179 insertions, 0 deletions
diff --git a/devtools/client/debugger/test/mochitest/browser_dbg-windowless-service-workers.js b/devtools/client/debugger/test/mochitest/browser_dbg-windowless-service-workers.js
new file mode 100644
index 0000000000..a38aebe6e0
--- /dev/null
+++ b/devtools/client/debugger/test/mochitest/browser_dbg-windowless-service-workers.js
@@ -0,0 +1,179 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at <http://mozilla.org/MPL/2.0/>. */
+
+// Test that we can detect a new service worker and hit breakpoints that we've
+// set in it.
+
+"use strict";
+
+// Use an URL with a specific port to check that Bug 1876533 is fixed
+// We're using URL without port in other tests, like browser_dbg-windowless-service-workers-reload.js
+const SW_URL = EXAMPLE_URL_WITH_PORT + "service-worker.sjs";
+
+add_task(async function () {
+  info("Subtest #1");
+  await pushPref("devtools.debugger.features.windowless-service-workers", true);
+  await pushPref("devtools.debugger.threads-visible", true);
+  await pushPref("dom.serviceWorkers.testing.enabled", true);
+
+  const dbg = await initDebuggerWithAbsoluteURL(
+    EXAMPLE_URL_WITH_PORT + "doc-service-workers.html"
+  );
+
+  invokeInTab("registerWorker");
+  await waitForSource(dbg, "service-worker.sjs");
+  const workerSource = findSource(dbg, "service-worker.sjs");
+
+  await addBreakpoint(dbg, "service-worker.sjs", 13);
+
+  invokeInTab("fetchFromWorker");
+
+  await waitForPaused(dbg);
+  assertPausedAtSourceAndLine(dbg, workerSource.id, 13);
+  // Leave the breakpoint and worker in place for the next subtest.
+  await resume(dbg);
+  await waitForRequestsToSettle(dbg);
+  await removeTab(gBrowser.selectedTab);
+});
+
+// Test that breakpoints can be immediately hit in service workers when reloading.
+add_task(async function () {
+  info("Subtest #2");
+
+  const toolbox = await openNewTabAndToolbox(
+    `${EXAMPLE_URL_WITH_PORT}doc-service-workers.html`,
+    "jsdebugger"
+  );
+  const dbg = createDebuggerContext(toolbox);
+
+  await checkAdditionalThreadCount(dbg, 1);
+
+  // The test page will immediately fetch from the service worker if registered.
+  const onReloaded = reload(dbg);
+
+  await waitForSource(dbg, "service-worker.sjs");
+  const workerSource = findSource(dbg, "service-worker.sjs");
+
+  await waitForPaused(dbg);
+  assertPausedAtSourceAndLine(dbg, workerSource.id, 13);
+  await checkAdditionalThreadCount(dbg, 1);
+
+  await resume(dbg);
+  await dbg.actions.removeAllBreakpoints();
+
+  info("Wait for reload to complete after resume");
+  await onReloaded;
+
+  await unregisterServiceWorker(SW_URL);
+
+  await checkAdditionalThreadCount(dbg, 0);
+  await waitForRequestsToSettle(dbg);
+  await removeTab(gBrowser.selectedTab);
+});
+
+// Test having a waiting and active service worker for the same registration.
+add_task(async function () {
+  info("Subtest #3");
+
+  const toolbox = await openNewTabAndToolbox(
+    `${EXAMPLE_URL_WITH_PORT}doc-service-workers.html`,
+    "jsdebugger"
+  );
+  const dbg = createDebuggerContext(toolbox);
+
+  invokeInTab("registerWorker");
+  await checkAdditionalThreadCount(dbg, 1);
+  await checkWorkerStatus(dbg, "activated");
+
+  const firstTab = gBrowser.selectedTab;
+
+  await addTab(
+    `${EXAMPLE_URL_WITH_PORT}service-worker.sjs?setStatus=newServiceWorker`
+  );
+  await removeTab(gBrowser.selectedTab);
+
+  const secondTab = await addTab(
+    `${EXAMPLE_URL_WITH_PORT}doc-service-workers.html`
+  );
+
+  await gBrowser.selectTabAtIndex(gBrowser.tabs.indexOf(firstTab));
+  await checkAdditionalThreadCount(dbg, 2);
+
+  const sources = await waitFor(() => {
+    const list = dbg.selectors
+      .getSourceList()
+      .filter(s => s.url.includes("service-worker.sjs"));
+    return list.length == 1 ? list : null;
+  });
+  ok(sources.length, "Found one sources for service worker");
+
+  // Add a breakpoint for the next subtest.
+  await addBreakpoint(dbg, "service-worker.sjs", 2);
+
+  await unregisterServiceWorker(SW_URL);
+
+  await checkAdditionalThreadCount(dbg, 0);
+  await waitForRequestsToSettle(dbg);
+  await removeTab(firstTab);
+  await removeTab(secondTab);
+
+  // Reset the SJS in case we will be repeating the test.
+  await addTab(`${EXAMPLE_URL_WITH_PORT}service-worker.sjs?setStatus=`);
+  await removeTab(gBrowser.selectedTab);
+});
+
+// Test setting breakpoints while the service worker is starting up.
+add_task(async function () {
+  info("Subtest #4");
+  if (Services.appinfo.fissionAutostart) {
+    // Disabled when serviceworker isolation is used due to bug 1749341
+    return;
+  }
+
+  const toolbox = await openNewTabAndToolbox(
+    `${EXAMPLE_URL_WITH_PORT}doc-service-workers.html`,
+    "jsdebugger"
+  );
+  const dbg = createDebuggerContext(toolbox);
+
+  invokeInTab("registerWorker");
+  await checkAdditionalThreadCount(dbg, 1);
+
+  await waitForSource(dbg, "service-worker.sjs");
+  const workerSource = findSource(dbg, "service-worker.sjs");
+
+  await waitForBreakpointCount(dbg, 1);
+  await waitForPaused(dbg);
+  assertPausedAtSourceAndLine(dbg, workerSource.id, 2);
+  await checkWorkerStatus(dbg, "parsed");
+
+  await addBreakpoint(dbg, "service-worker.sjs", 19);
+  await resume(dbg);
+  await waitForPaused(dbg);
+  assertPausedAtSourceAndLine(dbg, workerSource.id, 19);
+  await checkWorkerStatus(dbg, "installing");
+
+  await addBreakpoint(dbg, "service-worker.sjs", 5);
+  await resume(dbg);
+  await waitForPaused(dbg);
+  assertPausedAtSourceAndLine(dbg, workerSource.id, 5);
+  await checkWorkerStatus(dbg, "activating");
+
+  await resume(dbg);
+  await unregisterServiceWorker(SW_URL);
+
+  await checkAdditionalThreadCount(dbg, 0);
+  await waitForRequestsToSettle(dbg);
+  await removeTab(gBrowser.selectedTab);
+});
+
+async function checkWorkerStatus(dbg, status) {
+  /* TODO: Re-Add support for showing service worker status (Bug 1641099)
+  await waitUntil(() => {
+    const threads = dbg.selectors.getThreads();
+    return threads.some(t => t.serviceWorkerStatus == status);
+  });
+  ok(true, `Have thread with status ${status}`);
+  */
+}