🚀 Socket Launch Week Day 5:Introducing Repository Access Permissions and Custom Roles.Learn more →
@effect/sql-pg
Advanced tools
@effect/sql-pg - npm Package Compare versions
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"PgClient.d.ts","sourceRoot":"","sources":["../src/PgClient.ts"],"names":[],"mappings":"AAMA,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AACvC,OAAO,KAAK,QAAQ,MAAM,iBAAiB,CAAA;AAC3C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AAEvC,OAAO,KAAK,KAAK,MAAM,cAAc,CAAA;AAKrC,OAAO,KAAK,QAAQ,MAAM,iBAAiB,CAAA;AAC3C,OAAO,KAAK,KAAK,MAAM,cAAc,CAAA;AACrC,OAAO,KAAK,UAAU,MAAM,mBAAmB,CAAA;AAC/C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AACvC,OAAO,KAAK,UAAU,MAAM,uCAAuC,CAAA;AACnE,OAAO,KAAK,MAAM,MAAM,+BAA+B,CAAA;AAEvD,OAAO,EAAE,QAAQ,EAAE,MAAM,8BAA8B,CAAA;AACvD,OAAO,KAAK,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,+BAA+B,CAAA;AACrE,OAAO,KAAK,SAAS,MAAM,+BAA+B,CAAA;AAC1D,OAAO,KAAK,EAAE,MAAM,EAAE,MAAM,aAAa,CAAA;AACzC,OAAO,KAAK,EAAE,iBAAiB,EAAE,MAAM,UAAU,CAAA;AACjD,OAAO,KAAK,EAAE,MAAM,IAAI,CAAA;AASxB;;;GAGG;AACH,eAAO,MAAM,MAAM,EAAE,MAAmC,CAAA;AAExD;;;GAGG;AACH,MAAM,MAAM,MAAM,GAAG,0BAA0B,CAAA;AAE/C;;;GAGG;AACH,MAAM,WAAW,QAAS,SAAQ,MAAM,CAAC,SAAS;IAChD,QAAQ,CAAC,CAAC,MAAM,CAAC,EAAE,MAAM,CAAA;IACzB,QAAQ,CAAC,MAAM,EAAE,cAAc,CAAA;IAC/B,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAC,EAAE,OAAO,KAAK,QAAQ,CAAA;IACvC,QAAQ,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,MAAM,KAAK,MAAM,CAAC,MAAM,CAAC,MAAM,EAAE,QAAQ,CAAC,CAAA;IACrE,QAAQ,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,KAAK,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,QAAQ,CAAC,CAAA;CACrF;AAED;;;GAGG;AACH,eAAO,MAAM,QAAQ,wCAA0D,CAAA;AAE/E;;;GAGG;AACH,MAAM,WAAW,cAAc;IAC7B,QAAQ,CAAC,GAAG,CAAC,EAAE,QAAQ,CAAC,QAAQ,GAAG,SAAS,CAAA;IAE5C,QAAQ,CAAC,IAAI,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAClC,QAAQ,CAAC,IAAI,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAClC,QAAQ,CAAC,IAAI,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAClC,QAAQ,CAAC,GAAG,CAAC,EAAE,OAAO,GAAG,iBAAiB,GAAG,SAAS,CAAA;IACtD,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IACtC,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IACtC,QAAQ,CAAC,QAAQ,CAAC,EAAE,QAAQ,CAAC,QAAQ,GAAG,SAAS,CAAA;IAEjD,QAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,MAAM,MAAM,CAAC,GAAG,SAAS,CAAA;IAE5C,QAAQ,CAAC,WAAW,CAAC,EAAE,QAAQ,CAAC,KAAK,GAAG,SAAS,CAAA;IACjD,QAAQ,CAAC,cAAc,CAAC,EAAE,QAAQ,CAAC,KAAK,GAAG,SAAS,CAAA;IAEpD,QAAQ,CAAC,cAAc,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAC5C,QAAQ,CAAC,cAAc,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAC5C,QAAQ,CAAC,aAAa,CAAC,EAAE,QAAQ,CAAC,KAAK,GAAG,SAAS,CAAA;IAEnD,QAAQ,CAAC,eAAe,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAC7C,QAAQ,CAAC,cAAc,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,SAAS,CAAA;IAE7D,QAAQ,CAAC,oBAAoB,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS,CAAA;IACrE,QAAQ,CAAC,mBAAmB,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS,CAAA;IACpE,QAAQ,CAAC,aAAa,CAAC,EAAE,OAAO,GAAG,SAAS,CAAA;IAC5C,QAAQ,CAAC,KAAK,CAAC,EAAE,EAAE,CAAC,iBAAiB,GAAG,SAAS,CAAA;CAClD;AAED;;;GAGG;AACH,eAAO,MAAM,IAAI,GACf,SAAS,cAAc,KACtB,MAAM,CAAC,MAAM,CAAC,QAAQ,EAAE,QAAQ,EAAE,KAAK,CAAC,KAAK,GAAG,UAAU,CAAC,UAAU,CAsDpE,CAAA;AAEJ;;;GAGG;AACH,eAAO,MAAM,QAAQ;sBAEC,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC,IAAI,EAAE,QAAQ,EAAE,KAAK,CAAC,KAAK,CAAC;+BAEpC,MAAM,GAAG,SAAS;8BACnB,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,SAAS;oCAE7B,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS;mCACtC,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS;6BAC3C,OAAO,GAAG,SAAS;qBAC3B,EAAE,CAAC,iBAAiB,GAAG,SAAS;4EAkRnD,CAAA;AAwBF;;;GAGG;AACH,eAAO,MAAM,WAAW,EAAE,CACxB,MAAM,EAAE,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAChC,KAAK,CAAC,KAAK,CAAC,QAAQ,GAAG,MAAM,CAAC,SAAS,EAAE,MAAM,CAAC,WAAW,GAAG,QAAQ,CAYlC,CAAA;AAEzC;;;GAGG;AACH,eAAO,MAAM,KAAK,GAChB,QAAQ,cAAc,KACrB,KAAK,CAAC,KAAK,CAAC,QAAQ,GAAG,MAAM,CAAC,SAAS,EAAE,QAAQ,CAMX,CAAA;AAEzC;;;GAGG;AACH,eAAO,MAAM,aAAa,GAAI,SAAS;IACrC,QAAQ,CAAC,OAAO,EAAE,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC,IAAI,EAAE,QAAQ,EAAE,KAAK,CAAC,KAAK,CAAC,CAAA;IAE/D,QAAQ,CAAC,eAAe,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAC7C,QAAQ,CAAC,cAAc,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,SAAS,CAAA;IAE7D,QAAQ,CAAC,oBAAoB,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS,CAAA;IACrE,QAAQ,CAAC,mBAAmB,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS,CAAA;IACpE,QAAQ,CAAC,aAAa,CAAC,EAAE,OAAO,GAAG,SAAS,CAAA;IAC5C,QAAQ,CAAC,KAAK,CAAC,EAAE,EAAE,CAAC,iBAAiB,GAAG,SAAS,CAAA;CAClD,KAAG,KAAK,CAAC,KAAK,CAAC,QAAQ,GAAG,MAAM,CAAC,SAAS,EAAE,QAAQ,CAMZ,CAAA;AAEzC;;;GAGG;AACH,eAAO,MAAM,YAAY,GACvB,YAAY,CAAC,CAAC,EAAE,MAAM,KAAK,MAAM,EACjC,uBAAoB,KACnB,SAAS,CAAC,QAsCZ,CAAA;AAID;;;GAGG;AACH,MAAM,MAAM,QAAQ,GAAG,MAAM,CAAA;AAE7B;;;GAGG;AACH,UAAU,MAAO,SAAQ,MAAM,CAAC,QAAQ,EAAE,OAAO,CAAC;CAAG;AACrD;;;GAGG;AACH,QAAA,MAAM,MAAM,yDAAqC,CAAA"} | ||
| {"version":3,"file":"PgClient.d.ts","sourceRoot":"","sources":["../src/PgClient.ts"],"names":[],"mappings":"AAMA,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AACvC,OAAO,KAAK,QAAQ,MAAM,iBAAiB,CAAA;AAC3C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AAEvC,OAAO,KAAK,KAAK,MAAM,cAAc,CAAA;AAKrC,OAAO,KAAK,QAAQ,MAAM,iBAAiB,CAAA;AAC3C,OAAO,KAAK,KAAK,MAAM,cAAc,CAAA;AACrC,OAAO,KAAK,UAAU,MAAM,mBAAmB,CAAA;AAC/C,OAAO,KAAK,MAAM,MAAM,eAAe,CAAA;AACvC,OAAO,KAAK,UAAU,MAAM,uCAAuC,CAAA;AACnE,OAAO,KAAK,MAAM,MAAM,+BAA+B,CAAA;AAEvD,OAAO,EAQL,QAAQ,EAIT,MAAM,8BAA8B,CAAA;AACrC,OAAO,KAAK,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,+BAA+B,CAAA;AACrE,OAAO,KAAK,SAAS,MAAM,+BAA+B,CAAA;AAC1D,OAAO,KAAK,EAAE,MAAM,EAAE,MAAM,aAAa,CAAA;AACzC,OAAO,KAAK,EAAE,iBAAiB,EAAE,MAAM,UAAU,CAAA;AACjD,OAAO,KAAK,EAAE,MAAM,IAAI,CAAA;AAwDxB;;;GAGG;AACH,eAAO,MAAM,MAAM,EAAE,MAAmC,CAAA;AAExD;;;GAGG;AACH,MAAM,MAAM,MAAM,GAAG,0BAA0B,CAAA;AAE/C;;;GAGG;AACH,MAAM,WAAW,QAAS,SAAQ,MAAM,CAAC,SAAS;IAChD,QAAQ,CAAC,CAAC,MAAM,CAAC,EAAE,MAAM,CAAA;IACzB,QAAQ,CAAC,MAAM,EAAE,cAAc,CAAA;IAC/B,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAC,EAAE,OAAO,KAAK,QAAQ,CAAA;IACvC,QAAQ,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,MAAM,KAAK,MAAM,CAAC,MAAM,CAAC,MAAM,EAAE,QAAQ,CAAC,CAAA;IACrE,QAAQ,CAAC,MAAM,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,KAAK,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,QAAQ,CAAC,CAAA;CACrF;AAED;;;GAGG;AACH,eAAO,MAAM,QAAQ,wCAA0D,CAAA;AAE/E;;;GAGG;AACH,MAAM,WAAW,cAAc;IAC7B,QAAQ,CAAC,GAAG,CAAC,EAAE,QAAQ,CAAC,QAAQ,GAAG,SAAS,CAAA;IAE5C,QAAQ,CAAC,IAAI,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAClC,QAAQ,CAAC,IAAI,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAClC,QAAQ,CAAC,IAAI,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAClC,QAAQ,CAAC,GAAG,CAAC,EAAE,OAAO,GAAG,iBAAiB,GAAG,SAAS,CAAA;IACtD,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IACtC,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IACtC,QAAQ,CAAC,QAAQ,CAAC,EAAE,QAAQ,CAAC,QAAQ,GAAG,SAAS,CAAA;IAEjD,QAAQ,CAAC,MAAM,CAAC,EAAE,CAAC,MAAM,MAAM,CAAC,GAAG,SAAS,CAAA;IAE5C,QAAQ,CAAC,WAAW,CAAC,EAAE,QAAQ,CAAC,KAAK,GAAG,SAAS,CAAA;IACjD,QAAQ,CAAC,cAAc,CAAC,EAAE,QAAQ,CAAC,KAAK,GAAG,SAAS,CAAA;IAEpD,QAAQ,CAAC,cAAc,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAC5C,QAAQ,CAAC,cAAc,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAC5C,QAAQ,CAAC,aAAa,CAAC,EAAE,QAAQ,CAAC,KAAK,GAAG,SAAS,CAAA;IAEnD,QAAQ,CAAC,eAAe,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAC7C,QAAQ,CAAC,cAAc,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,SAAS,CAAA;IAE7D,QAAQ,CAAC,oBAAoB,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS,CAAA;IACrE,QAAQ,CAAC,mBAAmB,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS,CAAA;IACpE,QAAQ,CAAC,aAAa,CAAC,EAAE,OAAO,GAAG,SAAS,CAAA;IAC5C,QAAQ,CAAC,KAAK,CAAC,EAAE,EAAE,CAAC,iBAAiB,GAAG,SAAS,CAAA;CAClD;AAED;;;GAGG;AACH,eAAO,MAAM,IAAI,GACf,SAAS,cAAc,KACtB,MAAM,CAAC,MAAM,CAAC,QAAQ,EAAE,QAAQ,EAAE,KAAK,CAAC,KAAK,GAAG,UAAU,CAAC,UAAU,CAyDpE,CAAA;AAEJ;;;GAGG;AACH,eAAO,MAAM,QAAQ;sBAEC,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC,IAAI,EAAE,QAAQ,EAAE,KAAK,CAAC,KAAK,CAAC;+BAEpC,MAAM,GAAG,SAAS;8BACnB,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,SAAS;oCAE7B,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS;mCACtC,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS;6BAC3C,OAAO,GAAG,SAAS;qBAC3B,EAAE,CAAC,iBAAiB,GAAG,SAAS;4EAqUnD,CAAA;AAwBF;;;GAGG;AACH,eAAO,MAAM,WAAW,EAAE,CACxB,MAAM,EAAE,MAAM,CAAC,IAAI,CAAC,cAAc,CAAC,KAChC,KAAK,CAAC,KAAK,CAAC,QAAQ,GAAG,MAAM,CAAC,SAAS,EAAE,MAAM,CAAC,WAAW,GAAG,QAAQ,CAYlC,CAAA;AAEzC;;;GAGG;AACH,eAAO,MAAM,KAAK,GAChB,QAAQ,cAAc,KACrB,KAAK,CAAC,KAAK,CAAC,QAAQ,GAAG,MAAM,CAAC,SAAS,EAAE,QAAQ,CAMX,CAAA;AAEzC;;;GAGG;AACH,eAAO,MAAM,aAAa,GAAI,SAAS;IACrC,QAAQ,CAAC,OAAO,EAAE,MAAM,CAAC,MAAM,CAAC,EAAE,CAAC,IAAI,EAAE,QAAQ,EAAE,KAAK,CAAC,KAAK,CAAC,CAAA;IAE/D,QAAQ,CAAC,eAAe,CAAC,EAAE,MAAM,GAAG,SAAS,CAAA;IAC7C,QAAQ,CAAC,cAAc,CAAC,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,SAAS,CAAA;IAE7D,QAAQ,CAAC,oBAAoB,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS,CAAA;IACrE,QAAQ,CAAC,mBAAmB,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,MAAM,KAAK,MAAM,CAAC,GAAG,SAAS,CAAA;IACpE,QAAQ,CAAC,aAAa,CAAC,EAAE,OAAO,GAAG,SAAS,CAAA;IAC5C,QAAQ,CAAC,KAAK,CAAC,EAAE,EAAE,CAAC,iBAAiB,GAAG,SAAS,CAAA;CAClD,KAAG,KAAK,CAAC,KAAK,CAAC,QAAQ,GAAG,MAAM,CAAC,SAAS,EAAE,QAAQ,CAMZ,CAAA;AAEzC;;;GAGG;AACH,eAAO,MAAM,YAAY,GACvB,YAAY,CAAC,CAAC,EAAE,MAAM,KAAK,MAAM,EACjC,uBAAoB,KACnB,SAAS,CAAC,QAsCZ,CAAA;AAID;;;GAGG;AACH,MAAM,MAAM,QAAQ,GAAG,MAAM,CAAA;AAE7B;;;GAGG;AACH,UAAU,MAAO,SAAQ,MAAM,CAAC,QAAQ,EAAE,OAAO,CAAC;CAAG;AACrD;;;GAGG;AACH,QAAA,MAAM,MAAM,yDAAqC,CAAA"} |
+81
-26
@@ -22,3 +22,3 @@ /** | ||
| import * as Client from "effect/unstable/sql/SqlClient"; | ||
| import { SqlError } from "effect/unstable/sql/SqlError"; | ||
| import { AuthenticationError, AuthorizationError, ConnectionError, ConstraintError, DeadlockError, LockTimeoutError, SerializationError, SqlError, SqlSyntaxError, StatementTimeoutError, UnknownError } from "effect/unstable/sql/SqlError"; | ||
| import * as Statement from "effect/unstable/sql/Statement"; | ||
@@ -32,2 +32,47 @@ import * as Pg from "pg"; | ||
| const ATTR_SERVER_PORT = "server.port"; | ||
| const pgCodeFromCause = cause => { | ||
| if (typeof cause !== "object" || cause === null || !("code" in cause)) { | ||
| return undefined; | ||
| } | ||
| const code = cause.code; | ||
| return typeof code === "string" ? code : undefined; | ||
| }; | ||
| const classifyError = (cause, message, operation) => { | ||
| const props = { | ||
| cause, | ||
| message, | ||
| operation | ||
| }; | ||
| const code = pgCodeFromCause(cause); | ||
| if (code !== undefined) { | ||
| if (code.startsWith("08")) { | ||
| return new ConnectionError(props); | ||
| } | ||
| if (code.startsWith("28")) { | ||
| return new AuthenticationError(props); | ||
| } | ||
| if (code === "42501") { | ||
| return new AuthorizationError(props); | ||
| } | ||
| if (code.startsWith("42")) { | ||
| return new SqlSyntaxError(props); | ||
| } | ||
| if (code.startsWith("23")) { | ||
| return new ConstraintError(props); | ||
| } | ||
| if (code === "40P01") { | ||
| return new DeadlockError(props); | ||
| } | ||
| if (code === "40001") { | ||
| return new SerializationError(props); | ||
| } | ||
| if (code === "55P03") { | ||
| return new LockTimeoutError(props); | ||
| } | ||
| if (code === "57014") { | ||
| return new StatementTimeoutError(props); | ||
| } | ||
| } | ||
| return new UnknownError(props); | ||
| }; | ||
| /** | ||
@@ -73,4 +118,3 @@ * @category type ids | ||
| catch: cause => new SqlError({ | ||
| cause, | ||
| message: "PgClient: Failed to connect" | ||
| reason: classifyError(cause, "PgClient: Failed to connect", "connect") | ||
| }) | ||
@@ -80,4 +124,7 @@ }), () => Effect.promise(() => pool.end()).pipe(Effect.timeoutOption(1000))).pipe(Effect.timeoutOrElse({ | ||
| onTimeout: () => Effect.fail(new SqlError({ | ||
| cause: new Error("Connection timed out"), | ||
| message: "PgClient: Connection timed out" | ||
| reason: new ConnectionError({ | ||
| cause: new Error("Connection timed out"), | ||
| message: "PgClient: Connection timed out", | ||
| operation: "connect" | ||
| }) | ||
| })) | ||
@@ -115,4 +162,3 @@ })); | ||
| resume(Effect.fail(new SqlError({ | ||
| cause, | ||
| message: "Connection error" | ||
| reason: classifyError(cause, "Connection error", "acquireConnection") | ||
| }))); | ||
@@ -128,9 +174,11 @@ } | ||
| return resume(Effect.fail(new SqlError({ | ||
| cause, | ||
| message: "Failed to acquire connection" | ||
| reason: classifyError(cause, "Failed to acquire connection", "acquireConnection") | ||
| }))); | ||
| } else if (!client_) { | ||
| return resume(Effect.fail(new SqlError({ | ||
| message: "Failed to acquire connection", | ||
| cause: new Error("No client returned") | ||
| reason: new ConnectionError({ | ||
| message: "Failed to acquire connection", | ||
| cause: new Error("No client returned"), | ||
| operation: "acquireConnection" | ||
| }) | ||
| }))); | ||
@@ -163,4 +211,3 @@ } else if (done) { | ||
| resume(Effect.fail(new SqlError({ | ||
| cause: err, | ||
| message: "Failed to execute statement" | ||
| reason: classifyError(err, "Failed to execute statement", "execute") | ||
| }))); | ||
@@ -182,4 +229,3 @@ } else { | ||
| resume(Effect.fail(new SqlError({ | ||
| cause: err, | ||
| message: "Failed to execute statement" | ||
| reason: classifyError(err, "Failed to execute statement", "execute") | ||
| }))); | ||
@@ -204,4 +250,3 @@ } else { | ||
| resume(Effect.fail(new SqlError({ | ||
| cause: err, | ||
| message: "Failed to execute statement" | ||
| reason: classifyError(err, "Failed to execute statement", "execute") | ||
| }))); | ||
@@ -229,4 +274,3 @@ } else { | ||
| resume(Effect.fail(new SqlError({ | ||
| cause: err, | ||
| message: "Failed to execute statement" | ||
| reason: classifyError(err, "Failed to execute statement", "stream") | ||
| }))); | ||
@@ -250,4 +294,3 @@ } else if (Arr.isArrayNonEmpty(rows)) { | ||
| resume(Effect.fail(new SqlError({ | ||
| cause: err, | ||
| message: "Failed to acquire connection for transaction" | ||
| reason: classifyError(err, "Failed to acquire connection for transaction", "acquireConnection") | ||
| }))); | ||
@@ -267,4 +310,18 @@ } else { | ||
| const reserve = Effect.map(reserveRaw, client => new ConnectionImpl(client)); | ||
| const onListenClientError = _ => {}; | ||
| const listenClient = yield* RcRef.make({ | ||
| acquire: reserveRaw | ||
| acquire: Effect.acquireRelease(Effect.tryPromise({ | ||
| try: async () => { | ||
| const client = new Pg.Client(pool.options); | ||
| await client.connect(); | ||
| client.on("error", onListenClientError); | ||
| return client; | ||
| }, | ||
| catch: cause => new SqlError({ | ||
| reason: classifyError(cause, "Failed to acquire connection for listen", "acquireConnection") | ||
| }) | ||
| }), client => Effect.promise(() => { | ||
| client.off("error", onListenClientError); | ||
| return client.end(); | ||
| }).pipe(Effect.timeoutOption(1000))) | ||
| }); | ||
@@ -322,4 +379,3 @@ let config = { | ||
| catch: cause => new SqlError({ | ||
| cause, | ||
| message: "Failed to listen" | ||
| reason: classifyError(cause, "Failed to listen", "listen") | ||
| }) | ||
@@ -333,4 +389,3 @@ }); | ||
| resume(Effect.fail(new SqlError({ | ||
| cause: err, | ||
| message: "Failed to notify" | ||
| reason: classifyError(err, "Failed to notify", "notify") | ||
| }))); | ||
@@ -337,0 +392,0 @@ } else { |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"PgClient.js","names":["Arr","Cause","Channel","Config","Duration","Effect","Fiber","Layer","Number","Option","Queue","RcRef","Redacted","Scope","ServiceMap","Stream","Reactivity","Client","SqlError","Statement","Pg","PgConnString","Cursor","ATTR_DB_SYSTEM_NAME","ATTR_DB_NAMESPACE","ATTR_SERVER_ADDRESS","ATTR_SERVER_PORT","TypeId","PgClient","Service","make","options","fromPool","acquire","gen","pool","Pool","connectionString","url","value","undefined","user","username","host","database","password","ssl","port","stream","connectionTimeoutMillis","connectTimeout","toMillis","fromInputUnsafe","idleTimeoutMillis","idleTimeout","max","maxConnections","min","minConnections","maxLifetimeSeconds","connectionTTL","toSeconds","application_name","applicationName","types","on","_err","acquireRelease","tryPromise","try","query","catch","cause","message","promise","end","pipe","timeoutOption","timeoutOrElse","duration","seconds","onTimeout","fail","Error","fnUntraced","compiler","makeCompiler","transformQueryNames","transformJson","transformRows","transformResultNames","defaultTransforms","array","ConnectionImpl","pg","constructor","runWithClient","f","callback","resume","makeCancel","done","cancel","client","onError","cleanup","release","off","connect","client_","once","eff","suspend","void","ensuring","sync","run","params","err","result","succeed","Array","isArray","map","r","rows","execute","sql","executeRaw","executeWithoutTransform","executeValues","text","rowMode","values","executeUnprepared","executeStream","self","fromChannel","fromTransform","_","scope","provide","reserveRaw","addFinalizer","cursor","close","read","isArrayNonEmpty","fiber","getCurrent","getUnsafe","services","as","cause_","reserve","listenClient","config","parsed","parse","getOrUndefined","Object","assign","acquirer","transactionAcquirer","spanAttributes","entries","json","fragment","PgJson","listen","channel","queue","get","onNotification","msg","payload","offerUnsafe","escapeIdentifier","notify","cancelEffects","WeakMap","has","processId","processID","ending","interruptible","set","layerConfig","effectServices","unwrap","asEffect","flatMap","add","SqlClient","layer","layerFromPool","transform","transformValue","dialect","placeholder","onIdentifier","withoutTransform","escape","onRecordUpdate","placeholders","valueAlias","valueColumns","returning","flat","concat","onCustom","type","kind","paramA","defaultEscape","custom"],"sources":["../src/PgClient.ts"],"sourcesContent":[null],"mappings":"AAAA;;;AAGA,OAAO,KAAKA,GAAG,MAAM,cAAc;AACnC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,OAAO,MAAM,gBAAgB;AACzC,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,QAAQ,MAAM,iBAAiB;AAC3C,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,QAAQ,MAAM,iBAAiB;AAC3C,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,UAAU,MAAM,mBAAmB;AAC/C,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,UAAU,MAAM,uCAAuC;AACnE,OAAO,KAAKC,MAAM,MAAM,+BAA+B;AAEvD,SAASC,QAAQ,QAAQ,8BAA8B;AAEvD,OAAO,KAAKC,SAAS,MAAM,+BAA+B;AAG1D,OAAO,KAAKC,EAAE,MAAM,IAAI;AACxB,OAAO,KAAKC,YAAY,MAAM,sBAAsB;AACpD,OAAOC,MAAM,MAAM,WAAW;AAE9B,MAAMC,mBAAmB,GAAG,gBAAgB;AAC5C,MAAMC,iBAAiB,GAAG,cAAc;AACxC,MAAMC,mBAAmB,GAAG,gBAAgB;AAC5C,MAAMC,gBAAgB,GAAG,aAAa;AAEtC;;;;AAIA,OAAO,MAAMC,MAAM,GAAW,0BAA0B;AAoBxD;;;;AAIA,OAAO,MAAMC,QAAQ,gBAAGd,UAAU,CAACe,OAAO,CAAW,yBAAyB,CAAC;AAmC/E;;;;AAIA,OAAO,MAAMC,IAAI,GACfC,OAAuB,IAEvBC,QAAQ,CAAC;EACP,GAAGD,OAAO;EACVE,OAAO,EAAE5B,MAAM,CAAC6B,GAAG,CAAC,aAAS;IAC3B,MAAMC,IAAI,GAAG,IAAIf,EAAE,CAACgB,IAAI,CAAC;MACvBC,gBAAgB,EAAEN,OAAO,CAACO,GAAG,GAAG1B,QAAQ,CAAC2B,KAAK,CAACR,OAAO,CAACO,GAAG,CAAC,GAAGE,SAAS;MACvEC,IAAI,EAAEV,OAAO,CAACW,QAAQ;MACtBC,IAAI,EAAEZ,OAAO,CAACY,IAAI;MAClBC,QAAQ,EAAEb,OAAO,CAACa,QAAQ;MAC1BC,QAAQ,EAAEd,OAAO,CAACc,QAAQ,GAAGjC,QAAQ,CAAC2B,KAAK,CAACR,OAAO,CAACc,QAAQ,CAAC,GAAGL,SAAS;MACzEM,GAAG,EAAEf,OAAO,CAACe,GAAG;MAChBC,IAAI,EAAEhB,OAAO,CAACgB,IAAI;MAClB,IAAIhB,OAAO,CAACiB,MAAM,GAAG;QAAEA,MAAM,EAAEjB,OAAO,CAACiB;MAAM,CAAE,GAAG,EAAE,CAAC;MACrDC,uBAAuB,EAAElB,OAAO,CAACmB,cAAc,GAC3C9C,QAAQ,CAAC+C,QAAQ,CAAC/C,QAAQ,CAACgD,eAAe,CAACrB,OAAO,CAACmB,cAAc,CAAC,CAAC,GACnEV,SAAS;MACba,iBAAiB,EAAEtB,OAAO,CAACuB,WAAW,GAClClD,QAAQ,CAAC+C,QAAQ,CAAC/C,QAAQ,CAACgD,eAAe,CAACrB,OAAO,CAACuB,WAAW,CAAC,CAAC,GAChEd,SAAS;MACbe,GAAG,EAAExB,OAAO,CAACyB,cAAc;MAC3BC,GAAG,EAAE1B,OAAO,CAAC2B,cAAc;MAC3BC,kBAAkB,EAAE5B,OAAO,CAAC6B,aAAa,GACrCxD,QAAQ,CAACyD,SAAS,CAACzD,QAAQ,CAACgD,eAAe,CAACrB,OAAO,CAAC6B,aAAa,CAAC,CAAC,GACnEpB,SAAS;MACbsB,gBAAgB,EAAE/B,OAAO,CAACgC,eAAe,IAAI,gBAAgB;MAC7DC,KAAK,EAAEjC,OAAO,CAACiC;KAChB,CAAC;IAEF7B,IAAI,CAAC8B,EAAE,CAAC,OAAO,EAAGC,IAAI,IAAI,CAAE,CAAC,CAAC;IAE9B,OAAO7D,MAAM,CAAC8D,cAAc,CAC1B9D,MAAM,CAAC+D,UAAU,CAAC;MAChBC,GAAG,EAAEA,CAAA,KAAMlC,IAAI,CAACmC,KAAK,CAAC,UAAU,CAAC;MACjCC,KAAK,EAAGC,KAAK,IAAK,IAAItD,QAAQ,CAAC;QAAEsD,KAAK;QAAEC,OAAO,EAAE;MAA6B,CAAE;KACjF,CAAC,EACF,MACEpE,MAAM,CAACqE,OAAO,CAAC,MAAMvC,IAAI,CAACwC,GAAG,EAAE,CAAC,CAACC,IAAI,CACnCvE,MAAM,CAACwE,aAAa,CAAC,IAAI,CAAC,CAC3B,CACJ,CAACD,IAAI,CACJvE,MAAM,CAACyE,aAAa,CAAC;MACnBC,QAAQ,EAAEhD,OAAO,CAACmB,cAAc,IAAI9C,QAAQ,CAAC4E,OAAO,CAAC,CAAC,CAAC;MACvDC,SAAS,EAAEA,CAAA,KACT5E,MAAM,CAAC6E,IAAI,CACT,IAAIhE,QAAQ,CAAC;QACXsD,KAAK,EAAE,IAAIW,KAAK,CAAC,sBAAsB,CAAC;QACxCV,OAAO,EAAE;OACV,CAAC;KAEP,CAAC,CACH;IAED,OAAOtC,IAAI;EACb,CAAC;CACF,CAAC;AAEJ;;;;AAIA,OAAO,MAAMH,QAAQ,gBAAG3B,MAAM,CAAC+E,UAAU,CAAC,WACxCrD,OAUC;EAED,MAAMsD,QAAQ,GAAGC,YAAY,CAC3BvD,OAAO,CAACwD,mBAAmB,EAC3BxD,OAAO,CAACyD,aAAa,CACtB;EACD,MAAMC,aAAa,GAAG1D,OAAO,CAAC2D,oBAAoB,GAChDvE,SAAS,CAACwE,iBAAiB,CACzB5D,OAAO,CAAC2D,oBAAoB,EAC5B3D,OAAO,CAACyD,aAAa,CACtB,CAACI,KAAK,GACPpD,SAAS;EAEX,MAAML,IAAI,GAAG,OAAOJ,OAAO,CAACE,OAAO;EAEnC,MAAM4D,cAAc;IACTC,EAAE;IACXC,YAAYD,EAAkB;MAC5B,IAAI,CAACA,EAAE,GAAGA,EAAE;IACd;IAEQE,aAAaA,CAAIC,CAAmF;MAC1G,IAAI,IAAI,CAACH,EAAE,KAAKtD,SAAS,EAAE;QACzB,OAAOnC,MAAM,CAAC6F,QAAQ,CAAeC,MAAM,IAAI;UAC7CF,CAAC,CAAC,IAAI,CAACH,EAAG,EAAEK,MAAM,CAAC;UACnB,OAAOC,UAAU,CAACjE,IAAI,EAAE,IAAI,CAAC2D,EAAG,CAAC;QACnC,CAAC,CAAC;MACJ;MACA,OAAOzF,MAAM,CAAC6F,QAAQ,CAAeC,MAAM,IAAI;QAC7C,IAAIE,IAAI,GAAG,KAAK;QAChB,IAAIC,MAAM,GAAoC9D,SAAS;QACvD,IAAI+D,MAAM,GAA8B/D,SAAS;QACjD,SAASgE,OAAOA,CAAChC,KAAY;UAC3BiC,OAAO,CAACjC,KAAK,CAAC;UACd2B,MAAM,CAAC9F,MAAM,CAAC6E,IAAI,CAAC,IAAIhE,QAAQ,CAAC;YAAEsD,KAAK;YAAEC,OAAO,EAAE;UAAkB,CAAE,CAAC,CAAC,CAAC;QAC3E;QACA,SAASgC,OAAOA,CAACjC,KAAa;UAC5B,IAAI,CAAC6B,IAAI,EAAEE,MAAM,EAAEG,OAAO,CAAClC,KAAK,CAAC;UACjC6B,IAAI,GAAG,IAAI;UACXE,MAAM,EAAEI,GAAG,CAAC,OAAO,EAAEH,OAAO,CAAC;QAC/B;QACArE,IAAI,CAACyE,OAAO,CAAC,CAACpC,KAAK,EAAEqC,OAAO,KAAI;UAC9B,IAAIrC,KAAK,EAAE;YACT,OAAO2B,MAAM,CAAC9F,MAAM,CAAC6E,IAAI,CAAC,IAAIhE,QAAQ,CAAC;cAAEsD,KAAK;cAAEC,OAAO,EAAE;YAA8B,CAAE,CAAC,CAAC,CAAC;UAC9F,CAAC,MAAM,IAAI,CAACoC,OAAO,EAAE;YACnB,OAAOV,MAAM,CACX9F,MAAM,CAAC6E,IAAI,CACT,IAAIhE,QAAQ,CAAC;cAAEuD,OAAO,EAAE,8BAA8B;cAAED,KAAK,EAAE,IAAIW,KAAK,CAAC,oBAAoB;YAAC,CAAE,CAAC,CAClG,CACF;UACH,CAAC,MAAM,IAAIkB,IAAI,EAAE;YACfQ,OAAO,CAACH,OAAO,EAAE;YACjB;UACF;UACAH,MAAM,GAAGM,OAAO;UAChBN,MAAM,CAACO,IAAI,CAAC,OAAO,EAAEN,OAAO,CAAC;UAC7BF,MAAM,GAAGF,UAAU,CAACjE,IAAI,EAAEoE,MAAM,CAAC;UACjCN,CAAC,CAACM,MAAM,EAAGQ,GAAG,IAAI;YAChBN,OAAO,EAAE;YACTN,MAAM,CAACY,GAAG,CAAC;UACb,CAAC,CAAC;QACJ,CAAC,CAAC;QACF,OAAO1G,MAAM,CAAC2G,OAAO,CAAC,MAAK;UACzB,IAAI,CAACV,MAAM,EAAE;YACXG,OAAO,EAAE;YACT,OAAOpG,MAAM,CAAC4G,IAAI;UACpB;UACA,OAAO5G,MAAM,CAAC6G,QAAQ,CAACZ,MAAM,EAAEjG,MAAM,CAAC8G,IAAI,CAACV,OAAO,CAAC,CAAC;QACtD,CAAC,CAAC;MACJ,CAAC,CAAC;IACJ;IAEQW,GAAGA,CAAC9C,KAAa,EAAE+C,MAA8B;MACvD,OAAO,IAAI,CAACrB,aAAa,CAAqB,CAACO,MAAM,EAAEJ,MAAM,KAAI;QAC/DI,MAAM,CAACjC,KAAK,CAACA,KAAK,EAAE+C,MAAa,EAAE,CAACC,GAAG,EAAEC,MAAM,KAAI;UACjD,IAAID,GAAG,EAAE;YACPnB,MAAM,CAAC9F,MAAM,CAAC6E,IAAI,CAAC,IAAIhE,QAAQ,CAAC;cAAEsD,KAAK,EAAE8C,GAAG;cAAE7C,OAAO,EAAE;YAA6B,CAAE,CAAC,CAAC,CAAC;UAC3F,CAAC,MAAM;YACL;YACA0B,MAAM,CAAC9F,MAAM,CAACmH,OAAO,CACnBC,KAAK,CAACC,OAAO,CAACH,MAAM,CAAC,GACjBA,MAAM,CAACI,GAAG,CAAEC,CAAC,IAAKA,CAAC,CAACC,IAAI,IAAI,EAAE,CAAC,GAC/BN,MAAM,CAACM,IAAI,IAAI,EAAE,CACtB,CAAC;UACJ;QACF,CAAC,CAAC;MACJ,CAAC,CAAC;IACJ;IAEAC,OAAOA,CACLC,GAAW,EACXV,MAA8B,EAC9B5B,aAA0F;MAE1F,OAAOA,aAAa,GAChBpF,MAAM,CAACsH,GAAG,CAAC,IAAI,CAACP,GAAG,CAACW,GAAG,EAAEV,MAAM,CAAC,EAAE5B,aAAa,CAAC,GAChD,IAAI,CAAC2B,GAAG,CAACW,GAAG,EAAEV,MAAM,CAAC;IAC3B;IACAW,UAAUA,CAACD,GAAW,EAAEV,MAA8B;MACpD,OAAO,IAAI,CAACrB,aAAa,CAAY,CAACO,MAAM,EAAEJ,MAAM,KAAI;QACtDI,MAAM,CAACjC,KAAK,CAACyD,GAAG,EAAEV,MAAa,EAAE,CAACC,GAAG,EAAEC,MAAM,KAAI;UAC/C,IAAID,GAAG,EAAE;YACPnB,MAAM,CAAC9F,MAAM,CAAC6E,IAAI,CAAC,IAAIhE,QAAQ,CAAC;cAAEsD,KAAK,EAAE8C,GAAG;cAAE7C,OAAO,EAAE;YAA6B,CAAE,CAAC,CAAC,CAAC;UAC3F,CAAC,MAAM;YACL0B,MAAM,CAAC9F,MAAM,CAACmH,OAAO,CAACD,MAAM,CAAC,CAAC;UAChC;QACF,CAAC,CAAC;MACJ,CAAC,CAAC;IACJ;IACAU,uBAAuBA,CAACF,GAAW,EAAEV,MAA8B;MACjE,OAAO,IAAI,CAACD,GAAG,CAACW,GAAG,EAAEV,MAAM,CAAC;IAC9B;IACAa,aAAaA,CAACH,GAAW,EAAEV,MAA8B;MACvD,OAAO,IAAI,CAACrB,aAAa,CAAqB,CAACO,MAAM,EAAEJ,MAAM,KAAI;QAC/DI,MAAM,CAACjC,KAAK,CACV;UACE6D,IAAI,EAAEJ,GAAG;UACTK,OAAO,EAAE,OAAO;UAChBC,MAAM,EAAEhB;SACT,EACD,CAACC,GAAG,EAAEC,MAAM,KAAI;UACd,IAAID,GAAG,EAAE;YACPnB,MAAM,CAAC9F,MAAM,CAAC6E,IAAI,CAAC,IAAIhE,QAAQ,CAAC;cAAEsD,KAAK,EAAE8C,GAAG;cAAE7C,OAAO,EAAE;YAA6B,CAAE,CAAC,CAAC,CAAC;UAC3F,CAAC,MAAM;YACL0B,MAAM,CAAC9F,MAAM,CAACmH,OAAO,CAACD,MAAM,CAACM,IAAI,CAAC,CAAC;UACrC;QACF,CAAC,CACF;MACH,CAAC,CAAC;IACJ;IACAS,iBAAiBA,CACfP,GAAW,EACXV,MAA8B,EAC9B5B,aAA0F;MAE1F,OAAO,IAAI,CAACqC,OAAO,CAACC,GAAG,EAAEV,MAAM,EAAE5B,aAAa,CAAC;IACjD;IACA8C,aAAaA,CACXR,GAAW,EACXV,MAA8B,EAC9B5B,aAA0F;MAE1F;MACA,MAAM+C,IAAI,GAAG,IAAI;MACjB,OAAOzH,MAAM,CAAC0H,WAAW,CAACvI,OAAO,CAACwI,aAAa,CAACrI,MAAM,CAAC+E,UAAU,CAAC,WAAUuD,CAAC,EAAEC,KAAK;QAClF,MAAMrC,MAAM,GAAGiC,IAAI,CAAC1C,EAAE,KAAK,OAAOjF,KAAK,CAACgI,OAAO,CAACC,UAAU,EAAEF,KAAK,CAAC,CAAC;QACnE,OAAO/H,KAAK,CAACkI,YAAY,CAACH,KAAK,EAAEvI,MAAM,CAACqE,OAAO,CAAC,MAAMsE,MAAM,CAACC,KAAK,EAAE,CAAC,CAAC;QACtE,MAAMD,MAAM,GAAGzC,MAAM,CAACjC,KAAK,CAAC,IAAIhD,MAAM,CAACyG,GAAG,EAAEV,MAAa,CAAC,CAAC;QAC3D;QACA,OAAOhH,MAAM,CAAC6F,QAAQ,CAAyDC,MAAM,IAAI;UACvF6C,MAAM,CAACE,IAAI,CAAC,GAAG,EAAE,CAAC5B,GAAG,EAAEO,IAAI,KAAI;YAC7B,IAAIP,GAAG,EAAE;cACPnB,MAAM,CAAC9F,MAAM,CAAC6E,IAAI,CAAC,IAAIhE,QAAQ,CAAC;gBAAEsD,KAAK,EAAE8C,GAAG;gBAAE7C,OAAO,EAAE;cAA6B,CAAE,CAAC,CAAC,CAAC;YAC3F,CAAC,MAAM,IAAIzE,GAAG,CAACmJ,eAAe,CAACtB,IAAI,CAAC,EAAE;cACpC1B,MAAM,CAAC9F,MAAM,CAACmH,OAAO,CAAC/B,aAAa,GAAGA,aAAa,CAACoC,IAAI,CAAQ,GAAGA,IAAI,CAAC,CAAC;YAC3E,CAAC,MAAM;cACL1B,MAAM,CAAClG,KAAK,CAACoG,IAAI,EAAE,CAAC;YACtB;UACF,CAAC,CAAC;QACJ,CAAC,CAAC;MACJ,CAAC,CAAC,CAAC,CAAC;IACN;;EAGF,MAAMyC,UAAU,GAAGzI,MAAM,CAAC6F,QAAQ,CAAwCC,MAAM,IAAI;IAClF,MAAMiD,KAAK,GAAG9I,KAAK,CAAC+I,UAAU,EAAG;IACjC,MAAMT,KAAK,GAAG9H,UAAU,CAACwI,SAAS,CAACF,KAAK,CAACG,QAAQ,EAAE1I,KAAK,CAACA,KAAK,CAAC;IAC/D,IAAI2D,KAAK,GAAsBhC,SAAS;IACxCL,IAAI,CAACyE,OAAO,CAAC,CAACU,GAAG,EAAEf,MAAM,EAAEG,OAAO,KAAI;MACpC,IAAIY,GAAG,EAAE;QACPnB,MAAM,CAAC9F,MAAM,CAAC6E,IAAI,CAAC,IAAIhE,QAAQ,CAAC;UAAEsD,KAAK,EAAE8C,GAAG;UAAE7C,OAAO,EAAE;QAA8C,CAAE,CAAC,CAAC,CAAC;MAC5G,CAAC,MAAM;QACL0B,MAAM,CAAC9F,MAAM,CAACmJ,EAAE,CACd3I,KAAK,CAACkI,YAAY,CAChBH,KAAK,EACLvI,MAAM,CAAC8G,IAAI,CAAC,MAAK;UACfZ,MAAO,CAACI,GAAG,CAAC,OAAO,EAAEH,OAAO,CAAC;UAC7BE,OAAO,CAAClC,KAAK,CAAC;QAChB,CAAC,CAAC,CACH,EACD+B,MAAO,CACR,CAAC;MACJ;MACA,SAASC,OAAOA,CAACiD,MAAa;QAC5BjF,KAAK,GAAGiF,MAAM;MAChB;MACAlD,MAAO,CAACtC,EAAE,CAAC,OAAO,EAAEuC,OAAO,CAAC;IAC9B,CAAC,CAAC;EACJ,CAAC,CAAC;EACF,MAAMkD,OAAO,GAAGrJ,MAAM,CAACsH,GAAG,CAACmB,UAAU,EAAGvC,MAAM,IAAK,IAAIV,cAAc,CAACU,MAAM,CAAC,CAAC;EAE9E,MAAMoD,YAAY,GAAG,OAAOhJ,KAAK,CAACmB,IAAI,CAAC;IACrCG,OAAO,EAAE6G;GACV,CAAC;EAEF,IAAIc,MAAM,GAAmB;IAC3BtH,GAAG,EAAEH,IAAI,CAACJ,OAAO,CAACM,gBAAgB,GAAGzB,QAAQ,CAACkB,IAAI,CAACK,IAAI,CAACJ,OAAO,CAACM,gBAAgB,CAAC,GAAGG,SAAS;IAC7FG,IAAI,EAAER,IAAI,CAACJ,OAAO,CAACY,IAAI;IACvBI,IAAI,EAAEZ,IAAI,CAACJ,OAAO,CAACgB,IAAI;IACvBH,QAAQ,EAAET,IAAI,CAACJ,OAAO,CAACa,QAAQ;IAC/BF,QAAQ,EAAEP,IAAI,CAACJ,OAAO,CAACU,IAAI;IAC3BI,QAAQ,EAAE,OAAOV,IAAI,CAACJ,OAAO,CAACc,QAAQ,KAAK,QAAQ,GAAGjC,QAAQ,CAACkB,IAAI,CAACK,IAAI,CAACJ,OAAO,CAACc,QAAQ,CAAC,GAAGL,SAAS;IACtGM,GAAG,EAAEX,IAAI,CAACJ,OAAO,CAACe,GAAG;IACrBiB,eAAe,EAAE5B,IAAI,CAACJ,OAAO,CAAC+B,gBAAgB;IAC9CE,KAAK,EAAE7B,IAAI,CAACJ,OAAO,CAACiC;GACrB;EACD,IAAI7B,IAAI,CAACJ,OAAO,CAACM,gBAAgB,EAAE;IACjC;IACA,IAAI;MACF,MAAMwH,MAAM,GAAGxI,YAAY,CAACyI,KAAK,CAAC3H,IAAI,CAACJ,OAAO,CAACM,gBAAgB,CAAC;MAChEuH,MAAM,GAAG;QACP,GAAGA,MAAM;QACTjH,IAAI,EAAEiH,MAAM,CAACjH,IAAI,IAAIkH,MAAM,CAAClH,IAAI,IAAIH,SAAS;QAC7CO,IAAI,EAAE6G,MAAM,CAAC7G,IAAI,KAAK8G,MAAM,CAAC9G,IAAI,GAAGtC,MAAM,CAACsJ,cAAc,CAACvJ,MAAM,CAACsJ,KAAK,CAACD,MAAM,CAAC9G,IAAI,CAAC,CAAC,GAAGP,SAAS,CAAC;QACjGE,QAAQ,EAAEkH,MAAM,CAAClH,QAAQ,IAAImH,MAAM,CAACpH,IAAI,IAAID,SAAS;QACrDK,QAAQ,EAAE+G,MAAM,CAAC/G,QAAQ,KAAKgH,MAAM,CAAChH,QAAQ,GAAGjC,QAAQ,CAACkB,IAAI,CAAC+H,MAAM,CAAChH,QAAQ,CAAC,GAAGL,SAAS,CAAC;QAC3FI,QAAQ,EAAEgH,MAAM,CAAChH,QAAQ,IAAIiH,MAAM,CAACjH,QAAQ,IAAIJ;OACjD;IACH,CAAC,CAAC,MAAM;MACN;IAAA;EAEJ;EAEA,OAAOwH,MAAM,CAACC,MAAM,CAClB,OAAOhJ,MAAM,CAACa,IAAI,CAAC;IACjBoI,QAAQ,EAAE7J,MAAM,CAACmH,OAAO,CAAC,IAAI3B,cAAc,EAAE,CAAC;IAC9CsE,mBAAmB,EAAET,OAAO;IAC5BrE,QAAQ;IACR+E,cAAc,EAAE,CACd,IAAIrI,OAAO,CAACqI,cAAc,GAAGJ,MAAM,CAACK,OAAO,CAACtI,OAAO,CAACqI,cAAc,CAAC,GAAG,EAAE,CAAC,EACzE,CAAC7I,mBAAmB,EAAE,YAAY,CAAC,EACnC,CAACC,iBAAiB,EAAEoI,MAAM,CAAChH,QAAQ,IAAIgH,MAAM,CAAClH,QAAQ,IAAI,UAAU,CAAC,EACrE,CAACjB,mBAAmB,EAAEmI,MAAM,CAACjH,IAAI,IAAI,WAAW,CAAC,EACjD,CAACjB,gBAAgB,EAAEkI,MAAM,CAAC7G,IAAI,IAAI,IAAI,CAAC,CACxC;IACD0C;GACD,CAAC,EACF;IACE,CAAC9D,MAAM,GAAGA,MAAgB;IAC1BiI,MAAM;IACNU,IAAI,EAAG3B,CAAU,IAAKxH,SAAS,CAACoJ,QAAQ,CAAC,CAACC,MAAM,CAAC7B,CAAC,CAAC,CAAC,CAAC;IACrD8B,MAAM,EAAGC,OAAe,IACtB3J,MAAM,CAACmF,QAAQ,CAAmB7F,MAAM,CAAC+E,UAAU,CAAC,WAAUuF,KAAK;MACjE,MAAMpE,MAAM,GAAG,OAAO5F,KAAK,CAACiK,GAAG,CAACjB,YAAY,CAAC;MAC7C,SAASkB,cAAcA,CAACC,GAAoB;QAC1C,IAAIA,GAAG,CAACJ,OAAO,KAAKA,OAAO,IAAII,GAAG,CAACC,OAAO,EAAE;UAC1CrK,KAAK,CAACsK,WAAW,CAACL,KAAK,EAAEG,GAAG,CAACC,OAAO,CAAC;QACvC;MACF;MACA,OAAO1K,MAAM,CAAC0I,YAAY,CAAC,MACzB1I,MAAM,CAACqE,OAAO,CAAC,MAAK;QAClB6B,MAAM,CAACI,GAAG,CAAC,cAAc,EAAEkE,cAAc,CAAC;QAC1C,OAAOtE,MAAM,CAACjC,KAAK,CAAC,YAAYlD,EAAE,CAAC6J,gBAAgB,CAACP,OAAO,CAAC,EAAE,CAAC;MACjE,CAAC,CAAC,CACH;MACD,OAAOrK,MAAM,CAAC+D,UAAU,CAAC;QACvBC,GAAG,EAAEA,CAAA,KAAMkC,MAAM,CAACjC,KAAK,CAAC,UAAUlD,EAAE,CAAC6J,gBAAgB,CAACP,OAAO,CAAC,EAAE,CAAC;QACjEnG,KAAK,EAAGC,KAAK,IAAK,IAAItD,QAAQ,CAAC;UAAEsD,KAAK;UAAEC,OAAO,EAAE;QAAkB,CAAE;OACtE,CAAC;MACF8B,MAAM,CAACtC,EAAE,CAAC,cAAc,EAAE4G,cAAc,CAAC;IAC3C,CAAC,CAAC,CAAC;IACLK,MAAM,EAAEA,CAACR,OAAe,EAAEK,OAAe,KACvC1K,MAAM,CAAC6F,QAAQ,CAAkBC,MAAM,IAAI;MACzChE,IAAI,CAACmC,KAAK,CAAC,UAAUlD,EAAE,CAAC6J,gBAAgB,CAACP,OAAO,CAAC,MAAM,EAAE,CAACK,OAAO,CAAC,EAAGzD,GAAG,IAAI;QAC1E,IAAIA,GAAG,EAAE;UACPnB,MAAM,CAAC9F,MAAM,CAAC6E,IAAI,CAAC,IAAIhE,QAAQ,CAAC;YAAEsD,KAAK,EAAE8C,GAAG;YAAE7C,OAAO,EAAE;UAAkB,CAAE,CAAC,CAAC,CAAC;QAChF,CAAC,MAAM;UACL0B,MAAM,CAAC9F,MAAM,CAAC4G,IAAI,CAAC;QACrB;MACF,CAAC,CAAC;IACJ,CAAC;GACJ,CACF;AACH,CAAC,CAAC;AAEF,MAAMkE,aAAa,gBAAG,IAAIC,OAAO,EAAkD;AACnF,MAAMhF,UAAU,GAAGA,CAACjE,IAAa,EAAEoE,MAAqB,KAAI;EAC1D,IAAI4E,aAAa,CAACE,GAAG,CAAC9E,MAAM,CAAC,EAAE;IAC7B,OAAO4E,aAAa,CAACP,GAAG,CAACrE,MAAM,CAAE;EACnC;EACA,MAAM+E,SAAS,GAAI/E,MAAc,CAACgF,SAAS;EAC3C,MAAMxE,GAAG,GAAGuE,SAAS,KAAK9I;EACxB;EAAA,EACEnC,MAAM,CAAC6F,QAAQ,CAAQC,MAAM,IAAI;IACjC,IAAIhE,IAAI,CAACqJ,MAAM,EAAE,OAAOrF,MAAM,CAAC9F,MAAM,CAAC4G,IAAI,CAAC;IAC3C9E,IAAI,CAACmC,KAAK,CAAC,4BAA4BgH,SAAS,GAAG,EAAE,MAAK;MACxDnF,MAAM,CAAC9F,MAAM,CAAC4G,IAAI,CAAC;IACrB,CAAC,CAAC;EACJ,CAAC,CAAC,CAACrC,IAAI,CACLvE,MAAM,CAACoL,aAAa,EACpBpL,MAAM,CAACwE,aAAa,CAAC,IAAI,CAAC,CAC3B,GACCrC,SAAS;EACb2I,aAAa,CAACO,GAAG,CAACnF,MAAM,EAAEQ,GAAG,CAAC;EAC9B,OAAOA,GAAG;AACZ,CAAC;AAED;;;;AAIA,OAAO,MAAM4E,WAAW,GAGtB/B,MAAmC,IAEnCrJ,KAAK,CAACqL,cAAc,CAClBzL,MAAM,CAAC0L,MAAM,CAACjC,MAAM,CAAC,CAACkC,QAAQ,EAAE,CAAClH,IAAI,CACnCvE,MAAM,CAAC0L,OAAO,CAACjK,IAAI,CAAC,EACpBzB,MAAM,CAACsH,GAAG,CAAEpB,MAAM,IAChBzF,UAAU,CAACgB,IAAI,CAACF,QAAQ,EAAE2E,MAAM,CAAC,CAAC3B,IAAI,CACpC9D,UAAU,CAACkL,GAAG,CAAC/K,MAAM,CAACgL,SAAS,EAAE1F,MAAM,CAAC,CACzC,CACF,CACF,CACF,CAAC3B,IAAI,CAACrE,KAAK,CAACsI,OAAO,CAAC7H,UAAU,CAACkL,KAAK,CAAC,CAAC;AAEzC;;;;AAIA,OAAO,MAAMA,KAAK,GAChBtC,MAAsB,IAEtBrJ,KAAK,CAACqL,cAAc,CAClBvL,MAAM,CAACsH,GAAG,CAAC7F,IAAI,CAAC8H,MAAM,CAAC,EAAGrD,MAAM,IAC9BzF,UAAU,CAACgB,IAAI,CAACF,QAAQ,EAAE2E,MAAM,CAAC,CAAC3B,IAAI,CACpC9D,UAAU,CAACkL,GAAG,CAAC/K,MAAM,CAACgL,SAAS,EAAE1F,MAAM,CAAC,CACzC,CAAC,CACL,CAAC3B,IAAI,CAACrE,KAAK,CAACsI,OAAO,CAAC7H,UAAU,CAACkL,KAAK,CAAC,CAAC;AAEzC;;;;AAIA,OAAO,MAAMC,aAAa,GAAIpK,OAU7B,IACCxB,KAAK,CAACqL,cAAc,CAClBvL,MAAM,CAACsH,GAAG,CAAC3F,QAAQ,CAACD,OAAO,CAAC,EAAGwE,MAAM,IACnCzF,UAAU,CAACgB,IAAI,CAACF,QAAQ,EAAE2E,MAAM,CAAC,CAAC3B,IAAI,CACpC9D,UAAU,CAACkL,GAAG,CAAC/K,MAAM,CAACgL,SAAS,EAAE1F,MAAM,CAAC,CACzC,CAAC,CACL,CAAC3B,IAAI,CAACrE,KAAK,CAACsI,OAAO,CAAC7H,UAAU,CAACkL,KAAK,CAAC,CAAC;AAEzC;;;;AAIA,OAAO,MAAM5G,YAAY,GAAGA,CAC1B8G,SAAiC,EACjC5G,aAAa,GAAG,IAAI,KACE;EACtB,MAAM6G,cAAc,GAAG7G,aAAa,IAAI4G,SAAS,GAC7CjL,SAAS,CAACwE,iBAAiB,CAACyG,SAAS,CAAC,CAAC7J,KAAK,GAC5CC,SAAS;EAEb,OAAOrB,SAAS,CAACmE,YAAY,CAAW;IACtCgH,OAAO,EAAE,IAAI;IACbC,WAAWA,CAAC5D,CAAC;MACX,OAAO,IAAIA,CAAC,EAAE;IAChB,CAAC;IACD6D,YAAY,EAAEJ,SAAS,GACrB,UAAS7J,KAAK,EAAEkK,gBAAgB;MAC9B,OAAOA,gBAAgB,GAAGC,MAAM,CAACnK,KAAK,CAAC,GAAGmK,MAAM,CAACN,SAAS,CAAC7J,KAAK,CAAC,CAAC;IACpE,CAAC,GACDmK,MAAM;IACRC,cAAcA,CAACC,YAAY,EAAEC,UAAU,EAAEC,YAAY,EAAEzE,MAAM,EAAE0E,SAAS;MACtE,OAAO,CACL,WAAWH,YAAY,QAAQC,UAAU,GAAGC,YAAY,GAAGC,SAAS,GAAG,cAAcA,SAAS,CAAC,CAAC,CAAC,EAAE,GAAG,EAAE,EAAE,EAC1GA,SAAS,GACP1E,MAAM,CAAC2E,IAAI,EAAE,CAACC,MAAM,CAACF,SAAS,CAAC,CAAC,CAAC,CAAC,GAClC1E,MAAM,CAAC2E,IAAI,EAAE,CAChB;IACH,CAAC;IACDE,QAAQA,CAACC,IAAI,EAAEZ,WAAW,EAAEE,gBAAgB;MAC1C,QAAQU,IAAI,CAACC,IAAI;QACf,KAAK,QAAQ;UAAE;YACb,OAAO,CACLb,WAAW,CAAC/J,SAAS,CAAC,EACtB,CACEiK,gBAAgB,IAAIJ,cAAc,KAAK7J,SAAS,GAC5C2K,IAAI,CAACE,MAAM,GACXhB,cAAc,CAACc,IAAI,CAACE,MAAM,CAAC,CAChC,CACF;UACH;MACF;IACF;GACD,CAAC;AACJ,CAAC;AAED,MAAMX,MAAM,gBAAGvL,SAAS,CAACmM,aAAa,CAAC,IAAI,CAAC;AAa5C;;;;AAIA,MAAM9C,MAAM,gBAAGrJ,SAAS,CAACoM,MAAM,CAAS,QAAQ,CAAC","ignoreList":[]} | ||
| {"version":3,"file":"PgClient.js","names":["Arr","Cause","Channel","Config","Duration","Effect","Fiber","Layer","Number","Option","Queue","RcRef","Redacted","Scope","ServiceMap","Stream","Reactivity","Client","AuthenticationError","AuthorizationError","ConnectionError","ConstraintError","DeadlockError","LockTimeoutError","SerializationError","SqlError","SqlSyntaxError","StatementTimeoutError","UnknownError","Statement","Pg","PgConnString","Cursor","ATTR_DB_SYSTEM_NAME","ATTR_DB_NAMESPACE","ATTR_SERVER_ADDRESS","ATTR_SERVER_PORT","pgCodeFromCause","cause","undefined","code","classifyError","message","operation","props","startsWith","TypeId","PgClient","Service","make","options","fromPool","acquire","gen","pool","Pool","connectionString","url","value","user","username","host","database","password","ssl","port","stream","connectionTimeoutMillis","connectTimeout","toMillis","fromInputUnsafe","idleTimeoutMillis","idleTimeout","max","maxConnections","min","minConnections","maxLifetimeSeconds","connectionTTL","toSeconds","application_name","applicationName","types","on","_err","acquireRelease","tryPromise","try","query","catch","reason","promise","end","pipe","timeoutOption","timeoutOrElse","duration","seconds","onTimeout","fail","Error","fnUntraced","compiler","makeCompiler","transformQueryNames","transformJson","transformRows","transformResultNames","defaultTransforms","array","ConnectionImpl","pg","constructor","runWithClient","f","callback","resume","makeCancel","done","cancel","client","onError","cleanup","release","off","connect","client_","once","eff","suspend","void","ensuring","sync","run","params","err","result","succeed","Array","isArray","map","r","rows","execute","sql","executeRaw","executeWithoutTransform","executeValues","text","rowMode","values","executeUnprepared","executeStream","self","fromChannel","fromTransform","_","scope","provide","reserveRaw","addFinalizer","cursor","close","read","isArrayNonEmpty","fiber","getCurrent","getUnsafe","services","as","cause_","reserve","onListenClientError","listenClient","config","parsed","parse","getOrUndefined","Object","assign","acquirer","transactionAcquirer","spanAttributes","entries","json","fragment","PgJson","listen","channel","queue","get","onNotification","msg","payload","offerUnsafe","escapeIdentifier","notify","cancelEffects","WeakMap","has","processId","processID","ending","interruptible","set","layerConfig","effectServices","unwrap","asEffect","flatMap","add","SqlClient","layer","layerFromPool","transform","transformValue","dialect","placeholder","onIdentifier","withoutTransform","escape","onRecordUpdate","placeholders","valueAlias","valueColumns","returning","flat","concat","onCustom","type","kind","paramA","defaultEscape","custom"],"sources":["../src/PgClient.ts"],"sourcesContent":[null],"mappings":"AAAA;;;AAGA,OAAO,KAAKA,GAAG,MAAM,cAAc;AACnC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,OAAO,MAAM,gBAAgB;AACzC,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,QAAQ,MAAM,iBAAiB;AAC3C,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,QAAQ,MAAM,iBAAiB;AAC3C,OAAO,KAAKC,KAAK,MAAM,cAAc;AACrC,OAAO,KAAKC,UAAU,MAAM,mBAAmB;AAC/C,OAAO,KAAKC,MAAM,MAAM,eAAe;AACvC,OAAO,KAAKC,UAAU,MAAM,uCAAuC;AACnE,OAAO,KAAKC,MAAM,MAAM,+BAA+B;AAEvD,SACEC,mBAAmB,EACnBC,kBAAkB,EAClBC,eAAe,EACfC,eAAe,EACfC,aAAa,EACbC,gBAAgB,EAChBC,kBAAkB,EAClBC,QAAQ,EACRC,cAAc,EACdC,qBAAqB,EACrBC,YAAY,QACP,8BAA8B;AAErC,OAAO,KAAKC,SAAS,MAAM,+BAA+B;AAG1D,OAAO,KAAKC,EAAE,MAAM,IAAI;AACxB,OAAO,KAAKC,YAAY,MAAM,sBAAsB;AACpD,OAAOC,MAAM,MAAM,WAAW;AAE9B,MAAMC,mBAAmB,GAAG,gBAAgB;AAC5C,MAAMC,iBAAiB,GAAG,cAAc;AACxC,MAAMC,mBAAmB,GAAG,gBAAgB;AAC5C,MAAMC,gBAAgB,GAAG,aAAa;AAEtC,MAAMC,eAAe,GAAIC,KAAc,IAAwB;EAC7D,IAAI,OAAOA,KAAK,KAAK,QAAQ,IAAIA,KAAK,KAAK,IAAI,IAAI,EAAE,MAAM,IAAIA,KAAK,CAAC,EAAE;IACrE,OAAOC,SAAS;EAClB;EACA,MAAMC,IAAI,GAAGF,KAAK,CAACE,IAAI;EACvB,OAAO,OAAOA,IAAI,KAAK,QAAQ,GAAGA,IAAI,GAAGD,SAAS;AACpD,CAAC;AAED,MAAME,aAAa,GAAGA,CACpBH,KAAc,EACdI,OAAe,EACfC,SAAiB,KACf;EACF,MAAMC,KAAK,GAAG;IAAEN,KAAK;IAAEI,OAAO;IAAEC;EAAS,CAAE;EAC3C,MAAMH,IAAI,GAAGH,eAAe,CAACC,KAAK,CAAC;EACnC,IAAIE,IAAI,KAAKD,SAAS,EAAE;IACtB,IAAIC,IAAI,CAACK,UAAU,CAAC,IAAI,CAAC,EAAE;MACzB,OAAO,IAAIzB,eAAe,CAACwB,KAAK,CAAC;IACnC;IACA,IAAIJ,IAAI,CAACK,UAAU,CAAC,IAAI,CAAC,EAAE;MACzB,OAAO,IAAI3B,mBAAmB,CAAC0B,KAAK,CAAC;IACvC;IACA,IAAIJ,IAAI,KAAK,OAAO,EAAE;MACpB,OAAO,IAAIrB,kBAAkB,CAACyB,KAAK,CAAC;IACtC;IACA,IAAIJ,IAAI,CAACK,UAAU,CAAC,IAAI,CAAC,EAAE;MACzB,OAAO,IAAInB,cAAc,CAACkB,KAAK,CAAC;IAClC;IACA,IAAIJ,IAAI,CAACK,UAAU,CAAC,IAAI,CAAC,EAAE;MACzB,OAAO,IAAIxB,eAAe,CAACuB,KAAK,CAAC;IACnC;IACA,IAAIJ,IAAI,KAAK,OAAO,EAAE;MACpB,OAAO,IAAIlB,aAAa,CAACsB,KAAK,CAAC;IACjC;IACA,IAAIJ,IAAI,KAAK,OAAO,EAAE;MACpB,OAAO,IAAIhB,kBAAkB,CAACoB,KAAK,CAAC;IACtC;IACA,IAAIJ,IAAI,KAAK,OAAO,EAAE;MACpB,OAAO,IAAIjB,gBAAgB,CAACqB,KAAK,CAAC;IACpC;IACA,IAAIJ,IAAI,KAAK,OAAO,EAAE;MACpB,OAAO,IAAIb,qBAAqB,CAACiB,KAAK,CAAC;IACzC;EACF;EACA,OAAO,IAAIhB,YAAY,CAACgB,KAAK,CAAC;AAChC,CAAC;AAED;;;;AAIA,OAAO,MAAME,MAAM,GAAW,0BAA0B;AAoBxD;;;;AAIA,OAAO,MAAMC,QAAQ,gBAAGjC,UAAU,CAACkC,OAAO,CAAW,yBAAyB,CAAC;AAmC/E;;;;AAIA,OAAO,MAAMC,IAAI,GACfC,OAAuB,IAEvBC,QAAQ,CAAC;EACP,GAAGD,OAAO;EACVE,OAAO,EAAE/C,MAAM,CAACgD,GAAG,CAAC,aAAS;IAC3B,MAAMC,IAAI,GAAG,IAAIxB,EAAE,CAACyB,IAAI,CAAC;MACvBC,gBAAgB,EAAEN,OAAO,CAACO,GAAG,GAAG7C,QAAQ,CAAC8C,KAAK,CAACR,OAAO,CAACO,GAAG,CAAC,GAAGlB,SAAS;MACvEoB,IAAI,EAAET,OAAO,CAACU,QAAQ;MACtBC,IAAI,EAAEX,OAAO,CAACW,IAAI;MAClBC,QAAQ,EAAEZ,OAAO,CAACY,QAAQ;MAC1BC,QAAQ,EAAEb,OAAO,CAACa,QAAQ,GAAGnD,QAAQ,CAAC8C,KAAK,CAACR,OAAO,CAACa,QAAQ,CAAC,GAAGxB,SAAS;MACzEyB,GAAG,EAAEd,OAAO,CAACc,GAAG;MAChBC,IAAI,EAAEf,OAAO,CAACe,IAAI;MAClB,IAAIf,OAAO,CAACgB,MAAM,GAAG;QAAEA,MAAM,EAAEhB,OAAO,CAACgB;MAAM,CAAE,GAAG,EAAE,CAAC;MACrDC,uBAAuB,EAAEjB,OAAO,CAACkB,cAAc,GAC3ChE,QAAQ,CAACiE,QAAQ,CAACjE,QAAQ,CAACkE,eAAe,CAACpB,OAAO,CAACkB,cAAc,CAAC,CAAC,GACnE7B,SAAS;MACbgC,iBAAiB,EAAErB,OAAO,CAACsB,WAAW,GAClCpE,QAAQ,CAACiE,QAAQ,CAACjE,QAAQ,CAACkE,eAAe,CAACpB,OAAO,CAACsB,WAAW,CAAC,CAAC,GAChEjC,SAAS;MACbkC,GAAG,EAAEvB,OAAO,CAACwB,cAAc;MAC3BC,GAAG,EAAEzB,OAAO,CAAC0B,cAAc;MAC3BC,kBAAkB,EAAE3B,OAAO,CAAC4B,aAAa,GACrC1E,QAAQ,CAAC2E,SAAS,CAAC3E,QAAQ,CAACkE,eAAe,CAACpB,OAAO,CAAC4B,aAAa,CAAC,CAAC,GACnEvC,SAAS;MACbyC,gBAAgB,EAAE9B,OAAO,CAAC+B,eAAe,IAAI,gBAAgB;MAC7DC,KAAK,EAAEhC,OAAO,CAACgC;KAChB,CAAC;IAEF5B,IAAI,CAAC6B,EAAE,CAAC,OAAO,EAAGC,IAAI,IAAI,CAAE,CAAC,CAAC;IAE9B,OAAO/E,MAAM,CAACgF,cAAc,CAC1BhF,MAAM,CAACiF,UAAU,CAAC;MAChBC,GAAG,EAAEA,CAAA,KAAMjC,IAAI,CAACkC,KAAK,CAAC,UAAU,CAAC;MACjCC,KAAK,EAAGnD,KAAK,IAAK,IAAIb,QAAQ,CAAC;QAAEiE,MAAM,EAAEjD,aAAa,CAACH,KAAK,EAAE,6BAA6B,EAAE,SAAS;MAAC,CAAE;KAC1G,CAAC,EACF,MACEjC,MAAM,CAACsF,OAAO,CAAC,MAAMrC,IAAI,CAACsC,GAAG,EAAE,CAAC,CAACC,IAAI,CACnCxF,MAAM,CAACyF,aAAa,CAAC,IAAI,CAAC,CAC3B,CACJ,CAACD,IAAI,CACJxF,MAAM,CAAC0F,aAAa,CAAC;MACnBC,QAAQ,EAAE9C,OAAO,CAACkB,cAAc,IAAIhE,QAAQ,CAAC6F,OAAO,CAAC,CAAC,CAAC;MACvDC,SAAS,EAAEA,CAAA,KACT7F,MAAM,CAAC8F,IAAI,CACT,IAAI1E,QAAQ,CAAC;QACXiE,MAAM,EAAE,IAAItE,eAAe,CAAC;UAC1BkB,KAAK,EAAE,IAAI8D,KAAK,CAAC,sBAAsB,CAAC;UACxC1D,OAAO,EAAE,gCAAgC;UACzCC,SAAS,EAAE;SACZ;OACF,CAAC;KAEP,CAAC,CACH;IAED,OAAOW,IAAI;EACb,CAAC;CACF,CAAC;AAEJ;;;;AAIA,OAAO,MAAMH,QAAQ,gBAAG9C,MAAM,CAACgG,UAAU,CAAC,WACxCnD,OAUC;EAED,MAAMoD,QAAQ,GAAGC,YAAY,CAC3BrD,OAAO,CAACsD,mBAAmB,EAC3BtD,OAAO,CAACuD,aAAa,CACtB;EACD,MAAMC,aAAa,GAAGxD,OAAO,CAACyD,oBAAoB,GAChD9E,SAAS,CAAC+E,iBAAiB,CACzB1D,OAAO,CAACyD,oBAAoB,EAC5BzD,OAAO,CAACuD,aAAa,CACtB,CAACI,KAAK,GACPtE,SAAS;EAEX,MAAMe,IAAI,GAAG,OAAOJ,OAAO,CAACE,OAAO;EAEnC,MAAM0D,cAAc;IACTC,EAAE;IACXC,YAAYD,EAAkB;MAC5B,IAAI,CAACA,EAAE,GAAGA,EAAE;IACd;IAEQE,aAAaA,CAAIC,CAAmF;MAC1G,IAAI,IAAI,CAACH,EAAE,KAAKxE,SAAS,EAAE;QACzB,OAAOlC,MAAM,CAAC8G,QAAQ,CAAeC,MAAM,IAAI;UAC7CF,CAAC,CAAC,IAAI,CAACH,EAAG,EAAEK,MAAM,CAAC;UACnB,OAAOC,UAAU,CAAC/D,IAAI,EAAE,IAAI,CAACyD,EAAG,CAAC;QACnC,CAAC,CAAC;MACJ;MACA,OAAO1G,MAAM,CAAC8G,QAAQ,CAAeC,MAAM,IAAI;QAC7C,IAAIE,IAAI,GAAG,KAAK;QAChB,IAAIC,MAAM,GAAoChF,SAAS;QACvD,IAAIiF,MAAM,GAA8BjF,SAAS;QACjD,SAASkF,OAAOA,CAACnF,KAAY;UAC3BoF,OAAO,CAACpF,KAAK,CAAC;UACd8E,MAAM,CAAC/G,MAAM,CAAC8F,IAAI,CAAC,IAAI1E,QAAQ,CAAC;YAAEiE,MAAM,EAAEjD,aAAa,CAACH,KAAK,EAAE,kBAAkB,EAAE,mBAAmB;UAAC,CAAE,CAAC,CAAC,CAAC;QAC9G;QACA,SAASoF,OAAOA,CAACpF,KAAa;UAC5B,IAAI,CAACgF,IAAI,EAAEE,MAAM,EAAEG,OAAO,CAACrF,KAAK,CAAC;UACjCgF,IAAI,GAAG,IAAI;UACXE,MAAM,EAAEI,GAAG,CAAC,OAAO,EAAEH,OAAO,CAAC;QAC/B;QACAnE,IAAI,CAACuE,OAAO,CAAC,CAACvF,KAAK,EAAEwF,OAAO,KAAI;UAC9B,IAAIxF,KAAK,EAAE;YACT,OAAO8E,MAAM,CACX/G,MAAM,CAAC8F,IAAI,CACT,IAAI1E,QAAQ,CAAC;cACXiE,MAAM,EAAEjD,aAAa,CAACH,KAAK,EAAE,8BAA8B,EAAE,mBAAmB;aACjF,CAAC,CACH,CACF;UACH,CAAC,MAAM,IAAI,CAACwF,OAAO,EAAE;YACnB,OAAOV,MAAM,CACX/G,MAAM,CAAC8F,IAAI,CACT,IAAI1E,QAAQ,CAAC;cACXiE,MAAM,EAAE,IAAItE,eAAe,CAAC;gBAC1BsB,OAAO,EAAE,8BAA8B;gBACvCJ,KAAK,EAAE,IAAI8D,KAAK,CAAC,oBAAoB,CAAC;gBACtCzD,SAAS,EAAE;eACZ;aACF,CAAC,CACH,CACF;UACH,CAAC,MAAM,IAAI2E,IAAI,EAAE;YACfQ,OAAO,CAACH,OAAO,EAAE;YACjB;UACF;UACAH,MAAM,GAAGM,OAAO;UAChBN,MAAM,CAACO,IAAI,CAAC,OAAO,EAAEN,OAAO,CAAC;UAC7BF,MAAM,GAAGF,UAAU,CAAC/D,IAAI,EAAEkE,MAAM,CAAC;UACjCN,CAAC,CAACM,MAAM,EAAGQ,GAAG,IAAI;YAChBN,OAAO,EAAE;YACTN,MAAM,CAACY,GAAG,CAAC;UACb,CAAC,CAAC;QACJ,CAAC,CAAC;QACF,OAAO3H,MAAM,CAAC4H,OAAO,CAAC,MAAK;UACzB,IAAI,CAACV,MAAM,EAAE;YACXG,OAAO,EAAE;YACT,OAAOrH,MAAM,CAAC6H,IAAI;UACpB;UACA,OAAO7H,MAAM,CAAC8H,QAAQ,CAACZ,MAAM,EAAElH,MAAM,CAAC+H,IAAI,CAACV,OAAO,CAAC,CAAC;QACtD,CAAC,CAAC;MACJ,CAAC,CAAC;IACJ;IAEQW,GAAGA,CAAC7C,KAAa,EAAE8C,MAA8B;MACvD,OAAO,IAAI,CAACrB,aAAa,CAAqB,CAACO,MAAM,EAAEJ,MAAM,KAAI;QAC/DI,MAAM,CAAChC,KAAK,CAACA,KAAK,EAAE8C,MAAa,EAAE,CAACC,GAAG,EAAEC,MAAM,KAAI;UACjD,IAAID,GAAG,EAAE;YACPnB,MAAM,CACJ/G,MAAM,CAAC8F,IAAI,CAAC,IAAI1E,QAAQ,CAAC;cAAEiE,MAAM,EAAEjD,aAAa,CAAC8F,GAAG,EAAE,6BAA6B,EAAE,SAAS;YAAC,CAAE,CAAC,CAAC,CACpG;UACH,CAAC,MAAM;YACL;YACAnB,MAAM,CAAC/G,MAAM,CAACoI,OAAO,CACnBC,KAAK,CAACC,OAAO,CAACH,MAAM,CAAC,GACjBA,MAAM,CAACI,GAAG,CAAEC,CAAC,IAAKA,CAAC,CAACC,IAAI,IAAI,EAAE,CAAC,GAC/BN,MAAM,CAACM,IAAI,IAAI,EAAE,CACtB,CAAC;UACJ;QACF,CAAC,CAAC;MACJ,CAAC,CAAC;IACJ;IAEAC,OAAOA,CACLC,GAAW,EACXV,MAA8B,EAC9B5B,aAA0F;MAE1F,OAAOA,aAAa,GAChBrG,MAAM,CAACuI,GAAG,CAAC,IAAI,CAACP,GAAG,CAACW,GAAG,EAAEV,MAAM,CAAC,EAAE5B,aAAa,CAAC,GAChD,IAAI,CAAC2B,GAAG,CAACW,GAAG,EAAEV,MAAM,CAAC;IAC3B;IACAW,UAAUA,CAACD,GAAW,EAAEV,MAA8B;MACpD,OAAO,IAAI,CAACrB,aAAa,CAAY,CAACO,MAAM,EAAEJ,MAAM,KAAI;QACtDI,MAAM,CAAChC,KAAK,CAACwD,GAAG,EAAEV,MAAa,EAAE,CAACC,GAAG,EAAEC,MAAM,KAAI;UAC/C,IAAID,GAAG,EAAE;YACPnB,MAAM,CACJ/G,MAAM,CAAC8F,IAAI,CAAC,IAAI1E,QAAQ,CAAC;cAAEiE,MAAM,EAAEjD,aAAa,CAAC8F,GAAG,EAAE,6BAA6B,EAAE,SAAS;YAAC,CAAE,CAAC,CAAC,CACpG;UACH,CAAC,MAAM;YACLnB,MAAM,CAAC/G,MAAM,CAACoI,OAAO,CAACD,MAAM,CAAC,CAAC;UAChC;QACF,CAAC,CAAC;MACJ,CAAC,CAAC;IACJ;IACAU,uBAAuBA,CAACF,GAAW,EAAEV,MAA8B;MACjE,OAAO,IAAI,CAACD,GAAG,CAACW,GAAG,EAAEV,MAAM,CAAC;IAC9B;IACAa,aAAaA,CAACH,GAAW,EAAEV,MAA8B;MACvD,OAAO,IAAI,CAACrB,aAAa,CAAqB,CAACO,MAAM,EAAEJ,MAAM,KAAI;QAC/DI,MAAM,CAAChC,KAAK,CACV;UACE4D,IAAI,EAAEJ,GAAG;UACTK,OAAO,EAAE,OAAO;UAChBC,MAAM,EAAEhB;SACT,EACD,CAACC,GAAG,EAAEC,MAAM,KAAI;UACd,IAAID,GAAG,EAAE;YACPnB,MAAM,CACJ/G,MAAM,CAAC8F,IAAI,CAAC,IAAI1E,QAAQ,CAAC;cAAEiE,MAAM,EAAEjD,aAAa,CAAC8F,GAAG,EAAE,6BAA6B,EAAE,SAAS;YAAC,CAAE,CAAC,CAAC,CACpG;UACH,CAAC,MAAM;YACLnB,MAAM,CAAC/G,MAAM,CAACoI,OAAO,CAACD,MAAM,CAACM,IAAI,CAAC,CAAC;UACrC;QACF,CAAC,CACF;MACH,CAAC,CAAC;IACJ;IACAS,iBAAiBA,CACfP,GAAW,EACXV,MAA8B,EAC9B5B,aAA0F;MAE1F,OAAO,IAAI,CAACqC,OAAO,CAACC,GAAG,EAAEV,MAAM,EAAE5B,aAAa,CAAC;IACjD;IACA8C,aAAaA,CACXR,GAAW,EACXV,MAA8B,EAC9B5B,aAA0F;MAE1F;MACA,MAAM+C,IAAI,GAAG,IAAI;MACjB,OAAO1I,MAAM,CAAC2I,WAAW,CAACxJ,OAAO,CAACyJ,aAAa,CAACtJ,MAAM,CAACgG,UAAU,CAAC,WAAUuD,CAAC,EAAEC,KAAK;QAClF,MAAMrC,MAAM,GAAGiC,IAAI,CAAC1C,EAAE,KAAK,OAAOlG,KAAK,CAACiJ,OAAO,CAACC,UAAU,EAAEF,KAAK,CAAC,CAAC;QACnE,OAAOhJ,KAAK,CAACmJ,YAAY,CAACH,KAAK,EAAExJ,MAAM,CAACsF,OAAO,CAAC,MAAMsE,MAAM,CAACC,KAAK,EAAE,CAAC,CAAC;QACtE,MAAMD,MAAM,GAAGzC,MAAM,CAAChC,KAAK,CAAC,IAAIxD,MAAM,CAACgH,GAAG,EAAEV,MAAa,CAAC,CAAC;QAC3D;QACA,OAAOjI,MAAM,CAAC8G,QAAQ,CAAyDC,MAAM,IAAI;UACvF6C,MAAM,CAACE,IAAI,CAAC,GAAG,EAAE,CAAC5B,GAAG,EAAEO,IAAI,KAAI;YAC7B,IAAIP,GAAG,EAAE;cACPnB,MAAM,CAAC/G,MAAM,CAAC8F,IAAI,CAAC,IAAI1E,QAAQ,CAAC;gBAAEiE,MAAM,EAAEjD,aAAa,CAAC8F,GAAG,EAAE,6BAA6B,EAAE,QAAQ;cAAC,CAAE,CAAC,CAAC,CAAC;YAC5G,CAAC,MAAM,IAAIvI,GAAG,CAACoK,eAAe,CAACtB,IAAI,CAAC,EAAE;cACpC1B,MAAM,CAAC/G,MAAM,CAACoI,OAAO,CAAC/B,aAAa,GAAGA,aAAa,CAACoC,IAAI,CAAQ,GAAGA,IAAI,CAAC,CAAC;YAC3E,CAAC,MAAM;cACL1B,MAAM,CAACnH,KAAK,CAACqH,IAAI,EAAE,CAAC;YACtB;UACF,CAAC,CAAC;QACJ,CAAC,CAAC;MACJ,CAAC,CAAC,CAAC,CAAC;IACN;;EAGF,MAAMyC,UAAU,GAAG1J,MAAM,CAAC8G,QAAQ,CAAwCC,MAAM,IAAI;IAClF,MAAMiD,KAAK,GAAG/J,KAAK,CAACgK,UAAU,EAAG;IACjC,MAAMT,KAAK,GAAG/I,UAAU,CAACyJ,SAAS,CAACF,KAAK,CAACG,QAAQ,EAAE3J,KAAK,CAACA,KAAK,CAAC;IAC/D,IAAIyB,KAAK,GAAsBC,SAAS;IACxCe,IAAI,CAACuE,OAAO,CAAC,CAACU,GAAG,EAAEf,MAAM,EAAEG,OAAO,KAAI;MACpC,IAAIY,GAAG,EAAE;QACPnB,MAAM,CACJ/G,MAAM,CAAC8F,IAAI,CACT,IAAI1E,QAAQ,CAAC;UACXiE,MAAM,EAAEjD,aAAa,CACnB8F,GAAG,EACH,8CAA8C,EAC9C,mBAAmB;SAEtB,CAAC,CACH,CACF;MACH,CAAC,MAAM;QACLnB,MAAM,CAAC/G,MAAM,CAACoK,EAAE,CACd5J,KAAK,CAACmJ,YAAY,CAChBH,KAAK,EACLxJ,MAAM,CAAC+H,IAAI,CAAC,MAAK;UACfZ,MAAO,CAACI,GAAG,CAAC,OAAO,EAAEH,OAAO,CAAC;UAC7BE,OAAO,CAACrF,KAAK,CAAC;QAChB,CAAC,CAAC,CACH,EACDkF,MAAO,CACR,CAAC;MACJ;MACA,SAASC,OAAOA,CAACiD,MAAa;QAC5BpI,KAAK,GAAGoI,MAAM;MAChB;MACAlD,MAAO,CAACrC,EAAE,CAAC,OAAO,EAAEsC,OAAO,CAAC;IAC9B,CAAC,CAAC;EACJ,CAAC,CAAC;EACF,MAAMkD,OAAO,GAAGtK,MAAM,CAACuI,GAAG,CAACmB,UAAU,EAAGvC,MAAM,IAAK,IAAIV,cAAc,CAACU,MAAM,CAAC,CAAC;EAE9E,MAAMoD,mBAAmB,GAAIhB,CAAQ,IAAI,CACzC,CAAC;EAED,MAAMiB,YAAY,GAAG,OAAOlK,KAAK,CAACsC,IAAI,CAAC;IACrCG,OAAO,EAAE/C,MAAM,CAACgF,cAAc,CAC5BhF,MAAM,CAACiF,UAAU,CAAC;MAChBC,GAAG,EAAE,MAAAA,CAAA,KAAW;QACd,MAAMiC,MAAM,GAAG,IAAI1F,EAAE,CAACb,MAAM,CAACqC,IAAI,CAACJ,OAAO,CAAC;QAC1C,MAAMsE,MAAM,CAACK,OAAO,EAAE;QACtBL,MAAM,CAACrC,EAAE,CAAC,OAAO,EAAEyF,mBAAmB,CAAC;QACvC,OAAOpD,MAAM;MACf,CAAC;MACD/B,KAAK,EAAGnD,KAAK,IACX,IAAIb,QAAQ,CAAC;QACXiE,MAAM,EAAEjD,aAAa,CAACH,KAAK,EAAE,yCAAyC,EAAE,mBAAmB;OAC5F;KACJ,CAAC,EACDkF,MAAM,IACLnH,MAAM,CAACsF,OAAO,CAAC,MAAK;MAClB6B,MAAM,CAACI,GAAG,CAAC,OAAO,EAAEgD,mBAAmB,CAAC;MACxC,OAAOpD,MAAM,CAAC5B,GAAG,EAAE;IACrB,CAAC,CAAC,CAACC,IAAI,CACLxF,MAAM,CAACyF,aAAa,CAAC,IAAI,CAAC,CAC3B;GAEN,CAAC;EAEF,IAAIgF,MAAM,GAAmB;IAC3BrH,GAAG,EAAEH,IAAI,CAACJ,OAAO,CAACM,gBAAgB,GAAG5C,QAAQ,CAACqC,IAAI,CAACK,IAAI,CAACJ,OAAO,CAACM,gBAAgB,CAAC,GAAGjB,SAAS;IAC7FsB,IAAI,EAAEP,IAAI,CAACJ,OAAO,CAACW,IAAI;IACvBI,IAAI,EAAEX,IAAI,CAACJ,OAAO,CAACe,IAAI;IACvBH,QAAQ,EAAER,IAAI,CAACJ,OAAO,CAACY,QAAQ;IAC/BF,QAAQ,EAAEN,IAAI,CAACJ,OAAO,CAACS,IAAI;IAC3BI,QAAQ,EAAE,OAAOT,IAAI,CAACJ,OAAO,CAACa,QAAQ,KAAK,QAAQ,GAAGnD,QAAQ,CAACqC,IAAI,CAACK,IAAI,CAACJ,OAAO,CAACa,QAAQ,CAAC,GAAGxB,SAAS;IACtGyB,GAAG,EAAEV,IAAI,CAACJ,OAAO,CAACc,GAAG;IACrBiB,eAAe,EAAE3B,IAAI,CAACJ,OAAO,CAAC8B,gBAAgB;IAC9CE,KAAK,EAAE5B,IAAI,CAACJ,OAAO,CAACgC;GACrB;EACD,IAAI5B,IAAI,CAACJ,OAAO,CAACM,gBAAgB,EAAE;IACjC;IACA,IAAI;MACF,MAAMuH,MAAM,GAAGhJ,YAAY,CAACiJ,KAAK,CAAC1H,IAAI,CAACJ,OAAO,CAACM,gBAAgB,CAAC;MAChEsH,MAAM,GAAG;QACP,GAAGA,MAAM;QACTjH,IAAI,EAAEiH,MAAM,CAACjH,IAAI,IAAIkH,MAAM,CAAClH,IAAI,IAAItB,SAAS;QAC7C0B,IAAI,EAAE6G,MAAM,CAAC7G,IAAI,KAAK8G,MAAM,CAAC9G,IAAI,GAAGxD,MAAM,CAACwK,cAAc,CAACzK,MAAM,CAACwK,KAAK,CAACD,MAAM,CAAC9G,IAAI,CAAC,CAAC,GAAG1B,SAAS,CAAC;QACjGqB,QAAQ,EAAEkH,MAAM,CAAClH,QAAQ,IAAImH,MAAM,CAACpH,IAAI,IAAIpB,SAAS;QACrDwB,QAAQ,EAAE+G,MAAM,CAAC/G,QAAQ,KAAKgH,MAAM,CAAChH,QAAQ,GAAGnD,QAAQ,CAACqC,IAAI,CAAC8H,MAAM,CAAChH,QAAQ,CAAC,GAAGxB,SAAS,CAAC;QAC3FuB,QAAQ,EAAEgH,MAAM,CAAChH,QAAQ,IAAIiH,MAAM,CAACjH,QAAQ,IAAIvB;OACjD;IACH,CAAC,CAAC,MAAM;MACN;IAAA;EAEJ;EAEA,OAAO2I,MAAM,CAACC,MAAM,CAClB,OAAOlK,MAAM,CAACgC,IAAI,CAAC;IACjBmI,QAAQ,EAAE/K,MAAM,CAACoI,OAAO,CAAC,IAAI3B,cAAc,EAAE,CAAC;IAC9CuE,mBAAmB,EAAEV,OAAO;IAC5BrE,QAAQ;IACRgF,cAAc,EAAE,CACd,IAAIpI,OAAO,CAACoI,cAAc,GAAGJ,MAAM,CAACK,OAAO,CAACrI,OAAO,CAACoI,cAAc,CAAC,GAAG,EAAE,CAAC,EACzE,CAACrJ,mBAAmB,EAAE,YAAY,CAAC,EACnC,CAACC,iBAAiB,EAAE4I,MAAM,CAAChH,QAAQ,IAAIgH,MAAM,CAAClH,QAAQ,IAAI,UAAU,CAAC,EACrE,CAACzB,mBAAmB,EAAE2I,MAAM,CAACjH,IAAI,IAAI,WAAW,CAAC,EACjD,CAACzB,gBAAgB,EAAE0I,MAAM,CAAC7G,IAAI,IAAI,IAAI,CAAC,CACxC;IACDyC;GACD,CAAC,EACF;IACE,CAAC5D,MAAM,GAAGA,MAAgB;IAC1BgI,MAAM;IACNU,IAAI,EAAG5B,CAAU,IAAK/H,SAAS,CAAC4J,QAAQ,CAAC,CAACC,MAAM,CAAC9B,CAAC,CAAC,CAAC,CAAC;IACrD+B,MAAM,EAAGC,OAAe,IACtB7K,MAAM,CAACoG,QAAQ,CAAmB9G,MAAM,CAACgG,UAAU,CAAC,WAAUwF,KAAK;MACjE,MAAMrE,MAAM,GAAG,OAAO7G,KAAK,CAACmL,GAAG,CAACjB,YAAY,CAAC;MAC7C,SAASkB,cAAcA,CAACC,GAAoB;QAC1C,IAAIA,GAAG,CAACJ,OAAO,KAAKA,OAAO,IAAII,GAAG,CAACC,OAAO,EAAE;UAC1CvL,KAAK,CAACwL,WAAW,CAACL,KAAK,EAAEG,GAAG,CAACC,OAAO,CAAC;QACvC;MACF;MACA,OAAO5L,MAAM,CAAC2J,YAAY,CAAC,MACzB3J,MAAM,CAACsF,OAAO,CAAC,MAAK;QAClB6B,MAAM,CAACI,GAAG,CAAC,cAAc,EAAEmE,cAAc,CAAC;QAC1C,OAAOvE,MAAM,CAAChC,KAAK,CAAC,YAAY1D,EAAE,CAACqK,gBAAgB,CAACP,OAAO,CAAC,EAAE,CAAC;MACjE,CAAC,CAAC,CACH;MACD,OAAOvL,MAAM,CAACiF,UAAU,CAAC;QACvBC,GAAG,EAAEA,CAAA,KAAMiC,MAAM,CAAChC,KAAK,CAAC,UAAU1D,EAAE,CAACqK,gBAAgB,CAACP,OAAO,CAAC,EAAE,CAAC;QACjEnG,KAAK,EAAGnD,KAAK,IAAK,IAAIb,QAAQ,CAAC;UAAEiE,MAAM,EAAEjD,aAAa,CAACH,KAAK,EAAE,kBAAkB,EAAE,QAAQ;QAAC,CAAE;OAC9F,CAAC;MACFkF,MAAM,CAACrC,EAAE,CAAC,cAAc,EAAE4G,cAAc,CAAC;IAC3C,CAAC,CAAC,CAAC;IACLK,MAAM,EAAEA,CAACR,OAAe,EAAEK,OAAe,KACvC5L,MAAM,CAAC8G,QAAQ,CAAkBC,MAAM,IAAI;MACzC9D,IAAI,CAACkC,KAAK,CAAC,UAAU1D,EAAE,CAACqK,gBAAgB,CAACP,OAAO,CAAC,MAAM,EAAE,CAACK,OAAO,CAAC,EAAG1D,GAAG,IAAI;QAC1E,IAAIA,GAAG,EAAE;UACPnB,MAAM,CAAC/G,MAAM,CAAC8F,IAAI,CAAC,IAAI1E,QAAQ,CAAC;YAAEiE,MAAM,EAAEjD,aAAa,CAAC8F,GAAG,EAAE,kBAAkB,EAAE,QAAQ;UAAC,CAAE,CAAC,CAAC,CAAC;QACjG,CAAC,MAAM;UACLnB,MAAM,CAAC/G,MAAM,CAAC6H,IAAI,CAAC;QACrB;MACF,CAAC,CAAC;IACJ,CAAC;GACJ,CACF;AACH,CAAC,CAAC;AAEF,MAAMmE,aAAa,gBAAG,IAAIC,OAAO,EAAkD;AACnF,MAAMjF,UAAU,GAAGA,CAAC/D,IAAa,EAAEkE,MAAqB,KAAI;EAC1D,IAAI6E,aAAa,CAACE,GAAG,CAAC/E,MAAM,CAAC,EAAE;IAC7B,OAAO6E,aAAa,CAACP,GAAG,CAACtE,MAAM,CAAE;EACnC;EACA,MAAMgF,SAAS,GAAIhF,MAAc,CAACiF,SAAS;EAC3C,MAAMzE,GAAG,GAAGwE,SAAS,KAAKjK;EACxB;EAAA,EACElC,MAAM,CAAC8G,QAAQ,CAAQC,MAAM,IAAI;IACjC,IAAI9D,IAAI,CAACoJ,MAAM,EAAE,OAAOtF,MAAM,CAAC/G,MAAM,CAAC6H,IAAI,CAAC;IAC3C5E,IAAI,CAACkC,KAAK,CAAC,4BAA4BgH,SAAS,GAAG,EAAE,MAAK;MACxDpF,MAAM,CAAC/G,MAAM,CAAC6H,IAAI,CAAC;IACrB,CAAC,CAAC;EACJ,CAAC,CAAC,CAACrC,IAAI,CACLxF,MAAM,CAACsM,aAAa,EACpBtM,MAAM,CAACyF,aAAa,CAAC,IAAI,CAAC,CAC3B,GACCvD,SAAS;EACb8J,aAAa,CAACO,GAAG,CAACpF,MAAM,EAAEQ,GAAG,CAAC;EAC9B,OAAOA,GAAG;AACZ,CAAC;AAED;;;;AAIA,OAAO,MAAM6E,WAAW,GAGtB/B,MAAmC,IAEnCvK,KAAK,CAACuM,cAAc,CAClB3M,MAAM,CAAC4M,MAAM,CAACjC,MAAM,CAAC,CAACkC,QAAQ,EAAE,CAACnH,IAAI,CACnCxF,MAAM,CAAC4M,OAAO,CAAChK,IAAI,CAAC,EACpB5C,MAAM,CAACuI,GAAG,CAAEpB,MAAM,IAChB1G,UAAU,CAACmC,IAAI,CAACF,QAAQ,EAAEyE,MAAM,CAAC,CAAC3B,IAAI,CACpC/E,UAAU,CAACoM,GAAG,CAACjM,MAAM,CAACkM,SAAS,EAAE3F,MAAM,CAAC,CACzC,CACF,CACF,CACF,CAAC3B,IAAI,CAACtF,KAAK,CAACuJ,OAAO,CAAC9I,UAAU,CAACoM,KAAK,CAAC,CAAC;AAEzC;;;;AAIA,OAAO,MAAMA,KAAK,GAChBtC,MAAsB,IAEtBvK,KAAK,CAACuM,cAAc,CAClBzM,MAAM,CAACuI,GAAG,CAAC3F,IAAI,CAAC6H,MAAM,CAAC,EAAGtD,MAAM,IAC9B1G,UAAU,CAACmC,IAAI,CAACF,QAAQ,EAAEyE,MAAM,CAAC,CAAC3B,IAAI,CACpC/E,UAAU,CAACoM,GAAG,CAACjM,MAAM,CAACkM,SAAS,EAAE3F,MAAM,CAAC,CACzC,CAAC,CACL,CAAC3B,IAAI,CAACtF,KAAK,CAACuJ,OAAO,CAAC9I,UAAU,CAACoM,KAAK,CAAC,CAAC;AAEzC;;;;AAIA,OAAO,MAAMC,aAAa,GAAInK,OAU7B,IACC3C,KAAK,CAACuM,cAAc,CAClBzM,MAAM,CAACuI,GAAG,CAACzF,QAAQ,CAACD,OAAO,CAAC,EAAGsE,MAAM,IACnC1G,UAAU,CAACmC,IAAI,CAACF,QAAQ,EAAEyE,MAAM,CAAC,CAAC3B,IAAI,CACpC/E,UAAU,CAACoM,GAAG,CAACjM,MAAM,CAACkM,SAAS,EAAE3F,MAAM,CAAC,CACzC,CAAC,CACL,CAAC3B,IAAI,CAACtF,KAAK,CAACuJ,OAAO,CAAC9I,UAAU,CAACoM,KAAK,CAAC,CAAC;AAEzC;;;;AAIA,OAAO,MAAM7G,YAAY,GAAGA,CAC1B+G,SAAiC,EACjC7G,aAAa,GAAG,IAAI,KACE;EACtB,MAAM8G,cAAc,GAAG9G,aAAa,IAAI6G,SAAS,GAC7CzL,SAAS,CAAC+E,iBAAiB,CAAC0G,SAAS,CAAC,CAAC5J,KAAK,GAC5CnB,SAAS;EAEb,OAAOV,SAAS,CAAC0E,YAAY,CAAW;IACtCiH,OAAO,EAAE,IAAI;IACbC,WAAWA,CAAC7D,CAAC;MACX,OAAO,IAAIA,CAAC,EAAE;IAChB,CAAC;IACD8D,YAAY,EAAEJ,SAAS,GACrB,UAAS5J,KAAK,EAAEiK,gBAAgB;MAC9B,OAAOA,gBAAgB,GAAGC,MAAM,CAAClK,KAAK,CAAC,GAAGkK,MAAM,CAACN,SAAS,CAAC5J,KAAK,CAAC,CAAC;IACpE,CAAC,GACDkK,MAAM;IACRC,cAAcA,CAACC,YAAY,EAAEC,UAAU,EAAEC,YAAY,EAAE1E,MAAM,EAAE2E,SAAS;MACtE,OAAO,CACL,WAAWH,YAAY,QAAQC,UAAU,GAAGC,YAAY,GAAGC,SAAS,GAAG,cAAcA,SAAS,CAAC,CAAC,CAAC,EAAE,GAAG,EAAE,EAAE,EAC1GA,SAAS,GACP3E,MAAM,CAAC4E,IAAI,EAAE,CAACC,MAAM,CAACF,SAAS,CAAC,CAAC,CAAC,CAAC,GAClC3E,MAAM,CAAC4E,IAAI,EAAE,CAChB;IACH,CAAC;IACDE,QAAQA,CAACC,IAAI,EAAEZ,WAAW,EAAEE,gBAAgB;MAC1C,QAAQU,IAAI,CAACC,IAAI;QACf,KAAK,QAAQ;UAAE;YACb,OAAO,CACLb,WAAW,CAAClL,SAAS,CAAC,EACtB,CACEoL,gBAAgB,IAAIJ,cAAc,KAAKhL,SAAS,GAC5C8L,IAAI,CAACE,MAAM,GACXhB,cAAc,CAACc,IAAI,CAACE,MAAM,CAAC,CAChC,CACF;UACH;MACF;IACF;GACD,CAAC;AACJ,CAAC;AAED,MAAMX,MAAM,gBAAG/L,SAAS,CAAC2M,aAAa,CAAC,IAAI,CAAC;AAa5C;;;;AAIA,MAAM9C,MAAM,gBAAG7J,SAAS,CAAC4M,MAAM,CAAS,QAAQ,CAAC","ignoreList":[]} |
+3
-3
| { | ||
| "name": "@effect/sql-pg", | ||
| "version": "4.0.0-beta.36", | ||
| "version": "4.0.0-beta.37", | ||
| "type": "module", | ||
@@ -49,6 +49,6 @@ "license": "MIT", | ||
| "@types/pg-cursor": "^2.7.2", | ||
| "effect": "^4.0.0-beta.36" | ||
| "effect": "^4.0.0-beta.37" | ||
| }, | ||
| "peerDependencies": { | ||
| "effect": "^4.0.0-beta.36" | ||
| "effect": "^4.0.0-beta.37" | ||
| }, | ||
@@ -55,0 +55,0 @@ "dependencies": { |
+128
-15
@@ -23,3 +23,15 @@ /** | ||
| import type { Connection } from "effect/unstable/sql/SqlConnection" | ||
| import { SqlError } from "effect/unstable/sql/SqlError" | ||
| import { | ||
| AuthenticationError, | ||
| AuthorizationError, | ||
| ConnectionError, | ||
| ConstraintError, | ||
| DeadlockError, | ||
| LockTimeoutError, | ||
| SerializationError, | ||
| SqlError, | ||
| SqlSyntaxError, | ||
| StatementTimeoutError, | ||
| UnknownError | ||
| } from "effect/unstable/sql/SqlError" | ||
| import type { Custom, Fragment } from "effect/unstable/sql/Statement" | ||
@@ -38,2 +50,49 @@ import * as Statement from "effect/unstable/sql/Statement" | ||
| const pgCodeFromCause = (cause: unknown): string | undefined => { | ||
| if (typeof cause !== "object" || cause === null || !("code" in cause)) { | ||
| return undefined | ||
| } | ||
| const code = cause.code | ||
| return typeof code === "string" ? code : undefined | ||
| } | ||
| const classifyError = ( | ||
| cause: unknown, | ||
| message: string, | ||
| operation: string | ||
| ) => { | ||
| const props = { cause, message, operation } | ||
| const code = pgCodeFromCause(cause) | ||
| if (code !== undefined) { | ||
| if (code.startsWith("08")) { | ||
| return new ConnectionError(props) | ||
| } | ||
| if (code.startsWith("28")) { | ||
| return new AuthenticationError(props) | ||
| } | ||
| if (code === "42501") { | ||
| return new AuthorizationError(props) | ||
| } | ||
| if (code.startsWith("42")) { | ||
| return new SqlSyntaxError(props) | ||
| } | ||
| if (code.startsWith("23")) { | ||
| return new ConstraintError(props) | ||
| } | ||
| if (code === "40P01") { | ||
| return new DeadlockError(props) | ||
| } | ||
| if (code === "40001") { | ||
| return new SerializationError(props) | ||
| } | ||
| if (code === "55P03") { | ||
| return new LockTimeoutError(props) | ||
| } | ||
| if (code === "57014") { | ||
| return new StatementTimeoutError(props) | ||
| } | ||
| } | ||
| return new UnknownError(props) | ||
| } | ||
| /** | ||
@@ -141,3 +200,3 @@ * @category type ids | ||
| try: () => pool.query("SELECT 1"), | ||
| catch: (cause) => new SqlError({ cause, message: "PgClient: Failed to connect" }) | ||
| catch: (cause) => new SqlError({ reason: classifyError(cause, "PgClient: Failed to connect", "connect") }) | ||
| }), | ||
@@ -154,4 +213,7 @@ () => | ||
| new SqlError({ | ||
| cause: new Error("Connection timed out"), | ||
| message: "PgClient: Connection timed out" | ||
| reason: new ConnectionError({ | ||
| cause: new Error("Connection timed out"), | ||
| message: "PgClient: Connection timed out", | ||
| operation: "connect" | ||
| }) | ||
| }) | ||
@@ -215,3 +277,3 @@ ) | ||
| cleanup(cause) | ||
| resume(Effect.fail(new SqlError({ cause, message: "Connection error" }))) | ||
| resume(Effect.fail(new SqlError({ reason: classifyError(cause, "Connection error", "acquireConnection") }))) | ||
| } | ||
@@ -225,7 +287,19 @@ function cleanup(cause?: Error) { | ||
| if (cause) { | ||
| return resume(Effect.fail(new SqlError({ cause, message: "Failed to acquire connection" }))) | ||
| return resume( | ||
| Effect.fail( | ||
| new SqlError({ | ||
| reason: classifyError(cause, "Failed to acquire connection", "acquireConnection") | ||
| }) | ||
| ) | ||
| ) | ||
| } else if (!client_) { | ||
| return resume( | ||
| Effect.fail( | ||
| new SqlError({ message: "Failed to acquire connection", cause: new Error("No client returned") }) | ||
| new SqlError({ | ||
| reason: new ConnectionError({ | ||
| message: "Failed to acquire connection", | ||
| cause: new Error("No client returned"), | ||
| operation: "acquireConnection" | ||
| }) | ||
| }) | ||
| ) | ||
@@ -259,3 +333,5 @@ ) | ||
| if (err) { | ||
| resume(Effect.fail(new SqlError({ cause: err, message: "Failed to execute statement" }))) | ||
| resume( | ||
| Effect.fail(new SqlError({ reason: classifyError(err, "Failed to execute statement", "execute") })) | ||
| ) | ||
| } else { | ||
@@ -286,3 +362,5 @@ // Multi-statement queries return an array of results | ||
| if (err) { | ||
| resume(Effect.fail(new SqlError({ cause: err, message: "Failed to execute statement" }))) | ||
| resume( | ||
| Effect.fail(new SqlError({ reason: classifyError(err, "Failed to execute statement", "execute") })) | ||
| ) | ||
| } else { | ||
@@ -307,3 +385,5 @@ resume(Effect.succeed(result)) | ||
| if (err) { | ||
| resume(Effect.fail(new SqlError({ cause: err, message: "Failed to execute statement" }))) | ||
| resume( | ||
| Effect.fail(new SqlError({ reason: classifyError(err, "Failed to execute statement", "execute") })) | ||
| ) | ||
| } else { | ||
@@ -338,3 +418,3 @@ resume(Effect.succeed(result.rows)) | ||
| if (err) { | ||
| resume(Effect.fail(new SqlError({ cause: err, message: "Failed to execute statement" }))) | ||
| resume(Effect.fail(new SqlError({ reason: classifyError(err, "Failed to execute statement", "stream") }))) | ||
| } else if (Arr.isArrayNonEmpty(rows)) { | ||
@@ -357,3 +437,13 @@ resume(Effect.succeed(transformRows ? transformRows(rows) as any : rows)) | ||
| if (err) { | ||
| resume(Effect.fail(new SqlError({ cause: err, message: "Failed to acquire connection for transaction" }))) | ||
| resume( | ||
| Effect.fail( | ||
| new SqlError({ | ||
| reason: classifyError( | ||
| err, | ||
| "Failed to acquire connection for transaction", | ||
| "acquireConnection" | ||
| ) | ||
| }) | ||
| ) | ||
| ) | ||
| } else { | ||
@@ -379,4 +469,27 @@ resume(Effect.as( | ||
| const onListenClientError = (_: Error) => { | ||
| } | ||
| const listenClient = yield* RcRef.make({ | ||
| acquire: reserveRaw | ||
| acquire: Effect.acquireRelease( | ||
| Effect.tryPromise({ | ||
| try: async () => { | ||
| const client = new Pg.Client(pool.options) | ||
| await client.connect() | ||
| client.on("error", onListenClientError) | ||
| return client | ||
| }, | ||
| catch: (cause) => | ||
| new SqlError({ | ||
| reason: classifyError(cause, "Failed to acquire connection for listen", "acquireConnection") | ||
| }) | ||
| }), | ||
| (client) => | ||
| Effect.promise(() => { | ||
| client.off("error", onListenClientError) | ||
| return client.end() | ||
| }).pipe( | ||
| Effect.timeoutOption(1000) | ||
| ) | ||
| ) | ||
| }) | ||
@@ -446,3 +559,3 @@ | ||
| try: () => client.query(`LISTEN ${Pg.escapeIdentifier(channel)}`), | ||
| catch: (cause) => new SqlError({ cause, message: "Failed to listen" }) | ||
| catch: (cause) => new SqlError({ reason: classifyError(cause, "Failed to listen", "listen") }) | ||
| }) | ||
@@ -455,3 +568,3 @@ client.on("notification", onNotification) | ||
| if (err) { | ||
| resume(Effect.fail(new SqlError({ cause: err, message: "Failed to notify" }))) | ||
| resume(Effect.fail(new SqlError({ reason: classifyError(err, "Failed to notify", "notify") }))) | ||
| } else { | ||
@@ -458,0 +571,0 @@ resume(Effect.void) |
No alert changes
Improved metrics
- Total package byte prevSize
84414
10.16%- Lines of code
1473
12.61%No dependency changes