From cf27afb5b291eb611a456946f0ae86dfdd3f1a5e Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Tue, 11 Jun 2024 11:24:19 +0800
Subject: [PATCH] 1

---
 server/web3webhooks/controllers/webhooks.js | 33 +++++++++++++++++++++
 1 file changed, 33 insertions(+)

diff --git a/server/web3webhooks/controllers/webhooks.js b/server/web3webhooks/controllers/webhooks.js
index a9c4ef9..bdd308c 100644
--- a/server/web3webhooks/controllers/webhooks.js
+++ b/server/web3webhooks/controllers/webhooks.js
@@ -6,6 +6,39 @@ const metaFactory = require('../metadata/factory');
 const serviceFactory = require('../services/factory');
 
 async function webhooks(req, rsp) {
+  console.log(req.body);
+  const idx = 0;
+  const dbKey = 'BcEventDb' + idx;
+  const {err, conn} = await app.getDbConn(dbKey);
+  if (err) {
+    console.log(err);
+    return;
+  }
+  try {
+    const body = req.body;
+    const messageType = body.Type;
+    const messageId = body.MessageId;
+    const eventName = body.Message.event_name;
+    const eventId = body.Message.event_id;
+    const chain = body.Message.chain;
+    conn.upsert(
+      't_webhook_event',
+      [
+        ['event_id', eventId],
+      ],
+      [],
+      [
+        ['message_type', messageType],
+        ['message_id', messageId],
+        ['event_name', eventName],
+        ['event_id', eventId],
+        ['chain', chain],
+        ['raw_data', body],
+      ]
+    );
+  } finally {
+    conn.release();
+  }
 }
 
 function init() {