Porting process to V3

.gitattributes

@@ -0,0 +1,14 @@
+# Ensure consistent line endings
+* text=auto eol=lf
+
+# Binary files
+*.png binary
+*.jpg binary
+*.jpeg binary
+*.gif binary
+*.ico binary
+*.woff binary
+*.woff2 binary
+*.ttf binary
+*.otf binary
+*.eot binary

.github/workflows/verify.yaml → .github/workflows/verify-posix.yaml

@@ -1,17 +1,22 @@
-name: Verify
+name: Verify (POSIX)
 
 on:
   push:
-    branches: main
+    branches:
+      - main
   pull_request:
-    branches: main
+    branches:
+      - main
 
 permissions:
   contents: read
 
 jobs:
   test:
-    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        os: [ubuntu-latest, macos-latest]
+    runs-on: ${{ matrix.os }}
 
     steps:
       - name: checkout
@@ -21,7 +26,6 @@ jobs:
         uses: denoland/setup-deno@v2
         with:
           deno-version: v2.x
-
       - name: reload dependencies
         run: deno cache --reload **/mod.ts
 
@@ -31,4 +35,4 @@ jobs:
 
       - run: deno lint
 
-      - run: deno test --allow-net --allow-read --allow-write --allow-env --allow-run
+      - run: deno test --allow-net --allow-read --allow-write --allow-env --allow-run --allow-ffi

.github/workflows/verify-windows.yaml

@@ -0,0 +1,60 @@
+name: Verify (Windows)
+
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+    branches:
+      - main
+
+permissions:
+  contents: read
+
+jobs:
+  test:
+    runs-on: windows-latest
+    strategy:
+      matrix:
+        shell:
+          # tests pass in all shells, but in powershell and pwsh, they `echo $?` as false
+          # this causes tests to fail in CI. We'll need to run only bash and cmd until
+          # we figure this out.
+          # - powershell
+          # - pwsh
+          - bash
+          - cmd
+    defaults:
+      run:
+        shell: ${{matrix.shell}}
+
+    steps:
+      - name: checkout
+        uses: actions/checkout@v4
+
+      - name: setup deno
+        uses: denoland/setup-deno@v2
+        with:
+          deno-version: v2.x
+
+      - run: deno fmt --check
+
+      - run: deno lint
+
+      - name: "Test (${{matrix.shell}})"
+        if: matrix.shell == 'powershell' || matrix.shell == 'pwsh'
+        run: |
+          $env:SHELL = "${{matrix.shell}}"
+          deno test --allow-net --allow-read --allow-write --allow-env --allow-run --allow-ffi --trace-leaks
+
+      - name: "Test (${{matrix.shell}})"
+        if: matrix.shell == 'cmd'
+        run: |
+          set SHELL=${{matrix.shell}}
+          deno test --allow-net --allow-read --allow-write --allow-env --allow-run --allow-ffi --trace-leaks
+
+      - name: "Test (${{matrix.shell}})"
+        if: matrix.shell == 'bash'
+        run: |
+          export SHELL=${{matrix.shell}}
+          deno test --allow-net --allow-read --allow-write --allow-env --allow-run --allow-ffi --trace-leaks

AGENTS.md

@@ -0,0 +1,2 @@
+Always check syntax after making code changes. Always run `deno fmt` and
+`deno lint` before commiting.

bdd/README.md

@@ -24,7 +24,7 @@ Add to your `deno.json` imports:
 ```json
 {
   "imports": {
-    "@effectionx/bdd": "npm:@effectionx/bdd"
+    "@effectionx/bdd": "jsr:@effectionx/bdd"
   }
 }
 ```

bdd/deno.json

@@ -5,7 +5,7 @@
   "license": "MIT",
   "imports": {
     "effection": "npm:effection@^3",
-    "@effectionx/test-adapter": "npm:@effectionx/test-adapter@^0.5.1",
+    "@effectionx/test-adapter": "jsr:@effectionx/test-adapter@^0.1.0",
     "@std/testing": "jsr:@std/testing@^1"
   }
 }

context-api/context-api.test.ts

@@ -1,10 +1,10 @@
-import { describe, it } from "bdd";
 import { expect } from "@std/expect";
-import { type Operation, run, scoped } from "effection";
+import { type Operation, scoped } from "effection";
+import { describe, it } from "@effectionx/bdd";
 import { createApi } from "@effectionx/context-api";
 
 describe("context api", () => {
-  it("can invoke a handler from anywhere", async () => {
+  it("can invoke a handler from anywhere", function* () {
     let { one, two } = createApi("numbers", {
       *one() {
         return 1;
@@ -14,27 +14,22 @@ describe("context api", () => {
       },
     }).operations;
 
-    await run(function* () {
-      expect(yield* one()).toEqual(1);
-      expect(yield* two()).toEqual(2);
-    });
+    expect(yield* one()).toEqual(1);
+    expect(yield* two()).toEqual(2);
   });
 
-  it("can have handlers that are not functions", async () => {
+  it("can have handlers that are not functions", function* () {
     let { one } = createApi("one", {
       one: {
         *[Symbol.iterator]() {
           return 1;
         },
       },
     }).operations;
-
-    await run(function* () {
-      expect(yield* one).toEqual(1);
-    });
+    expect(yield* one).toEqual(1);
   });
 
-  it("can add middleware around operations and operation functions", async () => {
+  it("can add middleware around operations and operation functions", function* () {
     let numbers = createApi("numbers", {
       one: {
         *[Symbol.iterator]() {
@@ -47,105 +42,91 @@ describe("context api", () => {
     });
 
     let { one, two } = numbers.operations;
+    yield* numbers.around({
+      *one(args, next) {
+        return (yield* next(...args)) * 2;
+      },
+      *two(args, next) {
+        return (yield* next(...args)) * 2;
+      },
+    });
 
-    await run(function* () {
-      yield* numbers.around({
-        *one(args, next) {
-          return (yield* next(...args)) * 2;
-        },
-        *two(args, next) {
-          return (yield* next(...args)) * 2;
-        },
-      });
+    expect(yield* one).toEqual(2);
+    expect(yield* two()).toEqual(4);
+  });
 
-      expect(yield* one).toEqual(2);
-      expect(yield* two()).toEqual(4);
+  it("passes arguments to an operation", function* () {
+    const math = createApi("math", {
+      *add(left: number, right: number): Operation<number> {
+        return left + right;
+      },
     });
+
+    const { add } = math.operations;
+    expect(yield* add(1, 1)).toEqual(2);
   });
 
-  it("passes arguments to an operation", async () => {
+  it("can modify arguments to operations with middleware", function* () {
     const math = createApi("math", {
       *add(left: number, right: number): Operation<number> {
         return left + right;
       },
     });
 
     const { add } = math.operations;
-
-    await run(function* () {
-      expect(yield* add(1, 1)).toEqual(2);
+    yield* math.around({
+      *add([left, right], next) {
+        return yield* next(left + 1, right + 1);
+      },
     });
+
+    expect(yield* add(1, 1)).toEqual(4);
   });
 
-  it("can modify arguments to operations with middleware", async () => {
+  it("treats the middleware contextually", function* () {
     const math = createApi("math", {
       *add(left: number, right: number): Operation<number> {
         return left + right;
       },
     });
-
     const { add } = math.operations;
-
-    await run(function* () {
+    yield* scoped(function* () {
       yield* math.around({
         *add([left, right], next) {
           return yield* next(left + 1, right + 1);
         },
       });
-
       expect(yield* add(1, 1)).toEqual(4);
     });
+
+    expect(yield* add(1, 1)).toEqual(2);
   });
 
-  it("treats the middleware contextually", async () => {
+  it("chains multiple middleware", function* () {
     const math = createApi("math", {
       *add(left: number, right: number): Operation<number> {
         return left + right;
       },
     });
-    const { add } = math.operations;
 
-    await run(function* () {
-      yield* scoped(function* () {
-        yield* math.around({
-          *add([left, right], next) {
-            return yield* next(left + 1, right + 1);
-          },
-        });
-        expect(yield* add(1, 1)).toEqual(4);
-      });
-
-      expect(yield* add(1, 1)).toEqual(2);
+    yield* math.around({
+      *add([left, right], next) {
+        return 10 + (yield* next(left, right));
+      },
     });
-  });
 
-  it("chains multiple middleware", async () => {
-    const math = createApi("math", {
-      *add(left: number, right: number): Operation<number> {
-        return left + right;
+    yield* math.around({
+      *add([left, right], next) {
+        return 100 + (yield* next(left, right));
       },
     });
 
-    await run(function* () {
-      yield* math.around({
-        *add([left, right], next) {
-          return 10 + (yield* next(left, right));
-        },
-      });
-
-      yield* math.around({
-        *add([left, right], next) {
-          return 100 + (yield* next(left, right));
-        },
-      });
-
-      yield* math.around({
-        *add([left, right], next) {
-          return 20 + (yield* next(left, right));
-        },
-      });
-
-      expect(yield* math.operations.add(5, 15)).toEqual(150);
+    yield* math.around({
+      *add([left, right], next) {
+        return 20 + (yield* next(left, right));
+      },
     });
+
+    expect(yield* math.operations.add(5, 15)).toEqual(150);
   });
 });

context-api/deno.json

@@ -5,6 +5,7 @@
   "exports": "./mod.ts",
   "imports": {
     "effection": "npm:effection@^3",
-    "@std/expect": "jsr:@std/expect"
+    "@std/expect": "jsr:@std/expect@^1",
+    "@effectionx/bdd": "jsr:@effectionx/bdd@0.2.2"
   }
 }

deno.json

@@ -1,7 +1,5 @@
 {
   "imports": {
-    "bdd": "jsr:@std/testing@1/bdd",
-    "expect": "jsr:@std/expect@1",
     "effection": "npm:effection@^3",
     "@deno/dnt": "jsr:@deno/dnt@0.42.3",
     "@std/path": "jsr:@std/path@^1",
@@ -39,6 +37,7 @@
     "./websocket",
     "./worker",
     "./stream-helpers",
-    "./signals"
+    "./signals",
+    "./process"
   ]
 }