RWA CLI, coins (#11336)

* RWA CLI

* afiUSD

Author: waynebruce0x

coins/src/adapters/yield/misc4626/tokens.json

@@ -98,7 +98,8 @@
     "wstETH_WETH_x12_AAVEV3": "0xa260b049ddD6567E739139404C7554435c456d9E", 
     "wstrBTC": "0xA3Ca88cfb7bBe9CfBd47df053ffA2130C7E6f770", 
     "gtusdcf": "0xc582F04d8a82795aa2Ff9c8bb4c1c889fe7b754e", 
-    "yPrism": "0xdd5eff0756db08bad0ff16b66f88f506e7318894"
+    "yPrism": "0xdd5eff0756db08bad0ff16b66f88f506e7318894", 
+    "afiUSD": "0x0b4c655bc989baafe728f8270ff988a7c2b40fd1"
   },
   "arbitrum": {
     "voltGNS": "0x39ff5098081fbe1ab241c31fe0a9974fe9891d04",

defi/src/rwa/refill.ts defi/src/rwa/cli/refill.tsdefi/src/rwa/refill.ts renamed to defi/src/rwa/cli/refill.ts

@@ -1,7 +1,7 @@
 import { runInPromisePool } from "@defillama/sdk/build/generalUtil";
-import atvl from './atvl';
-import { getCurrentUnixTimestamp, getTimestampAtStartOfDay } from "../utils/date";
-import { fetchTimestampsPG, initPG } from "./db";
+import atvl from '../atvl';
+import { getCurrentUnixTimestamp, getTimestampAtStartOfDay } from "../../utils/date";
+import { fetchTimestampsPG, initPG } from "../db";
 
 const start = 1735690215; // 1 Jan 2025
 const end = getCurrentUnixTimestamp()

defi/src/rwa/cli/resetActiveMcap.ts

@@ -0,0 +1,67 @@
+import { initPG, fetchMetadataPG, DAILY_RWA_DATA, HOURLY_RWA_DATA } from "../db";
+
+async function main() {
+    console.log('Finding RWA IDs with activeMcapData = false...');
+
+    await initPG();
+
+    // Fetch all metadata
+    const metadata = await fetchMetadataPG();
+    console.log(`Fetched metadata for ${metadata.length} RWA assets`);
+
+    // Find IDs where activeMcapData is false
+    const idsToReset: string[] = [];
+    metadata.forEach((m: any) => {
+        if (m.data && m.data.activeMcapData === false) {
+            idsToReset.push(m.id);
+        }
+    });
+
+    console.log(`Found ${idsToReset.length} IDs with activeMcapData = false:`);
+    console.log(idsToReset);
+
+    if (idsToReset.length === 0) {
+        console.log('No IDs to reset. Exiting.');
+        process.exit();
+    }
+
+    // Update DAILY_RWA_DATA for all found IDs
+    console.log('\nUpdating DAILY_RWA_DATA...');
+    const [dailyAffectedRows] = await DAILY_RWA_DATA.update(
+        {
+            activemcap: JSON.stringify({}),
+            aggregatedactivemcap: 0,
+            updated_at: new Date(),
+        },
+        {
+            where: {
+                id: idsToReset,
+            },
+        }
+    );
+
+    console.log(`Updated ${dailyAffectedRows} record(s) in DAILY_RWA_DATA`);
+
+    // Update HOURLY_RWA_DATA for all found IDs
+    console.log('\nUpdating HOURLY_RWA_DATA...');
+    const [hourlyAffectedRows] = await HOURLY_RWA_DATA.update(
+        {
+            activemcap: JSON.stringify({}),
+            aggregatedactivemcap: 0,
+            updated_at: new Date(),
+        },
+        {
+            where: {
+                id: idsToReset,
+            },
+        }
+    );
+
+    console.log(`Updated ${hourlyAffectedRows} record(s) in HOURLY_RWA_DATA`);
+
+    console.log(`\nCompleted! Reset activemcap and aggregatedactivemcap for ${idsToReset.length} IDs across all timestamps.`);
+}
+
+main().catch((e) => {
+    console.error(`Error resetting activeMcap:`, e);
+}); // ts-node defi/src/rwa/resetActiveMcap.ts

defi/src/rwa/cli/resetId.ts

@@ -0,0 +1,30 @@
+import { initPG, DAILY_RWA_DATA } from "../db";
+
+const id = '202'
+
+async function main() {
+    console.log(`Resetting defiactivetvl and aggregatedactivemcap for id: ${id}`);
+
+    await initPG();
+
+    const [affectedRows] = await DAILY_RWA_DATA.update(
+        {
+            defiactivetvl: JSON.stringify({}),
+            aggregatedefiactivetvl: 0,
+            updated_at: new Date(),
+        },
+        {
+            where: {
+                id: id,
+            },
+        }
+    );
+
+    console.log(`Updated ${affectedRows} record(s) for id: ${id}`);
+    process.exit();
+}
+
+main().catch((e) => {
+    console.error(`Error resetting`, e);
+    process.exit(1);
+}); // ts-node defi/src/rwa/resetId.ts

defi/src/rwa/db.ts

@@ -2,8 +2,8 @@ import { getCurrentUnixTimestamp, getTimestampAtStartOfDay, secondsInDay } from
 import { DataTypes, Model, Op, QueryTypes, Sequelize } from 'sequelize'
 
 class META_RWA_DATA extends Model { }
-class DAILY_RWA_DATA extends Model { }
-class HOURLY_RWA_DATA extends Model { }
+export class DAILY_RWA_DATA extends Model { }
+export class HOURLY_RWA_DATA extends Model { }
 class BACKUP_RWA_DATA extends Model { }
 
 let pgConnection: any;