Update readme example

package.json

@@ -75,6 +75,9 @@
     "./main": "./esnext/main.js",
     "./start": "./esnext/start.js"
   },
+  "imports": {
+    "@virtualstate/internal": "./esnext/index.js"
+  },
   "repository": {
     "type": "git",
     "url": "git+https://github.com/virtualstate/internal.git"

src/index.ts

@@ -18,4 +18,5 @@ export * from "./fetch";
 export * from "./sync";
 export * from "./content-index";
 export * from "./periodic-sync";
+export * from "./worker";
 // export * from "./start";

src/tests/worker/service-worker/index.ts

@@ -8,14 +8,12 @@ import {
     executeServiceWorkerFetch,
     registerServiceWorkerFetch
 } from "../../../worker/service-worker/execute-fetch";
+import {fileURLToPath} from "node:url";
 
 export {};
 
-const instance = new URL(import.meta.url);
-const { pathname } = instance;
-const directory = dirname(pathname);
-instance.pathname = join(directory, "./worker.js");
-const worker = instance.toString();
+const pathname = fileURLToPath(import.meta.url);
+const worker = join(dirname(pathname), "./worker.js");
 
 async function waitForServiceWorker(registration: DurableServiceWorkerRegistration) {
     if (registration.active) {
@@ -78,4 +76,6 @@ async function waitForServiceWorker(registration: DurableServiceWorkerRegistrati
     }
 
 
-}
+}
+
+await import("./readme/main.js");

src/tests/worker/service-worker/readme/hello.js

@@ -0,0 +1,3 @@
+self.addEventListener("fetch", event => {
+    event.respondWith(new Response("Hello"))
+});

src/tests/worker/service-worker/readme/main.js

@@ -0,0 +1,15 @@
+import { serviceWorker, createServiceWorkerFetch } from "@virtualstate/internal";
+import { fileURLToPath } from "node:url";
+import { dirname, join } from "node:path";
+
+const pathname = fileURLToPath(import.meta.url);
+const worker = join(dirname(pathname), "./hello.js");
+
+const registration = await serviceWorker.register(worker);
+
+const fetch = createServiceWorkerFetch(registration);
+
+const response = await fetch("/");
+const text = await response.text();
+
+console.log(response.status, text); // 200 "Hello";

src/worker/index.ts

@@ -0,0 +1 @@
+export * from "./service-worker";

src/worker/service-worker/execute-fetch.ts

@@ -4,6 +4,7 @@ import {executeServiceWorkerWorker} from "./execute";
 import {isLike, ok} from "../../is";
 import type {FetchResponseMessage} from "./dispatch";
 import {DurableServiceWorkerRegistration, serviceWorker} from "./container";
+import {getOrigin} from "../../listen/config";
 
 export async function registerServiceWorkerFetch(worker: string, options?: RegistrationOptions) {
     const registration = await serviceWorker.register(worker, options);
@@ -19,7 +20,7 @@ export function createServiceWorkerFetch(registration: DurableServiceWorkerRegis
             request = new Request(input, init);
         } else {
             request = {
-                url: input,
+                url: new URL(input, getOrigin()).toString(),
                 method: init?.method,
                 headers: getFetchHeadersObject(
                     new Headers(init?.headers)

src/worker/service-worker/execute.ts

@@ -15,13 +15,6 @@ export function getServiceWorkerWorkerWorker(options?: WorkerOptions) {
     });
 }
 
-export function assertPushAsyncIterableIterator<T>(iterator: AsyncIterableIterator<T>): asserts iterator is PushAsyncIterableIterator<T> {
-    ok(
-        isLike<PushAsyncIterableIterator<T>>(iterator) &&
-        typeof iterator.clone === "function"
-    )
-}
-
 export async function executeServiceWorkerWorkerMessage(data?: ServiceWorkerWorkerData): Promise<unknown> {
     const iterator = executeServiceWorkerWorker(data)[Symbol.asyncIterator]();
     const next = await iterator.next();

src/worker/service-worker/index.ts

@@ -0,0 +1,3 @@
+export * from "./container";
+export * from "./execute-fetch";
+export * from "./execute";