diff --git a/deno.json b/deno.json index e2215b0..7c1c0b7 100644 --- a/deno.json +++ b/deno.json @@ -27,7 +27,7 @@ "file-type": "npm:file-type@^21.0.0", "node-cache": "npm:node-cache@^5.1.2", "rxjs": "npm:rxjs@^7.8.1", - "@flowcore/data-pump": "jsr:@flowcore/data-pump@^0.21.3", + "@flowcore/data-pump": "jsr:@flowcore/data-pump@^0.21.4", "@flowcore/sdk": "npm:@flowcore/sdk@^4.2.2", "postgres": "npm:postgres@^3.4.3", "ws": "npm:ws@^8.18.0", diff --git a/deno.lock b/deno.lock index 2fb573a..8855667 100644 --- a/deno.lock +++ b/deno.lock @@ -5,7 +5,7 @@ "jsr:@deno/cache-dir@~0.10.3": "0.10.3", "jsr:@deno/dnt@~0.41.3": "0.41.3", "jsr:@deno/graph@~0.73.1": "0.73.1", - "jsr:@flowcore/data-pump@~0.21.3": "0.21.3", + "jsr:@flowcore/data-pump@~0.21.4": "0.21.4", "jsr:@flowcore/sdk@^4.2.2": "4.2.2", "jsr:@flowcore/time-uuid@~0.1.1": "0.1.2", "jsr:@std/assert@0.223": "0.223.0", @@ -69,8 +69,8 @@ "@deno/graph@0.73.1": { "integrity": "cd69639d2709d479037d5ce191a422eabe8d71bb68b0098344f6b07411c84d41" }, - "@flowcore/data-pump@0.21.3": { - "integrity": "c18caf7623501b7d3b6d0eb85a577909481950ddf850958208aa7d701d49b0c0", + "@flowcore/data-pump@0.21.4": { + "integrity": "488532273480244bc6401183f080094a600441fa7f87d6ed3cef9a76f56b2a24", "dependencies": [ "jsr:@flowcore/sdk@^4.2.2", "jsr:@flowcore/time-uuid", @@ -384,7 +384,7 @@ "workspace": { "dependencies": [ "jsr:@deno/dnt@~0.41.3", - "jsr:@flowcore/data-pump@~0.21.3", + "jsr:@flowcore/data-pump@~0.21.4", "npm:@flowcore/sdk-transformer-core@^2.5.1", "npm:@flowcore/sdk@^4.2.2", "npm:bun-sqlite-key-value@^1.13.1", diff --git a/tests/postgres-pathway-state.test.ts b/tests/postgres-pathway-state.test.ts index efa4d74..7d76a4f 100644 --- a/tests/postgres-pathway-state.test.ts +++ b/tests/postgres-pathway-state.test.ts @@ -1,4 +1,4 @@ -import { assertEquals, assertFalse, assertRejects } from "https://deno.land/std@0.224.0/assert/mod.ts" +import { assert, assertEquals, assertFalse, assertRejects } from "https://deno.land/std@0.224.0/assert/mod.ts" import { createPostgresPathwayState, PostgresPathwayState } from "../src/pathways/postgres/postgres-pathway-state.ts" // Test configuration @@ -120,13 +120,18 @@ Deno.test({ port: 54321, } - await assertRejects( + const error = await assertRejects( async () => { const badState = createPostgresPathwayState(badConfig) await badState.isProcessed("some-event") }, Error, - "ENOTFOUND", + ) + // An unresolvable host is reported differently across resolvers/runners + // (ENOTFOUND vs EAI_AGAIN); both mean the host did not resolve. + assert( + /ENOTFOUND|EAI_AGAIN/.test(error.message), + `expected a DNS resolution failure (ENOTFOUND/EAI_AGAIN), got: ${error.message}`, ) })