feat: Store user space activty

src/writer/delete-proposal.ts

@@ -20,11 +20,23 @@ export async function verify(body): Promise<any> {
 
 export async function action(body): Promise<void> {
   const msg = jsonParse(body.msg);
+  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 = ?;
   `;
   await db.queryAsync(query, [id, id]);
+
+  await db.queryAsync(
+    `UPDATE user_space SET proposals_count = proposals_count - 1 WHERE user_id = ? AND space_id = ? LIMIT 1`,
+    [proposal.author, msg.space]
+  );
+  await db.queryAsync(
+    `INSERT INTO user_space (votes_count, user_id, space_id)
+    (select * from (select count(id) as votes_count, voter, space from votes where space = ? group by voter, space) as t)
+    ON DUPLICATE KEY UPDATE votes_count = t.votes_count`,
+    [msg.space]
+  );
 }

src/writer/proposal.ts

@@ -223,5 +223,16 @@ export async function action(body, ipfs, receipt, id): Promise<void> {
   const query = 'INSERT IGNORE INTO proposals SET ?; ';
   const params: any[] = [proposal];
 
-  await db.queryAsync(query, params);
+  const result = await db.queryAsync(query, params);
+
+  if (result.affectedRows > 0) {
+    await db.queryAsync(
+      `
+      INSERT INTO user_space (space_id, user_id, proposals_count)
+      VALUES(?, ?, 1)
+      ON DUPLICATE KEY UPDATE proposals_count = proposals_count + 1
+      `,
+      [space, author]
+    );
+  }
 }

src/writer/vote.ts

@@ -176,7 +176,18 @@ 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);
+    const result = await db.queryAsync('INSERT IGNORE INTO votes SET ?', params);
+
+    if (result.affectedRows > 0) {
+      await db.queryAsync(
+        `
+        INSERT INTO user_space (space_id, user_id, votes_count)
+        VALUES(?, ?, 1)
+        ON DUPLICATE KEY UPDATE votes_count = votes_count + 1
+        `,
+        [msg.space, voter]
+      );
+    }
   }
 
   // Update proposal scores and voters vp

test/schema.sql

@@ -164,3 +164,14 @@ CREATE TABLE messages (
   INDEX type (type),
   INDEX receipt (receipt)
 );
+
+CREATE TABLE user_space (
+  user_id varchar(64) NOT NULL,
+  space_id varchar(64) NOT NULL,
+  votes_count smallint unsigned NOT NULL DEFAULT '0',
+  proposals_count smallint unsigned NOT NULL DEFAULT '0',
+  UNIQUE KEY user_id_space_id (user_id,space_id),
+  INDEX space_id (space_id),
+  INDEX votes_count (votes_count),
+  INDEX proposals_count (proposals_count)
+);