Add details about underlying message types on input message protocol …

…errors Signed-off-by: Aman Karmani <[email protected]>
connectrpc · Sep 28, 2024 · 80f838c · 80f838c
1 parent b735d79
commit 80f838c
Showing 1 changed file with 24 additions and 0 deletions.
diff --git a/packages/connect/src/protocol/invoke-implementation.ts b/packages/connect/src/protocol/invoke-implementation.ts
@@ -151,6 +151,14 @@ export function transformInvokeImplementation<
           throw new ConnectError(
             "protocol error: received extra input message for unary method",
             Code.Unimplemented,
+            {
+              methodName: spec.method.name,
+              serviceTypeName: spec.service.typeName,
+              inputTypeName: spec.method.I.typeName,
+              outputTypeName: spec.method.O.typeName,
+              url: context.url,
+              requestMethod: context.requestMethod,
+            }
           );
         }
       };
@@ -162,6 +170,14 @@ export function transformInvokeImplementation<
           throw new ConnectError(
             "protocol error: missing input message for server-streaming method",
             Code.Unimplemented,
+            {
+              methodName: spec.method.name,
+              serviceTypeName: spec.service.typeName,
+              inputTypeName: spec.method.I.typeName,
+              outputTypeName: spec.method.O.typeName,
+              url: context.url,
+              requestMethod: context.requestMethod,
+            }
           );
         }
         const anyFn = async (
@@ -209,6 +225,14 @@ export function transformInvokeImplementation<
           throw new ConnectError(
             "protocol error: received extra input message for server-streaming method",
             Code.Unimplemented,
+            {
+              methodName: spec.method.name,
+              serviceTypeName: spec.service.typeName,
+              inputTypeName: spec.method.I.typeName,
+              outputTypeName: spec.method.O.typeName,
+              url: context.url,
+              requestMethod: context.requestMethod,
+            }
           );
         }
       };