summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rwxr-xr-x.ci/ci.cjs2121
-rw-r--r--.ci/ci.ts6
-rw-r--r--.ci/package-lock.json2
-rw-r--r--.ci/tsconfig.json2
-rw-r--r--model/job/index.ts9
-rw-r--r--model/job/jobs.ts10
-rw-r--r--model/package.json2
-rw-r--r--package-lock.json21
-rw-r--r--packpub/npm/Dockerfile20
-rw-r--r--packpub/npm/publish.sh10
-rw-r--r--server/package.json2
-rw-r--r--worker/package.json2
-rw-r--r--worker/scripts/npm_publish.ts103
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;
+ }),
+ );
+}
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2025-09-20 22:37:49 +0000