updates

thirdweb-dev · Sep 28, 2023 · 3a39830 · 3a39830
1 parent 3641c2c
commit 3a39830
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/server/controller/tx-update-listener.ts b/server/controller/tx-update-listener.ts
@@ -1,4 +1,5 @@
 import { connectToDatabase } from "../../core";
+import { getTxById } from "../../src/db/transactions/getTxById";
 import { env } from "../../src/utils/env";
 import { logger } from "../../src/utils/logger";
 
@@ -19,13 +20,15 @@ export const startTxUpdatesNotificationListener = async (): Promise<void> => {
         );
         const parsedPayload = JSON.parse(msg.payload);
         if (env.WEBHOOKS_ENABLED && env.WEBHOOK_URL.length > 0) {
+          const txData = await getTxById({ queueId: parsedPayload.id });
           const response = await fetch(env.WEBHOOK_URL!, {
             method: "POST",
             headers: {
+              Accept: "application/json",
               "Content-Type": "application/json",
               Authorization: `Bearer ${env.THIRDWEB_API_SECRET_KEY}`,
             },
-            body: JSON.stringify(parsedPayload),
+            body: JSON.stringify(txData),
           });
 
           logger.server.debug(

diff --git a/src/worker/tasks/retryTx.ts b/src/worker/tasks/retryTx.ts
@@ -13,10 +13,9 @@ export const retryTx = async () => {
   try {
     await prisma.$transaction(
       async (pgtx) => {
-        logger.worker.info(`[Transaction] Retrying`);
+        logger.worker.debug(`[Transaction] Retrying`);
         // Get one transaction to retry at a time
         const tx = await getTxToRetry({ pgtx });
-        console.log("tx", tx);
         if (!tx) {
           return;
         }