Merge pull request #327 from JoinColony/feat/create-stream-motion

 Streaming Payments API: Creating streams using motions

Author: jakubcolony

src/graphql/generated.ts

@@ -652,6 +652,8 @@ export enum ColonyActionType {
   CreateExpenditure = 'CREATE_EXPENDITURE',
   /** An action related to creating a streaming payment */
   CreateStreamingPayment = 'CREATE_STREAMING_PAYMENT',
+  /** An action related to creating a streaming payment via a motion */
+  CreateStreamingPaymentMotion = 'CREATE_STREAMING_PAYMENT_MOTION',
   /** 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/motions/motionCreated/handlers/index.ts

@@ -13,4 +13,4 @@ export { handleMulticallMotion } from './multicall';
 export { handleMakeArbitraryTransactionsMotion } from './makeArbitraryTransactions';
 export { handleMetadataDeltaMotion } from './metadataDelta';
 export * from './expenditures';
-export * from './streamingPayments.ts';
+export * from './streamingPayments';

src/handlers/motions/motionCreated/handlers/streamingPayments/cancelStreamingPaymentsMotion.ts

@@ -0,0 +1,27 @@
+import { TransactionDescription } from 'ethers/lib/utils';
+import { ContractEvent, motionNameMapping } from '~types';
+import { createMotionInDB } from '../../helpers';
+import {
+  getDomainDatabaseId,
+  getExpenditureDatabaseId,
+  toNumber,
+} from '~utils';
+
+export default async (
+  colonyAddress: string,
+  event: ContractEvent,
+  { name, args: actionArgs }: TransactionDescription,
+): Promise<void> => {
+  const { args } = event;
+  const [, , streamingPaymentId] = actionArgs;
+  const [, , domainId] = args;
+
+  await createMotionInDB(colonyAddress, event, {
+    type: motionNameMapping[name],
+    fromDomainId: getDomainDatabaseId(colonyAddress, domainId),
+    streamingPaymentId: getExpenditureDatabaseId(
+      colonyAddress,
+      toNumber(streamingPaymentId),
+    ),
+  });
+};

src/handlers/motions/motionCreated/handlers/streamingPayments/createStreamingPaymentMotion.ts

@@ -0,0 +1,27 @@
+import { TransactionDescription } from 'ethers/lib/utils';
+import { ContractEvent, motionNameMapping } from '~types';
+import { createMotionInDB } from '../../helpers';
+import {
+  getDomainDatabaseId,
+  getExpenditureDatabaseId,
+  toNumber,
+} from '~utils';
+
+export default async (
+  colonyAddress: string,
+  event: ContractEvent,
+  { name, args: actionArgs }: TransactionDescription,
+): Promise<void> => {
+  const { args } = event;
+  const [, , streamingPaymentId] = actionArgs;
+  const [, , domainId] = args;
+
+  await createMotionInDB(colonyAddress, event, {
+    type: motionNameMapping[name],
+    fromDomainId: getDomainDatabaseId(colonyAddress, domainId),
+    streamingPaymentId: getExpenditureDatabaseId(
+      colonyAddress,
+      toNumber(streamingPaymentId),
+    ),
+  });
+};

src/handlers/motions/motionCreated/handlers/streamingPayments.ts/index.ts renamed to src/handlers/motions/motionCreated/handlers/streamingPayments/index.ts

@@ -236,6 +236,15 @@ export const handleMotionCreated: EventHandler = async (
         break;
       }
 
+      case StreamingPaymentsOperations.CreateStreamingPayment: {
+        await handleCancelStreamingPaymentsMotion(
+          colonyAddress,
+          event,
+          parsedAction,
+        );
+        break;
+      }
+
       default: {
         break;
       }

src/handlers/motions/motionCreated/motionCreated.ts

@@ -27,6 +27,7 @@ export enum ColonyOperations {
 }
 
 export enum StreamingPaymentsOperations {
+  CreateStreamingPayment = 'create',
   CancelStreamingPayment = 'cancel',
 }
 
@@ -75,6 +76,8 @@ export const motionNameMapping: { [key: string]: ColonyActionType } = {
     ColonyActionType.ReleaseStagedPaymentsMotion,
   [StreamingPaymentsOperations.CancelStreamingPayment]:
     ColonyActionType.CancelStreamingPaymentMotion,
+  [StreamingPaymentsOperations.CreateStreamingPayment]:
+    ColonyActionType.CreateStreamingPaymentMotion,
 };
 
 export enum MotionSide {