Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 22 additions & 9 deletions src/modules/paymentProcessor/PP_Streaming_v1.sol
Original file line number Diff line number Diff line change
Expand Up @@ -245,8 +245,9 @@ contract PP_Streaming_v1 is Module_v1, IPP_Streaming_v1 {
/// @inheritdoc IPaymentProcessor_v1
function cancelRunningPayments(IERC20PaymentClientBase_v1 client)
external
onlyModule
validClient(address(client))
// onlyModule
// validClient(address(client))
onlyOrchestratorAdmin
{
_cancelRunningOrders(address(client));
}
Expand Down Expand Up @@ -540,17 +541,29 @@ contract PP_Streaming_v1 is Module_v1, IPP_Streaming_v1 {
uint streamId;
for (index; index < streamIdsArrayLength;) {
streamId = streamIdsArray[index];
_claimForSpecificStream(client, paymentReceiver, streamId);

// -------------------------------------------------------
// Note: Temporary Fix to prevent claims of faulty streams
// _claimForSpecificStream(client, paymentReceiver, streamId);
// -------------------------------------------------------

// If the paymentOrder being removed was already past its duration, then it would have been removed
// in the earlier _claimForSpecificStream call.
// Otherwise, we would remove that paymentOrder in the following lines.
if (
block.timestamp
< endForSpecificStream(client, paymentReceiver, streamId)
) {
_afterClaimCleanup(client, paymentReceiver, streamId);
}
// -------------------------------------------------------
// Note: Temporary Fix to prevent claims of faulty streams
// if (
// block.timestamp
// < endForSpecificStream(client, paymentReceiver, streamId)
// ) {
// _afterClaimCleanup(client, paymentReceiver, streamId);
// }
// -------------------------------------------------------

// Note: Temporary Fix to cancel all of the faulty streams
// -------------------------------------------------------
_afterClaimCleanup(client, paymentReceiver, streamId);
// -------------------------------------------------------

unchecked {
++index;
Expand Down