chore: add/remove pool manager

packages/common/src/allo/allo.ts

@@ -213,6 +213,30 @@ export interface Allo {
       indexingStatus: Result<null>;
     }
   >;
+
+  addPoolManager: (args: {
+    poolId: Hex;
+    manager: Address;
+  }) => AlloOperation<
+    Result<null>,
+    {
+      transaction: Result<Hex>;
+      transactionStatus: Result<TransactionReceipt>;
+      indexingStatus: Result<null>;
+    }
+  >;
+
+  removePoolManager: (args: {
+    poolId: Hex;
+    manager: Address;
+  }) => AlloOperation<
+    Result<null>,
+    {
+      transaction: Result<Hex>;
+      transactionStatus: Result<TransactionReceipt>;
+      indexingStatus: Result<null>;
+    }
+  >;
 }
 
 export { AlloOperation };

packages/common/src/allo/backends/allo-v1.ts

@@ -1173,6 +1173,34 @@ export class AlloV1 implements Allo {
       return success(args.roundId);
     });
   }
+
+  addPoolManager(args: { poolId: string; manager: Address }): AlloOperation<
+    Result<null>,
+    {
+      transaction: Result<Hex>;
+      transactionStatus: Result<TransactionReceipt>;
+      indexingStatus: Result<null>;
+    }
+  > {
+    return new AlloOperation(async ({ emit }) => {
+      const result = new AlloError("Unsupported on v1");
+      return error(result); 
+    });    
+  }
+
+  removePoolManager(args: { poolId: string; manager: Address }): AlloOperation<
+    Result<null>,
+    {
+      transaction: Result<Hex>;
+      transactionStatus: Result<TransactionReceipt>;
+      indexingStatus: Result<null>;
+    }
+  > {
+    return new AlloOperation(async ({ emit }) => {
+      const result = new AlloError("Unsupported on v1");
+      return error(result); 
+    });
+  }
 }
 
 // todo: move this out?

packages/common/src/allo/backends/allo-v2.ts

@@ -1200,6 +1200,100 @@ export class AlloV2 implements Allo {
       return success(null);
     });
   }
+
+  addPoolManager(args: { poolId: string; manager: Address }): AlloOperation<
+    Result<null>,
+    {
+      transaction: Result<Hex>;
+      transactionStatus: Result<TransactionReceipt>;
+      indexingStatus: Result<null>;
+    }
+  > {
+    return new AlloOperation(async ({ emit }) => {
+      const txData = this.allo.addPoolManager(
+        BigInt(args.poolId),
+        args.manager
+      );
+
+      const txResult = await sendRawTransaction(this.transactionSender, {
+        to: txData.to,
+        data: txData.data,
+        value: BigInt(txData.value),
+      });
+
+      emit("transaction", txResult);
+
+      if (txResult.type === "error") {
+        return error(txResult.error);
+      }
+
+      let receipt: TransactionReceipt;
+      try {
+        receipt = await this.transactionSender.wait(txResult.value);
+        emit("transactionStatus", success(receipt));
+      } catch (err) {
+        const result = new AlloError("Failed to add pool manager");
+        emit("transactionStatus", error(result));
+        return error(result);
+      }
+
+      await this.waitUntilIndexerSynced({
+        chainId: this.chainId,
+        blockNumber: receipt.blockNumber,
+      });
+
+      emit("indexingStatus", success(null));
+
+      return success(null);
+    });
+  }
+
+  removePoolManager(args: { poolId: string; manager: Address }): AlloOperation<
+    Result<null>,
+    {
+      transaction: Result<Hex>;
+      transactionStatus: Result<TransactionReceipt>;
+      indexingStatus: Result<null>;
+    }
+  > {
+    return new AlloOperation(async ({ emit }) => {
+      const txData = this.allo.removePoolManager(
+        BigInt(args.poolId),
+        args.manager
+      );
+
+      const txResult = await sendRawTransaction(this.transactionSender, {
+        to: txData.to,
+        data: txData.data,
+        value: BigInt(txData.value),
+      });
+
+      emit("transaction", txResult);
+
+      if (txResult.type === "error") {
+        return error(txResult.error);
+      }
+
+      let receipt: TransactionReceipt;
+      try {
+        receipt = await this.transactionSender.wait(txResult.value);
+        emit("transactionStatus", success(receipt));
+      } catch (err) {
+        const result = new AlloError("Failed to add pool manager");
+        emit("transactionStatus", error(result));
+        return error(result);
+      }
+
+      await this.waitUntilIndexerSynced({
+        chainId: this.chainId,
+        blockNumber: receipt.blockNumber,
+      });
+
+      emit("indexingStatus", success(null));
+
+      return success(null);
+    });
+  }
 }
 
 export function serializeProject(project: ProjectWithMerkleProof) {