feat: add recipient canceled event handler

flow-state-coop · May 29, 2024 · 2ed51c7 · 2ed51c7
1 parent 00bcd5f
commit 2ed51c7
Show file tree

Hide file tree

Showing 9 changed files with 69 additions and 23 deletions.
diff --git a/src/db/index.ts b/src/db/index.ts
@@ -73,7 +73,7 @@ export type RecipientsTable = {
   recipientAddress: string;
   anchorAddress: string | null;
   superappAddress: string | null;
-  status: "PENDING" | "REJECTED" | "APPROVED";
+  status: "PENDING" | "REJECTED" | "APPROVED" | "CANCELED";
   metadataCid: string | null;
   metadata: unknown;
   createdAtBlock: bigint;

diff --git a/src/db/migrate.ts b/src/db/migrate.ts
@@ -1,6 +1,6 @@
 import { Kysely, sql } from "kysely";
 
-const schemaName = "1";
+const schemaName = "2";
 
 async function migrate<T>(db: Kysely<T>) {
   const ref = (name: string) => sql.table(`${schemaName}.${name}`);
@@ -83,7 +83,7 @@ async function migrate<T>(db: Kysely<T>) {
 
   await schema
     .createType("status")
-    .asEnum(["PENDING", "REJECTED", "APPROVED"])
+    .asEnum(["PENDING", "REJECTED", "APPROVED", "CANCELED"])
     .execute();
 
   await schema

diff --git a/src/indexer/events/handleCanceled.ts b/src/indexer/events/handleCanceled.ts
@@ -0,0 +1,39 @@
+import { EventHandlerArgs, Indexer } from "chainsauce";
+import { IndexerContext } from "../handleEvent.js";
+import { abis } from "../../lib/abi/index.js";
+import { ZERO_ADDRESS } from "../../lib/constants.js";
+
+export async function handleCanceled(
+  args: EventHandlerArgs<
+    Indexer<typeof abis, IndexerContext>,
+    "AlloStrategy",
+    "Canceled"
+  >,
+) {
+  const {
+    event,
+    chainId,
+    context: { db },
+  } = args;
+
+  const {
+    params: { recipientId },
+    address,
+  } = event;
+
+  try {
+    await db
+      .updateTable("recipients")
+      .set({
+        status: "CANCELED",
+        superappAddress: ZERO_ADDRESS,
+        updatedAtBlock: event.blockNumber,
+      })
+      .where("chainId", "=", chainId)
+      .where("strategyAddress", "=", address.toLowerCase())
+      .where("id", "=", recipientId.toLowerCase())
+      .execute();
+  } catch (err) {
+    console.warn("DB write error");
+  }
+}
diff --git a/src/indexer/events/handlePoolCreated.ts b/src/indexer/events/handlePoolCreated.ts
@@ -4,19 +4,18 @@ import { getPendingPoolRoles } from "../../db/index.js";
 import { IndexerContext } from "../handleEvent.js";
 import { fetchIpfs } from "../ipfs.js";
 import { abis } from "../../lib/abi/index.js";
-import { ALLO_STRATEGY_ID } from "../../lib/constants.js";
-
-const NULL_BYTES =
-  "0x0000000000000000000000000000000000000000000000000000000000000000";
-const ZERO_ADDRESS =
-  "0x0000000000000000000000000000000000000000";
+import {
+  ALLO_STRATEGY_ID,
+  NULL_BYTES,
+  ZERO_ADDRESS,
+} from "../../lib/constants.js";
 
 export async function handlePoolCreated(
   args: EventHandlerArgs<
     Indexer<typeof abis, IndexerContext>,
     "Allo" | "PoolFactory",
     "PoolCreated"
-  >
+  >,
 ) {
   if (args.event.contractName === "Allo") {
     const {
@@ -57,7 +56,7 @@ export async function handlePoolCreated(
       const strategyName = "SQFSuperfluidv1";
       const managerRole = pad(`0x${poolId.toString(16)}`);
       const adminRole = keccak256(
-        encodePacked(["uint256", "string"], [poolId, "admin"])
+        encodePacked(["uint256", "string"], [poolId, "admin"]),
       );
       const metadata = await fetchIpfs(metadataCid);
 
@@ -96,7 +95,7 @@ export async function handlePoolCreated(
                   role: "admin",
                   createdAtBlock: event.blockNumber,
                 };
-              })
+              }),
             )
             .execute();
 
@@ -105,14 +104,14 @@ export async function handlePoolCreated(
             .where(
               "id",
               "in",
-              pendingAdminRoles.map((role) => role.id)
+              pendingAdminRoles.map((role) => role.id),
             )
             .execute();
         }
 
         const pendingManagerRoles = await getPendingPoolRoles(
           chainId,
-          managerRole
+          managerRole,
         );
 
         if (pendingManagerRoles.length > 0) {
@@ -127,7 +126,7 @@ export async function handlePoolCreated(
                   role: "manager",
                   createdAtBlock: event.blockNumber,
                 };
-              })
+              }),
             )
             .execute();
 
@@ -136,7 +135,7 @@ export async function handlePoolCreated(
             .where(
               "id",
               "in",
-              pendingManagerRoles.map((role) => role.id)
+              pendingManagerRoles.map((role) => role.id),
             )
             .execute();
         }
@@ -173,7 +172,7 @@ export async function handlePoolCreated(
     const strategyName = "StreamingQuadraticFunding";
     const managerRole = pad(`0x${poolId.toString(16)}`);
     const adminRole = keccak256(
-      encodePacked(["uint256", "string"], [poolId, "admin"])
+      encodePacked(["uint256", "string"], [poolId, "admin"]),
     );
     const metadata = await fetchIpfs(metadataCid);
 

diff --git a/src/indexer/events/handleRegistered.ts b/src/indexer/events/handleRegistered.ts
@@ -10,7 +10,7 @@ export async function handleRegistered(
     Indexer<typeof abis, IndexerContext>,
     "AlloStrategy" | "StreamingQuadraticFunding",
     "Registered"
-  >
+  >,
 ) {
   if (args.event.contractName === "AlloStrategy") {
     const {

diff --git a/src/indexer/events/handleUpdatedRegistration.ts b/src/indexer/events/handleUpdatedRegistration.ts
@@ -9,7 +9,7 @@ export async function handleUpdatedRegistration(
     Indexer<typeof abis, IndexerContext>,
     "AlloStrategy" | "StreamingQuadraticFunding",
     "UpdatedRegistration"
-  >
+  >,
 ) {
   if (args.event.contractName === "AlloStrategy") {
     const {
@@ -63,10 +63,7 @@ export async function handleUpdatedRegistration(
       "UpdatedRegistration"
     >;
 
-    const {
-      params,
-      address,
-    } = event;
+    const { params, address } = event;
 
     const {
       recipientAddress,

diff --git a/src/indexer/events/index.js b/src/indexer/events/index.js
@@ -3,6 +3,7 @@ export { handlePoolCreated } from "./handlePoolCreated.js";
 export { handleRegistered } from "./handleRegistered.js";
 export { handleUpdatedRegistration } from "./handleUpdatedRegistration.js";
 export { handleReviewed } from "./handleReviewed.js";
+export { handleCanceled } from "./handleCanceled.js";
 export { handleProfileMetadataUpdated } from "./handleProfileMetadataUpdated.js";
 export { handleProfileNameUpdated } from "./handleProfileNameUpdated.js";
 export { handleProfileOwnerUpdated } from "./handleProfileOwnerUpdated.js";

diff --git a/src/indexer/handleEvent.ts b/src/indexer/handleEvent.ts
@@ -10,6 +10,7 @@ import {
   handleRegistered,
   handleUpdatedRegistration,
   handleReviewed,
+  handleCanceled,
   handleProfileMetadataUpdated,
   handleProfileNameUpdated,
   handleProfileOwnerUpdated,
@@ -58,6 +59,12 @@ async function handleEvent(
       break;
     }
 
+    case "Canceled": {
+      await handleCanceled({ ...args, event });
+
+      break;
+    }
+
     case "ProfileMetadataUpdated": {
       await handleProfileMetadataUpdated({ ...args, event });
 

diff --git a/src/lib/constants.ts b/src/lib/constants.ts
@@ -2,6 +2,9 @@ export const ALLO_STRATEGY_ID =
   "0xf8a14294e80ff012e54157ec9d1b2827421f1e7f6bde38c06730b1c031b3f935";
 export const ALLO_OWNER_ROLE =
   "0x815b5a78dc333d344c7df9da23c04dbd432015cc701876ddb9ffe850e6882747";
+export const NULL_BYTES =
+  "0x0000000000000000000000000000000000000000000000000000000000000000";
+export const ZERO_ADDRESS = "0x0000000000000000000000000000000000000000";
 export const IPFS_GATEWAYS = [
   "https://gateway.pinata.cloud",
   "https://storry.tv",