(self)
| 251 | noop_count += 1 |
| 252 | |
| 253 | def do_CONNECT(self): |
| 254 | if not self.validate_auth(): |
| 255 | self.send_response(401) |
| 256 | self.end_headers() |
| 257 | return |
| 258 | |
| 259 | self.send_response(200) |
| 260 | self.end_headers() |
| 261 | |
| 262 | remote_host, remote_port = self.path.split(':') |
| 263 | remote_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) |
| 264 | remote_socket.connect((remote_host, int(remote_port))) |
| 265 | |
| 266 | self._tunnel(self.request, remote_socket) |
| 267 | remote_socket.close() |
| 268 | |
| 269 | def validate_auth(self): |
| 270 | return True |
nothing calls this directly
no test coverage detected