Move to nodejs and also lots of significant refactoring that should've been broken up but idgaf

1 files changed, 43 insertions, 29 deletions

diff --git a/u/trace/util.ts b/u/trace/util.ts
index db1db63..ec67571 100644
--- a/u/trace/util.ts
+++ b/u/trace/util.ts
@@ -1,45 +1,59 @@
 import {
-    ANSI,
+    IEither,
+    IMetric,
+    isEither,
+    ITraceable,
+    ITraceWith,
+    LogLevel,
+    ResultMetric,
     type Callable,
-    type IMetric,
     type ITraceableMapper,
-    type ITraceableTuple,
-    type MetricsTraceSupplier,
 } from '@emprespresso/pengueno';
 
 export class TraceUtil {
-    static withTrace<T, Trace>(
-        trace: string,
-        ansi?: Array<keyof typeof ANSI>,
-    ): ITraceableMapper<T, ITraceableTuple<T, Trace | Array<Trace>>, Trace> {
-        if (ansi) {
-            return (t) => [t.get(), `${ansi.join('')}${trace}${ANSI.RESET}`];
-        }
-        return (t) => [t.get(), trace];
+    static promiseify<T, U, Trace>(
+        mapper: ITraceableMapper<T, U, Trace>,
+    ): ITraceableMapper<Promise<T>, Promise<U>, Trace> {
+        return (traceablePromise) =>
+            traceablePromise.flatMapAsync(async (t) => t.move(await t.get()).map(mapper)).get();
     }
 
-    static withMetricTrace<T, Trace extends MetricsTraceSupplier>(
-        metric: IMetric,
-    ): ITraceableMapper<T, ITraceableTuple<T, Trace | Array<Trace>>, Trace> {
-        return (t) => [t.get(), metric as Trace];
+    static traceResultingEither<TErr, TOk, Trace>(
+        metric?: ResultMetric,
+        warnOnFailure = false,
+    ): ITraceableMapper<IEither<TErr, TOk>, ITraceable<IEither<TErr, TOk>, Trace>, Trace> {
+        return (t) => {
+            if (metric)
+                t.trace.trace(
+                    t.get().fold(
+                        (_err) => <Trace>(warnOnFailure ? metric.warn : metric.failure),
+                        (_ok) => <Trace>metric.success,
+                    ),
+                );
+            return t.traceScope((_t) =>
+                _t.get().fold(
+                    (_err) => <Trace>(warnOnFailure ? LogLevel.WARN : LogLevel.ERROR),
+                    (_ok) => <Trace>LogLevel.INFO,
+                ),
+            );
+        };
     }
 
-    static withFunctionTrace<F extends Callable, T, Trace>(
-        f: F,
-    ): ITraceableMapper<T, ITraceableTuple<T, Trace | Array<Trace>>, Trace> {
-        return TraceUtil.withTrace(`fn.${f.name}`);
+    static withTrace<T, Trace, _Trace extends ITraceWith<Trace>>(
+        trace: _Trace,
+    ): ITraceableMapper<T, ITraceable<T, Trace>, Trace> {
+        return (t) => t.traceScope(() => <Trace>trace);
     }
 
-    static withClassTrace<C extends object, T, Trace>(
-        c: C,
-    ): ITraceableMapper<T, ITraceableTuple<T, Trace | Array<Trace>>, Trace> {
-        return TraceUtil.withTrace(`class.${c.constructor.name}`);
+    static withMetricTrace<T, Trace>(metric: IMetric): ITraceableMapper<T, ITraceable<T, Trace>, Trace> {
+        return TraceUtil.withTrace(<Trace>metric);
     }
 
-    static promiseify<T, U, Trace>(
-        mapper: ITraceableMapper<T, U, Trace>,
-    ): ITraceableMapper<Promise<T>, Promise<U>, Trace> {
-        return (traceablePromise) =>
-            traceablePromise.flatMapAsync(async (t) => t.move(await t.get()).map(mapper)).get();
+    static withFunctionTrace<F extends Callable, T, Trace>(f: F): ITraceableMapper<T, ITraceable<T, Trace>, Trace> {
+        return TraceUtil.withTrace(<Trace>`fn.${f.name}`);
+    }
+
+    static withClassTrace<C extends object, T, Trace>(c: C): ITraceableMapper<T, ITraceable<T, Trace>, Trace> {
+        return TraceUtil.withTrace(<Trace>`class.${c.constructor.name}`);
     }
 }