From 723b39c6ab326ad8a3c34397cf6fa8937974265f Mon Sep 17 00:00:00 2001
From: Alexey Churkin <alx.churkin@gmail.com>
Date: Wed, 26 Jun 2024 16:06:24 +0200
Subject: [PATCH] Retrieve deBridge turnover from/to Solana from the api

---
 src/adapters/debridgedln/index.ts | 66 ++++++++++++++++++++-----------
 1 file changed, 43 insertions(+), 23 deletions(-)

diff --git a/src/adapters/debridgedln/index.ts b/src/adapters/debridgedln/index.ts
index 6a69c763..6ced7801 100644
--- a/src/adapters/debridgedln/index.ts
+++ b/src/adapters/debridgedln/index.ts
@@ -1,5 +1,9 @@
 import { BridgeAdapter, PartialContractEventParams } from "../../helpers/bridgeAdapter.type";
 import { getTxDataFromEVMEventLogs } from "../../helpers/processTransactions";
+import { ethers } from "ethers";
+import fetch from "node-fetch";
+import { EventData } from "../../utils/types";
+const retry = require("async-retry");
 
 /**
  * deBridge is a messaging infrastructure. DLN is a cross-chain trading infrastructure
@@ -49,28 +53,6 @@ const depositPrarms: PartialContractEventParams = {
   isDeposit: true,
 };
 
-// since doesn't support solana, need set withdraw = deposit
-// after support solana, change to original withdraw
-// const withdrawParams: PartialContractEventParams = {
-//   target: evmContracts.dlnSource,
-//   topic:
-//     "CreatedOrder((uint64,bytes,uint256,bytes,uint256,uint256,bytes,uint256,bytes,bytes,bytes,bytes,bytes,bytes),bytes32,bytes,uint256,uint256,uint32,bytes)",
-//   abi: [
-//     "event CreatedOrder((uint64 makerOrderNonce, bytes makerSrc, uint256 giveChainId, bytes giveTokenAddress, uint256 giveAmount, uint256 takeChainId, bytes takeTokenAddress, uint256 takeAmount, bytes receiverDst, bytes givePatchAuthoritySrc, bytes orderAuthorityAddressDst, bytes allowedTakerDst, bytes allowedCancelBeneficiarySrc, bytes externalCall) order, bytes32 orderId, bytes affiliateFee, uint256 nativeFixFee, uint256 percentFee, uint32 referralCode, bytes metadata)",
-//   ],
-//   logKeys: {
-//     blockNumber: "blockNumber",
-//     txHash: "transactionHash",
-//   },
-//   argKeys: {
-//     amount: "order.giveAmount",
-//     to: "order.receiverDst",
-//     from: "order.makerSrc",
-//     token: "order.giveTokenAddress",
-//   },
-//   isDeposit: false,
-// };
-
 const withdrawParams: PartialContractEventParams = {
   target: evmContracts.dlnDestination,
   topic:
@@ -113,7 +95,44 @@ const constructParams = (chain: SupportedChains) => {
     getTxDataFromEVMEventLogs("debridgedln", chain, fromBlock, toBlock, eventParams);
 };
 
-// need add solana and heco
+type ApiSolanaEvent = {
+  blockNumber: number,
+  txHash: string,
+  from: string,
+  to: string,
+  token: string,
+  amount: string,
+  isDeposit: boolean;
+  giveAmountUSD: number;
+}
+
+const solanaBlockNumberFirstUsedByDebridge = 166833820;
+
+const fetchSolanaEvents = async (fromBlock: number, toBlock: number): Promise<ApiSolanaEvent[]> => {
+  return retry(() => fetch(
+    `https://stats-api.dln.trade/api/OrderEvents/solanaDepositsAndWithdrawals?fromBlock=${fromBlock}&toBlock=${toBlock}`
+    )
+    .then(res => res.json())
+  )
+}
+
+const getSolanaEvents = async (fromBlock: number, toBlock: number): Promise<EventData[]> => {
+  // Performance optimization: deBridge does not have any orders from Solana prior this block
+  if (toBlock < solanaBlockNumberFirstUsedByDebridge) {
+    return [];
+  }
+
+  const events = await fetchSolanaEvents(fromBlock, toBlock)
+
+  return events.map((event) => (<EventData>{
+    ...event,
+    token: event.token === '11111111111111111111111111111111'
+      ? 'So11111111111111111111111111111111111111112'
+      : event.token,
+    amount: ethers.BigNumber.from(Math.round(event.giveAmountUSD)),
+    isUSDVolume: true,
+  }));
+};
 
 const adapter: BridgeAdapter = {
   ethereum: constructParams("ethereum"),
@@ -125,6 +144,7 @@ const adapter: BridgeAdapter = {
   linea: constructParams("linea"),
   optimism: constructParams("optimism"),
   base: constructParams("base"),
+  solana: getSolanaEvents,
 };
 
 export default adapter;