feat: store proposal, vote and follower count on space

src/writer/delete-proposal.ts

@@ -20,11 +20,14 @@ export async function verify(body): Promise<any> {
 
 export async function action(body): Promise<void> {
   const msg = jsonParse(body.msg);
-  const id = msg.payload.proposal;
+  const proposal = await getProposal(msg.space, msg.payload.proposal);
 
+  const id = msg.payload.proposal;
   const query = `
-  DELETE FROM proposals WHERE id = ? LIMIT 1;
-  DELETE FROM votes WHERE proposal = ?;
+    DELETE FROM proposals WHERE id = ? LIMIT 1;
+    DELETE FROM votes WHERE proposal = ?;
+    UPDATE spaces SET proposal_count = proposal_count - 1, vote_count = vote_count - ? WHERE id = ?;
   `;
-  await db.queryAsync(query, [id, id]);
+
+  await db.queryAsync(query, [id, id, proposal.votes, msg.space]);
 }

src/writer/follow.ts

@@ -10,6 +10,11 @@ export const getFollowsCount = async (follower: string): Promise<number> => {
 };
 
 export async function verify(message): Promise<any> {
+  const query = `SELECT * FROM follows WHERE follower = ? AND space = ? LIMIT 1`;
+  const follows = await db.queryAsync(query, [message.from, message.space]);
+
+  if (follows.length !== 0) return Promise.reject('you are already following this space');
+
   const count = await getFollowsCount(message.from);
 
   if (count >= FOLLOWS_LIMIT_PER_USER) {
@@ -19,7 +24,11 @@ export async function verify(message): Promise<any> {
   return true;
 }
 
-export async function action(message, ipfs, receipt, id): Promise<void> {
+export async function action(message, ipfs, _receipt, id): Promise<void> {
+  const query = `
+    INSERT IGNORE INTO follows SET ?;
+    UPDATE spaces SET follower_count = follower_count + 1 WHERE id = ?;
+  `;
   const params = {
     id,
     ipfs,
@@ -28,5 +37,5 @@ export async function action(message, ipfs, receipt, id): Promise<void> {
     created: message.timestamp
   };
 
-  await db.queryAsync('INSERT IGNORE INTO follows SET ?', params);
+  await db.queryAsync(query, [params, message.space]);
 }

src/writer/proposal.ts

@@ -241,8 +241,11 @@ export async function action(body, ipfs, receipt, id): Promise<void> {
     flagged: +containsFlaggedLinks(msg.payload.body)
   };
 
-  const query = 'INSERT IGNORE INTO proposals SET ?; ';
-  const params: any[] = [proposal];
+  const query = `
+    INSERT IGNORE INTO proposals SET ?;
+    UPDATE spaces SET proposal_count = proposal_count + 1 WHERE id = ?;
+  `;
+  const params: any[] = [proposal, space];
 
   await db.queryAsync(query, params);
 }

src/writer/unfollow.ts

@@ -1,10 +1,19 @@
 import db from '../helpers/mysql';
 
-export async function verify(): Promise<any> {
+export async function verify(message): Promise<any> {
+  const query = `SELECT * FROM follows WHERE follower = ? AND space = ? LIMIT 1`;
+  const follows = await db.queryAsync(query, [message.from, message.space]);
+
+  if (follows.length === 0) return Promise.reject('you can only unfollow a space you follow');
+
   return true;
 }
 
 export async function action(message): Promise<void> {
-  const query = 'DELETE FROM follows WHERE follower = ? AND space = ? LIMIT 1';
-  await db.queryAsync(query, [message.from, message.space]);
+  const query = `
+    DELETE FROM follows WHERE follower = ? AND space = ? LIMIT 1;
+    UPDATE spaces SET follower_count = follower_count - 1 WHERE id = ?;
+  `;
+
+  await db.queryAsync(query, [message.from, message.space, message.space]);
 }

src/writer/vote.ts

@@ -175,7 +175,13 @@ export async function action(body, ipfs, receipt, id, context): Promise<void> {
     );
   } else {
     // Store vote in dedicated table
-    await db.queryAsync('INSERT IGNORE INTO votes SET ?', params);
+    await db.queryAsync(
+      `
+      INSERT IGNORE INTO votes SET ?;
+      UPDATE spaces SET vote_count = vote_count + 1 WHERE id = ?;
+    `,
+      [params, msg.space]
+    );
   }
 
   // Update proposal scores and voters vp