From dc4ac7742690f8f2bd759d57108ac4455e717fe9 Mon Sep 17 00:00:00 2001
From: Elizabeth Hunt <me@liz.coffee>
Date: Sun, 20 Jul 2025 13:03:39 -0700
Subject: Mount src directory from path on host running worker container

---
 u/types/fn/either.ts | 56 ++++++++++++++++++++++++++++++++++------------------
 1 file changed, 37 insertions(+), 19 deletions(-)

(limited to 'u/types/fn/either.ts')

diff --git a/u/types/fn/either.ts b/u/types/fn/either.ts
index aa67d41..80f32b4 100644
--- a/u/types/fn/either.ts
+++ b/u/types/fn/either.ts
@@ -1,18 +1,36 @@
-import { BiMapper, IOptional, type Mapper, Optional, type Supplier, Tagged, isTagged } from '@emprespresso/pengueno';
+import {
+    BiMapper,
+    IOptional,
+    type Mapper,
+    Optional,
+    Predicate,
+    type Supplier,
+    Tagged,
+    isTagged,
+} from '@emprespresso/pengueno';
 
 export const IEitherTag = 'IEither' as const;
 export type IEitherTag = typeof IEitherTag;
 export const isEither = <E, T>(o: unknown): o is IEither<E, T> => isTagged(o, IEitherTag);
 export interface IEither<E, T> extends Tagged<IEitherTag> {
-    readonly mapBoth: <_E, _T>(errBranch: Mapper<E, _E>, okBranch: Mapper<T, _T>) => IEither<_E, _T>;
-    readonly fold: <_T>(leftFolder: Mapper<E, _T>, rightFolder: Mapper<T, _T>) => _T;
     readonly left: Supplier<IOptional<E>>;
     readonly right: Supplier<IOptional<T>>;
-    readonly moveRight: <_T>(t: _T) => IEither<E, _T>;
+
     readonly mapRight: <_T>(mapper: Mapper<T, _T>) => IEither<E, _T>;
+    readonly filter: (mapper: Predicate<T>) => IEither<E, T>;
     readonly mapLeft: <_E>(mapper: Mapper<E, _E>) => IEither<_E, T>;
+    readonly mapBoth: <_E, _T>(errBranch: Mapper<E, _E>, okBranch: Mapper<T, _T>) => IEither<_E, _T>;
+
     readonly flatMap: <_T>(mapper: Mapper<T, IEither<E, _T>>) => IEither<E, _T>;
     readonly flatMapAsync: <_T>(mapper: Mapper<T, Promise<IEither<E, _T>>>) => Promise<IEither<E, _T>>;
+
+    readonly moveRight: <_T>(t: _T) => IEither<E, _T>;
+    readonly fold: <_T>(leftFolder: Mapper<E, _T>, rightFolder: Mapper<T, _T>) => _T;
+    readonly joinRight: <O, _T>(other: IEither<E, O>, mapper: BiMapper<O, T, _T>) => IEither<E, _T>;
+    readonly joinRightAsync: <O, _T>(
+        other: Supplier<Promise<IEither<E, O>>> | Promise<IEither<E, O>>,
+        mapper: BiMapper<O, T, _T>,
+    ) => Promise<IEither<E, _T>>;
 }
 
 const ELeftTag = 'E.Left' as const;
@@ -62,6 +80,11 @@ export class Either<E, T> extends _Tagged implements IEither<E, T> {
         return Either.left<E, _T>(this.self.err);
     }
 
+    public filter(mapper: Predicate<T>): IEither<E, T> {
+        if (isLeft(this.self)) return Either.left<E, T>(this.self.err);
+        return Either.fromFailable<E, T>(() => this.right().filter(mapper).get());
+    }
+
     public async flatMapAsync<_T>(mapper: Mapper<T, Promise<IEither<E, _T>>>): Promise<IEither<E, _T>> {
         if (isLeft(this.self)) return Promise.resolve(Either.left(this.self.err));
         return await mapper(this.self.ok).catch((err) => Either.left(err));
@@ -82,23 +105,18 @@ export class Either<E, T> extends _Tagged implements IEither<E, T> {
         return Optional.none();
     }
 
-    static joinRight<K, E, T>(
-        arr: Array<K>,
-        mapper: BiMapper<K, T, IEither<E, T>>,
-        init: IEither<E, T>,
-    ): IEither<E, T> {
-        return arr.reduce((acc: IEither<E, T>, x: K) => acc.flatMap((t) => mapper(x, t)), init);
+    public joinRight<O, _T>(other: IEither<E, O>, mapper: BiMapper<O, T, _T>) {
+        return this.flatMap((t) => other.mapRight((o) => mapper(o, t)));
     }
 
-    static joinRightAsync<K, E, T>(
-        arr: Array<K>,
-        mapper: BiMapper<K, T, Promise<IEither<E, T>>>,
-        init: IEither<E, T>,
-    ): Promise<IEither<E, T>> {
-        return arr.reduce(
-            (acc: Promise<IEither<E, T>>, x: K) => acc.then((res) => res.flatMapAsync((t) => mapper(x, t))),
-            Promise.resolve(init),
-        );
+    public joinRightAsync<O, _T>(
+        other: Supplier<Promise<IEither<E, O>>> | Promise<IEither<E, O>>,
+        mapper: BiMapper<O, T, _T>,
+    ) {
+        return this.flatMapAsync(async (t) => {
+            const o = typeof other === 'function' ? other() : other;
+            return o.then((other) => other.mapRight((o) => mapper(o, t)));
+        });
     }
 
     static left<E, T>(e: E): IEither<E, T> {
-- 
cgit v1.2.3-70-g09d2