summaryrefslogtreecommitdiff
path: root/u/trace/util.ts
diff options
context:
space:
mode:
authorElizabeth Hunt <me@liz.coffee>2025-07-27 18:50:33 -0700
committerElizabeth Hunt <me@liz.coffee>2025-07-27 19:31:06 -0700
commit7aa11b7a8abacf81dec20fff21216df35d333756 (patch)
tree40f6a76c37412cf1c5a67f99a4ee30e3aae863c9 /u/trace/util.ts
parente4df72cd446270cf867ec308995a05e21b3aa601 (diff)
downloadci-7aa11b7a8abacf81dec20fff21216df35d333756.tar.gz
ci-7aa11b7a8abacf81dec20fff21216df35d333756.zip
Pulls in pengueno from npm
Diffstat (limited to 'u/trace/util.ts')
-rw-r--r--u/trace/util.ts59
1 files changed, 0 insertions, 59 deletions
diff --git a/u/trace/util.ts b/u/trace/util.ts
deleted file mode 100644
index ec67571..0000000
--- a/u/trace/util.ts
+++ /dev/null
@@ -1,59 +0,0 @@
-import {
- IEither,
- IMetric,
- isEither,
- ITraceable,
- ITraceWith,
- LogLevel,
- ResultMetric,
- type Callable,
- type ITraceableMapper,
-} from '@emprespresso/pengueno';
-
-export class TraceUtil {
- 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 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 withTrace<T, Trace, _Trace extends ITraceWith<Trace>>(
- trace: _Trace,
- ): ITraceableMapper<T, ITraceable<T, Trace>, Trace> {
- return (t) => t.traceScope(() => <Trace>trace);
- }
-
- static withMetricTrace<T, Trace>(metric: IMetric): ITraceableMapper<T, ITraceable<T, Trace>, Trace> {
- return TraceUtil.withTrace(<Trace>metric);
- }
-
- 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}`);
- }
-}