feat: multi sig

package.json

@@ -25,8 +25,8 @@
   },
   "homepage": "https://github.com/JoinColony/tx-ingestor",
   "dependencies": {
-    "@colony/colony-js": "^0.0.0-snapshot-69cce09-20240724101901",
-    "@colony/events": "0.0.0-snapshot-20240329154314",
+    "@colony/colony-js": "0.0.0-snapshot-85097e5-20240902145835",
+    "@colony/events": "0.0.0-snapshot-20240415105500",
     "aws-amplify": "^4.3.43",
     "cross-fetch": "^4.0.0",
     "dotenv": "^16.0.3",

src/constants.ts

@@ -11,6 +11,7 @@ export const SUPPORTED_EXTENSION_IDS = [
   Extension.StakedExpenditure,
   Extension.StagedExpenditure,
   Extension.StreamingPayments,
+  Extension.MultisigPermissions,
 ];
 
 export const SIMPLE_DECISIONS_ACTION_CODE = '0x12345678';

src/eventListeners/extension/index.ts

@@ -30,6 +30,7 @@ import {
   handleExtensionUninstalled,
   handleExtensionUpgraded,
 } from '~handlers';
+import { setupListenersForMultiSigExtensions } from './multiSig';
 
 export * from './stakedExpenditure';
 export * from './stagedExpenditure';
@@ -91,6 +92,7 @@ export const setupListenersForExtensions = async (): Promise<void> => {
   await setupListenersForStakedExpenditureExtensions();
   await setupListenersForStagedExpenditureExtensions();
   await setupListenersForStreamingPaymentsExtensions();
+  await setupListenersForMultiSigExtensions();
 };
 
 export const fetchExistingExtensions = async (

src/eventListeners/extension/multiSig.ts

@@ -0,0 +1,125 @@
+import { Extension, getExtensionHash } from '@colony/colony-js';
+import { handleManagePermissionsAction } from '~handlers';
+import {
+  handleMultiSigApprovalChanged,
+  handleMultiSigRejectionChanged,
+  handleMultiSigDomainSkillThresholdSet,
+  handleMultiSigGlobalThresholdSet,
+  handleMultiSigMotionCancelled,
+  handleMultiSigMotionCreated,
+  handleMultiSigMotionExecuted,
+} from '~handlers/multiSig';
+import { mutate, query } from '~amplifyClient';
+import {
+  GetActiveColonyMultisigsDocument,
+  GetActiveColonyMultisigsQuery,
+  GetActiveColonyMultisigsQueryVariables,
+  GetAllMultiSigRolesDocument,
+  GetAllMultiSigRolesQuery,
+  GetAllMultiSigRolesQueryVariables,
+  RemoveMultiSigRoleDocument,
+  RemoveMultiSigRoleMutation,
+  RemoveMultiSigRoleMutationVariables,
+} from '~graphql';
+
+import { ContractEventsSignatures } from '~types';
+import { notNull } from '~utils';
+import { addMultiSigParamsToDB } from '~utils/extensions/multiSig';
+import { output } from '~utils/logger';
+
+import { addExtensionEventListener, fetchExistingExtensions } from './index';
+import { updateMultiSigInDB } from '~handlers/multiSig/helpers';
+
+export const setupListenersForMultiSigExtensions = async (): Promise<void> => {
+  output(`Setting up listeners for MultiSig extensions`);
+  const existingExtensions = await fetchExistingExtensions(
+    getExtensionHash(Extension.MultisigPermissions),
+  );
+  existingExtensions.forEach((extension) =>
+    setupMultiSigListeners(extension.id, extension.colonyId),
+  );
+};
+
+export const handleMultiSigInstalled = async (
+  multiSigAddress: string,
+  colonyAddress: string,
+): Promise<void> => {
+  setupMultiSigListeners(multiSigAddress, colonyAddress);
+  await addMultiSigParamsToDB(multiSigAddress, colonyAddress);
+};
+
+export const handleMultiSigUninstalled = async (
+  colonyAddress: string,
+): Promise<void> => {
+  const multiSigRolesQuery = await query<
+    GetAllMultiSigRolesQuery,
+    GetAllMultiSigRolesQueryVariables
+  >(GetAllMultiSigRolesDocument, {
+    colonyAddress,
+  });
+
+  const roleEntries = multiSigRolesQuery?.data?.getRoleByColony?.items ?? [];
+
+  await Promise.all(
+    roleEntries.filter(notNull).map(async (entry) => {
+      await mutate<
+        RemoveMultiSigRoleMutation,
+        RemoveMultiSigRoleMutationVariables
+      >(RemoveMultiSigRoleDocument, {
+        id: entry.id,
+      });
+    }),
+  );
+
+  const activeMultiSigsQuery = await query<
+    GetActiveColonyMultisigsQuery,
+    GetActiveColonyMultisigsQueryVariables
+  >(GetActiveColonyMultisigsDocument, {
+    colonyAddress,
+  });
+
+  const multiSigs =
+    activeMultiSigsQuery?.data?.getMultiSigByColonyAddress?.items ?? [];
+  await Promise.all(
+    multiSigs.filter(notNull).map(async (entry) => {
+      await updateMultiSigInDB({
+        id: entry.id,
+        isExecuted: false,
+        isRejected: true,
+      });
+    }),
+  );
+};
+
+export const setupMultiSigListeners = (
+  multiSigAddress: string,
+  colonyAddress: string,
+): void => {
+  const multiSigEvents = {
+    [ContractEventsSignatures.MultisigMotionExecuted]:
+      handleMultiSigMotionExecuted,
+    [ContractEventsSignatures.MultisigMotionCancelled]:
+      handleMultiSigMotionCancelled,
+    [ContractEventsSignatures.MultisigMotionCreated]:
+      handleMultiSigMotionCreated,
+    [ContractEventsSignatures.MultisigApprovalChanged]:
+      handleMultiSigApprovalChanged,
+    [ContractEventsSignatures.MultisigRoleSet]: handleManagePermissionsAction,
+    [ContractEventsSignatures.MultisigRejectionChanged]:
+      handleMultiSigRejectionChanged,
+    [ContractEventsSignatures.MultisigGlobalThresholdSet]:
+      handleMultiSigGlobalThresholdSet,
+    [ContractEventsSignatures.MultisigDomainSkillThresholdSet]:
+      handleMultiSigDomainSkillThresholdSet,
+  };
+
+  Object.entries(multiSigEvents).forEach(([eventSignature, handler]) =>
+    addExtensionEventListener(
+      eventSignature as ContractEventsSignatures,
+      Extension.MultisigPermissions,
+      multiSigAddress,
+      colonyAddress,
+      handler,
+    ),
+  );
+};

src/eventListeners/types.ts

@@ -15,6 +15,7 @@ export enum EventListenerType {
   Extension = 'Extension',
   Token = 'Token',
   OneTxPayment = 'OneTxPayment',
+  MultisigPermissions = 'MultisigPermissions',
 }
 
 export interface ColonyEventListener extends BaseEventListener {

src/graphql/fragments/actions.graphql

@@ -0,0 +1,13 @@
+fragment ActionMetadataInfo on ColonyAction {
+  id
+  pendingDomainMetadata {
+    ...DomainMetadata
+  }
+  pendingColonyMetadata {
+    ...ColonyMetadata
+  }
+  colonyDecisionId
+  amount
+  networkFee
+  type
+}

src/graphql/fragments/colony.graphql

@@ -40,12 +40,18 @@ fragment ColonyMetadata on ColonyMetadata {
     name
     link
   }
+  objective {
+    title
+    description
+    progress
+  }
   changelog {
     transactionHash
     oldDisplayName
     newDisplayName
     hasAvatarChanged
     hasDescriptionChanged
     haveExternalLinksChanged
+    hasObjectiveChanged
   }
 }

src/graphql/fragments/multiSig.graphql

@@ -0,0 +1,33 @@
+fragment MultiSigUserSignature on MultiSigUserSignature {
+  id
+  multiSigId
+  role
+  colonyAddress
+  userAddress
+  vote
+  createdAt
+}
+
+fragment ColonyMultiSig on ColonyMultiSig {
+  id
+  colonyAddress
+  nativeMultiSigId
+  multiSigDomainId
+  nativeMultiSigDomainId
+  requiredPermissions
+  transactionHash
+  isExecuted
+  isRejected
+  isDecision
+  hasActionCompleted
+  signatures {
+    items {
+      ...MultiSigUserSignature
+    }
+  }
+  executedAt
+  executedBy
+  rejectedAt
+  rejectedBy
+  createdAt
+}