(self)
| 175 | random.seed() |
| 176 | |
| 177 | def _setup_event_system(self): |
| 178 | handlers = [] |
| 179 | |
| 180 | color = self.config.logging and 'color' in self.config.logging and self.config.logging['color'] |
| 181 | debug = self.config.debug |
| 182 | |
| 183 | handlers.append(LoggingHandler(color, debug)) |
| 184 | handlers.append(SocialHandler(self)) |
| 185 | handlers.append(CaptchaHandler(self, self.config.solve_captcha)) |
| 186 | |
| 187 | if self.config.websocket_server_url: |
| 188 | if self.config.websocket_start_embedded_server: |
| 189 | self.sio_runner = SocketIoRunner(self.config.websocket_server_url) |
| 190 | self.sio_runner.start_listening_async() |
| 191 | |
| 192 | websocket_handler = SocketIoHandler( |
| 193 | self, |
| 194 | self.config.websocket_server_url |
| 195 | ) |
| 196 | handlers.append(websocket_handler) |
| 197 | |
| 198 | if self.config.websocket_remote_control: |
| 199 | remote_control = WebsocketRemoteControl(self).start() |
| 200 | |
| 201 | # @var EventManager |
| 202 | self.event_manager = EventManager(self.config.walker_limit_output, *handlers) |
| 203 | self._register_events() |
| 204 | if self.config.show_events: |
| 205 | self.event_manager.event_report() |
| 206 | sys.exit(1) |
| 207 | |
| 208 | # Registering event: |
| 209 | # self.event_manager.register_event("location", parameters=['lat', 'lng']) |
| 210 | # |
| 211 | # Emitting event should be enough to add logging and send websocket |
| 212 | # message: : |
| 213 | # self.event_manager.emit('location', 'level'='info', data={'lat': 1, 'lng':1}), |
| 214 | |
| 215 | def _register_events(self): |
| 216 | self.event_manager.register_event( |
no test coverage detected