# -*- coding: utf-8 -*- from __future__ import unicode_literals from django.shortcuts import render from django.shortcuts import HttpResponse, redirect import plogical.CyberCPLogFileWriter as logging from loginSystem.views import loadLoginPage import os import json from plogical.mailUtilities import mailUtilities import subprocess, shlex from plogical.acl import ACLManager from models import PDNSStatus from .serviceManager import ServiceManager # Create your views here. def managePowerDNS(request): try: userID = request.session['userID'] currentACL = ACLManager.loadedACL(userID) if currentACL['admin'] == 1: pass else: return ACLManager.loadError() try: return render(request, 'manageServices/managePowerDNS.html', {"status": 1}) except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg)) return HttpResponse("See CyberCP main log file.") except KeyError: return redirect(loadLoginPage) def managePostfix(request): try: userID = request.session['userID'] currentACL = ACLManager.loadedACL(userID) if currentACL['admin'] == 1: pass else: return ACLManager.loadError() try: return render(request, 'manageServices/managePostfix.html', {"status": 1}) except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg)) return HttpResponse("See CyberCP main log file.") except KeyError: return redirect(loadLoginPage) def managePureFtpd(request): try: userID = request.session['userID'] currentACL = ACLManager.loadedACL(userID) if currentACL['admin'] == 1: pass else: return ACLManager.loadError() try: return render(request, 'manageServices/managePureFtpd.html', {"status": 1}) except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg)) return HttpResponse("See CyberCP main log file.") except KeyError: return redirect(loadLoginPage) def fetchStatus(request): try: userID = request.session['userID'] currentACL = ACLManager.loadedACL(userID) if currentACL['admin'] == 1: pass else: return ACLManager.loadErrorJson() try: if request.method == 'POST': mailUtilities.checkHome() data = json.loads(request.body) service = data['service'] if service == 'powerdns': data_ret = {} data_ret['status'] = 1 try: pdns = PDNSStatus.objects.get(pk=1) data_ret['installCheck'] = pdns.serverStatus data_ret['slaveIPData'] = pdns.also_notify except: PDNSStatus(serverStatus=1).save() data_ret['installCheck'] = 0 data_ret['slaveIPData'] = '' json_data = json.dumps(data_ret) return HttpResponse(json_data) elif service == 'postfix': if os.path.exists('/home/cyberpanel/postfix'): data_ret = {'status': 1, 'error_message': 'None', 'installCheck': 1} json_data = json.dumps(data_ret) return HttpResponse(json_data) else: data_ret = {'status': 1, 'error_message': 'None', 'installCheck': 0} json_data = json.dumps(data_ret) return HttpResponse(json_data) elif service == 'pureftpd': if os.path.exists('/home/cyberpanel/pureftpd'): data_ret = {'status': 1, 'error_message': 'None', 'installCheck': 1} json_data = json.dumps(data_ret) return HttpResponse(json_data) else: data_ret = {'status': 1, 'error_message': 'None', 'installCheck': 0} json_data = json.dumps(data_ret) return HttpResponse(json_data) except BaseException,msg: data_ret = {'status': 0, 'error_message': str(msg)} json_data = json.dumps(data_ret) return HttpResponse(json_data) except KeyError,msg: logging.CyberCPLogFileWriter.writeToFile(str(msg)) data_ret = {'status': 0, 'error_message': str(msg)} json_data = json.dumps(data_ret) return HttpResponse(json_data) def saveStatus(request): try: userID = request.session['userID'] currentACL = ACLManager.loadedACL(userID) if currentACL['admin'] == 1: pass else: return ACLManager.loadErrorJson() try: if request.method == 'POST': data = json.loads(request.body) status = data['status'] service = data['service'] mailUtilities.checkHome() if service == 'powerdns': if status == True: pdns = PDNSStatus.objects.get(pk=1) pdns.serverStatus = 1 pdns.allow_axfr_ips = data['slaveIPData'].replace(',', '/32,') pdns.also_notify = data['slaveIPData'] pdns.type = data['dnsMode'] pdns.save() extraArgs = {} extraArgs['type'] = data['dnsMode'] extraArgs['slaveIPData'] = data['slaveIPData'] sm = ServiceManager(extraArgs) sm.managePDNS() command = 'sudo systemctl start pdns' subprocess.call(shlex.split(command)) command = 'sudo systemctl enable pdns' subprocess.call(shlex.split(command)) else: pdns = PDNSStatus.objects.get(pk=1) pdns.serverStatus = 0 pdns.save() command = 'sudo systemctl stop pdns' subprocess.call(shlex.split(command)) command = 'sudo systemctl disable pdns' subprocess.call(shlex.split(command)) elif service == 'postfix': servicePath = '/home/cyberpanel/postfix' if status == True: writeToFile = open(servicePath, 'w+') writeToFile.close() command = 'sudo systemctl start postfix' subprocess.call(shlex.split(command)) else: command = 'sudo systemctl stop postfix' subprocess.call(shlex.split(command)) command = 'sudo systemctl disable postfix' subprocess.call(shlex.split(command)) try: os.remove(servicePath) except: pass elif service == 'pureftpd': if os.path.exists("/etc/lsb-release"): serviceName = 'pure-ftpd-mysql' else: serviceName = 'pure-ftpd' servicePath = '/home/cyberpanel/pureftpd' if status == True: writeToFile = open(servicePath, 'w+') writeToFile.close() command = 'sudo systemctl start ' + serviceName subprocess.call(shlex.split(command)) else: command = 'sudo systemctl stop ' + serviceName subprocess.call(shlex.split(command)) command = 'sudo systemctl disable ' + serviceName subprocess.call(shlex.split(command)) try: os.remove(servicePath) except: pass data_ret = {'status': 1, 'error_message': "None"} json_data = json.dumps(data_ret) return HttpResponse(json_data) except BaseException,msg: data_ret = {'status': 0, 'error_message': str(msg)} json_data = json.dumps(data_ret) return HttpResponse(json_data) except KeyError,msg: logging.CyberCPLogFileWriter.writeToFile(str(msg)) data_ret = {'status': 0, 'error_message': str(msg)} json_data = json.dumps(data_ret) return HttpResponse(json_data)