fix handling of destroyed/errored streams in waitDrain()

common/changes/@subsquid/util-internal-http-server/master_2024-03-17-23-17.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@subsquid/util-internal-http-server",
+      "comment": "remove unused import statement",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@subsquid/util-internal-http-server"
+}

common/changes/@subsquid/util-internal/master_2024-03-17-23-17.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@subsquid/util-internal",
+      "comment": "fix handling of destroyed/errored streams in `waitDrain()`",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@subsquid/util-internal"
+}

util/util-internal-http-server/src/app.ts

@@ -1,6 +1,5 @@
 import {createLogger, Logger} from '@subsquid/logger'
 import assert from 'assert'
-import * as buffer from 'buffer'
 import {HttpContext, HttpContextOptions, HttpRequest, HttpResponse} from './ctx'
 import {isHttpError} from './http-error'
 import {GetPatternParams, PathPattern} from './path-pattern'

util/util-internal/src/io.ts

@@ -4,12 +4,13 @@ import {ensureError} from './misc'
 
 export function waitDrain(out: Writable): Promise<void> {
     return new Promise((resolve, reject) => {
-        if (!out.writableNeedDrain) return resolve()
-
-        if (!out.writable) {
+        // https://github.com/nodejs/node/issues/42610
+        if (!out.writable || out.destroyed || out.errored || out.writableEnded) {
             return reject(new Error('output stream is no longer writable'))
         }
 
+        if (!out.writableNeedDrain) return resolve()
+
         function cleanup() {
             out.removeListener('error', error)
             out.removeListener('drain', drain)