fix non responsive node attestation (#6966)

AudiusProject · Dec 19, 2023 · a46ca96 · a46ca96
1 parent 8967859
commit a46ca96
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 8 deletions.
diff --git a/packages/discovery-provider/plugins/pedalboard/apps/trending-challenge-rewards/src/app.ts b/packages/discovery-provider/plugins/pedalboard/apps/trending-challenge-rewards/src/app.ts
@@ -137,8 +137,13 @@ const canSuccessfullyAttest = async (
     challengeId,
     oracleEthAddress
   )
-  const res = await fetch(url)
-  return res && res.ok
+  try {
+      const res = await fetch(url)
+      return res && res.ok;
+  } catch (e) {
+      console.warn("Can't attest", e, url)
+      return false
+  }
 }
 
 const makeAttestationEndpoint = (
@@ -218,7 +223,7 @@ const getAllChallenges = async (
     // select again if needed
     if (!isValidNodeSet) {
       possibleNodeSet = []
-      console.log('Node set not valid. Selecting nodes...')
+      console.log('Node set not valid. Selecting nodes...', possibleNodeSet)
       for (const nodeGroup of groups.values()) {
         if (possibleNodeSet.length === 3) {
           console.log(`Got 3 nodes!: ${JSON.stringify(possibleNodeSet)}`)
@@ -248,9 +253,9 @@ const getAllChallenges = async (
     // did we succeed?
     if (possibleNodeSet.length !== 3) {
       console.log(
-        `Could not find a valid node set for challenge: ${JSON.stringify(
-          challenge
-        )}, skipping.`
+        `Could not find a valid node set for challenge: ${
+          challenge.specifier
+        }, skipping.`, possibleNodeSet
       )
       impossibleChallenges.push(challenge)
       // reset it for next time

diff --git a/packages/discovery-provider/plugins/pedalboard/apps/trending-challenge-rewards/src/libs.ts b/packages/discovery-provider/plugins/pedalboard/apps/trending-challenge-rewards/src/libs.ts
@@ -13,6 +13,7 @@ export const initAudiusLibs = async (): Promise<AudiusLibs> => {
       rewardsManagerProgramId: process.env.rewardsManagerProgramId,
       rewardsManagerProgramPDA: process.env.rewardsManagerProgramPDA,
       rewardsManagerTokenPDA: process.env.rewardsManagerTokenPDA,
+      usdcMintAddress: process.env.usdcMintAddress,
       useRelay: process.env.useRelay,
     },
     ethWeb3Config: {

diff --git a/...ages/discovery-provider/plugins/pedalboard/apps/trending-challenge-rewards/src/queries.ts b/...ages/discovery-provider/plugins/pedalboard/apps/trending-challenge-rewards/src/queries.ts
@@ -54,8 +54,8 @@ export const getChallengesDisbursementsUserbanks = async (
 export const getChallengesDisbursementsUserbanksFriendly = async (
   discoveryDb: Knex,
   specifier: string
-): Promise<ChallengeDisbursementUserbankFriendly[]> =>
-  await discoveryDb<ChallengeDisbursementUserbankFriendly>(
+): Promise<ChallengeDisbursementUserbankFriendly[]> => {
+  const query =  discoveryDb<ChallengeDisbursementUserbankFriendly>(
     'user_challenges as u'
   )
     .select(
@@ -79,6 +79,9 @@ export const getChallengesDisbursementsUserbanksFriendly = async (
     .orderBy('u.challenge_id')
     .orderBy('u.specifier')
 
+    return await query
+  }
+
 export const getChallengesDisbursementsUserbanksFriendlyEnsureSlots = async (
   discoveryDb: Knex,
   specifier: string