| 32 | |
| 33 | |
| 34 | def send_pfs_update( |
| 35 | raiden: "RaidenService", |
| 36 | canonical_identifier: CanonicalIdentifier, |
| 37 | update_fee_schedule: bool = False, |
| 38 | ) -> None: |
| 39 | if raiden.routing_mode == RoutingMode.PRIVATE: |
| 40 | return |
| 41 | |
| 42 | channel_state = views.get_channelstate_by_canonical_identifier( |
| 43 | chain_state=views.state_from_raiden(raiden), canonical_identifier=canonical_identifier |
| 44 | ) |
| 45 | |
| 46 | if channel_state is None: |
| 47 | return |
| 48 | |
| 49 | capacity_msg = PFSCapacityUpdate.from_channel_state(channel_state) |
| 50 | capacity_msg.sign(raiden.signer) |
| 51 | raiden.transport.broadcast(capacity_msg, device_id=DeviceIDs.PFS) |
| 52 | log.debug( |
| 53 | "Sent a PFS Capacity Update", |
| 54 | node=to_checksum_address(raiden.address), |
| 55 | message=capacity_msg, |
| 56 | channel_state=channel_state, |
| 57 | ) |
| 58 | |
| 59 | if update_fee_schedule: |
| 60 | fee_msg = PFSFeeUpdate.from_channel_state(channel_state) |
| 61 | fee_msg.sign(raiden.signer) |
| 62 | |
| 63 | raiden.transport.broadcast(fee_msg, device_id=DeviceIDs.PFS) |
| 64 | log.debug( |
| 65 | "Sent a PFS Fee Update", |
| 66 | node=to_checksum_address(raiden.address), |
| 67 | message=fee_msg, |
| 68 | channel_state=channel_state, |
| 69 | ) |
| 70 | |
| 71 | |
| 72 | def update_monitoring_service_from_balance_proof( |