aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rwxr-xr-x.ci/ci.cjs1519
-rw-r--r--.ci/package-lock.json45
-rw-r--r--.ci/package.json3
-rw-r--r--model/package.json4
-rw-r--r--package-lock.json36
-rw-r--r--server/package.json2
-rw-r--r--worker/package.json2
7 files changed, 851 insertions, 760 deletions
diff --git a/.ci/ci.cjs b/.ci/ci.cjs
index eb1854e..2555c6c 100755
--- a/.ci/ci.cjs
+++ b/.ci/ci.cjs
@@ -26,9 +26,9 @@ var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__ge
mod
));
-// node_modules/@emprespresso/pengueno/dist/leftpadesque/prepend.js
+// ../node_modules/@emprespresso/pengueno/dist/leftpadesque/prepend.js
var require_prepend = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/leftpadesque/prepend.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/leftpadesque/prepend.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.prependWith = void 0;
@@ -37,9 +37,9 @@ var require_prepend = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/leftpadesque/debug.js
+// ../node_modules/@emprespresso/pengueno/dist/leftpadesque/debug.js
var require_debug = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/leftpadesque/debug.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/leftpadesque/debug.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.isDebug = exports2.isProd = void 0;
@@ -53,9 +53,9 @@ var require_debug = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/leftpadesque/memoize.js
+// ../node_modules/@emprespresso/pengueno/dist/leftpadesque/memoize.js
var require_memoize = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/leftpadesque/memoize.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/leftpadesque/memoize.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.memoize = void 0;
@@ -75,9 +75,9 @@ var require_memoize = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/leftpadesque/index.js
+// ../node_modules/@emprespresso/pengueno/dist/leftpadesque/index.js
var require_leftpadesque = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/leftpadesque/index.js"(exports2) {
+ "../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;
@@ -102,28 +102,28 @@ var require_leftpadesque = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/types/misc.js
+// ../node_modules/@emprespresso/pengueno/dist/types/misc.js
var require_misc = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/misc.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/types/misc.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
}
});
-// node_modules/@emprespresso/pengueno/dist/types/object.js
+// ../node_modules/@emprespresso/pengueno/dist/types/object.js
var require_object = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/object.js"(exports2) {
+ "../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;
+ var isObject5 = (o) => typeof o === "object" && !Array.isArray(o) && !!o;
+ exports2.isObject = isObject5;
}
});
-// node_modules/@emprespresso/pengueno/dist/types/tagged.js
+// ../node_modules/@emprespresso/pengueno/dist/types/tagged.js
var require_tagged = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/tagged.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/types/tagged.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.isTagged = void 0;
@@ -133,17 +133,17 @@ var require_tagged = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/types/fn/callable.js
+// ../node_modules/@emprespresso/pengueno/dist/types/fn/callable.js
var require_callable = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/fn/callable.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/types/fn/callable.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
}
});
-// node_modules/@emprespresso/pengueno/dist/types/fn/optional.js
+// ../node_modules/@emprespresso/pengueno/dist/types/fn/optional.js
var require_optional = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/fn/optional.js"(exports2) {
+ "../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;
@@ -222,9 +222,9 @@ var require_optional = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/types/fn/either.js
+// ../node_modules/@emprespresso/pengueno/dist/types/fn/either.js
var require_either = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/fn/either.js"(exports2) {
+ "../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;
@@ -244,7 +244,7 @@ var require_either = __commonJS({
this._tag = _tag;
}
};
- var Either2 = class _Either extends _Tagged {
+ var Either3 = class _Either extends _Tagged {
self;
constructor(self) {
super();
@@ -345,13 +345,13 @@ var require_either = __commonJS({
return new Promise((res) => setTimeout(res, wait));
}
};
- exports2.Either = Either2;
+ exports2.Either = Either3;
}
});
-// node_modules/@emprespresso/pengueno/dist/types/fn/index.js
+// ../node_modules/@emprespresso/pengueno/dist/types/fn/index.js
var require_fn = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/fn/index.js"(exports2) {
+ "../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;
@@ -376,9 +376,9 @@ var require_fn = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/types/collections/cons.js
+// ../node_modules/@emprespresso/pengueno/dist/types/collections/cons.js
var require_cons = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/collections/cons.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/types/collections/cons.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.ListZipper = exports2.Cons = void 0;
@@ -458,9 +458,9 @@ var require_cons = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/types/collections/jsonds.js
+// ../node_modules/@emprespresso/pengueno/dist/types/collections/jsonds.js
var require_jsonds = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/collections/jsonds.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/types/collections/jsonds.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.JSONHashMap = exports2.JSONSet = void 0;
@@ -524,9 +524,9 @@ var require_jsonds = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/types/collections/index.js
+// ../node_modules/@emprespresso/pengueno/dist/types/collections/index.js
var require_collections = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/collections/index.js"(exports2) {
+ "../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;
@@ -550,9 +550,9 @@ var require_collections = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/types/index.js
+// ../node_modules/@emprespresso/pengueno/dist/types/index.js
var require_types = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/types/index.js"(exports2) {
+ "../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;
@@ -579,9 +579,9 @@ var require_types = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/itrace.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/itrace.js
var require_itrace = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/itrace.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/itrace.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.TraceableImpl = void 0;
@@ -628,9 +628,9 @@ var require_itrace = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/metric/emittable.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/metric/emittable.js
var require_emittable = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/metric/emittable.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/metric/emittable.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.EmittableMetric = void 0;
@@ -656,9 +656,9 @@ var require_emittable = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/metric/metric.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/metric/metric.js
var require_metric = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/metric/metric.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/metric/metric.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.ResultMetric = exports2.Metric = void 0;
@@ -722,9 +722,9 @@ var require_metric = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/metric/trace.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/metric/trace.js
var require_trace = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/metric/trace.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/metric/trace.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.MetricsTrace = exports2.isMetricsTraceSupplier = void 0;
@@ -788,9 +788,9 @@ var require_trace = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/metric/index.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/metric/index.js
var require_metric2 = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/metric/index.js"(exports2) {
+ "../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;
@@ -828,9 +828,9 @@ var require_metric2 = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/log/ansi.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/ansi.js
var require_ansi = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/log/ansi.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/log/ansi.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.ANSI = void 0;
@@ -852,9 +852,9 @@ var require_ansi = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/log/level.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/level.js
var require_level = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/log/level.js"(exports2) {
+ "../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;
@@ -879,17 +879,17 @@ var require_level = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/log/logger.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/logger.js
var require_logger = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/log/logger.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/log/logger.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/log/pretty_json_console.js
+// ../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) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/log/pretty_json_console.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.PrettyJsonConsoleLogger = void 0;
@@ -930,9 +930,9 @@ var require_pretty_json_console = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/log/trace.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/trace.js
var require_trace2 = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/log/trace.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/log/trace.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.LogTrace = void 0;
@@ -989,9 +989,9 @@ var require_trace2 = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/log/index.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/log/index.js
var require_log = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/log/index.js"(exports2) {
+ "../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;
@@ -1018,9 +1018,9 @@ var require_log = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/trace.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/trace.js
var require_trace3 = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/trace.js"(exports2) {
+ "../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;
@@ -1081,9 +1081,9 @@ var require_trace3 = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/util.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/util.js
var require_util = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/util.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/trace/util.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.TraceUtil = void 0;
@@ -1116,9 +1116,9 @@ var require_util = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/trace/index.js
+// ../node_modules/@emprespresso/pengueno/dist/trace/index.js
var require_trace4 = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/trace/index.js"(exports2) {
+ "../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;
@@ -1145,9 +1145,9 @@ var require_trace4 = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/process/exec.js
+// ../node_modules/@emprespresso/pengueno/dist/process/exec.js
var require_exec = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/process/exec.js"(exports2) {
+ "../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;
@@ -1199,9 +1199,9 @@ var require_exec = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/process/env.js
+// ../node_modules/@emprespresso/pengueno/dist/process/env.js
var require_env = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/process/env.js"(exports2) {
+ "../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;
@@ -1222,15 +1222,15 @@ var require_env = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/process/validate_identifier.js
+// ../node_modules/@emprespresso/pengueno/dist/process/validate_identifier.js
var require_validate_identifier = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/process/validate_identifier.js"(exports2) {
+ "../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_dist2();
var validateIdentifier = (token) => {
- return /^[a-zA-Z0-9_\-:. \/]+$/.test(token) && !token.includes("..");
+ return /^[a-zA-Z0-9_\?\&\=\-:. \/]+$/.test(token) && !token.includes("..");
};
exports2.validateIdentifier = validateIdentifier;
var validateExecutionEntries = (obj) => {
@@ -1243,9 +1243,9 @@ var require_validate_identifier = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/process/argv.js
+// ../node_modules/@emprespresso/pengueno/dist/process/argv.js
var require_argv = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/process/argv.js"(exports2) {
+ "../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;
@@ -1276,9 +1276,9 @@ var require_argv = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/process/signals.js
+// ../node_modules/@emprespresso/pengueno/dist/process/signals.js
var require_signals = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/process/signals.js"(exports2) {
+ "../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;
@@ -1301,9 +1301,9 @@ var require_signals = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/process/index.js
+// ../node_modules/@emprespresso/pengueno/dist/process/index.js
var require_process = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/process/index.js"(exports2) {
+ "../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;
@@ -1330,17 +1330,17 @@ var require_process = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/http/body.js
+// ../node_modules/@emprespresso/pengueno/dist/server/http/body.js
var require_body = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/http/body.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/http/body.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
}
});
-// node_modules/@emprespresso/pengueno/dist/server/http/status.js
+// ../node_modules/@emprespresso/pengueno/dist/server/http/status.js
var require_status = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/http/status.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/http/status.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.HttpStatusCodes = void 0;
@@ -1418,17 +1418,17 @@ var require_status = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/http/method.js
+// ../node_modules/@emprespresso/pengueno/dist/server/http/method.js
var require_method = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/http/method.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/http/method.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
}
});
-// node_modules/@emprespresso/pengueno/dist/server/http/index.js
+// ../node_modules/@emprespresso/pengueno/dist/server/http/index.js
var require_http = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/http/index.js"(exports2) {
+ "../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;
@@ -1453,9 +1453,9 @@ var require_http = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/response/pengueno.js
+// ../node_modules/@emprespresso/pengueno/dist/server/response/pengueno.js
var require_pengueno = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/response/pengueno.js"(exports2) {
+ "../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;
@@ -1505,9 +1505,9 @@ var require_pengueno = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/response/index.js
+// ../node_modules/@emprespresso/pengueno/dist/server/response/index.js
var require_response = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/response/index.js"(exports2) {
+ "../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;
@@ -1530,9 +1530,9 @@ var require_response = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/request/pengueno.js
+// ../node_modules/@emprespresso/pengueno/dist/server/request/pengueno.js
var require_pengueno2 = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/request/pengueno.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/request/pengueno.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.PenguenoRequest = void 0;
@@ -1579,9 +1579,9 @@ var require_pengueno2 = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/request/index.js
+// ../node_modules/@emprespresso/pengueno/dist/server/request/index.js
var require_request = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/request/index.js"(exports2) {
+ "../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;
@@ -1604,9 +1604,9 @@ var require_request = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/activity/health.js
+// ../node_modules/@emprespresso/pengueno/dist/server/activity/health.js
var require_health = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/activity/health.js"(exports2) {
+ "../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;
@@ -1636,9 +1636,9 @@ var require_health = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/activity/fourohfour.js
+// ../node_modules/@emprespresso/pengueno/dist/server/activity/fourohfour.js
var require_fourohfour = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/activity/fourohfour.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/activity/fourohfour.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.FourOhFourActivityImpl = void 0;
@@ -1659,9 +1659,9 @@ var require_fourohfour = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/activity/index.js
+// ../node_modules/@emprespresso/pengueno/dist/server/activity/index.js
var require_activity = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/activity/index.js"(exports2) {
+ "../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;
@@ -1685,9 +1685,9 @@ var require_activity = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/filter/method.js
+// ../node_modules/@emprespresso/pengueno/dist/server/filter/method.js
var require_method2 = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/filter/method.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/filter/method.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.requireMethod = void 0;
@@ -1705,9 +1705,9 @@ var require_method2 = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/filter/json.js
+// ../node_modules/@emprespresso/pengueno/dist/server/filter/json.js
var require_json = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/filter/json.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/filter/json.js"(exports2) {
"use strict";
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.jsonModel = void 0;
@@ -1721,9 +1721,9 @@ var require_json = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/filter/index.js
+// ../node_modules/@emprespresso/pengueno/dist/server/filter/index.js
var require_filter = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/filter/index.js"(exports2) {
+ "../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;
@@ -1766,608 +1766,6 @@ var require_filter = __commonJS({
}
});
-// ../node_modules/@hono/node-server/dist/index.js
-var require_dist = __commonJS({
- "../node_modules/@hono/node-server/dist/index.js"(exports2, module2) {
- "use strict";
- var __create2 = Object.create;
- var __defProp2 = Object.defineProperty;
- var __getOwnPropDesc2 = Object.getOwnPropertyDescriptor;
- var __getOwnPropNames2 = Object.getOwnPropertyNames;
- var __getProtoOf2 = Object.getPrototypeOf;
- var __hasOwnProp2 = Object.prototype.hasOwnProperty;
- var __export = (target, all) => {
- for (var name in all)
- __defProp2(target, name, { get: all[name], enumerable: true });
- };
- var __copyProps2 = (to, from, except, desc) => {
- if (from && typeof from === "object" || typeof from === "function") {
- for (let key of __getOwnPropNames2(from))
- if (!__hasOwnProp2.call(to, key) && key !== except)
- __defProp2(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc2(from, key)) || desc.enumerable });
- }
- return to;
- };
- var __toESM2 = (mod, isNodeMode, target) => (target = mod != null ? __create2(__getProtoOf2(mod)) : {}, __copyProps2(
- // 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 ? __defProp2(target, "default", { value: mod, enumerable: true }) : target,
- mod
- ));
- var __toCommonJS = (mod) => __copyProps2(__defProp2({}, "__esModule", { value: true }), mod);
- var src_exports = {};
- __export(src_exports, {
- RequestError: () => RequestError,
- createAdaptorServer: () => createAdaptorServer,
- getRequestListener: () => getRequestListener,
- serve: () => serve
- });
- module2.exports = __toCommonJS(src_exports);
- var import_node_http = require("http");
- var import_node_http22 = require("http2");
- var import_node_http2 = require("http2");
- var import_node_stream = require("stream");
- var RequestError = class extends Error {
- constructor(message, options) {
- super(message, options);
- this.name = "RequestError";
- }
- };
- var toRequestError = (e) => {
- if (e instanceof RequestError) {
- return e;
- }
- return new RequestError(e.message, { cause: e });
- };
- var GlobalRequest = global.Request;
- var Request2 = class extends GlobalRequest {
- constructor(input, options) {
- if (typeof input === "object" && getRequestCache in input) {
- input = input[getRequestCache]();
- }
- if (typeof options?.body?.getReader !== "undefined") {
- ;
- options.duplex ??= "half";
- }
- super(input, options);
- }
- };
- var newHeadersFromIncoming = (incoming) => {
- const headerRecord = [];
- const rawHeaders = incoming.rawHeaders;
- for (let i = 0; i < rawHeaders.length; i += 2) {
- const { [i]: key, [i + 1]: value } = rawHeaders;
- if (key.charCodeAt(0) !== /*:*/
- 58) {
- headerRecord.push([key, value]);
- }
- }
- return new Headers(headerRecord);
- };
- var wrapBodyStream = Symbol("wrapBodyStream");
- var newRequestFromIncoming = (method, url, headers, incoming, abortController) => {
- const init = {
- method,
- headers,
- signal: abortController.signal
- };
- if (method === "TRACE") {
- init.method = "GET";
- const req = new Request2(url, init);
- Object.defineProperty(req, "method", {
- get() {
- return "TRACE";
- }
- });
- return req;
- }
- if (!(method === "GET" || method === "HEAD")) {
- if ("rawBody" in incoming && incoming.rawBody instanceof Buffer) {
- init.body = new ReadableStream({
- start(controller) {
- controller.enqueue(incoming.rawBody);
- controller.close();
- }
- });
- } else if (incoming[wrapBodyStream]) {
- let reader;
- init.body = new ReadableStream({
- async pull(controller) {
- try {
- reader ||= import_node_stream.Readable.toWeb(incoming).getReader();
- const { done, value } = await reader.read();
- if (done) {
- controller.close();
- } else {
- controller.enqueue(value);
- }
- } catch (error) {
- controller.error(error);
- }
- }
- });
- } else {
- init.body = import_node_stream.Readable.toWeb(incoming);
- }
- }
- return new Request2(url, init);
- };
- var getRequestCache = Symbol("getRequestCache");
- var requestCache = Symbol("requestCache");
- var incomingKey = Symbol("incomingKey");
- var urlKey = Symbol("urlKey");
- var headersKey = Symbol("headersKey");
- var abortControllerKey = Symbol("abortControllerKey");
- var getAbortController = Symbol("getAbortController");
- var requestPrototype = {
- get method() {
- return this[incomingKey].method || "GET";
- },
- get url() {
- return this[urlKey];
- },
- get headers() {
- return this[headersKey] ||= newHeadersFromIncoming(this[incomingKey]);
- },
- [getAbortController]() {
- this[getRequestCache]();
- return this[abortControllerKey];
- },
- [getRequestCache]() {
- this[abortControllerKey] ||= new AbortController();
- return this[requestCache] ||= newRequestFromIncoming(
- this.method,
- this[urlKey],
- this.headers,
- this[incomingKey],
- this[abortControllerKey]
- );
- }
- };
- [
- "body",
- "bodyUsed",
- "cache",
- "credentials",
- "destination",
- "integrity",
- "mode",
- "redirect",
- "referrer",
- "referrerPolicy",
- "signal",
- "keepalive"
- ].forEach((k) => {
- Object.defineProperty(requestPrototype, k, {
- get() {
- return this[getRequestCache]()[k];
- }
- });
- });
- ["arrayBuffer", "blob", "clone", "formData", "json", "text"].forEach((k) => {
- Object.defineProperty(requestPrototype, k, {
- value: function() {
- return this[getRequestCache]()[k]();
- }
- });
- });
- Object.setPrototypeOf(requestPrototype, Request2.prototype);
- var newRequest = (incoming, defaultHostname) => {
- const req = Object.create(requestPrototype);
- req[incomingKey] = incoming;
- const incomingUrl = incoming.url || "";
- if (incomingUrl[0] !== "/" && // short-circuit for performance. most requests are relative URL.
- (incomingUrl.startsWith("http://") || incomingUrl.startsWith("https://"))) {
- if (incoming instanceof import_node_http2.Http2ServerRequest) {
- throw new RequestError("Absolute URL for :path is not allowed in HTTP/2");
- }
- try {
- const url2 = new URL(incomingUrl);
- req[urlKey] = url2.href;
- } catch (e) {
- throw new RequestError("Invalid absolute URL", { cause: e });
- }
- return req;
- }
- const host = (incoming instanceof import_node_http2.Http2ServerRequest ? incoming.authority : incoming.headers.host) || defaultHostname;
- if (!host) {
- throw new RequestError("Missing host header");
- }
- let scheme;
- if (incoming instanceof import_node_http2.Http2ServerRequest) {
- scheme = incoming.scheme;
- if (!(scheme === "http" || scheme === "https")) {
- throw new RequestError("Unsupported scheme");
- }
- } else {
- scheme = incoming.socket && incoming.socket.encrypted ? "https" : "http";
- }
- const url = new URL(`${scheme}://${host}${incomingUrl}`);
- if (url.hostname.length !== host.length && url.hostname !== host.replace(/:\d+$/, "")) {
- throw new RequestError("Invalid host header");
- }
- req[urlKey] = url.href;
- return req;
- };
- var responseCache = Symbol("responseCache");
- var getResponseCache = Symbol("getResponseCache");
- var cacheKey = Symbol("cache");
- var GlobalResponse = global.Response;
- var Response2 = class _Response {
- #body;
- #init;
- [getResponseCache]() {
- delete this[cacheKey];
- return this[responseCache] ||= new GlobalResponse(this.#body, this.#init);
- }
- constructor(body, init) {
- let headers;
- this.#body = body;
- if (init instanceof _Response) {
- const cachedGlobalResponse = init[responseCache];
- if (cachedGlobalResponse) {
- this.#init = cachedGlobalResponse;
- this[getResponseCache]();
- return;
- } else {
- this.#init = init.#init;
- headers = new Headers(init.#init.headers);
- }
- } else {
- this.#init = init;
- }
- if (typeof body === "string" || typeof body?.getReader !== "undefined" || body instanceof Blob || body instanceof Uint8Array) {
- headers ||= init?.headers || { "content-type": "text/plain; charset=UTF-8" };
- this[cacheKey] = [init?.status || 200, body, headers];
- }
- }
- get headers() {
- const cache = this[cacheKey];
- if (cache) {
- if (!(cache[2] instanceof Headers)) {
- cache[2] = new Headers(cache[2]);
- }
- return cache[2];
- }
- return this[getResponseCache]().headers;
- }
- get status() {
- return this[cacheKey]?.[0] ?? this[getResponseCache]().status;
- }
- get ok() {
- const status = this.status;
- return status >= 200 && status < 300;
- }
- };
- ["body", "bodyUsed", "redirected", "statusText", "trailers", "type", "url"].forEach((k) => {
- Object.defineProperty(Response2.prototype, k, {
- get() {
- return this[getResponseCache]()[k];
- }
- });
- });
- ["arrayBuffer", "blob", "clone", "formData", "json", "text"].forEach((k) => {
- Object.defineProperty(Response2.prototype, k, {
- value: function() {
- return this[getResponseCache]()[k]();
- }
- });
- });
- Object.setPrototypeOf(Response2, GlobalResponse);
- Object.setPrototypeOf(Response2.prototype, GlobalResponse.prototype);
- async function readWithoutBlocking(readPromise) {
- return Promise.race([readPromise, Promise.resolve().then(() => Promise.resolve(void 0))]);
- }
- function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
- const cancel = (error) => {
- reader.cancel(error).catch(() => {
- });
- };
- writable.on("close", cancel);
- writable.on("error", cancel);
- (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
- return reader.closed.finally(() => {
- writable.off("close", cancel);
- writable.off("error", cancel);
- });
- function handleStreamError(error) {
- if (error) {
- writable.destroy(error);
- }
- }
- function onDrain() {
- reader.read().then(flow, handleStreamError);
- }
- function flow({ done, value }) {
- try {
- if (done) {
- writable.end();
- } else if (!writable.write(value)) {
- writable.once("drain", onDrain);
- } else {
- return reader.read().then(flow, handleStreamError);
- }
- } catch (e) {
- handleStreamError(e);
- }
- }
- }
- function writeFromReadableStream(stream, writable) {
- if (stream.locked) {
- throw new TypeError("ReadableStream is locked.");
- } else if (writable.destroyed) {
- return;
- }
- return writeFromReadableStreamDefaultReader(stream.getReader(), writable);
- }
- var buildOutgoingHttpHeaders = (headers) => {
- const res = {};
- if (!(headers instanceof Headers)) {
- headers = new Headers(headers ?? void 0);
- }
- const cookies = [];
- for (const [k, v] of headers) {
- if (k === "set-cookie") {
- cookies.push(v);
- } else {
- res[k] = v;
- }
- }
- if (cookies.length > 0) {
- res["set-cookie"] = cookies;
- }
- res["content-type"] ??= "text/plain; charset=UTF-8";
- return res;
- };
- var X_ALREADY_SENT = "x-hono-already-sent";
- var import_node_crypto = __toESM2(require("crypto"));
- var webFetch = global.fetch;
- if (typeof global.crypto === "undefined") {
- global.crypto = import_node_crypto.default;
- }
- global.fetch = (info, init) => {
- init = {
- // Disable compression handling so people can return the result of a fetch
- // directly in the loader without messing with the Content-Encoding header.
- compress: false,
- ...init
- };
- return webFetch(info, init);
- };
- var outgoingEnded = Symbol("outgoingEnded");
- var handleRequestError = () => new Response(null, {
- status: 400
- });
- var handleFetchError = (e) => new Response(null, {
- status: e instanceof Error && (e.name === "TimeoutError" || e.constructor.name === "TimeoutError") ? 504 : 500
- });
- var handleResponseError = (e, outgoing) => {
- const err = e instanceof Error ? e : new Error("unknown error", { cause: e });
- if (err.code === "ERR_STREAM_PREMATURE_CLOSE") {
- console.info("The user aborted a request.");
- } else {
- console.error(e);
- if (!outgoing.headersSent) {
- outgoing.writeHead(500, { "Content-Type": "text/plain" });
- }
- outgoing.end(`Error: ${err.message}`);
- outgoing.destroy(err);
- }
- };
- var flushHeaders = (outgoing) => {
- if ("flushHeaders" in outgoing && outgoing.writable) {
- outgoing.flushHeaders();
- }
- };
- var responseViaCache = async (res, outgoing) => {
- let [status, body, header] = res[cacheKey];
- if (header instanceof Headers) {
- header = buildOutgoingHttpHeaders(header);
- }
- if (typeof body === "string") {
- header["Content-Length"] = Buffer.byteLength(body);
- } else if (body instanceof Uint8Array) {
- header["Content-Length"] = body.byteLength;
- } else if (body instanceof Blob) {
- header["Content-Length"] = body.size;
- }
- outgoing.writeHead(status, header);
- if (typeof body === "string" || body instanceof Uint8Array) {
- outgoing.end(body);
- } else if (body instanceof Blob) {
- outgoing.end(new Uint8Array(await body.arrayBuffer()));
- } else {
- flushHeaders(outgoing);
- await writeFromReadableStream(body, outgoing)?.catch(
- (e) => handleResponseError(e, outgoing)
- );
- }
- ;
- outgoing[outgoingEnded]?.();
- };
- var isPromise = (res) => typeof res.then === "function";
- var responseViaResponseObject = async (res, outgoing, options = {}) => {
- if (isPromise(res)) {
- if (options.errorHandler) {
- try {
- res = await res;
- } catch (err) {
- const errRes = await options.errorHandler(err);
- if (!errRes) {
- return;
- }
- res = errRes;
- }
- } else {
- res = await res.catch(handleFetchError);
- }
- }
- if (cacheKey in res) {
- return responseViaCache(res, outgoing);
- }
- const resHeaderRecord = buildOutgoingHttpHeaders(res.headers);
- if (res.body) {
- const reader = res.body.getReader();
- const values = [];
- let done = false;
- let currentReadPromise = void 0;
- if (resHeaderRecord["transfer-encoding"] !== "chunked") {
- let maxReadCount = 2;
- for (let i = 0; i < maxReadCount; i++) {
- currentReadPromise ||= reader.read();
- const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
- console.error(e);
- done = true;
- });
- if (!chunk) {
- if (i === 1) {
- await new Promise((resolve) => setTimeout(resolve));
- maxReadCount = 3;
- continue;
- }
- break;
- }
- currentReadPromise = void 0;
- if (chunk.value) {
- values.push(chunk.value);
- }
- if (chunk.done) {
- done = true;
- break;
- }
- }
- if (done && !("content-length" in resHeaderRecord)) {
- resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
- }
- }
- outgoing.writeHead(res.status, resHeaderRecord);
- values.forEach((value) => {
- ;
- outgoing.write(value);
- });
- if (done) {
- outgoing.end();
- } else {
- if (values.length === 0) {
- flushHeaders(outgoing);
- }
- await writeFromReadableStreamDefaultReader(reader, outgoing, currentReadPromise);
- }
- } else if (resHeaderRecord[X_ALREADY_SENT]) {
- } else {
- outgoing.writeHead(res.status, resHeaderRecord);
- outgoing.end();
- }
- ;
- outgoing[outgoingEnded]?.();
- };
- var getRequestListener = (fetchCallback, options = {}) => {
- const autoCleanupIncoming = options.autoCleanupIncoming ?? true;
- if (options.overrideGlobalObjects !== false && global.Request !== Request2) {
- Object.defineProperty(global, "Request", {
- value: Request2
- });
- Object.defineProperty(global, "Response", {
- value: Response2
- });
- }
- return async (incoming, outgoing) => {
- let res, req;
- try {
- req = newRequest(incoming, options.hostname);
- let incomingEnded = !autoCleanupIncoming || incoming.method === "GET" || incoming.method === "HEAD";
- if (!incomingEnded) {
- ;
- incoming[wrapBodyStream] = true;
- incoming.on("end", () => {
- incomingEnded = true;
- });
- if (incoming instanceof import_node_http22.Http2ServerRequest) {
- ;
- outgoing[outgoingEnded] = () => {
- if (!incomingEnded) {
- setTimeout(() => {
- if (!incomingEnded) {
- setTimeout(() => {
- incoming.destroy();
- outgoing.destroy();
- });
- }
- });
- }
- };
- }
- }
- outgoing.on("close", () => {
- const abortController = req[abortControllerKey];
- if (abortController) {
- if (incoming.errored) {
- req[abortControllerKey].abort(incoming.errored.toString());
- } else if (!outgoing.writableFinished) {
- req[abortControllerKey].abort("Client connection prematurely closed.");
- }
- }
- if (!incomingEnded) {
- setTimeout(() => {
- if (!incomingEnded) {
- setTimeout(() => {
- incoming.destroy();
- });
- }
- });
- }
- });
- res = fetchCallback(req, { incoming, outgoing });
- if (cacheKey in res) {
- return responseViaCache(res, outgoing);
- }
- } catch (e) {
- if (!res) {
- if (options.errorHandler) {
- res = await options.errorHandler(req ? e : toRequestError(e));
- if (!res) {
- return;
- }
- } else if (!req) {
- res = handleRequestError();
- } else {
- res = handleFetchError(e);
- }
- } else {
- return handleResponseError(e, outgoing);
- }
- }
- try {
- return await responseViaResponseObject(res, outgoing, options);
- } catch (e) {
- return handleResponseError(e, outgoing);
- }
- };
- };
- var createAdaptorServer = (options) => {
- const fetchCallback = options.fetch;
- const requestListener = getRequestListener(fetchCallback, {
- hostname: options.hostname,
- overrideGlobalObjects: options.overrideGlobalObjects,
- autoCleanupIncoming: options.autoCleanupIncoming
- });
- const createServer = options.createServer || import_node_http.createServer;
- const server = createServer(options.serverOptions || {}, requestListener);
- return server;
- };
- var serve = (options, listeningListener) => {
- const server = createAdaptorServer(options);
- server.listen(options?.port ?? 3e3, options.hostname, () => {
- const serverInfo = server.address();
- listeningListener && listeningListener(serverInfo);
- });
- return server;
- };
- }
-});
-
// ../node_modules/hono/dist/cjs/compose.js
var require_compose = __commonJS({
"../node_modules/hono/dist/cjs/compose.js"(exports2, module2) {
@@ -4850,32 +4248,678 @@ var require_cjs = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/hono/proxy.js
+// ../node_modules/@hono/node-server/dist/index.js
+var require_dist = __commonJS({
+ "../node_modules/@hono/node-server/dist/index.js"(exports2, module2) {
+ "use strict";
+ var __create2 = Object.create;
+ var __defProp2 = Object.defineProperty;
+ var __getOwnPropDesc2 = Object.getOwnPropertyDescriptor;
+ var __getOwnPropNames2 = Object.getOwnPropertyNames;
+ var __getProtoOf2 = Object.getPrototypeOf;
+ var __hasOwnProp2 = Object.prototype.hasOwnProperty;
+ var __export = (target, all) => {
+ for (var name in all)
+ __defProp2(target, name, { get: all[name], enumerable: true });
+ };
+ var __copyProps2 = (to, from, except, desc) => {
+ if (from && typeof from === "object" || typeof from === "function") {
+ for (let key of __getOwnPropNames2(from))
+ if (!__hasOwnProp2.call(to, key) && key !== except)
+ __defProp2(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc2(from, key)) || desc.enumerable });
+ }
+ return to;
+ };
+ var __toESM2 = (mod, isNodeMode, target) => (target = mod != null ? __create2(__getProtoOf2(mod)) : {}, __copyProps2(
+ // 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 ? __defProp2(target, "default", { value: mod, enumerable: true }) : target,
+ mod
+ ));
+ var __toCommonJS = (mod) => __copyProps2(__defProp2({}, "__esModule", { value: true }), mod);
+ var src_exports = {};
+ __export(src_exports, {
+ RequestError: () => RequestError,
+ createAdaptorServer: () => createAdaptorServer,
+ getRequestListener: () => getRequestListener,
+ serve: () => serve
+ });
+ module2.exports = __toCommonJS(src_exports);
+ var import_node_http = require("http");
+ var import_node_http22 = require("http2");
+ var import_node_http2 = require("http2");
+ var import_node_stream = require("stream");
+ var RequestError = class extends Error {
+ constructor(message, options) {
+ super(message, options);
+ this.name = "RequestError";
+ }
+ };
+ var toRequestError = (e) => {
+ if (e instanceof RequestError) {
+ return e;
+ }
+ return new RequestError(e.message, { cause: e });
+ };
+ var GlobalRequest = global.Request;
+ var Request2 = class extends GlobalRequest {
+ constructor(input, options) {
+ if (typeof input === "object" && getRequestCache in input) {
+ input = input[getRequestCache]();
+ }
+ if (typeof options?.body?.getReader !== "undefined") {
+ ;
+ options.duplex ??= "half";
+ }
+ super(input, options);
+ }
+ };
+ var newHeadersFromIncoming = (incoming) => {
+ const headerRecord = [];
+ const rawHeaders = incoming.rawHeaders;
+ for (let i = 0; i < rawHeaders.length; i += 2) {
+ const { [i]: key, [i + 1]: value } = rawHeaders;
+ if (key.charCodeAt(0) !== /*:*/
+ 58) {
+ headerRecord.push([key, value]);
+ }
+ }
+ return new Headers(headerRecord);
+ };
+ var wrapBodyStream = Symbol("wrapBodyStream");
+ var newRequestFromIncoming = (method, url, headers, incoming, abortController) => {
+ const init = {
+ method,
+ headers,
+ signal: abortController.signal
+ };
+ if (method === "TRACE") {
+ init.method = "GET";
+ const req = new Request2(url, init);
+ Object.defineProperty(req, "method", {
+ get() {
+ return "TRACE";
+ }
+ });
+ return req;
+ }
+ if (!(method === "GET" || method === "HEAD")) {
+ if ("rawBody" in incoming && incoming.rawBody instanceof Buffer) {
+ init.body = new ReadableStream({
+ start(controller) {
+ controller.enqueue(incoming.rawBody);
+ controller.close();
+ }
+ });
+ } else if (incoming[wrapBodyStream]) {
+ let reader;
+ init.body = new ReadableStream({
+ async pull(controller) {
+ try {
+ reader ||= import_node_stream.Readable.toWeb(incoming).getReader();
+ const { done, value } = await reader.read();
+ if (done) {
+ controller.close();
+ } else {
+ controller.enqueue(value);
+ }
+ } catch (error) {
+ controller.error(error);
+ }
+ }
+ });
+ } else {
+ init.body = import_node_stream.Readable.toWeb(incoming);
+ }
+ }
+ return new Request2(url, init);
+ };
+ var getRequestCache = Symbol("getRequestCache");
+ var requestCache = Symbol("requestCache");
+ var incomingKey = Symbol("incomingKey");
+ var urlKey = Symbol("urlKey");
+ var headersKey = Symbol("headersKey");
+ var abortControllerKey = Symbol("abortControllerKey");
+ var getAbortController = Symbol("getAbortController");
+ var requestPrototype = {
+ get method() {
+ return this[incomingKey].method || "GET";
+ },
+ get url() {
+ return this[urlKey];
+ },
+ get headers() {
+ return this[headersKey] ||= newHeadersFromIncoming(this[incomingKey]);
+ },
+ [getAbortController]() {
+ this[getRequestCache]();
+ return this[abortControllerKey];
+ },
+ [getRequestCache]() {
+ this[abortControllerKey] ||= new AbortController();
+ return this[requestCache] ||= newRequestFromIncoming(
+ this.method,
+ this[urlKey],
+ this.headers,
+ this[incomingKey],
+ this[abortControllerKey]
+ );
+ }
+ };
+ [
+ "body",
+ "bodyUsed",
+ "cache",
+ "credentials",
+ "destination",
+ "integrity",
+ "mode",
+ "redirect",
+ "referrer",
+ "referrerPolicy",
+ "signal",
+ "keepalive"
+ ].forEach((k) => {
+ Object.defineProperty(requestPrototype, k, {
+ get() {
+ return this[getRequestCache]()[k];
+ }
+ });
+ });
+ ["arrayBuffer", "blob", "clone", "formData", "json", "text"].forEach((k) => {
+ Object.defineProperty(requestPrototype, k, {
+ value: function() {
+ return this[getRequestCache]()[k]();
+ }
+ });
+ });
+ Object.setPrototypeOf(requestPrototype, Request2.prototype);
+ var newRequest = (incoming, defaultHostname) => {
+ const req = Object.create(requestPrototype);
+ req[incomingKey] = incoming;
+ const incomingUrl = incoming.url || "";
+ if (incomingUrl[0] !== "/" && // short-circuit for performance. most requests are relative URL.
+ (incomingUrl.startsWith("http://") || incomingUrl.startsWith("https://"))) {
+ if (incoming instanceof import_node_http2.Http2ServerRequest) {
+ throw new RequestError("Absolute URL for :path is not allowed in HTTP/2");
+ }
+ try {
+ const url2 = new URL(incomingUrl);
+ req[urlKey] = url2.href;
+ } catch (e) {
+ throw new RequestError("Invalid absolute URL", { cause: e });
+ }
+ return req;
+ }
+ const host = (incoming instanceof import_node_http2.Http2ServerRequest ? incoming.authority : incoming.headers.host) || defaultHostname;
+ if (!host) {
+ throw new RequestError("Missing host header");
+ }
+ let scheme;
+ if (incoming instanceof import_node_http2.Http2ServerRequest) {
+ scheme = incoming.scheme;
+ if (!(scheme === "http" || scheme === "https")) {
+ throw new RequestError("Unsupported scheme");
+ }
+ } else {
+ scheme = incoming.socket && incoming.socket.encrypted ? "https" : "http";
+ }
+ const url = new URL(`${scheme}://${host}${incomingUrl}`);
+ if (url.hostname.length !== host.length && url.hostname !== host.replace(/:\d+$/, "")) {
+ throw new RequestError("Invalid host header");
+ }
+ req[urlKey] = url.href;
+ return req;
+ };
+ var responseCache = Symbol("responseCache");
+ var getResponseCache = Symbol("getResponseCache");
+ var cacheKey = Symbol("cache");
+ var GlobalResponse = global.Response;
+ var Response2 = class _Response {
+ #body;
+ #init;
+ [getResponseCache]() {
+ delete this[cacheKey];
+ return this[responseCache] ||= new GlobalResponse(this.#body, this.#init);
+ }
+ constructor(body, init) {
+ let headers;
+ this.#body = body;
+ if (init instanceof _Response) {
+ const cachedGlobalResponse = init[responseCache];
+ if (cachedGlobalResponse) {
+ this.#init = cachedGlobalResponse;
+ this[getResponseCache]();
+ return;
+ } else {
+ this.#init = init.#init;
+ headers = new Headers(init.#init.headers);
+ }
+ } else {
+ this.#init = init;
+ }
+ if (typeof body === "string" || typeof body?.getReader !== "undefined" || body instanceof Blob || body instanceof Uint8Array) {
+ headers ||= init?.headers || { "content-type": "text/plain; charset=UTF-8" };
+ this[cacheKey] = [init?.status || 200, body, headers];
+ }
+ }
+ get headers() {
+ const cache = this[cacheKey];
+ if (cache) {
+ if (!(cache[2] instanceof Headers)) {
+ cache[2] = new Headers(cache[2]);
+ }
+ return cache[2];
+ }
+ return this[getResponseCache]().headers;
+ }
+ get status() {
+ return this[cacheKey]?.[0] ?? this[getResponseCache]().status;
+ }
+ get ok() {
+ const status = this.status;
+ return status >= 200 && status < 300;
+ }
+ };
+ ["body", "bodyUsed", "redirected", "statusText", "trailers", "type", "url"].forEach((k) => {
+ Object.defineProperty(Response2.prototype, k, {
+ get() {
+ return this[getResponseCache]()[k];
+ }
+ });
+ });
+ ["arrayBuffer", "blob", "clone", "formData", "json", "text"].forEach((k) => {
+ Object.defineProperty(Response2.prototype, k, {
+ value: function() {
+ return this[getResponseCache]()[k]();
+ }
+ });
+ });
+ Object.setPrototypeOf(Response2, GlobalResponse);
+ Object.setPrototypeOf(Response2.prototype, GlobalResponse.prototype);
+ async function readWithoutBlocking(readPromise) {
+ return Promise.race([readPromise, Promise.resolve().then(() => Promise.resolve(void 0))]);
+ }
+ function writeFromReadableStreamDefaultReader(reader, writable, currentReadPromise) {
+ const cancel = (error) => {
+ reader.cancel(error).catch(() => {
+ });
+ };
+ writable.on("close", cancel);
+ writable.on("error", cancel);
+ (currentReadPromise ?? reader.read()).then(flow, handleStreamError);
+ return reader.closed.finally(() => {
+ writable.off("close", cancel);
+ writable.off("error", cancel);
+ });
+ function handleStreamError(error) {
+ if (error) {
+ writable.destroy(error);
+ }
+ }
+ function onDrain() {
+ reader.read().then(flow, handleStreamError);
+ }
+ function flow({ done, value }) {
+ try {
+ if (done) {
+ writable.end();
+ } else if (!writable.write(value)) {
+ writable.once("drain", onDrain);
+ } else {
+ return reader.read().then(flow, handleStreamError);
+ }
+ } catch (e) {
+ handleStreamError(e);
+ }
+ }
+ }
+ function writeFromReadableStream(stream, writable) {
+ if (stream.locked) {
+ throw new TypeError("ReadableStream is locked.");
+ } else if (writable.destroyed) {
+ return;
+ }
+ return writeFromReadableStreamDefaultReader(stream.getReader(), writable);
+ }
+ var buildOutgoingHttpHeaders = (headers) => {
+ const res = {};
+ if (!(headers instanceof Headers)) {
+ headers = new Headers(headers ?? void 0);
+ }
+ const cookies = [];
+ for (const [k, v] of headers) {
+ if (k === "set-cookie") {
+ cookies.push(v);
+ } else {
+ res[k] = v;
+ }
+ }
+ if (cookies.length > 0) {
+ res["set-cookie"] = cookies;
+ }
+ res["content-type"] ??= "text/plain; charset=UTF-8";
+ return res;
+ };
+ var X_ALREADY_SENT = "x-hono-already-sent";
+ var import_node_crypto = __toESM2(require("crypto"));
+ var webFetch = global.fetch;
+ if (typeof global.crypto === "undefined") {
+ global.crypto = import_node_crypto.default;
+ }
+ global.fetch = (info, init) => {
+ init = {
+ // Disable compression handling so people can return the result of a fetch
+ // directly in the loader without messing with the Content-Encoding header.
+ compress: false,
+ ...init
+ };
+ return webFetch(info, init);
+ };
+ var outgoingEnded = Symbol("outgoingEnded");
+ var handleRequestError = () => new Response(null, {
+ status: 400
+ });
+ var handleFetchError = (e) => new Response(null, {
+ status: e instanceof Error && (e.name === "TimeoutError" || e.constructor.name === "TimeoutError") ? 504 : 500
+ });
+ var handleResponseError = (e, outgoing) => {
+ const err = e instanceof Error ? e : new Error("unknown error", { cause: e });
+ if (err.code === "ERR_STREAM_PREMATURE_CLOSE") {
+ console.info("The user aborted a request.");
+ } else {
+ console.error(e);
+ if (!outgoing.headersSent) {
+ outgoing.writeHead(500, { "Content-Type": "text/plain" });
+ }
+ outgoing.end(`Error: ${err.message}`);
+ outgoing.destroy(err);
+ }
+ };
+ var flushHeaders = (outgoing) => {
+ if ("flushHeaders" in outgoing && outgoing.writable) {
+ outgoing.flushHeaders();
+ }
+ };
+ var responseViaCache = async (res, outgoing) => {
+ let [status, body, header] = res[cacheKey];
+ if (header instanceof Headers) {
+ header = buildOutgoingHttpHeaders(header);
+ }
+ if (typeof body === "string") {
+ header["Content-Length"] = Buffer.byteLength(body);
+ } else if (body instanceof Uint8Array) {
+ header["Content-Length"] = body.byteLength;
+ } else if (body instanceof Blob) {
+ header["Content-Length"] = body.size;
+ }
+ outgoing.writeHead(status, header);
+ if (typeof body === "string" || body instanceof Uint8Array) {
+ outgoing.end(body);
+ } else if (body instanceof Blob) {
+ outgoing.end(new Uint8Array(await body.arrayBuffer()));
+ } else {
+ flushHeaders(outgoing);
+ await writeFromReadableStream(body, outgoing)?.catch(
+ (e) => handleResponseError(e, outgoing)
+ );
+ }
+ ;
+ outgoing[outgoingEnded]?.();
+ };
+ var isPromise = (res) => typeof res.then === "function";
+ var responseViaResponseObject = async (res, outgoing, options = {}) => {
+ if (isPromise(res)) {
+ if (options.errorHandler) {
+ try {
+ res = await res;
+ } catch (err) {
+ const errRes = await options.errorHandler(err);
+ if (!errRes) {
+ return;
+ }
+ res = errRes;
+ }
+ } else {
+ res = await res.catch(handleFetchError);
+ }
+ }
+ if (cacheKey in res) {
+ return responseViaCache(res, outgoing);
+ }
+ const resHeaderRecord = buildOutgoingHttpHeaders(res.headers);
+ if (res.body) {
+ const reader = res.body.getReader();
+ const values = [];
+ let done = false;
+ let currentReadPromise = void 0;
+ if (resHeaderRecord["transfer-encoding"] !== "chunked") {
+ let maxReadCount = 2;
+ for (let i = 0; i < maxReadCount; i++) {
+ currentReadPromise ||= reader.read();
+ const chunk = await readWithoutBlocking(currentReadPromise).catch((e) => {
+ console.error(e);
+ done = true;
+ });
+ if (!chunk) {
+ if (i === 1) {
+ await new Promise((resolve) => setTimeout(resolve));
+ maxReadCount = 3;
+ continue;
+ }
+ break;
+ }
+ currentReadPromise = void 0;
+ if (chunk.value) {
+ values.push(chunk.value);
+ }
+ if (chunk.done) {
+ done = true;
+ break;
+ }
+ }
+ if (done && !("content-length" in resHeaderRecord)) {
+ resHeaderRecord["content-length"] = values.reduce((acc, value) => acc + value.length, 0);
+ }
+ }
+ outgoing.writeHead(res.status, resHeaderRecord);
+ values.forEach((value) => {
+ ;
+ outgoing.write(value);
+ });
+ if (done) {
+ outgoing.end();
+ } else {
+ if (values.length === 0) {
+ flushHeaders(outgoing);
+ }
+ await writeFromReadableStreamDefaultReader(reader, outgoing, currentReadPromise);
+ }
+ } else if (resHeaderRecord[X_ALREADY_SENT]) {
+ } else {
+ outgoing.writeHead(res.status, resHeaderRecord);
+ outgoing.end();
+ }
+ ;
+ outgoing[outgoingEnded]?.();
+ };
+ var getRequestListener = (fetchCallback, options = {}) => {
+ const autoCleanupIncoming = options.autoCleanupIncoming ?? true;
+ if (options.overrideGlobalObjects !== false && global.Request !== Request2) {
+ Object.defineProperty(global, "Request", {
+ value: Request2
+ });
+ Object.defineProperty(global, "Response", {
+ value: Response2
+ });
+ }
+ return async (incoming, outgoing) => {
+ let res, req;
+ try {
+ req = newRequest(incoming, options.hostname);
+ let incomingEnded = !autoCleanupIncoming || incoming.method === "GET" || incoming.method === "HEAD";
+ if (!incomingEnded) {
+ ;
+ incoming[wrapBodyStream] = true;
+ incoming.on("end", () => {
+ incomingEnded = true;
+ });
+ if (incoming instanceof import_node_http22.Http2ServerRequest) {
+ ;
+ outgoing[outgoingEnded] = () => {
+ if (!incomingEnded) {
+ setTimeout(() => {
+ if (!incomingEnded) {
+ setTimeout(() => {
+ incoming.destroy();
+ outgoing.destroy();
+ });
+ }
+ });
+ }
+ };
+ }
+ }
+ outgoing.on("close", () => {
+ const abortController = req[abortControllerKey];
+ if (abortController) {
+ if (incoming.errored) {
+ req[abortControllerKey].abort(incoming.errored.toString());
+ } else if (!outgoing.writableFinished) {
+ req[abortControllerKey].abort("Client connection prematurely closed.");
+ }
+ }
+ if (!incomingEnded) {
+ setTimeout(() => {
+ if (!incomingEnded) {
+ setTimeout(() => {
+ incoming.destroy();
+ });
+ }
+ });
+ }
+ });
+ res = fetchCallback(req, { incoming, outgoing });
+ if (cacheKey in res) {
+ return responseViaCache(res, outgoing);
+ }
+ } catch (e) {
+ if (!res) {
+ if (options.errorHandler) {
+ res = await options.errorHandler(req ? e : toRequestError(e));
+ if (!res) {
+ return;
+ }
+ } else if (!req) {
+ res = handleRequestError();
+ } else {
+ res = handleFetchError(e);
+ }
+ } else {
+ return handleResponseError(e, outgoing);
+ }
+ }
+ try {
+ return await responseViaResponseObject(res, outgoing, options);
+ } catch (e) {
+ return handleResponseError(e, outgoing);
+ }
+ };
+ };
+ var createAdaptorServer = (options) => {
+ const fetchCallback = options.fetch;
+ const requestListener = getRequestListener(fetchCallback, {
+ hostname: options.hostname,
+ overrideGlobalObjects: options.overrideGlobalObjects,
+ autoCleanupIncoming: options.autoCleanupIncoming
+ });
+ const createServer = options.createServer || import_node_http.createServer;
+ const server = createServer(options.serverOptions || {}, requestListener);
+ return server;
+ };
+ var serve = (options, listeningListener) => {
+ const server = createAdaptorServer(options);
+ server.listen(options?.port ?? 3e3, options.hostname, () => {
+ const serverInfo = server.address();
+ listeningListener && listeningListener(serverInfo);
+ });
+ return server;
+ };
+ }
+});
+
+// ../node_modules/@emprespresso/pengueno/dist/server/hono/proxy.js
var require_proxy = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/hono/proxy.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/hono/proxy.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 __setModuleDefault = exports2 && exports2.__setModuleDefault || (Object.create ? function(o, v) {
+ Object.defineProperty(o, "default", { enumerable: true, value: v });
+ } : function(o, v) {
+ o["default"] = v;
+ });
+ var __importStar = exports2 && exports2.__importStar || /* @__PURE__ */ function() {
+ var ownKeys = function(o) {
+ ownKeys = Object.getOwnPropertyNames || function(o2) {
+ var ar = [];
+ for (var k in o2) if (Object.prototype.hasOwnProperty.call(o2, k)) ar[ar.length] = k;
+ return ar;
+ };
+ return ownKeys(o);
+ };
+ return function(mod) {
+ if (mod && mod.__esModule) return mod;
+ var result = {};
+ if (mod != null) {
+ for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
+ }
+ __setModuleDefault(result, mod);
+ return result;
+ };
+ }();
Object.defineProperty(exports2, "__esModule", { value: true });
exports2.HonoProxy = void 0;
var pengueno_1 = require_dist2();
- var node_server_1 = require_dist();
- var hono_1 = require_cjs();
var AppLifetimeMetric = pengueno_1.Metric.fromName("HonoAppLifetime").asResult();
var AppRequestMetric = pengueno_1.Metric.fromName("HonoAppRequest");
var HonoProxy = class {
server;
- app = pengueno_1.LogMetricTraceable.of(new hono_1.Hono()).flatMap(pengueno_1.TraceUtil.withTrace(`AppId = ${crypto.randomUUID()}`)).flatMap(pengueno_1.TraceUtil.withMetricTrace(AppLifetimeMetric));
+ app;
constructor(server) {
this.server = server;
}
+ async initializeApp() {
+ if (this.app)
+ return this.app;
+ const { Hono: Hono2 } = await Promise.resolve().then(() => __importStar(require_cjs()));
+ this.app = pengueno_1.LogMetricTraceable.of(new Hono2()).flatMap(pengueno_1.TraceUtil.withTrace(`AppId = ${crypto.randomUUID()}`)).flatMap(pengueno_1.TraceUtil.withMetricTrace(AppLifetimeMetric));
+ return this.app;
+ }
async serve(port, hostname) {
- return this.app.map((tApp) => pengueno_1.Either.fromFailable(() => {
- const app = tApp.get();
- app.all("*", async (c) => tApp.flatMap(pengueno_1.TraceUtil.withMetricTrace(AppRequestMetric)).move(c.req).flatMap((tRequest) => pengueno_1.PenguenoRequest.from(tRequest)).map((req) => this.server.serve(req)).map(pengueno_1.TraceUtil.promiseify((tResponse) => {
+ const { serve } = await Promise.resolve().then(() => __importStar(require_dist()));
+ const app = await this.initializeApp();
+ return app.map((tApp) => pengueno_1.Either.fromFailable(() => {
+ const app2 = tApp.get();
+ app2.all("*", async (c) => tApp.flatMap(pengueno_1.TraceUtil.withMetricTrace(AppRequestMetric)).move(c.req).flatMap((tRequest) => pengueno_1.PenguenoRequest.from(tRequest)).map((req) => this.server.serve(req)).map(pengueno_1.TraceUtil.promiseify((tResponse) => {
tResponse.trace.trace(AppRequestMetric.count.withValue(1));
return new Response(tResponse.get().body(), tResponse.get());
})).get());
- return (0, node_server_1.serve)({
- fetch: (_r) => app.fetch(_r),
+ return serve({
+ fetch: (_r) => app2.fetch(_r),
port,
hostname
});
@@ -4886,9 +4930,9 @@ var require_proxy = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/hono/index.js
+// ../node_modules/@emprespresso/pengueno/dist/server/hono/index.js
var require_hono2 = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/hono/index.js"(exports2) {
+ "../node_modules/@emprespresso/pengueno/dist/server/hono/index.js"(exports2) {
"use strict";
var __createBinding = exports2 && exports2.__createBinding || (Object.create ? function(o, m, k, k2) {
if (k2 === void 0) k2 = k;
@@ -4911,9 +4955,9 @@ var require_hono2 = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/server/index.js
+// ../node_modules/@emprespresso/pengueno/dist/server/index.js
var require_server = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/server/index.js"(exports2) {
+ "../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;
@@ -4941,9 +4985,9 @@ var require_server = __commonJS({
}
});
-// node_modules/@emprespresso/pengueno/dist/index.js
+// ../node_modules/@emprespresso/pengueno/dist/index.js
var require_dist2 = __commonJS({
- "node_modules/@emprespresso/pengueno/dist/index.js"(exports2) {
+ "../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;
@@ -4970,8 +5014,14 @@ var require_dist2 = __commonJS({
}
});
-// node_modules/@emprespresso/ci_model/dist/job/index.js
+// ../model/dist/job/index.js
var import_pengueno = __toESM(require_dist2(), 1);
+
+// ../model/dist/pipeline/index.js
+var import_pengueno6 = __toESM(require_dist2(), 1);
+
+// ../model/job/index.ts
+var import_pengueno2 = __toESM(require_dist2(), 1);
var JobTypes = [
"fetch_code",
"ci_pipeline",
@@ -4982,12 +5032,15 @@ var JobTypes = [
"coolify_webhook.js"
];
var isJobType = (j) => typeof j === "string" && JobTypes.includes(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);
+var isJob = (j) => !!((0, import_pengueno2.isObject)(j) && "arguments" in j && (0, import_pengueno2.isObject)(j.arguments) && "type" in j && isJobType(j.type) && j);
-// node_modules/@emprespresso/ci_model/dist/pipeline/index.js
+// ../model/pipeline/index.ts
+var import_pengueno4 = __toESM(require_dist2(), 1);
+
+// ../model/pipeline/impl.ts
var import_pengueno3 = __toESM(require_dist2(), 1);
-// node_modules/@emprespresso/ci_model/dist/pipeline/builder.js
+// ../model/dist/pipeline/builder.js
var BasePipelineBuilder = class {
stages = [];
addStage(stage) {
@@ -4995,7 +5048,7 @@ var BasePipelineBuilder = class {
return this;
}
build() {
- return new PipelineImpl(this.stages);
+ return new PipelineImpl2(this.stages);
}
};
var DefaultGitHookPipelineBuilder = class extends BasePipelineBuilder {
@@ -5027,9 +5080,9 @@ var DefaultGitHookPipelineBuilder = class extends BasePipelineBuilder {
}
};
-// node_modules/@emprespresso/ci_model/dist/pipeline/impl.js
-var import_pengueno2 = __toESM(require_dist2(), 1);
-var PipelineImpl = class _PipelineImpl {
+// ../model/dist/pipeline/impl.js
+var import_pengueno5 = __toESM(require_dist2(), 1);
+var PipelineImpl2 = class _PipelineImpl {
serialJobs;
constructor(serialJobs) {
this.serialJobs = serialJobs;
@@ -5038,13 +5091,13 @@ var PipelineImpl = class _PipelineImpl {
return JSON.stringify({ serialJobs: this.serialJobs });
}
static from(s) {
- 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));
+ return import_pengueno5.Either.fromFailable(() => JSON.parse(s)).flatMap((eitherPipelineJson) => isPipeline2(eitherPipelineJson) ? import_pengueno5.Either.right(eitherPipelineJson) : import_pengueno5.Either.left(new Error("oh noes D: its a bad pipewine :(("))).mapRight((pipeline) => new _PipelineImpl(pipeline.serialJobs));
}
};
-// node_modules/@emprespresso/ci_model/dist/pipeline/index.js
-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));
+// ../model/dist/pipeline/index.js
+var isPipelineStage = (t) => (0, import_pengueno6.isObject)(t) && "parallelJobs" in t && Array.isArray(t.parallelJobs) && t.parallelJobs.every((j) => isJob(j));
+var isPipeline2 = (t) => (0, import_pengueno6.isObject)(t) && "serialJobs" in t && Array.isArray(t.serialJobs) && t.serialJobs.every((p) => isPipelineStage(p));
// dist/ci.js
var import_path = require("path");
diff --git a/.ci/package-lock.json b/.ci/package-lock.json
index 5e5dc79..a57dcec 100644
--- a/.ci/package-lock.json
+++ b/.ci/package-lock.json
@@ -5,29 +5,27 @@
"packages": {
"": {
"dependencies": {
- "@emprespresso/ci_model": "^0.2.0"
+ "@emprespresso/ci_model": "^0.3.0"
},
"devDependencies": {
+ "@types/node": "^24.10.1",
"esbuild": "0.25.5"
}
},
- "node_modules/@emprespresso/ci_model": {
- "version": "0.2.0",
- "resolved": "https://registry.npmjs.org/@emprespresso/ci_model/-/ci_model-0.2.0.tgz",
- "integrity": "sha512-yFr0WdAPxf0jhLwdjUUv8KikXVRuT7n81vWt+Km8w6FeKqFtf6h8+ZSIm301X/lEB9x77+CnAN+29NkpyQbPHA==",
+ "../model": {
+ "name": "@emprespresso/ci_model",
+ "version": "0.3.0",
"dependencies": {
- "@emprespresso/pengueno": "^0.0.13"
+ "@emprespresso/pengueno": "^0.0.17"
+ },
+ "devDependencies": {
+ "@types/node": "^24.10.1",
+ "typescript": "^5.9.3"
}
},
- "node_modules/@emprespresso/pengueno": {
- "version": "0.0.13",
- "resolved": "https://registry.npmjs.org/@emprespresso/pengueno/-/pengueno-0.0.13.tgz",
- "integrity": "sha512-eEMwbuF1hJsWNmVp8I5zCmWnIVlgTV+9w6wrkfcX6SMvEliotZ4ROZ/njndbFqzLRSID/+RptfYXLGYw2ZbswQ==",
- "license": "MIT",
- "engines": {
- "node": ">=22.16.0",
- "npm": ">=10.0.0"
- }
+ "node_modules/@emprespresso/ci_model": {
+ "resolved": "../model",
+ "link": true
},
"node_modules/@esbuild/linux-x64": {
"version": "0.25.5",
@@ -44,6 +42,16 @@
"node": ">=18"
}
},
+ "node_modules/@types/node": {
+ "version": "24.10.1",
+ "resolved": "https://registry.npmjs.org/@types/node/-/node-24.10.1.tgz",
+ "integrity": "sha512-GNWcUTRBgIRJD5zj+Tq0fKOJ5XZajIiBroOF0yvj2bSU1WvNdYS/dn9UxwsujGW4JX06dnHyjV2y9rRaybH0iQ==",
+ "dev": true,
+ "license": "MIT",
+ "dependencies": {
+ "undici-types": "~7.16.0"
+ }
+ },
"node_modules/esbuild": {
"version": "0.25.5",
"dev": true,
@@ -82,6 +90,13 @@
"@esbuild/win32-ia32": "0.25.5",
"@esbuild/win32-x64": "0.25.5"
}
+ },
+ "node_modules/undici-types": {
+ "version": "7.16.0",
+ "resolved": "https://registry.npmjs.org/undici-types/-/undici-types-7.16.0.tgz",
+ "integrity": "sha512-Zz+aZWSj8LE6zoxD+xrjh4VfkIG8Ya6LvYkZqtUQGJPZjYl53ypCaUwWqo7eI0x66KBGeRo+mlBEkMSeSZ38Nw==",
+ "dev": true,
+ "license": "MIT"
}
}
}
diff --git a/.ci/package.json b/.ci/package.json
index 181970e..e8b3c72 100644
--- a/.ci/package.json
+++ b/.ci/package.json
@@ -4,9 +4,10 @@
"clean": "rm -rf dist ci.cjs"
},
"dependencies": {
- "@emprespresso/ci_model": "^0.2.0"
+ "@emprespresso/ci_model": "^0.3.0"
},
"devDependencies": {
+ "@types/node": "^24.10.1",
"esbuild": "0.25.5"
},
"files": [
diff --git a/model/package.json b/model/package.json
index 9f67f58..e4aa44d 100644
--- a/model/package.json
+++ b/model/package.json
@@ -1,6 +1,6 @@
{
"name": "@emprespresso/ci_model",
- "version": "0.2.0",
+ "version": "0.3.0",
"type": "module",
"main": "./dist/index.js",
"types": "./dist/index.d.ts",
@@ -17,7 +17,7 @@
"type-check": "tsc --noEmit"
},
"dependencies": {
- "@emprespresso/pengueno": "^0.0.16"
+ "@emprespresso/pengueno": "^0.0.17"
},
"devDependencies": {
"typescript": "^5.9.3",
diff --git a/package-lock.json b/package-lock.json
index fdf8950..4497054 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -29,9 +29,9 @@
},
"model": {
"name": "@emprespresso/ci_model",
- "version": "0.2.0",
+ "version": "0.3.0",
"dependencies": {
- "@emprespresso/pengueno": "^0.0.16"
+ "@emprespresso/pengueno": "^0.0.17"
},
"devDependencies": {
"@types/node": "^24.10.1",
@@ -1250,13 +1250,17 @@
"link": true
},
"node_modules/@emprespresso/pengueno": {
- "version": "0.0.16",
- "resolved": "https://registry.npmjs.org/@emprespresso/pengueno/-/pengueno-0.0.16.tgz",
- "integrity": "sha512-w7j2kSnowesUzol+Je5JXvnxO9gooAMObiToifYR4UsciT0TyRbm7p7XkNiJhADHPLo6KDaCNwdCKTrvNfFzEQ==",
+ "version": "0.0.17",
+ "resolved": "https://registry.npmjs.org/@emprespresso/pengueno/-/pengueno-0.0.17.tgz",
+ "integrity": "sha512-pyfXLYGoLlQlMQAyYptRLLiRrnQmCju4I1/sv1KtsJv06oPvNqzHqUzJJGHrXg/90krg7GRcxLKQ0TnQ2Bskjw==",
"license": "MIT",
"engines": {
"node": ">=22.16.0",
"npm": ">=10.0.0"
+ },
+ "optionalDependencies": {
+ "@hono/node-server": "^1.18.2",
+ "hono": "^4.8.0"
}
},
"node_modules/@eslint-community/eslint-utils": {
@@ -4415,7 +4419,7 @@
"version": "0.1.0",
"dependencies": {
"@emprespresso/ci_model": "*",
- "@emprespresso/pengueno": "^0.0.16",
+ "@emprespresso/pengueno": "^0.0.17",
"@hono/node-server": "^1.14.0",
"hono": "^4.8.9"
}
@@ -4425,12 +4429,30 @@
"version": "0.1.0",
"dependencies": {
"@emprespresso/ci_model": "^0.2.0",
- "@emprespresso/pengueno": "^0.0.16",
+ "@emprespresso/pengueno": "^0.0.17",
"@infisical/sdk": "^4.0.6"
},
"devDependencies": {
"copyfiles": "2.4.1"
}
+ },
+ "worker/node_modules/@emprespresso/ci_model": {
+ "version": "0.2.0",
+ "resolved": "https://registry.npmjs.org/@emprespresso/ci_model/-/ci_model-0.2.0.tgz",
+ "integrity": "sha512-yFr0WdAPxf0jhLwdjUUv8KikXVRuT7n81vWt+Km8w6FeKqFtf6h8+ZSIm301X/lEB9x77+CnAN+29NkpyQbPHA==",
+ "dependencies": {
+ "@emprespresso/pengueno": "^0.0.13"
+ }
+ },
+ "worker/node_modules/@emprespresso/ci_model/node_modules/@emprespresso/pengueno": {
+ "version": "0.0.13",
+ "resolved": "https://registry.npmjs.org/@emprespresso/pengueno/-/pengueno-0.0.13.tgz",
+ "integrity": "sha512-eEMwbuF1hJsWNmVp8I5zCmWnIVlgTV+9w6wrkfcX6SMvEliotZ4ROZ/njndbFqzLRSID/+RptfYXLGYw2ZbswQ==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=22.16.0",
+ "npm": ">=10.0.0"
+ }
}
}
}
diff --git a/server/package.json b/server/package.json
index f007ad7..d2dfab4 100644
--- a/server/package.json
+++ b/server/package.json
@@ -20,7 +20,7 @@
"format:check": "prettier --check ."
},
"dependencies": {
- "@emprespresso/pengueno": "^0.0.16",
+ "@emprespresso/pengueno": "^0.0.17",
"@emprespresso/ci_model": "*",
"@hono/node-server": "^1.14.0",
"hono": "^4.8.9"
diff --git a/worker/package.json b/worker/package.json
index d046153..74d09bf 100644
--- a/worker/package.json
+++ b/worker/package.json
@@ -18,7 +18,7 @@
},
"dependencies": {
"@emprespresso/ci_model": "^0.2.0",
- "@emprespresso/pengueno": "^0.0.16",
+ "@emprespresso/pengueno": "^0.0.17",
"@infisical/sdk": "^4.0.6"
},
"devDependencies": {
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-02-05 10:31:13 +0000