mirror of
https://github.com/usmannasir/cyberpanel.git
synced 2025-11-06 21:35:55 +01:00
118 lines
3.7 KiB
Python
118 lines
3.7 KiB
Python
import signal
|
|
import sys
|
|
import ssl
|
|
from SimpleWebSocketServer import WebSocket, SimpleSSLWebSocketServer
|
|
import paramiko
|
|
import os
|
|
import json
|
|
import threading as multi
|
|
import time
|
|
|
|
class SSHServer(multi.Thread):
|
|
OKGREEN = '\033[92m'
|
|
ENDC = '\033[0m'
|
|
|
|
def loadPublicKey(self):
|
|
pubkey = '/root/.ssh/cyberpanel.pub'
|
|
data = open(pubkey, 'r').read()
|
|
authFile = '/root/.ssh/authorized_keys'
|
|
|
|
checker = 1
|
|
|
|
try:
|
|
authData = open(authFile, 'r').read()
|
|
if authData.find(data) > -1:
|
|
checker = 0
|
|
except:
|
|
pass
|
|
|
|
if checker:
|
|
writeToFile = open(authFile, 'a')
|
|
writeToFile.writelines(data)
|
|
writeToFile.close()
|
|
|
|
def __init__(self, websocket):
|
|
multi.Thread.__init__(self)
|
|
self.sshclient = paramiko.SSHClient()
|
|
self.sshclient.load_system_host_keys()
|
|
self.sshclient.set_missing_host_key_policy(paramiko.AutoAddPolicy())
|
|
k = paramiko.RSAKey.from_private_key_file('/root/.ssh/cyberpanel')
|
|
|
|
## Load Public Key
|
|
self.loadPublicKey()
|
|
|
|
self.sshclient.connect('127.0.0.1', 22, username='root', pkey=k)
|
|
self.shell = self.sshclient.invoke_shell(term='xterm')
|
|
self.shell.settimeout(0)
|
|
|
|
self.websocket = websocket
|
|
self.color = 0
|
|
|
|
def recvData(self):
|
|
while True:
|
|
try:
|
|
if os.path.exists(self.websocket.verifyPath):
|
|
if self.websocket.filePassword == self.websocket.filePassword:
|
|
if self.shell.recv_ready():
|
|
if self.color == 0:
|
|
text = '%sEnjoy your accelerated Internet by CyberPanel and LiteSpeed%s' % (SSHServer.OKGREEN, SSHServer.ENDC)
|
|
nText = 'Enjoy your accelerated Internet by CyberPanel'
|
|
self.websocket.sendMessage(self.shell.recv(9000).decode("utf-8").replace(nText, text))
|
|
self.color = 1
|
|
else:
|
|
self.websocket.sendMessage(self.shell.recv(9000).decode("utf-8"))
|
|
else:
|
|
time.sleep(0.01)
|
|
except BaseException, msg:
|
|
time.sleep(0.1)
|
|
|
|
def run(self):
|
|
try:
|
|
self.recvData()
|
|
except BaseException, msg:
|
|
print(str(msg))
|
|
|
|
|
|
class WebTerminalServer(WebSocket):
|
|
|
|
def handleMessage(self):
|
|
try:
|
|
data = json.loads(self.data)
|
|
if str(self.data).find('"tp":"init"') > -1:
|
|
self.verifyPath = str(data['data']['verifyPath'])
|
|
self.password = str(data['data']['password'])
|
|
self.filePassword = open(self.verifyPath, 'r').read()
|
|
else:
|
|
if os.path.exists(self.verifyPath):
|
|
if self.filePassword == self.filePassword:
|
|
self.shell.send(str(data['data']))
|
|
except:
|
|
pass
|
|
|
|
def handleConnected(self):
|
|
self.sh = SSHServer(self)
|
|
self.shell = self.sh.shell
|
|
self.sh.start()
|
|
|
|
def handleClose(self):
|
|
try:
|
|
os.remove(self.verifyPath)
|
|
except:
|
|
pass
|
|
|
|
|
|
if __name__ == "__main__":
|
|
pidfile = '/usr/local/CyberCP/WebTerminal/pid'
|
|
|
|
writeToFile = open(pidfile, 'w')
|
|
writeToFile.write(str(os.getpid()))
|
|
writeToFile.close()
|
|
|
|
server = SimpleSSLWebSocketServer('0.0.0.0', '5678', WebTerminalServer, '/usr/local/lscp/conf/cert.pem', '/usr/local/lscp/conf/key.pem', version=ssl.PROTOCOL_TLSv1)
|
|
|
|
def close_sig_handler(signal, frame):
|
|
server.close()
|
|
sys.exit()
|
|
|
|
signal.signal(signal.SIGINT, close_sig_handler)
|
|
server.serveforever() |