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

import json
import os,sys
import time

from django.http import HttpResponse

sys.path.append('/usr/local/CyberCP')
import django
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "CyberCP.settings")
try:
    django.setup()
except:
    pass
import os.path
import shutil
from plogical import CyberCPLogFileWriter as logging
import subprocess
import argparse
import shlex
from plogical.processUtilities import ProcessUtilities
import os
import bcrypt
import getpass
import smtplib
import threading as multi

try:
    from mailServer.models import Domains, EUsers
    from emailPremium.models import DomainLimits, EmailLimits
    from websiteFunctions.models import Websites, ChildDomains
except:
    pass

class mailUtilities:

installLogPath = "/home/cyberpanel/openDKIMInstallLog"
    spamassassinInstallLogPath = "/home/cyberpanel/spamassassinInstallLogPath"
    RspamdInstallLogPath = "/home/cyberpanel/RspamdInstallLogPath"
    RspamdUnInstallLogPath = "/home/cyberpanel/RspamdUnInstallLogPath"
    cyberPanelHome = "/home/cyberpanel"
    mailScannerInstallLogPath = "/home/cyberpanel/mailScannerInstallLogPath"
    RSpamdLogPath = '/var/log/rspamd/rspamd.log'

@staticmethod
    def SendEmail(sender, receivers, message):
        try:
            smtpObj = smtplib.SMTP('localhost')
            smtpObj.sendmail(sender, receivers, message)
            print("Successfully sent email")
        except BaseException as msg:
            logging.CyberCPLogFileWriter.writeToFile(str(msg))
    @staticmethod
    def AfterEffects(domain):
        path = "/usr/local/CyberCP/install/rainloop/cyberpanel.net.ini"

if not os.path.exists("/usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/domains/"):
            os.makedirs("/usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/domains/")

finalPath = "/usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/domains/" + domain + ".ini"
        finalPathJson = "/usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/domains/" + domain + ".json"

if not os.path.exists(finalPath):
            shutil.copy(path, finalPath)

contentJSON = """
{
    "name": "%s",
    "IMAP": {
        "host": "localhost",
        "port": 993,
        "type": 1,
        "timeout": 300,
        "shortLogin": false,
        "sasl": [
            "SCRAM-SHA3-512",
            "SCRAM-SHA-512",
            "SCRAM-SHA-256",
            "SCRAM-SHA-1",
            "PLAIN",
            "LOGIN"
        ],
        "ssl": {
            "verify_peer": false,
            "verify_peer_name": false,
            "allow_self_signed": false,
            "SNI_enabled": true,
            "disable_compression": true,
            "security_level": 1
        },
        "use_expunge_all_on_delete": false,
        "fast_simple_search": true,
        "force_select": false,
        "message_all_headers": false,
        "message_list_limit": 10000,
        "search_filter": "",
        "disabled_capabilities": []
    },
    "SMTP": {
        "host": "localhost",
        "port": 587,
        "type": 2,
        "timeout": 60,
        "shortLogin": false,
        "sasl": [
            "SCRAM-SHA3-512",
            "SCRAM-SHA-512",
            "SCRAM-SHA-256",
            "SCRAM-SHA-1",
            "PLAIN",
            "LOGIN"
        ],
        "ssl": {
            "verify_peer": false,
            "verify_peer_name": false,
            "allow_self_signed": false,
            "SNI_enabled": true,
            "disable_compression": true,
            "security_level": 1
        },
        "useAuth": true,
        "setSender": false,
        "usePhpMail": false,
        "authPlainLine": false
    },
    "Sieve": {
        "host": "localhost",
        "port": 4190,
        "type": 0,
        "timeout": 10,
        "shortLogin": false,
        "sasl": [
            "SCRAM-SHA3-512",
            "SCRAM-SHA-512",
            "SCRAM-SHA-256",
            "SCRAM-SHA-1",
            "PLAIN",
            "LOGIN"
        ],
        "ssl": {
            "verify_peer": false,
            "verify_peer_name": false,
            "allow_self_signed": false,
            "SNI_enabled": true,
            "disable_compression": true,
            "security_level": 1
        },
        "enabled": false
    },
    "whiteList": ""
}
""" % (domain)

WriteToFile = open(finalPathJson, 'w')
        WriteToFile.write(contentJSON)
        WriteToFile.close()

command = 'chown -R lscpd:lscpd /usr/local/lscp/cyberpanel/rainloop/data/'
        ProcessUtilities.normalExecutioner(command)

@staticmethod
    def InstallMailBoxFoldersPlugin():
        ### now download and install actual plugin

labsPath = '/usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/configs/application.ini'

command = f'mkdir /usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/plugins/mailbox-detect'
        ProcessUtilities.executioner(command)

command = f'chmod 700 /usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/plugins/mailbox-detect'
        ProcessUtilities.executioner(command)

command = f'chown lscpd:lscpd /usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/plugins/mailbox-detect'
        ProcessUtilities.executioner(command)

command = f'wget -O /usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/plugins/mailbox-detect/index.php https://raw.githubusercontent.com/the-djmaze/snappymail/master/plugins/mailbox-detect/index.php'
        ProcessUtilities.executioner(command)

command = f'chmod 644 /usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/plugins/mailbox-detect/index.php'
        ProcessUtilities.executioner(command)

command = f'chown lscpd:lscpd /usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/plugins/mailbox-detect/index.php'
        ProcessUtilities.executioner(command)

### Enable plugins and enable mailbox creation plugin

labsDataLines = open(labsPath, 'r').readlines()
        PluginsActivator = 0
        WriteToFile = open(labsPath, 'w')

for lines in labsDataLines:
            if lines.find('[plugins]') > -1:
                PluginsActivator = 1
                WriteToFile.write(lines)
            elif PluginsActivator and lines.find('enable = ') > -1:
                WriteToFile.write(f'enable = On\n')
            elif PluginsActivator and lines.find('enabled_list = ') > -1:
                WriteToFile.write(f'enabled_list = "mailbox-detect"\n')
            elif PluginsActivator == 1 and lines.find('[defaults]') > -1:
                PluginsActivator = 0
                WriteToFile.write(lines)
            else:
                WriteToFile.write(lines)
        WriteToFile.close()

## enable auto create in the enabled plugin
        PluginsFilePath = '/usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/configs/plugin-mailbox-detect.json'

WriteToFile = open(PluginsFilePath, 'w')
        WriteToFile.write("""{
    "plugin": {
        "autocreate_system_folders": true
    }
}
""")
        WriteToFile.close()

command = f'chown lscpd:lscpd {PluginsFilePath}'
        ProcessUtilities.executioner(command)

command = f'chmod 600 {PluginsFilePath}'
        ProcessUtilities.executioner(command)

@staticmethod
    def createEmailAccount(domain, userName, password, restore = None):
        try:

## Check if already exists

finalEmailUsername = userName + "@" + domain

if EUsers.objects.filter(email=finalEmailUsername).exists():
                raise BaseException("This account already exists!")

## Check for email limits.

ChildCheck = 0
            try:
                website = Websites.objects.get(domain=domain)
            except:
                website = ChildDomains.objects.get(domain=domain)
                ChildCheck = 1

try:

if not Domains.objects.filter(domain=domain).exists():
                    if ChildCheck == 0:
                        newEmailDomain = Domains(domainOwner=website, domain=domain)
                    else:
                        newEmailDomain = Domains(childOwner=website, domain=domain)

newEmailDomain.save()

if not DomainLimits.objects.filter(domain=newEmailDomain).exists():
                    domainLimits = DomainLimits(domain=newEmailDomain)
                    domainLimits.save()

if ChildCheck == 0:
                    if website.package.emailAccounts == 0 or (
                                newEmailDomain.eusers_set.all().count() < website.package.emailAccounts):
                        pass
                    else:
                        raise BaseException("Exceeded maximum amount of email accounts allowed for the package.")
                else:
                    if website.master.package.emailAccounts == 0 or (
                                newEmailDomain.eusers_set.all().count() < website.master.package.emailAccounts):
                        pass
                    else:
                        raise BaseException("Exceeded maximum amount of email accounts allowed for the package.")

except:

emailDomain = Domains.objects.get(domain=domain)
                if ChildCheck == 0:
                    if website.package.emailAccounts == 0 or (
                                emailDomain.eusers_set.all().count() < website.package.emailAccounts):
                        pass
                    else:
                        raise BaseException("Exceeded maximum amount of email accounts allowed for the package.")
                else:
                    if website.master.package.emailAccounts == 0 or (
                                emailDomain.eusers_set.all().count() < website.master.package.emailAccounts):
                        pass
                    else:
                        raise BaseException("Exceeded maximum amount of email accounts allowed for the package.")

## After effects

execPath = "/usr/local/CyberCP/bin/python /usr/local/CyberCP/plogical/mailUtilities.py"
            execPath = execPath + " AfterEffects --domain " + domain

if getpass.getuser() == 'root':
                ## This is the case when cPanel Importer is running and token is not present in enviroment.
                ProcessUtilities.normalExecutioner(execPath)
            else:
                ProcessUtilities.executioner(execPath, 'lscpd')

## After effects ends

emailDomain = Domains.objects.get(domain=domain)

#emailAcct = EUsers(emailOwner=emailDomain, email=finalEmailUsername, password=hash.hexdigest())

CentOSPath = '/etc/redhat-release'

if os.path.exists(CentOSPath):
                if restore == None:
                    password = bcrypt.hashpw(password.encode('utf-8'), bcrypt.gensalt())
                    password = '{CRYPT}%s' % (password.decode())
                emailAcct = EUsers(emailOwner=emailDomain, email=finalEmailUsername, password=password)
                emailAcct.mail = 'maildir:/home/vmail/%s/%s/Maildir' % (domain, userName)
                emailAcct.save()
            else:
                if restore == None:
                    password = bcrypt.hashpw(password.encode('utf-8'), bcrypt.gensalt())
                    password = '{CRYPT}%s' % (password.decode())
                emailAcct = EUsers(emailOwner=emailDomain, email=finalEmailUsername, password=password)
                emailAcct.mail = 'maildir:/home/vmail/%s/%s/Maildir' % (domain, userName)
                emailAcct.save()

emailLimits = EmailLimits(email=emailAcct)
            emailLimits.save()

### Create maildir structure if it doesn't exist
            
            # Create base maildir path
            maildir_base = f"/home/vmail/{domain}/{userName}"
            maildir_path = f"{maildir_base}/Maildir"
            
            # Create the main maildir structure
            if not os.path.exists(maildir_path):
                command = f"mkdir -p '{maildir_path}/cur' '{maildir_path}/new' '{maildir_path}/tmp'"
                ProcessUtilities.executioner(command, 'vmail')
                
                # Set proper permissions
                command = f"chmod -R 700 '{maildir_base}'"
                ProcessUtilities.executioner(command, 'vmail')
                
                # Ensure ownership is correct
                command = f"chown -R vmail:vmail '{maildir_base}'"
                ProcessUtilities.executioner(command, 'root')

# Create standard IMAP folders
            standard_folders = [
                ".Archive",
                ".Deleted Items", 
                ".Drafts",
                ".Sent",
                ".Junk E-mail"
            ]
            
            for folder in standard_folders:
                folder_path = f"{maildir_path}/{folder}"
                if not os.path.exists(folder_path):
                    command = f"mkdir -p '{folder_path}/cur' '{folder_path}/new' '{folder_path}/tmp'"
                    ProcessUtilities.executioner(command, 'vmail')
            
            # Set permissions for all folders
            command = f"chmod -R 700 '{maildir_path}'"
            ProcessUtilities.executioner(command, 'vmail')
            
            # Ensure final ownership
            command = f"chown -R vmail:vmail '{maildir_base}'"
            ProcessUtilities.executioner(command, 'root')

#if not os.path.exists('/usr/local/lscp/cyberpanel/rainloop/data/_data_/_default_/plugins/mailbox-detect'):
            #    mailUtilities.InstallMailBoxFoldersPlugin()

print("1,None")
            return 1,"None"

except BaseException as msg:
            logging.CyberCPLogFileWriter.writeToFile(
                str(msg) + "  [createEmailAccount]")
            print("0," + str(msg))
            return 0, str(msg)

@staticmethod
    def deleteEmailAccount(email):
        try:

email = EUsers(email=email)
            email.delete()

return 1, 'None'

except BaseException as msg:
            logging.CyberCPLogFileWriter.writeToFile(
                str(msg) + "  [deleteEmailAccount]")
            return 0, str(msg)

@staticmethod
    def getEmailAccounts(virtualHostName):
        try:
            emailDomain = Domains.objects.get(domain=virtualHostName)
            return emailDomain.eusers_set.all()
        except:
            return 0

@staticmethod
    def changeEmailPassword(email, newPassword, encrypt = None):
        try:
            changePass = EUsers.objects.get(email=email)
            if encrypt == None:
                # Always use bcrypt hashing regardless of OS
                password = bcrypt.hashpw(newPassword.encode('utf-8'), bcrypt.gensalt())
                password = '{CRYPT}%s' % (password.decode())
                changePass.password = password
            else:
                changePass.password = newPassword
            changePass.save()
            return 0,'None'
        except BaseException as msg:
            return 0, str(msg)

@staticmethod
    def setupDKIM(virtualHostName):
        try:
            ## Generate DKIM Keys

import tldextract

no_cache_extract = tldextract.TLDExtract(cache_dir=None)

actualDomain = virtualHostName
            extractDomain = no_cache_extract(virtualHostName)
            virtualHostName = extractDomain.domain + '.' + extractDomain.suffix

if not os.path.exists("/etc/opendkim/keys/" + virtualHostName + "/default.txt"):

path = '/etc/opendkim/keys/%s' % (virtualHostName)
                command = 'mkdir %s' % (path)
                ProcessUtilities.normalExecutioner(command)

## Generate keys

if ProcessUtilities.decideDistro() == ProcessUtilities.centos or ProcessUtilities.decideDistro() == ProcessUtilities.cent8:
                    command = "/usr/sbin/opendkim-genkey -D /etc/opendkim/keys/%s -d %s -s default" % (virtualHostName, virtualHostName)
                else:
                    command = "opendkim-genkey -D /etc/opendkim/keys/%s -d %s -s default" % (
                    virtualHostName, virtualHostName)

ProcessUtilities.normalExecutioner(command)

## Fix permissions

command = "chown -R root:opendkim /etc/opendkim/keys/" + virtualHostName
                ProcessUtilities.normalExecutioner(command)

command = "chmod 640 /etc/opendkim/keys/" + virtualHostName + "/default.private"
                ProcessUtilities.normalExecutioner(command)

command = "chmod 644 /etc/opendkim/keys/" + virtualHostName + "/default.txt"
                ProcessUtilities.normalExecutioner(command)

## Edit key file

keyTable = "/etc/opendkim/KeyTable"
            configToWrite = "default._domainkey." + actualDomain + " " + actualDomain + ":default:/etc/opendkim/keys/" + virtualHostName + "/default.private\n"

if not os.path.exists(keyTable):
                writeToFile = open(keyTable, 'a')
                writeToFile.write("##### CyberPanel Generated File - Do not edit if you don't know what you are doing.\n")
                writeToFile.close()

data = open(keyTable, 'r').read()

if data.find("default._domainkey." + actualDomain) == -1:

writeToFile = open(keyTable, 'a')
                writeToFile.write(configToWrite)
                writeToFile.close()

## Edit signing table

signingTable = "/etc/opendkim/SigningTable"
            configToWrite = "*@" + actualDomain + " default._domainkey." + actualDomain + "\n"

if not os.path.exists(signingTable):
                writeToFile = open(signingTable, 'a')
                writeToFile.write("##### CyberPanel Generated File - Do not edit if you don't know what you are doing.\n")
                writeToFile.close()

data = open(signingTable, 'r').read()

if data.find("default._domainkey." + actualDomain) == -1:

writeToFile = open(signingTable, 'a')
                writeToFile.write(configToWrite)
                writeToFile.close()

## Trusted hosts

trustedHosts = "/etc/opendkim/TrustedHosts"
            configToWrite = actualDomain + "\n"

if not os.path.exists(trustedHosts):

writeToFile = open(trustedHosts, 'a')
                writeToFile.write("##### CyberPanel Generated File - Do not edit if you don't know what you are doing.\n")
                writeToFile.close()

data = open(trustedHosts, 'r').read()

if data.find(actualDomain) == -1:

writeToFile = open(trustedHosts, 'a')
                writeToFile.write(configToWrite)
                writeToFile.close()

## Restart Postfix and OpenDKIM

command = "systemctl restart opendkim"
            subprocess.call(shlex.split(command))

command = "systemctl restart postfix"
            subprocess.call(shlex.split(command))

return 1, "None"

except BaseException as msg:
            logging.CyberCPLogFileWriter.writeToFile(
                str(msg) + "  [setupDKIM:275]")
            return 0, str(msg)

@staticmethod
    def checkIfDKIMInstalled():
        try:

path = "/etc/opendkim.conf"

command = "sudo cat " + path
            return ProcessUtilities.executioner(command)

except BaseException as msg:
            logging.CyberCPLogFileWriter.writeToFile(
                str(msg) + "  [checkIfDKIMInstalled]")
            return 0

@staticmethod
    def generateKeys(domain):
        try:
            result = mailUtilities.setupDKIM(domain)
            if result[0] == 0:
                raise BaseException(result[1])
            else:
                print("1,None")

except BaseException as msg:
            logging.CyberCPLogFileWriter.writeToFile(
                str(msg) + "  [generateKeys]")
            print("0," + str(msg))

@staticmethod
    def configureOpenDKIM():
            try:

## Configure OpenDKIM specific settings

openDKIMConfigurePath = "/etc/opendkim.conf"

configData = """
Mode	sv
Canonicalization	relaxed/simple
KeyTable	refile:/etc/opendkim/KeyTable
SigningTable	refile:/etc/opendkim/SigningTable
ExternalIgnoreList	refile:/etc/opendkim/TrustedHosts
InternalHosts	refile:/etc/opendkim/TrustedHosts
"""

writeToFile = open(openDKIMConfigurePath, 'a')
                writeToFile.write(configData)
                writeToFile.close()

## Configure postfix specific settings

postfixFilePath = "/etc/postfix/main.cf"

configData = """
smtpd_milters = inet:127.0.0.1:8891
non_smtpd_milters = $smtpd_milters
milter_default_action = accept
"""

writeToFile = open(postfixFilePath, 'a')
                writeToFile.write(configData)
                writeToFile.close()

#### Restarting Postfix and OpenDKIM

command = "systemctl start opendkim"
                subprocess.call(shlex.split(command))

command = "systemctl enable opendkim"
                subprocess.call(shlex.split(command))

command = "systemctl start postfix"
                subprocess.call(shlex.split(command))

print("1,None")
                return

except OSError as msg:
                logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [configureOpenDKIM]")
                print("0," + str(msg))
                return
            except BaseException as msg:
                logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [configureOpenDKIM]")
                print("0," + str(msg))
            return

@staticmethod
    def checkHome():
        try:
            try:
                FNULL = open(os.devnull, 'w')

if getpass.getuser() == 'root':
                    if not os.path.exists(mailUtilities.cyberPanelHome):
                        command = "mkdir " + mailUtilities.cyberPanelHome
                        subprocess.call(shlex.split(command), stdout=FNULL)

command = "sudo chown -R cyberpanel:cyberpanel " + mailUtilities.cyberPanelHome
                    subprocess.call(shlex.split(command), stdout=FNULL)
                else:
                    if not os.path.exists(mailUtilities.cyberPanelHome):
                        command = "mkdir " + mailUtilities.cyberPanelHome
                        ProcessUtilities.executioner(command)

command = "chown -R cyberpanel:cyberpanel " + mailUtilities.cyberPanelHome
                    ProcessUtilities.executioner(command)
            except:
                FNULL = open(os.devnull, 'w')
                command = "chown -R cyberpanel:cyberpanel " + mailUtilities.cyberPanelHome
                subprocess.call(shlex.split(command), stdout=FNULL)

except BaseException as msg:
            logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [checkHome]")

@staticmethod
    def installOpenDKIM(install, openDKIMINstall):
        try:

mailUtilities.checkHome()

command = 'sudo yum install opendkim -y'

cmd = shlex.split(command)

with open(mailUtilities.installLogPath, 'w') as f:
                res = subprocess.call(cmd, stdout=f)

if res == 1:
                writeToFile = open(mailUtilities.installLogPath, 'a')
                writeToFile.writelines("Can not be installed.[404]\n")
                writeToFile.close()
                logging.CyberCPLogFileWriter.writeToFile("[Could not Install OpenDKIM.]")
                return 0
            else:
                writeToFile = open(mailUtilities.installLogPath, 'a')
                writeToFile.writelines("OpenDKIM Installed.[200]\n")
                writeToFile.close()

return 1
        except BaseException as msg:
            writeToFile = open(mailUtilities.installLogPath, 'a')
            writeToFile.writelines("Can not be installed.[404]\n")
            writeToFile.close()
            logging.CyberCPLogFileWriter.writeToFile(str(msg) + "[installOpenDKIM]")

@staticmethod
    def restartServices():
        try:
            command = 'systemctl restart postfix'
            subprocess.call(shlex.split(command))

command = 'systemctl restart dovecot'
            subprocess.call(shlex.split(command))
        except BaseException as msg:
            logging.CyberCPLogFileWriter.writeToFile(str(msg) + " [restartServices]")

@staticmethod
    def installSpamAssassin(install, SpamAssassin):
        try:

if os.path.exists(mailUtilities.spamassassinInstallLogPath):
                os.remove(mailUtilities.spamassassinInstallLogPath)

if ProcessUtilities.decideDistro() == ProcessUtilities.centos or ProcessUtilities.decideDistro() == ProcessUtilities.cent8:
                command = 'sudo yum install spamassassin -y'
            else:
                command = 'sudo apt-get install spamassassin spamc -y'

cmd = shlex.split(command)

with open(mailUtilities.spamassassinInstallLogPath, 'w') as f:
                res = subprocess.call(cmd, stdout=f)

if res == 1:
                writeToFile = open(mailUtilities.spamassassinInstallLogPath, 'a')
                writeToFile.writelines("Can not be installed.[404]\n")
                writeToFile.close()
                logging.CyberCPLogFileWriter.writeToFile("[Could not Install SpamAssassin.]")
                return 0
            else:
                writeToFile = open(mailUtilities.spamassassinInstallLogPath, 'a')
                writeToFile.writelines("SpamAssassin Installed.[200]\n")
                writeToFile.close()

return 1
        except BaseException as msg:
            writeToFile = open(mailUtilities.spamassassinInstallLogPath, 'a')
            writeToFile.writelines("Can not be installed.[404]\n")
            writeToFile.close()
            logging.CyberCPLogFileWriter.writeToFile(str(msg) + "[installSpamAssassin]")

@staticmethod
    def SetupEmailLimits():
        rlFile = '/etc/rspamd/override.d/ratelimit.conf'
        rlContent = '''
custom_keywords = "/etc/rspamd/custom_ratelimit.lua";
'''
        if not os.path.exists(rlFile):

WriteToFile = open(rlFile, 'w')
            WriteToFile.write(rlContent)
            WriteToFile.close()

rlLUA = '/etc/rspamd/custom_ratelimit.lua'
            rlLUAContent = '''
local custom_keywords = {}
local d = {}

-- create map
d['badusers'] = rspamd_config:add_map({
  ['url']= '/etc/rspamd/badusers.map',
  ['type'] = 'map',
  ['description'] = 'Bad users'
})

custom_keywords.customrl = function(task)
  local rspamd_logger = require "rspamd_logger"
  -- get authenticated user
  local user = task:get_user()
  -- define a default ratelimit
  local default_rl = "10 / 1m"
  if not user then return end -- no user, return nil
  local user_rl = d['badusers']:get_key(user)
  if user_rl then
    local limit, duration, unit = string.match(user_rl, "(%d+)%s-/%s-(%d+)(%a*)")
    if limit and duration then
      duration = tonumber(duration)
      if unit == 'm' then
        duration = duration * 60 -- convert minutes to seconds
      elseif unit == 'h' then
        duration = duration * 3600 -- convert hours to seconds
      elseif unit == 'd' then
        duration = duration * 86400 -- convert days to seconds
      end
      local custom_rl = limit .. " / " .. duration .. "s"
      rspamd_logger.infox(rspamd_config, "User %s has custom ratelimit: %s", user, custom_rl)
      return "rs_customrl_" .. user, custom_rl
    else
      rspamd_logger.errx(rspamd_config, "Invalid ratelimit format for user %s, using default: %s", user, default_rl)
      return "rs_customrl_" .. user, default_rl
    end
  else
    rspamd_logger.infox(rspamd_config, "User %s not found in bad users map, using default ratelimit: %s", user, default_rl)
    return "rs_customrl_" .. user, default_rl
  end
end

return custom_keywords
'''

WriteToFile = open(rlLUA, 'w')
            WriteToFile.write(rlLUAContent)
            WriteToFile.close()

@staticmethod
    def installRspamd(install, rspamd):
        from manageServices.serviceManager import ServiceManager
        try:
            if os.path.exists(mailUtilities.RspamdInstallLogPath):
                os.remove(mailUtilities.RspamdInstallLogPath)

####Frist install redis
            ServiceManager.InstallRedis()

if ProcessUtilities.decideDistro() == ProcessUtilities.centos:

writeToFile = open(mailUtilities.RspamdInstallLogPath, 'a')
                writeToFile.writelines("Configuring RSPAMD repo..\n")
                writeToFile.close()

command = 'curl https://rspamd.com/rpm-stable/centos-7/rspamd.repo > /etc/yum.repos.d/rspamd.repo'
                ProcessUtilities.normalExecutioner(command, True)

command = 'rpm --import https://rspamd.com/rpm-stable/gpg.key'
                ProcessUtilities.normalExecutioner(command, True)

command = 'yum update'
                ProcessUtilities.normalExecutioner(command, True)

command = 'sudo yum install rspamd clamav-server clamav-data clamav-update clamav-filesystem clamav clamav-scanner-systemd clamav-devel clamav-lib clamav-server-systemd -y'

elif ProcessUtilities.decideDistro() == ProcessUtilities.cent8:

writeToFile = open(mailUtilities.RspamdInstallLogPath, 'a')
                writeToFile.writelines("Configuring RSPAMD repo..\n")
                writeToFile.close()

command = 'curl https://rspamd.com/rpm-stable/centos-8/rspamd.repo > /etc/yum.repos.d/rspamd.repo'
                ProcessUtilities.normalExecutioner(command, True)

command = 'rpm --import https://rspamd.com/rpm-stable/gpg.key'
                ProcessUtilities.normalExecutioner(command, True)

command = 'yum update'
                ProcessUtilities.normalExecutioner(command, True)

command = 'sudo yum install rspamd clamav clamd clamav-update -y'
            else:
                command = 'DEBIAN_FRONTEND=noninteractive apt-get install rspamd clamav clamav-daemon -y'

with open(mailUtilities.RspamdInstallLogPath, 'w') as f:
                res = subprocess.call(command, stdout=f, shell=True)

###### makefile
            path = "/etc/rspamd/local.d/antivirus.conf"
            content ="""# ================= DO NOT MODIFY THIS FILE =================
# 
# Manual changes will be lost when this file is regenerated.
#
# Please read the developer's guide, which is available
# at NethServer official site: https://www.nethserver.org
#
#

#Enable or disable the module 
enabled = true

# multiple scanners could be checked, for each we create a configuration block with an arbitrary name
clamav {
  # If set force this action if any virus is found (default unset: no action is forced, 'rewrite_subject' to tag as spam)
  action = "reject";

# if `true` only messages with non-image attachments will be checked (default true)
  scan_mime_parts = false;

# If `max_size` is set, messages > n bytes in size are not scanned
  max_size = 20000000;

# type of scanner: "clamav", "fprot", "sophos" or "savapi"
  type = "clamav";

# If set true, log message is emitted for clean messages
  log_clean = false;

# Timeout and retransmits increased in case of clamav is reloading its database
  # It takes a lot of time (25 to 60 seconds), after rspamd answers a temporally failure
  #timeout = 5;
  #retransmits = 2;

# servers to query (if port is unspecified, scanner-specific default is used)
  # can be specified multiple times to pool servers
  # can be set to a path to a unix socket
  servers = "127.0.0.1:3310";

# if `patterns` is specified virus name will be matched against provided regexes and the related
  # symbol will be yielded if a match is found. If no match is found, default symbol is yielded.
  patterns {
    # symbol_name = "pattern";
    CLAMAV_VIRUS = "^Eicar-Test-Signature$";
  }

# In version 1.7.0+ patterns could be a list for ordered matching
  #patterns = [{SANE_MAL = "Sanesecurity.Malware.*"}, {CLAM_UNOFFICIAL = "UNOFFICIAL$"}];

# `whitelist` points to a map of IP addresses. Mail from these addresses is not scanned.
  whitelist = "/etc/rspamd/antivirus.wl";
}
"""

wirtedata = open(path, 'w')
            wirtedata.writelines(content)
            wirtedata.close()

### disable dkim signing in rspamd in ref to https://github.com/usmannasir/cyberpanel/issues/1176

DKIMPath = '/etc/rspamd/local.d/dkim_signing.conf'

WriteToFile = open(DKIMPath, 'w')
            WriteToFile.write('enabled = false;\n')
            WriteToFile.close()

appendpath = "/etc/postfix/main.cf"

lines = open(appendpath, 'r').readlines()

WriteToFile = open(appendpath, 'w')

for line in lines:
                if line.find('inet:127.0.0.1:8891') > -1:
                    cLine = line.rstrip('\n')
                    content = f'{cLine}, inet:127.0.0.1:11332\n'
                    WriteToFile.write('### Please do not edit this line, editing this line could break configurations\n')
                    WriteToFile.write(content)
                elif line.find('non_smtpd_milters') > -1:
                    WriteToFile.write('non_smtpd_milters = $smtpd_milters\n')
                else:
                    WriteToFile.write(line)

WriteToFile.close()

wpath = "/etc/rspamd/local.d/redis.conf"
            wdata = """
write_servers = "127.0.0.1";
read_servers = "127.0.0.1";
"""

wirtedata2 = open(wpath, 'w')
            wirtedata2.writelines(wdata)
            wirtedata2.close()

if res == 1:
                writeToFile = open(mailUtilities.RspamdInstallLogPath, 'a')
                writeToFile.writelines("Can not be installed.[404]\n")
                writeToFile.close()
                logging.CyberCPLogFileWriter.writeToFile("[Could not Install Rspamd.]")
                return 0
            else:

if ProcessUtilities.decideDistro() == ProcessUtilities.centos or ProcessUtilities.decideDistro() == ProcessUtilities.cent8:
                    command = 'setsebool -P antivirus_can_scan_system 1'
                    cmd = shlex.split(command)