Merge pull request #49 from iluxonchik/feature/govbot-0.0.17

Feature/govbot 0.0.17 - Community Deliberation Votes Display
MinaFoundation · Sep 19, 2024 · b235e3d · b235e3d
2 parents d71f3c4 + 08fd677
commit b235e3d
Show file tree

Hide file tree

Showing 2 changed files with 48 additions and 4 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "mina-govbot",
-  "version": "0.0.16",
+  "version": "0.0.17",
   "description": "Discord bot for collective decision making for Mina Protocol",
   "main": "index.js",
   "directories": {

diff --git a/src/logic/VoteCountingLogic.ts b/src/logic/VoteCountingLogic.ts
@@ -1,4 +1,4 @@
-import { FundingRound, Proposal, SMEConsiderationVoteLog, CommitteeDeliberationVoteLog } from '../models';
+import { FundingRound, Proposal, SMEConsiderationVoteLog, CommitteeDeliberationVoteLog, GPTSummarizerVoteLog } from '../models';
 import { EndUserError } from '../Errors';
 import { CommitteeDeliberationVoteChoice } from '../types';
 import { TrackedInteraction } from '../core/BaseClasses';
@@ -29,6 +29,11 @@ interface VoteResultWithReasoning extends VoteResult {
     isPass: boolean;
     reason: string | null;
   }[];
+  communityFeedback?: {
+    voterUsername: string;
+    feedback: string;
+    reason: string | null;
+  }[];
 }
 
 export class VoteCountingLogic {
@@ -334,6 +339,8 @@ export class VoteCountingLogic {
 
         const proposerUsername = await this.getUsername(trackedInteraction, proposal.proposerDuid);
 
+        const communityFeedback = await this.getCommunityFeedback(proposal.id, trackedInteraction);
+
         return {
           projectId: proposal.id,
           projectName: proposal.name,
@@ -346,17 +353,44 @@ export class VoteCountingLogic {
           approvedModifiedVoters: approvedModifiedVoterUsernames,
           deliberationVotes,
           considerationVotes: [],
+          communityFeedback,
         };
       }),
     );
   }
 
+  private static async getCommunityFeedback(proposalId: number, trackedInteraction: TrackedInteraction) {
+    const feedbackLogs = await GPTSummarizerVoteLog.findAll({
+      where: { proposalId },
+      order: [['createdAt', 'DESC']],
+    });
+
+    const latestFeedback = new Map<string, { feedback: string; reason: string | null }>();
+    for (const log of feedbackLogs) {
+      if (!latestFeedback.has(log.duid)) {
+        latestFeedback.set(log.duid, { feedback: log.why, reason: log.reason });
+      }
+    }
+
+    const communityFeedback = [];
+    for (const [duid, { feedback, reason }] of latestFeedback) {
+      const voterUsername = await this.getUsername(trackedInteraction, duid);
+      communityFeedback.push({ voterUsername, feedback, reason });
+    }
+
+    return communityFeedback;
+  }
+
   public static formatVoteReasoningMessage(voteResults: VoteResultWithReasoning[]): EmbedBuilder[] {
     const embeds: EmbedBuilder[] = [];
 
     for (const result of voteResults) {
-      if (result.deliberationVotes.length === 0 && result.considerationVotes.length === 0) {
-        continue; // Skip projects with no votes
+      if (
+        result.deliberationVotes.length === 0 &&
+        result.considerationVotes.length === 0 &&
+        (!result.communityFeedback || result.communityFeedback.length === 0)
+      ) {
+        continue; // Skip projects with no votes or feedback
       }
 
       const embed = new EmbedBuilder()
@@ -382,6 +416,16 @@ export class VoteCountingLogic {
         embed.addFields({ name: 'Consideration Phase Votes', value: considerationField.trim() });
       }
 
+      if (result.communityFeedback && result.communityFeedback.length > 0) {
+        let feedbackField = '';
+        for (const feedback of result.communityFeedback) {
+          feedbackField += `**${feedback.voterUsername}**\n`;
+          feedbackField += `Feedback: ${feedback.feedback}\n`;
+          feedbackField += `Reason for Change: ${feedback.reason || 'No reason provided'}\n\n`;
+        }
+        embed.addFields({ name: 'Community Feedback', value: feedbackField.trim() });
+      }
+
       embeds.push(embed);
     }