mirror of
https://github.com/usmannasir/cyberpanel.git
synced 2025-11-08 06:16:08 +01:00
bug fix: add check to see if backup process killed
This commit is contained in:
@@ -454,14 +454,14 @@ class InstallCyberPanel:
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
try:
|
# try:
|
||||||
f = open('/etc/resolv.conf', 'a')
|
# f = open('/etc/resolv.conf', 'a')
|
||||||
f.write('nameserver 8.8.8.8')
|
# f.write('nameserver 8.8.8.8')
|
||||||
f.close()
|
# f.close()
|
||||||
except IOError as e:
|
# except IOError as e:
|
||||||
InstallCyberPanel.stdOut("[ERROR] Unable to create /etc/resolv.conf: " + str(e) +
|
# InstallCyberPanel.stdOut("[ERROR] Unable to create /etc/resolv.conf: " + str(e) +
|
||||||
". This may need to be fixed manually as 'echo \"nameserver 8.8.8.8\"> "
|
# ". This may need to be fixed manually as 'echo \"nameserver 8.8.8.8\"> "
|
||||||
"/etc/resolv.conf'", 1, 1, os.EX_OSERR)
|
# "/etc/resolv.conf'", 1, 1, os.EX_OSERR)
|
||||||
|
|
||||||
if self.distro == centos:
|
if self.distro == centos:
|
||||||
command = 'yum -y install epel-release'
|
command = 'yum -y install epel-release'
|
||||||
|
|||||||
@@ -52,8 +52,12 @@ class backupSchedule:
|
|||||||
tempStoragePath = data['tempStorage']
|
tempStoragePath = data['tempStorage']
|
||||||
|
|
||||||
backupSchedule.remoteBackupLogging(backupLogPath, "Waiting for backup to complete.. ")
|
backupSchedule.remoteBackupLogging(backupLogPath, "Waiting for backup to complete.. ")
|
||||||
|
time.sleep(5)
|
||||||
|
schedulerPath = '/home/cyberpanel/%s-backup.txt' % (virtualHost)
|
||||||
|
|
||||||
while (1):
|
while (1):
|
||||||
|
diff = datetime.now() - startingTime
|
||||||
|
|
||||||
backupDomain = virtualHost
|
backupDomain = virtualHost
|
||||||
status = os.path.join("/home", backupDomain, "backup/status")
|
status = os.path.join("/home", backupDomain, "backup/status")
|
||||||
backupFileNamePath = os.path.join("/home", backupDomain, "backup/backupFileName")
|
backupFileNamePath = os.path.join("/home", backupDomain, "backup/backupFileName")
|
||||||
@@ -117,6 +121,14 @@ class backupSchedule:
|
|||||||
except:
|
except:
|
||||||
pass
|
pass
|
||||||
return 0, tempStoragePath
|
return 0, tempStoragePath
|
||||||
|
elif os.path.exists(schedulerPath):
|
||||||
|
os.remove(schedulerPath)
|
||||||
|
return 0, 'Backup process killed without reporting any error.'
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
except BaseException, msg:
|
except BaseException, msg:
|
||||||
logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [119:startBackup]")
|
logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [119:startBackup]")
|
||||||
return 0, str(msg)
|
return 0, str(msg)
|
||||||
|
|||||||
@@ -24,6 +24,7 @@ class backupScheduleLocal:
|
|||||||
|
|
||||||
for virtualHost in os.listdir("/home"):
|
for virtualHost in os.listdir("/home"):
|
||||||
if match(r'([\da-z\.-]+\.[a-z\.]{2,12}|[\d\.]+)([\/:?=&#]{1}[\da-z\.-]+)*[\/\?]?', virtualHost, M | I):
|
if match(r'([\da-z\.-]+\.[a-z\.]{2,12}|[\d\.]+)([\/:?=&#]{1}[\da-z\.-]+)*[\/\?]?', virtualHost, M | I):
|
||||||
|
try:
|
||||||
retValues = backupSchedule.createLocalBackup(virtualHost, backupLogPath)
|
retValues = backupSchedule.createLocalBackup(virtualHost, backupLogPath)
|
||||||
|
|
||||||
if os.path.exists(backupScheduleLocal.localBackupPath):
|
if os.path.exists(backupScheduleLocal.localBackupPath):
|
||||||
@@ -35,6 +36,10 @@ class backupScheduleLocal:
|
|||||||
|
|
||||||
command = 'mv %s %s' % (backupPath, localBackupPath)
|
command = 'mv %s %s' % (backupPath, localBackupPath)
|
||||||
ProcessUtilities.normalExecutioner(command)
|
ProcessUtilities.normalExecutioner(command)
|
||||||
|
except BaseException, msg:
|
||||||
|
backupSchedule.remoteBackupLogging(backupLogPath,
|
||||||
|
'[ERROR] Backup failed for %s, error: %s moving on..' % (virtualHost, str(msg)))
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -263,6 +263,10 @@ class backupUtilities:
|
|||||||
##### Writing the name of backup file.
|
##### Writing the name of backup file.
|
||||||
|
|
||||||
## /home/example.com/backup/backupFileName
|
## /home/example.com/backup/backupFileName
|
||||||
|
pidFile = '%sstartBackup' % (backupPath)
|
||||||
|
writeToFile = open(pidFile, 'w')
|
||||||
|
writeToFile.writelines(str(os.getpid()))
|
||||||
|
writeToFile.close()
|
||||||
|
|
||||||
backupFileNamePath = os.path.join(backupPath,"backupFileName")
|
backupFileNamePath = os.path.join(backupPath,"backupFileName")
|
||||||
logging.CyberCPLogFileWriter.statusWriter(backupFileNamePath, backupName)
|
logging.CyberCPLogFileWriter.statusWriter(backupFileNamePath, backupName)
|
||||||
@@ -321,9 +325,17 @@ class backupUtilities:
|
|||||||
logging.CyberCPLogFileWriter.statusWriter(status, "Aborted, "+ str(msg) + ".[365] [5009]")
|
logging.CyberCPLogFileWriter.statusWriter(status, "Aborted, "+ str(msg) + ".[365] [5009]")
|
||||||
print ("Aborted, "+ str(msg) + ".[365] [5009]")
|
print ("Aborted, "+ str(msg) + ".[365] [5009]")
|
||||||
|
|
||||||
|
os.remove(pidFile)
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def BackupRoot(tempStoragePath, backupName, backupPath, metaPath=None):
|
def BackupRoot(tempStoragePath, backupName, backupPath, metaPath=None):
|
||||||
|
|
||||||
|
pidFile = '%sBackupRoot' % (backupPath)
|
||||||
|
|
||||||
|
writeToFile = open(pidFile, 'w')
|
||||||
|
writeToFile.writelines(str(os.getpid()))
|
||||||
|
writeToFile.close()
|
||||||
|
|
||||||
status = os.path.join(backupPath, 'status')
|
status = os.path.join(backupPath, 'status')
|
||||||
metaPathInBackup = os.path.join(tempStoragePath, 'meta.xml')
|
metaPathInBackup = os.path.join(tempStoragePath, 'meta.xml')
|
||||||
backupMetaData = ElementTree.parse(metaPathInBackup)
|
backupMetaData = ElementTree.parse(metaPathInBackup)
|
||||||
@@ -422,6 +434,7 @@ class backupUtilities:
|
|||||||
items.save()
|
items.save()
|
||||||
|
|
||||||
logging.CyberCPLogFileWriter.statusWriter(status, "Completed\n")
|
logging.CyberCPLogFileWriter.statusWriter(status, "Completed\n")
|
||||||
|
os.remove(pidFile)
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def initiateBackup(tempStoragePath,backupName,backupPath):
|
def initiateBackup(tempStoragePath,backupName,backupPath):
|
||||||
@@ -1056,16 +1069,24 @@ def submitBackupCreation(tempStoragePath, backupName, backupPath, backupDomain):
|
|||||||
|
|
||||||
##
|
##
|
||||||
|
|
||||||
|
schedulerPath = '/home/cyberpanel/%s-backup.txt' % (backupDomain)
|
||||||
|
|
||||||
if not os.path.exists(backupPath) or not os.path.islink(backupPath):
|
if not os.path.exists(backupPath) or not os.path.islink(backupPath):
|
||||||
command = 'mkdir -p %s' % (backupPath)
|
command = 'mkdir -p %s' % (backupPath)
|
||||||
ProcessUtilities.executioner(command)
|
ProcessUtilities.executioner(command)
|
||||||
else:
|
else:
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
if not os.path.exists(backupPath) or not os.path.islink(backupPath):
|
if not os.path.exists(backupPath) or not os.path.islink(backupPath):
|
||||||
command = 'chown -R %s:%s %s' % (website.externalApp, website.externalApp, backupPath)
|
command = 'chown -R %s:%s %s' % (website.externalApp, website.externalApp, backupPath)
|
||||||
ProcessUtilities.executioner(command)
|
ProcessUtilities.executioner(command)
|
||||||
else:
|
else:
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
##
|
##
|
||||||
@@ -1074,12 +1095,18 @@ def submitBackupCreation(tempStoragePath, backupName, backupPath, backupDomain):
|
|||||||
command = 'mkdir -p %s' % (tempStoragePath)
|
command = 'mkdir -p %s' % (tempStoragePath)
|
||||||
ProcessUtilities.executioner(command)
|
ProcessUtilities.executioner(command)
|
||||||
else:
|
else:
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
if not os.path.exists(tempStoragePath) or not os.path.islink(tempStoragePath):
|
if not os.path.exists(tempStoragePath) or not os.path.islink(tempStoragePath):
|
||||||
command = 'chown -R %s:%s %s' % (website.externalApp, website.externalApp, tempStoragePath)
|
command = 'chown -R %s:%s %s' % (website.externalApp, website.externalApp, tempStoragePath)
|
||||||
ProcessUtilities.executioner(command)
|
ProcessUtilities.executioner(command)
|
||||||
else:
|
else:
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
##
|
##
|
||||||
@@ -1087,12 +1114,18 @@ def submitBackupCreation(tempStoragePath, backupName, backupPath, backupDomain):
|
|||||||
command = 'touch %s' % (status)
|
command = 'touch %s' % (status)
|
||||||
ProcessUtilities.executioner(command)
|
ProcessUtilities.executioner(command)
|
||||||
else:
|
else:
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
if not os.path.exists(status) or not os.path.islink(status):
|
if not os.path.exists(status) or not os.path.islink(status):
|
||||||
command = 'chown cyberpanel:cyberpanel %s' % (status)
|
command = 'chown cyberpanel:cyberpanel %s' % (status)
|
||||||
ProcessUtilities.executioner(command)
|
ProcessUtilities.executioner(command)
|
||||||
else:
|
else:
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
|
|
||||||
@@ -1100,6 +1133,9 @@ def submitBackupCreation(tempStoragePath, backupName, backupPath, backupDomain):
|
|||||||
|
|
||||||
|
|
||||||
if result[0] == 0:
|
if result[0] == 0:
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
logging.CyberCPLogFileWriter.statusWriter(status, str(result[1]) + ' [1084][5009]')
|
logging.CyberCPLogFileWriter.statusWriter(status, str(result[1]) + ' [1084][5009]')
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
@@ -1113,6 +1149,9 @@ def submitBackupCreation(tempStoragePath, backupName, backupPath, backupDomain):
|
|||||||
output = ProcessUtilities.outputExecutioner(execPath, website.externalApp)
|
output = ProcessUtilities.outputExecutioner(execPath, website.externalApp)
|
||||||
if output.find('[5009') > -1:
|
if output.find('[5009') > -1:
|
||||||
logging.CyberCPLogFileWriter.writeToFile(output)
|
logging.CyberCPLogFileWriter.writeToFile(output)
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
## Backing up databases
|
## Backing up databases
|
||||||
@@ -1126,6 +1165,9 @@ def submitBackupCreation(tempStoragePath, backupName, backupPath, backupDomain):
|
|||||||
dbName = database.find('dbName').text
|
dbName = database.find('dbName').text
|
||||||
|
|
||||||
if mysqlUtilities.mysqlUtilities.createDatabaseBackup(dbName, '/home/cyberpanel') == 0:
|
if mysqlUtilities.mysqlUtilities.createDatabaseBackup(dbName, '/home/cyberpanel') == 0:
|
||||||
|
writeToFile = open(schedulerPath, 'w')
|
||||||
|
writeToFile.writelines('error')
|
||||||
|
writeToFile.close()
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
command = 'mv /home/cyberpanel/%s.sql %s/%s.sql' % (dbName, tempStoragePath, dbName)
|
command = 'mv /home/cyberpanel/%s.sql %s/%s.sql' % (dbName, tempStoragePath, dbName)
|
||||||
@@ -1134,6 +1176,7 @@ def submitBackupCreation(tempStoragePath, backupName, backupPath, backupDomain):
|
|||||||
##
|
##
|
||||||
|
|
||||||
output = ProcessUtilities.outputExecutioner(execPath, website.externalApp)
|
output = ProcessUtilities.outputExecutioner(execPath, website.externalApp)
|
||||||
|
|
||||||
if output.find('1,None') > -1:
|
if output.find('1,None') > -1:
|
||||||
execPath = "sudo nice -n 10 /usr/local/CyberCP/bin/python2 " + virtualHostUtilities.cyberPanel + "/plogical/backupUtilities.py"
|
execPath = "sudo nice -n 10 /usr/local/CyberCP/bin/python2 " + virtualHostUtilities.cyberPanel + "/plogical/backupUtilities.py"
|
||||||
execPath = execPath + " BackupRoot --tempStoragePath " + tempStoragePath + " --backupName " \
|
execPath = execPath + " BackupRoot --tempStoragePath " + tempStoragePath + " --backupName " \
|
||||||
|
|||||||
Reference in New Issue
Block a user