Function wait_for_reachable

tools/debugging/stress_test_transfers.py:203–229

Wait until the nodes used for the transfers can see each other.

(
    transfers: List[TransferPath], token_address: str, retry_timeout: int
)

def wait_for_reachable(
    transfers: List[TransferPath], token_address: str, retry_timeout: int
) -> None:
    """Wait until the nodes used for the transfers can see each other."""

    # Deduplicate the URLs for the channels which need reachability testing
    channels_not_reachable = set()
    for transfer in transfers:
        for payer, payee in zip(transfer, transfer[1:]):
            channel_url = f"{payer.url}/api/v1/channels/{token_address}/{payee.config.address}"
            channels_not_reachable.add(channel_url)

    # Now wait until every reachability constraint is satisfied
    while channels_not_reachable:
        log.info(f"Waiting for reachability of partner nodes: {channels_not_reachable}")

        for url in channels_not_reachable.copy():
            response = requests.get(url, headers={"Content-Type": "application/json"})
            data = response.json()

            # The return data **may** be `None`, this looks like a race
            # condition in the Raiden client REST API.
            if data and data.get("network_state") == NetworkState.REACHABLE.value:
                channels_not_reachable.remove(url)

        if channels_not_reachable:
            gevent.sleep(retry_timeout)


def start_and_wait_for_server(