Feat: Handle disable proxy colony metadataDelta event

Feat: Handle disable proxy colony metadataDelta event

apps/main-chain/src/handlers/metadataDelta/handlers/disableProxyColony.ts

@@ -0,0 +1,67 @@
+import { Id } from '@colony/colony-js';
+import {
+  ColonyActionType,
+  GetProxyColonyDocument,
+  GetProxyColonyQuery,
+  GetProxyColonyQueryVariables,
+  UpdateProxyColonyDocument,
+  UpdateProxyColonyMutation,
+  UpdateProxyColonyMutationVariables,
+} from '@joincolony/graphql';
+import { ContractEvent } from '@joincolony/blocks';
+import {
+  DisableProxyColonyOperation,
+  getColonyFromDB,
+  getDomainDatabaseId,
+  writeActionFromEvent,
+} from '~utils';
+import amplifyClient from '~amplifyClient';
+
+export const handleDisableProxyColony = async (
+  event: ContractEvent,
+  operation: DisableProxyColonyOperation,
+): Promise<void> => {
+  const { contractAddress: colonyAddress } = event;
+  const { agent: initiatorAddress } = event.args;
+
+  const foreignChainId = operation.payload[0];
+
+  const colony = await getColonyFromDB(colonyAddress);
+  if (!colony) {
+    return;
+  }
+
+  const proxyColonyId = `${colonyAddress}_${foreignChainId}`;
+
+  const item = await amplifyClient.query<
+    GetProxyColonyQuery,
+    GetProxyColonyQueryVariables
+  >(GetProxyColonyDocument, {
+    id: proxyColonyId,
+  });
+
+  // If the proxy colony is already disabled, we early-return
+  if (!item?.data?.getProxyColony?.isActive) {
+    return;
+  }
+
+  await amplifyClient.mutate<
+    UpdateProxyColonyMutation,
+    UpdateProxyColonyMutationVariables
+  >(UpdateProxyColonyDocument, {
+    input: {
+      id: proxyColonyId,
+      isActive: false,
+    },
+  });
+
+  await writeActionFromEvent(event, colonyAddress, {
+    type: ColonyActionType.RemoveProxyColony,
+    initiatorAddress,
+    multiChainInfo: {
+      targetChainId: Number(foreignChainId),
+      completed: true,
+    },
+    fromDomainId: getDomainDatabaseId(colonyAddress, Id.RootDomain),
+  });
+};

apps/main-chain/src/handlers/metadataDelta/metadataDelta.ts

@@ -1,6 +1,7 @@
 import { ContractEvent } from '@joincolony/blocks';
 import {
   isAddVerifiedMembersOperation,
+  isDisableProxyColonyOperation,
   isManageTokensOperation,
   isRemoveVerifiedMembersOperation,
   parseMetadataDeltaOperation,
@@ -9,6 +10,7 @@ import { handleAddVerifiedMembers } from './handlers/addVerifiedMembers';
 import { handleRemoveVerifiedMembers } from './handlers/removeVerifiedMembers';
 import { handleManageTokens } from './handlers/manageTokens';
 import { verbose } from '@joincolony/utils';
+import { handleDisableProxyColony } from './handlers/disableProxyColony';
 
 export default async (event: ContractEvent): Promise<void> => {
   const operationString = event.args.metadata;
@@ -33,5 +35,9 @@ export default async (event: ContractEvent): Promise<void> => {
     return;
   }
 
+  if (isDisableProxyColonyOperation(operation)) {
+    await handleDisableProxyColony(event, operation);
+  }
+
   verbose('Unknown operation type: ', operation);
 };

apps/main-chain/src/utils/metadataDelta/types.ts

@@ -2,6 +2,7 @@ export enum MetadataDeltaOperationType {
   ADD_VERIFIED_MEMBERS = 'ADD_VERIFIED_MEMBERS',
   REMOVE_VERIFIED_MEMBERS = 'REMOVE_VERIFIED_MEMBERS',
   MANAGE_TOKENS = 'MANAGE_TOKENS',
+  DISABLE_PROXY_COLONY = 'DISABLE_PROXY_COLONY',
 }
 
 export interface AddVerifiedMembersOperation {
@@ -19,7 +20,13 @@ export interface ManageTokensOperation {
   payload: string[];
 }
 
+export interface DisableProxyColonyOperation {
+  type: MetadataDeltaOperationType.DISABLE_PROXY_COLONY;
+  payload: string[];
+}
+
 export type MetadataDeltaOperation =
   | AddVerifiedMembersOperation
   | RemoveVerifiedMembersOperation
-  | ManageTokensOperation;
+  | ManageTokensOperation
+  | DisableProxyColonyOperation;

apps/main-chain/src/utils/metadataDelta/utils.ts

@@ -5,6 +5,7 @@ import {
   MetadataDeltaOperation,
   MetadataDeltaOperationType,
   ManageTokensOperation,
+  DisableProxyColonyOperation,
 } from './types';
 
 export const isAddVerifiedMembersOperation = (
@@ -40,6 +41,17 @@ export const isManageTokensOperation = (
   );
 };
 
+export const isDisableProxyColonyOperation = (
+  operation: MetadataDeltaOperation,
+): operation is DisableProxyColonyOperation => {
+  return (
+    operation.type === MetadataDeltaOperationType.DISABLE_PROXY_COLONY &&
+    operation.payload !== undefined &&
+    Array.isArray(operation.payload) &&
+    operation.payload.every((item) => typeof item === 'string')
+  );
+};
+
 const isMetadataDeltaOperation = (
   operation: any,
 ): operation is MetadataDeltaOperation => {

packages/graphql/src/mutations/proxyColonies.graphql

@@ -3,3 +3,9 @@ mutation CreateProxyColony($input: CreateProxyColonyInput!) {
     id
   }
 }
+
+mutation UpdateProxyColony($input: UpdateProxyColonyInput!) {
+  updateProxyColony(input: $input) {
+    id
+  }
+}

packages/graphql/src/queries/proxyColonies.graphql

@@ -0,0 +1,8 @@
+query GetProxyColony($id: ID!) {
+  getProxyColony(id: $id) {
+    chainId
+    colonyAddress
+    id
+    isActive
+  }
+}