585 lines
26 KiB
Python
585 lines
26 KiB
Python
from django.shortcuts import render
|
||
from django.http import HttpResponse
|
||
import subprocess
|
||
import shlex
|
||
import json
|
||
import configparser
|
||
import re
|
||
import redis
|
||
# from pandas import DataFrame
|
||
import sys
|
||
import getopt
|
||
import os
|
||
|
||
command_dic={'vpncmd':'vpncmd','server':'/SERVER','password':'/PASSWORD:','cmd':'/CMD','hub':'/HUB:',
|
||
'secret':'/SECRET:','retry_interval':'/RETRY_INTERVAL:','group':'/GROUP:','realname':'/REALNAME:','note':'/NOTE:',
|
||
'alias':'/ALIAS:','name':'/NAME:','value':'/VALUE:','client':'/CLIENT','username':'/USERNAME:','nicname':'/NICNAME:',
|
||
'type':'/TYPE:','start':'/START:','expire':'/EXPIRE:','gw':'/GW:','dns':'/DNS:','dns2':'/DNS2:','domain':'/DOMAIN:',
|
||
'log':'/LOG:','mac':'/MAC:','ip':'/IP：','mtu':'/MTU:','tcptimeout':'/TCPTIMEOUT:','udptimeout':'/UDPTIMEOUT:','device':'/DEVICE:',
|
||
'l2tp':'/L2TP:','l2tpraw':'/L2TPRAW:','etherip':'/ETHERIP:','psk':'/PSK:','defaulthub':'/DEFAULTHUB:','adminhub':'/ADMINHUB:',
|
||
'csv':'/CSV'}
|
||
response_dic={'miss':'miss parameters.',
|
||
'exist':'The user with the specified name already exists on the Virtual Hub.',
|
||
'success':'The command completed successfully.',
|
||
'not_found':'Object not found.',
|
||
'error':'The command execute failed.'
|
||
}
|
||
# col_DF=["config_id","addr_pool_id","addr_type","ip_addr","location","mrl_ip",\
|
||
# "link_id","encap_type","direction","outer_sport","outer_dport","outer_sip",\
|
||
# "outer_dip","outer_smac","outer_dmac","inner_smac","inner_dmac",\
|
||
# "is_valid","op_time"]
|
||
class Redis:
|
||
def __init__(self,host,port,index):
|
||
self.host=host
|
||
self.port=port
|
||
self.index=index
|
||
def connect(self):
|
||
try:
|
||
pool = redis.ConnectionPool(host=self.host, port=self.port, db=self.index,decode_responses=True)
|
||
r = redis.StrictRedis(connection_pool=pool)
|
||
except redis.RedisError as e:# Exception,e:print(str(e))
|
||
print("Error:"+str(e))
|
||
return -1,"Error:"+str(e)
|
||
# sys.exit(2)
|
||
try:
|
||
connect_result=r.ping()
|
||
except redis.ConnectionError:
|
||
print("Error:can not connect to redis server with host:"+self.host+" and port:"+self.port)
|
||
return -1,"Error:can not connect to redis server with host:"+self.host+" and port:"+self.port
|
||
# sys.exit(2)
|
||
else:
|
||
if connect_result==True:
|
||
self.r=r
|
||
return 0,"success"
|
||
else:
|
||
print("Error:Ping the Redis server returns not True, check again.")
|
||
return -1,"Error:Ping the Redis server returns not True, check again."
|
||
# sys.exit(2)
|
||
# http:\\localhost:8090\command?cmd_obj=server&cmd=UserCreate&server_pwd=111111&hub_name=NewHub0&hub_pwd=111111&user_name=*&group=none&realname=none¬e=none
|
||
# Create your views here.
|
||
def command(request):
|
||
# if username == "" and password = "" :
|
||
server_pwd,host,port,index=readconfig()
|
||
if request.method=='GET':
|
||
cmd_obj=request.GET.get('cmd_obj',default='server')
|
||
if cmd_obj=='server':
|
||
command=request.GET.get('cmd',default=None)
|
||
server_ip=request.GET.get('server_ip',default=None)
|
||
if(command==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
elif(command=='IpExist'):
|
||
candidate_ip=request.GET.get('candidate_ip',default=None)
|
||
print(candidate_ip)
|
||
if(candidate_ip==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
else:
|
||
rtn_code,outs=IpExist(host,port,candidate_ip,index)
|
||
my_dict=dict()
|
||
if(rtn_code==0):
|
||
my_dict['response']=outs
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
my_dict['error']=outs
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
elif(command=='IpNumGet'):
|
||
addr_pool_id=request.GET.get('addr_pool_id',default=None)
|
||
if(addr_pool_id==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
else:
|
||
rtn_code,outs=IpNumGet(host,port,addr_pool_id,index)
|
||
my_dict=dict()
|
||
if(rtn_code!=-1):
|
||
my_dict['response']=response_dic['success']
|
||
my_dict['num']=rtn_code
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
my_dict['error']=outs
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
elif(command=='AllIpGet'):
|
||
addr_pool_id=request.GET.get('addr_pool_id',default=None)
|
||
if(addr_pool_id==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
else:
|
||
rtn_code,outs=AllIpGet(host,port,addr_pool_id,index)
|
||
my_dict=dict()
|
||
if(rtn_code!=-1):
|
||
my_dict['response']=response_dic['success']
|
||
my_dict['candidate_ip']=outs
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
my_dict['error']=outs
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
elif(server_ip==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
else:
|
||
server_cmd=command_dic['vpncmd']+' '+server_ip+' '+command_dic['server']
|
||
# if(command=='ServerPasswordSet'):
|
||
# server_pwd=request.GET.get('server_pwd',default='111111')
|
||
# old_server_pwd=request.GET.get('old_server_pwd',default=None)
|
||
# if(old_server_pwd==None):
|
||
# command=server_cmd+command+' '+server_pwd
|
||
# else:
|
||
# command=server_cmd+command+' '+command_dic['password']+old_server_pwd+' '+command_dic['cmd']+' '+command+' '+server_pwd
|
||
# elif(command='BridgeCreate'):
|
||
# server_pwd=request.GET.get('server_pwd',default='111111')
|
||
# hub_name=request.GET.get('hub_name',default='NewHub0')
|
||
# device=request.GET.get('device',default=None)
|
||
# tap=request.GET.get('tap',default=None)
|
||
# command=server_cmd+' '+command_dic['password']+server_pwd+' '+command_dic['cmd']+' '+command+' '+hub_name+' '+command_dic['device']+device
|
||
# +' '+command_dic['tap']+tap
|
||
# elif(command=='AddIpTap'):
|
||
# ip=request.GET.get('ip',default=None)
|
||
# dev=request.GET.get('dev',default=None)
|
||
# command='ip addr add'+' '+ip+' '+'dev'+' '+'tap_'+dev
|
||
# elif(command=='IPsecEnable'):
|
||
# l2tp=request.GET.get('l2tp',default=None)
|
||
# l2tpraw=request.GET.get('l2tpraw',default=None)
|
||
# etherip=request.GET.get('etherip',default=None)
|
||
# psk=request.GET.get('psk',default=None)
|
||
# defaulthub=request.GET.get('defaulthub',defaul=None)
|
||
# command=server_cmd+' '+command_dic['password']+password+' '+command_dic['cmd']+' '+command+' '+command_dic['l2tp']+l2tp+\
|
||
# ' '+command_dic['l2tpraw']+l2tpraw+' '+command_dic['etherip']+etherip+' '+command_dic['psk']+psk+' '+command_dic['defaulthub']+\
|
||
# +defaulthub
|
||
# elif(command=='SessionList'):
|
||
# adminhub=request.GET.get('adminhub',default=None)
|
||
# command=server_cmd+' '+command_dic['password']+password+' '+command_dic['adminhub']+' '+command_dic['password']+password+' '+\
|
||
# command_dic['csv']+' '+command_dic['cmd']+' '+command
|
||
server_pwd=request.GET.get('server_pwd',default=server_pwd)
|
||
hub_name=request.GET.get('hub_name',default='NewHub0')
|
||
hub_pwd=request.GET.get('hub_pwd',default='111111')
|
||
hub_cmd=server_cmd+' '+command_dic['password']+server_pwd+' '+command_dic['hub']+hub_name+' '+command_dic['password']+hub_pwd+' '\
|
||
+command_dic['cmd']
|
||
hub_csv_cmd=server_cmd+' '+command_dic['password']+server_pwd+' '+command_dic['hub']+hub_name+' '+command_dic['password']+hub_pwd+' '\
|
||
+command_dic['csv']+' '+command_dic['cmd']
|
||
# if(command=='HubCreate'):
|
||
# command=command_dic['vpncmd']+' '+command_dic['server_ip']+' '+command_dic['server']+' '\
|
||
# +command_dic['password']+command_dic['server_pwd']+' '+command['cmd']+' '+cmd+' '+hub_name+' '+password+hub_pwd
|
||
# elif(command=='SecureNatEnable'):
|
||
# command=hub_cmd+command
|
||
# elif(command=='RadiusServerSet'):
|
||
# radius_ip=request.GET.get('radius_ip',default='192.168.11.137:1812')
|
||
# secret=request.GET.get('secret',default='111111')
|
||
# retry_interval=request.GET.get('retry_interval',default='500')
|
||
# command=hub_cmd+' '+command+' '+radius_ip+' '+command_dic['secret']+secret+command_dic['retry_interval']+retry_interval
|
||
if(command=='UserCreate'):
|
||
user_name=request.GET.get('user_name',default=None)
|
||
user_pwd=request.GET.get('user_pwd',default=None)
|
||
group=request.GET.get('group',default='none')
|
||
realname=request.GET.get('realname',default='none')
|
||
note=request.GET.get('note',default='none')
|
||
if(user_name==None or user_pwd==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
else:
|
||
command=hub_cmd+' '+command+' '+user_name+' '+command_dic['group']+group+' '+command_dic['realname']+realname+' '+command_dic['note']+note
|
||
outs,rtn_code=mysubprocess(command)
|
||
if(rtn_code==0):
|
||
command=hub_cmd+' '+'UserPasswordSet'+' '+user_name+' '+command_dic['password']+user_pwd
|
||
outs,rtn_code=mysubprocess(command)
|
||
if(rtn_code==0):
|
||
my_dict=dict()
|
||
my_dict['response']=response_dic['success']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
command=command=hub_cmd+' '+'UserDelete'+' '+user_name
|
||
mysubprocess(command)
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['error']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
else:
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['exist']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
# elif(command=='UserRadiusSet'):
|
||
# user_name=request.GET.get('user_name',default='\'*\'')
|
||
# alias=request.GET.get('alias',default='none')
|
||
# command=hub_cmd+' '+command+' '+user_name+' '+user_name+' '+command_dic['alias']+alias
|
||
elif(command=='UserPasswordSet'):
|
||
user_name=request.GET.get('user_name',default=None)
|
||
user_pwd=request.GET.get('user_pwd',default=None)
|
||
if(user_name==None or user_pwd==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
else:
|
||
command=hub_cmd+' '+command+' '+user_name+' '+command_dic['password']+user_pwd
|
||
outs,rtn_code=mysubprocess(command)
|
||
if(rtn_code==0):
|
||
my_dict=dict()
|
||
my_dict['response']=response_dic['success']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['error']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
elif(command=='UserList'):
|
||
command=hub_csv_cmd+' '+command
|
||
outs,rtn_code=mysubprocess(command)
|
||
if(rtn_code==0):
|
||
my_dict=dict()
|
||
my_dict['response']=response_dic['success']
|
||
my_list=outs.split('\n')
|
||
user_dict=dict()
|
||
user_list=list()
|
||
for x in range(1,len(my_list)):
|
||
user_info=my_list[x].split(',')
|
||
if(len(user_info)<10):
|
||
continue
|
||
transfer_info=my_list[x].split('\"')
|
||
user_dict['User_Name']=user_info[0]
|
||
user_dict['Num_Logins']=user_info[5]
|
||
if(user_info[6].find('None')==-1):
|
||
print(user_info[6])
|
||
temp_str=user_info[6].split(' ')
|
||
temp_str=temp_str[0]+' '+temp_str[2]
|
||
user_dict['Last_Login']=temp_str
|
||
else:
|
||
user_dict['Last_Login']='None'
|
||
if(len(user_info)>10):
|
||
user_dict['Transfer_Bytes']=transfer_info[1]
|
||
user_dict['Transfer_Packets']=transfer_info[3]
|
||
else:
|
||
user_dict['Transfer_Bytes']=user_info[8]
|
||
user_dict['Transfer_Packets']=user_info[9]
|
||
user_list.append(user_dict)
|
||
user_dict=dict()
|
||
my_dict['userlist']=user_list
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['error']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
elif(command=='UserDelete'):
|
||
user_name=request.GET.get('user_name',default=None)
|
||
if(user_name==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
else:
|
||
command=hub_cmd+' '+command+' '+user_name
|
||
outs,rtn_code=mysubprocess(command)
|
||
if(rtn_code==0):
|
||
my_dict=dict()
|
||
my_dict['response']=response_dic['success']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['error']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
# elif(command=='IPTable'):
|
||
# user_name=request.GET.get('user_name',default=None)
|
||
# if(user_name==None):
|
||
# myresponse=HttpResponse(json.dumps(response_dic['miss']),content_type='application/json',status=400)
|
||
# return myresponse
|
||
# else:
|
||
# command=hub_cmd+' '+command+' '+user_name
|
||
# if(hub_name==None):
|
||
# command=server_cmd+' '+command_dic['password']+password+' '+command_dic['adminhub']+' '+command_dic['password']+password+' '+\
|
||
# command_dic['csv']+' '+command_dic['cmd']+' '+command
|
||
elif(command=='UserGet'):
|
||
user_name=request.GET.get('user_name',default=None)
|
||
if(user_name==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
command=hub_csv_cmd+' '+command+' '+user_name
|
||
outs,rtn_code=mysubprocess(command)
|
||
if(rtn_code==0):
|
||
my_dict=dict()
|
||
my_dict['response']=response_dic['success']
|
||
my_list=outs.split('\n')
|
||
for x in range(1,len(my_list)):
|
||
user_info=my_list[x].split(',')
|
||
transfer_info=re.split(r'(\"| )',my_list[x])
|
||
transfer_info_short=re.split(r'(,| )',my_list[x])
|
||
if(user_info[0]=='User Name'):
|
||
my_dict['User_Name']=user_info[1]
|
||
elif(user_info[0].find('Created on')!=-1):
|
||
if(user_info[1].find('None')==-1):
|
||
temp_str=user_info[1].split(' ')
|
||
temp_str=temp_str[0]+' '+temp_str[2]
|
||
my_dict['Create_on']=temp_str
|
||
else:
|
||
my_dict['Create_on']='None'
|
||
elif(user_info[0].find('Update on')!=-1):
|
||
my_dict['Update_on']=user_info[1]
|
||
elif(user_info[0].find('Outgoing Unicast Packets')!=-1):
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Outgoing_Unicast_Packets']=transfer_info_short[6].replace(',','')
|
||
else:
|
||
my_dict['Outgoing_Unicast_Packets']=transfer_info[6].replace(',','')
|
||
elif(user_info[0].find('Outgoing Unicast Total Size')!=-1):
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Outgoing_Unicast_Total_Size']=transfer_info_short[8].replace(',','')
|
||
else:
|
||
my_dict['Outgoing_Unicast_Total_Size']=transfer_info[8].replace(',','')
|
||
elif(user_info[0].find('Outgoing Broadcast Packets')!=-1):
|
||
print(transfer_info,transfer_info_short)
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Outgoing_Broadcast_Packets']=transfer_info_short[6].replace(',','')
|
||
else:
|
||
my_dict['Outgoing_Broadcast_Packets']=transfer_info[6].replace(',','')
|
||
elif(user_info[0].find('Outgoing Broadcast Total Size')!=-1):
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Outgoing_Broadcast_Total_Size']=transfer_info_short[8].replace(',','')
|
||
else:
|
||
my_dict['Outgoing_Broadcast_Total_Size']=transfer_info[8].replace(',','')
|
||
elif(user_info[0].find('Incoming Unicast Packets')!=-1):
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Incoming_Unicast_Packets']=transfer_info_short[6].replace(',','')
|
||
else:
|
||
my_dict['Incoming_Unicast_Packets']=transfer_info[6].replace(',','')
|
||
elif(user_info[0].find('Incoming Unicast Total Size')!=-1):
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Incoming_Unicast_Total_Size']=transfer_info_short[8].replace(',','')
|
||
else:
|
||
my_dict['Incoming_Unicast_Total_Size']=transfer_info[8].replace(',','')
|
||
elif(user_info[0].find('Incoming Broadcast Packets')!=-1):
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Incoming_Broadcast_Packets']=transfer_info_short[6].replace(',','')
|
||
else:
|
||
my_dict['Incoming_Broadcast_Packets']=transfer_info[6].replace(',','')
|
||
elif(user_info[0].find('Incoming Broadcast Total Size')!=-1):
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Incoming_Broadcast_Total_Size']=transfer_info_short[8].replace(',','')
|
||
else:
|
||
my_dict['Incoming_Broadcast_Total_Size']=transfer_info[8].replace(',','')
|
||
elif(user_info[0].find('Number of Logins')!=-1):
|
||
if(my_list[x].find('\"')==-1):
|
||
my_dict['Number_of_Logins']=transfer_info_short[6].replace(',','')
|
||
else:
|
||
my_dict['Number_of_Logins']=transfer_info[6].replace(',','')
|
||
if(my_dict.get('Create_on')==None):
|
||
my_dict['Create_on']=''
|
||
elif(my_dict.get('Update on')==None):
|
||
my_dict['Update_on']=''
|
||
elif(my_dict.get('Outgoing_Unicast_Packets')==None):
|
||
my_dict['Outgoing_Unicast_Packets']=''
|
||
elif(my_dict.get('Outgoing_Unicast_Total_Size')==None):
|
||
my_dict['Outgoing_Unicast_Total_Size']=''
|
||
elif(my_dict.get('Outgoing_Broadcast_Packets')==None):
|
||
my_dict['Outgoing_Broadcast_Packets']=''
|
||
elif(my_dict.get('Outgoing_Broadcast_Total_Size')==None):
|
||
my_dict['Outgoing_Broadcast_Total_Size']=''
|
||
elif(my_dict.get('Incoming_Unicast_Packets')==None):
|
||
my_dict['Incoming_Unicast_Packets']=''
|
||
elif(my_dict.get('Incoming_Unicast_Total_Size')==None):
|
||
my_dict['Incoming_Unicast_Total_Size']=''
|
||
elif(my_dict.get('Incoming_Broadcast_Packets')==None):
|
||
my_dict['Incoming_Broadcast_Packets']=''
|
||
elif(my_dict.get('Incoming_Broadcast_Total_Size')==None):
|
||
my_dict['Incoming_Broadcast_Total_Size']=''
|
||
elif(my_dict.get('Number_of_Logins')==None):
|
||
my_dict['Number_of_Logins']=''
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['error']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
# elif(command=='LogFileList'):
|
||
# command=hub_cmd+' '+command
|
||
# elif(command=='DownloadLogFile'):
|
||
# file_addr=GET.get('user_name',default='./security_log/NewHub0/sec_20181031.log')
|
||
# command=hub_cmd+' '+command+' '+file_addr
|
||
elif(command=='UserPolicySet'):
|
||
user_name=request.GET.get('user_name',default=None)
|
||
policy_name=request.GET.get('name',default=None)
|
||
value=request.GET.get('value',default=None)
|
||
if(user_name==None or policy_name==None or value==None):
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['miss']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
command=hub_cmd+' '+command+' '+user_name+' '+command_dic['name']+policy_name+' '+command_dic['value']+value
|
||
outs,rtn_code=mysubprocess(command)
|
||
if(rtn_code==0):
|
||
my_dict=dict()
|
||
my_dict['response']=response_dic['success']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json')
|
||
return myresponse
|
||
else:
|
||
my_dict=dict()
|
||
my_dict['error']=response_dic['error']
|
||
myresponse=HttpResponse(json.dumps(my_dict),content_type='application/json',status=400)
|
||
return myresponse
|
||
# elif(command=='AdminOptionSet'):
|
||
# opt_set=request.GET.get('name',default='max_bitrates_download')
|
||
# value=request.GET.get('value',default='1000000')
|
||
# command=hub_cmd+' '+command+' '+opt_set+command_dict['value']+value
|
||
# elif(command=='DhcpSet'):
|
||
# start_ip=request.GET.get('start_ip',default=None)
|
||
# end=request.GET.get('end',default=None)
|
||
# mask=request.GET.get('mask',default=None)
|
||
# expire=request.GET.get('expire',default=None)
|
||
# gw=request.GET.get('gw',default=None)
|
||
# dns=request.GET.get('dns',default=None)
|
||
# dns2=request.GET.get('dns2',default=None)
|
||
# domain=request.GET.get('domain',default=None)
|
||
# log=request.GET.get('log',default=None)
|
||
# command==hub_cmd+' '+command+' '+command_dic['start']+start_ip+' '+command_dic['mask']+mask+' '+command_dic['expire']+expire\
|
||
# +' '+command_dic['gw']+gw+' '+command_dic['dns']+dns+' '+command_dic['dns2']+dns2+' '+command_dic['domain']+domain+' '+\
|
||
# command_dic['log']+log
|
||
# elif(command=='SecureNatHostSet'):
|
||
# mac=request.GET.get('mac',default=None)
|
||
# ip=request.GET.get('ip',default=None)
|
||
# mask=request.GET.get('mask',default=None)
|
||
# command=hub_cmd+' '+command+' '+command_dic['mac']+mac+' '+command_dic['ip']+ip+' '+command_dic['mask']+mask
|
||
# elif(command=='NatSet'):
|
||
# mtu=request.GET.get('mtu',default=None)
|
||
# tcptimeout=request.GET.get('tcptimeout',default=None)
|
||
# udptimeout=request.GET.get('udptimeout',default=None)
|
||
# log=request.GET.get('log',default=None)
|
||
# command=hub_cmd+' '+command+' '+command_dic['mtu']+mtu+' '+command_dic['tcptimeout']+tcptimeout+' '+command_dic['udptimeout']+\
|
||
# udptimeout+' '+command_dic['log']+log
|
||
# elif(command=='GroupCreate'):
|
||
# group=request.GET.get('group',default='none')
|
||
# realname=request.GET.get('realname',default='none')
|
||
# note=request.GET.get('note',default='none')
|
||
# command=hub_cmd+' '+command+' '+group+' '+command_dic['realname']+realname+' '+command_dic['note']+note
|
||
# elif(command='UserPasswordSet'):
|
||
# user_name=request.GET.get('user_name',default='\'*\'')
|
||
# user_pwd=request.GET.get('user_pwd',default=None)
|
||
# command=hub_cmd+' '+command+' '+user_name+' '+command_dic['password']+user_pwd
|
||
# outs,rtn_code=mysubprocess(command)
|
||
# if(rtn_code==0):
|
||
# myresponse=HttpResponse(json.dumps(outs),content_type='application/json')
|
||
# return myresponse
|
||
# else:
|
||
# myresponse=HttpResponse(json.dumps(response_dic['miss']),content_type='application/json',status=400)
|
||
# return myresponse
|
||
# elif cmd_obj=='client':
|
||
# command=request.GET.get('cmd')
|
||
# client_ip=request.GET.get('client_ip',default='localhost')
|
||
# client_cmd=command_dic['vpncmd']+' '+command_dic['client']+client_ip+' '+command_dic['cmd']
|
||
# if(command=='NicCreate'):
|
||
# nic_name=request.GET.get('nic_name',default='ethVPN3')
|
||
# command=client_cmd+' '+command+' '+nic_name
|
||
# elif(command=='AccountCreate'):
|
||
# account_name=request.GET.get('account_name',default='AccountL3')
|
||
# server_ip=request.GET.get('server_ip',default='192.168.11.137:443')
|
||
# hub_name=request.GET.get('hub_name',default='HubRadiusTest')
|
||
# user_name=request.GET.get('user_name',default='testing10')
|
||
# nic_name=request.GET.get('nic_name',default='ethVPN3')
|
||
# command=client_cmd+' '+command+' '+account+' '+command_dic['server']+':'+server_ip+' '+command_dic['hub']+hub_name+' '\
|
||
# +command_dic['username']+user_name+' '+command_dic['nic_name']+nic_name
|
||
# elif(command=='AccountPassword'):
|
||
# account=request.GET.get('account',default='AccountL3')
|
||
# account_pwd=request.GET.get('account_pwd',default='111111')
|
||
# account_type=request.GET.get('account_type',default='redius')
|
||
# command=client_cmd+' '+command+' '+account+' '+command_dic['password']+account_pwd+command_dic['type']+account_type
|
||
# elif(command=='AccountConnect'):
|
||
# account=request.GET.get('account',default='AccountL3')
|
||
# command=client_cmd+' '+command+' '+account
|
||
# elif(command=='AccountStatusGet'):
|
||
# account=request.GET.get('account',default='AccountL3')
|
||
# command=client_cmd+' '+command+' '+account
|
||
# elif(command=='dhclient'):
|
||
# nic_name=request.GET.get('account',default='vpn_ethvpn3')
|
||
# command='sudo'+' '+command+' '+nic_name
|
||
|
||
def mysubprocess(command, timeout1 = 6):
|
||
command = shlex.split(command)
|
||
try:
|
||
ssh_process = subprocess.Popen(command, shell=False, stdout = subprocess.PIPE, stderr = subprocess.PIPE, close_fds=True)
|
||
outs, errs = ssh_process.communicate(timeout = timeout1)
|
||
except Exception:
|
||
return "error",-1
|
||
else:
|
||
errs = errs.decode("utf-8")
|
||
outs = outs.decode("utf-8")
|
||
rtn_code = ssh_process.returncode
|
||
if rtn_code!= 0 and errs != '':
|
||
print("rtn_code: " + str(rtn_code))
|
||
print("errs: " + errs)
|
||
raise Exception("subprocess failed")
|
||
return outs,rtn_code
|
||
|
||
def readconfig():
|
||
myconfig=configparser.ConfigParser()
|
||
myconfig.read("CGI_config.conf")
|
||
server_pwd=myconfig.get("server","server_pwd")
|
||
host=myconfig.get("redis","host")
|
||
port=myconfig.get("redis","port")
|
||
index=myconfig.get("redis","index")
|
||
return server_pwd,host,port,index
|
||
|
||
def IpExist(host,port,candidate_ip,index):
|
||
P=Redis(host,port,index)
|
||
rtn,outs=P.connect()
|
||
my_set=set()
|
||
if(rtn!=-1):
|
||
scan_CANDIDATE=P.r.scan_iter(match="EFFECTIVE_RULE:IR_CANDIDATE_IP*")
|
||
for i in scan_CANDIDATE:
|
||
temp_list=P.r.get(i).split("\t")
|
||
my_set.add(temp_list[3])
|
||
if candidate_ip in my_set:
|
||
return 0,'true'
|
||
else:
|
||
return 0,'false'
|
||
else:
|
||
return -1,outs
|
||
|
||
def IpNumGet(host,port,addr_pool_id,index):# IpNumGet(group_id)
|
||
P=Redis(host,port,index)
|
||
rtn,outs=P.connect()
|
||
my_set=set()
|
||
if(rtn!=-1):
|
||
scan_CANDIDATE=P.r.scan_iter(match="EFFECTIVE_RULE:IR_CANDIDATE_IP*")
|
||
for i in scan_CANDIDATE:
|
||
temp_list=P.r.get(i).split("\t")
|
||
if(temp_list[1]==addr_pool_id):
|
||
my_set.add(temp_list[3])
|
||
return len(my_set),outs
|
||
else:
|
||
return -1,outs
|
||
|
||
def AllIpGet(host,port,addr_pool_id,index):# AllIpGet(group_id)
|
||
P=Redis(host,port,index)
|
||
rtn,outs=P.connect()
|
||
my_set=set()
|
||
if(rtn!=-1):
|
||
scan_CANDIDATE=P.r.scan_iter(match="EFFECTIVE_RULE:IR_CANDIDATE_IP*")
|
||
for i in scan_CANDIDATE:
|
||
temp_list=P.r.get(i).split("\t")
|
||
if(temp_list[1]==addr_pool_id):
|
||
my_set.add(temp_list[3])
|
||
return 0,list(my_set)
|
||
else:
|
||
return -1,outs |