improve error logging

quant-daddy · Feb 8, 2025 · d6c910d · d6c910d
1 parent fb6e2ab
commit d6c910d
Show file tree

Hide file tree

Showing 2 changed files with 31 additions and 0 deletions.
diff --git a/.changeset/witty-elephants-visit.md b/.changeset/witty-elephants-visit.md
@@ -0,0 +1,5 @@
+---
+"graphql-eventbus": patch
+---
+
+error log
diff --git a/packages/core/src/GraphQLEventbus.ts b/packages/core/src/GraphQLEventbus.ts
@@ -224,6 +224,17 @@ export class GraphQLEventbus {
         );
       }
     } catch (e) {
+      console.error(
+        "Consume failed for the payload ",
+        JSON.stringify(
+          {
+            topic,
+            data: baggage.payload,
+          },
+          null,
+          2,
+        ),
+      );
       if (consumeErrorHooks.length) {
         await Promise.all(
           consumeErrorHooks.map((hook) => {
@@ -306,6 +317,21 @@ export class GraphQLEventbus {
         );
       }
     } catch (e) {
+      console.error(
+        "Publish failed for the payload ",
+        JSON.stringify(
+          {
+            topic: props.topic,
+            baggage: {
+              metadata,
+              payload: props.payload,
+            },
+            extra: props.extra,
+          },
+          null,
+          2,
+        ),
+      );
       if (publishErrorHooks.length) {
         await Promise.all(
           publishErrorHooks.map((hook) => {