Close all channels and wait for settlement.
(
self,
registry_address: TokenNetworkRegistryAddress,
token_address: TokenAddress,
retry_timeout: NetworkTimeout = DEFAULT_RETRY_TIMEOUT,
)
| 323 | return token_network_address |
| 324 | |
| 325 | def token_network_leave( |
| 326 | self, |
| 327 | registry_address: TokenNetworkRegistryAddress, |
| 328 | token_address: TokenAddress, |
| 329 | retry_timeout: NetworkTimeout = DEFAULT_RETRY_TIMEOUT, |
| 330 | ) -> List[NettingChannelState]: |
| 331 | """Close all channels and wait for settlement.""" |
| 332 | if not is_binary_address(registry_address): |
| 333 | raise InvalidBinaryAddress("registry_address must be a valid address in binary") |
| 334 | if not is_binary_address(token_address): |
| 335 | raise InvalidBinaryAddress("token_address must be a valid address in binary") |
| 336 | |
| 337 | token_network_address = views.get_token_network_address_by_token_address( |
| 338 | chain_state=views.state_from_raiden(self.raiden), |
| 339 | token_network_registry_address=registry_address, |
| 340 | token_address=token_address, |
| 341 | ) |
| 342 | |
| 343 | if token_network_address is None: |
| 344 | raise UnknownTokenAddress( |
| 345 | f"Token {to_checksum_address(token_address)} is not registered " |
| 346 | f"with the network {to_checksum_address(registry_address)}." |
| 347 | ) |
| 348 | |
| 349 | channels = self.get_channel_list(registry_address, token_address) |
| 350 | self.channel_batch_close( |
| 351 | registry_address=registry_address, |
| 352 | token_address=token_address, |
| 353 | partner_addresses=[c.partner_state.address for c in channels], |
| 354 | retry_timeout=retry_timeout, |
| 355 | ) |
| 356 | return channels |
| 357 | |
| 358 | def is_already_existing_channel( |
| 359 | self, |