From 60da68c342f5fee1f46ea83cbabd84b8d20c9541 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Tue, 11 Jun 2024 17:35:21 +0800
Subject: [PATCH] 1

---
 server/web3webhooks/controllers/webhooks.js | 68 +++++++++++----------
 1 file changed, 36 insertions(+), 32 deletions(-)

diff --git a/server/web3webhooks/controllers/webhooks.js b/server/web3webhooks/controllers/webhooks.js
index 50caf0c..968ba32 100644
--- a/server/web3webhooks/controllers/webhooks.js
+++ b/server/web3webhooks/controllers/webhooks.js
@@ -6,7 +6,39 @@ const metaFactory = require('../metadata/factory');
 const serviceFactory = require('../services/factory');
 const { config, webhook } = require('@imtbl/sdk');
 
-async function procEvent(req, rsp) {
+async function procEvent(event, rsp) {
+  const idx = 0;
+  const dbKey = 'BcEventDb' + idx;
+  const {err, conn} = await app.getDbConn(dbKey);
+  if (err) {
+    rsp.status(500).send(err);
+    console.log(err);
+    return;
+  }
+  try {
+    const eventName = event.event_name;
+    const eventId = event.event_id;
+    const chain = event.chain;
+    await conn.upsert(
+      't_webhook_event',
+      [
+        ['event_id', eventId],
+      ],
+      [],
+      [
+        ['event_name', eventName],
+        ['event_id', eventId],
+        ['chain', chain],
+        ['raw_data', utils.jsonEncode(event)],
+      ]
+    );
+    rsp.send(utils.jsonEncode({"status": "ok"}));
+  } catch (e) {
+    console.log(e);
+    rsp.status(500).send(e);
+  } finally {
+    conn.release();
+  }
 }
 
 async function webhooks(req, rsp) {
@@ -23,38 +55,10 @@ async function webhooks(req, rsp) {
     }
   );
 
-  const idx = 0;
-  const dbKey = 'BcEventDb' + idx;
-  const {err, conn} = await app.getDbConn(dbKey);
-  if (err) {
-    rsp.status(500).send(err);
-    console.log(err);
-    return;
-  }
-  try {
-    const body = req.body;
-    const eventName = body.Message.event_name;
-    const eventId = body.Message.event_id;
-    const chain = body.Message.chain;
-    await conn.upsert(
-      't_webhook_event',
-      [
-        ['event_id', eventId],
-      ],
-      [],
-      [
-        ['event_name', eventName],
-        ['event_id', eventId],
-        ['chain', chain],
-        ['raw_data', body],
-      ]
-    );
+  if (events.length > 0) {
+
+  } else {
     rsp.send(utils.jsonEncode({"status": "ok"}));
-  } catch (e) {
-    console.log(e);
-    rsp.status(500).send(e);
-  } finally {
-    conn.release();
   }
 }