Merge pull request #217 from JoinColony/feat/2215-cancel-streams-using-permissions

Feat: Cancel streams using permissions

Author: iamsamgibbs

package-lock.json

@@ -25,8 +25,8 @@
   },
   "homepage": "https://github.com/JoinColony/tx-ingestor",
   "dependencies": {
-    "@colony/colony-js": "^7.1.0-next.0",
-    "@colony/events": "^1.0.1",
+    "@colony/colony-js": "^0.0.0-snapshot-20240503122240",
+    "@colony/events": "^0.0.0-snapshot-20240503122240",
     "aws-amplify": "^4.3.43",
     "cross-fetch": "^4.0.0",
     "dotenv": "^16.0.3",

package.json

@@ -23,6 +23,9 @@ export const setupListenersForStreamingPayments = (
   const events = [
     ContractEventsSignatures.StreamingPaymentCreated,
     ContractEventsSignatures.PaymentTokenUpdated,
+    ContractEventsSignatures.StartTimeSet,
+    ContractEventsSignatures.EndTimeSet,
+    ContractEventsSignatures.ClaimWaived,
   ];
 
   events.forEach((eventSignature) =>

src/eventListeners/extension/streamingPayments.ts

@@ -52,6 +52,7 @@ import {
   handlePaymentTokenUpdated,
   handleSetTokenAuthority,
   handleExpenditureStateChanged,
+  handleStreamingPaymentEndTimeSet,
 } from './handlers';
 
 dotenv.config();
@@ -329,6 +330,11 @@ export default async (event: ContractEvent): Promise<void> => {
       return;
     }
 
+    case ContractEventsSignatures.EndTimeSet: {
+      await handleStreamingPaymentEndTimeSet(event);
+      return;
+    }
+
     case ContractEventsSignatures.AnnotateTransaction: {
       await handleAnnotateTransaction(event);
       return;