From 052af317a3cbd0b8888502c2f232ef76f0af1873 Mon Sep 17 00:00:00 2001
From: murgatroid99 <mlumish@google.com>
Date: Mon, 28 Mar 2022 14:06:04 -0700
Subject: [PATCH] grpc-js: Avoid surfacing errors without gRPC error codes

---
 packages/grpc-js/src/call-stream.ts | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/packages/grpc-js/src/call-stream.ts b/packages/grpc-js/src/call-stream.ts
index 4eff39eb..e8f31275 100644
--- a/packages/grpc-js/src/call-stream.ts
+++ b/packages/grpc-js/src/call-stream.ts
@@ -839,7 +839,16 @@ export class Http2CallStream implements Call {
       message,
       flags: context.flags,
     };
-    const cb: WriteCallback = context.callback ?? (() => {});
+    const cb: WriteCallback = (error?: Error | null) => {
+      let code: Status = Status.UNAVAILABLE;
+      if ((error as NodeJS.ErrnoException)?.code === 'ERR_STREAM_WRITE_AFTER_END') {
+        code = Status.INTERNAL;
+      }
+      if (error) {
+        this.cancelWithStatus(code, `Write error: ${error.message}`);
+      }
+      context.callback?.();
+    };
     this.isWriteFilterPending = true;
     this.filterStack.sendMessage(Promise.resolve(writeObj)).then((message) => {
       this.isWriteFilterPending = false;