Skip to content

Commit

Permalink
Save new stake fraction in db
Browse files Browse the repository at this point in the history
  • Loading branch information
davecreaser authored and jakubcolony committed May 21, 2024
1 parent 6be55a2 commit 05b1725
Show file tree
Hide file tree
Showing 4 changed files with 24 additions and 46 deletions.
1 change: 1 addition & 0 deletions src/eventListeners/extension/stakedExpenditure.ts
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ export const setupListenersForStakedExpenditure = (
ContractEventsSignatures.ExpenditureCancelled,
ContractEventsSignatures.ExpenditureStakerPunished,
ContractEventsSignatures.ExpenditureMadeViaStake,
ContractEventsSignatures.StakeFractionSet,
];

events.forEach((eventSignature) =>
Expand Down
2 changes: 0 additions & 2 deletions src/eventProcessor.ts
Original file line number Diff line number Diff line change
Expand Up @@ -77,8 +77,6 @@ export default async (event: ContractEvent): Promise<void> => {
);
}

console.log('Handling event: ' + event.signature);

switch (event.signature) {
/*
* New Colony Added
Expand Down
65 changes: 22 additions & 43 deletions src/handlers/expenditures/stakeFractionSet.ts
Original file line number Diff line number Diff line change
@@ -1,47 +1,26 @@
import { ContractEvent } from '~types';
import {
addStakedExpenditureParamsToDB,
getStakedExpenditureClient,
} from '~utils';

export default async (event: ContractEvent): 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 } = event;

if (!colonyAddress) {
return;
}

const stakedExpenditureClient = await getStakedExpenditureClient(
colonyAddress,
);

if (!stakedExpenditureClient) {
return;
}

await addStakedExpenditureParamsToDB(
stakedExpenditureClient?.address,
colonyAddress,
);
};
2 changes: 1 addition & 1 deletion src/types/events.ts
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,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)',
Expand Down

0 comments on commit 05b1725

Please sign in to comment.