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 : ClusterManager.py

import json
import os.path
import shlex
import subprocess
import sys
import argparse
import django
import requests
sys.path.append('/usr/local/CyberCP')
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "CyberCP.settings")
django.setup()
from firewall.models import FirewallRules
from plogical.firewallUtilities import FirewallUtilities
from plogical.processUtilities import ProcessUtilities
from plogical.CyberCPLogFileWriter import CyberCPLogFileWriter as logging
from plogical.mysqlUtilities import mysqlUtilities
class ClusterManager:

LogURL = "https://platform.cyberpersons.com/HighAvailability/RecvData"
    UptimeURL = "https://platform.cyberpersons.com/servers/UptimeReport"
    ClusterFile = '/home/cyberpanel/cluster'
    CloudConfig = '/home/cyberpanel/cloud'
    vhostConfPath = '/usr/local/lsws/conf/vhosts'

def __init__(self, type):
        ##
        ipFile = "/etc/cyberpanel/machineIP"
        f = open(ipFile)
        ipData = f.read()
        self.ipAddress = ipData.split('\n', 1)[0]
        ##
        if os.path.exists(ClusterManager.ClusterFile):
            self.config = json.loads(open(ClusterManager.ClusterFile, 'r').read())
        elif os.path.exists(ClusterManager.CloudConfig):
            self.config = json.loads(open(ClusterManager.CloudConfig, 'r').read())

self.type = type

def PostStatus(self, message):
        try:
            finalData = {'name': self.config['name'], 'type': self.type, 'message': message, 'token': self.config['token']}
            resp = requests.post(ClusterManager.LogURL, data=json.dumps(finalData))
            if os.path.exists(ProcessUtilities.debugPath):
                logging.writeToFile(resp.text + '[info]')
        except BaseException as msg:
            logging.writeToFile('%s. [31:404]' % (str(msg)))

def FetchMySQLConfigFile(self):

if ProcessUtilities.decideDistro() == ProcessUtilities.centos:
            return '/etc/my.cnf.d/cluster.cnf'
        else:
            return '/etc/mysql/conf.d/cluster.cnf'

def DetechFromCluster(self):
        try:

command = 'rm -rf %s' % (self.FetchMySQLConfigFile())
            ProcessUtilities.normalExecutioner(command)

command = 'systemctl stop mysql'
            #ProcessUtilities.normalExecutioner(command)

command = 'systemctl restart mysql'
            #ProcessUtilities.executioner(command)

self.PostStatus('Successfully detached. [200]')

except BaseException as msg:
            self.PostStatus('Failed to detach, error %s [404].' % (str(msg)))

def SetupCluster(self):
        try:

CentOSPath = '/etc/redhat-release'

if os.path.exists(CentOSPath):
                cronPath = '/var/spool/cron/root'
            else:
                cronPath = '/var/spool/cron/crontabs/root'

ClusterPath = self.FetchMySQLConfigFile()
            ClusterConfigPath = '/home/cyberpanel/cluster'
            config = json.loads(open(ClusterConfigPath, 'r').read())

if self.type == 'Child':

### If Centos then update library path for galera

ClusterConfigFailover = config['ClusterConfigFailover']

if ProcessUtilities.decideDistro() == ProcessUtilities.centos or ProcessUtilities.decideDistro() == ProcessUtilities.cent8:
                    ClusterConfigFailover = ClusterConfigFailover.replace('/usr/lib/galera/libgalera_smm.so', '/usr/lib64/galera-4/libgalera_smm.so')

writeToFile = open(ClusterPath, 'w')
                writeToFile.write(ClusterConfigFailover)
                writeToFile.close()

writeToFile = open(cronPath, 'a')
                writeToFile.write('*/5 * * * * /usr/local/CyberCP/bin/python /usr/local/CyberCP/plogical/ClusterManager.py --function CreatePendingVirtualHosts --type Child\n')
                writeToFile.close()
            else:

### If Centos then update library path for galera

ClusterConfigMaster = config['ClusterConfigMaster']

if ProcessUtilities.decideDistro() == ProcessUtilities.centos or ProcessUtilities.decideDistro() == ProcessUtilities.cent8:
                    ClusterConfigMaster = ClusterConfigMaster.replace('/usr/lib/galera/libgalera_smm.so', '/usr/lib64/galera-4/libgalera_smm.so')

writeToFile = open(ClusterPath, 'w')
                writeToFile.write(ClusterConfigMaster)
                writeToFile.close()

writeToFile = open(cronPath, 'a')
                writeToFile.write('*/%s * * * * /usr/local/CyberCP/bin/python /usr/local/CyberCP/plogical/ClusterManager.py --function SyncNow --type Master\n' % (str(self.config['syncTime'])))
                writeToFile.write('*/3 * * * * /usr/local/CyberCP/bin/python /usr/local/CyberCP/plogical/ClusterManager.py --function PingNow --type Master\n')
                writeToFile.close()

command = 'systemctl restart cron'
            ProcessUtilities.normalExecutioner(command)

try:
                ### MySQL Public

newFireWallRule = FirewallRules(name="mysqlpub", port='3306', proto="tcp")
                newFireWallRule.save()
                FirewallUtilities.addRule('tcp', '3306', "0.0.0.0/0")

### For Galera Cluster replication traffic.

newFireWallRule = FirewallRules(name="galery", port='4567', proto="tcp")
                newFireWallRule.save()
                FirewallUtilities.addRule('tcp', '4567', "0.0.0.0/0")

### For Galera Cluster IST

newFireWallRule = FirewallRules(name="galeryist", port='4568', proto="tcp")
                newFireWallRule.save()
                FirewallUtilities.addRule('tcp', '4568', "0.0.0.0/0")

### For Galera Cluster SST

newFireWallRule = FirewallRules(name="galerysst", port='4444', proto="tcp")
                newFireWallRule.save()
                FirewallUtilities.addRule('tcp', '4444', "0.0.0.0/0")

### For Galera Cluster replication traffic. (UDP)

newFireWallRule = FirewallRules(name="galeryudp", port='4567', proto="udp")
                newFireWallRule.save()
                FirewallUtilities.addRule('udp', '4567', "0.0.0.0/0")

except:
                self.PostStatus('Failed to add Firewall rules, manually open the required ports..')

## Change permissions of cluster config path

command = 'chmod 600 %s' % (ClusterConfigPath)
            ProcessUtilities.executioner(command)

self.PostStatus('Successfully attached to cluster. [200]')

###

except BaseException as msg:
            self.PostStatus('Failed to attach, error %s [404].' % (str(msg)))

def BootMaster(self):
        try:

command = 'systemctl stop mysql'
            ProcessUtilities.normalExecutioner(command)

command = 'galera_new_cluster'
            ProcessUtilities.normalExecutioner(command)

self.PostStatus('Master server successfully booted. [200]')

###

except BaseException as msg:
            self.PostStatus('Failed to boot, error %s [404].' % (str(msg)))

def BootChild(self):
        try:

ChildData = '/home/cyberpanel/childaata'
            data = json.loads(open(ChildData, 'r').read())

## CyberPanel DB Creds

## Update settings file using the data fetched from master

dbName = data['dbName']
            dbUser = data['dbUser']
            password = data['password']
            host = data['host']
            port = data['port']

## Root DB Creds

rootdbName = data['rootdbName']
            rootdbdbUser = data['rootdbdbUser']
            rootdbpassword = data['rootdbpassword']

completDBString = """\nDATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': '%s',
        'USER': '%s',
        'PASSWORD': '%s',
        'HOST': '%s',
        'PORT':'%s'
    },
    'rootdb': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': '%s',
        'USER': '%s',
        'PASSWORD': '%s',
        'HOST': '%s',
        'PORT': '%s',
    },
}\n""" % (dbName, dbUser, password, host, port, rootdbName, rootdbdbUser, rootdbpassword, host, port)

settingsFile = '/usr/local/CyberCP/CyberCP/settings.py'

settingsData = open(settingsFile, 'r').readlines()

DATABASESCHECK = 0
            writeToFile = open(settingsFile, 'w')

for items in settingsData:
                if items.find('DATABASES = {') > -1:
                    DATABASESCHECK = 1

if DATABASESCHECK == 0:
                    writeToFile.write(items)

if items.find('DATABASE_ROUTERS = [') > -1:
                    DATABASESCHECK = 0
                    writeToFile.write(completDBString)
                    writeToFile.write(items)

writeToFile.close()

## new settings file restored

command = 'systemctl stop mysql'
            ProcessUtilities.normalExecutioner(command)

command = 'systemctl start mysql'
            ProcessUtilities.normalExecutioner(command)

## Restart lscpd

command = 'systemctl restart lscpd'
            ProcessUtilities.normalExecutioner(command)

## Update root password in cyberpanel file

writeToFile = open('/etc/cyberpanel/mysqlPassword', 'w')
            writeToFile.write(rootdbpassword)
            writeToFile.close()

## Update root password in .my.cnf

writeToFile = open('/home/cyberpanel/.my.cnf', 'w')
            content = """[mysqldump]
user=root
password=%s
max_allowed_packet=1024M
[mysql]
user=root
password=%s""" % (rootdbpassword, rootdbpassword)

writeToFile.write(content)
            writeToFile.close()

## Let this server process updates if master is down

connection, cursor = mysqlUtilities.setupConnection()
            cursor.execute("SET GLOBAL wsrep_provider_options='pc.ignore_sb=TRUE'")
            connection.close()

self.PostStatus('Fail over server successfully booted. [200]')

###

except BaseException as msg:
            self.PostStatus('Failed to boot, error %s [404].' % (str(msg)))

def CreatePendingVirtualHosts(self):
        try:

from plogical.virtualHostUtilities import virtualHostUtilities
            from websiteFunctions.models import Websites, ChildDomains

for website in Websites.objects.all():

confPath = '%s/%s' % (ClusterManager.vhostConfPath, website.domain)
                if not os.path.exists(confPath):
                    self.PostStatus('Domain %s found in master server, creating on child server now..' % (website.domain))
                    virtualHostUtilities.createVirtualHost(website.domain, website.adminEmail, website.phpSelection, website.externalApp, 1, 1, 0, website.admin.userName, website.package.packageName, 0, '/home/cyberpanel/temp', 1, 0)
                    self.PostStatus('Domain %s successfully created.' % (website.domain))

for childDomain in ChildDomains.objects.all():
                confPath = '%s/%s' % (ClusterManager.vhostConfPath, childDomain.domain)
                if not os.path.exists(confPath):
                    self.PostStatus('Child Domain %s found in master server, creating on child server now..' % (childDomain.domain))
                    virtualHostUtilities.createDomain(childDomain.master.domain, childDomain.domain, childDomain.phpSelection, childDomain.path, 1, 1, 0, childDomain.master.admin.userName, 0, 0)
                    self.PostStatus('Child Domain %s successfully created.' % (childDomain.domain))

## Cleanup of deleted domains

from plogical.acl import ACLManager
            import validators
            currentACL = ACLManager.loadedACL(1)
            allSite = ACLManager.findAllSites(currentACL, 1)

for website in os.listdir('/home'):

if validators.domain(website):
                    if website not in allSite:
                        self.PostStatus(
                            'Domain %s not found in Master, deleting data directories and configurations.' % (website))

command = 'rm -rf /home/%s' % (website)
                        ProcessUtilities.normalExecutioner(command)

command = 'rm -rf /%s/%s' % (ClusterManager.vhostConfPath, website)
                        ProcessUtilities.normalExecutioner(command)

self.PostStatus('All domains synced.')

except BaseException as msg:
            self.PostStatus('Failed to create pending vhosts, error %s [404].' % (str(msg)))

def SyncNow(self):
        try:

self.PostStatus('Syncing data from home directory to fail over server..')

command = "rsync -avzp -e 'ssh -o StrictHostKeyChecking=no -p %s -i /root/.ssh/cyberpanel' /home root@%s:/" % (self.config['failoverServerSSHPort'], self.config['failoverServerIP'])
            ProcessUtilities.normalExecutioner(command)

self.PostStatus('Syncing SSL certificates to fail over server..')

command = "rsync -avzp -e 'ssh -o StrictHostKeyChecking=no -p %s -i /root/.ssh/cyberpanel' /etc/letsencrypt root@%s:/etc" % (
            self.config['failoverServerSSHPort'], self.config['failoverServerIP'])
            ProcessUtilities.normalExecutioner(command)

self.PostStatus('Data and SSL certificates currently synced.')

except BaseException as msg:
            self.PostStatus('Failed to sync data, error %s [404].' % (str(msg)))

def PingNow(self):
        try:
            self.PostStatus('Master up. [200]')
        except BaseException as msg:
            self.PostStatus('Failed to ping cloud for online status, error %s [404].' % (str(msg)))

def DebugCluster(self):
        try:

if os.path.exists(ClusterManager.ClusterFile):
                self.PostStatus('Cluster config file exixts.')
            else:
                self.PostStatus('Cluster config file does not exists. [404]')

if os.path.exists(self.FetchMySQLConfigFile()):
                self.PostStatus('MySQL Cluster file exists.')
            else:
                self.PostStatus('MySQL Cluster file does not exists. [404]')

command = 'systemctl status mysql'
            result = subprocess.check_output(shlex.split(command)).decode("utf-8")

if result.find("active (running)") > -1:
                self.PostStatus('MySQL server is running.')
            else:
                self.PostStatus('MySQL server is down. [404]')

except BaseException as msg:
            self.PostStatus('Failed to debug cluster, error %s [404].' % (str(msg)))

def UptimeMonitor(self):
        try:

CentOSPath = '/etc/redhat-release'

if os.path.exists(CentOSPath):
                cronPath = '/var/spool/cron/root'
            else:
                cronPath = '/var/spool/cron/crontabs/root'

writeToFile = open(cronPath, 'a')

writeToFile.write('*/3 * * * * /usr/local/CyberCP/bin/python /usr/local/CyberCP/plogical/ClusterManager.py --function Uptime --type All\n')
            writeToFile.close()

command = 'systemctl restart cron'
            ProcessUtilities.normalExecutioner(command)

###

except BaseException as msg:
            logging.writeToFile('Error while setting up Uptime cron. Error %s' % (str(msg)))

def Uptime(self):
        try:
            finalData = {'name': self.config['name'], 'token': self.config['token']}
            resp = requests.post(ClusterManager.UptimeURL, data=json.dumps(finalData))
            if os.path.exists(ProcessUtilities.debugPath):
                logging.writeToFile(resp.text + '[Uptime:info]')
        except BaseException as msg:
            logging.writeToFile('%s. [31:404]' % (str(msg)))

def SyncToMaster(self):
        try:

self.PostStatus('Syncing data from home directory to Main server..')

command = "rsync -avzp -e 'ssh -o StrictHostKeyChecking=no -p %s -i /root/.ssh/cyberpanel' /home root@%s:/" % (self.config['masterServerSSHPort'], self.config['masterServerIP'])
            ProcessUtilities.normalExecutioner(command)

self.PostStatus('Syncing SSL certificates to Main server..')

command = "rsync -avzp -e 'ssh -o StrictHostKeyChecking=no -p %s -i /root/.ssh/cyberpanel' /etc/letsencrypt root@%s:/etc" % (
            self.config['masterServerSSHPort'], self.config['masterServerIP'])
            ProcessUtilities.normalExecutioner(command)

self.PostStatus('Data back to main.')

except BaseException as msg:
            self.PostStatus('Failed to sync data, error %s [404].' % (str(msg)))

def main():
    parser = argparse.ArgumentParser(description='CyberPanel Installer')
    parser.add_argument('--function', help='Function to run.')
    parser.add_argument('--type', help='Type of detach.')

args = parser.parse_args()

uc = ClusterManager(args.type)

if args.function == 'DetachCluster':
        uc.DetechFromCluster()
    elif args.function == 'SetupCluster':
        uc.SetupCluster()
    elif args.function == 'BootMaster':
        uc.BootMaster()
    elif args.function == 'BootChild':
        uc.BootChild()
    elif args.function == 'CreatePendingVirtualHosts':
        uc.CreatePendingVirtualHosts()
    elif args.function == 'SyncNow':
        uc.SyncNow()
    elif args.function == 'PingNow':
        uc.PingNow()
    elif args.function == 'DebugCluster':
        uc.DebugCluster()
    elif args.function == 'UptimeMonitor':
        uc.UptimeMonitor()
    elif args.function == 'Uptime':
        uc.Uptime()
    elif args.function == 'SyncToMaster':
        uc.SyncToMaster()

if __name__ == "__main__":
    main()

${this.title}

Code Editor : ClusterManager.py