Function inplace_delete_message

raiden/transfer/node.py:452–474

Check if the message exists in queue with ID `queueid` and exclude if found.

(
    message_queue: List[SendMessageEvent],
    state_change: Union[ReceiveDelivered, ReceiveProcessed, ReceiveWithdrawConfirmation],
)

def inplace_delete_message(
    message_queue: List[SendMessageEvent],
    state_change: Union[ReceiveDelivered, ReceiveProcessed, ReceiveWithdrawConfirmation],
) -> None:
    """Check if the message exists in queue with ID `queueid` and exclude if found."""
    for message in list(message_queue):
        # A withdraw request is only confirmed by a withdraw confirmation.
        # This is done because Processed is not an indicator that the partner has
        # processed and **accepted** our withdraw request. Receiving
        # `Processed` here would cause the withdraw request to be removed
        # from the queue although the confirmation may have not been sent.
        # This is avoided by waiting for the confirmation before removing
        # the withdraw request.
        if isinstance(message, SendWithdrawRequest):
            if not isinstance(state_change, ReceiveWithdrawConfirmation):
                continue

        message_found = (
            message.message_identifier == state_change.message_identifier
            and message.recipient == state_change.sender
        )
        if message_found:
            message_queue.remove(message)


def handle_block(chain_state: ChainState, state_change: Block) -> TransitionResult[ChainState]: