Overnight rebase

adapters/overnight/package.json

@@ -19,6 +19,7 @@
     "bignumber.js": "^9.1.2",
     "csv-parser": "^3.0.0",
     "decimal.js-light": "^2.5.1",
+    "ethers": "^5.7.2",
     "fast-csv": "^5.0.1",
     "jsbi": "^4.3.0",
     "tiny-invariant": "^1.3.1",

adapters/overnight/src/index.ts

@@ -1,5 +1,5 @@
-import { CHAINS, LP_LYNEX_SYMBOL, LP_LYNEX, PROTOCOLS, SNAPSHOTS_BLOCKS } from "./sdk/config";
-import { getLPValueByUserAndPoolFromPositions, getPositionsForAddressByPoolAtBlock, getTimestampAtBlock } from "./sdk/subgraphDetails";
+import { SNAPSHOTS_BLOCKS, OVN_CONTRACTS, LP_LYNEX, LP_LYNEX_SYMBOL, USD_PLUS_SYMBOL, USD_PLUS_LINEA, USDT_PLUS_SYMBOL, USDT_PLUS_LINEA } from "./sdk/config";
+import { getLPValueByUserAndPoolFromPositions, getUserTVLByBlock, getRebaseForUsersByPoolAtBlock, getTimestampAtBlock } from "./sdk/subgraphDetails";
 
 (BigInt.prototype as any).toJSON = function () {
   return this.toString();
@@ -19,40 +19,89 @@ interface CSVRow {
 
 const getData = async () => {
   const csvRows: CSVRow[] = [];
-
+  const csvRows_rebase: CSVRow[] = [];
+
   for (let block of SNAPSHOTS_BLOCKS) {
-    const positions = await getPositionsForAddressByPoolAtBlock(
-      block, "", "", CHAINS.LINEA, PROTOCOLS.OVN
-    );
+    const timestamp = new Date(await getTimestampAtBlock(block)).toISOString();
+    const positions = await getUserTVLByBlock({
+      blockNumber: block,
+      blockTimestamp: Number(timestamp),
+    });
 
-    console.log(`Block: ${block}`);
     console.log("Positions: ", positions.length);
-
     let lpValueByUsers = getLPValueByUserAndPoolFromPositions(positions);
 
-    const timestamp = new Date(await getTimestampAtBlock(block)).toISOString();
-
     lpValueByUsers.forEach((value, key) => {
       value.forEach((lpValue) => {
-        const lpValueStr = lpValue.toString();
-        // Accumulate CSV row data
-        csvRows.push({
-          user_address: key,
-          token_address: LP_LYNEX,
-          token_symbol: LP_LYNEX_SYMBOL,
-          token_balance: lpValueStr,
-          block_number: block.toString(),
-          timestamp
+          const lpValueStr = lpValue.toString();
+          // Accumulate CSV row data
+          csvRows.push({
+            user_address: key,
+            token_address: LP_LYNEX,
+            token_symbol: LP_LYNEX_SYMBOL,
+            token_balance: lpValueStr,
+            block_number: block.toString(),
+            timestamp
         });
+      })
+    });
+  }
+
+  // counting rebase by blocks range
+  // [0, 100, 200] -> gonna be counted like [0, 100] + [100, 200]
+  for (let [index, block] of SNAPSHOTS_BLOCKS.entries()) {
+    if (!SNAPSHOTS_BLOCKS[index + 1]) continue;
+    console.log(`Blocks: ${block} -> ${SNAPSHOTS_BLOCKS[index + 1]}`);
+
+    const positionsRebaseUsd = await getRebaseForUsersByPoolAtBlock({
+      blockNumberFrom: block,
+      blockNumberTo: SNAPSHOTS_BLOCKS[index + 1],
+      token: OVN_CONTRACTS.USDPLUS
+    });
+
+    const positionsRebaseUsdt = await getRebaseForUsersByPoolAtBlock({
+      blockNumberFrom: block,
+      blockNumberTo: SNAPSHOTS_BLOCKS[index + 1],
+      token: OVN_CONTRACTS.USDTPLUS
+    });
+
+    console.log("positionsRebase: ", positionsRebaseUsd.size);
+
+    // all results are counted for the END block
+    const timestamp = new Date(await getTimestampAtBlock(SNAPSHOTS_BLOCKS[index + 1])).toISOString();
+
+    positionsRebaseUsd.forEach((value, key) => {
+      csvRows_rebase.push({
+        user_address: key,
+        token_symbol: USD_PLUS_SYMBOL,
+        token_balance: value,
+        token_address: USD_PLUS_LINEA,
+        block_number: SNAPSHOTS_BLOCKS[index + 1].toString(),
+        timestamp
+      });
+    });
+
+    positionsRebaseUsdt.forEach((value, key) => {
+      csvRows_rebase.push({
+        user_address: key,
+        token_symbol: USDT_PLUS_SYMBOL,
+        token_balance: value,
+        token_address: USDT_PLUS_LINEA,
+        block_number: SNAPSHOTS_BLOCKS[index + 1].toString(),
+        timestamp
       });
     });
   }
 
   // Write the CSV output to a file
   const ws = fs.createWriteStream('outputData.csv');
+  const ws_rebase = fs.createWriteStream('outputData_rebase.csv');
   write(csvRows, { headers: true }).pipe(ws).on('finish', () => {
     console.log("CSV file has been written.");
   });
+  write(csvRows_rebase, { headers: true }).pipe(ws_rebase).on('finish', () => {
+    console.log("CSV file has been written.");
+  });
 };
 
 getData().then(() => {

adapters/overnight/src/sdk/abi.ts

@@ -0,0 +1,223 @@
+
+export const ERC20_ABI = [
+  {
+    constant: true,
+    inputs: [],
+    name: 'name',
+    outputs: [
+      {
+        name: '',
+        type: 'string',
+      },
+    ],
+    payable: false,
+    stateMutability: 'view',
+    type: 'function',
+  },
+  {
+    constant: false,
+    inputs: [
+      {
+        name: '_spender',
+        type: 'address',
+      },
+      {
+        name: '_value',
+        type: 'uint256',
+      },
+    ],
+    name: 'approve',
+    outputs: [
+      {
+        name: '',
+        type: 'bool',
+      },
+    ],
+    payable: false,
+    stateMutability: 'nonpayable',
+    type: 'function',
+  },
+  {
+    constant: true,
+    inputs: [],
+    name: 'totalSupply',
+    outputs: [
+      {
+        name: '',
+        type: 'uint256',
+      },
+    ],
+    payable: false,
+    stateMutability: 'view',
+    type: 'function',
+  },
+  {
+    constant: false,
+    inputs: [
+      {
+        name: '_from',
+        type: 'address',
+      },
+      {
+        name: '_to',
+        type: 'address',
+      },
+      {
+        name: '_value',
+        type: 'uint256',
+      },
+    ],
+    name: 'transferFrom',
+    outputs: [
+      {
+        name: '',
+        type: 'bool',
+      },
+    ],
+    payable: false,
+    stateMutability: 'nonpayable',
+    type: 'function',
+  },
+  {
+    constant: true,
+    inputs: [],
+    name: 'decimals',
+    outputs: [
+      {
+        name: '',
+        type: 'uint8',
+      },
+    ],
+    payable: false,
+    stateMutability: 'view',
+    type: 'function',
+  },
+  {
+    constant: true,
+    inputs: [
+      {
+        name: '_owner',
+        type: 'address',
+      },
+    ],
+    name: 'balanceOf',
+    outputs: [
+      {
+        name: 'balance',
+        type: 'uint256',
+      },
+    ],
+    payable: false,
+    stateMutability: 'view',
+    type: 'function',
+  },
+  {
+    constant: true,
+    inputs: [],
+    name: 'symbol',
+    outputs: [
+      {
+        name: '',
+        type: 'string',
+      },
+    ],
+    payable: false,
+    stateMutability: 'view',
+    type: 'function',
+  },
+  {
+    constant: false,
+    inputs: [
+      {
+        name: '_to',
+        type: 'address',
+      },
+      {
+        name: '_value',
+        type: 'uint256',
+      },
+    ],
+    name: 'transfer',
+    outputs: [
+      {
+        name: '',
+        type: 'bool',
+      },
+    ],
+    payable: false,
+    stateMutability: 'nonpayable',
+    type: 'function',
+  },
+  {
+    constant: true,
+    inputs: [
+      {
+        name: '_owner',
+        type: 'address',
+      },
+      {
+        name: '_spender',
+        type: 'address',
+      },
+    ],
+    name: 'allowance',
+    outputs: [
+      {
+        name: '',
+        type: 'uint256',
+      },
+    ],
+    payable: false,
+    stateMutability: 'view',
+    type: 'function',
+  },
+  {
+    payable: true,
+    stateMutability: 'payable',
+    type: 'fallback',
+  },
+  {
+    anonymous: false,
+    inputs: [
+      {
+        indexed: true,
+        name: 'owner',
+        type: 'address',
+      },
+      {
+        indexed: true,
+        name: 'spender',
+        type: 'address',
+      },
+      {
+        indexed: false,
+        name: 'value',
+        type: 'uint256',
+      },
+    ],
+    name: 'Approval',
+    type: 'event',
+  },
+  {
+    anonymous: false,
+    inputs: [
+      {
+        indexed: true,
+        name: 'from',
+        type: 'address',
+      },
+      {
+        indexed: true,
+        name: 'to',
+        type: 'address',
+      },
+      {
+        indexed: false,
+        name: 'value',
+        type: 'uint256',
+      },
+    ],
+    name: 'Transfer',
+    type: 'event',
+  },
+];