@effect-aws/lambda - npm Package Compare versions

Comparing version 1.5.2 to 1.6.0

dist/cjs/internal/aws/api-gateway-v1.js

 "use strict";
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) 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 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 var __importDefault = (this && this.__importDefault) || function (mod) {
@@ -7,3 +30,3 @@ return (mod && mod.__esModule) ? mod : { "default": mod };
 const node_url_1 = __importDefault(require("node:url"));
-const effect_1 = require("effect");
+const Record = __importStar(require("effect/Record"));
 const utils_js_1 = require("../utils.js");
@@ -36,3 +59,3 @@ function getPathWithQueryStringParams(event) {
         body,
-        headers: effect_1.Record.map(headers, String),
+        headers: Record.map(headers, String),
         multiValueHeaders,
@@ -39,0 +62,0 @@ isBase64Encoded,

dist/cjs/internal/aws/api-gateway-v1.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"api-gateway-v1.js","sourceRoot":"","sources":["../../../../src/internal/aws/api-gateway-v1.ts"],"names":[],"mappings":";;;;;AAAA,wDAA2B;AAE3B,mCAAgC;AAGhC,0CAA8E;AAE9E,SAAS,4BAA4B,CAAC,KAA2B;IAC/D,4FAA4F;IAC5F,MAAM,IAAI,GAAG,CAAC,KAAK,CAAC,cAAc;QAChC,KAAK,CAAC,cAAc,CAAC,KAAK;QAC1B,IAAI,KAAK,CAAC,cAAc,CAAC,KAAK,EAAE,CAAC;QACjC,KAAK,CAAC,IAAI,CAAC;IACb,OAAO,kBAAG,CAAC,MAAM,CAAC;QAChB,2CAA2C;QAC3C,QAAQ,EAAE,IAAI,CAAC,OAAO,CAAC,IAAI,MAAM,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC;QAC3C,KAAK,EAAE,KAAK,CAAC,+BAA+B;KAC7C,CAAC,CAAC;AACL,CAAC;AAED,MAAM,mCAAmC,GAAG,CAAC,KAA2B,EAAE,EAAE,CAC1E,IAAA,oCAAyB,EAAC;IACxB,KAAK;IACL,IAAI,EAAE,4BAA4B,CAAC,KAAK,CAAC;CAC1C,CAAC,CAAC;AAEL,MAAM,uBAAuB,GAA4E,CACvG,EAAE,IAAI,EAAE,OAAO,EAAE,eAAe,EAAE,UAAU,EAAE,EAC9C,EAAE;IACF,MAAM,iBAAiB,GAAG,IAAA,+BAAoB,EAAC,OAAO,CAAC,CAAC;IACxD,MAAM,sBAAsB,GAAG,iBAAiB,CAAC,mBAAmB,CAAC,CAAC;IAEtE,0DAA0D;IAC1D,IAAI,sBAAsB,IAAI,sBAAsB,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE,CAAC;QACzE,iBAAiB,CAAC,mBAAmB,CAAC,GAAG,sBAAsB,CAAC,MAAM,CACpE,CAAC,WAAW,EAAE,EAAE,CAAC,WAAW,KAAK,SAAS,CAC3C,CAAC;IACJ,CAAC;IAED,OAAO;QACL,UAAU;QACV,IAAI;QACJ,OAAO,EAAE,eAAM,CAAC,GAAG,CAAC,OAAO,EAAE,MAAM,CAAC;QACpC,iBAAiB;QACjB,eAAe;KAChB,CAAC;AACJ,CAAC,CAAC;AAEF,kBAAe;IACb,UAAU,EAAE,mCAAmC;IAC/C,WAAW,EAAE,uBAAuB;CACuB,CAAC"}
+{"version":3,"file":"api-gateway-v1.js","sourceRoot":"","sources":["../../../../src/internal/aws/api-gateway-v1.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,wDAA2B;AAE3B,sDAAwC;AAGxC,0CAA8E;AAE9E,SAAS,4BAA4B,CAAC,KAA2B;IAC/D,4FAA4F;IAC5F,MAAM,IAAI,GAAG,CAAC,KAAK,CAAC,cAAc;QAChC,KAAK,CAAC,cAAc,CAAC,KAAK;QAC1B,IAAI,KAAK,CAAC,cAAc,CAAC,KAAK,EAAE,CAAC;QACjC,KAAK,CAAC,IAAI,CAAC;IACb,OAAO,kBAAG,CAAC,MAAM,CAAC;QAChB,2CAA2C;QAC3C,QAAQ,EAAE,IAAI,CAAC,OAAO,CAAC,IAAI,MAAM,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC;QAC3C,KAAK,EAAE,KAAK,CAAC,+BAA+B;KAC7C,CAAC,CAAC;AACL,CAAC;AAED,MAAM,mCAAmC,GAAG,CAAC,KAA2B,EAAE,EAAE,CAC1E,IAAA,oCAAyB,EAAC;IACxB,KAAK;IACL,IAAI,EAAE,4BAA4B,CAAC,KAAK,CAAC;CAC1C,CAAC,CAAC;AAEL,MAAM,uBAAuB,GAA4E,CACvG,EAAE,IAAI,EAAE,OAAO,EAAE,eAAe,EAAE,UAAU,EAAE,EAC9C,EAAE;IACF,MAAM,iBAAiB,GAAG,IAAA,+BAAoB,EAAC,OAAO,CAAC,CAAC;IACxD,MAAM,sBAAsB,GAAG,iBAAiB,CAAC,mBAAmB,CAAC,CAAC;IAEtE,0DAA0D;IAC1D,IAAI,sBAAsB,IAAI,sBAAsB,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE,CAAC;QACzE,iBAAiB,CAAC,mBAAmB,CAAC,GAAG,sBAAsB,CAAC,MAAM,CACpE,CAAC,WAAW,EAAE,EAAE,CAAC,WAAW,KAAK,SAAS,CAC3C,CAAC;IACJ,CAAC;IAED,OAAO;QACL,UAAU;QACV,IAAI;QACJ,OAAO,EAAE,MAAM,CAAC,GAAG,CAAC,OAAO,EAAE,MAAM,CAAC;QACpC,iBAAiB;QACjB,eAAe;KAChB,CAAC;AACJ,CAAC,CAAC;AAEF,kBAAe;IACb,UAAU,EAAE,mCAAmC;IAC/C,WAAW,EAAE,uBAAuB;CACuB,CAAC"}

dist/cjs/internal/lambdaHandler.js

 "use strict";
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) 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 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.lambdaContextTag = exports.lambdaEventTag = void 0;
-const effect_1 = require("effect");
+const Context = __importStar(require("effect/Context"));
 /** @internal */
-exports.lambdaEventTag = effect_1.Context.GenericTag("@effect-aws/lambda/LambdaHandler/Event");
+exports.lambdaEventTag = Context.GenericTag("@effect-aws/lambda/LambdaHandler/Event");
 /** @internal */
-exports.lambdaContextTag = effect_1.Context.GenericTag("@effect-aws/lambda/LambdaHandler/Context");
+exports.lambdaContextTag = Context.GenericTag("@effect-aws/lambda/LambdaHandler/Context");
 //# sourceMappingURL=lambdaHandler.js.map

dist/cjs/internal/lambdaHandler.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"lambdaHandler.js","sourceRoot":"","sources":["../../../src/internal/lambdaHandler.ts"],"names":[],"mappings":";;;AAAA,mCAAiC;AAIjC,gBAAgB;AACH,QAAA,cAAc,GAAG,gBAAO,CAAC,UAAU,CAC9C,wCAAwC,CACzC,CAAC;AAEF,gBAAgB;AACH,QAAA,gBAAgB,GAAG,gBAAO,CAAC,UAAU,CAChD,0CAA0C,CAC3C,CAAC"}
+{"version":3,"file":"lambdaHandler.js","sourceRoot":"","sources":["../../../src/internal/lambdaHandler.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,wDAA0C;AAI1C,gBAAgB;AACH,QAAA,cAAc,GAAG,OAAO,CAAC,UAAU,CAC9C,wCAAwC,CACzC,CAAC;AAEF,gBAAgB;AACH,QAAA,gBAAgB,GAAG,OAAO,CAAC,UAAU,CAChD,0CAA0C,CAC3C,CAAC"}

dist/cjs/internal/stream.js

@@ -27,12 +27,14 @@ "use strict";
 exports.pipeTo = exports.pipeline = void 0;
-const platform_1 = require("@effect/platform");
 const NodeStream = __importStar(require("@effect/platform-node-shared/NodeStream"));
-const effect_1 = require("effect");
+const Error = __importStar(require("@effect/platform/Error"));
+const Effect = __importStar(require("effect/Effect"));
 const Function_1 = require("effect/Function");
+const Predicate = __importStar(require("effect/Predicate"));
+const Stream = __importStar(require("effect/Stream"));
 const NS = __importStar(require("node:stream/promises"));
 /** @internal */
-const isStream = (u) => effect_1.Predicate.hasProperty(u, effect_1.Stream.StreamTypeId);
+const isStream = (u) => Predicate.hasProperty(u, Stream.StreamTypeId);
 const handleErrnoException = (module, method) => (err) => {
     const reason = "Unknown";
-    return new platform_1.Error.SystemError({
+    return new Error.SystemError({
         reason,
@@ -48,3 +50,3 @@ module,
 /** @internal */
-const pipeline = (source, destination, options) => effect_1.Effect.tryPromise({
+const pipeline = (source, destination, options) => Effect.tryPromise({
     try: (signal) => NS.pipeline(source, destination, { ...options, signal }),
@@ -55,3 +57,3 @@ catch: handleErrnoException("Stream", "pipeline"),
 /** @internal */
-exports.pipeTo = (0, Function_1.dual)((args) => isStream(args[0]), (stream, writable, options) => stream.pipe(NodeStream.toReadable, effect_1.Effect.flatMap((readable) => (0, exports.pipeline)(readable, writable, options))));
+exports.pipeTo = (0, Function_1.dual)((args) => isStream(args[0]), (stream, writable, options) => stream.pipe(NodeStream.toReadable, Effect.flatMap((readable) => (0, exports.pipeline)(readable, writable, options))));
 //# sourceMappingURL=stream.js.map

dist/cjs/internal/stream.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"stream.js","sourceRoot":"","sources":["../../../src/internal/stream.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,+CAAyC;AACzC,oFAAsE;AACtE,mCAAmD;AACnD,8CAAuC;AAEvC,yDAA2C;AAE3C,gBAAgB;AAChB,MAAM,QAAQ,GAAG,CAAC,CAAU,EAAwC,EAAE,CAAC,kBAAS,CAAC,WAAW,CAAC,CAAC,EAAE,eAAM,CAAC,YAAY,CAAC,CAAC;AAErH,MAAM,oBAAoB,GACxB,CAAC,MAAmC,EAAE,MAAc,EAAE,EAAE,CAAC,CAAC,GAAY,EAAuB,EAAE;IAC7F,MAAM,MAAM,GAA4B,SAAS,CAAC;IAElD,OAAO,IAAI,gBAAK,CAAC,WAAW,CAAC;QAC3B,MAAM;QACN,MAAM;QACN,MAAM;QACN,gBAAgB,EAAE,EAAE;QACpB,OAAO,EAAG,GAA6B,CAAC,OAAO;QAC/C,WAAW,EAAG,GAA6B,CAAC,OAAO;QACnD,KAAK,EAAE,GAAG;KACX,CAAC,CAAC;AACL,CAAC,CAAC;AAEJ,gBAAgB;AACT,MAAM,QAAQ,GAMjB,CAAC,MAAM,EAAE,WAAW,EAAE,OAAO,EAAE,EAAE,CACnC,eAAM,CAAC,UAAU,CAAC;IAChB,GAAG,EAAE,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE,CAAC,QAAQ,CAAC,MAAM,EAAE,WAAW,EAAE,EAAE,GAAG,OAAO,EAAE,MAAM,EAAE,CAAC;IACzE,KAAK,EAAE,oBAAoB,CAAC,QAAQ,EAAE,UAAU,CAAC;CAClD,CAAC,CAAC;AAVQ,QAAA,QAAQ,YAUhB;AAEL,gBAAgB;AACH,QAAA,MAAM,GAUf,IAAA,eAAI,EACN,CAAC,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAC3B,CACE,MAAgD,EAChD,QAA+B,EAC/B,OAA4C,EAC5C,EAAE,CACF,MAAM,CAAC,IAAI,CACT,UAAU,CAAC,UAAU,EACrB,eAAM,CAAC,OAAO,CAAC,CAAC,QAAQ,EAAE,EAAE,CAAC,IAAA,gBAAQ,EAAC,QAAQ,EAAE,QAAQ,EAAE,OAAO,CAAC,CAAC,CACpE,CACJ,CAAC"}
+{"version":3,"file":"stream.js","sourceRoot":"","sources":["../../../src/internal/stream.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,oFAAsE;AACtE,8DAAgD;AAChD,sDAAwC;AACxC,8CAAuC;AACvC,4DAA8C;AAC9C,sDAAwC;AAExC,yDAA2C;AAE3C,gBAAgB;AAChB,MAAM,QAAQ,GAAG,CAAC,CAAU,EAAwC,EAAE,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC;AAErH,MAAM,oBAAoB,GACxB,CAAC,MAAmC,EAAE,MAAc,EAAE,EAAE,CAAC,CAAC,GAAY,EAAuB,EAAE;IAC7F,MAAM,MAAM,GAA4B,SAAS,CAAC;IAElD,OAAO,IAAI,KAAK,CAAC,WAAW,CAAC;QAC3B,MAAM;QACN,MAAM;QACN,MAAM;QACN,gBAAgB,EAAE,EAAE;QACpB,OAAO,EAAG,GAA6B,CAAC,OAAO;QAC/C,WAAW,EAAG,GAA6B,CAAC,OAAO;QACnD,KAAK,EAAE,GAAG;KACX,CAAC,CAAC;AACL,CAAC,CAAC;AAEJ,gBAAgB;AACT,MAAM,QAAQ,GAMjB,CAAC,MAAM,EAAE,WAAW,EAAE,OAAO,EAAE,EAAE,CACnC,MAAM,CAAC,UAAU,CAAC;IAChB,GAAG,EAAE,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE,CAAC,QAAQ,CAAC,MAAM,EAAE,WAAW,EAAE,EAAE,GAAG,OAAO,EAAE,MAAM,EAAE,CAAC;IACzE,KAAK,EAAE,oBAAoB,CAAC,QAAQ,EAAE,UAAU,CAAC;CAClD,CAAC,CAAC;AAVQ,QAAA,QAAQ,YAUhB;AAEL,gBAAgB;AACH,QAAA,MAAM,GAUf,IAAA,eAAI,EACN,CAAC,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAC3B,CACE,MAAgD,EAChD,QAA+B,EAC/B,OAA4C,EAC5C,EAAE,CACF,MAAM,CAAC,IAAI,CACT,UAAU,CAAC,UAAU,EACrB,MAAM,CAAC,OAAO,CAAC,CAAC,QAAQ,EAAE,EAAE,CAAC,IAAA,gBAAQ,EAAC,QAAQ,EAAE,QAAQ,EAAE,OAAO,CAAC,CAAC,CACpE,CACJ,CAAC"}

dist/cjs/LambdaHandler.d.ts

 /**
  * @since 1.4.0
  */
-import type { HttpApi, HttpRouter } from "@effect/platform";
-import { HttpApiBuilder, HttpApp } from "@effect/platform";
-import type { Cause } from "effect";
-import { Context, Effect, Layer } from "effect";
+import type * as HttpApi from "@effect/platform/HttpApi";
+import * as HttpApiBuilder from "@effect/platform/HttpApiBuilder";
+import * as HttpApp from "@effect/platform/HttpApp";
+import type * as HttpRouter from "@effect/platform/HttpRouter";
+import type * as Cause from "effect/Cause";
+import * as Context from "effect/Context";
+import * as Effect from "effect/Effect";
+import * as Layer from "effect/Layer";
 import type { ALBEvent, ALBResult, APIGatewayProxyEvent, APIGatewayProxyEventV2, APIGatewayProxyResult, APIGatewayProxyResultV2, CloudFrontRequestEvent, DynamoDBStreamEvent, EffectHandler, EffectHandlerWithLayer, EventBridgeEvent, Handler, KinesisStreamEvent, LambdaContext, S3Event, SelfManagedKafkaEvent, SNSEvent, SQSEvent, StreamHandler, StreamHandlerWithLayer } from "./Types.js";
@@ -9,0 +13,0 @@ /**

dist/cjs/LambdaHandler.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"LambdaHandler.d.ts","sourceRoot":"","sources":["../../src/LambdaHandler.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,EAAE,OAAO,EAAE,UAAU,EAAE,MAAM,kBAAkB,CAAC;AAC5D,OAAO,EAAE,cAAc,EAAE,OAAO,EAAE,MAAM,kBAAkB,CAAC;AAC3D,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,QAAQ,CAAC;AACpC,OAAO,EAAE,OAAO,EAAE,MAAM,EAAY,KAAK,EAAE,MAAM,QAAQ,CAAC;AAO1D,OAAO,KAAK,EACV,QAAQ,EACR,SAAS,EACT,oBAAoB,EACpB,sBAAsB,EACtB,qBAAqB,EACrB,uBAAuB,EACvB,sBAAsB,EACtB,mBAAmB,EACnB,aAAa,EACb,sBAAsB,EACtB,gBAAgB,EAChB,OAAO,EACP,kBAAkB,EAClB,aAAa,EACb,OAAO,EACP,qBAAqB,EACrB,QAAQ,EACR,QAAQ,EACR,aAAa,EACb,sBAAsB,EACvB,MAAM,YAAY,CAAC;AAEpB;;GAEG;AACH,MAAM,CAAC,OAAO,WAAW,aAAa,CAAC;IACrC;;;OAGG;IACH,KAAY,KAAK,GACb,QAAQ,GACR,oBAAoB,GACpB,sBAAsB,GACtB,gBAAgB,CAAC,MAAM,EAAE,OAAO,CAAC,GACjC,mBAAmB,GACnB,kBAAkB,GAClB,OAAO,GACP,qBAAqB,GACrB,QAAQ,GACR,QAAQ,GACR,sBAAsB,CAAC;IAE3B;;;OAGG;IACH,KAAY,MAAM,GACd,SAAS,GACT,qBAAqB,GACrB,uBAAuB,GACvB,IAAI,CAAC;CACV;AAED;;;GAGG;AACH,eAAO,MAAM,KAAK,uCAAsC,OAAO,MAAM,CAAC,CAAC,CAIhD,CAAC;AAExB;;;GAGG;AACH,eAAO,MAAM,OAAO,QAAO,OAAO,MAAM,CAAC,aAAa,CAInD,CAAC;AAEJ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,eAAO,MAAM,IAAI,EAAE;IACjB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACnF,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACjE;;;;;;;;;OASG;IACH,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,EAAE,WAAW,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;CAqBxG,CAAC;AAEF;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,eAAO,MAAM,MAAM,EAAE;IACnB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,OAAO,EAAE,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;IAChF,CAAC,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;CAqB/D,CAAC;AAEF,UAAU,cAAc;IACtB,QAAQ,CAAC,UAAU,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,OAAO,KAAK,OAAO,CAAC,OAAO,CACjE,KAAK,EACL,OAAO,CAAC,GAAG,GAAG,cAAc,CAAC,MAAM,GAAG,UAAU,CAAC,UAAU,CAAC,eAAe,CAC5E,CAAC;IACF,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC;AAED,KAAK,UAAU,GAAG,UAAU,CAAC,OAAO,OAAO,CAAC,YAAY,CAAC,CAAC;AAC1D,QAAA,MAAM,UAAU,2LAAkE,CAAC;AAEnF;;;;;GAKG;AACH,eAAO,MAAM,cAAc,aAAc,KAAK,cAAc,EAAE,YAAY,CAAC,KAAG,OAAO,MAAM,CACzF,UAAU,EACV,KAAK,EACH,eAAe,MAAM,GACrB,QAAQ,GAAG,GACX,WAAW,UAAU,CAAC,eAAe,GACrC,eAAe,UAAU,GACzB,mBAAmB,GACnB,aAAa,CAUb,CAAC;AAEL;;;;;GAKG;AACH,eAAO,MAAM,cAAc,aAAc,KAAK,cAAc,EAAE,YAAY,CAAC,KAAG,cAC5E,mBAAmB,EACnB,QAAQ,GAAG,GAAG,eAAe,MAAM,GAAG,WAAW,UAAU,CAAC,eAAe,GAAG,eAAe,UAAU,EACvG,MAAM,gBAAgB,EACtB,cAAc,MAAM,CA4DlB,CAAC;AAEL;;;;;;;;;;;;;;;;;;;;;;;;;GAyBG;AACH,eAAO,MAAM,WAAW,kBACf,MAAM,KAAK,CAAC,EAAE,GAAG,QAAQ,GAAG,GAAG,WAAW,UAAU,CAAC,eAAe,EAAE,EAAE,CAAC,YACtE,cAAc,KACvB,QAAQ,mBAAmB,EAAE,cAAc,MAAM,CAGnD,CAAC"}
+{"version":3,"file":"LambdaHandler.d.ts","sourceRoot":"","sources":["../../src/LambdaHandler.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,KAAK,OAAO,MAAM,0BAA0B,CAAC;AACzD,OAAO,KAAK,cAAc,MAAM,iCAAiC,CAAC;AAClE,OAAO,KAAK,OAAO,MAAM,0BAA0B,CAAC;AACpD,OAAO,KAAK,KAAK,UAAU,MAAM,6BAA6B,CAAC;AAC/D,OAAO,KAAK,KAAK,KAAK,MAAM,cAAc,CAAC;AAC3C,OAAO,KAAK,OAAO,MAAM,gBAAgB,CAAC;AAC1C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAC;AAExC,OAAO,KAAK,KAAK,MAAM,cAAc,CAAC;AAOtC,OAAO,KAAK,EACV,QAAQ,EACR,SAAS,EACT,oBAAoB,EACpB,sBAAsB,EACtB,qBAAqB,EACrB,uBAAuB,EACvB,sBAAsB,EACtB,mBAAmB,EACnB,aAAa,EACb,sBAAsB,EACtB,gBAAgB,EAChB,OAAO,EACP,kBAAkB,EAClB,aAAa,EACb,OAAO,EACP,qBAAqB,EACrB,QAAQ,EACR,QAAQ,EACR,aAAa,EACb,sBAAsB,EACvB,MAAM,YAAY,CAAC;AAEpB;;GAEG;AACH,MAAM,CAAC,OAAO,WAAW,aAAa,CAAC;IACrC;;;OAGG;IACH,KAAY,KAAK,GACb,QAAQ,GACR,oBAAoB,GACpB,sBAAsB,GACtB,gBAAgB,CAAC,MAAM,EAAE,OAAO,CAAC,GACjC,mBAAmB,GACnB,kBAAkB,GAClB,OAAO,GACP,qBAAqB,GACrB,QAAQ,GACR,QAAQ,GACR,sBAAsB,CAAC;IAE3B;;;OAGG;IACH,KAAY,MAAM,GACd,SAAS,GACT,qBAAqB,GACrB,uBAAuB,GACvB,IAAI,CAAC;CACV;AAED;;;GAGG;AACH,eAAO,MAAM,KAAK,uCAAsC,OAAO,MAAM,CAAC,CAAC,CAIhD,CAAC;AAExB;;;GAGG;AACH,eAAO,MAAM,OAAO,QAAO,OAAO,MAAM,CAAC,aAAa,CAInD,CAAC;AAEJ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,eAAO,MAAM,IAAI,EAAE;IACjB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACnF,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACjE;;;;;;;;;OASG;IACH,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,EAAE,WAAW,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;CAqBxG,CAAC;AAEF;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,eAAO,MAAM,MAAM,EAAE;IACnB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,OAAO,EAAE,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;IAChF,CAAC,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;CAqB/D,CAAC;AAEF,UAAU,cAAc;IACtB,QAAQ,CAAC,UAAU,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,OAAO,KAAK,OAAO,CAAC,OAAO,CACjE,KAAK,EACL,OAAO,CAAC,GAAG,GAAG,cAAc,CAAC,MAAM,GAAG,UAAU,CAAC,UAAU,CAAC,eAAe,CAC5E,CAAC;IACF,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC;AAED,KAAK,UAAU,GAAG,UAAU,CAAC,OAAO,OAAO,CAAC,YAAY,CAAC,CAAC;AAC1D,QAAA,MAAM,UAAU,2LAAkE,CAAC;AAEnF;;;;;GAKG;AACH,eAAO,MAAM,cAAc,aAAc,KAAK,cAAc,EAAE,YAAY,CAAC,KAAG,OAAO,MAAM,CACzF,UAAU,EACV,KAAK,EACH,eAAe,MAAM,GACrB,QAAQ,GAAG,GACX,WAAW,UAAU,CAAC,eAAe,GACrC,eAAe,UAAU,GACzB,mBAAmB,GACnB,aAAa,CAUb,CAAC;AAEL;;;;;GAKG;AACH,eAAO,MAAM,cAAc,aAAc,KAAK,cAAc,EAAE,YAAY,CAAC,KAAG,cAC5E,mBAAmB,EACnB,QAAQ,GAAG,GAAG,eAAe,MAAM,GAAG,WAAW,UAAU,CAAC,eAAe,GAAG,eAAe,UAAU,EACvG,MAAM,gBAAgB,EACtB,cAAc,MAAM,CA4DlB,CAAC;AAEL;;;;;;;;;;;;;;;;;;;;;;;;;GAyBG;AACH,eAAO,MAAM,WAAW,kBACf,MAAM,KAAK,CAAC,EAAE,GAAG,QAAQ,GAAG,GAAG,WAAW,UAAU,CAAC,eAAe,EAAE,EAAE,CAAC,YACtE,cAAc,KACvB,QAAQ,mBAAmB,EAAE,cAAc,MAAM,CAGnD,CAAC"}

dist/cjs/LambdaHandler.js

@@ -27,4 +27,8 @@ "use strict";
 exports.fromHttpApi = exports.httpApiHandler = exports.makeWebHandler = exports.stream = exports.make = exports.context = exports.event = void 0;
-const platform_1 = require("@effect/platform");
-const effect_1 = require("effect");
+const HttpApiBuilder = __importStar(require("@effect/platform/HttpApiBuilder"));
+const HttpApp = __importStar(require("@effect/platform/HttpApp"));
+const Context = __importStar(require("effect/Context"));
+const Effect = __importStar(require("effect/Effect"));
+const Function = __importStar(require("effect/Function"));
+const Layer = __importStar(require("effect/Layer"));
 const index_js_1 = require("./internal/index.js");
@@ -39,3 +43,3 @@ const internal = __importStar(require("./internal/lambdaHandler.js"));
  */
-const event = () => effect_1.Effect.map(effect_1.Effect.context(), (context) => effect_1.Context.unsafeGet(context, internal.lambdaEventTag));
+const event = () => Effect.map(Effect.context(), (context) => Context.unsafeGet(context, internal.lambdaEventTag));
 exports.event = event;
@@ -46,3 +50,3 @@ /**
  */
-const context = () => effect_1.Effect.map(effect_1.Effect.context(), (context) => effect_1.Context.unsafeGet(context, internal.lambdaContextTag));
+const context = () => Effect.map(Effect.context(), (context) => Context.unsafeGet(context, internal.lambdaContextTag));
 exports.context = context;
@@ -82,3 +86,3 @@ /**
 const make = (handlerOrOptions, globalLayer) => {
-    if (effect_1.Function.isFunction(handlerOrOptions)) {
+    if (Function.isFunction(handlerOrOptions)) {
         // Deprecated case
@@ -89,3 +93,3 @@ if (globalLayer) {
         }
-        return async (event, context) => handlerOrOptions(event, context).pipe(effect_1.Effect.runPromise);
+        return async (event, context) => handlerOrOptions(event, context).pipe(Effect.runPromise);
     }
@@ -132,4 +136,4 @@ const runtime = LambdaRuntime.fromLayer(handlerOrOptions.layer, { memoMap: handlerOrOptions.memoMap });
 const stream = (handlerOrOptions) => {
-    if (effect_1.Function.isFunction(handlerOrOptions)) {
-        return global.awslambda?.streamifyResponse(async (event, responseStream, context) => handlerOrOptions(event, context).pipe((0, stream_js_1.pipeTo)(responseStream, { end: true }), effect_1.Effect.runPromise));
+    if (Function.isFunction(handlerOrOptions)) {
+        return global.awslambda?.streamifyResponse(async (event, responseStream, context) => handlerOrOptions(event, context).pipe((0, stream_js_1.pipeTo)(responseStream, { end: true }), Effect.runPromise));
     }
@@ -143,3 +147,3 @@ const runtime = LambdaRuntime.fromLayer(handlerOrOptions.layer, { memoMap: handlerOrOptions.memoMap });
 exports.stream = stream;
-const WebHandler = effect_1.Context.GenericTag("@effect-aws/lambda/WebHandler");
+const WebHandler = Context.GenericTag("@effect-aws/lambda/WebHandler");
 /**
@@ -151,6 +155,6 @@ * Construct an `WebHandler` from an `HttpApi` instance.
  */
-const makeWebHandler = (options) => effect_1.Effect.gen(function* () {
-    const app = yield* platform_1.HttpApiBuilder.httpApp;
-    const rt = yield* effect_1.Effect.runtime();
-    return platform_1.HttpApp.toWebHandlerRuntime(rt)(options?.middleware ? options.middleware(app) : app);
+const makeWebHandler = (options) => Effect.gen(function* () {
+    const app = yield* HttpApiBuilder.httpApp;
+    const rt = yield* Effect.runtime();
+    return HttpApp.toWebHandlerRuntime(rt)(options?.middleware ? options.middleware(app) : app);
 });
@@ -164,3 +168,3 @@ exports.makeWebHandler = makeWebHandler;
  */
-const httpApiHandler = (options) => (event, context) => effect_1.Effect.gen(function* () {
+const httpApiHandler = (options) => (event, context) => Effect.gen(function* () {
     const eventSource = (0, index_js_1.getEventSource)(event);
@@ -173,3 +177,3 @@ const requestValues = eventSource.getRequest(event);
     });
-    const res = yield* (0, exports.makeWebHandler)(options).pipe(effect_1.Effect.provideService(internal.lambdaEventTag, event), effect_1.Effect.provideService(internal.lambdaContextTag, context), effect_1.Effect.andThen((handler) => handler(req)));
+    const res = yield* (0, exports.makeWebHandler)(options).pipe(Effect.provideService(internal.lambdaEventTag, event), Effect.provideService(internal.lambdaContextTag, context), Effect.andThen((handler) => handler(req)));
     const contentType = res.headers.get("content-type");
@@ -182,4 +186,4 @@ let isBase64Encoded = contentType && (0, utils_js_1.isContentTypeBinary)(contentType) ? true : false;
     const body = isBase64Encoded
-        ? (0, utils_js_1.encodeBase64)(yield* effect_1.Effect.promise(() => res.arrayBuffer()))
-        : yield* effect_1.Effect.promise(() => res.text());
+        ? (0, utils_js_1.encodeBase64)(yield* Effect.promise(() => res.arrayBuffer()))
+        : yield* Effect.promise(() => res.text());
     const headers = {};
@@ -236,3 +240,3 @@ if (res.headers.has("set-cookie")) {
 const fromHttpApi = (layer, options) => {
-    const httpApiLayer = effect_1.Layer.mergeAll(layer, platform_1.HttpApiBuilder.Router.Live, platform_1.HttpApiBuilder.Middleware.layer);
+    const httpApiLayer = Layer.mergeAll(layer, HttpApiBuilder.Router.Live, HttpApiBuilder.Middleware.layer);
     return (0, exports.make)({ handler: (0, exports.httpApiHandler)(options), layer: httpApiLayer, memoMap: options?.memoMap });
@@ -239,0 +243,0 @@ };

dist/cjs/LambdaHandler.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"LambdaHandler.js","sourceRoot":"","sources":["../../src/LambdaHandler.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAIA,+CAA2D;AAE3D,mCAA0D;AAC1D,kDAAqD;AACrD,sEAAwD;AACxD,oDAA8C;AAE9C,kDAAiG;AACjG,kEAAoD;AAwDpD;;;GAGG;AACI,MAAM,KAAK,GAAG,GAAoD,EAAE,CACzE,eAAM,CAAC,GAAG,CACR,eAAM,CAAC,OAAO,EAAS,EACvB,CAAC,OAAO,EAAE,EAAE,CAAC,gBAAO,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,cAAc,CAAC,CAC7C,CAAC;AAJX,QAAA,KAAK,SAIM;AAExB;;;GAGG;AACI,MAAM,OAAO,GAAG,GAAiC,EAAE,CACxD,eAAM,CAAC,GAAG,CACR,eAAM,CAAC,OAAO,EAAS,EACvB,CAAC,OAAO,EAAE,EAAE,CAAC,gBAAO,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,gBAAgB,CAAC,CACnE,CAAC;AAJS,QAAA,OAAO,WAIhB;AAEJ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACI,MAAM,IAAI,GAcb,CACF,gBAAsF,EACtF,WAAgC,EACjB,EAAE;IACjB,IAAI,iBAAQ,CAAC,UAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;QAC1C,kBAAkB;QAClB,IAAI,WAAW,EAAE,CAAC;YAChB,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC;YACrD,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,CAAC,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC;QAC7F,CAAC;QAED,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,CAC9B,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,eAAM,CAAC,UAA+D,CAAC,CAAC;IAClH,CAAC;IAED,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,gBAAgB,CAAC,KAAK,EAAE,EAAE,OAAO,EAAE,gBAAgB,CAAC,OAAO,EAAE,CAAC,CAAC;IACvG,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;QAC9B,OAAO,CAAC,8BAA8B,GAAG,KAAK,CAAC;QAC/C,OAAO,gBAAgB,CAAC,OAAO,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC;IAC3E,CAAC,CAAC;AACJ,CAAC,CAAC;AAlCW,QAAA,IAAI,QAkCf;AAEF;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACI,MAAM,MAAM,GAGf,CACF,gBAAgF,EAC9D,EAAE;IACpB,IAAI,iBAAQ,CAAC,UAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;QAC1C,OAAO,MAAM,CAAC,SAAS,EAAE,iBAAiB,CAAC,KAAK,EAAE,KAAK,EAAE,cAAc,EAAE,OAAO,EAAE,EAAE,CAClF,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CACnC,IAAA,kBAAM,EAAC,cAAc,EAAE,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,EACrC,eAAM,CAAC,UAAqE,CAC7E,CACF,CAAC;IACJ,CAAC;IAED,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,gBAAgB,CAAC,KAAK,EAAE,EAAE,OAAO,EAAE,gBAAgB,CAAC,OAAO,EAAE,CAAC,CAAC;IACvG,OAAO,MAAM,CAAC,SAAS,EAAE,iBAAiB,CAAC,KAAK,EAAE,KAAK,EAAE,cAAc,EAAE,OAAO,EAAE,EAAE;QAClF,OAAO,CAAC,8BAA8B,GAAG,KAAK,CAAC;QAC/C,OAAO,gBAAgB,CAAC,OAAO,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAClD,IAAA,kBAAM,EAAC,cAAc,EAAE,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,EACrC,OAAO,CAAC,UAAU,CACnB,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC,CAAC;AAvBW,QAAA,MAAM,UAuBjB;AAWF,MAAM,UAAU,GAAG,gBAAO,CAAC,UAAU,CAAa,+BAA+B,CAAC,CAAC;AAEnF;;;;;GAKG;AACI,MAAM,cAAc,GAAG,CAAC,OAA4C,EASzE,EAAE,CACF,eAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;IAClB,MAAM,GAAG,GAAG,KAAK,CAAC,CAAC,yBAAc,CAAC,OAAO,CAAC;IAC1C,MAAM,EAAE,GAAG,KAAK,CAAC,CAAC,eAAM,CAAC,OAAO,EAE7B,CAAC;IACJ,OAAO,kBAAO,CAAC,mBAAmB,CAAC,EAAE,CAAC,CACpC,OAAO,EAAE,UAAU,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CAAC,GAAU,CAAQ,CAAC,CAAC,CAAC,GAAG,CAClE,CAAC;AACJ,CAAC,CAAC,CAAC;AAlBQ,QAAA,cAAc,kBAkBtB;AAEL;;;;;GAKG;AACI,MAAM,cAAc,GAAG,CAAC,OAA4C,EAKzE,EAAE,CACJ,CAAC,KAAK,EAAE,OAAO,EAAE,EAAE,CACjB,eAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;IAClB,MAAM,WAAW,GAAG,IAAA,yBAAc,EAAC,KAAK,CAA2D,CAAC;IACpG,MAAM,aAAa,GAAG,WAAW,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAEpD,MAAM,GAAG,GAAG,IAAI,OAAO,CACrB,WAAW,aAAa,CAAC,aAAa,GAAG,aAAa,CAAC,IAAI,EAAE,EAC7D;QACE,MAAM,EAAE,aAAa,CAAC,MAAM;QAC5B,OAAO,EAAE,aAAa,CAAC,OAAO;QAC9B,IAAI,EAAE,aAAa,CAAC,IAAI;KACzB,CACF,CAAC;IAEF,MAAM,GAAG,GAAG,KAAK,CAAC,CAAC,IAAA,sBAAc,EAAC,OAAO,CAAC,CAAC,IAAI,CAC7C,eAAM,CAAC,cAAc,CAAC,QAAQ,CAAC,cAAc,EAAE,KAAK,CAAC,EACrD,eAAM,CAAC,cAAc,CAAC,QAAQ,CAAC,gBAAgB,EAAE,OAAO,CAAC,EACzD,eAAM,CAAC,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAC1C,CAAC;IAEF,MAAM,WAAW,GAAG,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC;IACpD,IAAI,eAAe,GAAG,WAAW,IAAI,IAAA,8BAAmB,EAAC,WAAW,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC;IAErF,IAAI,CAAC,eAAe,EAAE,CAAC;QACrB,MAAM,eAAe,GAAG,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;QAC5D,eAAe,GAAG,IAAA,kCAAuB,EAAC,eAAe,CAAC,CAAC;IAC7D,CAAC;IAED,MAAM,IAAI,GAAG,eAAe;QAC1B,CAAC,CAAC,IAAA,uBAAY,EAAC,KAAK,CAAC,CAAC,eAAM,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,WAAW,EAAE,CAAC,CAAC;QAC9D,CAAC,CAAC,KAAK,CAAC,CAAC,eAAM,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC,CAAC;IAE5C,MAAM,OAAO,GAAmD,EAAE,CAAC;IAEnE,IAAI,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,YAAY,CAAC,EAAE,CAAC;QAClC,MAAM,OAAO,GAAG,GAAG,CAAC,OAAO,CAAC,YAAY;YACtC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,YAAY,EAAE;YAC5B,CAAC,CAAC,KAAK,CAAC,IAAI,CAAE,GAAG,CAAC,OAAe,CAAC,OAAO,EAAE,CAAC;iBACzC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,KAAK,YAAY,CAAC;iBACxC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,CAAC,CAAC;QAE5B,IAAI,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC;YAC3B,OAAO,CAAC,YAAY,CAAC,GAAG,OAAO,CAAC;YAChC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,YAAY,CAAC,CAAC;QACnC,CAAC;IACH,CAAC;IAED,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,KAAK,EAAE,GAAG,EAAE,EAAE;QACjC,OAAO,CAAC,GAAG,CAAC,GAAG,KAAK,CAAC;IACvB,CAAC,CAAC,CAAC;IAEH,OAAO,WAAW,CAAC,WAAW,CAAC;QAC7B,KAAK;QACL,UAAU,EAAE,GAAG,CAAC,MAAM;QACtB,IAAI;QACJ,OAAO;QACP,eAAe;KAChB,CAAC,CAAC;AACL,CAAC,CAAC,CAAC;AAhEQ,QAAA,cAAc,kBAgEtB;AAEL;;;;;;;;;;;;;;;;;;;;;;;;;GAyBG;AACI,MAAM,WAAW,GAAG,CACzB,KAAgF,EAChF,OAAwB,EAC4B,EAAE;IACtD,MAAM,YAAY,GAAG,cAAK,CAAC,QAAQ,CAAC,KAAK,EAAE,yBAAc,CAAC,MAAM,CAAC,IAAI,EAAE,yBAAc,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IACxG,OAAO,IAAA,YAAI,EAAC,EAAE,OAAO,EAAE,IAAA,sBAAc,EAAC,OAAO,CAAC,EAAE,KAAK,EAAE,YAAY,EAAE,OAAO,EAAE,OAAO,EAAE,OAAO,EAAE,CAAC,CAAC;AACpG,CAAC,CAAC;AANW,QAAA,WAAW,eAMtB"}
+{"version":3,"file":"LambdaHandler.js","sourceRoot":"","sources":["../../src/LambdaHandler.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAIA,gFAAkE;AAClE,kEAAoD;AAGpD,wDAA0C;AAC1C,sDAAwC;AACxC,0DAA4C;AAC5C,oDAAsC;AACtC,kDAAqD;AACrD,sEAAwD;AACxD,oDAA8C;AAE9C,kDAAiG;AACjG,kEAAoD;AAwDpD;;;GAGG;AACI,MAAM,KAAK,GAAG,GAAoD,EAAE,CACzE,MAAM,CAAC,GAAG,CACR,MAAM,CAAC,OAAO,EAAS,EACvB,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,cAAc,CAAC,CAC7C,CAAC;AAJX,QAAA,KAAK,SAIM;AAExB;;;GAGG;AACI,MAAM,OAAO,GAAG,GAAiC,EAAE,CACxD,MAAM,CAAC,GAAG,CACR,MAAM,CAAC,OAAO,EAAS,EACvB,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,gBAAgB,CAAC,CACnE,CAAC;AAJS,QAAA,OAAO,WAIhB;AAEJ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACI,MAAM,IAAI,GAcb,CACF,gBAAsF,EACtF,WAAgC,EACjB,EAAE;IACjB,IAAI,QAAQ,CAAC,UAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;QAC1C,kBAAkB;QAClB,IAAI,WAAW,EAAE,CAAC;YAChB,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC;YACrD,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,CAAC,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC;QAC7F,CAAC;QAED,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,CAC9B,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,MAAM,CAAC,UAA+D,CAAC,CAAC;IAClH,CAAC;IAED,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,gBAAgB,CAAC,KAAK,EAAE,EAAE,OAAO,EAAE,gBAAgB,CAAC,OAAO,EAAE,CAAC,CAAC;IACvG,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;QAC9B,OAAO,CAAC,8BAA8B,GAAG,KAAK,CAAC;QAC/C,OAAO,gBAAgB,CAAC,OAAO,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC;IAC3E,CAAC,CAAC;AACJ,CAAC,CAAC;AAlCW,QAAA,IAAI,QAkCf;AAEF;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACI,MAAM,MAAM,GAGf,CACF,gBAAgF,EAC9D,EAAE;IACpB,IAAI,QAAQ,CAAC,UAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;QAC1C,OAAO,MAAM,CAAC,SAAS,EAAE,iBAAiB,CAAC,KAAK,EAAE,KAAK,EAAE,cAAc,EAAE,OAAO,EAAE,EAAE,CAClF,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CACnC,IAAA,kBAAM,EAAC,cAAc,EAAE,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,EACrC,MAAM,CAAC,UAAqE,CAC7E,CACF,CAAC;IACJ,CAAC;IAED,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,gBAAgB,CAAC,KAAK,EAAE,EAAE,OAAO,EAAE,gBAAgB,CAAC,OAAO,EAAE,CAAC,CAAC;IACvG,OAAO,MAAM,CAAC,SAAS,EAAE,iBAAiB,CAAC,KAAK,EAAE,KAAK,EAAE,cAAc,EAAE,OAAO,EAAE,EAAE;QAClF,OAAO,CAAC,8BAA8B,GAAG,KAAK,CAAC;QAC/C,OAAO,gBAAgB,CAAC,OAAO,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAClD,IAAA,kBAAM,EAAC,cAAc,EAAE,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,EACrC,OAAO,CAAC,UAAU,CACnB,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC,CAAC;AAvBW,QAAA,MAAM,UAuBjB;AAWF,MAAM,UAAU,GAAG,OAAO,CAAC,UAAU,CAAa,+BAA+B,CAAC,CAAC;AAEnF;;;;;GAKG;AACI,MAAM,cAAc,GAAG,CAAC,OAA4C,EASzE,EAAE,CACF,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;IAClB,MAAM,GAAG,GAAG,KAAK,CAAC,CAAC,cAAc,CAAC,OAAO,CAAC;IAC1C,MAAM,EAAE,GAAG,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,EAE7B,CAAC;IACJ,OAAO,OAAO,CAAC,mBAAmB,CAAC,EAAE,CAAC,CACpC,OAAO,EAAE,UAAU,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CAAC,GAAU,CAAQ,CAAC,CAAC,CAAC,GAAG,CAClE,CAAC;AACJ,CAAC,CAAC,CAAC;AAlBQ,QAAA,cAAc,kBAkBtB;AAEL;;;;;GAKG;AACI,MAAM,cAAc,GAAG,CAAC,OAA4C,EAKzE,EAAE,CACJ,CAAC,KAAK,EAAE,OAAO,EAAE,EAAE,CACjB,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;IAClB,MAAM,WAAW,GAAG,IAAA,yBAAc,EAAC,KAAK,CAA2D,CAAC;IACpG,MAAM,aAAa,GAAG,WAAW,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAEpD,MAAM,GAAG,GAAG,IAAI,OAAO,CACrB,WAAW,aAAa,CAAC,aAAa,GAAG,aAAa,CAAC,IAAI,EAAE,EAC7D;QACE,MAAM,EAAE,aAAa,CAAC,MAAM;QAC5B,OAAO,EAAE,aAAa,CAAC,OAAO;QAC9B,IAAI,EAAE,aAAa,CAAC,IAAI;KACzB,CACF,CAAC;IAEF,MAAM,GAAG,GAAG,KAAK,CAAC,CAAC,IAAA,sBAAc,EAAC,OAAO,CAAC,CAAC,IAAI,CAC7C,MAAM,CAAC,cAAc,CAAC,QAAQ,CAAC,cAAc,EAAE,KAAK,CAAC,EACrD,MAAM,CAAC,cAAc,CAAC,QAAQ,CAAC,gBAAgB,EAAE,OAAO,CAAC,EACzD,MAAM,CAAC,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAC1C,CAAC;IAEF,MAAM,WAAW,GAAG,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC;IACpD,IAAI,eAAe,GAAG,WAAW,IAAI,IAAA,8BAAmB,EAAC,WAAW,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC;IAErF,IAAI,CAAC,eAAe,EAAE,CAAC;QACrB,MAAM,eAAe,GAAG,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;QAC5D,eAAe,GAAG,IAAA,kCAAuB,EAAC,eAAe,CAAC,CAAC;IAC7D,CAAC;IAED,MAAM,IAAI,GAAG,eAAe;QAC1B,CAAC,CAAC,IAAA,uBAAY,EAAC,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,WAAW,EAAE,CAAC,CAAC;QAC9D,CAAC,CAAC,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC,CAAC;IAE5C,MAAM,OAAO,GAAmD,EAAE,CAAC;IAEnE,IAAI,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,YAAY,CAAC,EAAE,CAAC;QAClC,MAAM,OAAO,GAAG,GAAG,CAAC,OAAO,CAAC,YAAY;YACtC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,YAAY,EAAE;YAC5B,CAAC,CAAC,KAAK,CAAC,IAAI,CAAE,GAAG,CAAC,OAAe,CAAC,OAAO,EAAE,CAAC;iBACzC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,KAAK,YAAY,CAAC;iBACxC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,CAAC,CAAC;QAE5B,IAAI,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC;YAC3B,OAAO,CAAC,YAAY,CAAC,GAAG,OAAO,CAAC;YAChC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,YAAY,CAAC,CAAC;QACnC,CAAC;IACH,CAAC;IAED,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,KAAK,EAAE,GAAG,EAAE,EAAE;QACjC,OAAO,CAAC,GAAG,CAAC,GAAG,KAAK,CAAC;IACvB,CAAC,CAAC,CAAC;IAEH,OAAO,WAAW,CAAC,WAAW,CAAC;QAC7B,KAAK;QACL,UAAU,EAAE,GAAG,CAAC,MAAM;QACtB,IAAI;QACJ,OAAO;QACP,eAAe;KAChB,CAAC,CAAC;AACL,CAAC,CAAC,CAAC;AAhEQ,QAAA,cAAc,kBAgEtB;AAEL;;;;;;;;;;;;;;;;;;;;;;;;;GAyBG;AACI,MAAM,WAAW,GAAG,CACzB,KAAgF,EAChF,OAAwB,EAC4B,EAAE;IACtD,MAAM,YAAY,GAAG,KAAK,CAAC,QAAQ,CAAC,KAAK,EAAE,cAAc,CAAC,MAAM,CAAC,IAAI,EAAE,cAAc,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IACxG,OAAO,IAAA,YAAI,EAAC,EAAE,OAAO,EAAE,IAAA,sBAAc,EAAC,OAAO,CAAC,EAAE,KAAK,EAAE,YAAY,EAAE,OAAO,EAAE,OAAO,EAAE,OAAO,EAAE,CAAC,CAAC;AACpG,CAAC,CAAC;AANW,QAAA,WAAW,eAMtB"}

dist/cjs/LambdaRuntime.d.ts

@@ -0,7 +1,4 @@
+import type * as Layer from "effect/Layer";
+import * as ManagedRuntime from "effect/ManagedRuntime";
 /**
- * @since 1.0.0
- */
-import type { Layer } from "effect";
-import { ManagedRuntime } from "effect";
-/**
  * Makes a managed runtime from a layer asynchronously, designed for AWS Lambda.
@@ -8,0 +5,0 @@ * All finalizers will be executed on process termination or interruption.

dist/cjs/LambdaRuntime.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"LambdaRuntime.d.ts","sourceRoot":"","sources":["../../src/LambdaRuntime.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,QAAQ,CAAC;AACpC,OAAO,EAAmB,cAAc,EAAE,MAAM,QAAQ,CAAC;AAEzD;;;;;;;;;;;;;;;;;;GAkBG;AACH,eAAO,MAAM,SAAS,gBACb,MAAM,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,YACd;IAAE,QAAQ,CAAC,OAAO,CAAC,EAAE,MAAM,OAAO,CAAA;CAAE,KAC7C,eAAe,cAAc,CAAC,CAAC,EAAE,CAAC,CAmBpC,CAAC"}
+{"version":3,"file":"LambdaRuntime.d.ts","sourceRoot":"","sources":["../../src/LambdaRuntime.ts"],"names":[],"mappings":"AAKA,OAAO,KAAK,KAAK,KAAK,MAAM,cAAc,CAAC;AAC3C,OAAO,KAAK,cAAc,MAAM,uBAAuB,CAAC;AAExD;;;;;;;;;;;;;;;;;;GAkBG;AACH,eAAO,MAAM,SAAS,gBACb,MAAM,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,YACd;IAAE,QAAQ,CAAC,OAAO,CAAC,EAAE,MAAM,OAAO,CAAA;CAAE,KAC7C,eAAe,cAAc,CAAC,CAAC,EAAE,CAAC,CAmBpC,CAAC"}

dist/cjs/LambdaRuntime.js

 "use strict";
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) 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 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.fromLayer = void 0;
-const effect_1 = require("effect");
 /**
+ * @since 1.0.0
+ */
+const Console = __importStar(require("effect/Console"));
+const Effect = __importStar(require("effect/Effect"));
+const ManagedRuntime = __importStar(require("effect/ManagedRuntime"));
+/**
  * Makes a managed runtime from a layer asynchronously, designed for AWS Lambda.
@@ -25,10 +53,10 @@ * All finalizers will be executed on process termination or interruption.
 const fromLayer = (layer, options) => {
-    const rt = effect_1.ManagedRuntime.make(layer, options?.memoMap);
+    const rt = ManagedRuntime.make(layer, options?.memoMap);
     const signalHandler = (signal) => {
-        effect_1.Effect.runFork(effect_1.Effect.gen(function* () {
-            yield* effect_1.Console.log(`[runtime] ${signal} received`);
-            yield* effect_1.Console.log("[runtime] cleaning up");
+        Effect.runFork(Effect.gen(function* () {
+            yield* Console.log(`[runtime] ${signal} received`);
+            yield* Console.log("[runtime] cleaning up");
             yield* rt.disposeEffect;
-            yield* effect_1.Console.log("[runtime] exiting");
-            yield* effect_1.Effect.sync(() => process.exit(0));
+            yield* Console.log("[runtime] exiting");
+            yield* Effect.sync(() => process.exit(0));
         }));
@@ -35,0 +63,0 @@ };

dist/cjs/LambdaRuntime.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"LambdaRuntime.js","sourceRoot":"","sources":["../../src/LambdaRuntime.ts"],"names":[],"mappings":";;;AAIA,mCAAyD;AAEzD;;;;;;;;;;;;;;;;;;GAkBG;AACI,MAAM,SAAS,GAAG,CACvB,KAAwB,EACxB,OAA8C,EACT,EAAE;IACvC,MAAM,EAAE,GAAG,uBAAc,CAAC,IAAI,CAAC,KAAK,EAAE,OAAO,EAAE,OAAO,CAAC,CAAC;IAExD,MAAM,aAAa,GAA2B,CAAC,MAAM,EAAE,EAAE;QACvD,eAAM,CAAC,OAAO,CACZ,eAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;YAClB,KAAK,CAAC,CAAC,gBAAO,CAAC,GAAG,CAAC,aAAa,MAAM,WAAW,CAAC,CAAC;YACnD,KAAK,CAAC,CAAC,gBAAO,CAAC,GAAG,CAAC,uBAAuB,CAAC,CAAC;YAC5C,KAAK,CAAC,CAAC,EAAE,CAAC,aAAa,CAAC;YACxB,KAAK,CAAC,CAAC,gBAAO,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;YACxC,KAAK,CAAC,CAAC,eAAM,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC;QAC5C,CAAC,CAAC,CACH,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,aAAa,CAAC,CAAC;IACrC,OAAO,CAAC,EAAE,CAAC,QAAQ,EAAE,aAAa,CAAC,CAAC;IAEpC,OAAO,EAAE,CAAC;AACZ,CAAC,CAAC;AAtBW,QAAA,SAAS,aAsBpB"}
+{"version":3,"file":"LambdaRuntime.js","sourceRoot":"","sources":["../../src/LambdaRuntime.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA;;GAEG;AACH,wDAA0C;AAC1C,sDAAwC;AAExC,sEAAwD;AAExD;;;;;;;;;;;;;;;;;;GAkBG;AACI,MAAM,SAAS,GAAG,CACvB,KAAwB,EACxB,OAA8C,EACT,EAAE;IACvC,MAAM,EAAE,GAAG,cAAc,CAAC,IAAI,CAAC,KAAK,EAAE,OAAO,EAAE,OAAO,CAAC,CAAC;IAExD,MAAM,aAAa,GAA2B,CAAC,MAAM,EAAE,EAAE;QACvD,MAAM,CAAC,OAAO,CACZ,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;YAClB,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,aAAa,MAAM,WAAW,CAAC,CAAC;YACnD,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,uBAAuB,CAAC,CAAC;YAC5C,KAAK,CAAC,CAAC,EAAE,CAAC,aAAa,CAAC;YACxB,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;YACxC,KAAK,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC;QAC5C,CAAC,CAAC,CACH,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,aAAa,CAAC,CAAC;IACrC,OAAO,CAAC,EAAE,CAAC,QAAQ,EAAE,aAAa,CAAC,CAAC;IAEpC,OAAO,EAAE,CAAC;AACZ,CAAC,CAAC;AAtBW,QAAA,SAAS,aAsBpB"}

dist/cjs/Types.d.ts

@@ -5,4 +5,5 @@ /**
 import type { ALBEvent, ALBResult, APIGatewayProxyEvent, APIGatewayProxyEventV2, APIGatewayProxyResult, APIGatewayProxyResultV2, CloudFrontRequestEvent, Context, DynamoDBStreamEvent, EventBridgeEvent, KinesisStreamEvent, S3Event, SelfManagedKafkaEvent, SNSEvent, SQSEvent } from "aws-lambda";
-import type { Layer, Stream } from "effect";
 import type * as Effect from "effect/Effect";
+import type * as Layer from "effect/Layer";
+import type * as Stream from "effect/Stream";
 declare global {
@@ -9,0 +10,0 @@ namespace awslambda {

dist/cjs/Types.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"Types.d.ts","sourceRoot":"","sources":["../../src/Types.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,EACV,QAAQ,EACR,SAAS,EACT,oBAAoB,EACpB,sBAAsB,EACtB,qBAAqB,EACrB,uBAAuB,EACvB,sBAAsB,EACtB,OAAO,EACP,mBAAmB,EACnB,gBAAgB,EAChB,kBAAkB,EAClB,OAAO,EACP,qBAAqB,EACrB,QAAQ,EACR,QAAQ,EACT,MAAM,YAAY,CAAC;AACpB,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,EAAE,MAAM,QAAQ,CAAC;AAC5C,OAAO,KAAK,KAAK,MAAM,MAAM,eAAe,CAAC;AAE7C,OAAO,CAAC,MAAM,CAAC;IACb,UAAU,SAAS,CAAC;QAClB,SAAS,iBAAiB,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,gBAAgB,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;KACzE;CACF;AAED;;;;;GAKG;AACH,MAAM,MAAM,OAAO,CAAC,MAAM,GAAG,OAAO,EAAE,OAAO,GAAG,GAAG,IAAI,CACrD,KAAK,EAAE,MAAM,EACb,OAAO,EAAE,OAAO,KACb,OAAO,CAAC,OAAO,CAAC,CAAC;AAEtB;;;;;GAKG;AACH,MAAM,MAAM,gBAAgB,CAAC,MAAM,GAAG,OAAO,IAAI,CAC/C,KAAK,EAAE,MAAM,EACb,cAAc,EAAE,SAAS,CAAC,kBAAkB,EAC5C,OAAO,EAAE,OAAO,KACb,OAAO,CAAC,IAAI,CAAC,CAAC;AAEnB;;;;;GAKG;AACH,MAAM,MAAM,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,IAAI,IAAI,CACrD,KAAK,EAAE,CAAC,EACR,OAAO,EAAE,OAAO,KACb,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAE5B;;;;;;;;GAQG;AACH,MAAM,MAAM,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,GAAG,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,CAAC,GAAG,IAAI,IAAI;IAC3E,QAAQ,CAAC,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,CAAC;IAC7C,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;IACnC,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC,CAAC;AAEF;;;;;GAKG;AACH,MAAM,MAAM,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,MAAM,GAAG,UAAU,IAAI,CACpE,KAAK,EAAE,CAAC,EACR,OAAO,EAAE,OAAO,KACb,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAE5B;;;;;;;;GAQG;AACH,MAAM,MAAM,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,GAAG,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,CAAC,GAAG,MAAM,GAAG,UAAU,IAAI;IAC1F,QAAQ,CAAC,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,CAAC;IAC7C,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;IACnC,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC,CAAC;AAEF,OAAO;AACL;;GAEG;AACH,QAAQ;AACR;;GAEG;AACH,SAAS;AACT;;GAEG;AACH,oBAAoB;AACpB;;GAEG;AACH,sBAAsB;AACtB;;GAEG;AACH,qBAAqB;AACrB;;GAEG;AACH,uBAAuB;AACvB;;GAEG;AACH,sBAAsB;AACtB;;GAEG;AACH,OAAO,IAAI,aAAa;AACxB;;GAEG;AACH,mBAAmB;AACnB;;GAEG;AACH,gBAAgB;AAChB;;GAEG;AACH,kBAAkB;AAClB;;GAEG;AACH,OAAO;AACP;;GAEG;AACH,qBAAqB;AACrB;;GAEG;AACH,QAAQ;AACR;;GAEG;AACH,QAAQ,GACT,CAAC"}
+{"version":3,"file":"Types.d.ts","sourceRoot":"","sources":["../../src/Types.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,EACV,QAAQ,EACR,SAAS,EACT,oBAAoB,EACpB,sBAAsB,EACtB,qBAAqB,EACrB,uBAAuB,EACvB,sBAAsB,EACtB,OAAO,EACP,mBAAmB,EACnB,gBAAgB,EAChB,kBAAkB,EAClB,OAAO,EACP,qBAAqB,EACrB,QAAQ,EACR,QAAQ,EACT,MAAM,YAAY,CAAC;AACpB,OAAO,KAAK,KAAK,MAAM,MAAM,eAAe,CAAC;AAC7C,OAAO,KAAK,KAAK,KAAK,MAAM,cAAc,CAAC;AAC3C,OAAO,KAAK,KAAK,MAAM,MAAM,eAAe,CAAC;AAE7C,OAAO,CAAC,MAAM,CAAC;IACb,UAAU,SAAS,CAAC;QAClB,SAAS,iBAAiB,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,gBAAgB,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;KACzE;CACF;AAED;;;;;GAKG;AACH,MAAM,MAAM,OAAO,CAAC,MAAM,GAAG,OAAO,EAAE,OAAO,GAAG,GAAG,IAAI,CACrD,KAAK,EAAE,MAAM,EACb,OAAO,EAAE,OAAO,KACb,OAAO,CAAC,OAAO,CAAC,CAAC;AAEtB;;;;;GAKG;AACH,MAAM,MAAM,gBAAgB,CAAC,MAAM,GAAG,OAAO,IAAI,CAC/C,KAAK,EAAE,MAAM,EACb,cAAc,EAAE,SAAS,CAAC,kBAAkB,EAC5C,OAAO,EAAE,OAAO,KACb,OAAO,CAAC,IAAI,CAAC,CAAC;AAEnB;;;;;GAKG;AACH,MAAM,MAAM,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,IAAI,IAAI,CACrD,KAAK,EAAE,CAAC,EACR,OAAO,EAAE,OAAO,KACb,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAE5B;;;;;;;;GAQG;AACH,MAAM,MAAM,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,GAAG,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,CAAC,GAAG,IAAI,IAAI;IAC3E,QAAQ,CAAC,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,CAAC;IAC7C,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;IACnC,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC,CAAC;AAEF;;;;;GAKG;AACH,MAAM,MAAM,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,MAAM,GAAG,UAAU,IAAI,CACpE,KAAK,EAAE,CAAC,EACR,OAAO,EAAE,OAAO,KACb,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAE5B;;;;;;;;GAQG;AACH,MAAM,MAAM,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,GAAG,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,CAAC,GAAG,MAAM,GAAG,UAAU,IAAI;IAC1F,QAAQ,CAAC,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,CAAC;IAC7C,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;IACnC,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC,CAAC;AAEF,OAAO;AACL;;GAEG;AACH,QAAQ;AACR;;GAEG;AACH,SAAS;AACT;;GAEG;AACH,oBAAoB;AACpB;;GAEG;AACH,sBAAsB;AACtB;;GAEG;AACH,qBAAqB;AACrB;;GAEG;AACH,uBAAuB;AACvB;;GAEG;AACH,sBAAsB;AACtB;;GAEG;AACH,OAAO,IAAI,aAAa;AACxB;;GAEG;AACH,mBAAmB;AACnB;;GAEG;AACH,gBAAgB;AAChB;;GAEG;AACH,kBAAkB;AAClB;;GAEG;AACH,OAAO;AACP;;GAEG;AACH,qBAAqB;AACrB;;GAEG;AACH,QAAQ;AACR;;GAEG;AACH,QAAQ,GACT,CAAC"}

dist/dts/LambdaHandler.d.ts

 /**
  * @since 1.4.0
  */
-import type { HttpApi, HttpRouter } from "@effect/platform";
-import { HttpApiBuilder, HttpApp } from "@effect/platform";
-import type { Cause } from "effect";
-import { Context, Effect, Layer } from "effect";
+import type * as HttpApi from "@effect/platform/HttpApi";
+import * as HttpApiBuilder from "@effect/platform/HttpApiBuilder";
+import * as HttpApp from "@effect/platform/HttpApp";
+import type * as HttpRouter from "@effect/platform/HttpRouter";
+import type * as Cause from "effect/Cause";
+import * as Context from "effect/Context";
+import * as Effect from "effect/Effect";
+import * as Layer from "effect/Layer";
 import type { ALBEvent, ALBResult, APIGatewayProxyEvent, APIGatewayProxyEventV2, APIGatewayProxyResult, APIGatewayProxyResultV2, CloudFrontRequestEvent, DynamoDBStreamEvent, EffectHandler, EffectHandlerWithLayer, EventBridgeEvent, Handler, KinesisStreamEvent, LambdaContext, S3Event, SelfManagedKafkaEvent, SNSEvent, SQSEvent, StreamHandler, StreamHandlerWithLayer } from "./Types.js";
@@ -9,0 +13,0 @@ /**

dist/dts/LambdaHandler.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"LambdaHandler.d.ts","sourceRoot":"","sources":["../../src/LambdaHandler.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,EAAE,OAAO,EAAE,UAAU,EAAE,MAAM,kBAAkB,CAAC;AAC5D,OAAO,EAAE,cAAc,EAAE,OAAO,EAAE,MAAM,kBAAkB,CAAC;AAC3D,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,QAAQ,CAAC;AACpC,OAAO,EAAE,OAAO,EAAE,MAAM,EAAY,KAAK,EAAE,MAAM,QAAQ,CAAC;AAO1D,OAAO,KAAK,EACV,QAAQ,EACR,SAAS,EACT,oBAAoB,EACpB,sBAAsB,EACtB,qBAAqB,EACrB,uBAAuB,EACvB,sBAAsB,EACtB,mBAAmB,EACnB,aAAa,EACb,sBAAsB,EACtB,gBAAgB,EAChB,OAAO,EACP,kBAAkB,EAClB,aAAa,EACb,OAAO,EACP,qBAAqB,EACrB,QAAQ,EACR,QAAQ,EACR,aAAa,EACb,sBAAsB,EACvB,MAAM,YAAY,CAAC;AAEpB;;GAEG;AACH,MAAM,CAAC,OAAO,WAAW,aAAa,CAAC;IACrC;;;OAGG;IACH,KAAY,KAAK,GACb,QAAQ,GACR,oBAAoB,GACpB,sBAAsB,GACtB,gBAAgB,CAAC,MAAM,EAAE,OAAO,CAAC,GACjC,mBAAmB,GACnB,kBAAkB,GAClB,OAAO,GACP,qBAAqB,GACrB,QAAQ,GACR,QAAQ,GACR,sBAAsB,CAAC;IAE3B;;;OAGG;IACH,KAAY,MAAM,GACd,SAAS,GACT,qBAAqB,GACrB,uBAAuB,GACvB,IAAI,CAAC;CACV;AAED;;;GAGG;AACH,eAAO,MAAM,KAAK,uCAAsC,OAAO,MAAM,CAAC,CAAC,CAIhD,CAAC;AAExB;;;GAGG;AACH,eAAO,MAAM,OAAO,QAAO,OAAO,MAAM,CAAC,aAAa,CAInD,CAAC;AAEJ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,eAAO,MAAM,IAAI,EAAE;IACjB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACnF,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACjE;;;;;;;;;OASG;IACH,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,EAAE,WAAW,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;CAqBxG,CAAC;AAEF;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,eAAO,MAAM,MAAM,EAAE;IACnB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,OAAO,EAAE,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;IAChF,CAAC,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;CAqB/D,CAAC;AAEF,UAAU,cAAc;IACtB,QAAQ,CAAC,UAAU,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,OAAO,KAAK,OAAO,CAAC,OAAO,CACjE,KAAK,EACL,OAAO,CAAC,GAAG,GAAG,cAAc,CAAC,MAAM,GAAG,UAAU,CAAC,UAAU,CAAC,eAAe,CAC5E,CAAC;IACF,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC;AAED,KAAK,UAAU,GAAG,UAAU,CAAC,OAAO,OAAO,CAAC,YAAY,CAAC,CAAC;AAC1D,QAAA,MAAM,UAAU,2LAAkE,CAAC;AAEnF;;;;;GAKG;AACH,eAAO,MAAM,cAAc,aAAc,KAAK,cAAc,EAAE,YAAY,CAAC,KAAG,OAAO,MAAM,CACzF,UAAU,EACV,KAAK,EACH,eAAe,MAAM,GACrB,QAAQ,GAAG,GACX,WAAW,UAAU,CAAC,eAAe,GACrC,eAAe,UAAU,GACzB,mBAAmB,GACnB,aAAa,CAUb,CAAC;AAEL;;;;;GAKG;AACH,eAAO,MAAM,cAAc,aAAc,KAAK,cAAc,EAAE,YAAY,CAAC,KAAG,cAC5E,mBAAmB,EACnB,QAAQ,GAAG,GAAG,eAAe,MAAM,GAAG,WAAW,UAAU,CAAC,eAAe,GAAG,eAAe,UAAU,EACvG,MAAM,gBAAgB,EACtB,cAAc,MAAM,CA4DlB,CAAC;AAEL;;;;;;;;;;;;;;;;;;;;;;;;;GAyBG;AACH,eAAO,MAAM,WAAW,kBACf,MAAM,KAAK,CAAC,EAAE,GAAG,QAAQ,GAAG,GAAG,WAAW,UAAU,CAAC,eAAe,EAAE,EAAE,CAAC,YACtE,cAAc,KACvB,QAAQ,mBAAmB,EAAE,cAAc,MAAM,CAGnD,CAAC"}
+{"version":3,"file":"LambdaHandler.d.ts","sourceRoot":"","sources":["../../src/LambdaHandler.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,KAAK,OAAO,MAAM,0BAA0B,CAAC;AACzD,OAAO,KAAK,cAAc,MAAM,iCAAiC,CAAC;AAClE,OAAO,KAAK,OAAO,MAAM,0BAA0B,CAAC;AACpD,OAAO,KAAK,KAAK,UAAU,MAAM,6BAA6B,CAAC;AAC/D,OAAO,KAAK,KAAK,KAAK,MAAM,cAAc,CAAC;AAC3C,OAAO,KAAK,OAAO,MAAM,gBAAgB,CAAC;AAC1C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAC;AAExC,OAAO,KAAK,KAAK,MAAM,cAAc,CAAC;AAOtC,OAAO,KAAK,EACV,QAAQ,EACR,SAAS,EACT,oBAAoB,EACpB,sBAAsB,EACtB,qBAAqB,EACrB,uBAAuB,EACvB,sBAAsB,EACtB,mBAAmB,EACnB,aAAa,EACb,sBAAsB,EACtB,gBAAgB,EAChB,OAAO,EACP,kBAAkB,EAClB,aAAa,EACb,OAAO,EACP,qBAAqB,EACrB,QAAQ,EACR,QAAQ,EACR,aAAa,EACb,sBAAsB,EACvB,MAAM,YAAY,CAAC;AAEpB;;GAEG;AACH,MAAM,CAAC,OAAO,WAAW,aAAa,CAAC;IACrC;;;OAGG;IACH,KAAY,KAAK,GACb,QAAQ,GACR,oBAAoB,GACpB,sBAAsB,GACtB,gBAAgB,CAAC,MAAM,EAAE,OAAO,CAAC,GACjC,mBAAmB,GACnB,kBAAkB,GAClB,OAAO,GACP,qBAAqB,GACrB,QAAQ,GACR,QAAQ,GACR,sBAAsB,CAAC;IAE3B;;;OAGG;IACH,KAAY,MAAM,GACd,SAAS,GACT,qBAAqB,GACrB,uBAAuB,GACvB,IAAI,CAAC;CACV;AAED;;;GAGG;AACH,eAAO,MAAM,KAAK,uCAAsC,OAAO,MAAM,CAAC,CAAC,CAIhD,CAAC;AAExB;;;GAGG;AACH,eAAO,MAAM,OAAO,QAAO,OAAO,MAAM,CAAC,aAAa,CAInD,CAAC;AAEJ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,eAAO,MAAM,IAAI,EAAE;IACjB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACnF,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;IACjE;;;;;;;;;OASG;IACH,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,EAAE,WAAW,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;CAqBxG,CAAC;AAEF;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,eAAO,MAAM,MAAM,EAAE;IACnB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,EAAE,OAAO,EAAE,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,EAAE,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;IAChF,CAAC,CAAC,EAAE,CAAC,EAAE,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,IAAI,CAAC,CAAC;CAqB/D,CAAC;AAEF,UAAU,cAAc;IACtB,QAAQ,CAAC,UAAU,CAAC,EAAE,CAAC,OAAO,EAAE,OAAO,CAAC,OAAO,KAAK,OAAO,CAAC,OAAO,CACjE,KAAK,EACL,OAAO,CAAC,GAAG,GAAG,cAAc,CAAC,MAAM,GAAG,UAAU,CAAC,UAAU,CAAC,eAAe,CAC5E,CAAC;IACF,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC;AAED,KAAK,UAAU,GAAG,UAAU,CAAC,OAAO,OAAO,CAAC,YAAY,CAAC,CAAC;AAC1D,QAAA,MAAM,UAAU,2LAAkE,CAAC;AAEnF;;;;;GAKG;AACH,eAAO,MAAM,cAAc,aAAc,KAAK,cAAc,EAAE,YAAY,CAAC,KAAG,OAAO,MAAM,CACzF,UAAU,EACV,KAAK,EACH,eAAe,MAAM,GACrB,QAAQ,GAAG,GACX,WAAW,UAAU,CAAC,eAAe,GACrC,eAAe,UAAU,GACzB,mBAAmB,GACnB,aAAa,CAUb,CAAC;AAEL;;;;;GAKG;AACH,eAAO,MAAM,cAAc,aAAc,KAAK,cAAc,EAAE,YAAY,CAAC,KAAG,cAC5E,mBAAmB,EACnB,QAAQ,GAAG,GAAG,eAAe,MAAM,GAAG,WAAW,UAAU,CAAC,eAAe,GAAG,eAAe,UAAU,EACvG,MAAM,gBAAgB,EACtB,cAAc,MAAM,CA4DlB,CAAC;AAEL;;;;;;;;;;;;;;;;;;;;;;;;;GAyBG;AACH,eAAO,MAAM,WAAW,kBACf,MAAM,KAAK,CAAC,EAAE,GAAG,QAAQ,GAAG,GAAG,WAAW,UAAU,CAAC,eAAe,EAAE,EAAE,CAAC,YACtE,cAAc,KACvB,QAAQ,mBAAmB,EAAE,cAAc,MAAM,CAGnD,CAAC"}

dist/dts/LambdaRuntime.d.ts

@@ -0,7 +1,4 @@
+import type * as Layer from "effect/Layer";
+import * as ManagedRuntime from "effect/ManagedRuntime";
 /**
- * @since 1.0.0
- */
-import type { Layer } from "effect";
-import { ManagedRuntime } from "effect";
-/**
  * Makes a managed runtime from a layer asynchronously, designed for AWS Lambda.
@@ -8,0 +5,0 @@ * All finalizers will be executed on process termination or interruption.

dist/dts/LambdaRuntime.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"LambdaRuntime.d.ts","sourceRoot":"","sources":["../../src/LambdaRuntime.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,QAAQ,CAAC;AACpC,OAAO,EAAmB,cAAc,EAAE,MAAM,QAAQ,CAAC;AAEzD;;;;;;;;;;;;;;;;;;GAkBG;AACH,eAAO,MAAM,SAAS,gBACb,MAAM,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,YACd;IAAE,QAAQ,CAAC,OAAO,CAAC,EAAE,MAAM,OAAO,CAAA;CAAE,KAC7C,eAAe,cAAc,CAAC,CAAC,EAAE,CAAC,CAmBpC,CAAC"}
+{"version":3,"file":"LambdaRuntime.d.ts","sourceRoot":"","sources":["../../src/LambdaRuntime.ts"],"names":[],"mappings":"AAKA,OAAO,KAAK,KAAK,KAAK,MAAM,cAAc,CAAC;AAC3C,OAAO,KAAK,cAAc,MAAM,uBAAuB,CAAC;AAExD;;;;;;;;;;;;;;;;;;GAkBG;AACH,eAAO,MAAM,SAAS,gBACb,MAAM,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,YACd;IAAE,QAAQ,CAAC,OAAO,CAAC,EAAE,MAAM,OAAO,CAAA;CAAE,KAC7C,eAAe,cAAc,CAAC,CAAC,EAAE,CAAC,CAmBpC,CAAC"}

dist/dts/Types.d.ts

@@ -5,4 +5,5 @@ /**
 import type { ALBEvent, ALBResult, APIGatewayProxyEvent, APIGatewayProxyEventV2, APIGatewayProxyResult, APIGatewayProxyResultV2, CloudFrontRequestEvent, Context, DynamoDBStreamEvent, EventBridgeEvent, KinesisStreamEvent, S3Event, SelfManagedKafkaEvent, SNSEvent, SQSEvent } from "aws-lambda";
-import type { Layer, Stream } from "effect";
 import type * as Effect from "effect/Effect";
+import type * as Layer from "effect/Layer";
+import type * as Stream from "effect/Stream";
 declare global {
@@ -9,0 +10,0 @@ namespace awslambda {

dist/dts/Types.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"Types.d.ts","sourceRoot":"","sources":["../../src/Types.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,EACV,QAAQ,EACR,SAAS,EACT,oBAAoB,EACpB,sBAAsB,EACtB,qBAAqB,EACrB,uBAAuB,EACvB,sBAAsB,EACtB,OAAO,EACP,mBAAmB,EACnB,gBAAgB,EAChB,kBAAkB,EAClB,OAAO,EACP,qBAAqB,EACrB,QAAQ,EACR,QAAQ,EACT,MAAM,YAAY,CAAC;AACpB,OAAO,KAAK,EAAE,KAAK,EAAE,MAAM,EAAE,MAAM,QAAQ,CAAC;AAC5C,OAAO,KAAK,KAAK,MAAM,MAAM,eAAe,CAAC;AAE7C,OAAO,CAAC,MAAM,CAAC;IACb,UAAU,SAAS,CAAC;QAClB,SAAS,iBAAiB,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,gBAAgB,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;KACzE;CACF;AAED;;;;;GAKG;AACH,MAAM,MAAM,OAAO,CAAC,MAAM,GAAG,OAAO,EAAE,OAAO,GAAG,GAAG,IAAI,CACrD,KAAK,EAAE,MAAM,EACb,OAAO,EAAE,OAAO,KACb,OAAO,CAAC,OAAO,CAAC,CAAC;AAEtB;;;;;GAKG;AACH,MAAM,MAAM,gBAAgB,CAAC,MAAM,GAAG,OAAO,IAAI,CAC/C,KAAK,EAAE,MAAM,EACb,cAAc,EAAE,SAAS,CAAC,kBAAkB,EAC5C,OAAO,EAAE,OAAO,KACb,OAAO,CAAC,IAAI,CAAC,CAAC;AAEnB;;;;;GAKG;AACH,MAAM,MAAM,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,IAAI,IAAI,CACrD,KAAK,EAAE,CAAC,EACR,OAAO,EAAE,OAAO,KACb,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAE5B;;;;;;;;GAQG;AACH,MAAM,MAAM,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,GAAG,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,CAAC,GAAG,IAAI,IAAI;IAC3E,QAAQ,CAAC,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,CAAC;IAC7C,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;IACnC,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC,CAAC;AAEF;;;;;GAKG;AACH,MAAM,MAAM,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,MAAM,GAAG,UAAU,IAAI,CACpE,KAAK,EAAE,CAAC,EACR,OAAO,EAAE,OAAO,KACb,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAE5B;;;;;;;;GAQG;AACH,MAAM,MAAM,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,GAAG,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,CAAC,GAAG,MAAM,GAAG,UAAU,IAAI;IAC1F,QAAQ,CAAC,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,CAAC;IAC7C,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;IACnC,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC,CAAC;AAEF,OAAO;AACL;;GAEG;AACH,QAAQ;AACR;;GAEG;AACH,SAAS;AACT;;GAEG;AACH,oBAAoB;AACpB;;GAEG;AACH,sBAAsB;AACtB;;GAEG;AACH,qBAAqB;AACrB;;GAEG;AACH,uBAAuB;AACvB;;GAEG;AACH,sBAAsB;AACtB;;GAEG;AACH,OAAO,IAAI,aAAa;AACxB;;GAEG;AACH,mBAAmB;AACnB;;GAEG;AACH,gBAAgB;AAChB;;GAEG;AACH,kBAAkB;AAClB;;GAEG;AACH,OAAO;AACP;;GAEG;AACH,qBAAqB;AACrB;;GAEG;AACH,QAAQ;AACR;;GAEG;AACH,QAAQ,GACT,CAAC"}
+{"version":3,"file":"Types.d.ts","sourceRoot":"","sources":["../../src/Types.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,EACV,QAAQ,EACR,SAAS,EACT,oBAAoB,EACpB,sBAAsB,EACtB,qBAAqB,EACrB,uBAAuB,EACvB,sBAAsB,EACtB,OAAO,EACP,mBAAmB,EACnB,gBAAgB,EAChB,kBAAkB,EAClB,OAAO,EACP,qBAAqB,EACrB,QAAQ,EACR,QAAQ,EACT,MAAM,YAAY,CAAC;AACpB,OAAO,KAAK,KAAK,MAAM,MAAM,eAAe,CAAC;AAC7C,OAAO,KAAK,KAAK,KAAK,MAAM,cAAc,CAAC;AAC3C,OAAO,KAAK,KAAK,MAAM,MAAM,eAAe,CAAC;AAE7C,OAAO,CAAC,MAAM,CAAC;IACb,UAAU,SAAS,CAAC;QAClB,SAAS,iBAAiB,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,gBAAgB,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;KACzE;CACF;AAED;;;;;GAKG;AACH,MAAM,MAAM,OAAO,CAAC,MAAM,GAAG,OAAO,EAAE,OAAO,GAAG,GAAG,IAAI,CACrD,KAAK,EAAE,MAAM,EACb,OAAO,EAAE,OAAO,KACb,OAAO,CAAC,OAAO,CAAC,CAAC;AAEtB;;;;;GAKG;AACH,MAAM,MAAM,gBAAgB,CAAC,MAAM,GAAG,OAAO,IAAI,CAC/C,KAAK,EAAE,MAAM,EACb,cAAc,EAAE,SAAS,CAAC,kBAAkB,EAC5C,OAAO,EAAE,OAAO,KACb,OAAO,CAAC,IAAI,CAAC,CAAC;AAEnB;;;;;GAKG;AACH,MAAM,MAAM,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,IAAI,IAAI,CACrD,KAAK,EAAE,CAAC,EACR,OAAO,EAAE,OAAO,KACb,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAE5B;;;;;;;;GAQG;AACH,MAAM,MAAM,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,GAAG,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,CAAC,GAAG,IAAI,IAAI;IAC3E,QAAQ,CAAC,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,CAAC;IAC7C,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;IACnC,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC,CAAC;AAEF;;;;;GAKG;AACH,MAAM,MAAM,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,GAAG,KAAK,EAAE,CAAC,GAAG,MAAM,GAAG,UAAU,IAAI,CACpE,KAAK,EAAE,CAAC,EACR,OAAO,EAAE,OAAO,KACb,MAAM,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAE5B;;;;;;;;GAQG;AACH,MAAM,MAAM,sBAAsB,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,GAAG,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,CAAC,GAAG,MAAM,GAAG,UAAU,IAAI;IAC1F,QAAQ,CAAC,OAAO,EAAE,aAAa,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC,CAAC;IAC7C,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC;IACnC,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,CAAC,OAAO,CAAC;CAClC,CAAC;AAEF,OAAO;AACL;;GAEG;AACH,QAAQ;AACR;;GAEG;AACH,SAAS;AACT;;GAEG;AACH,oBAAoB;AACpB;;GAEG;AACH,sBAAsB;AACtB;;GAEG;AACH,qBAAqB;AACrB;;GAEG;AACH,uBAAuB;AACvB;;GAEG;AACH,sBAAsB;AACtB;;GAEG;AACH,OAAO,IAAI,aAAa;AACxB;;GAEG;AACH,mBAAmB;AACnB;;GAEG;AACH,gBAAgB;AAChB;;GAEG;AACH,kBAAkB;AAClB;;GAEG;AACH,OAAO;AACP;;GAEG;AACH,qBAAqB;AACrB;;GAEG;AACH,QAAQ;AACR;;GAEG;AACH,QAAQ,GACT,CAAC"}

dist/esm/internal/aws/api-gateway-v1.js

 import url from "node:url";
-import { Record } from "effect";
+import * as Record from "effect/Record";
 import { getMultiValueHeaders, getRequestValuesFromEvent } from "../utils.js";
@@ -4,0 +4,0 @@ function getPathWithQueryStringParams(event) {

dist/esm/internal/aws/api-gateway-v1.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"api-gateway-v1.js","sourceRoot":"","sources":["../../../../src/internal/aws/api-gateway-v1.ts"],"names":[],"mappings":"AAAA,OAAO,GAAG,MAAM,UAAU,CAAC;AAE3B,OAAO,EAAE,MAAM,EAAE,MAAM,QAAQ,CAAC;AAGhC,OAAO,EAAE,oBAAoB,EAAE,yBAAyB,EAAE,MAAM,aAAa,CAAC;AAE9E,SAAS,4BAA4B,CAAC,KAA2B;IAC/D,4FAA4F;IAC5F,MAAM,IAAI,GAAG,CAAC,KAAK,CAAC,cAAc;QAChC,KAAK,CAAC,cAAc,CAAC,KAAK;QAC1B,IAAI,KAAK,CAAC,cAAc,CAAC,KAAK,EAAE,CAAC;QACjC,KAAK,CAAC,IAAI,CAAC;IACb,OAAO,GAAG,CAAC,MAAM,CAAC;QAChB,2CAA2C;QAC3C,QAAQ,EAAE,IAAI,CAAC,OAAO,CAAC,IAAI,MAAM,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC;QAC3C,KAAK,EAAE,KAAK,CAAC,+BAA+B;KAC7C,CAAC,CAAC;AACL,CAAC;AAED,MAAM,mCAAmC,GAAG,CAAC,KAA2B,EAAE,EAAE,CAC1E,yBAAyB,CAAC;IACxB,KAAK;IACL,IAAI,EAAE,4BAA4B,CAAC,KAAK,CAAC;CAC1C,CAAC,CAAC;AAEL,MAAM,uBAAuB,GAA4E,CACvG,EAAE,IAAI,EAAE,OAAO,EAAE,eAAe,EAAE,UAAU,EAAE,EAC9C,EAAE;IACF,MAAM,iBAAiB,GAAG,oBAAoB,CAAC,OAAO,CAAC,CAAC;IACxD,MAAM,sBAAsB,GAAG,iBAAiB,CAAC,mBAAmB,CAAC,CAAC;IAEtE,0DAA0D;IAC1D,IAAI,sBAAsB,IAAI,sBAAsB,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE,CAAC;QACzE,iBAAiB,CAAC,mBAAmB,CAAC,GAAG,sBAAsB,CAAC,MAAM,CACpE,CAAC,WAAW,EAAE,EAAE,CAAC,WAAW,KAAK,SAAS,CAC3C,CAAC;IACJ,CAAC;IAED,OAAO;QACL,UAAU;QACV,IAAI;QACJ,OAAO,EAAE,MAAM,CAAC,GAAG,CAAC,OAAO,EAAE,MAAM,CAAC;QACpC,iBAAiB;QACjB,eAAe;KAChB,CAAC;AACJ,CAAC,CAAC;AAEF,eAAe;IACb,UAAU,EAAE,mCAAmC;IAC/C,WAAW,EAAE,uBAAuB;CACuB,CAAC"}
+{"version":3,"file":"api-gateway-v1.js","sourceRoot":"","sources":["../../../../src/internal/aws/api-gateway-v1.ts"],"names":[],"mappings":"AAAA,OAAO,GAAG,MAAM,UAAU,CAAC;AAE3B,OAAO,KAAK,MAAM,MAAM,eAAe,CAAC;AAGxC,OAAO,EAAE,oBAAoB,EAAE,yBAAyB,EAAE,MAAM,aAAa,CAAC;AAE9E,SAAS,4BAA4B,CAAC,KAA2B;IAC/D,4FAA4F;IAC5F,MAAM,IAAI,GAAG,CAAC,KAAK,CAAC,cAAc;QAChC,KAAK,CAAC,cAAc,CAAC,KAAK;QAC1B,IAAI,KAAK,CAAC,cAAc,CAAC,KAAK,EAAE,CAAC;QACjC,KAAK,CAAC,IAAI,CAAC;IACb,OAAO,GAAG,CAAC,MAAM,CAAC;QAChB,2CAA2C;QAC3C,QAAQ,EAAE,IAAI,CAAC,OAAO,CAAC,IAAI,MAAM,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC;QAC3C,KAAK,EAAE,KAAK,CAAC,+BAA+B;KAC7C,CAAC,CAAC;AACL,CAAC;AAED,MAAM,mCAAmC,GAAG,CAAC,KAA2B,EAAE,EAAE,CAC1E,yBAAyB,CAAC;IACxB,KAAK;IACL,IAAI,EAAE,4BAA4B,CAAC,KAAK,CAAC;CAC1C,CAAC,CAAC;AAEL,MAAM,uBAAuB,GAA4E,CACvG,EAAE,IAAI,EAAE,OAAO,EAAE,eAAe,EAAE,UAAU,EAAE,EAC9C,EAAE;IACF,MAAM,iBAAiB,GAAG,oBAAoB,CAAC,OAAO,CAAC,CAAC;IACxD,MAAM,sBAAsB,GAAG,iBAAiB,CAAC,mBAAmB,CAAC,CAAC;IAEtE,0DAA0D;IAC1D,IAAI,sBAAsB,IAAI,sBAAsB,CAAC,QAAQ,CAAC,SAAS,CAAC,EAAE,CAAC;QACzE,iBAAiB,CAAC,mBAAmB,CAAC,GAAG,sBAAsB,CAAC,MAAM,CACpE,CAAC,WAAW,EAAE,EAAE,CAAC,WAAW,KAAK,SAAS,CAC3C,CAAC;IACJ,CAAC;IAED,OAAO;QACL,UAAU;QACV,IAAI;QACJ,OAAO,EAAE,MAAM,CAAC,GAAG,CAAC,OAAO,EAAE,MAAM,CAAC;QACpC,iBAAiB;QACjB,eAAe;KAChB,CAAC;AACJ,CAAC,CAAC;AAEF,eAAe;IACb,UAAU,EAAE,mCAAmC;IAC/C,WAAW,EAAE,uBAAuB;CACuB,CAAC"}

dist/esm/internal/lambdaHandler.js

@@ -1,2 +0,2 @@
-import { Context } from "effect";
+import * as Context from "effect/Context";
 /** @internal */
@@ -3,0 +3,0 @@ export const lambdaEventTag = Context.GenericTag("@effect-aws/lambda/LambdaHandler/Event");

dist/esm/internal/lambdaHandler.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"lambdaHandler.js","sourceRoot":"","sources":["../../../src/internal/lambdaHandler.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,OAAO,EAAE,MAAM,QAAQ,CAAC;AAIjC,gBAAgB;AAChB,MAAM,CAAC,MAAM,cAAc,GAAG,OAAO,CAAC,UAAU,CAC9C,wCAAwC,CACzC,CAAC;AAEF,gBAAgB;AAChB,MAAM,CAAC,MAAM,gBAAgB,GAAG,OAAO,CAAC,UAAU,CAChD,0CAA0C,CAC3C,CAAC"}
+{"version":3,"file":"lambdaHandler.js","sourceRoot":"","sources":["../../../src/internal/lambdaHandler.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,OAAO,MAAM,gBAAgB,CAAC;AAI1C,gBAAgB;AAChB,MAAM,CAAC,MAAM,cAAc,GAAG,OAAO,CAAC,UAAU,CAC9C,wCAAwC,CACzC,CAAC;AAEF,gBAAgB;AAChB,MAAM,CAAC,MAAM,gBAAgB,GAAG,OAAO,CAAC,UAAU,CAChD,0CAA0C,CAC3C,CAAC"}

dist/esm/internal/stream.js

@@ -1,5 +0,7 @@
-import { Error } from "@effect/platform";
 import * as NodeStream from "@effect/platform-node-shared/NodeStream";
-import { Effect, Predicate, Stream } from "effect";
+import * as Error from "@effect/platform/Error";
+import * as Effect from "effect/Effect";
 import { dual } from "effect/Function";
+import * as Predicate from "effect/Predicate";
+import * as Stream from "effect/Stream";
 import * as NS from "node:stream/promises";
@@ -6,0 +8,0 @@ /** @internal */

dist/esm/internal/stream.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"stream.js","sourceRoot":"","sources":["../../../src/internal/stream.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,KAAK,EAAE,MAAM,kBAAkB,CAAC;AACzC,OAAO,KAAK,UAAU,MAAM,yCAAyC,CAAC;AACtE,OAAO,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,EAAE,MAAM,QAAQ,CAAC;AACnD,OAAO,EAAE,IAAI,EAAE,MAAM,iBAAiB,CAAC;AAEvC,OAAO,KAAK,EAAE,MAAM,sBAAsB,CAAC;AAE3C,gBAAgB;AAChB,MAAM,QAAQ,GAAG,CAAC,CAAU,EAAwC,EAAE,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC;AAErH,MAAM,oBAAoB,GACxB,CAAC,MAAmC,EAAE,MAAc,EAAE,EAAE,CAAC,CAAC,GAAY,EAAuB,EAAE;IAC7F,MAAM,MAAM,GAA4B,SAAS,CAAC;IAElD,OAAO,IAAI,KAAK,CAAC,WAAW,CAAC;QAC3B,MAAM;QACN,MAAM;QACN,MAAM;QACN,gBAAgB,EAAE,EAAE;QACpB,OAAO,EAAG,GAA6B,CAAC,OAAO;QAC/C,WAAW,EAAG,GAA6B,CAAC,OAAO;QACnD,KAAK,EAAE,GAAG;KACX,CAAC,CAAC;AACL,CAAC,CAAC;AAEJ,gBAAgB;AAChB,MAAM,CAAC,MAAM,QAAQ,GAMjB,CAAC,MAAM,EAAE,WAAW,EAAE,OAAO,EAAE,EAAE,CACnC,MAAM,CAAC,UAAU,CAAC;IAChB,GAAG,EAAE,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE,CAAC,QAAQ,CAAC,MAAM,EAAE,WAAW,EAAE,EAAE,GAAG,OAAO,EAAE,MAAM,EAAE,CAAC;IACzE,KAAK,EAAE,oBAAoB,CAAC,QAAQ,EAAE,UAAU,CAAC;CAClD,CAAC,CAAC;AAEL,gBAAgB;AAChB,MAAM,CAAC,MAAM,MAAM,GAUf,IAAI,CACN,CAAC,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAC3B,CACE,MAAgD,EAChD,QAA+B,EAC/B,OAA4C,EAC5C,EAAE,CACF,MAAM,CAAC,IAAI,CACT,UAAU,CAAC,UAAU,EACrB,MAAM,CAAC,OAAO,CAAC,CAAC,QAAQ,EAAE,EAAE,CAAC,QAAQ,CAAC,QAAQ,EAAE,QAAQ,EAAE,OAAO,CAAC,CAAC,CACpE,CACJ,CAAC"}
+{"version":3,"file":"stream.js","sourceRoot":"","sources":["../../../src/internal/stream.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,UAAU,MAAM,yCAAyC,CAAC;AACtE,OAAO,KAAK,KAAK,MAAM,wBAAwB,CAAC;AAChD,OAAO,KAAK,MAAM,MAAM,eAAe,CAAC;AACxC,OAAO,EAAE,IAAI,EAAE,MAAM,iBAAiB,CAAC;AACvC,OAAO,KAAK,SAAS,MAAM,kBAAkB,CAAC;AAC9C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAC;AAExC,OAAO,KAAK,EAAE,MAAM,sBAAsB,CAAC;AAE3C,gBAAgB;AAChB,MAAM,QAAQ,GAAG,CAAC,CAAU,EAAwC,EAAE,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC,EAAE,MAAM,CAAC,YAAY,CAAC,CAAC;AAErH,MAAM,oBAAoB,GACxB,CAAC,MAAmC,EAAE,MAAc,EAAE,EAAE,CAAC,CAAC,GAAY,EAAuB,EAAE;IAC7F,MAAM,MAAM,GAA4B,SAAS,CAAC;IAElD,OAAO,IAAI,KAAK,CAAC,WAAW,CAAC;QAC3B,MAAM;QACN,MAAM;QACN,MAAM;QACN,gBAAgB,EAAE,EAAE;QACpB,OAAO,EAAG,GAA6B,CAAC,OAAO;QAC/C,WAAW,EAAG,GAA6B,CAAC,OAAO;QACnD,KAAK,EAAE,GAAG;KACX,CAAC,CAAC;AACL,CAAC,CAAC;AAEJ,gBAAgB;AAChB,MAAM,CAAC,MAAM,QAAQ,GAMjB,CAAC,MAAM,EAAE,WAAW,EAAE,OAAO,EAAE,EAAE,CACnC,MAAM,CAAC,UAAU,CAAC;IAChB,GAAG,EAAE,CAAC,MAAM,EAAE,EAAE,CAAC,EAAE,CAAC,QAAQ,CAAC,MAAM,EAAE,WAAW,EAAE,EAAE,GAAG,OAAO,EAAE,MAAM,EAAE,CAAC;IACzE,KAAK,EAAE,oBAAoB,CAAC,QAAQ,EAAE,UAAU,CAAC;CAClD,CAAC,CAAC;AAEL,gBAAgB;AAChB,MAAM,CAAC,MAAM,MAAM,GAUf,IAAI,CACN,CAAC,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAC3B,CACE,MAAgD,EAChD,QAA+B,EAC/B,OAA4C,EAC5C,EAAE,CACF,MAAM,CAAC,IAAI,CACT,UAAU,CAAC,UAAU,EACrB,MAAM,CAAC,OAAO,CAAC,CAAC,QAAQ,EAAE,EAAE,CAAC,QAAQ,CAAC,QAAQ,EAAE,QAAQ,EAAE,OAAO,CAAC,CAAC,CACpE,CACJ,CAAC"}

dist/esm/LambdaHandler.js

@@ -1,3 +0,7 @@
-import { HttpApiBuilder, HttpApp } from "@effect/platform";
-import { Context, Effect, Function, Layer } from "effect";
+import * as HttpApiBuilder from "@effect/platform/HttpApiBuilder";
+import * as HttpApp from "@effect/platform/HttpApp";
+import * as Context from "effect/Context";
+import * as Effect from "effect/Effect";
+import * as Function from "effect/Function";
+import * as Layer from "effect/Layer";
 import { getEventSource } from "./internal/index.js";
@@ -4,0 +8,0 @@ import * as internal from "./internal/lambdaHandler.js";

dist/esm/LambdaHandler.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"LambdaHandler.js","sourceRoot":"","sources":["../../src/LambdaHandler.ts"],"names":[],"mappings":"AAIA,OAAO,EAAE,cAAc,EAAE,OAAO,EAAE,MAAM,kBAAkB,CAAC;AAE3D,OAAO,EAAE,OAAO,EAAE,MAAM,EAAE,QAAQ,EAAE,KAAK,EAAE,MAAM,QAAQ,CAAC;AAC1D,OAAO,EAAE,cAAc,EAAE,MAAM,qBAAqB,CAAC;AACrD,OAAO,KAAK,QAAQ,MAAM,6BAA6B,CAAC;AACxD,OAAO,EAAE,MAAM,EAAE,MAAM,sBAAsB,CAAC;AAE9C,OAAO,EAAE,YAAY,EAAE,uBAAuB,EAAE,mBAAmB,EAAE,MAAM,qBAAqB,CAAC;AACjG,OAAO,KAAK,aAAa,MAAM,oBAAoB,CAAC;AAwDpD;;;GAGG;AACH,MAAM,CAAC,MAAM,KAAK,GAAG,GAAoD,EAAE,CACzE,MAAM,CAAC,GAAG,CACR,MAAM,CAAC,OAAO,EAAS,EACvB,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,cAAc,CAAC,CAC7C,CAAC;AAExB;;;GAGG;AACH,MAAM,CAAC,MAAM,OAAO,GAAG,GAAiC,EAAE,CACxD,MAAM,CAAC,GAAG,CACR,MAAM,CAAC,OAAO,EAAS,EACvB,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,gBAAgB,CAAC,CACnE,CAAC;AAEJ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,MAAM,CAAC,MAAM,IAAI,GAcb,CACF,gBAAsF,EACtF,WAAgC,EACjB,EAAE;IACjB,IAAI,QAAQ,CAAC,UAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;QAC1C,kBAAkB;QAClB,IAAI,WAAW,EAAE,CAAC;YAChB,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC;YACrD,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,CAAC,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC;QAC7F,CAAC;QAED,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,CAC9B,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,MAAM,CAAC,UAA+D,CAAC,CAAC;IAClH,CAAC;IAED,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,gBAAgB,CAAC,KAAK,EAAE,EAAE,OAAO,EAAE,gBAAgB,CAAC,OAAO,EAAE,CAAC,CAAC;IACvG,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;QAC9B,OAAO,CAAC,8BAA8B,GAAG,KAAK,CAAC;QAC/C,OAAO,gBAAgB,CAAC,OAAO,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC;IAC3E,CAAC,CAAC;AACJ,CAAC,CAAC;AAEF;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,MAAM,CAAC,MAAM,MAAM,GAGf,CACF,gBAAgF,EAC9D,EAAE;IACpB,IAAI,QAAQ,CAAC,UAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;QAC1C,OAAO,MAAM,CAAC,SAAS,EAAE,iBAAiB,CAAC,KAAK,EAAE,KAAK,EAAE,cAAc,EAAE,OAAO,EAAE,EAAE,CAClF,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CACnC,MAAM,CAAC,cAAc,EAAE,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,EACrC,MAAM,CAAC,UAAqE,CAC7E,CACF,CAAC;IACJ,CAAC;IAED,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,gBAAgB,CAAC,KAAK,EAAE,EAAE,OAAO,EAAE,gBAAgB,CAAC,OAAO,EAAE,CAAC,CAAC;IACvG,OAAO,MAAM,CAAC,SAAS,EAAE,iBAAiB,CAAC,KAAK,EAAE,KAAK,EAAE,cAAc,EAAE,OAAO,EAAE,EAAE;QAClF,OAAO,CAAC,8BAA8B,GAAG,KAAK,CAAC;QAC/C,OAAO,gBAAgB,CAAC,OAAO,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAClD,MAAM,CAAC,cAAc,EAAE,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,EACrC,OAAO,CAAC,UAAU,CACnB,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC,CAAC;AAWF,MAAM,UAAU,GAAG,OAAO,CAAC,UAAU,CAAa,+BAA+B,CAAC,CAAC;AAEnF;;;;;GAKG;AACH,MAAM,CAAC,MAAM,cAAc,GAAG,CAAC,OAA4C,EASzE,EAAE,CACF,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;IAClB,MAAM,GAAG,GAAG,KAAK,CAAC,CAAC,cAAc,CAAC,OAAO,CAAC;IAC1C,MAAM,EAAE,GAAG,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,EAE7B,CAAC;IACJ,OAAO,OAAO,CAAC,mBAAmB,CAAC,EAAE,CAAC,CACpC,OAAO,EAAE,UAAU,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CAAC,GAAU,CAAQ,CAAC,CAAC,CAAC,GAAG,CAClE,CAAC;AACJ,CAAC,CAAC,CAAC;AAEL;;;;;GAKG;AACH,MAAM,CAAC,MAAM,cAAc,GAAG,CAAC,OAA4C,EAKzE,EAAE,CACJ,CAAC,KAAK,EAAE,OAAO,EAAE,EAAE,CACjB,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;IAClB,MAAM,WAAW,GAAG,cAAc,CAAC,KAAK,CAA2D,CAAC;IACpG,MAAM,aAAa,GAAG,WAAW,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAEpD,MAAM,GAAG,GAAG,IAAI,OAAO,CACrB,WAAW,aAAa,CAAC,aAAa,GAAG,aAAa,CAAC,IAAI,EAAE,EAC7D;QACE,MAAM,EAAE,aAAa,CAAC,MAAM;QAC5B,OAAO,EAAE,aAAa,CAAC,OAAO;QAC9B,IAAI,EAAE,aAAa,CAAC,IAAI;KACzB,CACF,CAAC;IAEF,MAAM,GAAG,GAAG,KAAK,CAAC,CAAC,cAAc,CAAC,OAAO,CAAC,CAAC,IAAI,CAC7C,MAAM,CAAC,cAAc,CAAC,QAAQ,CAAC,cAAc,EAAE,KAAK,CAAC,EACrD,MAAM,CAAC,cAAc,CAAC,QAAQ,CAAC,gBAAgB,EAAE,OAAO,CAAC,EACzD,MAAM,CAAC,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAC1C,CAAC;IAEF,MAAM,WAAW,GAAG,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC;IACpD,IAAI,eAAe,GAAG,WAAW,IAAI,mBAAmB,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC;IAErF,IAAI,CAAC,eAAe,EAAE,CAAC;QACrB,MAAM,eAAe,GAAG,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;QAC5D,eAAe,GAAG,uBAAuB,CAAC,eAAe,CAAC,CAAC;IAC7D,CAAC;IAED,MAAM,IAAI,GAAG,eAAe;QAC1B,CAAC,CAAC,YAAY,CAAC,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,WAAW,EAAE,CAAC,CAAC;QAC9D,CAAC,CAAC,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC,CAAC;IAE5C,MAAM,OAAO,GAAmD,EAAE,CAAC;IAEnE,IAAI,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,YAAY,CAAC,EAAE,CAAC;QAClC,MAAM,OAAO,GAAG,GAAG,CAAC,OAAO,CAAC,YAAY;YACtC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,YAAY,EAAE;YAC5B,CAAC,CAAC,KAAK,CAAC,IAAI,CAAE,GAAG,CAAC,OAAe,CAAC,OAAO,EAAE,CAAC;iBACzC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,KAAK,YAAY,CAAC;iBACxC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,CAAC,CAAC;QAE5B,IAAI,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC;YAC3B,OAAO,CAAC,YAAY,CAAC,GAAG,OAAO,CAAC;YAChC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,YAAY,CAAC,CAAC;QACnC,CAAC;IACH,CAAC;IAED,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,KAAK,EAAE,GAAG,EAAE,EAAE;QACjC,OAAO,CAAC,GAAG,CAAC,GAAG,KAAK,CAAC;IACvB,CAAC,CAAC,CAAC;IAEH,OAAO,WAAW,CAAC,WAAW,CAAC;QAC7B,KAAK;QACL,UAAU,EAAE,GAAG,CAAC,MAAM;QACtB,IAAI;QACJ,OAAO;QACP,eAAe;KAChB,CAAC,CAAC;AACL,CAAC,CAAC,CAAC;AAEL;;;;;;;;;;;;;;;;;;;;;;;;;GAyBG;AACH,MAAM,CAAC,MAAM,WAAW,GAAG,CACzB,KAAgF,EAChF,OAAwB,EAC4B,EAAE;IACtD,MAAM,YAAY,GAAG,KAAK,CAAC,QAAQ,CAAC,KAAK,EAAE,cAAc,CAAC,MAAM,CAAC,IAAI,EAAE,cAAc,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IACxG,OAAO,IAAI,CAAC,EAAE,OAAO,EAAE,cAAc,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,YAAY,EAAE,OAAO,EAAE,OAAO,EAAE,OAAO,EAAE,CAAC,CAAC;AACpG,CAAC,CAAC"}
+{"version":3,"file":"LambdaHandler.js","sourceRoot":"","sources":["../../src/LambdaHandler.ts"],"names":[],"mappings":"AAIA,OAAO,KAAK,cAAc,MAAM,iCAAiC,CAAC;AAClE,OAAO,KAAK,OAAO,MAAM,0BAA0B,CAAC;AAGpD,OAAO,KAAK,OAAO,MAAM,gBAAgB,CAAC;AAC1C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAC;AACxC,OAAO,KAAK,QAAQ,MAAM,iBAAiB,CAAC;AAC5C,OAAO,KAAK,KAAK,MAAM,cAAc,CAAC;AACtC,OAAO,EAAE,cAAc,EAAE,MAAM,qBAAqB,CAAC;AACrD,OAAO,KAAK,QAAQ,MAAM,6BAA6B,CAAC;AACxD,OAAO,EAAE,MAAM,EAAE,MAAM,sBAAsB,CAAC;AAE9C,OAAO,EAAE,YAAY,EAAE,uBAAuB,EAAE,mBAAmB,EAAE,MAAM,qBAAqB,CAAC;AACjG,OAAO,KAAK,aAAa,MAAM,oBAAoB,CAAC;AAwDpD;;;GAGG;AACH,MAAM,CAAC,MAAM,KAAK,GAAG,GAAoD,EAAE,CACzE,MAAM,CAAC,GAAG,CACR,MAAM,CAAC,OAAO,EAAS,EACvB,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,cAAc,CAAC,CAC7C,CAAC;AAExB;;;GAGG;AACH,MAAM,CAAC,MAAM,OAAO,GAAG,GAAiC,EAAE,CACxD,MAAM,CAAC,GAAG,CACR,MAAM,CAAC,OAAO,EAAS,EACvB,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,gBAAgB,CAAC,CACnE,CAAC;AAEJ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,MAAM,CAAC,MAAM,IAAI,GAcb,CACF,gBAAsF,EACtF,WAAgC,EACjB,EAAE;IACjB,IAAI,QAAQ,CAAC,UAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;QAC1C,kBAAkB;QAClB,IAAI,WAAW,EAAE,CAAC;YAChB,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,WAAW,CAAC,CAAC;YACrD,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,CAAC,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC;QAC7F,CAAC;QAED,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,CAC9B,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,MAAM,CAAC,UAA+D,CAAC,CAAC;IAClH,CAAC;IAED,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,gBAAgB,CAAC,KAAK,EAAE,EAAE,OAAO,EAAE,gBAAgB,CAAC,OAAO,EAAE,CAAC,CAAC;IACvG,OAAO,KAAK,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE;QAC9B,OAAO,CAAC,8BAA8B,GAAG,KAAK,CAAC;QAC/C,OAAO,gBAAgB,CAAC,OAAO,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,OAAO,CAAC,UAAU,CAAC,CAAC;IAC3E,CAAC,CAAC;AACJ,CAAC,CAAC;AAEF;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;GA+BG;AACH,MAAM,CAAC,MAAM,MAAM,GAGf,CACF,gBAAgF,EAC9D,EAAE;IACpB,IAAI,QAAQ,CAAC,UAAU,CAAC,gBAAgB,CAAC,EAAE,CAAC;QAC1C,OAAO,MAAM,CAAC,SAAS,EAAE,iBAAiB,CAAC,KAAK,EAAE,KAAK,EAAE,cAAc,EAAE,OAAO,EAAE,EAAE,CAClF,gBAAgB,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CACnC,MAAM,CAAC,cAAc,EAAE,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,EACrC,MAAM,CAAC,UAAqE,CAC7E,CACF,CAAC;IACJ,CAAC;IAED,MAAM,OAAO,GAAG,aAAa,CAAC,SAAS,CAAC,gBAAgB,CAAC,KAAK,EAAE,EAAE,OAAO,EAAE,gBAAgB,CAAC,OAAO,EAAE,CAAC,CAAC;IACvG,OAAO,MAAM,CAAC,SAAS,EAAE,iBAAiB,CAAC,KAAK,EAAE,KAAK,EAAE,cAAc,EAAE,OAAO,EAAE,EAAE;QAClF,OAAO,CAAC,8BAA8B,GAAG,KAAK,CAAC;QAC/C,OAAO,gBAAgB,CAAC,OAAO,CAAC,KAAK,EAAE,OAAO,CAAC,CAAC,IAAI,CAClD,MAAM,CAAC,cAAc,EAAE,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,EACrC,OAAO,CAAC,UAAU,CACnB,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC,CAAC;AAWF,MAAM,UAAU,GAAG,OAAO,CAAC,UAAU,CAAa,+BAA+B,CAAC,CAAC;AAEnF;;;;;GAKG;AACH,MAAM,CAAC,MAAM,cAAc,GAAG,CAAC,OAA4C,EASzE,EAAE,CACF,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;IAClB,MAAM,GAAG,GAAG,KAAK,CAAC,CAAC,cAAc,CAAC,OAAO,CAAC;IAC1C,MAAM,EAAE,GAAG,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,EAE7B,CAAC;IACJ,OAAO,OAAO,CAAC,mBAAmB,CAAC,EAAE,CAAC,CACpC,OAAO,EAAE,UAAU,CAAC,CAAC,CAAC,OAAO,CAAC,UAAU,CAAC,GAAU,CAAQ,CAAC,CAAC,CAAC,GAAG,CAClE,CAAC;AACJ,CAAC,CAAC,CAAC;AAEL;;;;;GAKG;AACH,MAAM,CAAC,MAAM,cAAc,GAAG,CAAC,OAA4C,EAKzE,EAAE,CACJ,CAAC,KAAK,EAAE,OAAO,EAAE,EAAE,CACjB,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;IAClB,MAAM,WAAW,GAAG,cAAc,CAAC,KAAK,CAA2D,CAAC;IACpG,MAAM,aAAa,GAAG,WAAW,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IAEpD,MAAM,GAAG,GAAG,IAAI,OAAO,CACrB,WAAW,aAAa,CAAC,aAAa,GAAG,aAAa,CAAC,IAAI,EAAE,EAC7D;QACE,MAAM,EAAE,aAAa,CAAC,MAAM;QAC5B,OAAO,EAAE,aAAa,CAAC,OAAO;QAC9B,IAAI,EAAE,aAAa,CAAC,IAAI;KACzB,CACF,CAAC;IAEF,MAAM,GAAG,GAAG,KAAK,CAAC,CAAC,cAAc,CAAC,OAAO,CAAC,CAAC,IAAI,CAC7C,MAAM,CAAC,cAAc,CAAC,QAAQ,CAAC,cAAc,EAAE,KAAK,CAAC,EACrD,MAAM,CAAC,cAAc,CAAC,QAAQ,CAAC,gBAAgB,EAAE,OAAO,CAAC,EACzD,MAAM,CAAC,OAAO,CAAC,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAC1C,CAAC;IAEF,MAAM,WAAW,GAAG,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC;IACpD,IAAI,eAAe,GAAG,WAAW,IAAI,mBAAmB,CAAC,WAAW,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,KAAK,CAAC;IAErF,IAAI,CAAC,eAAe,EAAE,CAAC;QACrB,MAAM,eAAe,GAAG,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;QAC5D,eAAe,GAAG,uBAAuB,CAAC,eAAe,CAAC,CAAC;IAC7D,CAAC;IAED,MAAM,IAAI,GAAG,eAAe;QAC1B,CAAC,CAAC,YAAY,CAAC,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,WAAW,EAAE,CAAC,CAAC;QAC9D,CAAC,CAAC,KAAK,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC,CAAC;IAE5C,MAAM,OAAO,GAAmD,EAAE,CAAC;IAEnE,IAAI,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,YAAY,CAAC,EAAE,CAAC;QAClC,MAAM,OAAO,GAAG,GAAG,CAAC,OAAO,CAAC,YAAY;YACtC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,YAAY,EAAE;YAC5B,CAAC,CAAC,KAAK,CAAC,IAAI,CAAE,GAAG,CAAC,OAAe,CAAC,OAAO,EAAE,CAAC;iBACzC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,KAAK,YAAY,CAAC;iBACxC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAM,EAAE,EAAE,CAAC,CAAC,CAAC,CAAC;QAE5B,IAAI,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC;YAC3B,OAAO,CAAC,YAAY,CAAC,GAAG,OAAO,CAAC;YAChC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,YAAY,CAAC,CAAC;QACnC,CAAC;IACH,CAAC;IAED,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,KAAK,EAAE,GAAG,EAAE,EAAE;QACjC,OAAO,CAAC,GAAG,CAAC,GAAG,KAAK,CAAC;IACvB,CAAC,CAAC,CAAC;IAEH,OAAO,WAAW,CAAC,WAAW,CAAC;QAC7B,KAAK;QACL,UAAU,EAAE,GAAG,CAAC,MAAM;QACtB,IAAI;QACJ,OAAO;QACP,eAAe;KAChB,CAAC,CAAC;AACL,CAAC,CAAC,CAAC;AAEL;;;;;;;;;;;;;;;;;;;;;;;;;GAyBG;AACH,MAAM,CAAC,MAAM,WAAW,GAAG,CACzB,KAAgF,EAChF,OAAwB,EAC4B,EAAE;IACtD,MAAM,YAAY,GAAG,KAAK,CAAC,QAAQ,CAAC,KAAK,EAAE,cAAc,CAAC,MAAM,CAAC,IAAI,EAAE,cAAc,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;IACxG,OAAO,IAAI,CAAC,EAAE,OAAO,EAAE,cAAc,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,YAAY,EAAE,OAAO,EAAE,OAAO,EAAE,OAAO,EAAE,CAAC,CAAC;AACpG,CAAC,CAAC"}

dist/esm/LambdaRuntime.js

@@ -1,3 +0,8 @@
-import { Console, Effect, ManagedRuntime } from "effect";
 /**
+ * @since 1.0.0
+ */
+import * as Console from "effect/Console";
+import * as Effect from "effect/Effect";
+import * as ManagedRuntime from "effect/ManagedRuntime";
+/**
  * Makes a managed runtime from a layer asynchronously, designed for AWS Lambda.
@@ -4,0 +9,0 @@ * All finalizers will be executed on process termination or interruption.

dist/esm/LambdaRuntime.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"LambdaRuntime.js","sourceRoot":"","sources":["../../src/LambdaRuntime.ts"],"names":[],"mappings":"AAIA,OAAO,EAAE,OAAO,EAAE,MAAM,EAAE,cAAc,EAAE,MAAM,QAAQ,CAAC;AAEzD;;;;;;;;;;;;;;;;;;GAkBG;AACH,MAAM,CAAC,MAAM,SAAS,GAAG,CACvB,KAAwB,EACxB,OAA8C,EACT,EAAE;IACvC,MAAM,EAAE,GAAG,cAAc,CAAC,IAAI,CAAC,KAAK,EAAE,OAAO,EAAE,OAAO,CAAC,CAAC;IAExD,MAAM,aAAa,GAA2B,CAAC,MAAM,EAAE,EAAE;QACvD,MAAM,CAAC,OAAO,CACZ,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;YAClB,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,aAAa,MAAM,WAAW,CAAC,CAAC;YACnD,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,uBAAuB,CAAC,CAAC;YAC5C,KAAK,CAAC,CAAC,EAAE,CAAC,aAAa,CAAC;YACxB,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;YACxC,KAAK,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC;QAC5C,CAAC,CAAC,CACH,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,aAAa,CAAC,CAAC;IACrC,OAAO,CAAC,EAAE,CAAC,QAAQ,EAAE,aAAa,CAAC,CAAC;IAEpC,OAAO,EAAE,CAAC;AACZ,CAAC,CAAC"}
+{"version":3,"file":"LambdaRuntime.js","sourceRoot":"","sources":["../../src/LambdaRuntime.ts"],"names":[],"mappings":"AAAA;;GAEG;AACH,OAAO,KAAK,OAAO,MAAM,gBAAgB,CAAC;AAC1C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAC;AAExC,OAAO,KAAK,cAAc,MAAM,uBAAuB,CAAC;AAExD;;;;;;;;;;;;;;;;;;GAkBG;AACH,MAAM,CAAC,MAAM,SAAS,GAAG,CACvB,KAAwB,EACxB,OAA8C,EACT,EAAE;IACvC,MAAM,EAAE,GAAG,cAAc,CAAC,IAAI,CAAC,KAAK,EAAE,OAAO,EAAE,OAAO,CAAC,CAAC;IAExD,MAAM,aAAa,GAA2B,CAAC,MAAM,EAAE,EAAE;QACvD,MAAM,CAAC,OAAO,CACZ,MAAM,CAAC,GAAG,CAAC,QAAQ,CAAC;YAClB,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,aAAa,MAAM,WAAW,CAAC,CAAC;YACnD,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,uBAAuB,CAAC,CAAC;YAC5C,KAAK,CAAC,CAAC,EAAE,CAAC,aAAa,CAAC;YACxB,KAAK,CAAC,CAAC,OAAO,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;YACxC,KAAK,CAAC,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC;QAC5C,CAAC,CAAC,CACH,CAAC;IACJ,CAAC,CAAC;IAEF,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,aAAa,CAAC,CAAC;IACrC,OAAO,CAAC,EAAE,CAAC,QAAQ,EAAE,aAAa,CAAC,CAAC;IAEpC,OAAO,EAAE,CAAC;AACZ,CAAC,CAAC"}

package.json

 {
   "name": "@effect-aws/lambda",
-  "version": "1.5.2",
+  "version": "1.6.0",
   "description": "Effectful AWS Lambda handler",
@@ -5,0 +5,0 @@ "license": "MIT",

src/internal/aws/api-gateway-v1.ts

 import url from "node:url";
 
-import { Record } from "effect";
+import * as Record from "effect/Record";
 import type { APIGatewayProxyEvent, APIGatewayProxyResult } from "../../Types.js";
@@ -5,0 +5,0 @@ import type { EventSource } from "../types.js";

src/internal/lambdaHandler.ts

@@ -1,2 +0,2 @@
-import { Context } from "effect";
+import * as Context from "effect/Context";
 import type { LambdaHandler } from "../LambdaHandler.js";
@@ -3,0 +3,0 @@ import type { LambdaContext } from "../Types.js";

src/internal/stream.ts

@@ -1,5 +0,7 @@
-import { Error } from "@effect/platform";
 import * as NodeStream from "@effect/platform-node-shared/NodeStream";
-import { Effect, Predicate, Stream } from "effect";
+import * as Error from "@effect/platform/Error";
+import * as Effect from "effect/Effect";
 import { dual } from "effect/Function";
+import * as Predicate from "effect/Predicate";
+import * as Stream from "effect/Stream";
 import type { PipelineDestination, PipelineSource } from "node:stream";
@@ -6,0 +8,0 @@ import * as NS from "node:stream/promises";

src/LambdaHandler.ts

 /**
  * @since 1.4.0
  */
-import type { HttpApi, HttpRouter } from "@effect/platform";
-import { HttpApiBuilder, HttpApp } from "@effect/platform";
-import type { Cause } from "effect";
-import { Context, Effect, Function, Layer } from "effect";
+import type * as HttpApi from "@effect/platform/HttpApi";
+import * as HttpApiBuilder from "@effect/platform/HttpApiBuilder";
+import * as HttpApp from "@effect/platform/HttpApp";
+import type * as HttpRouter from "@effect/platform/HttpRouter";
+import type * as Cause from "effect/Cause";
+import * as Context from "effect/Context";
+import * as Effect from "effect/Effect";
+import * as Function from "effect/Function";
+import * as Layer from "effect/Layer";
 import { getEventSource } from "./internal/index.js";
@@ -9,0 +14,0 @@ import * as internal from "./internal/lambdaHandler.js";

src/LambdaRuntime.ts

 /**
  * @since 1.0.0
  */
-import type { Layer } from "effect";
-import { Console, Effect, ManagedRuntime } from "effect";
+import * as Console from "effect/Console";
+import * as Effect from "effect/Effect";
+import type * as Layer from "effect/Layer";
+import * as ManagedRuntime from "effect/ManagedRuntime";
 
@@ -7,0 +9,0 @@ /**

src/Types.ts

@@ -21,4 +21,5 @@ /**
 } from "aws-lambda";
-import type { Layer, Stream } from "effect";
 import type * as Effect from "effect/Effect";
+import type * as Layer from "effect/Layer";
+import type * as Stream from "effect/Stream";
 
@@ -25,0 +26,0 @@ declare global {

New alerts

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Fixed alerts

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

235945

2.29%

Lines of code

4269

2.52%

No dependency changes