Wait until the token network is visible to the RaidenService. Note: This does not time out, use gevent.Timeout.
(
raiden: "RaidenService",
token_network_registry_address: TokenNetworkRegistryAddress,
token_address: TokenAddress,
retry_timeout: float,
)
| 500 | |
| 501 | |
| 502 | def wait_for_token_network( |
| 503 | raiden: "RaidenService", |
| 504 | token_network_registry_address: TokenNetworkRegistryAddress, |
| 505 | token_address: TokenAddress, |
| 506 | retry_timeout: float, |
| 507 | ) -> None: # pragma: no unittest |
| 508 | """Wait until the token network is visible to the RaidenService. |
| 509 | |
| 510 | Note: |
| 511 | This does not time out, use gevent.Timeout. |
| 512 | """ |
| 513 | token_network = views.get_token_network_by_token_address( |
| 514 | views.state_from_raiden(raiden), token_network_registry_address, token_address |
| 515 | ) |
| 516 | log_details = { |
| 517 | "token_network_registry_address": to_checksum_address(token_network_registry_address), |
| 518 | "token_address": to_checksum_address(token_address), |
| 519 | } |
| 520 | while token_network is None: |
| 521 | assert raiden, ALARM_TASK_ERROR_MSG |
| 522 | assert raiden.alarm, ALARM_TASK_ERROR_MSG |
| 523 | |
| 524 | log.debug("wait_for_token_network", **log_details) |
| 525 | gevent.sleep(retry_timeout) |
| 526 | token_network = views.get_token_network_by_token_address( |
| 527 | views.state_from_raiden(raiden), token_network_registry_address, token_address |
| 528 | ) |
| 529 | |
| 530 | |
| 531 | def wait_for_settle( |