Merge pull request #1 from Jobflow-io/common-models

Author: fiws

.gitignore

@@ -3,6 +3,7 @@ src/scratchpad.ts
 dist
 docs
 context
+tmp
 
 ## in scratchpad, we only track setup.ts
 src/scratchpad/*

package.json

@@ -48,6 +48,7 @@
     "@effect/platform": "^0.94.1",
     "@effect/platform-node": "^0.104.0",
     "@effect/vitest": "^0.27.0",
+    "@types/node": "^25.0.8",
     "effect": "^3.19.14",
     "playwright": "^1.57.0",
     "tsdown": "0.20.0-beta.1",

pnpm-lock.yaml

@@ -0,0 +1,145 @@
+import { assert, layer } from "@effect/vitest";
+import { Effect, Fiber, Option, Stream } from "effect";
+import { chromium } from "playwright-core";
+import { PlaywrightBrowser } from "./browser";
+import { PlaywrightEnvironment } from "./experimental";
+
+layer(PlaywrightEnvironment.layer(chromium))("PlaywrightCommon", (it) => {
+  it.scoped("PlaywrightRequest and PlaywrightResponse", () =>
+    Effect.gen(function* () {
+      const browser = yield* PlaywrightBrowser;
+      const page = yield* browser.newPage();
+
+      const requestFiber = yield* page
+        .eventStream("request")
+        .pipe(Stream.runHead)
+        .pipe(Effect.fork);
+
+      const responseFiber = yield* page
+        .eventStream("response")
+        .pipe(Stream.runHead)
+        .pipe(Effect.fork);
+
+      yield* page.goto("http://example.com");
+
+      const request = yield* Fiber.join(requestFiber).pipe(Effect.flatten);
+      const response = yield* Fiber.join(responseFiber).pipe(Effect.flatten);
+
+      assert((yield* request.url).includes("example.com"));
+      assert((yield* request.method) === "GET");
+      assert((yield* request.isNavigationRequest) === true);
+
+      assert((yield* response.url).includes("example.com"));
+      assert((yield* response.ok) === true);
+      assert((yield* response.status) === 200);
+
+      const headers = yield* response.headers;
+      assert(headers["content-type"] !== undefined);
+
+      const respRequest = response.request();
+      assert((yield* respRequest.url).includes("example.com"));
+
+      const requestResponse = yield* request.response;
+      assert(Option.isSome(requestResponse));
+      assert((yield* requestResponse.value.url) === (yield* response.url));
+    }).pipe(PlaywrightEnvironment.withBrowser),
+  );
+
+  it.scoped("PlaywrightWorker", () =>
+    Effect.gen(function* () {
+      const browser = yield* PlaywrightBrowser;
+      const page = yield* browser.newPage();
+
+      const workerFiber = yield* page
+        .eventStream("worker")
+        .pipe(Stream.runHead)
+        .pipe(Effect.fork);
+
+      yield* page.evaluate(() => {
+        const blob = new Blob(['console.log("worker")'], {
+          type: "application/javascript",
+        });
+        new Worker(URL.createObjectURL(blob));
+      });
+
+      const worker = yield* Fiber.join(workerFiber).pipe(Effect.flatten);
+
+      assert((yield* worker.url).startsWith("blob:"));
+      const result = yield* worker.evaluate(() => 1 + 1);
+      assert(result === 2);
+    }).pipe(PlaywrightEnvironment.withBrowser),
+  );
+
+  it.scoped("PlaywrightDialog", () =>
+    Effect.gen(function* () {
+      const browser = yield* PlaywrightBrowser;
+      const page = yield* browser.newPage();
+
+      const dialogFiber = yield* page
+        .eventStream("dialog")
+        .pipe(Stream.runHead)
+        .pipe(Effect.fork);
+
+      yield* page.evaluate(() => {
+        setTimeout(() => alert("hello world"), 10);
+      });
+
+      const dialog = yield* Fiber.join(dialogFiber).pipe(Effect.flatten);
+
+      assert((yield* dialog.message) === "hello world");
+      assert((yield* dialog.type) === "alert");
+
+      yield* dialog.accept();
+    }).pipe(PlaywrightEnvironment.withBrowser),
+  );
+
+  it.scoped("PlaywrightFileChooser", () =>
+    Effect.gen(function* () {
+      const browser = yield* PlaywrightBrowser;
+      const page = yield* browser.newPage();
+
+      yield* page.evaluate(() => {
+        document.body.innerHTML = '<input type="file" id="fileinput" />';
+      });
+
+      const fileChooserFiber = yield* page
+        .eventStream("filechooser")
+        .pipe(Stream.runHead)
+        .pipe(Effect.fork);
+
+      yield* page.locator("#fileinput").click();
+
+      const fileChooser = yield* Fiber.join(fileChooserFiber).pipe(
+        Effect.flatten,
+      );
+
+      assert((yield* fileChooser.isMultiple) === false);
+      assert(fileChooser.element() !== null);
+    }).pipe(PlaywrightEnvironment.withBrowser),
+  );
+
+  it.scoped("PlaywrightDownload", () =>
+    Effect.gen(function* () {
+      const browser = yield* PlaywrightBrowser;
+      const page = yield* browser.newPage();
+
+      yield* page.evaluate(() => {
+        document.body.innerHTML =
+          '<a text="Download" id="download" href="data:application/octet-stream,hello world" download="test.txt">Download</a>';
+      });
+
+      const downloadFiber = yield* page
+        .eventStream("download")
+        .pipe(Stream.runHead)
+        .pipe(Effect.fork);
+
+      yield* page.locator("#download").click();
+
+      const download = yield* Fiber.join(downloadFiber).pipe(Effect.flatten);
+
+      assert((yield* download.suggestedFilename) === "test.txt");
+      const url = yield* download.url;
+      assert(url.startsWith("data:"));
+    }).pipe(PlaywrightEnvironment.withBrowser),
+  );
+});