Save new stake fraction in db

src/eventListeners/colony.ts

@@ -44,7 +44,6 @@ import {
   handleMoveFundsAction,
   handleReputationMiningCycleComplete,
   handleSetTokenAuthority,
-  handleStakeFractionSet,
   handleTokenUnlockedAction,
   handleTransfer,
 } from '~handlers';
@@ -152,7 +151,6 @@ export const setupListenersForColony = (
       handleExpenditurePayoutClaimed,
     [ContractEventsSignatures.ExpenditureStateChanged]:
       handleExpenditureStateChanged,
-    [ContractEventsSignatures.StakeFractionSet]: handleStakeFractionSet,
     [ContractEventsSignatures.AnnotateTransaction]: handleAnnotateTransaction,
     [ContractEventsSignatures.ArbitraryTransaction]:
       handleMakeAbitraryTransactionAction,

src/eventListeners/extension/stakedExpenditure.ts

@@ -4,6 +4,7 @@ import {
   handleExpenditureMadeViaStake,
   handleExpenditureStakerPunished,
   handleExtensionInitialised,
+  handleStakeFractionSet,
   handleStakeReclaimed,
 } from '~handlers';
 
@@ -41,6 +42,7 @@ export const setupListenersForStakedExpenditure = (
         handleExpenditureStakerPunished,
       [ContractEventsSignatures.ExpenditureMadeViaStake]:
         handleExpenditureMadeViaStake,
+      [ContractEventsSignatures.StakeFractionSet]: handleStakeFractionSet,
     };
 
     Object.entries(eventHandlers).forEach(([eventSignature, handler]) =>

src/handlers/expenditures/stakeFractionSet.ts

@@ -1,49 +1,30 @@
-import { ContractEvent, EventHandler } from '~types';
+import { ExtensionEventListener } from '~eventListeners';
+import { EventHandler } from '~types';
+import {
+  addStakedExpenditureParamsToDB,
+  getStakedExpenditureClient,
+} from '~utils';
 
 export const handleStakeFractionSet: EventHandler = async (
-  event: ContractEvent,
+  _,
+  listener,
 ): Promise<void> => {
-  console.log(event.args);
-  //   const { colonyAddress, blockNumber } = event;
-  //   const { streamingPaymentId } = event.args;
-  //   const convertedNativeId = toNumber(streamingPaymentId);
-  //   if (!colonyAddress) {
-  //     return;
-  //   }
-  //   const streamingPaymentsClient = await getStreamingPaymentsClient(
-  //     colonyAddress,
-  //   );
-  //   if (!streamingPaymentsClient) {
-  //     return;
-  //   }
-  //   const streamingPayment = await streamingPaymentsClient.getStreamingPayment(
-  //     streamingPaymentId,
-  //     { blockTag: blockNumber },
-  //   );
-  //   if (!streamingPayment) {
-  //     return;
-  //   }
-  //   const {
-  //     recipient: recipientAddress,
-  //     domainId,
-  //     startTime,
-  //     endTime,
-  //     interval,
-  //   } = streamingPayment;
-  //   const databaseId = getExpenditureDatabaseId(colonyAddress, convertedNativeId);
-  //   verbose(`Streaming payment with ID ${databaseId} created`);
-  //   await mutate<
-  //     CreateStreamingPaymentMutation,
-  //     CreateStreamingPaymentMutationVariables
-  //   >(CreateStreamingPaymentDocument, {
-  //     input: {
-  //       id: databaseId,
-  //       nativeId: convertedNativeId,
-  //       recipientAddress,
-  //       nativeDomainId: toNumber(domainId),
-  //       startTime: toNumber(startTime),
-  //       endTime: toNumber(endTime),
-  //       interval: interval.toString(),
-  //     },
-  //   });
+  const { colonyAddress } = listener as ExtensionEventListener;
+
+  if (!colonyAddress) {
+    return;
+  }
+
+  const stakedExpenditureClient = await getStakedExpenditureClient(
+    colonyAddress,
+  );
+
+  if (!stakedExpenditureClient) {
+    return;
+  }
+
+  await addStakedExpenditureParamsToDB(
+    stakedExpenditureClient?.address,
+    colonyAddress,
+  );
 };

src/types/events.ts

@@ -97,7 +97,7 @@ export enum ContractEventsSignatures {
   StakeReclaimed = 'StakeReclaimed(uint256)',
   ExpenditureStakerPunished = 'ExpenditureStakerPunished(address,uint256,bool)',
   ExpenditureMadeViaStake = 'ExpenditureMadeViaStake(address,uint256,uint256)',
-  StakeFractionSet = 'StakeFractionSet(address, uint256)',
+  StakeFractionSet = 'StakeFractionSet(address,uint256)',
 
   // Staged Expenditures
   ExpenditureMadeStaged = 'ExpenditureMadeStaged(uint256,bool)',