(self, message)
| 481 | |
| 482 | # Incoming handshake set request |
| 483 | def handleHandshake(self, message): |
| 484 | self.setHandshake(message["params"]) |
| 485 | data = self.getHandshakeInfo() |
| 486 | data["cmd"] = "response" |
| 487 | data["to"] = message["req_id"] |
| 488 | self.send(data) # Send response to handshake |
| 489 | # Sent crypt request to client |
| 490 | if self.crypt and not self.sock_wrapped: |
| 491 | server = (self.type == "in") |
| 492 | self.log("Crypt in connection using: %s (server side: %s)..." % (self.crypt, server)) |
| 493 | try: |
| 494 | self.sock = CryptConnection.manager.wrapSocket(self.sock, self.crypt, server, cert_pin=self.cert_pin) |
| 495 | self.sock_wrapped = True |
| 496 | except Exception as err: |
| 497 | if not config.force_encryption: |
| 498 | self.log("Crypt connection error, adding %s:%s as broken ssl. %s" % (self.ip, self.port, Debug.formatException(err))) |
| 499 | self.server.broken_ssl_ips[self.ip] = True |
| 500 | self.close("Broken ssl") |
| 501 | |
| 502 | if not self.sock_wrapped and self.cert_pin: |
| 503 | self.close("Crypt connection error: Socket not encrypted, but certificate pin present") |
| 504 | |
| 505 | # Send data to connection |
| 506 | def send(self, message, streaming=False): |
no test coverage detected