Add support for MoveFunds action

src/eventProcessor.ts

@@ -17,6 +17,7 @@ import {
   handleExtensionInitialised,
   handleCreateDomainAction,
   handleTokenUnlockedAction,
+  handleMoveFundsAction,
 } from './handlers';
 
 dotenv.config();
@@ -128,6 +129,11 @@ export default async (event: ContractEvent): Promise<void> => {
       return;
     }
 
+    case ContractEventsSignatures.ColonyFundsMovedBetweenFundingPots: {
+      await handleMoveFundsAction(event);
+      return;
+    }
+
     default: {
       return;
     }

src/handlers/actions/index.ts

@@ -2,3 +2,4 @@ export { default as handleMintTokensAction } from './mintTokens';
 export { default as handlePaymentAction } from './payment';
 export { default as handleCreateDomainAction } from './createDomain';
 export { default as handleTokenUnlockedAction } from './unlockToken';
+export { default as handleMoveFundsAction } from './moveFunds';

src/handlers/actions/moveFunds.ts

@@ -0,0 +1,58 @@
+import {
+  AnyColonyClient,
+  ColonyClientV1,
+  ColonyClientV2,
+  ColonyClientV3,
+  ColonyClientV4,
+} from '@colony/colony-js';
+import { BigNumber } from 'ethers';
+import networkClient from '~/networkClient';
+import { ColonyActionType, ContractEvent } from '~/types';
+import { toNumber, writeActionFromEvent } from '~/utils';
+import { getDatabaseDomainId } from '~/utils/domains';
+
+/**
+ * The handler makes use of colonyClient getDomainFromFundingPot method which is only
+ * available on ColonyClientV5 and above. The following type predicate allows to check
+ * we're dealing with a client that supports this method
+ */
+type SupportedColonyClient = Exclude<
+  AnyColonyClient,
+  ColonyClientV1 | ColonyClientV2 | ColonyClientV3 | ColonyClientV4
+>;
+const isSupportedColonyClient = (
+  colonyClient: AnyColonyClient,
+): colonyClient is SupportedColonyClient =>
+  (colonyClient as SupportedColonyClient).getDomainFromFundingPot !== undefined;
+
+export default async (event: ContractEvent): Promise<void> => {
+  const { contractAddress: colonyAddress } = event;
+  const {
+    agent: initiatorAddress,
+    token: tokenAddress,
+    amount,
+    fromPot,
+    toPot,
+  } = event.args;
+
+  const colonyClient = await networkClient.getColonyClient(colonyAddress);
+  let fromDomainId: BigNumber | undefined;
+  let toDomainId: BigNumber | undefined;
+  if (isSupportedColonyClient(colonyClient)) {
+    fromDomainId = await colonyClient.getDomainFromFundingPot(fromPot);
+    toDomainId = await colonyClient.getDomainFromFundingPot(toPot);
+  }
+
+  await writeActionFromEvent(event, colonyAddress, {
+    type: ColonyActionType.MoveFunds,
+    initiatorAddress,
+    tokenAddress,
+    amount: amount.toString(),
+    fromDomainId: fromDomainId
+      ? getDatabaseDomainId(colonyAddress, toNumber(fromDomainId))
+      : undefined,
+    toDomainId: toDomainId
+      ? getDatabaseDomainId(colonyAddress, toNumber(toDomainId))
+      : undefined,
+  });
+};

src/types.ts

@@ -49,6 +49,7 @@ export enum ContractEventsSignatures {
   OneTxPaymentMade = 'OneTxPaymentMade(address,uint256,uint256)',
   DomainAdded = 'DomainAdded(address,uint256)',
   TokenUnlocked = 'TokenUnlocked(address)',
+  ColonyFundsMovedBetweenFundingPots = 'ColonyFundsMovedBetweenFundingPots(address,uint256,uint256,uint256,address)',
 }
 
 /*
@@ -69,4 +70,5 @@ export enum ColonyActionType {
   Payment = 'PAYMENT',
   CreateDomain = 'CREATE_DOMAIN',
   UnlockToken = 'UNLOCK_TOKEN',
+  MoveFunds = 'MOVE_FUNDS',
 }

src/utils/actions/listener.ts

@@ -20,4 +20,8 @@ export const addActionEventListeners = async (
     ContractEventsSignatures.TokenUnlocked,
     colonyAddress,
   );
+  await addColonyEventListener(
+    ContractEventsSignatures.ColonyFundsMovedBetweenFundingPots,
+    colonyAddress,
+  );
 };