build

porsager · porsager · commit 5974e7fcc171 · 2024-10-25T10:36:45.000+02:00
diff --git a/cf/src/connection.js b/cf/src/connection.js
@@ -387,7 +387,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function queryError(query, err) {
-    Object.defineProperties(err, {
+    'query' in err || 'parameters' in err || Object.defineProperties(err, {
       stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug },
       query: { value: query.string, enumerable: options.debug },
       parameters: { value: query.parameters, enumerable: options.debug },
diff --git a/cjs/src/connection.js b/cjs/src/connection.js
@@ -385,7 +385,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function queryError(query, err) {
-    'parameters' in err || Object.defineProperties(err, {
+    'query' in err || 'parameters' in err || Object.defineProperties(err, {
       stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug },
       query: { value: query.string, enumerable: options.debug },
       parameters: { value: query.parameters, enumerable: options.debug },
diff --git a/deno/README.md b/deno/README.md
@@ -533,7 +533,7 @@ for await (const chunk of readableStream) {
 }
 ```
 
-> **NOTE** This is a low-level API which does not provide any type safety. To make this work, you must match your [`copy query` parameters](https://www.postgresql.org/docs/14/sql-copy.html) correctly to your [Node.js stream read or write](https://nodejs.org/api/stream.html) code. Ensure [Node.js stream backpressure](https://nodejs.org/en/docs/guides/backpressuring-in-streams/) is handled correctly to avoid memory exhaustion.
+> **NOTE** This is a low-level API which does not provide any type safety. To make this work, you must match your [`copy query` parameters](https://www.postgresql.org/docs/14/sql-copy.html) correctly to your [Node.js stream read or write](https://nodejs.org/api/stream.html) code. Ensure [Node.js stream backpressure](https://nodejs.org/en/learn/modules/backpressuring-in-streams) is handled correctly to avoid memory exhaustion.
 
 ### Canceling Queries in Progress
 
diff --git a/deno/src/connection.js b/deno/src/connection.js
@@ -388,7 +388,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose
   }
 
   function queryError(query, err) {
-    Object.defineProperties(err, {
+    'query' in err || 'parameters' in err || Object.defineProperties(err, {
       stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug },
       query: { value: query.string, enumerable: options.debug },
       parameters: { value: query.parameters, enumerable: options.debug },
diff --git a/deno/tests/index.js b/deno/tests/index.js
@@ -2583,4 +2583,4 @@ t('arrays in reserved connection', async() => {
   ]
 })
 
-;window.addEventListener("unload", () => Deno.exit(process.exitCode))
+;globalThis.addEventListener("unload", () => Deno.exit(process.exitCode))

Original file line number	Diff line number	Diff line change
`@@ -387,7 +387,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`387`	`387`	`}`
`388`	`388`
`389`	`389`	`function queryError(query, err) {`
`390`		`- Object.defineProperties(err, {`
	`390`	`+ 'query' in err \|\| 'parameters' in err \|\| Object.defineProperties(err, {`
`391`	`391`	`stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug },`
`392`	`392`	`query: { value: query.string, enumerable: options.debug },`
`393`	`393`	`parameters: { value: query.parameters, enumerable: options.debug },`
Original file line number	Diff line number	Diff line change
`@@ -385,7 +385,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`385`	`385`	`}`
`386`	`386`
`387`	`387`	`function queryError(query, err) {`
`388`		`- 'parameters' in err \|\| Object.defineProperties(err, {`
	`388`	`+ 'query' in err \|\| 'parameters' in err \|\| Object.defineProperties(err, {`
`389`	`389`	`stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug },`
`390`	`390`	`query: { value: query.string, enumerable: options.debug },`
`391`	`391`	`parameters: { value: query.parameters, enumerable: options.debug },`
Original file line number	Diff line number	Diff line change
`@@ -533,7 +533,7 @@ for await (const chunk of readableStream) {`
`533`	`533`	`}`
`534`	`534`	```
`535`	`535`
`536`		-> NOTE This is a low-level API which does not provide any type safety. To make this work, you must match your [`copy query` parameters](https://www.postgresql.org/docs/14/sql-copy.html) correctly to your [Node.js stream read or write](https://nodejs.org/api/stream.html) code. Ensure [Node.js stream backpressure](https://nodejs.org/en/docs/guides/backpressuring-in-streams/) is handled correctly to avoid memory exhaustion.
	`536`	+> NOTE This is a low-level API which does not provide any type safety. To make this work, you must match your [`copy query` parameters](https://www.postgresql.org/docs/14/sql-copy.html) correctly to your [Node.js stream read or write](https://nodejs.org/api/stream.html) code. Ensure [Node.js stream backpressure](https://nodejs.org/en/learn/modules/backpressuring-in-streams) is handled correctly to avoid memory exhaustion.
`537`	`537`
`538`	`538`	`### Canceling Queries in Progress`
`539`	`539`
Original file line number	Diff line number	Diff line change
`@@ -388,7 +388,7 @@ function Connection(options, queues = {}, { onopen = noop, onend = noop, onclose`
`388`	`388`	`}`
`389`	`389`
`390`	`390`	`function queryError(query, err) {`
`391`		`- Object.defineProperties(err, {`
	`391`	`+ 'query' in err \|\| 'parameters' in err \|\| Object.defineProperties(err, {`
`392`	`392`	`stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug },`
`393`	`393`	`query: { value: query.string, enumerable: options.debug },`
`394`	`394`	`parameters: { value: query.parameters, enumerable: options.debug },`
Original file line number	Diff line number	Diff line change
`@@ -2583,4 +2583,4 @@ t('arrays in reserved connection', async() => {`
`2583`	`2583`	`]`
`2584`	`2584`	`})`
`2585`	`2585`
`2586`		`-;window.addEventListener("unload", () => Deno.exit(process.exitCode))`
	`2586`	`+;globalThis.addEventListener("unload", () => Deno.exit(process.exitCode))`