Migrate all async computations to Effects

deno.json

@@ -10,8 +10,7 @@
     "packages/fabric/testing",
     "packages/fabric/validations",
     "packages/templates/domain",
-    "packages/templates/lib",
-    "apps/syntropy/domain"
+    "packages/templates/lib"
   ],
   "compilerOptions": {
     "strict": true,

deno.lock

@@ -127,11 +127,15 @@
   },
   "workspace": {
     "members": {
+      "packages/fabric/core": {
+        "dependencies": [
+          "jsr:@quentinadam/decimal@~0.1.6"
+        ]
+      },
       "packages/fabric/domain": {
         "dependencies": [
           "jsr:@fabric/core@*",
-          "jsr:@fabric/validations@*",
-          "jsr:@quentinadam/decimal@~0.1.6"
+          "jsr:@fabric/validations@*"
         ]
       },
       "packages/fabric/sqlite-store": {

packages/fabric/core/array/array-element.test.ts

@@ -1,10 +1,57 @@
 import { describe, expectTypeOf, test } from "@fabric/testing";
-import type { ArrayElement } from "./array-element.ts";
+import type {
+  ArrayElement,
+  TupleFirstElement,
+  TupleLastElement,
+} from "./array-element.ts";
 
 describe("ArrayElement", () => {
   test("Given an array, it should return the element type of the array", () => {
     type result = ArrayElement<["a", "b", "c"]>;
-
     expectTypeOf<result>().toEqualTypeOf<"a" | "b" | "c">();
   });
+
+  test("Given an array of numbers, it should return the element type of the array", () => {
+    type result = ArrayElement<[1, 2, 3]>;
+    expectTypeOf<result>().toEqualTypeOf<1 | 2 | 3>();
+  });
+
+  test("Given an empty array, it should return never", () => {
+    type result = ArrayElement<[]>;
+    expectTypeOf<result>().toEqualTypeOf<never>();
+  });
+});
+
+describe("TupleFirstElement", () => {
+  test("Given a tuple, it should return the first element type of the tuple", () => {
+    type result = TupleFirstElement<[1, 2, 3]>;
+    expectTypeOf<result>().toEqualTypeOf<1>();
+  });
+
+  test("Given a tuple with different types, it should return the first element type of the tuple", () => {
+    type result = TupleFirstElement<[string, number, boolean]>;
+    expectTypeOf<result>().toEqualTypeOf<string>();
+  });
+
+  test("Given an empty tuple, it should return never", () => {
+    type result = TupleFirstElement<[]>;
+    expectTypeOf<result>().toEqualTypeOf<never>();
+  });
+});
+
+describe("TupleLastElement", () => {
+  test("Given a tuple, it should return the last element type of the tuple", () => {
+    type result = TupleLastElement<[1, 2, 3]>;
+    expectTypeOf<result>().toEqualTypeOf<3>();
+  });
+
+  test("Given a tuple with different types, it should return the last element type of the tuple", () => {
+    type result = TupleLastElement<[string, number, boolean]>;
+    expectTypeOf<result>().toEqualTypeOf<boolean>();
+  });
+
+  test("Given an empty tuple, it should return never", () => {
+    type result = TupleLastElement<[]>;
+    expectTypeOf<result>().toEqualTypeOf<never>();
+  });
 });

packages/fabric/core/effect/effect.test.ts

@@ -0,0 +1,153 @@
+import { describe, expect, expectTypeOf, fn, test } from "@fabric/testing";
+import { UnexpectedError } from "../index.ts";
+import { Result } from "../result/result.ts";
+import { Effect, type ExtractEffectDependencies } from "./effect.ts";
+
+describe("Effect", () => {
+  test("Effect.from should create an Effect that returns a successful Result", async () => {
+    const effect = Effect.from(() => Result.ok(42));
+    const result = await effect.run();
+    expect(result.isOk()).toBe(true);
+    expect(result.unwrapOrThrow()).toBe(42);
+  });
+
+  test("Effect.from should create an Effect that returns a failed Result with the correct error type and message", async () => {
+    const effect = Effect.from(() =>
+      Result.failWith(new UnexpectedError("failure"))
+    );
+    const result = await effect.run();
+    expect(result.isError()).toBe(true);
+    expect(result.unwrapErrorOrThrow()).toBeInstanceOf(UnexpectedError);
+    expect(result.unwrapErrorOrThrow().message).toBe("failure");
+  });
+
+  test("Effect.tryFrom should create an Effect that returns a successful Result", async () => {
+    const effect = Effect.tryFrom(
+      () => Promise.resolve(42),
+      (e) => new UnexpectedError(e.message),
+    );
+    const result = await effect.run();
+    expect(result.isOk()).toBe(true);
+    expect(result.unwrapOrThrow()).toBe(42);
+  });
+
+  test("Effect.tryFrom should create an Effect that returns a failed Result with the correct error type and message", async () => {
+    const effect = Effect.tryFrom(
+      () => Promise.reject(new Error("failure")),
+      (e) => new UnexpectedError(e.message),
+    );
+    const result = await effect.run();
+    expect(result.isError()).toBe(true);
+    expect(result.unwrapErrorOrThrow()).toBeInstanceOf(UnexpectedError);
+    expect(result.unwrapErrorOrThrow().message).toBe("failure");
+  });
+
+  test("Effect.ok should create an Effect that returns a successful Result", async () => {
+    const effect = Effect.ok(42);
+    const result = await effect.run();
+    expect(result.isOk()).toBe(true);
+    expect(result.unwrapOrThrow()).toBe(42);
+  });
+
+  test("Effect.failWith should create an Effect that returns a failed Result with the correct error type and message", async () => {
+    const effect = Effect.failWith(new UnexpectedError("failure"));
+    const result = await effect.run();
+    expect(result.isError()).toBe(true);
+    expect(result.unwrapErrorOrThrow()).toBeInstanceOf(UnexpectedError);
+    expect(result.unwrapErrorOrThrow().message).toBe("failure");
+  });
+
+  test("Effect.map should map a successful Result to a new successful Result", async () => {
+    const effect = Effect.ok(42).map((value) => value * 2);
+    const result = await effect.run();
+    expect(result.isOk()).toBe(true);
+    expect(result.unwrapOrThrow()).toBe(84);
+  });
+
+  test("Effect.map should skip maps when the Result is an error", async () => {
+    const mockFn = fn() as () => number;
+    const effect = Effect.failWith(new UnexpectedError("failure")).map(
+      mockFn,
+    );
+    const result = await effect.run();
+    expect(result.isError()).toBe(true);
+    expect(result.unwrapErrorOrThrow()).toBeInstanceOf(UnexpectedError);
+    expect(result.unwrapErrorOrThrow().message).toBe("failure");
+    expect(mockFn).not.toHaveBeenCalled();
+  });
+
+  test(
+    "Effect.flatMap should map a successful Effect to a new Effect",
+    async () => {
+      const effect = Effect.ok(42).flatMap((value) => Effect.ok(value * 2));
+      const result = await effect.run();
+      expect(result.isOk()).toBe(true);
+      expect(result.unwrapOrThrow()).toBe(84);
+    },
+  );
+
+  test("Effect.flatMap should map a successful Effect to a new failed Effect", async () => {
+    const effect = Effect.ok(42).flatMap(() =>
+      Effect.failWith(new UnexpectedError("failure"))
+    );
+    const result = await effect.run();
+    expect(result.isError()).toBe(true);
+    expect(result.unwrapErrorOrThrow()).toBeInstanceOf(UnexpectedError);
+    expect(result.unwrapErrorOrThrow().message).toBe("failure");
+  });
+
+  test("Effect.flatMap should skip maps when the Result is an error", async () => {
+    const mockFn = fn() as () => Effect<number, UnexpectedError>;
+    const effect = Effect.failWith(new UnexpectedError("failure")).flatMap(
+      mockFn,
+    );
+    const result = await effect.run();
+    expect(result.isError()).toBe(true);
+    expect(result.unwrapErrorOrThrow()).toBeInstanceOf(UnexpectedError);
+    expect(result.unwrapErrorOrThrow().message).toBe("failure");
+    expect(mockFn).not.toHaveBeenCalled();
+  });
+
+  test("Effect.flatMap should result in an effect which requires both dependencies", async () => {
+    const effect = Effect.from(({ a }: { a: number }) => Result.ok(a * 2))
+      .flatMap((value) =>
+        Effect.from(({ b }: { b: number }) => Result.ok(value + b))
+      );
+
+    const result = await effect.run({ a: 1, b: 2 });
+    expect(result.isOk()).toBe(true);
+    expect(result.unwrapOrThrow()).toBe(4);
+
+    //This should fail to compile
+    //await effect.run({ a: 1 });
+
+    type Deps = ExtractEffectDependencies<typeof effect>;
+
+    expectTypeOf<Deps>().toEqualTypeOf<{ a: number } & { b: number }>();
+  });
+
+  test("Effect.flatMap should work if an effect has dependencies and the other effect does not", async () => {
+    const effect = Effect.from(({ a }: { a: number }) => Result.ok(a * 2))
+      .flatMap((value) => Effect.ok(value + 2));
+
+    const result = await effect.run({ a: 1 });
+    expect(result.isOk()).toBe(true);
+    expect(result.unwrapOrThrow()).toBe(4);
+
+    type Deps = ExtractEffectDependencies<typeof effect>;
+
+    expectTypeOf<Deps>().toEqualTypeOf<{ a: number }>();
+  });
+
+  test("Effect.seq should run multiple effects in sequence", async () => {
+    const effect = Effect.seq(
+      () => Effect.ok(1),
+      (x) => Effect.ok(x + 1),
+      (x) => Effect.ok(x * 2),
+    );
+
+    const result = await effect.run();
+    expect(result.isOk()).toBe(true);
+    expect(result.unwrapOrThrow()).toBe(4);
+  });
+});

packages/fabric/core/effect/effect.ts

@@ -0,0 +1,144 @@
+// deno-lint-ignore-file no-explicit-any
+import type { TaggedError } from "../error/tagged-error.ts";
+import { Result } from "../result/result.ts";
+import type { MaybePromise } from "../types/maybe-promise.ts";
+import type { MergeTypes } from "../types/merge-types.ts";
+
+export class Effect<
+  TValue = any,
+  TError extends TaggedError = never,
+  TDeps = void,
+> {
+  static from<TValue, TError extends TaggedError = never, TDeps = void>(
+    fn: (deps: TDeps) => MaybePromise<Result<TValue, TError>>,
+  ): Effect<TValue, TError, TDeps> {
+    return new Effect(fn);
+  }
+  static tryFrom<TValue, TError extends TaggedError = never, TDeps = void>(
+    fn: () => MaybePromise<TValue>,
+    errorMapper: (error: any) => TError,
+  ): Effect<TValue, TError, TDeps> {
+    return new Effect(
+      async () => {
+        try {
+          const value = await fn();
+          return Result.ok(value);
+        } catch (error) {
+          return Result.failWith(errorMapper(error));
+        }
+      },
+    );
+  }
+
+  static ok(): Effect<void>;
+  static ok<TValue>(value: TValue): Effect<TValue>;
+  static ok<TValue>(value?: TValue): Effect<any> {
+    return new Effect(() => Result.ok(value));
+  }
+
+  static failWith<TError extends TaggedError>(
+    error: TError,
+  ): Effect<never, TError> {
+    return new Effect(() => Result.failWith(error));
+  }
+
+  constructor(
+    private readonly fn: (
+      deps: TDeps,
+    ) => MaybePromise<Result<TValue, TError>>,
+  ) {
+  }
+
+  map<TNewValue>(
+    fn: (value: TValue) => MaybePromise<TNewValue>,
+  ): Effect<TNewValue, TError, TDeps> {
+    return new Effect(async (deps: TDeps) => {
+      const result = await this.fn(deps);
+      if (result.isError()) {
+        return result;
+      }
+      return Result.ok(await fn(result.value as TValue));
+    });
+  }
+
+  flatMap<TNewValue, TNewError extends TaggedError, TNewDeps = void>(
+    fn: (
+      value: TValue,
+    ) => Effect<TNewValue, TNewError, TNewDeps>,
+  ): Effect<TNewValue, TError | TNewError, MergeTypes<TDeps, TNewDeps>> {
+    return new Effect(async (deps: TDeps & TNewDeps) => {
+      const result = await this.fn(deps);
+      if (result.isError()) {
+        return result as Result<TNewValue, TError | TNewError>;
+      }
+      return await fn(result.value as TValue).fn(deps);
+    }) as Effect<
+      TNewValue,
+      TError | TNewError,
+      MergeTypes<TDeps, TNewDeps>
+    >;
+  }
+
+  async run(deps: TDeps): Promise<Result<TValue, TError>> {
+    return await this.fn(deps);
+  }
+
+  async runOrThrow(deps: TDeps): Promise<TValue> {
+    return (await this.fn(deps)).unwrapOrThrow();
+  }
+
+  async failOrThrow(deps: TDeps): Promise<TError> {
+    return (await this.fn(deps)).unwrapErrorOrThrow();
+  }
+
+  static seq<
+    T1,
+    TE1 extends TaggedError,
+    T2,
+    TE2 extends TaggedError,
+  >(
+    fn1: () => Effect<T1, TE1>,
+    fn2: (value: T1) => Effect<T2, TE2>,
+  ): Effect<T2, TE1 | TE2>;
+  static seq<
+    T1,
+    TE1 extends TaggedError,
+    T2,
+    TE2 extends TaggedError,
+    T3,
+    TE3 extends TaggedError,
+  >(
+    fn1: () => Effect<T1, TE1>,
+    fn2: (value: T1) => Effect<T2, TE2>,
+    fn3: (value: T2) => Effect<T3, TE3>,
+  ): Effect<T3, TE1 | TE2 | TE3>;
+  static seq<
+    T1,
+    TE1 extends TaggedError,
+    T2,
+    TE2 extends TaggedError,
+    T3,
+    TE3 extends TaggedError,
+    T4,
+    TE4 extends TaggedError,
+  >(
+    fn1: () => Effect<T1, TE1>,
+    fn2: (value: T1) => Effect<T2, TE2>,
+    fn3: (value: T2) => Effect<T3, TE3>,
+    fn4: (value: T3) => Effect<T4, TE4>,
+  ): Effect<T4, TE1 | TE2 | TE3 | TE4>;
+  static seq(
+    ...fns: ((...args: any[]) => Effect<any, any>)[]
+  ): Effect<any, any> {
+    let result = fns[0]!();
+
+    for (let i = 1; i < fns.length; i++) {
+      result = result.flatMap((value) => fns[i]!(value));
+    }
+
+    return result;
+  }
+}
+
+export type ExtractEffectDependencies<T> = T extends
+  Effect<any, any, infer TDeps> ? TDeps : never;

packages/fabric/core/effect/index.ts

@@ -0,0 +1 @@
+export * from "./effect.ts";

packages/fabric/core/error/tagged-error.ts

@@ -1,4 +1,4 @@
-import { type TaggedVariant, VariantTag } from "../variant/index.ts";
+import { type TaggedVariant, VariantTag } from "../variant/variant.ts";
 
 /**
  * A TaggedError is a tagged variant with an error message.

packages/fabric/core/index.ts

@@ -1,5 +1,6 @@
 import Decimal from "decimal";
 export * from "./array/index.ts";
+export * from "./effect/index.ts";
 export * from "./error/index.ts";
 export * from "./record/index.ts";
 export * from "./result/index.ts";

packages/fabric/core/result/async-result.ts

@@ -1,146 +0,0 @@
-// deno-lint-ignore-file no-namespace no-explicit-any no-async-promise-executor
-import { UnexpectedError } from "@fabric/core";
-import type { TaggedError } from "../error/tagged-error.ts";
-import type { MaybePromise } from "../types/maybe-promise.ts";
-import { Result } from "./result.ts";
-
-/**
- * An AsyncResult represents the result of an asynchronous operation that can
- * resolve to a value of type `TValue` or an error of type `TError`.
- */
-export class AsyncResult<
-  TValue = any,
-  TError extends TaggedError = never,
-> {
-  static tryFrom<T, TError extends TaggedError>(
-    fn: () => MaybePromise<T>,
-    errorMapper: (error: any) => TError,
-  ): AsyncResult<T, TError> {
-    return new AsyncResult(
-      new Promise<Result<T, TError>>(async (resolve) => {
-        try {
-          const value = await fn();
-          resolve(Result.ok(value));
-        } catch (error) {
-          resolve(Result.failWith(errorMapper(error)));
-        }
-      }),
-    );
-  }
-
-  static from<T>(fn: () => MaybePromise<T>): AsyncResult<T, never> {
-    return AsyncResult.tryFrom(
-      fn,
-      (error) => new UnexpectedError(error) as never,
-    );
-  }
-
-  static ok(): AsyncResult<void, never>;
-  static ok<T>(value: T): AsyncResult<T, never>;
-  static ok(value?: any) {
-    return new AsyncResult(Promise.resolve(Result.ok(value)));
-  }
-
-  static succeedWith = AsyncResult.ok;
-
-  static failWith<TError extends TaggedError>(
-    error: TError,
-  ): AsyncResult<never, TError> {
-    return new AsyncResult(Promise.resolve(Result.failWith(error)));
-  }
-
-  private constructor(private r: Promise<Result<TValue, TError>>) {
-  }
-
-  promise(): Promise<Result<TValue, TError>> {
-    return this.r;
-  }
-
-  async unwrapOrThrow(): Promise<TValue> {
-    return (await this.r).unwrapOrThrow();
-  }
-
-  async orThrow(): Promise<void> {
-    return (await this.r).orThrow();
-  }
-
-  async unwrapErrorOrThrow(): Promise<TError> {
-    return (await this.r).unwrapErrorOrThrow();
-  }
-
-  /**
-   * Map a function over the value of the result.
-   */
-  map<TMappedValue>(
-    fn: (value: TValue) => TMappedValue,
-  ): AsyncResult<TMappedValue, TError> {
-    return new AsyncResult(
-      this.r.then((result) => result.map(fn)),
-    );
-  }
-
-  /**
-   * Maps a function over the value of the result and flattens the result.
-   */
-  flatMap<TMappedValue, TMappedError extends TaggedError>(
-    fn: (value: TValue) => AsyncResult<TMappedValue, TMappedError>,
-  ): AsyncResult<TMappedValue, TError | TMappedError> {
-    return new AsyncResult(
-      this.r.then((result) => {
-        if (result.isError()) {
-          return result as any;
-        }
-
-        return (fn(result.unwrapOrThrow())).promise();
-      }),
-    );
-  }
-
-  /**
-   * Try to map a function over the value of the result.
-   * If the function throws an error, the result will be a failure.
-   */
-  tryMap<TMappedValue>(
-    fn: (value: TValue) => TMappedValue,
-    errMapper: (error: any) => TError,
-  ): AsyncResult<TMappedValue, TError> {
-    return new AsyncResult(
-      this.r.then((result) => result.tryMap(fn, errMapper)),
-    );
-  }
-
-  /**
-   * Map a function over the error of the result.
-   */
-  errorMap<TMappedError extends TaggedError>(
-    fn: (error: TError) => TMappedError,
-  ): AsyncResult<TValue, TMappedError> {
-    return new AsyncResult(
-      this.r.then((result) => result.errorMap(fn)),
-    );
-  }
-
-  /**
-   * Execute a function if the result is not an error.
-   * The function does not affect the result.
-   */
-  tap(fn: (value: TValue) => void): AsyncResult<TValue, TError> {
-    return new AsyncResult(
-      this.r.then((result) => result.tap(fn)),
-    );
-  }
-
-  assert<TResultValue, TResultError extends TaggedError>(
-    fn: (value: TValue) => AsyncResult<TResultValue, TResultError>,
-  ): AsyncResult<TValue, TError | TResultError> {
-    return new AsyncResult(
-      this.r.then((result) => {
-        if (result.isError()) {
-          return result as any;
-        }
-
-        return (fn(result.unwrapOrThrow())).promise();
-      }),
-    );
-  }
-}

packages/fabric/core/result/index.ts

@@ -1,2 +1 @@
-export * from "./async-result.ts";
 export * from "./result.ts";

packages/fabric/core/run/run.test.ts

@@ -1,4 +1,4 @@
-import { AsyncResult } from "@fabric/core";
+import { Effect } from "@fabric/core";
 import { describe, expect, test } from "@fabric/testing";
 import { UnexpectedError } from "../error/unexpected-error.ts";
 import { Run } from "./run.ts";
@@ -6,21 +6,21 @@ import { Run } from "./run.ts";
 describe("Run", () => {
   describe("In Sequence", () => {
     test("should pipe the results of multiple async functions", async () => {
-      const result = Run.seq(
-        () => AsyncResult.succeedWith(1),
-        (x) => AsyncResult.succeedWith(x + 1),
-        (x) => AsyncResult.succeedWith(x * 2),
+      const result = await Run.seq(
+        () => Effect.ok(1),
+        (x) => Effect.ok(x + 1),
+        (x) => Effect.ok(x * 2),
       );
 
-      expect(await result.unwrapOrThrow()).toEqual(4);
+      expect(result.unwrapOrThrow()).toEqual(4);
     });
 
     test("should return the first error if one of the functions fails", async () => {
       const result = await Run.seq(
-        () => AsyncResult.succeedWith(1),
-        () => AsyncResult.failWith(new UnexpectedError()),
-        (x) => AsyncResult.succeedWith(x * 2),
-      ).promise();
+        () => Effect.ok(1),
+        () => Effect.failWith(new UnexpectedError()),
+        (x) => Effect.ok(x * 2),
+      );
 
       expect(result.isError()).toBe(true);
     });

packages/fabric/core/run/run.ts

@@ -1,6 +1,7 @@
 // deno-lint-ignore-file no-namespace no-explicit-any
+import { Effect } from "../effect/index.ts";
 import type { TaggedError } from "../error/tagged-error.ts";
-import type { AsyncResult } from "../result/async-result.ts";
+import { Result } from "../result/index.ts";
 
 export namespace Run {
   // prettier-ignore
@@ -10,10 +11,9 @@ export namespace Run {
     T2,
     TE2 extends TaggedError,
   >(
-    fn1: () => AsyncResult<T1, TE1>,
-    fn2: (value: T1) => AsyncResult<T2, TE2>,
-  ): AsyncResult<T2, TE1 | TE2>;
-  // prettier-ignore
+    fn1: () => Effect<T1, TE1>,
+    fn2: (value: T1) => Effect<T2, TE2>,
+  ): Promise<Result<T2, TE1 | TE2>>;
   export function seq<
     T1,
     TE1 extends TaggedError,
@@ -22,11 +22,10 @@ export namespace Run {
     T3,
     TE3 extends TaggedError,
   >(
-    fn1: () => AsyncResult<T1, TE1>,
-    fn2: (value: T1) => AsyncResult<T2, TE2>,
-    fn3: (value: T2) => AsyncResult<T3, TE3>,
-  ): AsyncResult<T3, TE1 | TE2 | TE3>;
-  // prettier-ignore
+    fn1: () => Effect<T1, TE1>,
+    fn2: (value: T1) => Effect<T2, TE2>,
+    fn3: (value: T2) => Effect<T3, TE3>,
+  ): Promise<Result<T3, TE1 | TE2 | TE3>>;
   export function seq<
     T1,
     TE1 extends TaggedError,
@@ -37,21 +36,21 @@ export namespace Run {
     T4,
     TE4 extends TaggedError,
   >(
-    fn1: () => AsyncResult<T1, TE1>,
-    fn2: (value: T1) => AsyncResult<T2, TE2>,
-    fn3: (value: T2) => AsyncResult<T3, TE3>,
-    fn4: (value: T3) => AsyncResult<T4, TE4>,
-  ): AsyncResult<T4, TE1 | TE2 | TE3 | TE4>;
+    fn1: () => Effect<T1, TE1>,
+    fn2: (value: T1) => Effect<T2, TE2>,
+    fn3: (value: T2) => Effect<T3, TE3>,
+    fn4: (value: T3) => Effect<T4, TE4>,
+  ): Promise<Result<T4, TE1 | TE2 | TE3 | TE4>>;
   export function seq(
-    ...fns: ((...args: any[]) => AsyncResult<any, any>)[]
-  ): AsyncResult<any, any> {
+    ...fns: ((...args: any[]) => Effect<any, any>)[]
+  ): Promise<Result<any, any>> {
     let result = fns[0]!();
 
     for (let i = 1; i < fns.length; i++) {
       result = result.flatMap((value) => fns[i]!(value));
     }
 
-    return result;
+    return result.run();
   }
 
   // prettier-ignore
@@ -61,8 +60,8 @@ export namespace Run {
     T2,
     TE2 extends TaggedError,
   >(
-    fn1: () => AsyncResult<T1, TE1>,
-    fn2: (value: T1) => AsyncResult<T2, TE2>,
+    fn1: () => Effect<T1, TE1>,
+    fn2: (value: T1) => Effect<T2, TE2>,
   ): Promise<T2>;
   // prettier-ignore
   export function seqOrThrow<
@@ -73,14 +72,14 @@ export namespace Run {
     T3,
     TE3 extends TaggedError,
   >(
-    fn1: () => AsyncResult<T1, TE1>,
-    fn2: (value: T1) => AsyncResult<T2, TE2>,
-    fn3: (value: T2) => AsyncResult<T3, TE3>,
+    fn1: () => Effect<T1, TE1>,
+    fn2: (value: T1) => Effect<T2, TE2>,
+    fn3: (value: T2) => Effect<T3, TE3>,
   ): Promise<T2>;
-  export function seqOrThrow(
-    ...fns: ((...args: any[]) => AsyncResult<any, any>)[]
+  export async function seqOrThrow(
+    ...fns: ((...args: any[]) => Effect<any, any>)[]
   ): Promise<any> {
-    const result = (seq as any)(...fns);
+    const result = await (seq as any)(...fns);
 
     return result.unwrapOrThrow();
   }

packages/fabric/core/types/merge-types.ts

@@ -0,0 +1,14 @@
+/**
+ * Merges two types A and B into a new type that contains all the properties of A and B.
+ * This is like `A & B`, but it also works when A or B are `never` or `void` and coalesces the result type
+ * to the non-never type.
+ * @example
+ * type AuB = MergeTypes<{ a: string }, { b: number }>; //{ a: string, b: number }
+ * const x: AuB = { a: "a", b: 1 };
+ *
+ * type JustB = MergeTypes<never, { b: number }>; //{ b: number }
+ * const y: JustB = { b: 1 };
+ */
+export type MergeTypes<A, B> = [A] extends [void] | [never] ? B
+  : [B] extends [void] | [never] ? A
+  : A & B;

packages/fabric/domain/events/event-store.ts

@@ -1,7 +1,8 @@
 import type {
-  AsyncResult,
+  Effect,
   MaybePromise,
   PosixDate,
+  UnexpectedError,
   UUID,
   VariantFromTag,
   VariantTag,
@@ -16,11 +17,11 @@ export interface EventStore<TEvents extends DomainEvent> {
    */
   append<T extends TEvents>(
     event: T,
-  ): AsyncResult<StoredEvent<T>, StoreQueryError>;
+  ): Effect<StoredEvent<T>, StoreQueryError | UnexpectedError>;
 
   getEventsFromStream(
     streamId: UUID,
-  ): AsyncResult<StoredEvent<TEvents>[], StoreQueryError>;
+  ): Effect<StoredEvent<TEvents>[], StoreQueryError>;
 
   subscribe<TEventKey extends TEvents[VariantTag]>(
     events: TEventKey[],

packages/fabric/domain/events/event.ts

@@ -1,6 +1,5 @@
 // deno-lint-ignore-file no-explicit-any
-import type { TaggedVariant, VariantTag } from "@fabric/core";
-import type { UUID } from "../../core/types/uuid.ts";
+import type { TaggedVariant, UUID, VariantTag } from "@fabric/core";
 
 /**
  * An event is a tagged variant with a payload and a timestamp.

packages/fabric/domain/models/field-parsers.ts

@@ -6,7 +6,7 @@ import {
   type VariantFromTag,
 } from "@fabric/core";
 import { isUUID, parseAndSanitizeString } from "@fabric/validations";
-import type { FieldDefinition, FieldToType } from "./index.ts";
+import { FieldDefinition, FieldToType } from "./fields.ts";
 
 export type FieldParsers = {
   [K in FieldDefinition["_tag"]]: FieldParser<

packages/fabric/domain/models/state-store.ts

@@ -1,4 +1,4 @@
-import type { AsyncResult } from "@fabric/core";
+import { Effect } from "@fabric/core";
 import type { StoreQueryError } from "../errors/query-error.ts";
 import type { ModelSchemaFromModels } from "./model-schema.ts";
 import type { Model, ModelToType } from "./model.ts";
@@ -15,5 +15,5 @@ export interface WritableStateStore<TModel extends Model>
   insertInto<T extends keyof ModelSchemaFromModels<TModel>>(
     collection: T,
     record: ModelToType<ModelSchemaFromModels<TModel>[T]>,
-  ): AsyncResult<void, StoreQueryError>;
+  ): Effect<void, StoreQueryError>;
 }

packages/fabric/domain/models/store-query/store-query.ts

@@ -1,10 +1,5 @@
 // deno-lint-ignore-file no-explicit-any
-import {
-  type AsyncResult,
-  type Keyof,
-  type Optional,
-  TaggedError,
-} from "@fabric/core";
+import { Effect, type Keyof, type Optional, TaggedError } from "@fabric/core";
 import type { StoreQueryError } from "../../errors/query-error.ts";
 import type { FilterOptions } from "./filter-options.ts";
 import type { OrderByOptions } from "./order-by-options.ts";
@@ -14,84 +9,84 @@ export interface StoreQuery<T> {
   orderBy(opts: OrderByOptions<T>): StoreLimitableQuery<T>;
   limit(limit: number, offset?: number): SelectableQuery<T>;
 
-  select(): AsyncResult<T[], StoreQueryError>;
+  select(): Effect<T[], StoreQueryError>;
   select<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>[], StoreQueryError>;
+  ): Effect<Pick<T, K>[], StoreQueryError>;
 
-  selectOne(): AsyncResult<Optional<T>, StoreQueryError>;
+  selectOne(): Effect<Optional<T>, StoreQueryError>;
   selectOne<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Optional<Pick<T, K>>, StoreQueryError>;
+  ): Effect<Optional<Pick<T, K>>, StoreQueryError>;
 
-  selectOneOrFail(): AsyncResult<T, StoreQueryError | NotFoundError>;
+  selectOneOrFail(): Effect<T, StoreQueryError | NotFoundError>;
   selectOneOrFail<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>, StoreQueryError | NotFoundError>;
+  ): Effect<Pick<T, K>, StoreQueryError | NotFoundError>;
 
-  assertNone(): AsyncResult<void, StoreQueryError | AlreadyExistsError>;
+  assertNone(): Effect<void, StoreQueryError | AlreadyExistsError>;
 }
 
 export interface StoreSortableQuery<T> {
   orderBy(opts: OrderByOptions<T>): StoreLimitableQuery<T>;
   limit(limit: number, offset?: number): SelectableQuery<T>;
 
-  select(): AsyncResult<T[], StoreQueryError>;
+  select(): Effect<T[], StoreQueryError>;
   select<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>[], StoreQueryError>;
+  ): Effect<Pick<T, K>[], StoreQueryError>;
 
-  selectOne(): AsyncResult<Optional<T>, StoreQueryError>;
+  selectOne(): Effect<Optional<T>, StoreQueryError>;
   selectOne<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Optional<Pick<T, K>>, StoreQueryError>;
+  ): Effect<Optional<Pick<T, K>>, StoreQueryError>;
 
-  selectOneOrFail(): AsyncResult<T, StoreQueryError | NotFoundError>;
+  selectOneOrFail(): Effect<T, StoreQueryError | NotFoundError>;
   selectOneOrFail<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>, StoreQueryError | NotFoundError>;
+  ): Effect<Pick<T, K>, StoreQueryError | NotFoundError>;
 
-  assertNone(): AsyncResult<void, StoreQueryError | AlreadyExistsError>;
+  assertNone(): Effect<void, StoreQueryError | AlreadyExistsError>;
 }
 
 export interface StoreLimitableQuery<T> {
   limit(limit: number, offset?: number): SelectableQuery<T>;
 
-  select(): AsyncResult<T[], StoreQueryError>;
+  select(): Effect<T[], StoreQueryError>;
   select<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>[], StoreQueryError>;
+  ): Effect<Pick<T, K>[], StoreQueryError>;
 
-  selectOne(): AsyncResult<Optional<T>, StoreQueryError>;
+  selectOne(): Effect<Optional<T>, StoreQueryError>;
   selectOne<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Optional<Pick<T, K>>, StoreQueryError>;
+  ): Effect<Optional<Pick<T, K>>, StoreQueryError>;
 
-  selectOneOrFail(): AsyncResult<T, StoreQueryError | NotFoundError>;
+  selectOneOrFail(): Effect<T, StoreQueryError | NotFoundError>;
   selectOneOrFail<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>, StoreQueryError | NotFoundError>;
+  ): Effect<Pick<T, K>, StoreQueryError | NotFoundError>;
 
-  assertNone(): AsyncResult<void, StoreQueryError | AlreadyExistsError>;
+  assertNone(): Effect<void, StoreQueryError | AlreadyExistsError>;
 }
 
 export interface SelectableQuery<T> {
-  select(): AsyncResult<T[], StoreQueryError>;
+  select(): Effect<T[], StoreQueryError>;
   select<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>[], StoreQueryError>;
+  ): Effect<Pick<T, K>[], StoreQueryError>;
 
-  selectOne(): AsyncResult<Optional<T>, StoreQueryError>;
+  selectOne(): Effect<Optional<T>, StoreQueryError>;
   selectOne<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Optional<Pick<T, K>>, StoreQueryError>;
+  ): Effect<Optional<Pick<T, K>>, StoreQueryError>;
 
-  selectOneOrFail(): AsyncResult<T, StoreQueryError | NotFoundError>;
+  selectOneOrFail(): Effect<T, StoreQueryError | NotFoundError>;
   selectOneOrFail<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>, StoreQueryError | NotFoundError>;
+  ): Effect<Pick<T, K>, StoreQueryError | NotFoundError>;
 
-  assertNone(): AsyncResult<void, StoreQueryError | AlreadyExistsError>;
+  assertNone(): Effect<void, StoreQueryError | AlreadyExistsError>;
 }
 
 export interface StoreQueryDefinition<K extends string = string> {

packages/fabric/domain/services/uuid-generator.mock.ts

@@ -1,4 +1,4 @@
-import type { UUID } from "../../core/types/uuid.ts";
+import type { UUID } from "@fabric/core";
 import type { UUIDGenerator } from "./uuid-generator.ts";
 
 export const UUIDGeneratorMock: UUIDGenerator = {

packages/fabric/domain/services/uuid-generator.ts

@@ -1,4 +1,4 @@
-import type { UUID } from "../../core/types/uuid.ts";
+import type { UUID } from "@fabric/core";
 
 export interface UUIDGenerator {
   generate(): UUID;

packages/fabric/domain/use-case/use-case.ts

@@ -1,4 +1,4 @@
-import type { AsyncResult, TaggedError } from "@fabric/core";
+import type { Effect, TaggedError } from "@fabric/core";
 
 /**
  * A use case is a piece of domain logic that can be executed.
@@ -9,8 +9,8 @@ export type UseCase<
   TOutput,
   TErrors extends TaggedError<string>,
 > = TPayload extends undefined
-  ? (dependencies: TDependencies) => AsyncResult<TOutput, TErrors>
+  ? (dependencies: TDependencies) => Effect<TOutput, TErrors>
   : (
     dependencies: TDependencies,
     payload: TPayload,
-  ) => AsyncResult<TOutput, TErrors>;
+  ) => Effect<TOutput, TErrors>;

packages/fabric/sqlite-store/events/event-store.test.ts

@@ -22,11 +22,11 @@ describe("Event Store", () => {
 
   beforeEach(async () => {
     store = new SQLiteEventStore(":memory:");
-    await store.migrate().orThrow();
+    await store.migrate().runOrThrow();
   });
 
   afterEach(async () => {
-    await store.close().orThrow();
+    await store.close().runOrThrow();
   });
 
   test("Should append an event", async () => {
@@ -39,9 +39,9 @@ describe("Event Store", () => {
       payload: { name: "test" },
     };
 
-    await store.append(userCreated).orThrow();
+    await store.append(userCreated).runOrThrow();
 
-    const events = await store.getEventsFromStream(newUUID).unwrapOrThrow();
+    const events = await store.getEventsFromStream(newUUID).runOrThrow();
 
     expect(events).toHaveLength(1);
 
@@ -69,7 +69,7 @@ describe("Event Store", () => {
 
     store.subscribe(["UserCreated"], subscriber);
 
-    await store.append(userCreated).orThrow();
+    await store.append(userCreated).runOrThrow();
 
     expect(subscriber).toHaveBeenCalledTimes(1);
     expect(subscriber).toHaveBeenCalledWith({

packages/fabric/sqlite-store/events/event-store.ts

@@ -1,9 +1,10 @@
 import {
-  AsyncResult,
+  Effect,
   JSONUtils,
   MaybePromise,
   PosixDate,
-  Run,
+  Result,
+  UnexpectedError,
   UUID,
   VariantTag,
 } from "@fabric/core";
@@ -32,8 +33,8 @@ export class SQLiteEventStore<TEvents extends DomainEvent>
     this.db = new SQLiteDatabase(dbPath);
   }
 
-  migrate(): AsyncResult<void, StoreQueryError> {
-    return AsyncResult.tryFrom(
+  migrate(): Effect<void, StoreQueryError> {
+    return Effect.tryFrom(
       () => {
         this.db.init();
         this.db.run(
@@ -54,8 +55,8 @@ export class SQLiteEventStore<TEvents extends DomainEvent>
 
   getEventsFromStream(
     streamId: UUID,
-  ): AsyncResult<StoredEvent<TEvents>[], StoreQueryError> {
-    return AsyncResult.tryFrom(
+  ): Effect<StoredEvent<TEvents>[], StoreQueryError> {
+    return Effect.tryFrom(
       () => {
         const events = this.db.allPrepared(
           `SELECT * FROM events WHERE streamId = $id`,
@@ -79,13 +80,13 @@ export class SQLiteEventStore<TEvents extends DomainEvent>
 
   append<T extends TEvents>(
     event: T,
-  ): AsyncResult<StoredEvent<T>, StoreQueryError> {
-    return Run.seq(
+  ): Effect<StoredEvent<T>, StoreQueryError | UnexpectedError> {
+    return Effect.seq(
       () => this.getLastVersion(event.streamId),
       (version) =>
-        AsyncResult.from(() => {
+        Effect.from(() => {
           this.streamVersions.set(event.streamId, version + 1n);
-          return version;
+          return Result.ok(version);
         }),
       (version) => this.storeEvent(event.streamId, version + 1n, event),
       (storedEvent) =>
@@ -93,15 +94,17 @@ export class SQLiteEventStore<TEvents extends DomainEvent>
     );
   }
 
-  private notifySubscribers(event: StoredEvent<TEvents>): AsyncResult<void> {
-    return AsyncResult.from(async () => {
+  private notifySubscribers(
+    event: StoredEvent<TEvents>,
+  ): Effect<void, UnexpectedError> {
+    return Effect.tryFrom(async () => {
       const subscribers = this.eventSubscribers.get(event[VariantTag]) || [];
       await Promise.all(subscribers.map((subscriber) => subscriber(event)));
-    });
+    }, (e) => new UnexpectedError(e.message));
   }
 
-  private getLastVersion(streamId: UUID): AsyncResult<bigint, StoreQueryError> {
-    return AsyncResult.tryFrom(
+  private getLastVersion(streamId: UUID): Effect<bigint, StoreQueryError> {
+    return Effect.tryFrom(
       () => {
         const { lastVersion } = this.db.onePrepared(
           `SELECT max(version) as lastVersion FROM events WHERE streamId = $id`,
@@ -132,8 +135,8 @@ export class SQLiteEventStore<TEvents extends DomainEvent>
     });
   }
 
-  close(): AsyncResult<void, StoreQueryError> {
-    return AsyncResult.tryFrom(
+  close(): Effect<void, StoreQueryError> {
+    return Effect.tryFrom(
       () => this.db.close(),
       (error) => new StoreQueryError(error.message),
     );
@@ -143,8 +146,8 @@ export class SQLiteEventStore<TEvents extends DomainEvent>
     streamId: UUID,
     version: bigint,
     event: T,
-  ): AsyncResult<StoredEvent<T>, StoreQueryError> {
-    return AsyncResult.tryFrom(
+  ): Effect<StoredEvent<T>, StoreQueryError> {
+    return Effect.tryFrom(
       () => {
         const storedEvent: StoredEvent<T> = {
           ...event,

packages/fabric/sqlite-store/state/query-builder.test.ts

@@ -20,26 +20,26 @@ describe("QueryBuilder", () => {
 
   beforeEach(async () => {
     stateStore = new SQLiteStateStore(":memory:", models);
-    await stateStore.migrate().unwrapOrThrow();
+    await stateStore.migrate().runOrThrow();
     await stateStore.insertInto("test", {
       id: UUIDGeneratorMock.generate(),
       name: "test1",
-    }).unwrapOrThrow();
+    }).runOrThrow();
     await stateStore.insertInto("test", {
       id: UUIDGeneratorMock.generate(),
       name: "test2",
-    }).unwrapOrThrow();
+    }).runOrThrow();
   });
 
   afterEach(async () => {
-    await stateStore.close().unwrapOrThrow();
+    await stateStore.close().runOrThrow();
   });
 
   test("select() after a where() should return valid results", async () => {
     const result = await stateStore.from("test").where({
       name: isLike("test%"),
     })
-      .select().unwrapOrThrow();
+      .select().runOrThrow();
     expect(result).toEqual([{
       id: expect.any(String),
       name: "test1",
@@ -51,7 +51,7 @@ describe("QueryBuilder", () => {
 
   test("selectOneOrFail() should return a single result", async () => {
     const result = await stateStore.from("test").where({ name: "test1" })
-      .selectOneOrFail().unwrapOrThrow();
+      .selectOneOrFail().runOrThrow();
     expect(result).toEqual({
       id: expect.any(String),
       name: "test1",
@@ -60,14 +60,14 @@ describe("QueryBuilder", () => {
 
   test("selectOneOrFail() should fail if no results are found", async () => {
     const error = await stateStore.from("test").where({ name: "not-found" })
-      .selectOneOrFail().unwrapErrorOrThrow();
+      .selectOneOrFail().failOrThrow();
 
     expect(error).toBeInstanceOf(NotFoundError);
   });
 
   test("selectOne() should return a single result", async () => {
     const result = await stateStore.from("test")
-      .selectOne().unwrapOrThrow();
+      .selectOne().runOrThrow();
 
     expect(result).toEqual({
       id: expect.any(String),
@@ -79,7 +79,7 @@ describe("QueryBuilder", () => {
     const result = await stateStore.from("test").where({
       name: "not-found",
     })
-      .selectOne().unwrapOrThrow();
+      .selectOne().runOrThrow();
 
     expect(result).toBeUndefined();
   });
@@ -87,14 +87,14 @@ describe("QueryBuilder", () => {
   test("assertNone() should succeed if no results are found", async () => {
     const result = await stateStore.from("test").where({
       name: "not-found",
-    }).assertNone().unwrapOrThrow();
+    }).assertNone().runOrThrow();
 
     expect(result).toBeUndefined();
   });
 
   test("assertNone() should fail if results are found", async () => {
     const error = await stateStore.from("test").where({ name: "test1" })
-      .assertNone().unwrapErrorOrThrow();
+      .assertNone().failOrThrow();
 
     expect(error).toBeInstanceOf(AlreadyExistsError);
   });

packages/fabric/sqlite-store/state/query-builder.ts

@@ -1,5 +1,5 @@
 // deno-lint-ignore-file no-explicit-any
-import { AsyncResult, Keyof, Optional } from "@fabric/core";
+import { Effect, Keyof, Optional } from "@fabric/core";
 import {
   AlreadyExistsError,
   FilterOptions,
@@ -47,12 +47,12 @@ export class QueryBuilder<T> implements StoreQuery<T> {
     });
   }
 
-  select(): AsyncResult<T[], StoreQueryError>;
+  select(): Effect<T[], StoreQueryError>;
   select<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>[], StoreQueryError>;
-  select<K extends Keyof<T>>(keys?: K[]): AsyncResult<any, StoreQueryError> {
-    return AsyncResult.tryFrom(
+  ): Effect<Pick<T, K>[], StoreQueryError>;
+  select<K extends Keyof<T>>(keys?: K[]): Effect<any, StoreQueryError> {
+    return Effect.tryFrom(
       () => {
         const [sql, params] = getSelectStatement(
           this.schema[this.query.from]!,
@@ -71,12 +71,12 @@ export class QueryBuilder<T> implements StoreQuery<T> {
     );
   }
 
-  selectOne(): AsyncResult<Optional<T>, StoreQueryError>;
+  selectOne(): Effect<Optional<T>, StoreQueryError>;
   selectOne<K extends Keyof<T>>(
     keys: K[],
-  ): AsyncResult<Optional<Pick<T, K>>, StoreQueryError>;
-  selectOne<K extends Keyof<T>>(keys?: K[]): AsyncResult<any, StoreQueryError> {
-    return AsyncResult.tryFrom(
+  ): Effect<Optional<Pick<T, K>>, StoreQueryError>;
+  selectOne<K extends Keyof<T>>(keys?: K[]): Effect<any, StoreQueryError> {
+    return Effect.tryFrom(
       async () => {
         const [stmt, params] = getSelectStatement(
           this.schema[this.query.from]!,
@@ -96,14 +96,14 @@ export class QueryBuilder<T> implements StoreQuery<T> {
     );
   }
 
-  selectOneOrFail(): AsyncResult<T, StoreQueryError | NotFoundError>;
+  selectOneOrFail(): Effect<T, StoreQueryError | NotFoundError>;
   selectOneOrFail<K extends Extract<keyof T, string>>(
     keys: K[],
-  ): AsyncResult<Pick<T, K>, StoreQueryError | NotFoundError>;
+  ): Effect<Pick<T, K>, StoreQueryError | NotFoundError>;
   selectOneOrFail<K extends Extract<keyof T, string>>(
     keys?: K[],
-  ): AsyncResult<any, StoreQueryError | NotFoundError> {
-    return AsyncResult.tryFrom(
+  ): Effect<any, StoreQueryError | NotFoundError> {
+    return Effect.tryFrom(
       async () => {
         const [stmt, params] = getSelectStatement(
           this.schema[this.query.from]!,
@@ -122,14 +122,14 @@ export class QueryBuilder<T> implements StoreQuery<T> {
       (err) => new StoreQueryError(err.message),
     ).flatMap((result) => {
       if (!result) {
-        return AsyncResult.failWith(new NotFoundError());
+        return Effect.failWith(new NotFoundError());
       }
-      return AsyncResult.ok(result);
+      return Effect.ok(result);
     });
   }
 
-  assertNone(): AsyncResult<void, StoreQueryError | AlreadyExistsError> {
-    return AsyncResult.tryFrom(
+  assertNone(): Effect<void, StoreQueryError | AlreadyExistsError> {
+    return Effect.tryFrom(
       async () => {
         const [stmt, params] = getSelectStatement(
           this.schema[this.query.from]!,
@@ -146,9 +146,9 @@ export class QueryBuilder<T> implements StoreQuery<T> {
       (err) => new StoreQueryError(err.message),
     ).flatMap((result) => {
       if (result) {
-        return AsyncResult.failWith(new AlreadyExistsError());
+        return Effect.failWith(new AlreadyExistsError());
       }
-      return AsyncResult.ok();
+      return Effect.ok();
     });
   }
 }

packages/fabric/sqlite-store/state/state-store.test.ts

@@ -1,4 +1,4 @@
-import { Run } from "@fabric/core";
+import { Effect, Run } from "@fabric/core";
 import { Field, isLike, Model } from "@fabric/domain";
 import { UUIDGeneratorMock } from "@fabric/domain/mocks";
 import { afterEach, beforeEach, describe, expect, test } from "@fabric/testing";
@@ -20,11 +20,11 @@ describe("State Store", () => {
 
   beforeEach(async () => {
     store = new SQLiteStateStore(":memory:", models);
-    await store.migrate().orThrow();
+    await store.migrate().runOrThrow();
   });
 
   afterEach(async () => {
-    await store.close().orThrow();
+    await store.close().runOrThrow();
   });
 
   test("should insert a record", async () => {
@@ -33,7 +33,7 @@ describe("State Store", () => {
     await store.insertInto("users", {
       id: newUUID,
       name: "test",
-    }).orThrow();
+    }).runOrThrow();
   });
 
   test("should select all records", async () => {
@@ -42,9 +42,9 @@ describe("State Store", () => {
     await store.insertInto("users", {
       name: "test",
       id: newUUID,
-    }).orThrow();
+    }).runOrThrow();
 
-    const result = await store.from("users").select().unwrapOrThrow();
+    const result = await store.from("users").select().runOrThrow();
 
     // expectTypeOf(result).toEqualTypeOf<
     //   {
@@ -64,7 +64,7 @@ describe("State Store", () => {
   test("should select records with a filter", async () => {
     const newUUID = UUIDGeneratorMock.generate();
 
-    await Run.seqOrThrow(
+    await Effect.seq(
       () =>
         store.insertInto("users", {
           name: "test",
@@ -80,14 +80,14 @@ describe("State Store", () => {
           name: "anotherName2",
           id: UUIDGeneratorMock.generate(),
         }),
-    );
+    ).runOrThrow();
 
     const result = await store
       .from("users")
       .where({
         name: isLike("te%"),
       })
-      .select().unwrapOrThrow();
+      .select().runOrThrow();
 
     // expectTypeOf(result).toEqualTypeOf<
     //   {
@@ -107,17 +107,20 @@ describe("State Store", () => {
   test("should update a record", async () => {
     const newUUID = UUIDGeneratorMock.generate();
 
-    await store.insertInto("users", {
-      name: "test",
-      id: newUUID,
-    }).orThrow();
-
-    await store.update("users", newUUID, {
-      name: "updated",
-    }).orThrow();
+    await Effect.seq(
+      () =>
+        store.insertInto("users", {
+          name: "test",
+          id: newUUID,
+        }),
+      () =>
+        store.update("users", newUUID, {
+          name: "updated",
+        }),
+    ).runOrThrow();
 
     const result = await store.from("users").where({ id: newUUID }).selectOne()
-      .unwrapOrThrow();
+      .runOrThrow();
 
     expect(result).toEqual({
       id: newUUID,
@@ -128,34 +131,37 @@ describe("State Store", () => {
   test("should delete a record", async () => {
     const newUUID = UUIDGeneratorMock.generate();
 
-    await store.insertInto("users", {
-      name: "test",
-      id: newUUID,
-    }).orThrow();
-
-    await store.delete("users", newUUID).orThrow();
+    await Effect.seq(
+      () =>
+        store.insertInto("users", {
+          name: "test",
+          id: newUUID,
+        }),
+      () => store.delete("users", newUUID),
+    ).runOrThrow();
 
     const result = await store.from("users").where({ id: newUUID }).selectOne()
-      .unwrapOrThrow();
+      .runOrThrow();
 
     expect(result).toBeUndefined();
   });
 
-  //test for inserting into a collection with a reference
-
   test("should insert a record with a reference", async () => {
     const newUUID = UUIDGeneratorMock.generate();
     const ownerUUID = UUIDGeneratorMock.generate();
 
-    await store.insertInto("users", {
-      id: ownerUUID,
-      name: "test",
-    }).orThrow();
-
-    await store.insertInto("demo", {
-      id: newUUID,
-      value: 1.0,
-      owner: ownerUUID,
-    }).orThrow();
+    await Run.seqOrThrow(
+      () =>
+        store.insertInto("users", {
+          id: ownerUUID,
+          name: "test",
+        }),
+      () =>
+        store.insertInto("demo", {
+          id: newUUID,
+          value: 1.0,
+          owner: ownerUUID,
+        }),
+    );
   });
 });

packages/fabric/sqlite-store/state/state-store.ts

@@ -1,4 +1,4 @@
-import { AsyncResult, UnexpectedError, UUID } from "@fabric/core";
+import { Effect, UnexpectedError, UUID } from "@fabric/core";
 import {
   Model,
   ModelSchemaFromModels,
@@ -37,10 +37,10 @@ export class SQLiteStateStore<TModel extends Model>
   insertInto<T extends keyof ModelSchemaFromModels<TModel>>(
     collection: T,
     record: ModelToType<ModelSchemaFromModels<TModel>[T]>,
-  ): AsyncResult<void, StoreQueryError> {
+  ): Effect<void, StoreQueryError> {
     const model = this.schema[collection];
 
-    return AsyncResult.tryFrom(
+    return Effect.tryFrom(
       () => {
         this.db.runPrepared(
           `INSERT INTO ${model.name} (${
@@ -67,10 +67,10 @@ export class SQLiteStateStore<TModel extends Model>
     collection: T,
     id: UUID,
     record: Partial<ModelToType<ModelSchemaFromModels<TModel>[T]>>,
-  ): AsyncResult<void, StoreQueryError> {
+  ): Effect<void, StoreQueryError> {
     const model = this.schema[collection];
 
-    return AsyncResult.tryFrom(
+    return Effect.tryFrom(
       () => {
         const params = recordToSQLParamRecord(model, {
           ...record,
@@ -92,10 +92,10 @@ export class SQLiteStateStore<TModel extends Model>
   delete<T extends keyof ModelSchemaFromModels<TModel>>(
     collection: T,
     id: UUID,
-  ): AsyncResult<void, StoreQueryError> {
+  ): Effect<void, StoreQueryError> {
     const model = this.schema[collection];
 
-    return AsyncResult.tryFrom(
+    return Effect.tryFrom(
       () => {
         this.db.runPrepared(
           `DELETE FROM ${model.name} WHERE id = ${keyToParamKey("id")}`,
@@ -108,8 +108,8 @@ export class SQLiteStateStore<TModel extends Model>
     );
   }
 
-  migrate(): AsyncResult<void, StoreQueryError> {
-    return AsyncResult.tryFrom(
+  migrate(): Effect<void, StoreQueryError> {
+    return Effect.tryFrom(
       async () => {
         this.db.init();
         await this.db.withTransaction(() => {
@@ -124,7 +124,10 @@ export class SQLiteStateStore<TModel extends Model>
     );
   }
 
-  close(): AsyncResult<void, UnexpectedError> {
-    return AsyncResult.from(() => this.db.close());
+  close(): Effect<void, UnexpectedError> {
+    return Effect.tryFrom(
+      () => this.db.close(),
+      (e) => new UnexpectedError(e.message),
+    );
   }
 }