Handle an incoming client event.
(self, eio_sid, namespace, id, data)
| 576 | self.manager.disconnect(sid, namespace, ignore_queue=True) |
| 577 | |
| 578 | def _handle_event(self, eio_sid, namespace, id, data): |
| 579 | """Handle an incoming client event.""" |
| 580 | namespace = namespace or '/' |
| 581 | sid = self.manager.sid_from_eio_sid(eio_sid, namespace) |
| 582 | self.logger.info('received event "%s" from %s [%s]', data[0], sid, |
| 583 | namespace) |
| 584 | if not self.manager.is_connected(sid, namespace): |
| 585 | self.logger.warning('%s is not connected to namespace %s', |
| 586 | sid, namespace) |
| 587 | return |
| 588 | if self.async_handlers: |
| 589 | self.start_background_task(self._handle_event_internal, self, sid, |
| 590 | eio_sid, data, namespace, id) |
| 591 | else: |
| 592 | self._handle_event_internal(self, sid, eio_sid, data, namespace, |
| 593 | id) |
| 594 | |
| 595 | def _handle_event_internal(self, server, sid, eio_sid, data, namespace, |
| 596 | id): |
no test coverage detected