feat: update proposal's value

Author: wa0x6e

src/scores.ts

@@ -97,6 +97,26 @@ async function updateProposalScores(proposalId: string, scores: any, votes: numb
   ]);
 }
 
+async function updateProposalScoresValue(
+  proposalId: string,
+  score_by_strategy_by_choice: number[][]
+) {
+  const scores_by_strategy =
+    score_by_strategy_by_choice?.[0]
+      ?.map((_, index) => score_by_strategy_by_choice.reduce((sum, array) => sum + array[index], 0))
+      ?.map(score => parseFloat(score.toFixed(9))) || [];
+
+  const score_total_value = scores_by_strategy.reduce((sum, score) => sum + score, 0);
+
+  const query = `
+    UPDATE proposals
+    SET scores_total_value = ?,
+    scores_by_strategy = ?
+    WHERE id = ? LIMIT 1;
+  `;
+  await db.queryAsync(query, [score_total_value, JSON.stringify(scores_by_strategy), proposalId]);
+}
+
 const pendingRequests = {};
 
 export async function updateProposalAndVotes(proposalId: string, force = false) {
@@ -186,6 +206,9 @@ export async function updateProposalAndVotes(proposalId: string, force = false)
     );
 
     delete pendingRequests[proposalId];
+
+    await updateProposalScoresValue(proposalId, results.scores_by_strategy);
+
     return true;
   } catch (e) {
     delete pendingRequests[proposalId];

test/schema.sql

@@ -64,7 +64,7 @@ CREATE TABLE proposals (
   scores_state VARCHAR(24) NOT NULL DEFAULT '',
   scores_total DECIMAL(64,30) NOT NULL,
   scores_updated INT(11) NOT NULL,
-  scores_total_value DECIMAL(64,30) NOT NULL DEFAULT '0.000000000000000000000000000000',
+  scores_total_value DECIMAL(13,3) NOT NULL DEFAULT 0.000,
   vp_value_by_strategy json NOT NULL,
   votes INT(12) NOT NULL,
   flagged INT NOT NULL DEFAULT 0,