gavindiaz/polymarket-analyst_github
1
0
Fork 0
mirror of https://github.com/theodore-song/polymarket-analyst.git synced 2026-08-24 04:58:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Classify nested Neon connection failures

Browse Source
This commit is contained in:
Theodore Song
2026-08-19 08:31:01 -04:00
parent f75e6b0877
commit 720aa75d78
2 changed files with 14 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/state.js
+9 -3
View File
@@ -19,8 +19,9 @@ function withBlobAuth(options = {}) {
export function providerErrorCode(error) {
if (!error) return "not_configured_or_not_attempted";
const code = String(error.code || error.cause && error.cause.code || "").toUpperCase();
const message = String(error.message || error).toLowerCase();
const nested = error.sourceError || error.cause;
const code = String(error.code || nested && (nested.code || nested.cause && nested.cause.code) || "").toUpperCase();
const message = `${String(error.message || error)} ${String(nested && nested.message || "")}`.toLowerCase();
if (code === "28P01" || code === "28000") return "authorization_failed";
if (code === "3D000") return "database_not_found";
if (code.startsWith("08")) return "connection_failed";
@@ -35,12 +36,17 @@ export function providerErrorCode(error) {
}
function providerErrorMetadata(error) {
const nested = error && (error.sourceError || error.cause);
const name = String(error && error.name || "Error");
const code = String(error && (error.code || error.cause && error.cause.code) || "").toUpperCase();
const nestedName = String(nested && nested.name || "none");
const code = String(error && (error.code || nested && (nested.code || nested.cause && nested.cause.code)) || "").toUpperCase();
const httpStatus = String(error && error.message || "").match(/HTTP status\s+(\d{3})/i);
return {
status: providerErrorCode(error),
error_class: /^[A-Za-z][A-Za-z0-9_]{0,39}$/.test(name) ? name : "Error",
source_error_class: /^[A-Za-z][A-Za-z0-9_]{0,39}$/.test(nestedName) ? nestedName : "none",
error_code: /^[A-Z0-9_]{1,32}$/.test(code) ? code : "none",
http_status: httpStatus ? Number(httpStatus[1]) : null,
};
}
scripts/test-server-state.mjs
+5
View File
@@ -47,5 +47,10 @@ assert.equal(compactedState.signal_ledger.expired_ungraded, 7);
assert.equal(providerErrorCode(new Error("403 Forbidden")), "authorization_failed");
assert.equal(providerErrorCode(new Error("invalid connection string")), "invalid_connection_string");
assert.equal(providerErrorCode(Object.assign(new Error("database rejected login"), { code: "28P01" })), "authorization_failed");
const nestedFetchError = Object.assign(new Error("Error connecting to database"), {
name: "NeonDbError",
sourceError: Object.assign(new TypeError("fetch failed"), { cause: { code: "ENOTFOUND" } }),
});
assert.equal(providerErrorCode(nestedFetchError), "dns_failed");
console.log("server state tests passed");