Nemcio/CyberPanel
1
0
Fork 0
mirror of https://github.com/usmannasir/cyberpanel.git synced 2025-11-08 06:16:08 +01:00
Code Issues Packages Projects Releases Wiki Activity

switchoff security DOne Frontend

Browse Source
This commit is contained in:
Hassan Hashmi
2024-04-27 17:27:12 +05:00
parent e98d5485c3
commit 00f8191fb3
5 changed files with 341 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

84
serverStatus/views.py
View File

@@ -28,11 +28,19 @@ EXPIRE = 3
VERSION = '2.3'
BUILD = 5
def serverStatusHome(request):
proc = httpProc(request, 'serverStatus/index.html',
None, 'admin')
return proc.render()
def Switchoffsecurity(request):
proc = httpProc(request, 'serverStatus/Switchoffsecurity.html',
None, 'admin')
return proc.render()
def litespeedStatus(request):
try:
userID = request.session['userID']
@@ -91,6 +99,7 @@ def litespeedStatus(request):
logging.CyberCPLogFileWriter.writeToFile(str(msg) + "[litespeedStatus]")
return redirect(loadLoginPage)
def stopOrRestartLitespeed(request):
try:
userID = request.session['userID']
@@ -124,10 +133,12 @@ def stopOrRestartLitespeed(request):
logging.CyberCPLogFileWriter.writeToFile(str(msg) + "[stopOrRestartLitespeed]")
return HttpResponse("Not Logged in as admin")
def cyberCPMainLogFile(request):
proc = httpProc(request, 'serverStatus/cybercpmainlogfile.html', None, 'admin')
return proc.render()
def getFurtherDataFromLogFile(request):
try:
userID = request.session['userID']
@@ -151,6 +162,7 @@ def getFurtherDataFromLogFile(request):
logging.CyberCPLogFileWriter.writeToFile(str(msg) + "[getFurtherDataFromLogFile]")
return HttpResponse("Not Logged in as admin")
def services(request):
data = {}
@@ -168,6 +180,7 @@ def services(request):
proc = httpProc(request, 'serverStatus/services.html', data, 'admin')
return proc.render()
def servicesStatus(request):
try:
userID = request.session['userID']
@@ -276,6 +289,7 @@ def servicesStatus(request):
except KeyError:
return redirect(loadLoginPage)
def servicesAction(request):
try:
userID = request.session['userID']
@@ -328,6 +342,7 @@ def servicesAction(request):
final_json = json.dumps(final_dic)
return HttpResponse(final_json)
def switchTOLSWS(request):
try:
userID = request.session['userID']
@@ -361,6 +376,35 @@ def switchTOLSWS(request):
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
def securityruleUpdate(request):
try:
userID = request.session['userID']
currentACL = ACLManager.loadedACL(userID)
if currentACL['admin'] == 1:
pass
else:
return ACLManager.loadErrorJson('status', 0)
data = json.loads(request.body)
ActivateTags = data['ActivateTags']
DeactivatedTags = data['DeactivatedTags']
RuleID = data['RuleID']
Regular_expressions = data['Regular_expressions']
data_ret = {'status': 1, 'error_message': "None", }
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
except BaseException as msg:
data_ret = {'status': 0, 'error_message': str(msg)}
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
def switchTOLSWSStatus(request):
try:
@@ -387,10 +431,11 @@ def switchTOLSWSStatus(request):
except BaseException as msg:
command = "sudo rm -f " + serverStatusUtil.ServerStatusUtil.lswsInstallStatusPath
ProcessUtilities.popenExecutioner(command)
data_ret = {'status': 0,'abort': 1, 'requestStatus': str(msg), 'installed': 0}
data_ret = {'status': 0, 'abort': 1, 'requestStatus': str(msg), 'installed': 0}
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
def licenseStatus(request):
try:
userID = request.session['userID']
@@ -407,7 +452,8 @@ def licenseStatus(request):
serial = ProcessUtilities.outputExecutioner(command)
if serial.find('No such file or directory') > -1:
final_dic = {'status': 1, "erroMessage": 0, 'lsSerial': 'Trial License in use.', 'lsexpiration': 'Trial license expires 15 days after activation.'}
final_dic = {'status': 1, "erroMessage": 0, 'lsSerial': 'Trial License in use.',
'lsexpiration': 'Trial license expires 15 days after activation.'}
final_json = json.dumps(final_dic)
return HttpResponse(final_json)
@@ -427,6 +473,7 @@ def licenseStatus(request):
final_json = json.dumps(final_dic)
return HttpResponse(final_json)
def refreshLicense(request):
try:
userID = request.session['userID']
@@ -439,7 +486,6 @@ def refreshLicense(request):
else:
return ACLManager.loadErrorJson('status', 0)
command = 'sudo /usr/local/lsws/bin/lshttpd -V'
ProcessUtilities.outputExecutioner(command)
@@ -512,6 +558,7 @@ def topProcesses(request):
proc = httpProc(request, "serverStatus/topProcesses.html", None, 'admin')
return proc.render()
def topProcessesStatus(request):
try:
userID = request.session['userID']
@@ -586,7 +633,6 @@ def topProcessesStatus(request):
memoryInf0[1] = list(filter(None, memoryInf0[1].split(' ')))
memoryInf0[2] = list(filter(None, memoryInf0[2].split(' ')))
try:
data['totalMemory'] = '%sMB' % (memoryInf0[1][1])
except:
@@ -606,7 +652,6 @@ def topProcessesStatus(request):
except:
data['buffCache'] = '%sMB' % ('0')
## Swap
try:
@@ -681,8 +726,8 @@ def topProcessesStatus(request):
total, used, free = shutil.disk_usage("/")
data['TotalDisk'] = '%s GB' % (total // (2 ** 30))
data['TotalDiskUsed'] = '%s GB' % (used // (2 ** 30))
data['TotalDiskFree'] =' %s GB' % (free // (2 ** 30))
data['TotalDiskUsed'] = '%s GB' % (used // (2 ** 30))
data['TotalDiskFree'] = ' %s GB' % (free // (2 ** 30))
final_json = json.dumps(data)
return HttpResponse(final_json)
@@ -692,6 +737,7 @@ def topProcessesStatus(request):
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
def killProcess(request):
try:
userID = request.session['userID']
@@ -721,10 +767,12 @@ def killProcess(request):
final_json = json.dumps(final_dic)
return HttpResponse(final_json)
def packageManager(request):
proc = httpProc(request, "serverStatus/packageManager.html", None, 'admin')
return proc.render()
def fetchPackages(request):
try:
@@ -842,8 +890,7 @@ def fetchPackages(request):
## make list of packages that need update
#if os.path.exists(ProcessUtilities.debugPath):
# if os.path.exists(ProcessUtilities.debugPath):
# logging.CyberCPLogFileWriter.writeToFile('All packages: %s' % (str(packages)))
from s3Backups.s3Backups import S3Backups
@@ -857,7 +904,7 @@ def fetchPackages(request):
counter = 0
if os.path.exists(ProcessUtilities.debugPath):
logging.CyberCPLogFileWriter.writeToFile('Final packages: %s' % (str(finalPackages)))
logging.CyberCPLogFileWriter.writeToFile('Final packages: %s' % (str(finalPackages)))
import re
for items in finalPackages:
@@ -896,7 +943,9 @@ def fetchPackages(request):
else:
lock = 0
dic = {'package': nowSplitted[0].split('/')[0], 'version': '%s %s' % (nowSplitted[1].split(' ')[1], nowSplitted[1].split(' ')[2]), 'upgrade': upgrade, 'lock': lock}
dic = {'package': nowSplitted[0].split('/')[0],
'version': '%s %s' % (nowSplitted[1].split(' ')[1], nowSplitted[1].split(' ')[2]),
'upgrade': upgrade, 'lock': lock}
counter = counter + 1
if checker == 0:
@@ -923,7 +972,6 @@ def fetchPackages(request):
else:
upgrade = 'Upgrade available'
if details[0].split('.')[0] in locked:
lock = 1
else:
@@ -965,7 +1013,8 @@ def fetchPackages(request):
json_data = json_data + ']'
data_ret = {'status': 1, 'packages': json_data, 'pagination': pagination, 'fetchedPackages': counter, 'totalPackages': len(packages)}
data_ret = {'status': 1, 'packages': json_data, 'pagination': pagination, 'fetchedPackages': counter,
'totalPackages': len(packages)}
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
@@ -974,6 +1023,7 @@ def fetchPackages(request):
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
def fetchPackageDetails(request):
try:
@@ -1004,6 +1054,7 @@ def fetchPackageDetails(request):
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
def updatePackage(request):
try:
@@ -1027,7 +1078,7 @@ def updatePackage(request):
extraArgs = {}
extraArgs['package'] = package
from plogical.applicationInstaller import ApplicationInstaller
from plogical.applicationInstaller import ApplicationInstaller
background = ApplicationInstaller('updatePackage', extraArgs)
background.start()
@@ -1043,6 +1094,7 @@ def updatePackage(request):
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
def lockStatus(request):
try:
@@ -1179,11 +1231,11 @@ def submitPortChange(request):
ProcessUtilities.executioner('systemctl restart lscpd')
data_ret = {'status': 1,}
data_ret = {'status': 1, }
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
except BaseException as msg:
data_ret = {'status': 0, 'error_message': str(msg)}
json_data = json.dumps(data_ret)
return HttpResponse(json_data)
return HttpResponse(json_data)