staking: migrate from discovery and fix prod runtime + build issues

apps/staking/package.json

@@ -3,16 +3,18 @@
   "version": "0.0.2",
   "private": true,
   "scripts": {
-    "start": "npx tsx ./src/index.ts",
+    "build": "tsc",
+    "clean": "rm -rf dist",
     "dev": "npx tsx watch ./src/index.ts",
-    "test": "vitest",
-    "lint": "tsc --noEmit && eslint \"src/**/*.ts*\""
+    "lint": "tsc --noEmit && eslint \"src/**/*.ts*\"",
+    "start": "node ./dist/index.js",
+    "test": "vitest"
   },
   "jest": {
     "preset": "jest-presets/jest/node"
   },
   "dependencies": {
-    "@audius/eth": "0.1.0",
+    "@audius/eth": "1.0.0",
     "@audius/sdk": "10.0.0",
     "@pedalboard/basekit": "*",
     "@pedalboard/logger": "*",

apps/staking/src/index.ts

@@ -10,6 +10,8 @@ import dotenv from 'dotenv'
 
 dotenv.config()
 
+const PORT = 6000
+
 export type SharedData = {
   ethRpcEndpoint: string
   viemClient: PublicClient<HttpTransport, typeof mainnet>
@@ -27,7 +29,7 @@ const main = async () => {
       chain: mainnet,
       transport: http(process.env.eth_rpc_endpoint!)
     }),
-    port: process.env.port ? parseInt(process.env.port) : 6000
+    port: PORT
   }
   await new App<SharedData>({ appData: sharedData })
     .task(async (app: App<SharedData>) => {

apps/staking/src/routes/health.ts

@@ -2,11 +2,11 @@ import { NextFunction, Request, Response } from 'express'
 import { App } from '@pedalboard/basekit'
 import { SharedData } from '..'
 
-export const health = (app: App<SharedData>) => async (
-  req: Request,
+export const health = (_app: App<SharedData>) => async (
+  _req: Request,
   res: Response,
   next: NextFunction
 ) => {
-  res.send({ status: 'up', port: app.viewAppData().port })
+  res.send({ status: 'ok' })
   next()
 }

apps/staking/src/routes/initRound.ts

@@ -2,19 +2,33 @@ import { NextFunction, Request, Response } from 'express'
 import { App } from '@pedalboard/basekit'
 import { SharedData } from '..'
 import { ClaimsManager } from '@audius/eth'
-import { PublicClient } from 'viem'
 
 export const initRound = (app: App<SharedData>) => async (
   req: Request,
   res: Response,
   next: NextFunction
 ) => {
   const { viemClient } = app.viewAppData()
-  const claimsManager = new ClaimsManager(viemClient as PublicClient)
 
-  const latestBlock = Number((await viemClient.getBlock()).number)
-  const lastFundedBlockNumber = Number(await claimsManager.getLastFundedBlock())
-  const fundingRoundBlockDiff = Number(await claimsManager.getFundingRoundBlockDiff())
+  const [latestBlock, lastFundedBlockNumber, fundingRoundBlockDiff] =
+    await Promise.all([
+      viemClient.getBlock().then((b) => Number(b.number)),
+      viemClient
+        .readContract({
+          abi: ClaimsManager.abi,
+          address: ClaimsManager.address,
+          functionName: 'getLastFundedBlock'
+        })
+        .then(Number),
+      viemClient
+        .readContract({
+          abi: ClaimsManager.abi,
+          address: ClaimsManager.address,
+          functionName: 'getFundingRoundBlockDiff'
+        })
+        .then(Number)
+    ])
+
   const blockDiff = latestBlock - lastFundedBlockNumber
 
   if (lastFundedBlockNumber < latestBlock - 1.1 * fundingRoundBlockDiff) {
@@ -23,7 +37,7 @@ export const initRound = (app: App<SharedData>) => async (
       lastFundedBlockNumber,
       latestBlock,
       fundingRoundBlockDiff,
-      blockDiff,
+      blockDiff
     })
     next()
     return
@@ -34,8 +48,7 @@ export const initRound = (app: App<SharedData>) => async (
     lastFundedBlockNumber,
     latestBlock,
     fundingRoundBlockDiff,
-    blockDiff,
+    blockDiff
   })
   next()
 }
-