fix data insertion for cluster matching

Giveth · Jan 22, 2025 · 54fa338 · 54fa338
1 parent 734dbab
commit 54fa338
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/src/adapters/cocmAdapter/cocmAdapter.ts b/src/adapters/cocmAdapter/cocmAdapter.ts
@@ -35,7 +35,7 @@ export class CocmAdapter implements CocmAdapterInterface {
           i18n.__(translationErrorMessagesKeys.CLUSTER_MATCHING_API_ERROR),
         );
       }
-      return result.data;
+      return result.data.matching_data;
     } catch (e) {
       logger.error('clusterMatchingApi error', e);
       throw new Error(

diff --git a/src/services/cronJobs/syncEstimatedClusterMatchingJob.ts b/src/services/cronJobs/syncEstimatedClusterMatchingJob.ts
@@ -40,7 +40,8 @@ export const fetchAndUpdateClusterEstimatedMatching = async () => {
     votes_data: clusterMatchingDonations,
     strategy: defaultMatchingStrategy,
     min_donation_threshold_amount: activeQfRound.minimumValidUsdValue,
-    matching_cap_amount: activeQfRound.allocatedFundUSD * activeQfRound.maximumReward,
+    matching_cap_amount:
+      activeQfRound.allocatedFundUSD * activeQfRound.maximumReward,
     matching_amount: activeQfRound.allocatedFundUSD,
     passport_threshold: activeQfRound.minimumPassportScore,
   };

diff --git a/src/workers/cocm/estimatedClusterMatchingWorker.ts b/src/workers/cocm/estimatedClusterMatchingWorker.ts
@@ -24,11 +24,12 @@ const worker: EstimatedClusterMatchingWorker = {
       const params: any[] = [];
       const values = matchingData
         .map((data, index) => {
+          const baseIndex = index * 3;
           params.push(data.project_name, qfRoundId, data.matching_amount);
           return `(
-            (SELECT id FROM project WHERE title = $${index * 3 + 1}),
-            $${index * 3 + 2},
-            $${index * 3 + 3}
+            (SELECT id FROM project WHERE title = $${baseIndex + 1}),
+            $${baseIndex + 2},
+            $${baseIndex + 3}
           )`;
         })
         .join(',');