Gecko [ aodai.devttt.com ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
.my.cnf.4370	0 B	-rw-r--r--
.mysql.4370	0 B	-rw-r--r--
Backupsv2.py	59.03 KB	-rw-r--r--
ClusterManager.py	17.68 KB	-rw-r--r--
CyberCPLogFileWriter.py	4.37 KB	-rw-r--r--
CyberPanelUpgrade.py	3.64 KB	-rw-r--r--
DockerSites.py	61.86 KB	-rw-r--r--
IncScheduler.py	88.07 KB	-rw-r--r--
SwitchOldAliasToNew.py	2.4 KB	-rw-r--r--
__init__.py	0 B	-rw-r--r--
acl.py	50.61 KB	-rw-r--r--
acl.py.backup_dns_fix	48.95 KB	-rw-r--r--
adminPass.py	2.41 KB	-rw-------
alias.py	647 B	-rw-r--r--
apiAccess.py	418 B	-rw-r--r--
applicationInstaller.py	352.05 KB	-rw-r--r--
backupSchedule.py	22.21 KB	-rw-r--r--
backupScheduleLocal.py	5.31 KB	-rw-r--r--
backupUtilities.py	110.15 KB	-rw-r--r--
bandwidthReset.py	7.25 KB	-rw-r--r--
cPanelImporter.py	41.33 KB	-rw-r--r--
childDomain.py	1.25 KB	-rw-r--r--
cronUtil.py	5.34 KB	-rw-r--r--
csf.py	48.63 KB	-rw-r--r--
customACME.py	51.55 KB	-rw-r--r--
dnsUtilities.py	38.7 KB	-rw-r--r--
domain.xml	0 B	-rw-r--r--
emergency_2fa_disable.py	1.24 KB	-rw-r--r--
filesPermsUtilities.py	6.17 KB	-rw-r--r--
filesPermsUtilities.py.bak	6.17 KB	-rw-r--r--
findBWUsage.py	4.6 KB	-rw-r--r--
firewallUtilities.py	8.18 KB	-rw-r--r--
ftpUtilities.py	7.56 KB	-rw-r--r--
getSystemInformation.py	5.29 KB	-rw-r--r--
hashPassword.py	1.22 KB	-rw-r--r--
httpProc.py	4.81 KB	-rw-r--r--
installUtilities.py	19.04 KB	-rw-r--r--
letsEncrypt.py	0 B	-rw-r--r--
mailUtilities.py	104.79 KB	-rw-r--r--
modSec.py	26.71 KB	-rw-r--r--
mysqlUtilities.py	41.46 KB	-rw-r--r--
phpUtilities.py	19.8 KB	-rw-r--r--
phpmyadminsignin.php	2.08 KB	-rw-r--r--
pluginManagerGlobal.py	813 B	-rw-r--r--
processUtilities.py	22.42 KB	-rw-r--r--
randomPassword.py	200 B	-rw-r--r--
rebuildQuotas.py	3.29 KB	-rw-r--r--
remoteBackup.py	14.81 KB	-rw-r--r--
remoteTransferUtilities.py	16.43 KB	-rw-r--r--
renew.py	5.64 KB	-rwxr-xr-x
restoreMeta.py	7.65 KB	-rw-r--r--
serverLogs.py	735 B	-rw-r--r--
sslUtilities.py	49.26 KB	-rw-r--r--
sslv2.py	26.18 KB	-rw-r--r--
test.py	0 B	-rw-r--r--
test1.py	0 B	-rw-r--r--
tuning.py	18.08 KB	-rw-r--r--
upgrade.py	213.62 KB	-rw-r--r--
upgrade.py.bak	97.03 KB	-rw-r--r--
upgradeCritical.py	1.15 KB	-rwx------
vhost.py	47 KB	-rw-r--r--
vhostConfs.py	14.41 KB	-rw-r--r--
virtualHostUtilities.py	92.31 KB	-rw-r--r--

Code Editor : cPanelImporter.py

#!/usr/local/CyberCP/bin/python
import os.path
import sys
import django
sys.path.append('/usr/local/CyberCP')
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "CyberCP.settings")
django.setup()
import argparse
from plogical.processUtilities import ProcessUtilities
from random import randint
from plogical.CyberCPLogFileWriter import CyberCPLogFileWriter as logging
import re
import shutil
from dns.models import Domains, Records
from manageServices.models import PDNSStatus
from loginSystem.models import Administrator
from plogical.dnsUtilities import DNS
import MySQLdb as mysql
import MySQLdb.cursors as cursors
import shlex
import subprocess
from databases.models import Databases
from websiteFunctions.models import Websites, ChildDomains as CDomains
from plogical.vhost import vhost
from plogical.virtualHostUtilities import virtualHostUtilities
from plogical.mailUtilities import mailUtilities
from mailServer.models import EUsers
import time

class ChildDomains:

def __init__(self, domain, addon):
        self.domain = domain
        self.addon = addon

class cPanelImporter:
    MailDir = 1
    MdBox = 0
    mainBackupPath = '/home/backup/'

def __init__(self, backupFile, logFile):
        self.backupFile = backupFile
        self.fileName = backupFile.split('/')[-1].replace('.tar.gz', '')
        self.logFile = logFile
        self.PHPVersion = ''
        self.email = ''
        self.mainDomain = ''
        self.homeDir = ''
        self.documentRoot = ''
        self.mailFormat = 1
        self.externalApp = ''

## New

self.MainSite = []
        self.OtherDomains = []
        self.OtherDomainNames = []
        self.InheritPHP = ''

def LoadDomains(self):
        try:
            ###
            CompletPathToExtractedArchive = cPanelImporter.mainBackupPath + self.fileName
            ### Find Domain Name
            import json
            UserData = json.loads(open('%s/userdata/cache.json' % (CompletPathToExtractedArchive), 'r').read())

for key, value in UserData.items():
                if value[2] == 'main':
                    self.MainSite = value
                    self.PHPVersion = value[9]
                    self.InheritPHP = self.PHPDecider(None)

if os.path.exists(ProcessUtilities.debugPath):
                        print(f'Main domain: {self.MainSite}, MainSite php version or version to be used for sites with no PHP {self.InheritPHP}')

else:
                    self.OtherDomainNames.append(key)
                    self.OtherDomains.append(value)

if os.path.exists(ProcessUtilities.debugPath):
                        print(f'Other domains: {key}, Value {str(value)}')

except BaseException as msg:
            print(str(msg))

def PHPDecider(self, domainName):

if self.PHPVersion == 'inherit' or not self.PHPVersion:
            self.PHPVersion = self.InheritPHP or 'PHP 7.4'
        else:
            version_number = ''.join(filter(str.isdigit, self.PHPVersion))
            if len(version_number) == 2:  # Ensure there are exactly two digits
                self.PHPVersion = f'PHP {version_number[0]}.{version_number[1]}'

### if the PHP Version extracted from file is not available then change it to next available

try:

from plogical.phpUtilities import phpUtilities

if domainName !=None:
                    completePathToConfigFile = f'/usr/local/lsws/conf/vhosts/{domainName}/vhost.conf'
                else:
                    completePathToConfigFile = None

phpVersion = phpUtilities.FindIfSaidPHPIsAvaiableOtherwiseMaketheNextOneAvailableToUse(completePathToConfigFile, self.PHPVersion)

if phpVersion != self.PHPVersion:
                    logging.statusWriter(self.logFile, f'PHP version for {self.mainDomain} has been changed from {self.PHPVersion} to {phpVersion}.', 1)
                    self.PHPVersion = phpVersion
            except:
                pass

return self.PHPVersion

def SetupSSL(self, path, domain):

data = open(path, 'r').readlines()

Key = []
        Cert = []

KeyCheck = 1
        CertCheck = 0

for items in data:
            if KeyCheck == 1 and items.find('-----END RSA PRIVATE KEY-----') > -1:
                KeyCheck = 0
                CertCheck = 1
                Key.append(items)
                continue
            else:
                Key.append(items)

if CertCheck == 1:
                Cert.append(items)

KeyPath = '/home/cyberpanel/%s' % (str(randint(1000, 9999)))

writeToFile = open(KeyPath, 'w')

for items in Key:
            writeToFile.writelines(items)

writeToFile.close()

CertPath = '/home/cyberpanel/%s' % (str(randint(1000, 9999)))

writeToFile = open(CertPath, 'w')

for items in Cert:
            writeToFile.writelines(items)

writeToFile.close()

virtualHostUtilities.saveSSL(domain, KeyPath, CertPath)

def ExtractBackup(self):
        try:

message = 'Extracting main cPanel archive file: %s' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

if not os.path.exists(cPanelImporter.mainBackupPath):
                os.mkdir(cPanelImporter.mainBackupPath)

os.chdir(cPanelImporter.mainBackupPath)

command = 'tar -xf %s --directory %s' % (self.backupFile, cPanelImporter.mainBackupPath)
            ProcessUtilities.normalExecutioner(command)

message = '%s successfully extracted.' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

return 1

except BaseException as msg:
            message = 'Failed to extract backup for file %s, error message: %s. [ExtractBackup]' % (
            self.backupFile, str(msg))
            logging.statusWriter(self.logFile, message, 1)
            return 0

def CreateMainWebsite(self):
        try:

message = 'Creating main account from archive file: %s' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

## Paths

DomainName = self.MainSite[3]
            self.mainDomain = DomainName
            CompletPathToExtractedArchive = cPanelImporter.mainBackupPath + self.fileName
            DomainMeta = '%s/userdata/%s' % (CompletPathToExtractedArchive, DomainName)

### Find Domain Name

message = 'Detected main domain for this file is: %s.' % (DomainName)
            logging.statusWriter(self.logFile, message, 1)

## Find PHP Version

message = 'Finding PHP version for %s.' % (DomainName)
            logging.statusWriter(self.logFile, message, 1)

self.PHPVersion = self.MainSite[9]
            self.PHPDecider(None)

message = 'PHP version of %s is %s.' % (DomainName, self.PHPVersion)
            logging.statusWriter(self.logFile, message, 1)

## Find Email

message = 'Finding Server Admin email for %s.' % (DomainName)
            logging.statusWriter(self.logFile, message, 1)

data = open(DomainMeta, 'r').readlines()

for items in data:
                if items.find('serveradmin') > -1:
                    self.email = items.split(' ')[-1].replace('\n', '')
                    break

message = 'Server Admin email for %s is %s.' % (DomainName, self.email)
            logging.statusWriter(self.logFile, message, 1)

## Create Site

message = 'Calling core to create %s.' % (DomainName)
            logging.statusWriter(self.logFile, message, 1)

self.externalApp = "".join(re.findall("[a-zA-Z]+", DomainName))[:7]

try:
                counter = 0
                while True:
                    tWeb = Websites.objects.get(externalApp=self.externalApp)
                    self.externalApp = '%s%s' % (tWeb.externalApp, str(counter))
                    counter = counter + 1
                    print(self.externalApp)
            except BaseException as msg:
                logging.statusWriter(self.logFile, str(msg), 1)
                time.sleep(2)

result = virtualHostUtilities.createVirtualHost(DomainName, self.email, self.PHPVersion, self.externalApp, 1, 0,
                                                            0, 'admin', 'Default', 0)

if result[0] == 1:
                pass
            else:
                message = f'Failed to create main site %s from archive file: %s. Error {str(result)}' % (DomainName, self.backupFile)
                logging.statusWriter(self.logFile, message, 1)
                return 0

message = 'Successfully created %s from core.' % (DomainName)
            logging.statusWriter(self.logFile, message, 1)

### Let see if there is SSL

message = 'Detecting SSL for %s.' % (DomainName)
            logging.statusWriter(self.logFile, message, 1)

SSLPath = '%s/apache_tls/%s' % (CompletPathToExtractedArchive, DomainName)

if os.path.exists(SSLPath):
                message = 'SSL found for %s, setting up.' % (DomainName)
                logging.statusWriter(self.logFile, message, 1)
                self.SetupSSL(SSLPath, DomainName)
                message = 'SSL set up OK for %s.' % (DomainName)
                logging.statusWriter(self.logFile, message, 1)
            else:
                message = 'SSL not detected for %s, you can later issue SSL from Manage SSL in CyberPanel.' % (DomainName)
                logging.statusWriter(self.logFile, message, 1)

## Document root

message = 'Restoring document root files for %s.' % (DomainName)
            logging.statusWriter(self.logFile, message, 1)

message = 'self.MainSite[4] %s.' % (self.MainSite[4])
            logging.statusWriter(self.logFile, message, 1)

message = 'self.MainSite[0] %s.' % (self.MainSite[0])
            logging.statusWriter(self.logFile, message, 1)

if self.MainSite[4].find('home/') > -1:
                self.homeDir = self.MainSite[4].replace('/home/%s/' % (self.MainSite[0]), '')
            else:
                self.homeDir = self.MainSite[4].replace('/home2/%s/' % (self.MainSite[0]), '')

message = 'self.homeDir %s.' % (self.homeDir)
            logging.statusWriter(self.logFile, message, 1)

nowPath = '/home/%s/public_html' % (DomainName)
            if os.path.exists(nowPath):
                shutil.rmtree(nowPath)

movePath = '%s/homedir/%s' % (
            CompletPathToExtractedArchive, self.homeDir)

if os.path.exists(ProcessUtilities.debugPath):
                logging.statusWriter(self.logFile, f'Directory from where docRoot of main site data will be moved {movePath}')

shutil.copytree(movePath, nowPath, symlinks=True)

message = 'Main site %s created from archive file: %s' % (DomainName, self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

return 1

except BaseException as msg:
            message = 'Failed to create main website from backup file %s, error message: %s.' % (
            self.backupFile, str(msg))
            logging.statusWriter(self.logFile, message, 1)
            return 0

def CreateChildDomains(self):
        try:

message = 'Creating child domains from archive file: %s' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

CompletPathToExtractedArchive = cPanelImporter.mainBackupPath + self.fileName

### Find Possible Child Domains

message = 'Finding Addon/Subdomains from backup file %s. Account main domain was %s.' % (self.backupFile, self.mainDomain)
            logging.statusWriter(self.logFile, message, 1)

message = 'Following Addon/Subdomains found for backup file %s. Account main domain was %s.' % (
            self.backupFile, self.mainDomain)
            logging.statusWriter(self.logFile, message, 1)

for items in self.OtherDomainNames:
                print(items)

## Starting Child-domains creation

message = 'Starting Addon/Subdomains creation from backup file %s. Account main domain was %s.' % (
                self.backupFile, self.mainDomain)
            logging.statusWriter(self.logFile, message, 1)

counter = 0

for items in self.OtherDomainNames:

try:

message = 'Creating %s.' % (items)
                    logging.statusWriter(self.logFile, message, 1)

path = '/home/' + self.mainDomain + '/' + items

## Find PHP Version

self.PHPVersion = self.OtherDomains[counter][9]
                    self.PHPDecider(None)

message = 'Calling core to create %s.' % (items)
                    logging.statusWriter(self.logFile, message, 1)

result = virtualHostUtilities.createDomain(self.mainDomain, items, self.PHPVersion, path, 1, 0,
                                                               0, 'admin', 0)

if result[0] == 1:
                        message = 'Child domain %s created from archive file: %s' % (items, self.backupFile)
                        logging.statusWriter(self.logFile, message, 1)
                    else:
                        message = 'Failed to create Child domain %s from archive file: %s' % (items, self.backupFile)
                        logging.statusWriter(self.logFile, message, 1)

## Setup SSL

message = 'Detecting SSL for %s.' % (items)
                    logging.statusWriter(self.logFile, message, 1)

SSLPath = '%s/apache_tls/%s' % (CompletPathToExtractedArchive, items)

if os.path.exists(SSLPath):
                        message = 'SSL found for %s, setting up.' % (items)
                        logging.statusWriter(self.logFile, message, 1)
                        self.SetupSSL(SSLPath, items)
                        message = 'SSL set up OK for %s.' % (items)
                        logging.statusWriter(self.logFile, message, 1)
                    else:
                        SSLPath = '%s/apache_tls/%s.%s' % (CompletPathToExtractedArchive, items, self.mainDomain)
                        if os.path.exists(SSLPath):
                            message = 'SSL found for %s, setting up.' % (items)
                            logging.statusWriter(self.logFile, message, 1)
                            self.SetupSSL(SSLPath, items)
                            message = 'SSL set up OK for %s.' % (items)
                            logging.statusWriter(self.logFile, message, 1)
                        else:
                            message = 'SSL not detected for %s, you can later issue SSL from Manage SSL in CyberPanel.' % (
                                items)
                            logging.statusWriter(self.logFile, message, 1)

## Creating Document root for childs

message = 'Restoring document root files for %s.' % (items)
                    logging.statusWriter(self.logFile, message, 1)

message = 'self.OtherDomains[counter][4] %s.' % (self.OtherDomains[counter][4])
                    logging.statusWriter(self.logFile, message, 1)

message = 'self.MainSite[0] %s.' % (self.MainSite[0])
                    logging.statusWriter(self.logFile, message, 1)

if self.OtherDomains[counter][4].find('home/') > -1:
                        ChildDocRoot = self.OtherDomains[counter][4].replace('/home/%s/' % (self.MainSite[0]), '')
                    else:
                        ChildDocRoot = self.OtherDomains[counter][4].replace('/home2/%s/' % (self.MainSite[0]), '')

#ChildDocRoot = self.OtherDomains[counter][4].replace('/home/%s/' % (self.MainSite[0]), '')

message = 'ChildDocRoot %s.' % (ChildDocRoot)
                    logging.statusWriter(self.logFile, message, 1)

if os.path.exists(path):
                        shutil.rmtree(path)

movePath = '%s/homedir/%s' % (CompletPathToExtractedArchive, ChildDocRoot)
                    logging.statusWriter(self.logFile, 'Document root in cPanel Backup for %s is %s' % (items, movePath), 1)

if os.path.exists(movePath):
                        shutil.copytree(movePath, path)

message = 'Successfully created child domain.'
                    logging.statusWriter(self.logFile, message, 1)

counter = counter + 1

except BaseException as msg:
                    message = 'Failed to create child domain from backup file %s, error message: %s. Moving on..' % (
                        self.backupFile, str(msg))
                    logging.statusWriter(self.logFile, message, 1)
                    counter = counter + 1

return 1

except BaseException as msg:
            message = 'Failed to create child domain from backup file %s, error message: %s.' % (
            self.backupFile, str(msg))
            logging.statusWriter(self.logFile, message, 1)
            return 0

def createDummyChild(self, childDomain):
        path = '/home/%s/public_html/%s' % (self.mainDomain, childDomain)
        virtualHostUtilities.createDomain(self.mainDomain, childDomain, self.PHPVersion, path, 0, 0,
                                                   0, 'admin', 0)

def CreateDNSRecords(self):
        try:

message = 'We are going to create DNS records now, please note we will not create DKIM records. Make sure to create them from CyberPanel interface using our DKIM manager.'
            logging.statusWriter(self.logFile, message, 1)

ipFile = "/etc/cyberpanel/machineIP"
            f = open(ipFile)
            ipData = f.read()
            ipAddress = ipData.split('\n', 1)[0]
            admin = Administrator.objects.get(userName='admin')

CompletPathToExtractedArchive = cPanelImporter.mainBackupPath + self.fileName
            DNSZonesPath = '%s/dnszones' % (CompletPathToExtractedArchive)

for items in os.listdir(DNSZonesPath):
                topLevelDomain = items.replace('.db', '', 1)

message = 'Creating DNS records for %s' % (topLevelDomain)
                logging.statusWriter(self.logFile, message, 1)

try:
                    Domains.objects.get(name=topLevelDomain).delete()
                except:
                    pass

try:
                    pdns = PDNSStatus.objects.get(pk=1)
                    if pdns.type == 'MASTER':
                        zone = Domains(admin=admin, name=topLevelDomain, type="MASTER")
                        zone.save()
                    else:
                        zone = Domains(admin=admin, name=topLevelDomain, type="NATIVE")
                        zone.save()
                except:
                    zone = Domains(admin=admin, name=topLevelDomain, type="NATIVE")
                    zone.save()
                    pass

content = "ns1." + topLevelDomain + " hostmaster." + topLevelDomain + " 1 10800 3600 1209600 3600"

soaRecord = Records(domainOwner=zone,
                                    domain_id=zone.id,
                                    name=topLevelDomain,
                                    type="SOA",
                                    content=content,
                                    ttl=3600,
                                    prio=0,
                                    disabled=0,
                                    auth=1)
                soaRecord.save()

CurrentZonePath = '%s/%s' % (DNSZonesPath, items)

data = open(CurrentZonePath, 'r').readlines()

SOACheck = 0
                start = 0

for items in data:
                    try:
                        if items.find('SOA') > -1:
                            SOACheck = 1
                            continue

if (SOACheck == 1 and items.find(')') > -1) or (SOACheck == 1 and items.find('NS') > -1 and items.find(zone.name) > -1):
                            SOACheck = 0
                            start = 1
                            continue
                        else:
                            pass

if start == 1:
                            if os.path.exists(ProcessUtilities.debugPath):
                                message = f'Current DNS record we are creating for {zone.name} is {items}'
                                logging.statusWriter(self.logFile, message, 1)
                            if len(items) > 3:
                                if items.find("DKIM1") > -1:
                                    continue
                                RecordsData = items.split('\t')

if RecordsData[3] == 'A':
                                    RecordsData[4] = ipAddress

if RecordsData[0].find(topLevelDomain) > -1:
                                    if RecordsData[3] == 'MX':
                                        DNS.createDNSRecord(zone, RecordsData[0].rstrip('.'), RecordsData[3],RecordsData[5].rstrip('.').rstrip('.\n'), int(RecordsData[4]), RecordsData[1])
                                    else:
                                        DNS.createDNSRecord(zone, RecordsData[0].rstrip('.'), RecordsData[3], RecordsData[4].rstrip('.').rstrip('.\n'), 0, RecordsData[1])
                                else:
                                    if RecordsData[3] == 'MX':
                                        DNS.createDNSRecord(zone, RecordsData[0] + '.' + topLevelDomain, RecordsData[3],
                                                            RecordsData[5].rstrip('.').rstrip('.\n'), RecordsData[4],
                                                            RecordsData[1])
                                    else:
                                        DNS.createDNSRecord(zone, RecordsData[0] + '.' + topLevelDomain , RecordsData[3], RecordsData[4].rstrip('.').rstrip('.\n'), 0,
                                                            RecordsData[1])
                    except BaseException as msg:
                        message = 'Failed while creating DNS entry for %s, error message: %s.' % (topLevelDomain, str(msg))
                        logging.statusWriter(self.logFile, message, 1)

message = 'DNS records successfully created for %s.' % (topLevelDomain)
                logging.statusWriter(self.logFile, message, 1)

return 1

except BaseException as msg:
            message = 'Failed to create DNS records from file %s, error message: %s.' % (
            self.backupFile, str(msg))
            logging.statusWriter(self.logFile, message, 1)
            return 0

def setupConnection(self, db=None):
        try:
            passFile = "/etc/cyberpanel/mysqlPassword"

f = open(passFile)
            data = f.read()
            password = data.split('\n', 1)[0]
            password = password.replace('\n', '').replace('\r', '')

conn = mysql.connect(user='root', passwd=password, cursorclass=cursors.SSCursor)
            cursor = conn.cursor()

return conn, cursor

except BaseException as msg:
            message = 'Failed to connect to database, error message: %s. [ExtractBackup]' % (str(msg))
            logging.statusWriter(self.logFile, message, 1)
            return 0, 0

def RestoreDatabases(self):
        try:

message = 'Restoring databases from %s.' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

##
            passFile = "/etc/cyberpanel/mysqlPassword"

try:
                import json
                jsonData = json.loads(open(passFile, 'r').read())

mysqluser = jsonData['mysqluser']
                mysqlpassword = jsonData['mysqlpassword']
                mysqlport = jsonData['mysqlport']
                mysqlhost = jsonData['mysqlhost']
                password = mysqlpassword
            except:
                passFile = "/etc/cyberpanel/mysqlPassword"
                f = open(passFile)
                data = f.read()
                password = data.split('\n', 1)[0]
                mysqlhost = 'localhost'
                mysqlport = '3306'
                mysqluser = 'root'

cnfPath = '/home/cyberpanel/.my.cnf'

if not os.path.exists(cnfPath):
                cnfContent = """[mysqldump]
user=root
password=%s
max_allowed_packet=1024M
[mysql]
user=root
password=%s
""" % (password, password)
                writeToFile = open(cnfPath, 'w')
                writeToFile.write(cnfContent)
                writeToFile.close()

os.chmod(cnfPath, 0o600)

f = open(passFile)
            data = f.read()
            password = data.split('\n', 1)[0]
            ##

connection, cursor = self.setupConnection()

CompletPathToExtractedArchive = cPanelImporter.mainBackupPath + self.fileName

DatabasesPath = '%s/mysql' % (CompletPathToExtractedArchive)

for items in os.listdir(DatabasesPath):
                if items.find('roundcube') > -1:
                    continue
                if items.endswith('.sql'):
                    message = 'Restoring MySQL dump for %s.' % (items.replace('.sql', ''))
                    logging.statusWriter(self.logFile, message, 1)

try:
                        cursor.execute("CREATE DATABASE `%s`" % (items.replace('.sql', '')))
                    except BaseException as msg:
                        message = 'Failed while restoring database %s from backup file %s, error message: %s' % (items.replace('.sql', ''), self.backupFile, str(msg))
                        logging.statusWriter(self.logFile, message, 1)

command =  f'mysql --defaults-file=/home/cyberpanel/.my.cnf -u {mysqluser} --host={mysqlhost} --port {mysqlport} ' + items.replace('.sql', '')

message = f'Full command to restore DB {command}'
                    logging.statusWriter(self.logFile, message, 1)

cmd = shlex.split(command)

DBPath = "%s/%s" % (DatabasesPath, items)

# with open(DBPath, 'r') as f:
                    #     message = f'Full command to restore DB {cmd}'
                    #     logging.statusWriter(self.logFile, message, 1)
                    #
                    #     res = subprocess.call(cmd, stdin=f)

with open(DBPath, 'r') as f:

try:
                            # Run the command using subprocess.run, capturing stdout and stderr
                            result = subprocess.run(cmd, stdin=f, stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                                    universal_newlines=True)

# Log stdout and stderr
                            logging.statusWriter(self.logFile, f'STDOUT: {result.stdout}', 1)
                            logging.statusWriter(self.logFile, f'STDERR: {result.stderr}', 1)

# Check if the command failed
                            if result.returncode != 0:
                                logging.statusWriter(self.logFile,
                                                     f'Command failed with return code {result.returncode}', 2)
                        except Exception as e:
                            # Log any exception that occurs
                            logging.statusWriter(self.logFile, f'Exception occurred: {str(e)}', 2)

website = Websites.objects.get(domain=self.mainDomain)

## Trying to figure out dbname

CommandsPath = '%s/mysql.sql' % (CompletPathToExtractedArchive)

data = open(CommandsPath, 'r').readlines()

### temp disable if user not added, need to remove this try,catch and to ensure user gets added

try:

for inItems in data:
                            if (inItems.find('GRANT ALL PRIVILEGES') > -1 or inItems.find('GRANT USAGE') > -1) and inItems.find('localhost') > -1 and inItems.find('_test') == -1:
                                cDBName = inItems.split('`')[1].replace('\\', '')
                                logging.statusWriter(self.logFile, inItems, 1)
                                if cDBName == items.replace('.sql', ''):
                                    cDBUser = inItems.replace("`","'").replace("\\","").split("'")[1]
                                    message = 'Database user for %s is %s.' % (cDBName, cDBUser)
                                    logging.statusWriter(self.logFile, message, 1)
                                    if Databases.objects.filter(dbUser=cDBUser).count() > 0:
                                        continue
                                    break
                    except:
                        pass

### temp disable if user not added, need to remove this try,catch and to ensure user gets added

try:
                        db = Databases(website=website, dbName=items.replace('.sql', ''), dbUser=cDBUser)
                        db.save()
                    except:
                        db = Databases(website=website, dbName=items.replace('.sql', ''), dbUser='root')
                        db.save()
                        pass

message = 'MySQL dump successfully restored for %s.' % (items.replace('.sql', ''))
                    logging.statusWriter(self.logFile, message, 1)

message = 'Creating Database users from backup file %s.' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

CommandsPath = '%s/mysql.sql' % (CompletPathToExtractedArchive)

data = open(CommandsPath, 'r').readlines()

for items in data:
                if items.find("--") > -1 or items.find("'cyberpanel'@") > -1:
                    continue
                try:
                    if os.path.exists(ProcessUtilities.debugPath):
                        message = f'Currently executing MySQL command {items}'
                        logging.statusWriter(self.logFile, message, 1)
                    cursor.execute(items)
                except BaseException as msg:
                    message = 'Failed while restoring database %s from backup file %s, error message: %s' % (
                    items.replace('.sql', ''), self.backupFile, str(msg))
                    logging.statusWriter(self.logFile, message, 1)

connection.close()

message = 'Databases successfully restored.'
            logging.statusWriter(self.logFile, message, 1)

return 1

except BaseException as msg:
            message = 'Failed to restore databases from file %s, error message: %s.' % (
            self.backupFile, str(msg))
            logging.statusWriter(self.logFile, message, 1)
            return 0

def FixPermissions(self):
        from filemanager.filemanager import FileManager
        fm = FileManager(None, None)
        fm.fixPermissions(self.mainDomain)
        
    def createCronJobs(self):
        try:
            
            message = 'Restoring cron jobs from %s.' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)
            
            CompletPathToExtractedArchive = cPanelImporter.mainBackupPath + self.fileName            
            cronPath = '%s/cron' % (CompletPathToExtractedArchive)
            
            
            if len(os.listdir(cronPath)) == 0:
                message = 'No Cron Job file found.'
                logging.statusWriter(self.logFile, message, 1)
                return 1
            
            if ProcessUtilities.decideDistro() == ProcessUtilities.centos or ProcessUtilities.decideDistro() == ProcessUtilities.cent8:
                localCronPath = "/var/spool/cron/" + self.externalApp
            else:
                localCronPath = "/var/spool/cron/crontabs/" + self.externalApp
                
            localCronFile = open(localCronPath, "a+")
                
            commandT = 'touch %s' % (localCronPath)
            ProcessUtilities.executioner(commandT, 'root')
            commandT = 'chown %s:%s %s' % (self.externalApp, self.externalApp, localCronPath)
            ProcessUtilities.executioner(commandT, 'root')

# There's only single file usually but running for all found
            for item in os.listdir(cronPath):
                cronFile = open('%s/%s' % (cronPath, item), 'r')
                cronJobs = cronFile.readlines()
                
                # Filter actual jobs and remove variables and last new line character
                for job in cronJobs:
                    if len(job.split(' ')) > 1:
                        # Valid enough, add it to user
                        localCronFile.write(job)
                    
            message = 'Cron Jobs successfully restored.'
            logging.statusWriter(self.logFile, message, 1)

return 1
        
        except BaseException as msg:
            message = 'Failed to restore Cron Jobs from file %s, error message: %s.' % (
            self.backupFile, str(msg))
            logging.statusWriter(self.logFile, message, 1)
            return 0

def DeleteSite(self):
        vhost.deleteVirtualHostConfigurations(self.mainDomain)

def checkIfExists(self, virtualHostName):
        if Websites.objects.filter(domain=virtualHostName).count() > 0:
            return 1

if CDomains.objects.filter(domain=virtualHostName).count() > 0:
            return 1

return 0

def RestoreEmails(self):
        try:

message = 'Restoring emails from archive file: %s' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

CompletPathToExtractedArchive = cPanelImporter.mainBackupPath + self.fileName

### Find Mail Format
            UserData = '%s/homedir/mail' % (CompletPathToExtractedArchive)
            FormatPath = '%s/mailbox_format.cpanel' % (UserData)

message = 'Detecting email format from %s.' % (self.backupFile)
            logging.statusWriter(self.logFile, message, 1)

try:

Format = open(FormatPath, 'r').read()

if Format.find('mdbox') > -1:
                    self.mailFormat = cPanelImporter.MdBox
                    message = 'Mdbox format detected from %s.' % (self.backupFile)
                    logging.statusWriter(self.logFile, message, 1)
                else:
                    self.mailFormat = cPanelImporter.MailDir
                    message = 'Maildir format detected from %s.' % (self.backupFile)
                    logging.statusWriter(self.logFile, message, 1)
            except:
                self.mailFormat = cPanelImporter.MailDir

####

if os.path.exists(ProcessUtilities.debugPath):
                logging.statusWriter(self.logFile, f'Content of user data before starting to restore emails {str(UserData)}')

for items in os.listdir(UserData):

FinalMailDomainPath = '%s/%s' % (UserData, items)

if os.path.exists(ProcessUtilities.debugPath):
                    logging.statusWriter(self.logFile,
                                         f'Final email path for {items} is {str(FinalMailDomainPath)}')

if os.path.isdir(FinalMailDomainPath):
                    if items[0] == '.':
                        continue
                    if items.find('.') > -1:
                        for it in os.listdir(FinalMailDomainPath):
                            try:
                                if self.checkIfExists(items) == 0:
                                    self.createDummyChild(items)

mailUtilities.createEmailAccount(items, it, 'cyberpanel')
                                finalEmailUsername = it + "@" + items
                                message = 'Starting restore for %s.' % (finalEmailUsername)
                                logging.statusWriter(self.logFile, message, 1)
                                eUser = EUsers.objects.get(email=finalEmailUsername)

if self.mailFormat == cPanelImporter.MailDir:
                                    eUser.mail = 'maildir:/home/vmail/%s/%s/Maildir' % (items, it)
                                    MailPath = '/home/vmail/%s/%s' % (items, it)

command = 'mkdir -p %s' % (MailPath)
                                    ProcessUtilities.normalExecutioner(command)

command = 'rm -rf %s/Maildir' % (MailPath)
                                    ProcessUtilities.normalExecutioner(command)

MailPathInBackup = '%s/%s' % (FinalMailDomainPath, it)

if os.path.exists(ProcessUtilities.debugPath):
                                        logging.statusWriter(self.logFile,
                                                             f'Mail path in backup for {items} is {str(MailPathInBackup)}')

command = 'mv %s %s/Maildir' % (MailPathInBackup, MailPath)
                                    subprocess.call(command, shell=True)

else:
                                    eUser.mail = 'mdbox:/home/vmail/%s/%s/Mdbox' % (items, it)
                                    MailPath = '/home/vmail/%s/%s' % (items, it)

command = 'mkdir -p %s' % (MailPath)
                                    ProcessUtilities.normalExecutioner(command)

command = 'rm -rf %s/Mdbox' % (MailPath)
                                    ProcessUtilities.normalExecutioner(command)

MailPathInBackup = '%s/%s' % (FinalMailDomainPath, it)

command = 'mv %s %s/Mdbox' % (MailPathInBackup, MailPath)
                                    subprocess.call(command, shell=True)

## Also update password

PasswordPath = '%s/homedir/etc/%s/shadow' % (CompletPathToExtractedArchive, items)
                                PasswordData = open(PasswordPath, 'r').readlines()

for i in PasswordData:
                                    if i.find(it) > -1:
                                        finalPassword = '%s%s' % ('{CRYPT}', i.split(':')[1])
                                        eUser.password = finalPassword

eUser.save()

message = 'Restore completed for %s.' % (finalEmailUsername)
                                logging.statusWriter(self.logFile, message, 1)
                            except BaseException as msg:
                                message = 'Failed to restore emails from archive file %s, For domain: %s. error message: %s. [ExtractBackup]' % (
                                    self.backupFile, items, str(msg))
                                logging.statusWriter(self.logFile, message, 1)

command = 'chown -R vmail:vmail /home/vmail'
            ProcessUtilities.normalExecutioner(command)

message = 'Emails successfully restored'
            logging.statusWriter(self.logFile, message, 1)

return 1

except BaseException as msg:
            message = 'Failed to restore emails from archive file %s, error message: %s. [ExtractBackup]' % (
            self.backupFile, str(msg))
            logging.statusWriter(self.logFile, message, 1)
            return 0

def MainController(self):

if self.ExtractBackup():
            pass
        else:
            return

self.LoadDomains()

if self.CreateMainWebsite():
            pass
        else:
            return 0

if self.CreateChildDomains():
            pass
        else:
            return 0

if self.CreateDNSRecords():
            pass
        else:
            return 0

if self.RestoreDatabases():
            pass
        else:
            return 0

if self.createCronJobs():
            pass
        else:
            pass

self.RestoreEmails()
        self.FixPermissions()

message = 'Backup file %s successfully restored.' % (self.backupFile)
        logging.statusWriter(self.logFile, message, 1)

return 1

def main():
    LogFile = '/home/cyberpanel/%s' % (str(randint(1000, 9999)))
    message = 'Backup logs to be generated in %s' % (LogFile)
    print(message)

parser = argparse.ArgumentParser(description='CyberPanel cPanel Importer')
    parser.add_argument('--path', help='Path where cPanel .tar.gz files are stored.')

args = parser.parse_args()

for items in os.listdir(args.path):
        if items.endswith('.tar.gz'):
            finalPath = '%s/%s' % (args.path.rstrip('/'), items)
            try:
                cI = cPanelImporter(finalPath, LogFile)
                if cI.MainController():
                    pass
                else:
                    pass
            except:
                pass

if __name__ == "__main__":
    main()

${this.title}

Code Editor : cPanelImporter.py