feat(firewall): revert tabcoins earnings

filipedeschamps · Jul 29, 2024 · 1e959ad · 1e959ad
1 parent 7afa252
commit 1e959ad
Show file tree

Hide file tree

Showing 3 changed files with 474 additions and 2 deletions.
diff --git a/models/content.js b/models/content.js
@@ -989,4 +989,5 @@ export default Object.freeze({
   findWithStrategy,
   create,
   update,
+  creditOrDebitTabCoins,
 });
diff --git a/models/firewall/rules.js b/models/firewall/rules.js
@@ -1,5 +1,6 @@
 import { TooManyRequestsError } from 'errors';
 import database from 'infra/database.js';
+import content from 'models/content';
 import event from 'models/event.js';
 import notification from 'models/notification';
 
@@ -115,7 +116,10 @@ async function createContentTextRootRuleSideEffect(context) {
     },
   });
 
-  await sendContentTextNotification(results.rows, createdEvent);
+  await Promise.allSettled([
+    undoContentsTabcoins(results.rows, createdEvent),
+    sendContentTextNotification(results.rows, createdEvent),
+  ]);
 }
 
 async function createContentTextChildRule(context) {
@@ -154,7 +158,25 @@ async function createContentTextChildRuleSideEffect(context) {
     },
   });
 
-  await sendContentTextNotification(results.rows, createdEvent);
+  await Promise.allSettled([
+    undoContentsTabcoins(results.rows, createdEvent),
+    sendContentTextNotification(results.rows, createdEvent),
+  ]);
+}
+
+async function undoContentsTabcoins(contentRows, createdEvent) {
+  for (const contentObject of contentRows) {
+    await content.creditOrDebitTabCoins(
+      {
+        ...contentObject,
+        status: contentObject.status_before_update,
+      },
+      contentObject,
+      {
+        eventId: createdEvent.id,
+      },
+    );
+  }
 }
 
 async function sendContentTextNotification(contentRows, event) {