Remove chain node from topics + Fix ERC20 voting

libs/model/src/comment/CreateComment.command.ts

@@ -71,7 +71,7 @@ export function CreateComment(): Command<
               text,
               address_id: address.id!,
               reaction_count: 0,
-              reaction_weights_sum: 0,
+              reaction_weights_sum: '0',
               created_by: '',
               search: getCommentSearchVector(text),
               content_url: contentUrl,

libs/model/src/comment/CreateCommentReaction.command.ts

@@ -38,7 +38,7 @@ export function CreateCommentReaction(): Command<
               address_id: address.id!,
               comment_id: comment.id,
               reaction: payload.reaction,
-              calculated_voting_weight,
+              calculated_voting_weight: calculated_voting_weight?.toString(),
               canvas_msg_id: payload.canvas_msg_id,
               canvas_signed_data: payload.canvas_signed_data,
             },

libs/model/src/community/CreateTopic.command.ts

@@ -63,7 +63,6 @@ export function CreateTopic(): Command<
           options = {
             ...options,
             weighted_voting: payload.weighted_voting,
-            chain_node_id: payload.chain_node_id || undefined,
             token_address: payload.token_address || undefined,
             token_symbol: payload.token_symbol || undefined,
             vote_weight_multiplier: payload.vote_weight_multiplier || undefined,

libs/model/src/models/associations.ts

@@ -34,8 +34,7 @@ export const buildAssociations = (db: DB) => {
 
   db.ChainNode.withMany(db.Community)
     .withMany(db.EvmEventSource)
-    .withOne(db.LastProcessedEvmBlock)
-    .withMany(db.Topic);
+    .withOne(db.LastProcessedEvmBlock);
 
   db.ContractAbi.withMany(db.EvmEventSource, { foreignKey: 'abi_id' });
 

libs/model/src/models/comment.ts

@@ -56,7 +56,7 @@ export default (
         defaultValue: 0,
       },
       reaction_weights_sum: {
-        type: Sequelize.INTEGER,
+        type: Sequelize.DECIMAL(78, 0),
         allowNull: false,
         defaultValue: 0,
       },

libs/model/src/models/reaction.ts

@@ -20,7 +20,10 @@ export default (
       comment_id: { type: Sequelize.INTEGER, allowNull: true },
       address_id: { type: Sequelize.INTEGER, allowNull: false },
       reaction: { type: Sequelize.ENUM('like'), allowNull: false },
-      calculated_voting_weight: { type: Sequelize.INTEGER, allowNull: true },
+      calculated_voting_weight: {
+        type: Sequelize.DECIMAL(78, 0),
+        allowNull: true,
+      },
       // canvas-related columns
       canvas_signed_data: { type: Sequelize.JSONB, allowNull: true },
       canvas_msg_id: { type: Sequelize.STRING, allowNull: true },

libs/model/src/models/thread.ts

@@ -77,7 +77,7 @@ export default (
         defaultValue: 0,
       },
       reaction_weights_sum: {
-        type: Sequelize.INTEGER,
+        type: Sequelize.DECIMAL(78, 0),
         allowNull: false,
         defaultValue: 0,
       },

libs/model/src/models/topic.ts

@@ -1,7 +1,6 @@
 import { Topic } from '@hicommonwealth/schemas';
 import Sequelize from 'sequelize';
 import { z } from 'zod';
-import { ChainNodeAttributes } from './chain_node';
 import type { CommunityAttributes } from './community';
 import type { ThreadAttributes } from './thread';
 import type { ModelInstance } from './types';
@@ -10,7 +9,6 @@ export type TopicAttributes = z.infer<typeof Topic> & {
   // associations
   community?: CommunityAttributes;
   threads?: ThreadAttributes[] | TopicAttributes['id'][];
-  ChainNode?: ChainNodeAttributes;
 };
 export type TopicInstance = ModelInstance<TopicAttributes>;
 
@@ -50,18 +48,9 @@ export default (
       },
       telegram: { type: Sequelize.STRING, allowNull: true },
       weighted_voting: { type: Sequelize.STRING, allowNull: true },
-      chain_node_id: {
-        type: Sequelize.INTEGER,
-        allowNull: true,
-        references: {
-          model: 'ChainNodes',
-          key: 'id',
-        },
-        onUpdate: 'CASCADE',
-      },
       token_address: { type: Sequelize.STRING, allowNull: true },
       token_symbol: { type: Sequelize.STRING, allowNull: true },
-      vote_weight_multiplier: { type: Sequelize.INTEGER, allowNull: true },
+      vote_weight_multiplier: { type: Sequelize.FLOAT, allowNull: true },
     },
     {
       timestamps: true,

libs/model/src/services/stakeHelper.ts

@@ -17,9 +17,9 @@ import { contractHelpers } from '../services/commonProtocol';
 export async function getVotingWeight(
   topic_id: number,
   address: string,
-): Promise<number | null> {
+): Promise<BigNumber | null> {
   if (config.STAKE.REACTION_WEIGHT_OVERRIDE)
-    return config.STAKE.REACTION_WEIGHT_OVERRIDE;
+    return BigNumber.from(config.STAKE.REACTION_WEIGHT_OVERRIDE);
 
   const topic = await models.Topic.findByPk(topic_id, {
     include: [
@@ -38,25 +38,21 @@ export async function getVotingWeight(
           },
         ],
       },
-      {
-        model: models.ChainNode,
-        required: false,
-      },
     ],
   });
-
   mustExist('Topic', topic);
 
   const { community } = topic;
-
   mustExist('Community', community);
 
+  const chain_node = community.ChainNode;
+
   if (topic.weighted_voting === TopicWeightedVoting.Stake) {
+    mustExist('Chain Node Eth Chain Id', chain_node?.eth_chain_id);
     mustExist('Community Namespace Address', community.namespace_address);
+
     const stake = topic.community?.CommunityStakes?.at(0);
     mustExist('Community Stake', stake);
-    const chain_node = community.ChainNode;
-    mustExist('Chain Node Eth Chain Id', chain_node?.eth_chain_id);
 
     const stakeBalances = await contractHelpers.getNamespaceBalance(
       community.namespace_address,
@@ -70,24 +66,23 @@ export async function getVotingWeight(
 
     return commonProtocol.calculateVoteWeight(stakeBalance, stake.vote_weight);
   } else if (topic.weighted_voting === TopicWeightedVoting.ERC20) {
-    const {
-      ChainNode: chain_node,
-      token_address,
-      vote_weight_multiplier,
-    } = topic;
-    mustExist('Topic Chain Node Eth Chain Id', chain_node?.eth_chain_id);
+    mustExist('Chain Node Eth Chain Id', chain_node?.eth_chain_id);
 
     const balances = await tokenBalanceCache.getBalances({
       balanceSourceType: BalanceSourceType.ERC20,
       addresses: [address],
       sourceOptions: {
-        evmChainId: chain_node?.eth_chain_id,
-        contractAddress: token_address!,
+        evmChainId: chain_node.eth_chain_id,
+        contractAddress: topic.token_address!,
       },
       cacheRefresh: true,
     });
-    const balance = balances[address];
-    return commonProtocol.calculateVoteWeight(balance, vote_weight_multiplier!);
+    const result = commonProtocol.calculateVoteWeight(
+      balances[address],
+      topic.vote_weight_multiplier!,
+    );
+    // only count full ERC20 tokens
+    return result?.div(BigNumber.from(10).pow(18)) || null;
   }
 
   // no weighted voting

libs/model/src/tester/e2eSeeds.ts

@@ -201,7 +201,7 @@ export const e2eTestEntities = async function (
                   stage: 'discussion',
                   view_count: 0,
                   reaction_count: 0,
-                  reaction_weights_sum: 0,
+                  reaction_weights_sum: '0',
                   comment_count: 0,
                   search: getThreadSearchVector(
                     `testThread Title ${-i - 1}`,
@@ -233,7 +233,7 @@ export const e2eTestEntities = async function (
                   stage: 'discussion',
                   view_count: 0,
                   reaction_count: 0,
-                  reaction_weights_sum: 0,
+                  reaction_weights_sum: '0',
                   comment_count: 0,
                   search: getThreadSearchVector(
                     `testThread Title ${-i - 1 - 2}`,
@@ -276,6 +276,7 @@ export const e2eTestEntities = async function (
                   text: '',
                   thread_id: -1,
                   reaction_count: 0,
+                  reaction_weights_sum: '0',
                   search: getCommentSearchVector(''),
                 },
               })
@@ -298,6 +299,7 @@ export const e2eTestEntities = async function (
                   text: '',
                   thread_id: -2,
                   reaction_count: 0,
+                  reaction_weights_sum: '0',
                   search: getCommentSearchVector(''),
                 },
               })

libs/model/src/thread/CreateThread.command.ts

@@ -131,7 +131,7 @@ export function CreateThread(): Command<
               view_count: 0,
               comment_count: 0,
               reaction_count: 0,
-              reaction_weights_sum: 0,
+              reaction_weights_sum: '0',
               search: getThreadSearchVector(rest.title, body),
               content_url: contentUrl,
             },

libs/model/src/thread/CreateThreadReaction.command.ts

@@ -46,7 +46,7 @@ export function CreateThreadReaction(): Command<
               address_id: address.id!,
               thread_id: thread.id,
               reaction: payload.reaction,
-              calculated_voting_weight,
+              calculated_voting_weight: calculated_voting_weight?.toString(),
               canvas_msg_id: payload.canvas_msg_id,
               canvas_signed_data: payload.canvas_signed_data,
             },

libs/model/test/community/community-lifecycle.spec.ts

@@ -460,7 +460,6 @@ describe('Community lifecycle', () => {
     });
 
     test('should create topic (stake weighted)', async () => {
-      // when community is staked, topic will automatically be staked
       await models.CommunityStake.create({
         community_id: community.id,
         stake_id: 1,
@@ -476,6 +475,7 @@ describe('Community lifecycle', () => {
           description: 'boohoo',
           featured_in_sidebar: false,
           featured_in_new_post: false,
+          weighted_voting: TopicWeightedVoting.Stake,
         },
       });
       const { topic } = result!;

libs/model/test/contest-worker/contest-worker-policy.spec.ts

@@ -99,7 +99,7 @@ describe('Contest Worker Policy', () => {
             stage: '',
             view_count: 0,
             reaction_count: 0,
-            reaction_weights_sum: 0,
+            reaction_weights_sum: '0',
             comment_count: 0,
             deleted_at: undefined,
             pinned: false,

libs/model/test/contest/contests-projection-lifecycle.spec.ts

@@ -162,7 +162,7 @@ describe('Contests projection lifecycle', () => {
           topic_id: undefined,
           view_count: 1,
           reaction_count: 1,
-          reaction_weights_sum: 1,
+          reaction_weights_sum: '1',
           comment_count: 1,
           discord_meta: undefined,
           deleted_at: undefined, // so we can find it!

libs/model/test/email/recap-email-lifecycle.spec.ts

@@ -72,11 +72,13 @@ describe('Recap email lifecycle', () => {
       topic_id: community?.topics?.at(0)?.id,
       pinned: false,
       read_only: false,
+      reaction_weights_sum: '0',
     });
 
     [comment] = await seed('Comment', {
       address_id: community?.Addresses?.at(0)?.id,
       thread_id: thread!.id!,
+      reaction_weights_sum: '0',
     });
   });
 

libs/model/test/email/util.ts

@@ -324,6 +324,7 @@ export async function generateThreads(
     topic_id: communityThree?.topics?.at(0)?.id,
     pinned: false,
     read_only: false,
+    reaction_weights_sum: '0',
   });
 
   // 3 threads for communityOne and 1 thread for communityTwo
@@ -334,6 +335,7 @@ export async function generateThreads(
     pinned: false,
     read_only: false,
     view_count: 10,
+    reaction_weights_sum: '0',
   });
   const [threadTwo] = await seed('Thread', {
     address_id: communityOne?.Addresses?.at(0)?.id,
@@ -342,6 +344,7 @@ export async function generateThreads(
     pinned: false,
     read_only: false,
     view_count: 5,
+    reaction_weights_sum: '0',
   });
 
   const [threadThree] = await seed('Thread', {
@@ -351,6 +354,7 @@ export async function generateThreads(
     pinned: false,
     read_only: false,
     view_count: 1,
+    reaction_weights_sum: '0',
   });
 
   const [threadFour] = await seed('Thread', {
@@ -360,6 +364,7 @@ export async function generateThreads(
     pinned: false,
     read_only: false,
     view_count: 10,
+    reaction_weights_sum: '0',
   });
 
   return {

libs/model/test/reaction/reaction-lifecycle.spec.ts

@@ -53,6 +53,7 @@ describe('Reactions lifecycle', () => {
         deleted_at: undefined, // so we can find it!
         pinned: false,
         read_only: false,
+        reaction_weights_sum: '0',
       },
       //{ mock: true, log: true },
     );
@@ -68,7 +69,7 @@ describe('Reactions lifecycle', () => {
       reaction: 'like',
       canvas_signed_data: '',
       canvas_msg_id: '',
-      calculated_voting_weight: 0,
+      calculated_voting_weight: '0',
     });
 
     const lastOutboxEntry = await models.Outbox.findOne({

libs/model/test/subscription/comment-subscription-lifecycle.spec.ts

@@ -46,15 +46,18 @@ describe('Comment subscription lifecycle', () => {
       topic_id: community?.topics?.at(0)?.id,
       pinned: false,
       read_only: false,
+      reaction_weights_sum: '0',
     });
 
     [commentOne] = await seed('Comment', {
       address_id: community?.Addresses?.at(0)?.id,
       thread_id: thread!.id!,
+      reaction_weights_sum: '0',
     });
     [commentTwo] = await seed('Comment', {
       address_id: community?.Addresses?.at(0)?.id,
       thread_id: thread!.id!,
+      reaction_weights_sum: '0',
     });
     actor = {
       user: { id: user!.id!, email: user!.email! },

libs/model/test/subscription/thread-subscription-lifecycle.spec.ts

@@ -46,13 +46,15 @@ describe('Thread subscription lifecycle', () => {
       topic_id: community!.topics![0].id,
       pinned: false,
       read_only: false,
+      reaction_weights_sum: '0',
     });
     [threadTwo] = await seed('Thread', {
       address_id: community!.Addresses![0].id!,
       community_id: community?.id,
       topic_id: community!.topics![0].id,
       pinned: false,
       read_only: false,
+      reaction_weights_sum: '0',
     });
     actor = {
       user: { id: user!.id!, email: user!.email! },