'Handle a CONNECT request.'

def handle_http_connect(self, connect, lg):

    self.pathod_handler.wfile.write((('HTTP/1.1    200    Connection    established\r\n' + ('Proxy-agent:    %s\r\n' % version.PATHOD.encode())) + '\r\n'))
    self.pathod_handler.wfile.flush()
    if (not self.pathod_handler.server.ssloptions.not_after_connect):
        try:
            (cert, key, chain_file_) = self.pathod_handler.server.ssloptions.get_cert(connect[0].encode())
            self.pathod_handler.convert_to_ssl(cert, key, handle_sni=self.pathod_handler.handle_sni, request_client_cert=self.pathod_handler.server.ssloptions.request_client_cert, cipher_list=self.pathod_handler.server.ssloptions.ciphers, method=self.pathod_handler.server.ssloptions.ssl_version, options=self.pathod_handler.server.ssloptions.ssl_options, alpn_select=self.pathod_handler.server.ssloptions.alpn_select)
        except exceptions.TlsException as v:
            s = str(v)
            lg(s)
            return (None, dict(type='error', msg=s))
    return (self.pathod_handler.handle_http_request, None)
