Feat: create action when creating streaming payment

src/graphql/generated.ts

@@ -400,6 +400,8 @@ export enum ColonyActionType {
   CreateDomainMotion = 'CREATE_DOMAIN_MOTION',
   /** An action related to creating an expenditure (advanced payment) */
   CreateExpenditure = 'CREATE_EXPENDITURE',
+  /** An action related to creating a streaming payment */
+  CreateStreamingPayment = 'CREATE_STREAMING_PAYMENT',
   /** An action related to editing a domain's details */
   EditDomain = 'EDIT_DOMAIN',
   /** An action related to editing a domain's details via a motion */

src/handlers/expenditures/streamingPaymentCreated.ts

@@ -1,20 +1,23 @@
 import { mutate } from '~amplifyClient';
 import {
+  ColonyActionType,
   CreateStreamingPaymentDocument,
   CreateStreamingPaymentMutation,
   CreateStreamingPaymentMutationVariables,
 } from '~graphql';
 import { ContractEvent } from '~types';
 import {
+  getDomainDatabaseId,
   getExpenditureDatabaseId,
   getStreamingPaymentsClient,
   toNumber,
   verbose,
+  writeActionFromEvent,
 } from '~utils';
 
 export default async (event: ContractEvent): Promise<void> => {
   const { colonyAddress, blockNumber } = event;
-  const { streamingPaymentId } = event.args;
+  const { streamingPaymentId, agent: initiatorAddress } = event.args;
   const convertedNativeId = toNumber(streamingPaymentId);
 
   if (!colonyAddress) {
@@ -62,4 +65,11 @@ export default async (event: ContractEvent): Promise<void> => {
       interval: interval.toString(),
     },
   });
+
+  await writeActionFromEvent(event, colonyAddress, {
+    type: ColonyActionType.CreateStreamingPayment,
+    initiatorAddress,
+    expenditureId: databaseId,
+    fromDomainId: getDomainDatabaseId(colonyAddress, toNumber(domainId)),
+  });
 };