(sid)
| 133 | raise ConnectionRefusedError('authentication failed') |
| 134 | |
| 135 | async def config(sid): |
| 136 | await self.sio.sleep(0.1) |
| 137 | |
| 138 | # supported features |
| 139 | features = ['AGGREGATED_EVENTS'] |
| 140 | if not self.read_only: |
| 141 | features += ['EMIT', 'JOIN', 'LEAVE', 'DISCONNECT', 'MJOIN', |
| 142 | 'MLEAVE', 'MDISCONNECT'] |
| 143 | if self.mode == 'development': |
| 144 | features.append('ALL_EVENTS') |
| 145 | await self.sio.emit('config', {'supportedFeatures': features}, |
| 146 | to=sid, namespace=self.admin_namespace) |
| 147 | |
| 148 | # send current sockets |
| 149 | if self.mode == 'development': |
| 150 | all_sockets = [] |
| 151 | for nsp in self.sio.manager.get_namespaces(): |
| 152 | for sid, eio_sid in self.sio.manager.get_participants( |
| 153 | nsp, None): |
| 154 | all_sockets.append( |
| 155 | self.serialize_socket(sid, nsp, eio_sid)) |
| 156 | await self.sio.emit('all_sockets', all_sockets, to=sid, |
| 157 | namespace=self.admin_namespace) |
| 158 | |
| 159 | self.sio.start_background_task(config, sid) |
| 160 |
nothing calls this directly
no test coverage detected