Feature: Streaming Payments

src/eventListeners/extension/streamingPayments.ts

@@ -1,8 +1,14 @@
 import { Extension, getExtensionHash } from '@colony/colony-js';
 import {
   handlePaymentTokenUpdated,
+  handleStreamingPaymentClaimed,
+  handleStreamingPaymentClaimWaived,
   handleStreamingPaymentCreated,
 } from '~handlers';
+import {
+  handleStreamingPaymentStartTimeSet,
+  handleStreamingPaymentEndTimeSet,
+} from '~handlers/expenditures/index';
 
 import { ContractEventsSignatures } from '~types';
 import { output } from '~utils';
@@ -28,6 +34,11 @@ export const setupListenersForStreamingPayments = (
     [ContractEventsSignatures.StreamingPaymentCreated]:
       handleStreamingPaymentCreated,
     [ContractEventsSignatures.PaymentTokenUpdated]: handlePaymentTokenUpdated,
+    [ContractEventsSignatures.StartTimeSet]: handleStreamingPaymentStartTimeSet,
+    [ContractEventsSignatures.EndTimeSet]: handleStreamingPaymentEndTimeSet,
+    [ContractEventsSignatures.StreamingPaymentClaimed]:
+      handleStreamingPaymentClaimed,
+    [ContractEventsSignatures.ClaimWaived]: handleStreamingPaymentClaimWaived,
   };
 
   Object.entries(eventHandlers).forEach(([eventSignature, handler]) =>

src/graphql/fragments/expenditures.graphql

@@ -41,3 +41,36 @@ fragment ExpenditureSlot on ExpenditureSlot {
     networkFee
   }
 }
+
+fragment StreamingPayment on StreamingPayment {
+  id
+  startTime
+  endTime
+  tokenAddress
+  amount
+  interval
+  metadata {
+    ...StreamingPaymentMetadata
+  }
+  claims {
+    amount
+    timestamp
+  }
+}
+
+fragment StreamingPaymentMetadata on StreamingPaymentMetadata {
+  id
+  endCondition
+  changelog {
+    transactionHash
+    oldEndCondition
+    newEndCondition
+  }
+}
+
+fragment StreamingPaymentChanges on StreamingPaymentChanges {
+  startTime
+  endTime
+  interval
+  amount
+}

src/graphql/fragments/motions.graphql

@@ -49,6 +49,8 @@ fragment ColonyMotion on ColonyMotion {
   }
   isDecision
   transactionHash
+  streamingPaymentId
+  pendingStreamingPaymentMetadataId
 }
 
 fragment VoterRecord on VoterRecord {