# -*- coding: utf-8 -*- from __future__ import unicode_literals from django.shortcuts import render,redirect from django.http import HttpResponse # Create your views here. from .models import DBUsers from loginSystem.models import Administrator import json from websiteFunctions.models import Websites,Backups,dest,backupSchedules,ChildDomains import plogical.CyberCPLogFileWriter as logging from loginSystem.views import loadLoginPage import os import time import plogical.backupUtilities as backupUtil from shutil import rmtree import shlex import subprocess import signal import plogical.remoteBackup as rBackup import requests def loadBackupHome(request): try: val = request.session['userID'] admin = Administrator.objects.get(pk=val) viewStatus = 1 if admin.type == 3: viewStatus = 0 return render(request,'backup/index.html',{"viewStatus":viewStatus}) except KeyError: return redirect(loadLoginPage) def restoreSite(request): try: val = request.session['userID'] try: admin = Administrator.objects.get(pk=request.session['userID']) if admin.type == 1: path = "/home/backup" if not os.path.exists(path): return render(request, 'backup/restore.html') else: all_files = [] ext = ".tar.gz" files = os.listdir(path) for filename in files: if filename.endswith(ext): all_files.append(filename) return render(request, 'backup/restore.html',{'backups':all_files}) else: return HttpResponse("You should be admin to perform restores.") except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg)) return HttpResponse(str(msg)) except KeyError: return redirect(loadLoginPage) def backupSite(request): try: val = request.session['userID'] try: admin = Administrator.objects.get(pk=request.session['userID']) if admin.type == 1: websites = Websites.objects.all() websitesName = [] for items in websites: websitesName.append(items.domain) else: if admin.type == 2: websites = admin.websites_set.all() admins = Administrator.objects.filter(owner=admin.pk) websitesName = [] for items in websites: websitesName.append(items.domain) for items in admins: webs = items.websites_set.all() for web in webs: websitesName.append(web.domain) else: websitesName = [] websites = Websites.objects.filter(admin=admin) for items in websites: websitesName.append(items.domain) return render(request, 'backup/backup.html', {'websiteList':websitesName}) except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg)) return HttpResponse(str(msg)) except KeyError: return redirect(loadLoginPage) def getCurrentBackups(request): try: val = request.session['userID'] try: if request.method == 'POST': data = json.loads(request.body) backupDomain = data['websiteToBeBacked'] website = Websites.objects.get(domain=backupDomain) backups = website.backups_set.all() json_data = "[" checker = 0 for items in backups: if items.status == 0: status="Pending" else: status="Completed" dic = {'id': items.id, 'file': items.fileName, 'date': items.date, 'size': items.size, 'status': status } if checker == 0: json_data = json_data + json.dumps(dic) checker = 1 else: json_data = json_data + ',' + json.dumps(dic) json_data = json_data + ']' final_json = json.dumps({'fetchStatus': 1, 'error_message': "None","data":json_data}) return HttpResponse(final_json) except BaseException,msg: final_dic = {'fetchStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) except KeyError: final_dic = {'fetchStatus': 0, 'error_message': "Not Logged In, please refresh the page or login again."} final_json = json.dumps(final_dic) return HttpResponse(final_json) def submitBackupCreation(request): try: if request.method == 'POST': data = json.loads(request.body) backupDomain = data['websiteToBeBacked'] website = Websites.objects.get(domain=backupDomain) backupPath = "/home/" + backupDomain + "/backup/" if not os.path.exists(backupPath): os.mkdir(backupPath) domainUser = backupDomain.split('.') backupName = 'backup-' + domainUser[0] + "-" + time.strftime("%I-%M-%S-%a-%b-%Y") tempStoragePath = backupPath + backupName if not os.path.exists(tempStoragePath): os.mkdir(tempStoragePath) ## Generating meta meta = tempStoragePath + "/meta" metaFile = open(meta, 'w') metaFile.write(backupDomain + "-" + website.phpSelection + "\n") childDomains = website.childdomains_set.all() databases = website.databases_set.all() metaFile.write("Child Domains\n") for items in childDomains: metaFile.write(items.domain + "-" + items.phpSelection + "-" + items.path + "\n") metaFile.write("Databases\n") for items in databases: dbuser = DBUsers.objects.get(user=items.dbUser) metaFile.write(items.dbName + "-" + items.dbUser + "-" + dbuser.password + "\n") metaFile.close() backupUtil.backupUtilities.initiateBackup(tempStoragePath, backupName, backupPath) newBackup = Backups(website=website, fileName=backupName, date=time.strftime("%I-%M-%S-%a-%b-%Y"), size=0, status=0) newBackup.save() final_json = json.dumps({'metaStatus': 1, 'error_message': "None", 'tempStorage': tempStoragePath}) return HttpResponse(final_json) except BaseException, msg: final_dic = {'metaStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) def backupStatus(request): try: try: if request.method == 'POST': data = json.loads(request.body) backupDomain = data['websiteToBeBacked'] status = "/home/"+backupDomain+"/backup/status" if os.path.exists(status): readStatus = open(status,'r').readlines() readStatus[0] = readStatus[0].strip('\n') readStatus[1] = readStatus[1].strip('\n') if readStatus[1] == "completed": os.remove(status) backupOb = Backups.objects.get(fileName=readStatus[0]) backupOb.status = 1 ## adding backup data to database. try: backupOb.size = str(int(float(os.path.getsize("/home/"+backupDomain+"/backup/"+readStatus[0]+".tar.gz"))/(1024.0 * 1024.0)))+"MB" backupOb.save() except: backupOb.size = str(int(os.path.getsize("/home/"+backupDomain+"/backup/"+readStatus[0]+".tar.gz"))) backupOb.save() final_json = json.dumps({'backupStatus': 1, 'error_message': "None", "status": 0}) return HttpResponse(final_json) elif readStatus[1] == "Aborted, please check CyberPanel main log file.": ## removing status file, so that backup can re-run try: os.remove(status) backupOb = Backups.objects.get(fileName=readStatus[0]) backupOb.delete() except BaseException,msg: logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [backupStatus]") final_json = json.dumps({'backupStatus': 1, 'error_message': "None",'fileName':readStatus[0], "status": "Aborted, please check CyberPanel main log file."}) return HttpResponse(final_json) elif readStatus[1] == "Aborted manually.": ## removing status file, so that backup can re-run try: os.remove(status) backupOb = Backups.objects.get(fileName=readStatus[0]) backupOb.delete() except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [backupStatus]") final_json = json.dumps({'backupStatus': 1, 'error_message': "None", 'fileName': readStatus[0], "status": "Aborted manually."}) return HttpResponse(final_json) final_json = json.dumps({'backupStatus': 1, 'error_message': "None",'fileName':readStatus[0], "status": readStatus[1]}) return HttpResponse(final_json) else: final_json = json.dumps({'backupStatus': 0, 'error_message': "None", "status": 0}) return HttpResponse(final_json) except BaseException,msg: final_dic = {'backupStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [backupStatus]") return HttpResponse(final_json) except KeyError: final_dic = {'backupStatus': 0, 'error_message': "Not Logged In, please refresh the page or login again."} final_json = json.dumps(final_dic) logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [backupStatus]") return HttpResponse(final_json) def cancelBackupCreation(request): try: val = request.session['userID'] try: if request.method == 'POST': data = json.loads(request.body) backupCancellationDomain = data['backupCancellationDomain'] fileName = data['fileName'] path = "/home/"+backupCancellationDomain+"/backup/pid" pid = open(path,"r").readlines()[0] try: os.kill(int(pid),signal.SIGKILL) except BaseException,msg: logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [cancelBackupCreation]") backupPath = "/home/" + backupCancellationDomain + "/backup/" tempStoragePath = backupPath + fileName try: backupOb = Backups.objects.get(fileName=fileName) backupOb.delete() except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [cancelBackupCreation]") try: os.remove(tempStoragePath + ".tar.gz") except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [cancelBackupCreation]") try: rmtree(tempStoragePath) except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [cancelBackupCreation]") status = open(backupPath + 'status', "w") status.write(fileName + "\n") status.write("Aborted manually.") status.close() final_json = json.dumps({'abortStatus': 1, 'error_message': "None", "status": 0}) return HttpResponse(final_json) except BaseException,msg: final_dic = {'abortStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) except KeyError: final_dic = {'abortStatus': 0, 'error_message': "Not Logged In, please refresh the page or login again."} final_json = json.dumps(final_dic) return HttpResponse(final_json) def deleteBackup(request): try: val = request.session['userID'] try: if request.method == 'POST': data = json.loads(request.body) backupID = data['backupID'] backup = Backups.objects.get(id=backupID) domainName = backup.website.domain path = "/home/"+domainName+"/backup/"+backup.fileName+".tar.gz" if os.path.exists(path): os.remove(path) backup.delete() final_json = json.dumps({'deleteStatus': 1, 'error_message': "None", "status": 0}) return HttpResponse(final_json) except BaseException,msg: final_dic = {'deleteStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) except KeyError: final_dic = {'deleteStatus': 0, 'error_message': "Not Logged In, please refresh the page or login again."} final_json = json.dumps(final_dic) return HttpResponse(final_json) def submitRestore(request): try: if request.method == 'POST': data = json.loads(request.body) backupFile = data['backupFile'] originalFile = "/home/backup/" + backupFile if not os.path.exists(originalFile): dir = data['dir'] else: dir = None backupUtil.backupUtilities.initiateRestore(backupFile, dir) final_dic = {'restoreStatus': 1, 'error_message': "None"} final_json = json.dumps(final_dic) return HttpResponse(final_json) except BaseException, msg: final_dic = {'restoreStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) def restoreStatus(request): try: if request.method == 'POST': data = json.loads(request.body) backupFile = data['backupFile'].strip(".tar.gz") path = "/home/backup/" + data['backupFile'] if os.path.exists(path): path = "/home/backup/" + backupFile else: dir = data['dir'] path = "/home/backup/transfer-" + str(dir) + "/" + backupFile if os.path.exists(path): try: status = open(path + '/status', 'r').readlines()[0] except: status = "Just Started" if status == "Done": rmtree(path) final_json = json.dumps({'restoreStatus': 1, 'error_message': "None", "status": "Done"}) return HttpResponse(final_json) if status == "Website already exists": rmtree(path) final_json = json.dumps({'restoreStatus': 1, 'error_message': "Website already exists", "status": "Website already exists"}) return HttpResponse(final_json) if status.find("Not able to create Account and databases") > -1: rmtree(path) final_json = json.dumps( {'restoreStatus': 1, 'error_message': "Not able to create Account and databases, aborting.", "status": "Not able to create Account and databases, aborting."}) return HttpResponse(final_json) final_json = json.dumps({'restoreStatus': 1, 'error_message': "None", "status": status}) return HttpResponse(final_json) else: final_json = json.dumps({'restoreStatus': 1, 'error_message': "None", "status": 0}) return HttpResponse(final_json) except BaseException, msg: final_dic = {'restoreStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) def backupDestinations(request): try: val = request.session['userID'] admin = Administrator.objects.get(pk=val) if admin.type==1: return render(request, 'backup/backupDestinations.html', {}) else: return HttpResponse("You should be admin to add backup destinations.") except KeyError: return redirect(loadLoginPage) def submitDestinationCreation(request): try: try: if request.method == 'POST': path = "/usr/local/CyberCP/backup/" destinations = path+"destinations" if not os.path.exists(path): os.mkdir(path) data = json.loads(request.body) ipAddress = data['IPAddress'] password = data['password'] if dest.objects.all().count() == 2: final_dic = {'destStatus': 0, 'error_message': "Currently only one remote destination is allowed."} final_json = json.dumps(final_dic) return HttpResponse(final_json) try: dest.objects.get(destLoc=ipAddress) final_dic = {'destStatus': 0, 'error_message': "This destination already exists."} final_json = json.dumps(final_dic) return HttpResponse(final_json) except: status = backupUtil.backupUtilities.setupSSHKeys(ipAddress,password) if status == 1: newDest = dest(destLoc=ipAddress) newDest.save() writeToFile = open(destinations,"w") writeToFile.writelines(ipAddress+"\n") writeToFile.close() backupUtil.backupUtilities.initiateBackupDirCreation(ipAddress) final_dic = {'destStatus': 1, 'error_message': "None"} final_json = json.dumps(final_dic) return HttpResponse(final_json) else: final_dic = {'destStatus': 0, 'error_message': status} final_json = json.dumps(final_dic) return HttpResponse(final_json) except BaseException,msg: final_dic = {'destStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) except KeyError: final_dic = {'destStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) def getCurrentBackupDestinations(request): try: val = request.session['userID'] try: if request.method == 'POST': records = dest.objects.all() json_data = "[" checker = 0 for items in records: if items.destLoc == "Home": continue dic = {'id': items.id, 'ip': items.destLoc, } if checker == 0: json_data = json_data + json.dumps(dic) checker = 1 else: json_data = json_data + ',' + json.dumps(dic) json_data = json_data + ']' final_json = json.dumps({'fetchStatus': 1, 'error_message': "None","data":json_data}) return HttpResponse(final_json) except BaseException,msg: final_dic = {'fetchStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) except KeyError: final_dic = {'fetchStatus': 0, 'error_message': "Not Logged In, please refresh the page or login again."} final_json = json.dumps(final_dic) return HttpResponse(final_json) def getConnectionStatus(request): try: try: if request.method == 'POST': data = json.loads(request.body) ipAddress = data['IPAddress'] if backupUtil.backupUtilities.checkConnection(ipAddress)==1: final_dic = {'connStatus': 1, 'error_message': "None"} final_json = json.dumps(final_dic) return HttpResponse(final_json) else: final_dic = {'connStatus': 0, 'error_message': "None"} final_json = json.dumps(final_dic) return HttpResponse(final_json) except BaseException,msg: final_dic = {'connStatus': 1, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) except KeyError: final_dic = {'connStatus': 1, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) def deleteDestination(request): try: try: if request.method == 'POST': data = json.loads(request.body) ipAddress = data['IPAddress'] delDest = dest.objects.get(destLoc=ipAddress) delDest.delete() path = "/usr/local/CyberCP/backup/" destinations = path + "destinations" data = open(destinations,'r').readlines() writeToFile = open(destinations,'r') for items in data: if items.find(ipAddress) > -1: continue else: writeToFile.writelines(items) writeToFile.close() ## Deleting Cron Tab Entries for this destination path = "/etc/crontab" data = open(path, 'r').readlines() writeToFile = open(path, 'w') for items in data: if items.find("backupSchedule.py") > -1: continue else: writeToFile.writelines(items) writeToFile.close() final_dic = {'delStatus': 1, 'error_message': "None"} final_json = json.dumps(final_dic) return HttpResponse(final_json) except BaseException,msg: final_dic = {'delStatus': 1, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) except KeyError: final_dic = {'delStatus': 1, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) def scheduleBackup(request): try: val = request.session['userID'] admin = Administrator.objects.get(pk=val) if admin.type == 1: if dest.objects.all().count() <= 1: try: homeDest = dest(destLoc="Home") homeDest.save() except: pass backups = dest.objects.all() destinations = [] for items in backups: destinations.append(items.destLoc) return render(request,'backup/backupSchedule.html',{'destinations':destinations}) else: return HttpResponse("You should be admin to schedule backups.") except KeyError: return redirect(loadLoginPage) def getCurrentBackupSchedules(request): try: val = request.session['userID'] try: if request.method == 'POST': records = backupSchedules.objects.all() json_data = "[" checker = 0 for items in records: dic = {'id': items.id, 'destLoc': items.dest.destLoc, 'frequency':items.frequency, } if checker == 0: json_data = json_data + json.dumps(dic) checker = 1 else: json_data = json_data + ',' + json.dumps(dic) json_data = json_data + ']' final_json = json.dumps({'fetchStatus': 1, 'error_message': "None","data":json_data}) return HttpResponse(final_json) except BaseException,msg: final_dic = {'fetchStatus': 0, 'error_message': str(msg)} final_json = json.dumps(final_dic) return HttpResponse(final_json) except KeyError: final_dic = {'fetchStatus': 0, 'error_message': "Not Logged In, please refresh the page or login again."} final_json = json.dumps(final_dic) return HttpResponse(final_json) def submitBackupSchedule(request): try: val = request.session['userID'] try: if request.method == 'POST': data = json.loads(request.body) backupDest = data['backupDest'] backupFreq = data['backupFreq'] path = "/etc/crontab" ## check if already exists try: schedule = backupSchedules.objects.get(frequency=backupFreq) if schedule.dest.destLoc == backupDest: final_json = json.dumps({'scheduleStatus': 0, 'error_message': "This schedule already exists"}) return HttpResponse(final_json) else: if backupDest == "Home" and backupFreq == "Daily": cronJob = "0 3 * * 0-6 root python /usr/local/CyberCP/plogical/backupScheduleLocal.py" writeToFile = open(path,'a') writeToFile.writelines(cronJob+"\n") writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules(dest=destination, frequency=backupFreq) newSchedule.save() final_json = json.dumps({'scheduleStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest == "Home" and backupFreq == "Weekly": cronJob = "0 3 * * 3 root python /usr/local/CyberCP/plogical/backupScheduleLocal.py " writeToFile = open(path, 'a') writeToFile.writelines(cronJob + "\n") writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules(dest=destination, frequency=backupFreq) newSchedule.save() final_json = json.dumps({'scheduleStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest != "Home" and backupFreq == "Daily": cronJob = "0 3 * * 0-6 root python /usr/local/CyberCP/plogical/backupSchedule.py" writeToFile = open(path, 'a') writeToFile.writelines(cronJob + "\n") writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules(dest=destination, frequency=backupFreq) newSchedule.save() final_json = json.dumps({'scheduleStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest != "Home" and backupFreq == "Weekly": cronJob = "0 3 * * 3 root python /usr/local/CyberCP/plogical/backupSchedule.py " writeToFile = open(path, 'a') writeToFile.writelines(cronJob + "\n") writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules(dest=destination,frequency=backupFreq) newSchedule.save() final_json = json.dumps({'scheduleStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) except: if backupDest == "Home" and backupFreq == "Daily": cronJob = "0 3 * * 0-6 root python /usr/local/CyberCP/plogical/backupScheduleLocal.py" writeToFile = open(path, 'a') writeToFile.writelines(cronJob + "\n") writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules(dest=destination, frequency=backupFreq) newSchedule.save() final_json = json.dumps({'scheduleStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest == "Home" and backupFreq == "Weekly": cronJob = "0 3 * * 3 root python /usr/local/CyberCP/plogical/backupScheduleLocal.py " writeToFile = open(path, 'a') writeToFile.writelines(cronJob + "\n") writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules(dest=destination, frequency=backupFreq) newSchedule.save() final_json = json.dumps({'scheduleStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest != "Home" and backupFreq == "Daily": cronJob = "0 3 * * 0-6 root python /usr/local/CyberCP/plogical/backupSchedule.py" writeToFile = open(path, 'a') writeToFile.writelines(cronJob + "\n") writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules(dest=destination, frequency=backupFreq) newSchedule.save() final_json = json.dumps({'scheduleStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest != "Home" and backupFreq == "Weekly": cronJob = "0 3 * * 3 root python /usr/local/CyberCP/plogical/backupSchedule.py " writeToFile = open(path, 'a') writeToFile.writelines(cronJob + "\n") writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules(dest=destination, frequency=backupFreq) newSchedule.save() final_json = json.dumps({'scheduleStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) except BaseException,msg: final_json = json.dumps({'scheduleStatus': 0, 'error_message': str(msg)}) return HttpResponse(final_json) except KeyError: final_json = json.dumps({'scheduleStatus': 0, 'error_message': str(msg)}) return HttpResponse(final_json) def scheduleDelete(request): try: val = request.session['userID'] try: if request.method == 'POST': data = json.loads(request.body) backupDest = data['destLoc'] backupFreq = data['frequency'] path = "/etc/crontab" if backupDest == "Home" and backupFreq == "Daily": data = open(path, "r").readlines() writeToFile = open(path, 'w') for items in data: if items.find("0-6") > -1 and items.find("backupScheduleLocal.py") > -1: continue else: writeToFile.writelines(items) writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules.objects.get(dest=destination, frequency=backupFreq) newSchedule.delete() final_json = json.dumps({'delStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest == "Home" and backupFreq == "Weekly": data = open(path, "r").readlines() writeToFile = open(path, 'w') for items in data: if items.find("* 3") > -1 and items.find("backupScheduleLocal.py") > -1: continue else: writeToFile.writelines(items) writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules.objects.get(dest=destination, frequency=backupFreq) newSchedule.delete() final_json = json.dumps({'delStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest != "Home" and backupFreq == "Daily": data = open(path, "r").readlines() writeToFile = open(path, 'w') for items in data: if items.find("0-6") > -1 and items.find("backupSchedule.py") > -1: continue else: writeToFile.writelines(items) writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules.objects.get(dest=destination, frequency=backupFreq) newSchedule.delete() final_json = json.dumps({'delStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) elif backupDest != "Home" and backupFreq == "Weekly": data = open(path, "r").readlines() writeToFile = open(path, 'w') for items in data: if items.find("* 3") > -1 and items.find("backupSchedule.py") > -1: continue else: writeToFile.writelines(items) writeToFile.close() command = "systemctl restart crond" subprocess.call(shlex.split(command)) destination = dest.objects.get(destLoc=backupDest) newSchedule = backupSchedules.objects.get(dest=destination, frequency=backupFreq) newSchedule.delete() final_json = json.dumps({'delStatus': 1, 'error_message': "None"}) return HttpResponse(final_json) except BaseException,msg: final_json = json.dumps({'delStatus': 0, 'error_message': str(msg)}) return HttpResponse(final_json) except KeyError: final_json = json.dumps({'delStatus': 0, 'error_message': str(msg)}) return HttpResponse(final_json) def remoteBackups(request): try: userID = request.session['userID'] admin = Administrator.objects.get(pk=userID) if admin.type == 3: return HttpResponse("You don't have enough priviliges to access this page.") return render(request,'backup/remoteBackups.html') except KeyError: return redirect(loadLoginPage) def submitRemoteBackups(request): try: if request.method == 'POST': data = json.loads(request.body) ipAddress = data['ipAddress'] password = data['password'] sshkey = rBackup.remoteBackup.getKey(ipAddress, password) if sshkey[0] == 1: pass else: final_json = json.dumps({'status': 0, 'error_message': sshkey[1]}) return HttpResponse(final_json) sshkey = sshkey[1] pathToSSH = "/root/.ssh/authorized_keys" if not os.path.exists("/root/.ssh"): os.makedirs("/root/.ssh") if not os.path.exists(pathToSSH): f = open(pathToSSH,"w") f.close() else: if not os.path.exists(pathToSSH): f = open(pathToSSH,"w") f.close() presenseCheck = 0 data = open(pathToSSH,"r").readlines() for items in data: if items.find(sshkey)>-1: presenseCheck = 1 if presenseCheck == 0: writeToFile = open(pathToSSH, 'a') writeToFile.writelines("#Added by CyberPanel\n") writeToFile.writelines("\n") writeToFile.writelines(sshkey) writeToFile.writelines("\n") writeToFile.close() #ownIP = requests.get('https://api.ipify.org').text finalData = json.dumps({'username': "admin","password": password}) url = "https://" + ipAddress + ":8090/api/fetchAccountsFromRemoteServer" r = requests.post(url, data=finalData, verify=False) data = json.loads(r.text) if data['fetchStatus'] == 1: json_data = data['data'] data_ret = {'status': 1, 'error_message': "None", "dir": "Null",'data':json_data} data_ret = json.dumps(data_ret) return HttpResponse(data_ret) else: data_ret = {'status': 0, 'error_message': "Not able to fetch accounts from remote server. Error Message: "+data['error_message'], "dir": "Null"} data_ret = json.dumps(data_ret) return HttpResponse(data_ret) else: return HttpResponse("This URL only accepts POST requests") except BaseException, msg: final_json = json.dumps({'status': 0, 'type':'exception', 'error_message': str(msg)}) return HttpResponse(final_json) def starRemoteTransfer(request): try: val = request.session['userID'] try: if request.method == 'POST': data = json.loads(request.body) ipAddress = data['ipAddress'] password = data['password'] accountsToTransfer = data['accountsToTransfer'] ownIP = requests.get('https://api.ipify.org').text finalData = json.dumps({'username': "admin", "password": password,"ipAddress": ownIP,"accountsToTransfer":accountsToTransfer}) url = "https://" + ipAddress + ":8090/api/remoteTransfer" r = requests.post(url, data=finalData, verify=False) data = json.loads(r.text) if data['transferStatus'] == 1: ## create local directory that will host backups localStoragePath = "/home/backup/transfer-" + str(data['dir']) if not os.path.exists(localStoragePath): os.makedirs(localStoragePath) final_json = json.dumps({'remoteTransferStatus': 1, 'error_message': "None","dir":data['dir']}) return HttpResponse(final_json) else: final_json = json.dumps({'remoteTransferStatus': 0, 'error_message':"Can not initiate remote transfer. Error message: "+ data['error_message']}) return HttpResponse(final_json) except BaseException,msg: final_json = json.dumps({'remoteTransferStatus': 0, 'error_message': str(msg)}) return HttpResponse(final_json) except KeyError: final_json = json.dumps({'remoteTransferStatus': 0, 'error_message': str(msg)}) return HttpResponse(final_json) def getRemoteTransferStatus(request): try: if request.method == "POST": data = json.loads(request.body) ipAddress = data['ipAddress'] password = data['password'] dir = data['dir'] username = "admin" finalData = json.dumps({'dir': dir, "username":username,"password":password}) r = requests.post("https://"+ipAddress+":8090/api/FetchRemoteTransferStatus", data=finalData,verify=False) data = json.loads(r.text) if data['fetchStatus'] == 1: if data['status'].find("Backups are successfully generated and received on") > -1: data = {'remoteTransferStatus': 1, 'error_message': "None", "status": data['status'],'backupsSent': 1} json_data = json.dumps(data) return HttpResponse(json_data) else: data = {'remoteTransferStatus': 1, 'error_message': "None", "status": data['status'], 'backupsSent': 0} json_data = json.dumps(data) return HttpResponse(json_data) else: data = {'remoteTransferStatus': 0, 'error_message': data['error_message'], 'backupsSent': 0} json_data = json.dumps(data) return HttpResponse(json_data) except BaseException, msg: data = {'remoteTransferStatus': 0, 'error_message': str(msg),'backupsSent': 0} json_data = json.dumps(data) return HttpResponse(json_data) def remoteBackupRestore(request): try: val = request.session['userID'] try: if request.method == "POST": data = json.loads(request.body) backupDir = data['backupDir'] backupDirComplete = "/home/backup/transfer-"+str(backupDir) #adminEmail = admin.email restoreRequest = rBackup.remoteBackup.remoteRestore(backupDirComplete,str(backupDir)) if restoreRequest[0] == 1: data = {'remoteRestoreStatus': 1, 'error_message': 'None'} json_data = json.dumps(data) return HttpResponse(json_data) else: data = {'remoteRestoreStatus': 0, 'error_message': restoreRequest[1]} json_data = json.dumps(data) return HttpResponse(json_data) except BaseException, msg: data = {'remoteRestoreStatus': 0, 'error_message': str(msg)} json_data = json.dumps(data) return HttpResponse(json_data) except KeyError: data_ret = {'remoteRestoreStatus': 0, 'error_message': "not logged in as admin", "existsStatus": 0} json_data = json.dumps(data_ret) return HttpResponse(json_data) def localRestoreStatus(request): try: if request.method == "POST": data = json.loads(request.body) backupDir = data['backupDir'] #admin = Administrator.objects.get(userName=username) backupLogPath = "/home/backup/transfer-"+ backupDir +"/" + "backup_log" removalPath = "/home/backup/transfer-"+ str(backupDir) if os.path.isfile(backupLogPath): statusFile = open(backupLogPath,"r") status = statusFile.read() statusFile.close() if status.find("completed[success]")>-1: rmtree(removalPath) data_ret = {'remoteTransferStatus': 1, 'error_message': "None", "status": status, "complete": 1} json_data = json.dumps(data_ret) return HttpResponse(json_data) else: data_ret = {'remoteTransferStatus': 1, 'error_message': "None", "status": status, "complete": 0} json_data = json.dumps(data_ret) return HttpResponse(json_data) else: data_ret = {'remoteTransferStatus': 0, 'error_message': "No such log found","status":"None","complete":0} json_data = json.dumps(data_ret) return HttpResponse(json_data) except BaseException, msg: data = {'remoteTransferStatus': 0,'error_message': str(msg),"status":"None","complete":0} json_data = json.dumps(data) return HttpResponse(json_data) def cancelRemoteBackup(request): try: if request.method == "POST": data = json.loads(request.body) ipAddress = data['ipAddress'] password = data['password'] dir = data['dir'] username = "admin" finalData = json.dumps({'dir': dir, "username":username,"password":password}) r = requests.post("https://"+ipAddress+":8090/api/cancelRemoteTransfer", data=finalData,verify=False) data = json.loads(r.text) if data['cancelStatus'] == 1: pass else: logging.CyberCPLogFileWriter.writeToFile("Some error cancelling at remote server, see the log file for remote server.") path = "/home/backup/transfer-" + str(dir) if os.path.exists(path): try: pathpid = path + "/pid" pid = open(pathpid, "r").readlines()[0] try: os.kill(int(pid), signal.SIGKILL) except BaseException, msg: logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [cancelRemoteBackup]") rmtree(path) except: rmtree(path) data = {'cancelStatus': 1, 'error_message': "None"} json_data = json.dumps(data) return HttpResponse(json_data) else: data = {'cancelStatus': 1, 'error_message': "None"} json_data = json.dumps(data) return HttpResponse(json_data) except BaseException, msg: data = {'cancelStatus': 0, 'error_message': str(msg)} json_data = json.dumps(data) return HttpResponse(json_data)