Poll Transfer events, populate daily_fil table, reformat endpoint handling

Author: PatrickNercessian

bin/spark-stats.js

@@ -1,9 +1,14 @@
 import '../lib/instrument.js'
+import { ethers } from 'ethers'
 import http from 'node:http'
 import { once } from 'node:events'
+import fs from 'node:fs/promises'
+import { fileURLToPath } from 'node:url'
+import { onContractEvent } from 'on-contract-event'
 import pg from 'pg'
 import { createHandler } from '../lib/handler.js'
-import { DATABASE_URL } from '../lib/config.js'
+import { DATABASE_URL, IE_CONTRACT_ADDRESS, RPC_URL, rpcHeaders } from '../lib/config.js'
+import { updateDailyFilStats } from '../lib/platform-stats-generator.js'
 
 const {
   PORT = 8080,
@@ -50,3 +55,40 @@ console.log('Starting the http server on host %j port %s', HOST, PORT)
 server.listen(PORT, HOST)
 await once(server, 'listening')
 console.log(`http://${HOST}:${PORT}`)
+
+// Set up the Ethereum provider and contract
+const fetchRequest = new ethers.FetchRequest(RPC_URL)
+fetchRequest.setHeader('Authorization', rpcHeaders.Authorization || '')
+const provider = new ethers.JsonRpcProvider(
+  fetchRequest,
+  null,
+  { batchMaxCount: 1 }
+)
+const ieContract = new ethers.Contract(
+  IE_CONTRACT_ADDRESS,
+  JSON.parse(
+    await fs.readFile(
+      fileURLToPath(new URL('../lib/abi.json', import.meta.url)),
+      'utf8'
+    )
+  ),
+  provider
+)
+
+const onTransfer = async (to, amount) => {
+  const transferEvent = { to_address: to, amount }
+  updateDailyFilStats(pgPool, transferEvent)
+}
+
+// Listen for Transfer events from the IE contract
+const it = onContractEvent({
+  contract: ieContract,
+  provider,
+  rpcUrl: RPC_URL,
+  rpcHeaders
+})
+for await (const event of it) {
+  if (event.name === 'Transfer') {
+    await onTransfer(...event.args)
+  }
+}