logging liq pool data indexing

the-standard · Feb 26, 2024 · 7f60981 · 7f60981
1 parent 93c9077
commit 7f60981
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 9 deletions.
diff --git a/index.js b/index.js
@@ -12,7 +12,7 @@ schedulePricingIndexing();
 // scheduleStatIndexing();
 scheduleIndexYieldData();
 scheduleVaultTransactionIndexing();
-// scheduleLiquidationPoolData();
+scheduleLiquidationPoolData();
 
 const server = http.createServer(async (req, res) => {
   res.statusCode = 200;

diff --git a/src/liquidationPools.js b/src/liquidationPools.js
@@ -56,7 +56,7 @@ const fetchPrices = async (networkName, wallet) => {
 };
 
 const scheduleLiquidationPoolData = async _ => {
-  schedule.scheduleJob('22 * * * *', async _ => {
+  schedule.scheduleJob('* * * * *', async _ => {
     console.log('indexing liquidation pool snapshots')
     const network = getNetwork('arbitrum');
     const provider = new getDefaultProvider(network.rpc);
@@ -79,13 +79,14 @@ const scheduleLiquidationPoolData = async _ => {
         const now = new Date();
         const client = await pool.connect();
         try {
-          const query = 'INSERT INTO user_pool_snapshots (user_address,assets,snapshot_at) VALUES ($1,$2,$3);';
-          const data = [
-            holderAddress.toLowerCase(),
-            assets,
-            now
-          ];
-          await client.query(query, data);
+          console.log(POSTGRES_HOST, POSTGRES_PORT, POSTGRES_DB, POSTGRES_USERNAME, POSTGRES_PASSWORD.length)
+          // const query = 'INSERT INTO user_pool_snapshots (user_address,assets,snapshot_at) VALUES ($1,$2,$3);';
+          // const data = [
+          //   holderAddress.toLowerCase(),
+          //   assets,
+          //   now
+          // ];
+          // await client.query(query, data);
         } catch (e) {
           console.log(e);
         } finally {