Adds npm packpub script

13 files changed, 1858 insertions, 452 deletions

diff --git a/.ci/ci.cjs b/.ci/ci.cjs
index f8a5e2b..95f4ff9 100755
--- a/.ci/ci.cjs
+++ b/.ci/ci.cjs
@@ -1,488 +1,1752 @@
 #!/usr/bin/env node
 "use strict";
-
-// ../u/leftpadesque/debug.ts
-var _hasEnv = true;
-var _env = _hasEnv && (process.env.ENVIRONMENT ?? "").toLowerCase().includes("prod") ? "production" : "development";
-var isProd = () => _env === "production";
-var _debug = !isProd() || _hasEnv && ["y", "t"].some((process.env.DEBUG ?? "").toLowerCase().startsWith);
-var isDebug = () => _debug;
-
-// ../u/leftpadesque/memoize.ts
-var memoize = (fn) => {
-  const cache = /* @__PURE__ */ new Map();
-  return (...args) => {
-    const key = JSON.stringify(args);
-    if (cache.has(key)) {
-      return cache.get(key);
-    }
-    const res = fn.apply(args);
-    cache.set(key, res);
-    return res;
-  };
+var __create = Object.create;
+var __defProp = Object.defineProperty;
+var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
+var __getOwnPropNames = Object.getOwnPropertyNames;
+var __getProtoOf = Object.getPrototypeOf;
+var __hasOwnProp = Object.prototype.hasOwnProperty;
+var __commonJS = (cb, mod) => function __require() {
+  return mod || (0, cb[__getOwnPropNames(cb)[0]])((mod = { exports: {} }).exports, mod), mod.exports;
 };
-
-// ../u/trace/itrace.ts
-var TraceableImpl = class _TraceableImpl {
-  constructor(item, trace) {
-    this.item = item;
-    this.trace = trace;
-  }
-  map(mapper) {
-    const result = mapper(this);
-    return new _TraceableImpl(result, this.trace);
-  }
-  coExtend(mapper) {
-    const results = mapper(this);
-    return Array.from(results).map((result) => this.move(result));
-  }
-  flatMap(mapper) {
-    return mapper(this);
-  }
-  flatMapAsync(mapper) {
-    return new _TraceableImpl(
-      mapper(this).then((t) => t.get()),
-      this.trace
-    );
-  }
-  traceScope(mapper) {
-    return new _TraceableImpl(this.get(), this.trace.traceScope(mapper(this)));
-  }
-  peek(peek) {
-    peek(this);
-    return this;
-  }
-  move(t) {
-    return this.map(() => t);
-  }
-  bimap(mapper) {
-    const { item, trace: _trace } = mapper(this);
-    return this.move(item).traceScope(() => _trace);
-  }
-  get() {
-    return this.item;
+var __copyProps = (to, from, except, desc) => {
+  if (from && typeof from === "object" || typeof from === "function") {
+    for (let key of __getOwnPropNames(from))
+      if (!__hasOwnProp.call(to, key) && key !== except)
+        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
   }
+  return to;
 };
+var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__getProtoOf(mod)) : {}, __copyProps(
+  // If the importer is in node compatibility mode or this is not an ESM
+  // file that has been converted to a CommonJS file using a Babel-
+  // compatible transform (i.e. "__esModule" has not been set), then set
+  // "default" to the CommonJS "module.exports" for node compatibility.
+  isNodeMode || !mod || !mod.__esModule ? __defProp(target, "default", { value: mod, enumerable: true }) : target,
+  mod
+));
 
-// ../u/trace/metric/emittable.ts
-var EmittableMetric = class {
-  constructor(name, unit) {
-    this.name = name;
-    this.unit = unit;
-  }
-  withValue(value) {
-    return {
-      name: this.name,
-      unit: this.unit,
-      emissionTimestamp: Date.now(),
-      value,
-      _tag: MetricValueTag
+// ../node_modules/@emprespresso/pengueno/dist/leftpadesque/prepend.js
+var require_prepend = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/leftpadesque/prepend.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.prependWith = void 0;
+    var prependWith = (arr, prep) => Array(arr.length * 2).fill(0).map((_, i) => i % 2 === 0).map((isPrep, i) => isPrep ? prep : arr[Math.floor(i / 2)]);
+    exports2.prependWith = prependWith;
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/leftpadesque/debug.js
+var require_debug = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/leftpadesque/debug.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.isDebug = exports2.isProd = void 0;
+    var _hasEnv = true;
+    var _env = _hasEnv && (process.env.ENVIRONMENT ?? "").toLowerCase().includes("prod") ? "production" : "development";
+    var isProd = () => _env === "production";
+    exports2.isProd = isProd;
+    var _debug = !(0, exports2.isProd)() || _hasEnv && ["y", "t"].some((process.env.DEBUG ?? "").toLowerCase().startsWith);
+    var isDebug = () => _debug;
+    exports2.isDebug = isDebug;
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/leftpadesque/memoize.js
+var require_memoize = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/leftpadesque/memoize.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.memoize = void 0;
+    var memoize = (fn) => {
+      const cache = /* @__PURE__ */ new Map();
+      return (...args) => {
+        const key = JSON.stringify(args);
+        if (cache.has(key)) {
+          return cache.get(key);
+        }
+        const res = fn(...args);
+        cache.set(key, res);
+        return res;
+      };
     };
+    exports2.memoize = memoize;
   }
-};
+});
 
-// ../u/trace/metric/metric.ts
-var _Tagged = class {
-  constructor(_tag = IMetricTag) {
-    this._tag = _tag;
-  }
-};
-var Metric = class _Metric extends _Tagged {
-  constructor(name, parent = void 0, count = new EmittableMetric(_Metric.join(name, "count"), "COUNT" /* COUNT */), time = new EmittableMetric(_Metric.join(name, "time"), "MILLISECONDS" /* MILLISECONDS */)) {
-    super();
-    this.name = name;
-    this.parent = parent;
-    this.count = count;
-    this.time = time;
-  }
-  static DELIM = ".";
-  child(_name) {
-    const childName = _Metric.join(this.name, _name);
-    return new _Metric(childName, this);
-  }
-  asResult() {
-    return ResultMetric.from(this);
+// ../node_modules/@emprespresso/pengueno/dist/leftpadesque/index.js
+var require_leftpadesque = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/leftpadesque/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_prepend(), exports2);
+    __exportStar(require_debug(), exports2);
+    __exportStar(require_memoize(), exports2);
   }
-  static join(...name) {
-    return name.join(_Metric.DELIM);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/types/misc.js
+var require_misc = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/misc.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
   }
-  static fromName(name) {
-    return new _Metric(name);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/types/object.js
+var require_object = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/object.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.isObject = void 0;
+    var isObject3 = (o) => typeof o === "object" && !Array.isArray(o) && !!o;
+    exports2.isObject = isObject3;
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/types/tagged.js
+var require_tagged = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/tagged.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.isTagged = void 0;
+    var index_1 = require_types();
+    var isTagged = (o, tag) => !!((0, index_1.isObject)(o) && "_tag" in o && o._tag === tag);
+    exports2.isTagged = isTagged;
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/types/fn/callable.js
+var require_callable = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/fn/callable.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
   }
-};
-var ResultMetric = class _ResultMetric extends Metric {
-  constructor(name, parent = void 0, failure, success, warn) {
-    super(name, parent);
-    this.name = name;
-    this.parent = parent;
-    this.failure = failure;
-    this.success = success;
-    this.warn = warn;
-  }
-  static from(metric) {
-    const failure = metric.child("failure");
-    const success = metric.child("success");
-    const warn = metric.child("warn");
-    return new _ResultMetric(metric.name, metric.parent, failure, success, warn);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/types/fn/optional.js
+var require_optional = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/fn/optional.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.Optional = exports2.IOptionalEmptyError = exports2.isOptional = exports2.IOptionalTag = void 0;
+    var pengueno_1 = require_dist();
+    exports2.IOptionalTag = "IOptional";
+    var isOptional = (o) => (0, pengueno_1.isTagged)(o, exports2.IOptionalTag);
+    exports2.isOptional = isOptional;
+    var IOptionalEmptyError = class extends Error {
+    };
+    exports2.IOptionalEmptyError = IOptionalEmptyError;
+    var OSomeTag = "O.Some";
+    var ONoneTag = "O.None";
+    var isNone = (o) => (0, pengueno_1.isTagged)(o, ONoneTag);
+    var isSome = (o) => (0, pengueno_1.isTagged)(o, OSomeTag);
+    var _Tagged = class {
+      _tag;
+      constructor(_tag = exports2.IOptionalTag) {
+        this._tag = _tag;
+      }
+    };
+    var Optional = class _Optional extends _Tagged {
+      self;
+      constructor(self) {
+        super();
+        this.self = self;
+      }
+      move(t) {
+        return this.map(() => t);
+      }
+      orSome(supplier) {
+        if (isNone(this.self))
+          return _Optional.from(supplier());
+        return this;
+      }
+      get() {
+        if (isNone(this.self))
+          throw new IOptionalEmptyError("called get() on None optional");
+        return this.self.value;
+      }
+      filter(mapper) {
+        if (isNone(this.self) || !mapper(this.self.value))
+          return _Optional.none();
+        return _Optional.some(this.self.value);
+      }
+      map(mapper) {
+        if (isNone(this.self))
+          return _Optional.none();
+        return _Optional.from(mapper(this.self.value));
+      }
+      flatMap(mapper) {
+        if (isNone(this.self))
+          return _Optional.none();
+        return _Optional.from(mapper(this.self.value)).orSome(() => _Optional.none()).get();
+      }
+      present() {
+        return isSome(this.self);
+      }
+      *[Symbol.iterator]() {
+        if (isSome(this.self))
+          yield this.self.value;
+      }
+      static some(value) {
+        return new _Optional({ value, _tag: OSomeTag });
+      }
+      static _none = new _Optional({ _tag: ONoneTag });
+      static none() {
+        return this._none;
+      }
+      static from(value) {
+        if (value === null || value === void 0)
+          return _Optional.none();
+        return _Optional.some(value);
+      }
+    };
+    exports2.Optional = Optional;
   }
-};
+});
 
-// ../u/trace/metric/trace.ts
-var MetricsTrace = class _MetricsTrace {
-  constructor(metricConsumer, activeTraces = /* @__PURE__ */ new Map(), completedTraces = /* @__PURE__ */ new Set()) {
-    this.metricConsumer = metricConsumer;
-    this.activeTraces = activeTraces;
-    this.completedTraces = completedTraces;
-  }
-  traceScope(trace) {
-    const now = Date.now();
-    const metricsToTrace = (Array.isArray(trace) ? trace : [trace]).filter(isIMetric);
-    const initialTraces = new Map(metricsToTrace.map((metric) => [metric, now]));
-    return new _MetricsTrace(this.metricConsumer, initialTraces);
-  }
-  trace(metrics) {
-    if (!metrics || typeof metrics === "string") {
-      return this;
-    }
-    const now = Date.now();
-    const allMetrics = Array.isArray(metrics) ? metrics : [metrics];
-    const valuesToEmit = allMetrics.filter(isMetricValue);
-    const traceableMetrics = allMetrics.filter(isIMetric);
-    const metricsToStart = traceableMetrics.filter((m) => !this.activeTraces.has(m));
-    const metricsToEnd = traceableMetrics.filter((m) => this.activeTraces.has(m) && !this.completedTraces.has(m));
-    const endedMetricValues = metricsToEnd.flatMap((metric) => [
-      metric.count.withValue(1),
-      metric.time.withValue(now - this.activeTraces.get(metric))
-    ]);
-    const allMetricsToEmit = [...valuesToEmit, ...endedMetricValues];
-    if (allMetricsToEmit.length > 0) {
-      this.metricConsumer(allMetricsToEmit);
-    }
-    const nextActiveTraces = new Map([
-      ...this.activeTraces,
-      ...metricsToStart.map((m) => [m, now])
-    ]);
-    const nextCompletedTraces = /* @__PURE__ */ new Set([...this.completedTraces, ...metricsToEnd]);
-    return new _MetricsTrace(this.metricConsumer, nextActiveTraces, nextCompletedTraces);
+// ../node_modules/@emprespresso/pengueno/dist/types/fn/either.js
+var require_either = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/fn/either.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.Either = exports2.isRight = exports2.isLeft = exports2.isEither = exports2.IEitherTag = void 0;
+    var pengueno_1 = require_dist();
+    exports2.IEitherTag = "IEither";
+    var isEither = (o) => (0, pengueno_1.isTagged)(o, exports2.IEitherTag);
+    exports2.isEither = isEither;
+    var ELeftTag = "E.Left";
+    var isLeft = (o) => (0, pengueno_1.isTagged)(o, ELeftTag);
+    exports2.isLeft = isLeft;
+    var ERightTag = "E.Right";
+    var isRight = (o) => (0, pengueno_1.isTagged)(o, ERightTag);
+    exports2.isRight = isRight;
+    var _Tagged = class {
+      _tag;
+      constructor(_tag = exports2.IEitherTag) {
+        this._tag = _tag;
+      }
+    };
+    var Either2 = class _Either extends _Tagged {
+      self;
+      constructor(self) {
+        super();
+        this.self = self;
+      }
+      moveRight(t) {
+        return this.mapRight(() => t);
+      }
+      mapBoth(errBranch, okBranch) {
+        if ((0, exports2.isLeft)(this.self))
+          return _Either.left(errBranch(this.self.err));
+        return _Either.right(okBranch(this.self.ok));
+      }
+      mapRight(mapper) {
+        if ((0, exports2.isRight)(this.self))
+          return _Either.right(mapper(this.self.ok));
+        return _Either.left(this.self.err);
+      }
+      mapLeft(mapper) {
+        if ((0, exports2.isLeft)(this.self))
+          return _Either.left(mapper(this.self.err));
+        return _Either.right(this.self.ok);
+      }
+      flatMap(mapper) {
+        if ((0, exports2.isRight)(this.self))
+          return mapper(this.self.ok);
+        return _Either.left(this.self.err);
+      }
+      filter(mapper) {
+        if ((0, exports2.isLeft)(this.self))
+          return _Either.left(this.self.err);
+        return _Either.fromFailable(() => this.right().filter(mapper).get());
+      }
+      async flatMapAsync(mapper) {
+        if ((0, exports2.isLeft)(this.self))
+          return Promise.resolve(_Either.left(this.self.err));
+        return await mapper(this.self.ok).catch((err) => _Either.left(err));
+      }
+      fold(leftFolder, rightFolder) {
+        if ((0, exports2.isLeft)(this.self))
+          return leftFolder(this.self.err);
+        return rightFolder(this.self.ok);
+      }
+      left() {
+        if ((0, exports2.isLeft)(this.self))
+          return pengueno_1.Optional.from(this.self.err);
+        return pengueno_1.Optional.none();
+      }
+      right() {
+        if ((0, exports2.isRight)(this.self))
+          return pengueno_1.Optional.from(this.self.ok);
+        return pengueno_1.Optional.none();
+      }
+      joinRight(other, mapper) {
+        return this.flatMap((t) => other.mapRight((o) => mapper(o, t)));
+      }
+      joinRightAsync(other, mapper) {
+        return this.flatMapAsync(async (t) => {
+          const o = typeof other === "function" ? other() : other;
+          return await o.then((other2) => other2.mapRight((o2) => mapper(o2, t)));
+        });
+      }
+      static left(e) {
+        return new _Either({ err: e, _tag: ELeftTag });
+      }
+      static right(t) {
+        return new _Either({ ok: t, _tag: ERightTag });
+      }
+      static fromFailable(s) {
+        try {
+          return _Either.right(s());
+        } catch (e) {
+          return _Either.left(e);
+        }
+      }
+      static async fromFailableAsync(s) {
+        return await (typeof s === "function" ? s() : s).then((t) => _Either.right(t)).catch((e) => _Either.left(e));
+      }
+    };
+    exports2.Either = Either2;
   }
-};
+});
 
-// ../u/trace/metric/index.ts
-var MetricValueTag = "MetricValue";
-var isMetricValue = (t) => isTagged(t, MetricValueTag);
-var IMetricTag = "IMetric";
-var isIMetric = (t) => isTagged(t, IMetricTag);
-
-// ../u/trace/log/ansi.ts
-var ANSI = {
-  RESET: "\x1B[0m",
-  BOLD: "\x1B[1m",
-  DIM: "\x1B[2m",
-  RED: "\x1B[31m",
-  GREEN: "\x1B[32m",
-  YELLOW: "\x1B[33m",
-  BLUE: "\x1B[34m",
-  MAGENTA: "\x1B[35m",
-  CYAN: "\x1B[36m",
-  WHITE: "\x1B[37m",
-  BRIGHT_RED: "\x1B[91m",
-  BRIGHT_YELLOW: "\x1B[93m",
-  GRAY: "\x1B[90m"
-};
+// ../node_modules/@emprespresso/pengueno/dist/types/fn/index.js
+var require_fn = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/fn/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_callable(), exports2);
+    __exportStar(require_optional(), exports2);
+    __exportStar(require_either(), exports2);
+  }
+});
 
-// ../u/trace/log/level.ts
-var logLevelOrder = [
-  "DEBUG" /* DEBUG */,
-  "INFO" /* INFO */,
-  "WARN" /* WARN */,
-  "ERROR" /* ERROR */,
-  "SYS" /* SYS */
-];
-var isLogLevel = (l) => typeof l === "string" && logLevelOrder.some((level) => level === l);
-
-// ../u/trace/log/pretty_json_console.ts
-var PrettyJsonConsoleLogger = class {
-  log(level, ...trace) {
-    const message = JSON.stringify(
-      {
-        level,
-        trace
-      },
-      null,
-      4
-    );
-    const styled = `${this.getStyle(level)}${message}${ANSI.RESET}
-`;
-    this.getStream(level)(styled);
+// ../node_modules/@emprespresso/pengueno/dist/types/collections/cons.js
+var require_cons = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/collections/cons.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.ListZipper = exports2.Cons = void 0;
+    var pengueno_1 = require_dist();
+    var Cons = class _Cons {
+      value;
+      next;
+      constructor(value, next = pengueno_1.Optional.none()) {
+        this.value = value;
+        this.next = next;
+      }
+      before(head) {
+        return new _Cons(this.value, head);
+      }
+      replace(_value) {
+        return new _Cons(_value, this.next);
+      }
+      *[Symbol.iterator]() {
+        for (let cur = pengueno_1.Optional.some(this); cur.present(); cur = cur.flatMap((cur2) => cur2.next)) {
+          yield cur.get().value;
+        }
+      }
+      static addOnto(items, tail) {
+        return Array.from(items).reverse().reduce((cons, value) => pengueno_1.Optional.from(new _Cons(value, cons)), tail);
+      }
+      static from(items) {
+        return _Cons.addOnto(items, pengueno_1.Optional.none());
+      }
+    };
+    exports2.Cons = Cons;
+    var ListZipper = class _ListZipper {
+      reversedPathToHead;
+      currentHead;
+      constructor(reversedPathToHead, currentHead) {
+        this.reversedPathToHead = reversedPathToHead;
+        this.currentHead = currentHead;
+      }
+      read() {
+        return this.currentHead.map(({ value }) => value);
+      }
+      next() {
+        return this.currentHead.map((head) => new _ListZipper(pengueno_1.Optional.some(head.before(this.reversedPathToHead)), head.next));
+      }
+      previous() {
+        return this.reversedPathToHead.map((lastVisited) => new _ListZipper(lastVisited.next, pengueno_1.Optional.some(lastVisited.before(this.currentHead))));
+      }
+      prependChunk(values) {
+        return new _ListZipper(Cons.addOnto(Array.from(values).reverse(), this.reversedPathToHead), this.currentHead);
+      }
+      prepend(value) {
+        return this.prependChunk([value]);
+      }
+      remove() {
+        const newHead = this.currentHead.flatMap((right) => right.next);
+        return new _ListZipper(this.reversedPathToHead, newHead);
+      }
+      replace(value) {
+        const newHead = this.currentHead.map((right) => right.replace(value));
+        return new _ListZipper(this.reversedPathToHead, newHead);
+      }
+      *[Symbol.iterator]() {
+        let head = this;
+        for (let prev = head.previous(); prev.present(); prev = prev.flatMap((p) => p.previous())) {
+          head = prev.get();
+        }
+        if (head.currentHead.present())
+          yield* head.currentHead.get();
+      }
+      collection() {
+        return Array.from(this);
+      }
+      static from(iterable) {
+        return new _ListZipper(pengueno_1.Optional.none(), Cons.from(iterable));
+      }
+    };
+    exports2.ListZipper = ListZipper;
   }
-  getStream(level) {
-    if (level === "ERROR" /* ERROR */) {
-      return console.error;
-    }
-    return console.log;
-  }
-  getStyle(level) {
-    switch (level) {
-      case "UNKNOWN" /* UNKNOWN */:
-      case "INFO" /* INFO */:
-        return `${ANSI.MAGENTA}`;
-      case "DEBUG" /* DEBUG */:
-        return `${ANSI.CYAN}`;
-      case "WARN" /* WARN */:
-        return `${ANSI.BRIGHT_YELLOW}`;
-      case "ERROR" /* ERROR */:
-        return `${ANSI.BRIGHT_RED}`;
-      case "SYS" /* SYS */:
-        return `${ANSI.DIM}${ANSI.BLUE}`;
-    }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/types/collections/index.js
+var require_collections = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/collections/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_cons(), exports2);
   }
-};
+});
 
-// ../u/trace/log/trace.ts
-var LogTrace = class _LogTrace {
-  constructor(logger = new PrettyJsonConsoleLogger(), traces = [defaultTrace], defaultLevel = "INFO" /* INFO */, allowedLevels = defaultAllowedLevelsSupplier) {
-    this.logger = logger;
-    this.traces = traces;
-    this.defaultLevel = defaultLevel;
-    this.allowedLevels = allowedLevels;
-  }
-  traceScope(trace) {
-    return new _LogTrace(this.logger, this.traces.concat(trace), this.defaultLevel, this.allowedLevels);
-  }
-  trace(trace) {
-    const { traces, level: _level } = this.foldTraces(this.traces.concat(trace));
-    if (!this.allowedLevels().has(_level)) return;
-    const level = _level === "UNKNOWN" /* UNKNOWN */ ? this.defaultLevel : _level;
-    this.logger.log(level, ...traces);
-  }
-  foldTraces(_traces) {
-    const _logTraces = _traces.map((trace) => typeof trace === "function" ? trace() : trace);
-    const _level = _logTraces.filter((trace) => isLogLevel(trace)).reduce((acc, level2) => Math.max(logLevelOrder.indexOf(level2), acc), -1);
-    const level = logLevelOrder[_level] ?? "UNKNOWN" /* UNKNOWN */;
-    const traces = _logTraces.filter((trace) => !isLogLevel(trace)).map((trace) => {
-      if (typeof trace === "object") {
-        return `TracedException.Name = ${trace.name}, TracedException.Message = ${trace.message}, TracedException.Stack = ${trace.stack}`;
-      }
-      return trace;
+// ../node_modules/@emprespresso/pengueno/dist/types/index.js
+var require_types = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/types/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
     });
-    return {
-      level,
-      traces
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_misc(), exports2);
+    __exportStar(require_object(), exports2);
+    __exportStar(require_tagged(), exports2);
+    __exportStar(require_fn(), exports2);
+    __exportStar(require_collections(), exports2);
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/trace/itrace.js
+var require_itrace = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/itrace.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.TraceableImpl = void 0;
+    var TraceableImpl = class _TraceableImpl {
+      item;
+      trace;
+      constructor(item, trace) {
+        this.item = item;
+        this.trace = trace;
+      }
+      map(mapper) {
+        const result = mapper(this);
+        return new _TraceableImpl(result, this.trace);
+      }
+      coExtend(mapper) {
+        const results = mapper(this);
+        return Array.from(results).map((result) => this.move(result));
+      }
+      flatMap(mapper) {
+        return mapper(this);
+      }
+      flatMapAsync(mapper) {
+        return new _TraceableImpl(mapper(this).then((t) => t.get()), this.trace);
+      }
+      traceScope(mapper) {
+        return new _TraceableImpl(this.get(), this.trace.traceScope(mapper(this)));
+      }
+      peek(peek) {
+        peek(this);
+        return this;
+      }
+      move(t) {
+        return this.map(() => t);
+      }
+      bimap(mapper) {
+        const { item, trace: _trace } = mapper(this);
+        return this.move(item).traceScope(() => _trace);
+      }
+      get() {
+        return this.item;
+      }
     };
+    exports2.TraceableImpl = TraceableImpl;
   }
-};
-var defaultTrace = () => `TimeStamp = ${(/* @__PURE__ */ new Date()).toISOString()}`;
-var defaultAllowedLevels = memoize(
-  (isDebug2) => /* @__PURE__ */ new Set([
-    "UNKNOWN" /* UNKNOWN */,
-    ...isDebug2 ? ["DEBUG" /* DEBUG */] : [],
-    "INFO" /* INFO */,
-    "WARN" /* WARN */,
-    "ERROR" /* ERROR */,
-    "SYS" /* SYS */
-  ])
-);
-var defaultAllowedLevelsSupplier = () => defaultAllowedLevels(isDebug());
-
-// ../u/trace/trace.ts
-var LogTraceable = class _LogTraceable extends TraceableImpl {
-  static LogTrace = new LogTrace();
-  static of(t) {
-    return new _LogTraceable(t, _LogTraceable.LogTrace);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/trace/metric/emittable.js
+var require_emittable = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/metric/emittable.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.EmittableMetric = void 0;
+    var index_1 = require_metric2();
+    var EmittableMetric = class {
+      name;
+      unit;
+      constructor(name, unit) {
+        this.name = name;
+        this.unit = unit;
+      }
+      withValue(value) {
+        return {
+          name: this.name,
+          unit: this.unit,
+          emissionTimestamp: Date.now(),
+          value,
+          _tag: index_1.MetricValueTag
+        };
+      }
+    };
+    exports2.EmittableMetric = EmittableMetric;
   }
-};
-var getEmbeddedMetricConsumer = (logTrace) => (metrics) => {
-  if (metrics.length === 0) return;
-  logTrace.traceScope("SYS" /* SYS */).trace(`Metrics = <metrics>${JSON.stringify(metrics)}</metrics>`);
-};
-var EmbeddedMetricsTraceable = class _EmbeddedMetricsTraceable extends TraceableImpl {
-  static MetricsTrace = new MetricsTrace(getEmbeddedMetricConsumer(LogTraceable.LogTrace));
-  static of(t, metricsTrace = _EmbeddedMetricsTraceable.MetricsTrace) {
-    return new _EmbeddedMetricsTraceable(t, metricsTrace);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/trace/metric/metric.js
+var require_metric = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/metric/metric.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.ResultMetric = exports2.Metric = void 0;
+    var index_1 = require_metric2();
+    var _Tagged = class {
+      _tag;
+      constructor(_tag = index_1.IMetricTag) {
+        this._tag = _tag;
+      }
+    };
+    var Metric = class _Metric extends _Tagged {
+      name;
+      parent;
+      count;
+      time;
+      static DELIM = ".";
+      constructor(name, parent = void 0, count = new index_1.EmittableMetric(_Metric.join(name, "count"), index_1.Unit.COUNT), time = new index_1.EmittableMetric(_Metric.join(name, "time"), index_1.Unit.MILLISECONDS)) {
+        super();
+        this.name = name;
+        this.parent = parent;
+        this.count = count;
+        this.time = time;
+      }
+      child(_name) {
+        const childName = _Metric.join(this.name, _name);
+        return new _Metric(childName, this);
+      }
+      asResult() {
+        return ResultMetric.from(this);
+      }
+      static join(...name) {
+        return name.join(_Metric.DELIM);
+      }
+      static fromName(name) {
+        return new _Metric(name);
+      }
+    };
+    exports2.Metric = Metric;
+    var ResultMetric = class _ResultMetric extends Metric {
+      name;
+      parent;
+      failure;
+      success;
+      warn;
+      constructor(name, parent = void 0, failure, success, warn) {
+        super(name, parent);
+        this.name = name;
+        this.parent = parent;
+        this.failure = failure;
+        this.success = success;
+        this.warn = warn;
+      }
+      static from(metric) {
+        const failure = metric.child("failure");
+        const success = metric.child("success");
+        const warn = metric.child("warn");
+        return new _ResultMetric(metric.name, metric.parent, failure, success, warn);
+      }
+    };
+    exports2.ResultMetric = ResultMetric;
   }
-};
+});
 
-// ../u/process/exec.ts
-var CmdMetric = Metric.fromName("Exec").asResult();
+// ../node_modules/@emprespresso/pengueno/dist/trace/metric/trace.js
+var require_trace = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/metric/trace.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.MetricsTrace = exports2.isMetricsTraceSupplier = void 0;
+    var pengueno_1 = require_dist();
+    var isMetricsTraceSupplier = (t) => (0, pengueno_1.isMetricValue)(t) || (0, pengueno_1.isIMetric)(t) || Array.isArray(t) && t.every((_m) => (0, pengueno_1.isMetricValue)(_m) || (0, pengueno_1.isIMetric)(_m));
+    exports2.isMetricsTraceSupplier = isMetricsTraceSupplier;
+    var MetricsTrace = class _MetricsTrace {
+      metricConsumer;
+      activeTraces;
+      completedTraces;
+      constructor(metricConsumer, activeTraces = /* @__PURE__ */ new Map(), completedTraces = /* @__PURE__ */ new Set()) {
+        this.metricConsumer = metricConsumer;
+        this.activeTraces = activeTraces;
+        this.completedTraces = completedTraces;
+      }
+      traceScope(trace) {
+        const now = Date.now();
+        const metricsToTrace = (Array.isArray(trace) ? trace : [trace]).filter(pengueno_1.isIMetric);
+        const initialTraces = new Map(metricsToTrace.map((metric) => [metric, now]));
+        return new _MetricsTrace(this.metricConsumer, initialTraces);
+      }
+      trace(metrics) {
+        if (!metrics || typeof metrics === "string") {
+          return this;
+        }
+        const now = Date.now();
+        const allMetrics = Array.isArray(metrics) ? metrics : [metrics];
+        const valuesToEmit = allMetrics.filter(pengueno_1.isMetricValue);
+        const traceableMetrics = allMetrics.filter(pengueno_1.isIMetric);
+        const metricsToStart = traceableMetrics.filter((m) => !this.activeTraces.has(m));
+        const metricsToEnd = traceableMetrics.filter((m) => this.activeTraces.has(m) && !this.completedTraces.has(m));
+        const endedMetricValues = metricsToEnd.flatMap((metric) => [
+          metric.count.withValue(1),
+          metric.time.withValue(now - this.activeTraces.get(metric))
+        ]);
+        const allMetricsToEmit = [...valuesToEmit, ...endedMetricValues];
+        if (allMetricsToEmit.length > 0) {
+          this.metricConsumer(allMetricsToEmit);
+        }
+        const nextActiveTraces = new Map([
+          ...this.activeTraces,
+          ...metricsToStart.map((m) => [m, now])
+        ]);
+        const nextCompletedTraces = /* @__PURE__ */ new Set([...this.completedTraces, ...metricsToEnd]);
+        return new _MetricsTrace(this.metricConsumer, nextActiveTraces, nextCompletedTraces);
+      }
+    };
+    exports2.MetricsTrace = MetricsTrace;
+  }
+});
 
-// ../u/process/signals.ts
-var SigIntMetric = Metric.fromName("SigInt").asResult();
-var SigTermMetric = Metric.fromName("SigTerm").asResult();
+// ../node_modules/@emprespresso/pengueno/dist/trace/metric/index.js
+var require_metric2 = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/metric/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.isIMetric = exports2.IMetricTag = exports2.isMetricValue = exports2.MetricValueTag = exports2.Unit = void 0;
+    var pengueno_1 = require_dist();
+    var Unit;
+    (function(Unit2) {
+      Unit2["COUNT"] = "COUNT";
+      Unit2["MILLISECONDS"] = "MILLISECONDS";
+    })(Unit || (exports2.Unit = Unit = {}));
+    exports2.MetricValueTag = "MetricValue";
+    var isMetricValue = (t) => (0, pengueno_1.isTagged)(t, exports2.MetricValueTag);
+    exports2.isMetricValue = isMetricValue;
+    exports2.IMetricTag = "IMetric";
+    var isIMetric = (t) => (0, pengueno_1.isTagged)(t, exports2.IMetricTag);
+    exports2.isIMetric = isIMetric;
+    __exportStar(require_emittable(), exports2);
+    __exportStar(require_metric(), exports2);
+    __exportStar(require_trace(), exports2);
+  }
+});
 
-// ../u/server/response/pengueno.ts
-var ResponseCodeMetrics = [0, 1, 2, 3, 4, 5].map((x) => Metric.fromName(`response.${x}xx`).asResult());
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/ansi.js
+var require_ansi = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/log/ansi.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.ANSI = void 0;
+    exports2.ANSI = {
+      RESET: "\x1B[0m",
+      BOLD: "\x1B[1m",
+      DIM: "\x1B[2m",
+      RED: "\x1B[31m",
+      GREEN: "\x1B[32m",
+      YELLOW: "\x1B[33m",
+      BLUE: "\x1B[34m",
+      MAGENTA: "\x1B[35m",
+      CYAN: "\x1B[36m",
+      WHITE: "\x1B[37m",
+      BRIGHT_RED: "\x1B[91m",
+      BRIGHT_YELLOW: "\x1B[93m",
+      GRAY: "\x1B[90m"
+    };
+  }
+});
 
-// ../u/server/activity/health.ts
-var healthCheckMetric = Metric.fromName("Health").asResult();
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/level.js
+var require_level = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/log/level.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.isLogLevel = exports2.logLevelOrder = exports2.LogLevel = void 0;
+    var LogLevel;
+    (function(LogLevel2) {
+      LogLevel2["UNKNOWN"] = "UNKNOWN";
+      LogLevel2["INFO"] = "INFO";
+      LogLevel2["WARN"] = "WARN";
+      LogLevel2["DEBUG"] = "DEBUG";
+      LogLevel2["ERROR"] = "ERROR";
+      LogLevel2["SYS"] = "SYS";
+    })(LogLevel || (exports2.LogLevel = LogLevel = {}));
+    exports2.logLevelOrder = [
+      LogLevel.DEBUG,
+      LogLevel.INFO,
+      LogLevel.WARN,
+      LogLevel.ERROR,
+      LogLevel.SYS
+    ];
+    var isLogLevel = (l) => typeof l === "string" && exports2.logLevelOrder.some((level) => level === l);
+    exports2.isLogLevel = isLogLevel;
+  }
+});
 
-// ../u/server/filter/json.ts
-var ParseJsonMetric = Metric.fromName("JsonParse").asResult();
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/logger.js
+var require_logger = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/log/logger.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+  }
+});
 
-// ../u/server/filter/index.ts
-var ErrorSource = ((ErrorSource2) => {
-  ErrorSource2[ErrorSource2["USER"] = "WARN" /* WARN */] = "USER";
-  ErrorSource2[ErrorSource2["SYSTEM"] = "ERROR" /* ERROR */] = "SYSTEM";
-  return ErrorSource2;
-})(ErrorSource || {});
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/pretty_json_console.js
+var require_pretty_json_console = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/log/pretty_json_console.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.PrettyJsonConsoleLogger = void 0;
+    var index_1 = require_log();
+    var PrettyJsonConsoleLogger = class {
+      log(level, ...trace) {
+        const message = JSON.stringify({
+          level,
+          trace
+        }, null, 4);
+        const styled = `${this.getStyle(level)}${message}${index_1.ANSI.RESET}
+`;
+        this.getStream(level)(styled);
+      }
+      getStream(level) {
+        if (level === index_1.LogLevel.ERROR) {
+          return console.error;
+        }
+        return console.log;
+      }
+      getStyle(level) {
+        switch (level) {
+          case index_1.LogLevel.UNKNOWN:
+          case index_1.LogLevel.INFO:
+            return `${index_1.ANSI.MAGENTA}`;
+          case index_1.LogLevel.DEBUG:
+            return `${index_1.ANSI.CYAN}`;
+          case index_1.LogLevel.WARN:
+            return `${index_1.ANSI.BRIGHT_YELLOW}`;
+          case index_1.LogLevel.ERROR:
+            return `${index_1.ANSI.BRIGHT_RED}`;
+          case index_1.LogLevel.SYS:
+            return `${index_1.ANSI.DIM}${index_1.ANSI.BLUE}`;
+        }
+      }
+    };
+    exports2.PrettyJsonConsoleLogger = PrettyJsonConsoleLogger;
+  }
+});
 
-// ../u/types/object.ts
-var isObject = (o) => typeof o === "object" && !Array.isArray(o) && !!o;
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/trace.js
+var require_trace2 = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/log/trace.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.LogTrace = void 0;
+    var pengueno_1 = require_dist();
+    var index_1 = require_log();
+    var LogTrace = class _LogTrace {
+      logger;
+      traces;
+      defaultLevel;
+      allowedLevels;
+      constructor(logger = new index_1.PrettyJsonConsoleLogger(), traces = [defaultTrace], defaultLevel = index_1.LogLevel.INFO, allowedLevels = defaultAllowedLevelsSupplier) {
+        this.logger = logger;
+        this.traces = traces;
+        this.defaultLevel = defaultLevel;
+        this.allowedLevels = allowedLevels;
+      }
+      traceScope(trace) {
+        return new _LogTrace(this.logger, this.traces.concat(trace), this.defaultLevel, this.allowedLevels);
+      }
+      trace(trace) {
+        const { traces, level: _level } = this.foldTraces(this.traces.concat(trace));
+        if (!this.allowedLevels().has(_level))
+          return;
+        const level = _level === index_1.LogLevel.UNKNOWN ? this.defaultLevel : _level;
+        this.logger.log(level, ...traces);
+      }
+      foldTraces(_traces) {
+        const _logTraces = _traces.map((trace) => typeof trace === "function" ? trace() : trace);
+        const _level = _logTraces.filter((trace) => (0, index_1.isLogLevel)(trace)).reduce((acc, level2) => Math.max(index_1.logLevelOrder.indexOf(level2), acc), -1);
+        const level = index_1.logLevelOrder[_level] ?? index_1.LogLevel.UNKNOWN;
+        const traces = _logTraces.filter((trace) => !(0, index_1.isLogLevel)(trace)).map((trace) => {
+          if (typeof trace === "object") {
+            return `TracedException.Name = ${trace.name}, TracedException.Message = ${trace.message}, TracedException.Stack = ${trace.stack}`;
+          }
+          return trace;
+        });
+        return {
+          level,
+          traces
+        };
+      }
+    };
+    exports2.LogTrace = LogTrace;
+    var defaultTrace = () => `TimeStamp = ${(/* @__PURE__ */ new Date()).toISOString()}`;
+    var defaultAllowedLevels = (0, pengueno_1.memoize)((isDebug) => /* @__PURE__ */ new Set([
+      index_1.LogLevel.UNKNOWN,
+      ...isDebug ? [index_1.LogLevel.DEBUG] : [],
+      index_1.LogLevel.INFO,
+      index_1.LogLevel.WARN,
+      index_1.LogLevel.ERROR,
+      index_1.LogLevel.SYS
+    ]));
+    var defaultAllowedLevelsSupplier = () => defaultAllowedLevels((0, pengueno_1.isDebug)());
+  }
+});
 
-// ../u/types/tagged.ts
-var isTagged = (o, tag) => !!(isObject(o) && "_tag" in o && o._tag === tag);
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/index.js
+var require_log = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/log/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_ansi(), exports2);
+    __exportStar(require_level(), exports2);
+    __exportStar(require_logger(), exports2);
+    __exportStar(require_pretty_json_console(), exports2);
+    __exportStar(require_trace2(), exports2);
+  }
+});
 
-// ../u/types/fn/either.ts
-var IEitherTag = "IEither";
-var ELeftTag = "E.Left";
-var isLeft = (o) => isTagged(o, ELeftTag);
-var ERightTag = "E.Right";
-var isRight = (o) => isTagged(o, ERightTag);
-var _Tagged2 = class {
-  constructor(_tag = IEitherTag) {
-    this._tag = _tag;
-  }
-};
-var Either = class _Either extends _Tagged2 {
-  constructor(self) {
-    super();
-    this.self = self;
-  }
-  moveRight(t) {
-    return this.mapRight(() => t);
-  }
-  mapBoth(errBranch, okBranch) {
-    if (isLeft(this.self)) return _Either.left(errBranch(this.self.err));
-    return _Either.right(okBranch(this.self.ok));
-  }
-  mapRight(mapper) {
-    if (isRight(this.self)) return _Either.right(mapper(this.self.ok));
-    return _Either.left(this.self.err);
-  }
-  mapLeft(mapper) {
-    if (isLeft(this.self)) return _Either.left(mapper(this.self.err));
-    return _Either.right(this.self.ok);
-  }
-  flatMap(mapper) {
-    if (isRight(this.self)) return mapper(this.self.ok);
-    return _Either.left(this.self.err);
-  }
-  filter(mapper) {
-    if (isLeft(this.self)) return _Either.left(this.self.err);
-    return _Either.fromFailable(() => this.right().filter(mapper).get());
-  }
-  async flatMapAsync(mapper) {
-    if (isLeft(this.self)) return Promise.resolve(_Either.left(this.self.err));
-    return await mapper(this.self.ok).catch((err) => _Either.left(err));
-  }
-  fold(leftFolder, rightFolder) {
-    if (isLeft(this.self)) return leftFolder(this.self.err);
-    return rightFolder(this.self.ok);
-  }
-  left() {
-    if (isLeft(this.self)) return Optional.from(this.self.err);
-    return Optional.none();
-  }
-  right() {
-    if (isRight(this.self)) return Optional.from(this.self.ok);
-    return Optional.none();
+// ../node_modules/@emprespresso/pengueno/dist/trace/trace.js
+var require_trace3 = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/trace.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.LogMetricTraceable = exports2.LogMetricTrace = exports2.EmbeddedMetricsTraceable = exports2.LogTraceable = void 0;
+    var _1 = require_trace4();
+    var LogTraceable = class _LogTraceable extends _1.TraceableImpl {
+      static LogTrace = new _1.LogTrace();
+      static of(t) {
+        return new _LogTraceable(t, _LogTraceable.LogTrace);
+      }
+    };
+    exports2.LogTraceable = LogTraceable;
+    var getEmbeddedMetricConsumer = (logTrace) => (metrics) => {
+      if (metrics.length === 0)
+        return;
+      logTrace.traceScope(_1.LogLevel.SYS).trace(`Metrics = <metrics>${JSON.stringify(metrics)}</metrics>`);
+    };
+    var EmbeddedMetricsTraceable = class _EmbeddedMetricsTraceable extends _1.TraceableImpl {
+      static MetricsTrace = new _1.MetricsTrace(getEmbeddedMetricConsumer(LogTraceable.LogTrace));
+      static of(t, metricsTrace = _EmbeddedMetricsTraceable.MetricsTrace) {
+        return new _EmbeddedMetricsTraceable(t, metricsTrace);
+      }
+    };
+    exports2.EmbeddedMetricsTraceable = EmbeddedMetricsTraceable;
+    var LogMetricTrace = class _LogMetricTrace {
+      logTrace;
+      metricsTrace;
+      constructor(logTrace, metricsTrace) {
+        this.logTrace = logTrace;
+        this.metricsTrace = metricsTrace;
+      }
+      // public traceScope(trace: LogTraceSupplier | MetricsTraceSupplier): LogMetricTrace {
+      //     if (isMetricsTraceSupplier(trace)) {
+      //         this.metricsTrace = this.metricsTrace.traceScope(trace);
+      //         return this;
+      //     }
+      //     this.logTrace = this.logTrace.traceScope(trace);
+      //     return this;
+      // }
+      traceScope(trace) {
+        if ((0, _1.isMetricsTraceSupplier)(trace)) {
+          return new _LogMetricTrace(this.logTrace, this.metricsTrace.traceScope(trace));
+        }
+        return new _LogMetricTrace(this.logTrace.traceScope(trace), this.metricsTrace);
+      }
+      trace(trace) {
+        if ((0, _1.isMetricsTraceSupplier)(trace)) {
+          this.metricsTrace.trace(trace);
+          return this;
+        }
+        this.logTrace.trace(trace);
+        return this;
+      }
+    };
+    exports2.LogMetricTrace = LogMetricTrace;
+    var LogMetricTraceable = class _LogMetricTraceable extends _1.TraceableImpl {
+      static ofLogTraceable(t) {
+        const metricsTrace = new _1.MetricsTrace(getEmbeddedMetricConsumer(t.trace));
+        return new _LogMetricTraceable(t.get(), new LogMetricTrace(t.trace, metricsTrace));
+      }
+      static of(t) {
+        const logTrace = LogTraceable.of(t);
+        return _LogMetricTraceable.ofLogTraceable(logTrace);
+      }
+    };
+    exports2.LogMetricTraceable = LogMetricTraceable;
   }
-  joinRight(other, mapper) {
-    return this.flatMap((t) => other.mapRight((o) => mapper(o, t)));
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/trace/util.js
+var require_util = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/util.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.TraceUtil = void 0;
+    var pengueno_1 = require_dist();
+    var TraceUtil = class _TraceUtil {
+      static promiseify(mapper) {
+        return (traceablePromise) => traceablePromise.flatMapAsync(async (t) => t.move(await t.get()).map(mapper)).get();
+      }
+      static traceResultingEither(metric, warnOnFailure = false) {
+        return (t) => {
+          if (metric)
+            t.trace.trace(t.get().fold((_err) => warnOnFailure ? metric.warn : metric.failure, (_ok) => metric.success));
+          return t.traceScope((_t) => _t.get().fold((_err) => warnOnFailure ? pengueno_1.LogLevel.WARN : pengueno_1.LogLevel.ERROR, (_ok) => pengueno_1.LogLevel.INFO));
+        };
+      }
+      static withTrace(trace) {
+        return (t) => t.traceScope(() => trace);
+      }
+      static withMetricTrace(metric) {
+        return _TraceUtil.withTrace(metric);
+      }
+      static withFunctionTrace(f) {
+        return _TraceUtil.withTrace(`fn.${f.name}`);
+      }
+      static withClassTrace(c) {
+        return _TraceUtil.withTrace(`class.${c.constructor.name}`);
+      }
+    };
+    exports2.TraceUtil = TraceUtil;
   }
-  joinRightAsync(other, mapper) {
-    return this.flatMapAsync(async (t) => {
-      const o = typeof other === "function" ? other() : other;
-      return o.then((other2) => other2.mapRight((o2) => mapper(o2, t)));
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/trace/index.js
+var require_trace4 = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/trace/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
     });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_itrace(), exports2);
+    __exportStar(require_metric2(), exports2);
+    __exportStar(require_log(), exports2);
+    __exportStar(require_trace3(), exports2);
+    __exportStar(require_util(), exports2);
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/process/exec.js
+var require_exec = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/process/exec.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.getStdoutMany = exports2.getStdout = exports2.CmdMetric = void 0;
+    var pengueno_1 = require_dist();
+    var node_child_process_1 = require("node:child_process");
+    exports2.CmdMetric = pengueno_1.Metric.fromName("Exec").asResult();
+    var getStdout = (cmd, options = { streamTraceable: [] }) => cmd.flatMap(pengueno_1.TraceUtil.withFunctionTrace(exports2.getStdout)).flatMap((tCmd) => tCmd.traceScope(() => `Command = ${tCmd.get()}`)).map((tCmd) => {
+      const cmd2 = tCmd.get();
+      const _exec = typeof cmd2 === "string" ? cmd2 : cmd2.join(" ");
+      const env = options.clearEnv ? options.env : { ...process.env, ...options.env };
+      return pengueno_1.Either.fromFailableAsync(new Promise((res, rej) => {
+        const proc = (0, node_child_process_1.exec)(_exec, { env });
+        let stdout = "";
+        proc.stdout?.on("data", (d) => {
+          const s = d.toString();
+          stdout += s;
+          if (options.streamTraceable?.includes("stdout")) {
+            tCmd.trace.trace(s);
+          }
+        });
+        const stderr = "";
+        proc.stderr?.on("data", (d) => {
+          const s = d.toString();
+          stdout += s;
+          if (options.streamTraceable?.includes("stderr")) {
+            tCmd.trace.trace(s);
+          }
+        });
+        proc.on("exit", (code) => {
+          const streams = { stdout, stderr };
+          if (code === 0) {
+            res(streams);
+          } else {
+            rej(new Error(`exited with non-zero code: ${code}. ${stderr}`));
+          }
+        });
+      }));
+    }).map(pengueno_1.TraceUtil.promiseify((tEitherStdStreams) => tEitherStdStreams.get().mapRight(({ stderr, stdout }) => {
+      if (stderr)
+        tEitherStdStreams.trace.traceScope(pengueno_1.LogLevel.DEBUG).trace(`StdErr = ${stderr}`);
+      return stdout;
+    }))).peek(pengueno_1.TraceUtil.promiseify(pengueno_1.TraceUtil.traceResultingEither(exports2.CmdMetric))).get();
+    exports2.getStdout = getStdout;
+    var getStdoutMany = (cmds, options = { streamTraceable: [] }) => cmds.coExtend((t) => t.get()).reduce(async (_result, tCmd) => {
+      const result = await _result;
+      return result.joinRightAsync(() => tCmd.map((cmd) => (0, exports2.getStdout)(cmd, options)).get(), (stdout, pre) => pre.concat(stdout));
+    }, Promise.resolve(pengueno_1.Either.right([])));
+    exports2.getStdoutMany = getStdoutMany;
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/process/env.js
+var require_env = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/process/env.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.getRequiredEnvVars = exports2.getRequiredEnv = exports2.getEnv = void 0;
+    var pengueno_1 = require_dist();
+    var getEnv = (name) => pengueno_1.Optional.from(process.env[name]);
+    exports2.getEnv = getEnv;
+    var getRequiredEnv = (name) => pengueno_1.Either.fromFailable(() => (0, exports2.getEnv)(name).get()).mapLeft(() => new Error(`environment variable "${name}" is required D:`));
+    exports2.getRequiredEnv = getRequiredEnv;
+    var getRequiredEnvVars = (vars) => {
+      const emptyEnvironment = pengueno_1.Either.right({});
+      const addTo = (env, key, val) => ({
+        ...env,
+        [key]: val
+      });
+      return vars.reduce((environment, key) => environment.joinRight((0, exports2.getRequiredEnv)(key), (value, environment2) => addTo(environment2, key, value)), emptyEnvironment);
+    };
+    exports2.getRequiredEnvVars = getRequiredEnvVars;
   }
-  static left(e) {
-    return new _Either({ err: e, _tag: ELeftTag });
-  }
-  static right(t) {
-    return new _Either({ ok: t, _tag: ERightTag });
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/process/validate_identifier.js
+var require_validate_identifier = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/process/validate_identifier.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.validateExecutionEntries = exports2.validateIdentifier = void 0;
+    var pengueno_1 = require_dist();
+    var validateIdentifier = (token) => {
+      return /^[a-zA-Z0-9_\-:. \/]+$/.test(token) && !token.includes("..");
+    };
+    exports2.validateIdentifier = validateIdentifier;
+    var validateExecutionEntries = (obj) => {
+      const invalidEntries = Object.entries(obj).filter((e) => !e.every((x) => typeof x === "string" && (0, exports2.validateIdentifier)(x)));
+      if (invalidEntries.length > 0)
+        return pengueno_1.Either.left(invalidEntries);
+      return pengueno_1.Either.right(obj);
+    };
+    exports2.validateExecutionEntries = validateExecutionEntries;
   }
-  static fromFailable(s) {
-    try {
-      return _Either.right(s());
-    } catch (e) {
-      return _Either.left(e);
-    }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/process/argv.js
+var require_argv = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/process/argv.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.argv = exports2.getArg = exports2.isArgKey = void 0;
+    var pengueno_1 = require_dist();
+    var isArgKey = (k) => k.startsWith("--");
+    exports2.isArgKey = isArgKey;
+    var getArg = (arg, argv2, whenValue) => {
+      const argIndex = pengueno_1.Optional.from(argv2.findIndex((_argv) => (0, exports2.isArgKey)(_argv) && _argv.split("=")[0] === arg)).filter((index) => index >= 0 && index < argv2.length);
+      if (!argIndex.present()) {
+        return pengueno_1.Optional.from(whenValue.absent).map((v) => pengueno_1.Either.right(v)).orSome(() => pengueno_1.Either.left(new Error(`arg ${arg} is not present in arguments list and does not have an 'absent' value`))).get();
+      }
+      return argIndex.flatMap((idx) => pengueno_1.Optional.from(argv2.at(idx)).map((_argv) => _argv.includes("=") ? _argv.split("=")[1] : argv2.at(idx + 1))).filter((next) => !(0, exports2.isArgKey)(next)).map((next) => whenValue.present(next)).orSome(() => whenValue.unspecified).map((v) => pengueno_1.Either.right(v)).get();
+    };
+    exports2.getArg = getArg;
+    var argv = (args, handlers, argv2 = process.argv.slice(2)) => {
+      const defaultHandler = { present: (value) => value };
+      const processArg = (arg) => {
+        const handler = handlers?.[arg] ?? defaultHandler;
+        return (0, exports2.getArg)(arg, argv2, handler).mapRight((value) => [arg, value]);
+      };
+      const res = args.map(processArg).reduce((acc, current) => acc.flatMap((accValue) => current.mapRight(([key, value]) => ({
+        ...accValue,
+        [key]: value
+      }))), pengueno_1.Either.right({})).mapRight((result) => result);
+      return res;
+    };
+    exports2.argv = argv;
   }
-  static async fromFailableAsync(s) {
-    return await (typeof s === "function" ? s() : s).then((t) => _Either.right(t)).catch((e) => _Either.left(e));
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/process/signals.js
+var require_signals = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/process/signals.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.Signals = exports2.SigTermMetric = exports2.SigIntMetric = void 0;
+    var pengueno_1 = require_dist();
+    exports2.SigIntMetric = pengueno_1.Metric.fromName("SigInt").asResult();
+    exports2.SigTermMetric = pengueno_1.Metric.fromName("SigTerm").asResult();
+    var Signals = class {
+      static async awaitClose(t) {
+        const success = pengueno_1.Either.right(void 0);
+        return new Promise((res) => {
+          const metricizedInterruptHandler = (metric) => (err) => t.flatMap(pengueno_1.TraceUtil.withMetricTrace(metric)).peek((_t) => _t.trace.trace("closing")).move(pengueno_1.Optional.from(err).map((e) => pengueno_1.Either.left(e)).orSome(() => success).get()).flatMap(pengueno_1.TraceUtil.traceResultingEither(metric)).map((e) => res(e.get())).peek((_t) => _t.trace.trace("finished")).get();
+          const sigintCloser = metricizedInterruptHandler(exports2.SigIntMetric);
+          const sigtermCloser = metricizedInterruptHandler(exports2.SigTermMetric);
+          process.on("SIGINT", () => t.flatMap(pengueno_1.TraceUtil.withTrace("SIGINT")).get().close(sigintCloser));
+          process.on("SIGTERM", () => t.flatMap(pengueno_1.TraceUtil.withTrace("SIGTERM")).get().close(sigtermCloser));
+        });
+      }
+    };
+    exports2.Signals = Signals;
   }
-};
+});
 
-// ../u/types/fn/optional.ts
-var IOptionalTag = "IOptional";
-var IOptionalEmptyError = class extends Error {
-};
-var OSomeTag = "O.Some";
-var ONoneTag = "O.None";
-var isNone = (o) => isTagged(o, ONoneTag);
-var isSome = (o) => isTagged(o, OSomeTag);
-var _Tagged3 = class {
-  constructor(_tag = IOptionalTag) {
-    this._tag = _tag;
+// ../node_modules/@emprespresso/pengueno/dist/process/index.js
+var require_process = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/process/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_exec(), exports2);
+    __exportStar(require_env(), exports2);
+    __exportStar(require_validate_identifier(), exports2);
+    __exportStar(require_argv(), exports2);
+    __exportStar(require_signals(), exports2);
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/http/body.js
+var require_body = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/http/body.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
   }
-};
-var Optional = class _Optional extends _Tagged3 {
-  constructor(self) {
-    super();
-    this.self = self;
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/http/status.js
+var require_status = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/http/status.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.HttpStatusCodes = void 0;
+    exports2.HttpStatusCodes = {
+      100: "Continue",
+      101: "Switching Protocols",
+      102: "Processing (WebDAV)",
+      200: "OK",
+      201: "Created",
+      202: "Accepted",
+      203: "Non-Authoritative Information",
+      204: "No Content",
+      205: "Reset Content",
+      206: "Partial Content",
+      207: "Multi-Status (WebDAV)",
+      208: "Already Reported (WebDAV)",
+      226: "IM Used",
+      300: "Multiple Choices",
+      301: "Moved Permanently",
+      302: "Found",
+      303: "See Other",
+      304: "Not Modified",
+      305: "Use Proxy",
+      306: "(Unused)",
+      307: "Temporary Redirect",
+      308: "Permanent Redirect (experimental)",
+      400: "Bad Request",
+      401: "Unauthorized",
+      402: "Payment Required",
+      403: "Forbidden",
+      404: "Not Found",
+      405: "Method Not Allowed",
+      406: "Not Acceptable",
+      407: "Proxy Authentication Required",
+      408: "Request Timeout",
+      409: "Conflict",
+      410: "Gone",
+      411: "Length Required",
+      412: "Precondition Failed",
+      413: "Request Entity Too Large",
+      414: "Request-URI Too Long",
+      415: "Unsupported Media Type",
+      416: "Requested Range Not Satisfiable",
+      417: "Expectation Failed",
+      418: "I'm a teapot (RFC 2324)",
+      420: "Enhance Your Calm (Twitter)",
+      422: "Unprocessable Entity (WebDAV)",
+      423: "Locked (WebDAV)",
+      424: "Failed Dependency (WebDAV)",
+      425: "Reserved for WebDAV",
+      426: "Upgrade Required",
+      428: "Precondition Required",
+      429: "Too Many Requests",
+      431: "Request Header Fields Too Large",
+      444: "No Response (Nginx)",
+      449: "Retry With (Microsoft)",
+      450: "Blocked by Windows Parental Controls (Microsoft)",
+      451: "Unavailable For Legal Reasons",
+      499: "Client Closed Request (Nginx)",
+      500: "Internal Server Error",
+      501: "Not Implemented",
+      502: "Bad Gateway",
+      503: "Service Unavailable",
+      504: "Gateway Timeout",
+      505: "HTTP Version Not Supported",
+      506: "Variant Also Negotiates (Experimental)",
+      507: "Insufficient Storage (WebDAV)",
+      508: "Loop Detected (WebDAV)",
+      509: "Bandwidth Limit Exceeded (Apache)",
+      510: "Not Extended",
+      511: "Network Authentication Required",
+      598: "Network read timeout error",
+      599: "Network connect timeout error"
+    };
   }
-  move(t) {
-    return this.map(() => t);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/http/method.js
+var require_method = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/http/method.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
   }
-  orSome(supplier) {
-    if (isNone(this.self)) return _Optional.from(supplier());
-    return this;
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/http/index.js
+var require_http = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/http/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_body(), exports2);
+    __exportStar(require_status(), exports2);
+    __exportStar(require_method(), exports2);
   }
-  get() {
-    if (isNone(this.self)) throw new IOptionalEmptyError("called get() on None optional");
-    return this.self.value;
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/response/pengueno.js
+var require_pengueno = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/response/pengueno.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.JsonResponse = exports2.PenguenoResponse = exports2.getResponseMetrics = void 0;
+    var pengueno_1 = require_dist();
+    var getHeaders = (req, extraHeaders) => {
+      const optHeaders = {
+        ...req.getResponseHeaders(),
+        ...extraHeaders
+      };
+      optHeaders["Content-Type"] = (optHeaders["Content-Type"] ?? "text/plain") + "; charset=utf-8";
+      return optHeaders;
+    };
+    var ResponseCodeMetrics = [0, 1, 2, 3, 4, 5].map((x) => pengueno_1.Metric.fromName(`response.${x}xx`).asResult());
+    var getResponseMetrics = (status, elapsedMs) => {
+      const index = Math.floor(status / 100);
+      return ResponseCodeMetrics.flatMap((metric, i) => pengueno_1.Optional.from(i).filter((i2) => i2 === index).map(() => [metric.count.withValue(1)]).flatMap((metricValues) => pengueno_1.Optional.from(elapsedMs).map((ms) => metricValues.concat(metric.time.withValue(ms))).orSome(() => metricValues)).orSome(() => [metric.count.withValue(0)]).get());
+    };
+    exports2.getResponseMetrics = getResponseMetrics;
+    var PenguenoResponse = class {
+      _body;
+      statusText;
+      status;
+      headers;
+      constructor(req, _body, opts) {
+        this._body = _body;
+        this.headers = getHeaders(req.get(), opts?.headers ?? {});
+        this.status = opts.status;
+        this.statusText = opts.statusText ?? pengueno_1.HttpStatusCodes[this.status];
+        req.trace.trace((0, exports2.getResponseMetrics)(opts.status, req.get().elapsedTimeMs()));
+      }
+      body() {
+        return this._body;
+      }
+    };
+    exports2.PenguenoResponse = PenguenoResponse;
+    var JsonResponse = class extends PenguenoResponse {
+      constructor(req, e, _opts) {
+        const opts = { ..._opts, headers: { ..._opts.headers, "Content-Type": "application/json" } };
+        if ((0, pengueno_1.isEither)(e)) {
+          super(req, JSON.stringify(e.fold((error) => ({ error, ok: void 0 }), (ok) => ({ ok }))), opts);
+          return;
+        }
+        super(req, JSON.stringify(Math.floor(opts.status / 100) > 4 ? { error: e } : { ok: e }), opts);
+      }
+    };
+    exports2.JsonResponse = JsonResponse;
   }
-  filter(mapper) {
-    if (isNone(this.self) || !mapper(this.self.value)) return _Optional.none();
-    return _Optional.some(this.self.value);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/response/index.js
+var require_response = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/response/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_pengueno(), exports2);
   }
-  map(mapper) {
-    if (isNone(this.self)) return _Optional.none();
-    return _Optional.from(mapper(this.self.value));
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/request/pengueno.js
+var require_pengueno2 = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/request/pengueno.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.PenguenoRequest = void 0;
+    var greetings = ["hewwo :D", "hiya cutie", "boop!", "sending virtual hugs!", "stay pawsitive"];
+    var penguenoGreeting = () => greetings[Math.floor(Math.random() * greetings.length)];
+    var PenguenoRequest = class _PenguenoRequest {
+      req;
+      id;
+      at;
+      constructor(req, id, at) {
+        this.req = req;
+        this.id = id;
+        this.at = at;
+      }
+      elapsedTimeMs(after = () => Date.now()) {
+        return after() - this.at.getTime();
+      }
+      getResponseHeaders() {
+        const RequestId = this.id;
+        const RequestReceivedUnix = this.at.getTime();
+        const RequestHandleUnix = Date.now();
+        const DeltaUnix = this.elapsedTimeMs(() => RequestHandleUnix);
+        const Hai = penguenoGreeting();
+        return Object.entries({
+          RequestId,
+          RequestReceivedUnix,
+          RequestHandleUnix,
+          DeltaUnix,
+          Hai
+        }).reduce((acc, [key, val]) => ({ ...acc, [key]: val.toString() }), {});
+      }
+      static from(request) {
+        const id = crypto.randomUUID();
+        return request.bimap((tRequest) => {
+          const request2 = tRequest.get();
+          const url = new URL(request2.url);
+          const { pathname } = url;
+          const trace = `RequestId = ${id}, Method = ${request2.method}, Path = ${pathname}`;
+          return { item: new _PenguenoRequest(request2, id, /* @__PURE__ */ new Date()), trace };
+        });
+      }
+    };
+    exports2.PenguenoRequest = PenguenoRequest;
   }
-  flatMap(mapper) {
-    if (isNone(this.self)) return _Optional.none();
-    return _Optional.from(mapper(this.self.value)).orSome(() => _Optional.none()).get();
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/request/index.js
+var require_request = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/request/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_pengueno2(), exports2);
   }
-  present() {
-    return isSome(this.self);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/activity/health.js
+var require_health = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/activity/health.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.HealthCheckActivityImpl = exports2.HealthCheckOutput = exports2.HealthCheckInput = void 0;
+    var pengueno_1 = require_dist();
+    var HealthCheckInput;
+    (function(HealthCheckInput2) {
+      HealthCheckInput2[HealthCheckInput2["CHECK"] = 0] = "CHECK";
+    })(HealthCheckInput || (exports2.HealthCheckInput = HealthCheckInput = {}));
+    var HealthCheckOutput;
+    (function(HealthCheckOutput2) {
+      HealthCheckOutput2[HealthCheckOutput2["YAASSSLAYQUEEN"] = 0] = "YAASSSLAYQUEEN";
+    })(HealthCheckOutput || (exports2.HealthCheckOutput = HealthCheckOutput = {}));
+    var healthCheckMetric = pengueno_1.Metric.fromName("Health").asResult();
+    var HealthCheckActivityImpl = class {
+      check;
+      constructor(check) {
+        this.check = check;
+      }
+      checkHealth(req) {
+        return req.flatMap(pengueno_1.TraceUtil.withFunctionTrace(this.checkHealth)).flatMap(pengueno_1.TraceUtil.withMetricTrace(healthCheckMetric)).flatMap((r) => r.move(HealthCheckInput.CHECK).map((input) => this.check(input))).peek(pengueno_1.TraceUtil.promiseify(pengueno_1.TraceUtil.traceResultingEither(healthCheckMetric))).map(pengueno_1.TraceUtil.promiseify((h) => {
+          const { status, message } = h.get().fold(() => ({ status: 500, message: "err" }), () => ({ status: 200, message: "ok" }));
+          return new pengueno_1.JsonResponse(req, message, { status });
+        })).get();
+      }
+    };
+    exports2.HealthCheckActivityImpl = HealthCheckActivityImpl;
   }
-  *[Symbol.iterator]() {
-    if (isSome(this.self)) yield this.self.value;
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/activity/fourohfour.js
+var require_fourohfour = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/activity/fourohfour.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.FourOhFourActivityImpl = void 0;
+    var pengueno_1 = require_dist();
+    var messages = [
+      "D: meow-t found! your api call ran away!",
+      "404-bidden! but like...in a cute way >:3 !",
+      ":< your data went on a paw-sible vacation!",
+      "uwu~ not found, but found our hearts instead!"
+    ];
+    var randomFourOhFour = () => messages[Math.floor(Math.random() * messages.length)];
+    var FourOhFourActivityImpl = class {
+      fourOhFour(req) {
+        return req.move(new pengueno_1.JsonResponse(req, randomFourOhFour(), { status: 404 })).map((resp) => Promise.resolve(resp.get())).get();
+      }
+    };
+    exports2.FourOhFourActivityImpl = FourOhFourActivityImpl;
   }
-  static some(value) {
-    return new _Optional({ value, _tag: OSomeTag });
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/activity/index.js
+var require_activity = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/activity/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_health(), exports2);
+    __exportStar(require_fourohfour(), exports2);
   }
-  static _none = new _Optional({ _tag: ONoneTag });
-  static none() {
-    return this._none;
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/filter/method.js
+var require_method2 = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/filter/method.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.requireMethod = void 0;
+    var pengueno_1 = require_dist();
+    var requireMethod = (methods) => (req) => req.flatMap(pengueno_1.TraceUtil.withFunctionTrace(exports2.requireMethod)).map((t) => {
+      const { req: { method } } = t.get();
+      if (!methods.includes(method)) {
+        const msg = "that's not how you pet me (\u22DF\uFE4F\u22DE)~";
+        t.trace.traceScope(pengueno_1.LogLevel.WARN).trace(msg);
+        return pengueno_1.Either.left(new pengueno_1.PenguenoError(msg, 405));
+      }
+      return pengueno_1.Either.right(method);
+    }).get();
+    exports2.requireMethod = requireMethod;
   }
-  static from(value) {
-    if (value === null || value === void 0) return _Optional.none();
-    return _Optional.some(value);
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/filter/json.js
+var require_json = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/filter/json.js"(exports2) {
+    "use strict";
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.jsonModel = void 0;
+    var pengueno_1 = require_dist();
+    var ParseJsonMetric = pengueno_1.Metric.fromName("JsonParse").asResult();
+    var jsonModel = (jsonTransformer) => (r) => r.flatMap(pengueno_1.TraceUtil.withFunctionTrace(exports2.jsonModel)).flatMap(pengueno_1.TraceUtil.withMetricTrace(ParseJsonMetric)).map((j) => pengueno_1.Either.fromFailableAsync(j.get().req.json()).then((either) => either.mapLeft((errReason) => {
+      j.trace.traceScope(pengueno_1.LogLevel.WARN).trace(errReason);
+      return new pengueno_1.PenguenoError("seems to be invalid JSON (>//<) can you fix?", 400);
+    }))).flatMapAsync(pengueno_1.TraceUtil.promiseify(pengueno_1.TraceUtil.traceResultingEither(ParseJsonMetric))).map(pengueno_1.TraceUtil.promiseify((traceableEitherJson) => traceableEitherJson.get().mapRight((j) => traceableEitherJson.move(j)).flatMap(jsonTransformer))).get();
+    exports2.jsonModel = jsonModel;
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/filter/index.js
+var require_filter = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/filter/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    exports2.PenguenoError = exports2.ErrorSource = void 0;
+    var pengueno_1 = require_dist();
+    var ErrorSource;
+    (function(ErrorSource2) {
+      ErrorSource2["USER"] = "WARN";
+      ErrorSource2["SYSTEM"] = "ERROR";
+    })(ErrorSource || (exports2.ErrorSource = ErrorSource = {}));
+    var PenguenoError = class extends Error {
+      message;
+      status;
+      source;
+      constructor(message, status) {
+        super(message);
+        this.message = message;
+        this.status = status;
+        this.source = Math.floor(status / 100) === 4 ? ErrorSource.USER : ErrorSource.SYSTEM;
+      }
+    };
+    exports2.PenguenoError = PenguenoError;
+    __exportStar(require_method2(), exports2);
+    __exportStar(require_json(), exports2);
   }
-};
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/index.js
+var require_server = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/server/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_http(), exports2);
+    __exportStar(require_response(), exports2);
+    __exportStar(require_request(), exports2);
+    __exportStar(require_activity(), exports2);
+    __exportStar(require_filter(), exports2);
+  }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/index.js
+var require_dist = __commonJS({
+  "../node_modules/@emprespresso/pengueno/dist/index.js"(exports2) {
+    "use strict";
+    var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      var desc = Object.getOwnPropertyDescriptor(m, k);
+      if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+        desc = { enumerable: true, get: function() {
+          return m[k];
+        } };
+      }
+      Object.defineProperty(o, k2, desc);
+    } : function(o, m, k, k2) {
+      if (k2 === void 0) k2 = k;
+      o[k2] = m[k];
+    });
+    var __exportStar = exports2 && exports2.__exportStar || function(m, exports3) {
+      for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports3, p)) __createBinding(exports3, m, p);
+    };
+    Object.defineProperty(exports2, "__esModule", { value: true });
+    __exportStar(require_leftpadesque(), exports2);
+    __exportStar(require_types(), exports2);
+    __exportStar(require_trace4(), exports2);
+    __exportStar(require_process(), exports2);
+    __exportStar(require_server(), exports2);
+  }
+});
 
 // ../model/job/index.ts
+var import_pengueno = __toESM(require_dist(), 1);
 var JobTypes = [
   "fetch_code",
   "ci_pipeline",
   "build_docker_image.js",
   "ansible_playbook.js",
-  "checkout_ci.js"
+  "checkout_ci.js",
+  "npm_publish.js"
 ];
 var isJobType = (j) => typeof j === "string" && JobTypes.includes(j);
-var isJob = (j) => !!(isObject(j) && "arguments" in j && isObject(j.arguments) && "type" in j && isJobType(j.type) && j);
+var isJob = (j) => !!((0, import_pengueno.isObject)(j) && "arguments" in j && (0, import_pengueno.isObject)(j.arguments) && "type" in j && isJobType(j.type) && j);
+
+// ../model/pipeline/index.ts
+var import_pengueno3 = __toESM(require_dist(), 1);
 
 // ../model/pipeline/builder.ts
 var BasePipelineBuilder = class {
@@ -523,6 +1787,7 @@ var DefaultGitHookPipelineBuilder = class extends BasePipelineBuilder {
 };
 
 // ../model/pipeline/impl.ts
+var import_pengueno2 = __toESM(require_dist(), 1);
 var PipelineImpl = class _PipelineImpl {
   constructor(serialJobs) {
     this.serialJobs = serialJobs;
@@ -531,15 +1796,15 @@ var PipelineImpl = class _PipelineImpl {
     return JSON.stringify({ serialJobs: this.serialJobs });
   }
   static from(s) {
-    return Either.fromFailable(() => JSON.parse(s)).flatMap(
-      (eitherPipelineJson) => isPipeline(eitherPipelineJson) ? Either.right(eitherPipelineJson) : Either.left(new Error("oh noes D: its a bad pipewine :(("))
+    return import_pengueno2.Either.fromFailable(() => JSON.parse(s)).flatMap(
+      (eitherPipelineJson) => isPipeline(eitherPipelineJson) ? import_pengueno2.Either.right(eitherPipelineJson) : import_pengueno2.Either.left(new Error("oh noes D: its a bad pipewine :(("))
     ).mapRight((pipeline) => new _PipelineImpl(pipeline.serialJobs));
   }
 };
 
 // ../model/pipeline/index.ts
-var isPipelineStage = (t) => isObject(t) && "parallelJobs" in t && Array.isArray(t.parallelJobs) && t.parallelJobs.every((j) => isJob(j));
-var isPipeline = (t) => isObject(t) && "serialJobs" in t && Array.isArray(t.serialJobs) && t.serialJobs.every((p) => isPipelineStage(p));
+var isPipelineStage = (t) => (0, import_pengueno3.isObject)(t) && "parallelJobs" in t && Array.isArray(t.parallelJobs) && t.parallelJobs.every((j) => isJob(j));
+var isPipeline = (t) => (0, import_pengueno3.isObject)(t) && "serialJobs" in t && Array.isArray(t.serialJobs) && t.serialJobs.every((p) => isPipelineStage(p));
 
 // dist/ci.js
 var REGISTRY = "oci.liz.coffee";
@@ -569,12 +1834,12 @@ var getPipeline = () => {
   gitHookPipeline.addStage({
     parallelJobs: [baseCiPackageBuild]
   });
-  const subPackages = ["worker", "server"].map((_package) => ({
+  const subPackages = ["worker", "server", "packpub/npm"].map((_package) => ({
     type: "build_docker_image.js",
     arguments: {
       ...commonBuildArgs,
-      repository: `${IMG}_${_package}`,
-      buildTarget: _package,
+      repository: `${IMG}_${_package.replaceAll("/", "_")}`,
+      buildTarget: _package.replaceAll("/", "_"),
       dockerfile: `${_package}/Dockerfile`
     }
   }));
diff --git a/.ci/ci.ts b/.ci/ci.ts
index e6663db..3480fe9 100644
--- a/.ci/ci.ts
+++ b/.ci/ci.ts
@@ -38,14 +38,14 @@ const getPipeline = () => {
         parallelJobs: [baseCiPackageBuild],
     });
 
-    const subPackages = ['worker', 'server'].map(
+    const subPackages = ['worker', 'server', 'packpub/npm'].map(
         (_package) =>
             <Job>{
                 type: 'build_docker_image.js',
                 arguments: {
                     ...commonBuildArgs,
-                    repository: `${IMG}_${_package}`,
-                    buildTarget: _package,
+                    repository: `${IMG}_${_package.replaceAll('/', '_')}`,
+                    buildTarget: _package.replaceAll('/', '_'),
                     dockerfile: `${_package}/Dockerfile`,
                 },
             },
diff --git a/.ci/package-lock.json b/.ci/package-lock.json
index b45979e..6c80b5c 100644
--- a/.ci/package-lock.json
+++ b/.ci/package-lock.json
@@ -15,7 +15,7 @@
             "name": "@emprespresso/ci_model",
             "version": "0.1.0",
             "dependencies": {
-                "@emprespresso/pengueno": "*"
+                "@emprespresso/pengueno": "^0.0.6"
             }
         },
         "node_modules/@emprespresso/ci_model": {
diff --git a/.ci/tsconfig.json b/.ci/tsconfig.json
index 58e9147..3858ff4 100644
--- a/.ci/tsconfig.json
+++ b/.ci/tsconfig.json
@@ -11,5 +11,5 @@
     },
     "include": ["**/*.ts"],
     "exclude": ["node_modules", "dist", "**/*.test.ts", "**/*.spec.ts"],
-    "references": [{ "path": "../u" }, { "path": "../model" }]
+    "references": [{ "path": "../model" }]
 }
diff --git a/model/job/index.ts b/model/job/index.ts
index 473b61a..da44528 100644
--- a/model/job/index.ts
+++ b/model/job/index.ts
@@ -1,13 +1,20 @@
 import { isObject } from '@emprespresso/pengueno';
 
 export type JobArgT = Record<string, string>;
-export type JobType = 'fetch_code' | 'ci_pipeline' | 'build_docker_image.js' | 'ansible_playbook.js' | 'checkout_ci.js';
+export type JobType =
+    | 'fetch_code'
+    | 'ci_pipeline'
+    | 'build_docker_image.js'
+    | 'ansible_playbook.js'
+    | 'checkout_ci.js'
+    | 'npm_publish.js';
 export const JobTypes: Array<JobType> = [
     'fetch_code',
     'ci_pipeline',
     'build_docker_image.js',
     'ansible_playbook.js',
     'checkout_ci.js',
+    'npm_publish.js',
 ];
 export interface Job {
     readonly type: JobType;
diff --git a/model/job/jobs.ts b/model/job/jobs.ts
index dc23070..8c6bdab 100644
--- a/model/job/jobs.ts
+++ b/model/job/jobs.ts
@@ -11,6 +11,16 @@ export interface FetchCodeJob {
     readonly arguments: FetchCodeJobProps;
 }
 
+export interface NpmPublishJobProps extends JobArgT {
+    readonly source: string;
+    readonly registry: string;
+}
+
+export interface NpmPublishJob {
+    readonly type: 'npm_publish.js';
+    readonly arguments: NpmPublishJobProps;
+}
+
 export interface BuildDockerImageJobProps extends JobArgT {
     readonly registry: string;
     readonly namespace: string;
diff --git a/model/package.json b/model/package.json
index 5d5cec4..0f4f691 100644
--- a/model/package.json
+++ b/model/package.json
@@ -17,7 +17,7 @@
         "type-check": "tsc --noEmit"
     },
     "dependencies": {
-        "@emprespresso/pengueno": "^0.0.5"
+        "@emprespresso/pengueno": "^0.0.6"
     },
     "files": [
         "dist/**/*",
diff --git a/package-lock.json b/package-lock.json
index 8522d1f..feaf151 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -40,7 +40,7 @@
             "name": "@emprespresso/ci_model",
             "version": "0.1.0",
             "dependencies": {
-                "@emprespresso/pengueno": "^0.0.5"
+                "@emprespresso/pengueno": "^0.0.6"
             }
         },
         "node_modules/@emprespresso/ci_model": {
@@ -56,13 +56,10 @@
             "link": true
         },
         "node_modules/@emprespresso/pengueno": {
-            "version": "0.0.5",
-            "resolved": "https://registry.npmjs.org/@emprespresso/pengueno/-/pengueno-0.0.5.tgz",
-            "integrity": "sha512-UvkcchpQfD6EeIaoyeMtBC1WfjF21O+y1WFIM2Nft5R4vRcPefa2xtGHZep7JSE9Fi98sp02LKhY9YAZHxXhCw==",
+            "version": "0.0.6",
+            "resolved": "https://registry.npmjs.org/@emprespresso/pengueno/-/pengueno-0.0.6.tgz",
+            "integrity": "sha512-QjyNXJPFp6OlOuk6cH/0yzdFznItofqhB1wF75k/Len5A0BsqvuE1QGU9aZ7AkujGkIpbv21Vm6K21/bmk0S2A==",
             "license": "MIT",
-            "dependencies": {
-                "module-alias": "^2.2.3"
-            },
             "engines": {
                 "node": ">=22.16.0",
                 "npm": ">=10.0.0"
@@ -1584,12 +1581,6 @@
                 "node": ">=10"
             }
         },
-        "node_modules/module-alias": {
-            "version": "2.2.3",
-            "resolved": "https://registry.npmjs.org/module-alias/-/module-alias-2.2.3.tgz",
-            "integrity": "sha512-23g5BFj4zdQL/b6tor7Ji+QY4pEfNH784BMslY9Qb0UnJWRAt+lQGLYmRaM0KDBwIG23ffEBELhZDP2rhi9f/Q==",
-            "license": "MIT"
-        },
         "node_modules/ms": {
             "version": "2.1.3",
             "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.3.tgz",
@@ -2282,7 +2273,7 @@
             "version": "0.1.0",
             "dependencies": {
                 "@emprespresso/ci_model": "*",
-                "@emprespresso/pengueno": "^0.0.5",
+                "@emprespresso/pengueno": "^0.0.6",
                 "@hono/node-server": "^1.14.0",
                 "hono": "^4.8.9"
             }
@@ -2292,7 +2283,7 @@
             "version": "0.1.0",
             "dependencies": {
                 "@emprespresso/ci_model": "*",
-                "@emprespresso/pengueno": "^0.0.5"
+                "@emprespresso/pengueno": "^0.0.6"
             },
             "devDependencies": {
                 "copyfiles": "2.4.1"
diff --git a/packpub/npm/Dockerfile b/packpub/npm/Dockerfile
new file mode 100644
index 0000000..48abf1b
--- /dev/null
+++ b/packpub/npm/Dockerfile
@@ -0,0 +1,20 @@
+FROM debian:stable-slim AS ci_packpub_npm
+
+RUN apt-get update  \
+    && apt-get -y --no-install-recommends install  \
+        sudo curl git ca-certificates build-essential \
+    && rm -rf /var/lib/apt/lists/*
+
+SHELL ["/bin/bash", "-o", "pipefail", "-c"]
+ENV MISE_DATA_DIR="/mise"
+ENV MISE_CONFIG_DIR="/mise"
+ENV MISE_CACHE_DIR="/mise/cache"
+ENV MISE_INSTALL_PATH="/usr/local/bin/mise"
+ENV PATH="/mise/shims:$PATH"
+# ENV MISE_VERSION="..."
+
+RUN curl https://mise.run | sh
+
+COPY publish.sh /publish.sh
+
+ENTRYPOINT [ "/bin/bash", "publish.sh" ]
diff --git a/packpub/npm/publish.sh b/packpub/npm/publish.sh
new file mode 100644
index 0000000..4ca32d9
--- /dev/null
+++ b/packpub/npm/publish.sh
@@ -0,0 +1,10 @@
+#!/bin/bash
+
+cd /src
+mise trust
+
+npm run install --save-dev
+npm run build
+
+npm link
+npm publish --access public
diff --git a/server/package.json b/server/package.json
index f29d460..c0ce5c6 100644
--- a/server/package.json
+++ b/server/package.json
@@ -20,7 +20,7 @@
         "format:check": "prettier --check ."
     },
     "dependencies": {
-        "@emprespresso/pengueno": "^0.0.5",
+        "@emprespresso/pengueno": "^0.0.6",
         "@emprespresso/ci_model": "*",
         "@hono/node-server": "^1.14.0",
         "hono": "^4.8.9"
diff --git a/worker/package.json b/worker/package.json
index 4db8dba..912a168 100644
--- a/worker/package.json
+++ b/worker/package.json
@@ -18,7 +18,7 @@
     },
     "dependencies": {
         "@emprespresso/ci_model": "*",
-        "@emprespresso/pengueno": "^0.0.5"
+        "@emprespresso/pengueno": "^0.0.6"
     },
     "devDependencies": {
         "copyfiles": "2.4.1"
diff --git a/worker/scripts/npm_publish.ts b/worker/scripts/npm_publish.ts
index e69de29..f97ee48 100644
--- a/worker/scripts/npm_publish.ts
+++ b/worker/scripts/npm_publish.ts
@@ -0,0 +1,103 @@
+#!/usr/bin/env node
+
+import {
+    Either,
+    getRequiredEnvVars,
+    getStdout,
+    type IEither,
+    LogTraceable,
+    LogMetricTraceable,
+    Metric,
+    prependWith,
+    TraceUtil,
+} from '@emprespresso/pengueno';
+import { Bitwarden, getPathOnHost, type SecureNote } from '@emprespresso/ci_worker';
+import { writeFile, mkdir } from 'fs/promises';
+import { join } from 'path';
+import { rmSync } from 'fs';
+import { NpmPublishJob } from '@emprespresso/ci_model';
+
+const eitherJob = getRequiredEnvVars(['source', 'registry']).mapRight(
+    (baseArgs) =>
+        <NpmPublishJob>{
+            type: 'npm_publish.js',
+            arguments: baseArgs,
+        },
+);
+
+const eitherVault = Bitwarden.getConfigFromEnvironment().mapRight((config) => new Bitwarden(config));
+
+const packPubMetric = Metric.fromName('npm_publish.packpub');
+const _logJob = LogTraceable.of(eitherJob).flatMap(TraceUtil.withTrace('npm_publish'));
+await LogMetricTraceable.ofLogTraceable(_logJob)
+    .flatMap(TraceUtil.withMetricTrace(packPubMetric))
+    .peek((tEitherJob) => tEitherJob.trace.trace('starting npm packpub job! (⑅˘꒳˘)'))
+    .map((tEitherJob) =>
+        tEitherJob.get().flatMapAsync((job) =>
+            eitherVault.flatMapAsync(async (vault) => {
+                const eitherKey = await vault.unlock(tEitherJob);
+                tEitherJob.trace.trace('unlocked vault :3');
+                return eitherKey.mapRight((key) => ({ job, key, vault }));
+            }),
+        ),
+    )
+    .map(async (tEitherJobVault) =>
+        (await tEitherJobVault.get()).flatMapAsync(({ job, key, vault }) =>
+            vault
+                .fetchSecret<SecureNote>(tEitherJobVault, key, 'npm_auth_token')
+                .then((e) =>
+                    e
+                        .mapRight(({ notes }) => notes)
+                        .mapRight((token) => [job.arguments.registry, `_authToken=${token.trim()}`].join(':'))
+                        .flatMapAsync((npmRc) => saveToTempFile(npmRc)),
+                )
+                .then((e) => e.mapRight((npmRc) => ({ npmRc, job })))
+                .finally(() => vault.lock(tEitherJobVault, key)),
+        ),
+    )
+    .map(async (tEitherJobNpmRc) => {
+        const jobNpmRc = await tEitherJobNpmRc.get();
+        return jobNpmRc.flatMapAsync(async ({ job, npmRc }) => {
+            const [srcMount, npmRcMount] = await Promise.all(
+                [join(process.cwd(), job.arguments.source), npmRc].map((x) =>
+                    getPathOnHost(x).then((e) => e.right().get()),
+                ),
+            );
+            const volumes = [`${srcMount}:/src`, `${npmRcMount}:/etc/npmrc`];
+            const packPub = [
+                'docker',
+                'run',
+                ...prependWith(volumes, '-v'),
+                'oci.liz.coffee/emprespresso/ci_packpub_npm:release',
+            ];
+            tEitherJobNpmRc.trace.trace(`running packpub magic~ (◕ᴗ◕✿) ${packPub}`);
+            return tEitherJobNpmRc
+                .move(packPub)
+                .map((c) =>
+                    getStdout(c, { streamTraceable: ['stdout', 'stderr'] }).then((e) => {
+                        rmSync(npmRcMount!);
+                        return e;
+                    }),
+                )
+                .get();
+        });
+    })
+    .map(async (tEitherJob) => {
+        const eitherJob = await tEitherJob.get();
+        return eitherJob.fold(
+            (e) => Promise.reject(e),
+            () => Promise.resolve(0),
+        );
+    })
+    .get();
+
+async function saveToTempFile(text: string): Promise<IEither<Error, string>> {
+    const dir = join(process.cwd(), '.secrets', crypto.randomUUID());
+    const file = join(dir, 'secret');
+    return Either.fromFailableAsync(() =>
+        mkdir(dir, { recursive: true }).then(async () => {
+            await writeFile(file, text, { encoding: 'utf-8' });
+            return file;
+        }),
+    );
+}