(id)
| 140 | global savedPeerId |
| 141 | @peer.on(PeerEventType.Open) |
| 142 | async def peer_open(id): |
| 143 | logger.info('Peer signaling connection open.') |
| 144 | global savedPeerId |
| 145 | # Workaround for peer.reconnect deleting previous id |
| 146 | if peer.id is None: |
| 147 | logger.info('pnpService: Received null id from peer open') |
| 148 | peer.id = savedPeerId |
| 149 | else: |
| 150 | if savedPeerId != peer.id: |
| 151 | logger.info( |
| 152 | 'PNP Service returned new peerId. Old {}, New {}', |
| 153 | savedPeerId, |
| 154 | peer.id |
| 155 | ) |
| 156 | _savePeerId(peer.id) |
| 157 | logger.info('savedPeerId: {}', peer.id) |
| 158 | |
| 159 | @peer.on(PeerEventType.Disconnected) |
| 160 | async def peer_disconnected(peerId): |
nothing calls this directly
no test coverage detected