完善基础脚本
This commit is contained in:
XiaoXianNv-boot
721
server/run.py
Normal file → Executable file
721
server/run.py
Normal file → Executable file
@@ -1,372 +1,369 @@
|
||||
|
||||
# coding=utf-8
|
||||
#!/bin/python
|
||||
|
||||
import imp
|
||||
import threading
|
||||
import socket
|
||||
import os
|
||||
import time
|
||||
import sys
|
||||
import traceback
|
||||
import socket
|
||||
|
||||
import psutil
|
||||
import random
|
||||
import psutil
|
||||
import traceback
|
||||
import threading
|
||||
|
||||
run_ = 0
|
||||
exit = ''
|
||||
def rom(info):
|
||||
i=0
|
||||
retlist1=[]
|
||||
rom=0
|
||||
disks=1
|
||||
if info['OS'] == "Linux":
|
||||
romsh = os.popen("LANG=en_US df -h")
|
||||
list = romsh.read().split("\n")
|
||||
ilen = len(list)
|
||||
while i < ilen:
|
||||
if list[i] == "":
|
||||
i += 1
|
||||
elif list[i].split(" ")[0] == "Filesystem":
|
||||
i += 1
|
||||
elif list[i].split(" ")[0] == "udev":
|
||||
i += 1
|
||||
elif list[i].split(" ")[0] == "tmpfs":
|
||||
i += 1
|
||||
elif list[i].split(" ")[0] == "devtmpfs":
|
||||
i += 1
|
||||
elif list[i].split(" ")[0] == "overlay":
|
||||
i += 1
|
||||
elif list[i].split(" ")[0][:-1] == "/dev/zram":
|
||||
i += 1
|
||||
elif list[i].split(" ")[0][:-1] == "/dev/loop":
|
||||
i += 1
|
||||
else:
|
||||
|
||||
def httplink(new_client_socket,RUL,RUL_CS,post_data,user,Headers,info):
|
||||
diskinfo = int(list[i].split("%")[0].split(" ")[-1])
|
||||
|
||||
if rom < diskinfo:
|
||||
rom = diskinfo
|
||||
i=i+1
|
||||
disks += 1
|
||||
else:
|
||||
list = psutil.disk_partitions()
|
||||
ilen = len(list)
|
||||
while i < ilen:
|
||||
if list[i].mountpoint == "/boot":
|
||||
i += 1
|
||||
else:
|
||||
try:
|
||||
diskinfo = psutil.disk_usage(list[i].mountpoint)
|
||||
if rom < diskinfo.percent:
|
||||
rom = diskinfo.percent
|
||||
except Exception as e:
|
||||
if(len(e.args) == 2):
|
||||
if e.args[1] != '设备未就绪。':
|
||||
print(e.args)
|
||||
else:
|
||||
print(e.args)
|
||||
i=i+1
|
||||
disks += 1
|
||||
return str(rom)
|
||||
|
||||
|
||||
|
||||
def httpserver_void(new_client_socket,RUL,RUL_CS,post_data,Headers,logs,info):
|
||||
global session_
|
||||
global a
|
||||
global Versino
|
||||
global run_
|
||||
global update
|
||||
global OS
|
||||
global ttime
|
||||
global sent_before
|
||||
global recv_before
|
||||
global exit
|
||||
global ttime
|
||||
global exre
|
||||
|
||||
if RUL == "/favicon.ico":
|
||||
sh = imp.load_source("server/main/http.py","server/main/http.py")
|
||||
if post_data == b'':
|
||||
post = RUL_CS.split('&')
|
||||
else:
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
sh.file(new_client_socket,post,Versino,RUL,user,Headers,info)
|
||||
my_file = "./web/" + info["theme"] + RUL
|
||||
link = ''
|
||||
for i in RUL_CS.split('&'):
|
||||
tmp = i.split('=')
|
||||
if tmp[0] == 'link':
|
||||
link = tmp[1]
|
||||
if user != "no_login":
|
||||
if os.path.isdir(my_file):
|
||||
if os.path.isfile("./web/" + info["theme"] + RUL + "/index.php"):
|
||||
RUL = RUL + "/index.php"
|
||||
else:
|
||||
my_file = "./web/" + info["theme"] + RUL + "/index.html"
|
||||
if os.path.isfile(my_file):
|
||||
RUL = RUL + "/index.html"
|
||||
if os.path.isfile("./web/" + info["theme"] + RUL):
|
||||
tmp2 = RUL.split('.')
|
||||
if tmp2[-1] == 'php':
|
||||
sh = imp.load_source("server/main/http.py","server/main/http.py")
|
||||
if post_data == b'':
|
||||
post = RUL_CS.split('&')
|
||||
else:
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
sh.php(new_client_socket,post,Versino,RUL,user,Headers,info)
|
||||
else:
|
||||
sh = imp.load_source("server/main/http.py","server/main/http.py")
|
||||
if post_data == b'':
|
||||
post = RUL_CS.split('&')
|
||||
else:
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
sh.file(new_client_socket,post,Versino,RUL,user,Headers,info)
|
||||
else:
|
||||
if RUL == "/login":
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
else:
|
||||
if RUL == "/login":
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
name = ""
|
||||
password = ""
|
||||
checkbox = ""
|
||||
for p in post:
|
||||
pp = p.split("=")
|
||||
if pp[0] == "name":
|
||||
name = pp[1]
|
||||
if pp[0] == "password":
|
||||
password = pp[1]
|
||||
if pp[0] == "checkbox":
|
||||
checkbox = pp[1]
|
||||
ifuser = ""
|
||||
ifpass = ""
|
||||
tools = imp.load_source('tools',"Tools/Tools.py")
|
||||
text = ''
|
||||
type = "Content-Type: text/html;charset=UTF-8"
|
||||
if tools.ifuser(name,password) == "yes":
|
||||
text = '{"data":"login"}'
|
||||
cok = ""
|
||||
for x in range(32):
|
||||
cok = cok + random.choice("0123456789qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLLZXCVBNM")
|
||||
fs_rr = session_
|
||||
fs_session = fs_rr.split('\n')
|
||||
for fs_ in fs_session:
|
||||
if fs_ == "sessinon":
|
||||
session_ = (fs_)
|
||||
session_ = session_ + ("\n")
|
||||
else:
|
||||
if fs_ == "":
|
||||
fs_ = fs_
|
||||
else:
|
||||
fs__ = fs_.split(',')
|
||||
session_ = session_ + fs_ + ("\n")
|
||||
import datetime
|
||||
cookie_date = (datetime.datetime.now()+datetime.timedelta(days=1)).strftime("%a, %d %b %Y %H:%M:%S GMT")
|
||||
session_ = session_ + cok + "," + name + "," + cookie_date + "\n"
|
||||
if checkbox == "true":
|
||||
fs_user = open(".config/sessino","r")#sessino
|
||||
fs_r = fs_user.read()
|
||||
fs_rr = fs_r#.decode("utf-8")
|
||||
fs_session = fs_rr.split('\n')
|
||||
fs_user.close()
|
||||
user_write = ''
|
||||
for fs_ in fs_session:
|
||||
if fs_ == "sessinon":
|
||||
fs_ = fs_
|
||||
else:
|
||||
if fs_ == "":
|
||||
fs_ = fs_
|
||||
else:
|
||||
fs__ = fs_.split(",")
|
||||
type = type + "\r\nset-Cookie: Cluster_management_Jiang=" + cok + "; SameSite=Lax; Expires=" + cookie_date + ""
|
||||
fs_user = open(".config/sessino","a")
|
||||
fs_user.write(cok + "," + name + "," + cookie_date + "\n")
|
||||
fs_user.close()
|
||||
else:
|
||||
type = type + "\r\nset-Cookie: Cluster_management_Jiang=" + cok + "; SameSite=Lax;"# Expires=" + cookie_date + "\r\n"
|
||||
else:
|
||||
text = '{"data":"用户名或密码错误"}'
|
||||
sh = imp.load_source("server/main/http.py","server/main/http.py")
|
||||
sh.textpost(new_client_socket,Versino,text,"200",type)
|
||||
else:
|
||||
RUL_ = "/login.html"
|
||||
if RUL[:len("/assets")] == "/assets":
|
||||
RUL_ = RUL
|
||||
sh = imp.load_source("server/main/http.py","server/main/http.py")
|
||||
strr = {}
|
||||
httpserver = imp.load_source("server/main/httpserver.py","server/main/httpserver.py")
|
||||
try:
|
||||
data = httpserver.catHeaders("Cookie",Headers)
|
||||
data = httpserver.catCookie("Cluster_management_Jiang",Headers)
|
||||
print()
|
||||
user = ""
|
||||
tmp4 = session_.split('\n')
|
||||
for y in range(len(tmp4)):
|
||||
tmp5 = tmp4[y].split(',')
|
||||
if len(tmp5) >1:
|
||||
if data == tmp5[0]:
|
||||
user = tmp5[1]
|
||||
if RUL == "/favicon.ico":
|
||||
if post_data == b'':
|
||||
post = RUL_CS.split('&')
|
||||
else:
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
sh.file(new_client_socket,post,Versino,RUL_,user,Headers,info)
|
||||
def http_to_char(data):
|
||||
rul_ = data.split('%')
|
||||
for y in range(len(rul_)):
|
||||
if y == 0:
|
||||
data = rul_[y].encode("utf-8")
|
||||
elif y == (len(rul_)+1):
|
||||
y=y
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
httpserver.httppostfile(new_client_socket,"200","./web" + RUL,True,Headers,info)
|
||||
else:
|
||||
hex = rul_[y][:2]
|
||||
charb = bytes.fromhex(hex)
|
||||
data = data + charb
|
||||
if len(rul_[y]) > 2:
|
||||
data = data + rul_[y][2:].encode("utf-8")
|
||||
data = data.decode("utf-8")
|
||||
return data
|
||||
|
||||
def tcplink(sock, addr, info):
|
||||
try:
|
||||
new_client_socket = sock
|
||||
client_addr = addr
|
||||
global session_
|
||||
global a
|
||||
global run_
|
||||
global update
|
||||
|
||||
RUL = ''
|
||||
RUL_t = ''
|
||||
HTTPMethod = ''
|
||||
|
||||
user = "no_login"
|
||||
# 接收客户端发送过来的请求
|
||||
recv_tcp = new_client_socket.recv(8192)
|
||||
if recv_tcp:
|
||||
if recv_tcp == b'':
|
||||
#print(str(client_addr) + " ???")
|
||||
recv_tcp = new_client_socket.recv(8192)
|
||||
if recv_tcp == b'':
|
||||
#print(str(client_addr) + " ???")
|
||||
return
|
||||
else:
|
||||
return
|
||||
recv_data=""
|
||||
post_data=b''
|
||||
Headers = ''
|
||||
recv_data = recv_tcp.split(b'\r\n\r\n')
|
||||
haslen = len(recv_data[0]) + 4
|
||||
post_data = recv_tcp[haslen:]
|
||||
recv_data = recv_data[0].decode("utf-8")
|
||||
Headers = recv_data.split('\r\n')
|
||||
RUL = ''
|
||||
RUL_CS = ''
|
||||
RUL = Headers[0].split(' ')[1].split('?')[0].split('#')[0]
|
||||
RUL_CS = Headers[0].split(' ')
|
||||
RUL_CS = RUL_CS[1].split('?')
|
||||
if len(RUL_CS) == 1:
|
||||
RUL_CS = ''
|
||||
else:
|
||||
RUL_CS = http_to_char(RUL_CS[1])
|
||||
|
||||
for h in Headers:
|
||||
tmp2 = h.split(' ')
|
||||
if tmp2[0] == "Cookie:":
|
||||
for x in range(0,len(tmp2)):
|
||||
tmp3 = tmp2[x].split('=')
|
||||
if(tmp3[0] == "Cluster_management_Jiang"):
|
||||
tmp4 = session_.split('\n')
|
||||
for y in range(len(tmp4)):
|
||||
tmp5 = tmp4[y].split(',')
|
||||
tmp3t = tmp3[1].split(';')
|
||||
if tmp3t[0] == tmp5[0]:
|
||||
user = tmp5[1]
|
||||
'''if "login" == "login":
|
||||
if user == "no_login":
|
||||
RUL_t = RUL
|
||||
tmp6 = RUL_t.split('/')
|
||||
if tmp6[1] != "assets":
|
||||
if len(tmp6) == 2:
|
||||
RUL = '/login'
|
||||
else:
|
||||
RUL = '/login'
|
||||
if RUL_t == "/login/dev":
|
||||
RUL = RUL_t'''
|
||||
pr = (time.strftime("I %Y-%m-%d %H:%M:%S ", time.localtime()).encode("utf-8"))
|
||||
pr += ((str(client_addr) + ' ' + user + ' ' + Headers[0].split(' ')[1]).encode("utf-8"))
|
||||
print(pr.decode("utf-8"))
|
||||
logs = open(".logs/run.py/" + time.strftime("%Y-%m-%d.log", time.localtime()),"ab")
|
||||
logs.write(time.strftime("I %Y-%m-%d %H:%M:%S ", time.localtime()).encode("utf-8"))
|
||||
logs.write((str(client_addr) + ' ' + user + ' ' + Headers[0].split(' ')[1]).encode("utf-8"))
|
||||
logs.write(b'\r\n')
|
||||
logs.close()
|
||||
if info['debug']:
|
||||
httplink(new_client_socket,RUL,RUL_CS,post_data,user,Headers,info)
|
||||
else:
|
||||
t = threading.Thread(target=httplink, args=(new_client_socket,RUL,RUL_CS,post_data,user,Headers,info))
|
||||
t.start()
|
||||
except Exception as e:
|
||||
pr = (time.strftime("E %Y-%m-%d %H:%M:%S ", time.localtime()).encode("utf-8"))
|
||||
pr += ((traceback.format_exc()).encode("utf-8"))
|
||||
print(pr.decode("utf-8"))
|
||||
logs = open(".logs/run.py/" + time.strftime("%Y-%m-%d.log", time.localtime()),"ab")
|
||||
logs.write(time.strftime("E %Y-%m-%d %H:%M:%S ", time.localtime()).encode("utf-8"))
|
||||
logs.write((traceback.format_exc()).encode("utf-8"))
|
||||
logs.write(b'\r\n')
|
||||
logs.close()
|
||||
#e500(new_client_socket,Versino,user,Headers,traceback.format_exc())
|
||||
time.sleep(1)
|
||||
|
||||
def tcptossltx(sock,tcp_server_socket):
|
||||
rin = 1
|
||||
while rin == 1:
|
||||
try:
|
||||
recv_tcp = sock.recv(8192)
|
||||
if recv_tcp:
|
||||
tcp_server_socket.send(recv_tcp)
|
||||
else:
|
||||
rin = 0
|
||||
print("txend")
|
||||
tcp_server_socket.close()
|
||||
sock.close()
|
||||
|
||||
except Exception as e:
|
||||
rin = 0
|
||||
tcp_server_socket.close()
|
||||
sock.close()
|
||||
if len(e.args) > 1:
|
||||
if e.args[1] != "你的主机中的软件中止了一个已建立的连接。":
|
||||
print(e.args)
|
||||
else:
|
||||
print(e.args)
|
||||
def tcptosslrx(tcp_server_sockets,socks):
|
||||
rin = 1
|
||||
while rin == 1:
|
||||
try:
|
||||
recv_tcp = socks.recv(8192)
|
||||
if recv_tcp:
|
||||
tcp_server_sockets.send(recv_tcp)
|
||||
else:
|
||||
rin = 0
|
||||
print("rxend")
|
||||
socks.close()
|
||||
tcp_server_sockets.close()
|
||||
|
||||
except Exception as e:
|
||||
rin = 0
|
||||
socks.close()
|
||||
tcp_server_sockets.close()
|
||||
if len(e.args) > 1:
|
||||
if e.args[1] != "远程主机强迫关闭了一个现有的连接。":
|
||||
print(e.args)
|
||||
else:
|
||||
print(e.args)
|
||||
def tcptossllink(tcp_server_socket,ssl_port,recv_tcp):
|
||||
rin = 1
|
||||
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
|
||||
sock.connect(ssl_port)
|
||||
sock.send(recv_tcp)
|
||||
tx = threading.Thread(target=tcptossltx, args=(sock,tcp_server_socket))
|
||||
tx.start()
|
||||
rx = threading.Thread(target=tcptosslrx, args=(sock,tcp_server_socket))
|
||||
rx.start()
|
||||
if tx.is_alive():
|
||||
tx.join()
|
||||
if rx.is_alive():
|
||||
rx.join()
|
||||
|
||||
|
||||
def tcptossl(tcp_server_socket,ssl_port):
|
||||
while tcp_server_socket != '':
|
||||
try:
|
||||
sock, addr = tcp_server_socket.accept()
|
||||
sock.settimeout(60)
|
||||
recv_tcp = sock.recv(8192)
|
||||
if recv_tcp == b'':
|
||||
#print(str(client_addr) + " ???")
|
||||
recv_tcp = sock.recv(8192)
|
||||
if recv_tcp == b'':
|
||||
#print(str(client_addr) + " ???")
|
||||
sock.close()
|
||||
if recv_tcp != b'':
|
||||
if recv_tcp[:3] == b'GET':
|
||||
res = b''
|
||||
recv_tcp_buff = recv_tcp.split(b'\r\n')
|
||||
host = recv_tcp.split(b'Host: ')[1].split(b'\r\n')[0]
|
||||
res = res + ('HTTP/1.1 307 Temporary Redirect\r\n'.encode("utf-8"))
|
||||
res = res + ('Location: https://'.encode("utf-8"))
|
||||
res = res + (host)
|
||||
res = res + (recv_tcp_buff[0].split(b' ')[1])
|
||||
res = res + ('\r\n'.encode("utf-8"))
|
||||
res = res + (("Server: JCM/" + Versino + "\r\n").encode("utf-8"))
|
||||
res = res + ("Connection: close\r\n".encode("utf-8"))
|
||||
res = res + ("Content-Length: 0\r\n".encode("utf-8"))
|
||||
res = res + ('\r\n\r\n\r\n'.encode("utf-8"))
|
||||
|
||||
sock.send(res)
|
||||
#sock.close()
|
||||
#print()
|
||||
recv_tcp = sock.recv(8192)
|
||||
if recv_tcp == b'':
|
||||
#print(str(client_addr) + " ???")
|
||||
recv_tcp = sock.recv(8192)
|
||||
if recv_tcp == b'':
|
||||
#print(str(client_addr) + " ???")
|
||||
sock.close()
|
||||
if user == "":
|
||||
ma = "200"
|
||||
if RUL == "/login":
|
||||
if Headers[0][:4] == "POST":
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
name = ""
|
||||
password = ""
|
||||
checkbox = ""
|
||||
for p in post:
|
||||
pp = p.split("=")
|
||||
if pp[0] == "name":
|
||||
name = pp[1]
|
||||
if pp[0] == "password":
|
||||
password = pp[1]
|
||||
if pp[0] == "checkbox":
|
||||
checkbox = pp[1]
|
||||
tools = imp.load_source("Tools/Tools.py","Tools/Tools.py")
|
||||
tools = tools.ifuser(name,password)
|
||||
res = ""
|
||||
if tools == "yes":
|
||||
cok = ''
|
||||
for x in range(32):
|
||||
cok = cok + random.choice("0123456789qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLLZXCVBNM")
|
||||
fs_rr = session_
|
||||
fs_session = fs_rr.split('\n')
|
||||
for fs_ in fs_session:
|
||||
if fs_ == "sessinon":
|
||||
session_ = (fs_)
|
||||
session_ = session_ + ("\n")
|
||||
else:
|
||||
if fs_ == "":
|
||||
fs_ = fs_
|
||||
else:
|
||||
session_ = session_ + fs_ + ("\n")
|
||||
fs__ = fs_.split(',')
|
||||
import datetime
|
||||
cookie_date = (datetime.datetime.now()+datetime.timedelta(days=1)).strftime("%a, %d %b %Y %H:%M:%S GMT")
|
||||
#time.strftime("%a, %d %b %Y %H:%M:%S GMT", time.localtime(time.strptime("1","%d")))
|
||||
|
||||
session_ = session_ + cok + "," + name + "," + cookie_date + "\n"
|
||||
if checkbox == "true":
|
||||
fs_user = open(".config/sessino","r")#sessino
|
||||
fs_r = fs_user.read()
|
||||
fs_rr = fs_r#.decode("utf-8")
|
||||
fs_session = fs_rr.split('\n')
|
||||
fs_user.close()
|
||||
user_write = ''
|
||||
for fs_ in fs_session:
|
||||
if fs_ == "sessinon":
|
||||
fs_ = fs_
|
||||
else:
|
||||
if fs_ == "":
|
||||
fs_ = fs_
|
||||
else:
|
||||
fs__ = fs_.split(",")
|
||||
res = res + "set-Cookie: Cluster_management_Jiang=" + cok + "; SameSite=Lax; Expires=" + cookie_date
|
||||
fs_user = open(".config/sessino","a")
|
||||
fs_user.write(cok + "," + name + "," + cookie_date + "\n")
|
||||
fs_user.close()
|
||||
else:
|
||||
res = res + "set-Cookie: Cluster_management_Jiang=" + cok + "; SameSite=Lax;"# Expires=" + cookie_date + "\r\n"
|
||||
res = "application/json\r\n" + res
|
||||
httpserver.httppostchar(new_client_socket,"200",b"{\"data\":\"login\"}",res,Headers,info)
|
||||
else:
|
||||
print("6")
|
||||
res = "application/json" + res
|
||||
httpserver.httppostchar(new_client_socket,"200","{\"data\":\"用户名或密码错误\"}".encode("utf-8"),res,Headers,info)
|
||||
|
||||
if RUL[:len("/assets")] != "/assets":
|
||||
RUL = "/login.html"
|
||||
ma = "401"
|
||||
RUL = "./web/" + info["theme"] + RUL
|
||||
httpserver.httppostfile(new_client_socket,ma,RUL,True,Headers,info)
|
||||
else:
|
||||
my_file = "./web/" + info["theme"] + RUL
|
||||
link = ''
|
||||
for i in RUL_CS.split('&'):
|
||||
tmp = i.split('=')
|
||||
if tmp[0] == 'link':
|
||||
link = tmp[1]
|
||||
if os.path.isdir(my_file):
|
||||
if os.path.isfile("./web/" + info["theme"] + RUL + "/index.php"):
|
||||
RUL = RUL + "/index.php"
|
||||
else:
|
||||
print("9")
|
||||
my_file = "./web/" + info["theme"] + RUL + "/index.html"
|
||||
if os.path.isfile(my_file):
|
||||
RUL = RUL + "/index.html"
|
||||
if os.path.isfile("./web/" + info["theme"] + RUL):
|
||||
tmp2 = RUL.split('.')
|
||||
if tmp2[-1] == 'php':
|
||||
php = imp.load_source("server/main/php.py","server/main/php.py")
|
||||
if post_data == b'':
|
||||
post = RUL_CS.split('&')
|
||||
else:
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
data = php.php(new_client_socket,post,RUL,user,Headers,info,strr)
|
||||
httpserver.httppostchar(new_client_socket,"200",data.encode("utf-8"),"text/html;charset=UTF-8",Headers,info)
|
||||
else:
|
||||
RUL = "./web/" + info["theme"] + RUL
|
||||
httpserver.httppostfile(new_client_socket,"200",RUL,True,Headers,info)
|
||||
else:
|
||||
t = threading.Thread(target=tcptossllink, args=(sock,ssl_port,recv_tcp))
|
||||
t.start()
|
||||
except Exception as e:
|
||||
if e.args[0] != "timed out":
|
||||
print(e.args)
|
||||
if RUL == "/login":
|
||||
httpserver.httppostchar(new_client_socket,"200",b"{\"data\":\"login\"}","application/json",Headers,info)
|
||||
elif RUL == "/token":
|
||||
httpserver.httppostchar(new_client_socket,"200",b"{\"token\":\"\"}","application/json",Headers,info)
|
||||
elif RUL == "/main/info":
|
||||
res = ''
|
||||
if os.path.isfile(".config/main/lits.json"):
|
||||
fs = open(".config/main/lits.json", "rb")
|
||||
hosts = fs.read().decode("utf-8").split('\n')
|
||||
res += '{"for": "'+str(len(hosts)-1)+'","server": ['
|
||||
for i in range(len(hosts)-1):
|
||||
ii = hosts[i].split('"')
|
||||
if i == 0 :
|
||||
res += '{"name": "'+ ii[3] +'",'
|
||||
else:
|
||||
res += ',{"name": "'+ ii[3] +'",'
|
||||
if ii[7] == "127.0.0.1":
|
||||
sent_now = psutil.net_io_counters().bytes_sent
|
||||
recv_now = psutil.net_io_counters().bytes_recv
|
||||
sent = (sent_now - sent_before)/1024/(time.time()-ttime) # 算出1秒后的差值
|
||||
recv = (recv_now - recv_before)/1024/(time.time()-ttime)
|
||||
ttime=time.time()
|
||||
sent_before=sent_now
|
||||
recv_before=recv_now
|
||||
res += '"api": "1",'
|
||||
if info['OS'] == "Linux":
|
||||
res += '"safe": "--",'
|
||||
else:
|
||||
res += '"safe": "--",'
|
||||
res += '"cpu": "'+str(psutil.cpu_percent(None))+'",'
|
||||
res += '"ram": "'+str(psutil.virtual_memory().percent)+'",'
|
||||
res += '"rom": "'+rom(info)+'",'
|
||||
tx = ""
|
||||
rx = ""
|
||||
if sent < 1000:
|
||||
tx = '{0}KB/s'.format("%.2f"%sent)
|
||||
else:
|
||||
sent = sent / 1024
|
||||
tx = '{0}MB/s'.format("%.2f"%sent)
|
||||
if recv < 1000:
|
||||
rx = '{0}KB/s'.format("%.2f"%recv)
|
||||
else:
|
||||
recv = recv / 1024
|
||||
rx = '{0}MB/s'.format("%.2f"%recv)
|
||||
res += '"tx": "'+tx+'",'
|
||||
res += '"rx": "'+rx+'"'
|
||||
res += '}'
|
||||
else:
|
||||
url = "http://" + ii[7] + ":8889/assets/info"
|
||||
sh = imp.load_source("server/main/httpclient","server/main/httpclient.py")
|
||||
#cat,cdata = sh.Client(ii[7],int(ii[19]),"/assets/info")
|
||||
cat,cdata = sh.Client(ii[7],int(ii[19]),'/login/dev','')
|
||||
if cat == "200":
|
||||
try:
|
||||
#response = urllib.request.urlopen(url, timeout=1)
|
||||
#html = response.read().decode('utf-8') # 获取到页面的源代码
|
||||
#html = sh.Client("pi.lan",8889,"/assets/info")
|
||||
res += '"api": "1",'
|
||||
data = cdata.decode("utf-8").split('"')
|
||||
res += '"safe": "'+data[3]+'",'
|
||||
res += '"cpu": "'+data[7]+'",'
|
||||
res += '"ram": "'+data[11]+'",'
|
||||
res += '"rom": "'+data[15]+'",'
|
||||
res += '"tx": "'+data[19]+'",'
|
||||
res += '"rx": "'+data[23]+'"'
|
||||
res += '}'
|
||||
except:
|
||||
res += '"api": "0",'
|
||||
res += '"safe": "--",'
|
||||
res += '"cpu": "--",'
|
||||
res += '"ram": "--",'
|
||||
res += '"rom": "--",'
|
||||
res += '"tx": "--KB/s",'
|
||||
res += '"rx": "--KB/s"'
|
||||
res += '}'
|
||||
else:
|
||||
data = os.popen('ping ' + ii[7] + ' -c 1 | grep icmp_seq').read()
|
||||
if len(data.split('icmp_seq=1 ttl=64')) == 2:
|
||||
res += '"api": "2",'
|
||||
res += '"safe": "--",'
|
||||
res += '"cpu": "--",'
|
||||
res += '"ram": "--",'
|
||||
res += '"rom": "--",'
|
||||
res += '"tx": "--KB/s",'
|
||||
res += '"rx": "--KB/s"'
|
||||
res += '}'
|
||||
else:
|
||||
res += '"api": "0",'
|
||||
res += '"safe": "--",'
|
||||
res += '"cpu": "--",'
|
||||
res += '"ram": "--",'
|
||||
res += '"rom": "--",'
|
||||
res += '"tx": "--KB/s",'
|
||||
res += '"rx": "--KB/s"'
|
||||
res += '}'
|
||||
res += ']'
|
||||
res += '}'
|
||||
httpserver.httppostchar(new_client_socket,"200",res.encode("utf-8"),"application/json",Headers,info)
|
||||
else:
|
||||
if os.path.isdir('.config') == False:
|
||||
os.mkdir('.config')
|
||||
if os.path.isdir('.config/main') == False:
|
||||
os.mkdir('.config/main')
|
||||
fs = open(".config/main/lits.json", "a")
|
||||
data = '{"name":"'+"127.0.0.1"+'","host":"'+"127.0.0.1"+'"}' + '\n'
|
||||
fs.write(data)
|
||||
fs.close()
|
||||
else:
|
||||
my_file = "./server" + RUL + "/api.py"
|
||||
if os.path.isfile(my_file):
|
||||
if post_data == b'':
|
||||
post = RUL_CS.split('&')
|
||||
else:
|
||||
rul_ = post_data.decode("utf-8").split('%')
|
||||
post_data = b''
|
||||
for y in range(len(rul_)):
|
||||
if y == 0:
|
||||
post_data = rul_[y].encode("utf-8")
|
||||
elif y == (len(rul_)+1):
|
||||
y=y
|
||||
else:
|
||||
hex = rul_[y][:2]
|
||||
charb = bytes.fromhex(hex)
|
||||
post_data = post_data + charb
|
||||
if len(rul_[y]) > 2:
|
||||
post_data = post_data + rul_[y][2:].encode("utf-8")
|
||||
#RUL_CS = RUL_CS.decode("utf-8")
|
||||
post = post_data.decode("utf-8").split('&')
|
||||
|
||||
sh = imp.load_source(RUL + "/api.py",my_file)
|
||||
sh.main(new_client_socket,post,Headers,info,user)
|
||||
else:
|
||||
strr = {}
|
||||
strr["err"] = '404'
|
||||
sh = imp.load_source("server/main/php.py","server/main/php.py")
|
||||
data = sh.php(new_client_socket,"post","/404.php",user,Headers,info,strr)
|
||||
httpserver.httppostchar(new_client_socket,"404",data.encode("utf-8"),"text/html;charset=UTF-8",Headers,info)
|
||||
#res = "HTTP/1.1 404 OK \r\n"
|
||||
except Exception as e:
|
||||
strr = {}
|
||||
strr["err"] = traceback.format_exc()
|
||||
logsprnt("ERROR",info,traceback.format_exc())
|
||||
sh = imp.load_source("server/main/php.py","server/main/php.py")
|
||||
data = sh.php(new_client_socket,"post","/500.php",user,Headers,info,strr)
|
||||
httpserver.httppostchar(new_client_socket,"500",data.encode("utf-8"),"text/html;charset=UTF-8",Headers,info)
|
||||
|
||||
if exre == 'reset':
|
||||
return -9
|
||||
if exre == 'exit':
|
||||
return -2
|
||||
return 0
|
||||
|
||||
def shutdown(data):
|
||||
global exre
|
||||
exre = data
|
||||
|
||||
def logsprnt(live,info,data):
|
||||
print(live,end=' ')
|
||||
print(data,end='\r')
|
||||
|
||||
def main(info):
|
||||
global session_
|
||||
global a
|
||||
global run_
|
||||
global update
|
||||
global OS
|
||||
global ttime
|
||||
global sent_before
|
||||
global recv_before
|
||||
global Versino
|
||||
global exit
|
||||
global ttime
|
||||
global session_
|
||||
global exre
|
||||
|
||||
exre = ''
|
||||
|
||||
print("boot")
|
||||
fs = open("./server/server.ini", "rb")
|
||||
@@ -406,7 +403,6 @@ def main(info):
|
||||
print(e.args)
|
||||
time.sleep(1)
|
||||
tcp_server_socket.listen(100)
|
||||
|
||||
tcp_server_socket_run = tcp_server_socket
|
||||
if os.path.exists(".config/ssl/site.key"):
|
||||
try:
|
||||
@@ -424,36 +420,7 @@ def main(info):
|
||||
print(e.args)
|
||||
time.sleep(1)
|
||||
tcp_server_socket_run = tcp_server_socket
|
||||
a = 1
|
||||
while a < 10:
|
||||
try:
|
||||
print("start")
|
||||
while run_ < 10:
|
||||
try:
|
||||
sock, addr = tcp_server_socket_run.accept()
|
||||
sock.settimeout(60)
|
||||
tcplink(sock, addr , info)
|
||||
except Exception as e:
|
||||
if run_ == 9:
|
||||
run_ = 16
|
||||
if e.args[0] != "timed out":
|
||||
print(e.args)
|
||||
except Exception as e:
|
||||
print(e.args)
|
||||
sock.close()
|
||||
tcp_server_socket.close()
|
||||
if exit == "reboot":
|
||||
imp.load_source("server/init.py","server/init.py")
|
||||
#os.system("\"" + info["python"] + '\" server/init.py')
|
||||
sys.exit()
|
||||
|
||||
if __name__ == "__main__":
|
||||
info = {}
|
||||
info["Versino"] = 'V0.0'
|
||||
info["python"] = sys.executable
|
||||
info["dir"] = os.getcwd()
|
||||
info["OS"] = OS_
|
||||
info["OS_name"] = OS
|
||||
info["port"] = 8888
|
||||
info['debug'] = False
|
||||
main(info)
|
||||
httpserver = imp.load_source("server/main/httpserver.py","server/main/httpserver.py")
|
||||
res = httpserver.server(tcp_server_socket_run,info,logsprnt,httpserver_void)
|
||||
if res == -9:
|
||||
main(info)
|
||||
|
||||
Reference in New Issue
Block a user