package de.hsadmin.mods.dom; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.persistence.EntityManager; import javax.persistence.Query; import de.hsadmin.core.model.AbstractEntity; import de.hsadmin.core.qserv.CompoundProcessor; import de.hsadmin.core.qserv.CopyFileProcessor; import de.hsadmin.core.qserv.CreateFileProcessor; import de.hsadmin.core.qserv.EntityProcessorFactory; import de.hsadmin.core.qserv.Processor; import de.hsadmin.core.qserv.ProcessorException; import de.hsadmin.core.qserv.ShellProcessor; import de.hsadmin.core.qserv.TemplateProcessor; import de.hsadmin.core.qserv.WaitingTasksProcessor; import de.hsadmin.mods.email.EMailAddress; import de.hsadmin.mods.email.EMailAddressProcessorFactory; import de.hsadmin.mods.pac.Pac; import de.hsadmin.mods.user.UnixUser; public class DomainProcessorFactory implements EntityProcessorFactory { /** * @return a Processor which creates a domain * @throws ProcessorException */ public Processor createCreateProcessor(EntityManager em, T entity) throws ProcessorException { String hiveName = entity.getHiveName(); Domain dom = (Domain) entity; UnixUser domUser = dom.getUser(); Pac pac = domUser.getPac(); String domName = dom.getName(); String zonefileTargetPath = "/etc/bind/pri." + domName; Map templateVars = new HashMap(); templateVars.put("SIO", Long.toString(System.currentTimeMillis()/1000L)); templateVars.put("DOM_HOSTNAME", domName); templateVars.put("PAC_HOSTNAME", pac.getName() + ".hostsharing.net"); templateVars.put("DOM_IPNUMBER", pac.getCurINetAddr().getInetAddr()); Processor zonefileTemplateProcessor = new TemplateProcessor("/de/hsadmin/mods/dom/zonefile.jtpl", templateVars, zonefileTargetPath, false); Processor zonefileACLProcessor = new ShellProcessor("chown root:bind " + zonefileTargetPath + " && chmod 644 " + zonefileTargetPath); Processor prizonesFileProcessor = new ShellProcessor("echo 'zone \"" + domName + "\" { type master; file \"pri." + domName + "\"; };' >>/etc/bind/named.pri-zones" + " && sort /etc/bind/named.pri-zones | uniq >/etc/bind/named.pri-zones.tmp" + " && mv /etc/bind/named.pri-zones.tmp /etc/bind/named.pri-zones"); // zone "zweisprech.de" { type slave; file "sec.zweisprech.de"; masters { 83.223.95.31; }; }; String hiveInetAddr = pac.getHive().getInetAddr().getInetAddr(); Processor smtpTransportsProcessor = new ShellProcessor("echo " + domName + " >> /etc/postfix/relaydomains" + " && invoke-rc.d postfix reload"); Processor dnsReloadProcessor = new ShellProcessor("invoke-rc.d bind9 reload"); EMailAddressProcessorFactory eMailAddressProcessorFactory = new EMailAddressProcessorFactory(); Processor dnsSetupProcessor = new CompoundProcessor(zonefileTemplateProcessor, zonefileACLProcessor, prizonesFileProcessor, dnsReloadProcessor); WaitingTasksProcessor mainProcessor = new WaitingTasksProcessor(dnsSetupProcessor); CompoundProcessor emailAdrProcessor = new CompoundProcessor(); Query query = em.createQuery("SELECT adr FROM " + EMailAddress.class.getAnnotation(javax.persistence.Entity.class).name() + " adr WHERE adr.domain.name='" + domName + "'"); List resultList = query.getResultList(); for (Object obj : resultList) { EMailAddress eMailAddress = (EMailAddress) obj; emailAdrProcessor.appendProcessor(eMailAddressProcessorFactory.createCreateProcessor(em, eMailAddress)); } mainProcessor.appendProcessor(hiveName, emailAdrProcessor, "Setup EMail"); Processor seczonesFileProcessor = null; String[] dnsServerQueues = { "dns1", "dns2", "dns3" }; for (String queueName : dnsServerQueues) { seczonesFileProcessor = new ShellProcessor("echo 'zone \"" + domName + "\" { type slave; file \"sec." + domName + "\"; masters { " + hiveInetAddr + "; }; };' >>/etc/bind/named-hsh.conf" + " && sort /etc/bind/named-hsh.conf | uniq >/etc/bind/named-hsh.conf.tmp" + " && mv /etc/bind/named-hsh.conf.tmp /etc/bind/named-hsh.conf" + " && invoke-rc.d bind9 reload"); mainProcessor.appendProcessor(queueName, seczonesFileProcessor, queueName + ".hostsharing.net"); } Processor relayDomainsProcessor = null; String[] mailServerQueues = { "mail1", "mail2", "mail3" }; for (String queueName : mailServerQueues) { relayDomainsProcessor = new ShellProcessor("postmap -r -i /etc/postfix/relaydomains", domName + " anything"); mainProcessor.appendProcessor(queueName, relayDomainsProcessor, queueName + ".hostsharing.net"); } mainProcessor.appendProcessor("backupmx", smtpTransportsProcessor, "backupmx.hostsharing.net"); String domsDir = domUser.getHomedir() + "/doms"; String domainDir = domsDir + "/" + dom.getName(); String[] subDirs = new String[] { "htdocs", "htdocs-ssl", "subs", "subs/www", "subs-ssl", "subs-ssl/www", "cgi", "fastcgi", "cgi-ssl", "fastcgi-ssl", "etc", "var" }; String pacName = pac.getName(); String userName = domUser.getName(); Processor mkDomainDirProzessor = new ShellProcessor( "mkdir --mode=1550 --parents " + domsDir + " && " + "chown httpd:" + pacName + " " + domsDir + " && " + "mkdir --mode=750 " + domainDir + " && " + "chown " + userName + ":httpd " + domainDir ); CompoundProcessor domDirsProcessor = new CompoundProcessor(mkDomainDirProzessor); for (String subDir : subDirs) { domDirsProcessor.appendProcessor(new ShellProcessor( "mkdir --mode=755 " + domainDir + "/" + subDir + " && " + "chown " + userName + ":" + pacName + " " + domainDir + "/" + subDir )); } templateVars = new HashMap(); templateVars.put("DOMAIN", domName); templateVars.put("USER_NAME", domUser.getComment()); templateVars.put("PROTOCOL", "http"); domDirsProcessor.appendProcessor( new CreateFileProcessor("/de/hsadmin/mods/dom/htaccess.jtpl", templateVars, domainDir + "/htdocs/.htaccess", userName, pacName, "644") ); templateVars.put("PROTOCOL", "https"); domDirsProcessor.appendProcessor( new CreateFileProcessor("/de/hsadmin/mods/dom/htaccess.jtpl", templateVars, domainDir + "/htdocs-ssl/.htaccess", userName, pacName, "644") ); domDirsProcessor.appendProcessor( new CreateFileProcessor("/de/hsadmin/mods/dom/index.html.jtpl", templateVars, domainDir + "/subs/www/index.html", userName, pacName, "644") ); domDirsProcessor.appendProcessor( new CreateFileProcessor("/de/hsadmin/mods/dom/index.html.jtpl", templateVars, domainDir + "/subs-ssl/www/index.html", userName, pacName, "644") ); domDirsProcessor.appendProcessor( new CreateFileProcessor("/de/hsadmin/mods/dom/test.cgi.jtpl", templateVars, domainDir + "/cgi/test.cgi", userName, pacName, "755") ); domDirsProcessor.appendProcessor( new CreateFileProcessor("/de/hsadmin/mods/dom/test.cgi.jtpl", templateVars, domainDir + "/cgi-ssl/test.cgi", userName, pacName, "755") ); domDirsProcessor.appendProcessor( new CopyFileProcessor("/usr/local/src/phpstub/phpstub", domainDir + "/fastcgi/phpstub", userName, pacName, "755") ); domDirsProcessor.appendProcessor( new CopyFileProcessor("/usr/local/src/phpstub/phpstub", domainDir + "/fastcgi-ssl/phpstub", userName, pacName, "755") ); domDirsProcessor.appendProcessor( new ShellProcessor("ln -s " + domainDir + " /home/doms/ && " + "chown --no-dereference " + userName + ":" + pacName + " /home/doms/" + domName + " && " + "chown " + userName + ":httpd /home/doms/" + domName + "/") ); mainProcessor.appendProcessor(hiveName, domDirsProcessor, "Setup doms/" + domName + "-Directory"); Processor domSetupProcessor = new ShellProcessor("mk-httpd-conf " + pacName + " && invoke-rc.d apache2 reload >/dev/null 2>&1"); mainProcessor.appendProcessor(hiveName, domSetupProcessor, "Setup Apache VHost"); return mainProcessor; } /** * @return a Processor which updates a domain */ public Processor createUpdateProcessor(EntityManager em, T entity) { return null; } /** * @return a Processor which deletes a domain */ public Processor createDeleteProcessor(EntityManager em, T entity) { Domain dom = (Domain) entity; String domName = dom.getName(); ShellProcessor emailAddressRemoveProcessor = new ShellProcessor("for KEY in $(postmap -s /etc/postfix/virtual|grep " + domName + "|cut -f1); do postmap -d $KEY /etc/postfix/virtual; done"); ShellProcessor dnsRemoveRemoveProcessor = new ShellProcessor("grep -v pri." + domName + " /etc/bind/named.pri-zones > /etc/bind/named.pri-zones.tmp" + " && mv /etc/bind/named.pri-zones.tmp /etc/bind/named.pri-zones" + " && rm /etc/bind/pri." + domName + " && invoke-rc.d bind9 reload"); WaitingTasksProcessor mainProcessor = new WaitingTasksProcessor(new CompoundProcessor(emailAddressRemoveProcessor, dnsRemoveRemoveProcessor)); Processor seczonesFileProcessor = null; String[] dnsQueues = { "dns1", "dns2", "dns3" }; for (String queueName : dnsQueues) { seczonesFileProcessor = new ShellProcessor("grep -v sec." + domName + " /etc/bind/named-hsh.conf >/etc/bind/named-hsh.conf.tmp" + " && mv /etc/bind/named-hsh.conf.tmp /etc/bind/named-hsh.conf" + " && rm /var/cache/bind/sec." + domName + " && invoke-rc.d bind9 reload"); mainProcessor.appendProcessor(queueName, seczonesFileProcessor, queueName + ".hostsharing.net"); } Processor mailQueueProcessor = null; String[] mailServerQueues = { "mail1", "mail2", "mail3" }; for (String queueName : mailServerQueues) { mailQueueProcessor = new ShellProcessor("postmap -d '" + domName + "' /etc/postfix/relaydomains"); mainProcessor.appendProcessor(queueName, mailQueueProcessor, queueName + ".hostsharing.net"); } Processor vhostDelProcessor = new ShellProcessor("rm /home/doms/" + domName + " && rm -rf " + dom.getUser().getHomedir() + "/doms/" + domName + " && rm /etc/apache2/sites-generated/" + domName + " && rm /etc/apache2/sites-*/`ls -1 /etc/apache2/sites-enabled/ | egrep \"^[01]+-" + domName + "$\"`" + " && invoke-rc.d apache2 reload >/dev/null 2>&1"); mainProcessor.appendProcessor(dom.getHiveName(), vhostDelProcessor, "remove apache vhost"); Processor smtpRelayDelProcessor = new ShellProcessor("grep -v " + domName + " /etc/postfix/relaydomains > /etc/postfix/relaydomains.tmp" + " && mv /etc/postfix/relaydomains.tmp /etc/postfix/relaydomains" + " && invoke-rc.d postfix reload"); mainProcessor.appendProcessor("backupmx", smtpRelayDelProcessor, "backupmx.hostsharing.net"); return mainProcessor; } }