(self)
| 363 | self._send_packet(packet) |
| 364 | |
| 365 | def connect(self): |
| 366 | if self.websocket: |
| 367 | self.websocket.close() |
| 368 | if self.event_stream: |
| 369 | self.event_stream = None |
| 370 | self.websocket = websocket.WebSocket(sslopt={"cert_reqs": ssl.CERT_NONE}) |
| 371 | self.websocket.connect( |
| 372 | self.cloud_host, |
| 373 | cookie=self.cookie, |
| 374 | origin=self.origin, |
| 375 | enable_multithread=True, |
| 376 | timeout=self.ws_timeout, |
| 377 | header=self.header, |
| 378 | ) |
| 379 | self._handshake() |
| 380 | self.active_connection = True |
| 381 | if self.print_connect_message: |
| 382 | print("Connected to cloud server ", self.cloud_host) |
| 383 | |
| 384 | def disconnect(self): |
| 385 | self.active_connection = False |
no test coverage detected