| 6,46 → 6,59 |
|---|
| import java.io.Writer; |
| import java.io.BufferedWriter; |
| import java.io.OutputStreamWriter; |
| import java.io.Reader; |
| import java.io.BufferedReader; |
| import java.io.InputStreamReader; |
| import java.net.Socket; |
| import ak.hostadmiral.util.ModelException; |
| import ak.hostadmiral.util.ConfigInit; |
| import ak.hostadmiral.util.ConfigUtils; |
| import ak.hostadmiral.core.model.*; |
| |
| import org.apache.log4j.Logger; |
| |
| public class TcpListener |
| implements |
| ConfigInit, |
| UserCreatedListener, |
| UserModifiedListener, |
| UserDeletedListener, |
| InetDomainCreatedListener, |
| InetDomainModifiedListener, |
| InetDomainDeletedListener, |
| SystemUserCreatedListener, |
| SystemUserModifiedListener, |
| SystemUserDeletedListener, |
| MailboxCreatedListener, |
| MailboxModifiedListener, |
| MailboxDeletedListener, |
| MailAliasCreatedListener, |
| MailAliasModifiedListener, |
| MailAliasDeletedListener |
| implements |
| ConfigInit, |
| UserCreatedListener, |
| UserModifiedListener, |
| UserDeletedListener, |
| InetDomainCreatedListener, |
| InetDomainModifiedListener, |
| InetDomainDeletedListener, |
| SystemUserCreatedListener, |
| SystemUserModifiedListener, |
| SystemUserDeletedListener, |
| MailboxCreatedListener, |
| MailboxModifiedListener, |
| MailboxDeletedListener, |
| MailAliasCreatedListener, |
| MailAliasModifiedListener, |
| MailAliasDeletedListener |
| { |
| private static final Logger logger = Logger.getLogger(TcpListener.class); |
| |
| private static String hostname; |
| private static int port; |
| private static String password; |
| protected static Object lock = new Object(); |
| |
| public static final String PROTOCOL_NAME = "HostAdmiral_TcpListener"; |
| public static final String PROTOCOL_VERSION = "0.1"; |
| public static final String PROTOCOL_NAME = "HostAdmiral_TcpListener"; |
| public static final String PROTOCOL_VER_MAJ = "1"; |
| public static final String PROTOCOL_VER_MIN = "0"; |
| public static final String PASSWORD_DIGEST = "crypt"; |
| |
| public void init(Map params) |
| throws ModelException |
| { |
| setHostname(((String[])params.get("hostname"))[0]); |
| setPort(Integer.parseInt(((String[])params.get("port"))[0])); |
| ConfigUtils cfg = new ConfigUtils(params); |
| |
| // save params |
| setHostname(cfg.getString("hostname", "127.0.0.1", true, false)); |
| setPort(cfg.getInteger("port", null, false).intValue()); |
| setPassword(cfg.getString("password", null, true, true)); |
| |
| // register listeners |
| UserManager.getInstance().addCreatedListener(this); |
| UserManager.getInstance().addModifiedListener(this); |
| UserManager.getInstance().addDeletedListener(this); |
| 87,37 → 100,93 |
|---|
| port = port_; |
| } |
| |
| protected static String escape(String s) |
| { |
| // FIXME: any other problem characters? optimize it? |
| s = s.replaceAll("\0", "\\\\0"); |
| s = s.replaceAll("\\\\", "\\\\\\\\"); |
| s = s.replaceAll("\t", "\\\\t"); |
| s = s.replaceAll("\n", "\\\\n"); |
| s = s.replaceAll("\r", "\\\\r"); |
| return s; |
| } |
| public static void setPassword(String password_) |
| { |
| password = password_; |
| } |
| |
| protected static String escape(String s) |
| { |
| // FIXME: any other problem characters? optimize it? |
| s = s.replaceAll("\\\\", "\\\\\\\\"); |
| s = s.replaceAll("\0", "\\\\0"); |
| s = s.replaceAll("\t", "\\\\t"); |
| s = s.replaceAll("\n", "\\\\n"); |
| s = s.replaceAll("\r", "\\\\r"); |
| return s; |
| } |
| |
| protected static void send(String message) |
| throws ModelException |
| { |
| synchronized(lock) { |
| try { |
| Socket socket = new Socket(hostname, port); |
| Writer out = new BufferedWriter( |
| new OutputStreamWriter(socket.getOutputStream())); |
| |
| if(PROTOCOL_NAME != null) { |
| out.write(PROTOCOL_NAME); |
| out.write(" "); |
| Socket socket = new Socket(hostname, port); |
| |
| // send request |
| Writer out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); |
| |
| out.write(PROTOCOL_NAME + " " + PROTOCOL_VER_MAJ + "." + PROTOCOL_VER_MIN + "\n"); |
| if(password != null) { |
| out.write("password=" + password + "\n"); |
| } |
| if(PROTOCOL_VERSION != null) { |
| out.write(PROTOCOL_VERSION); |
| out.write("\n"); |
| } |
| out.write(message); |
| out.write("\n\n"); |
| out.close(); |
| out.flush(); |
| socket.shutdownOutput(); |
| |
| // get response |
| BufferedReader in = new BufferedReader( |
| new InputStreamReader(socket.getInputStream())); |
| String line; |
| boolean headerDone = false; |
| boolean codeDone = false; |
| while((line = in.readLine()) != null) { |
| if(!headerDone) { |
| if(!line.matches("^" + PROTOCOL_NAME + " " + PROTOCOL_VER_MAJ + "\\.\\d+$")) |
| throw new ModelException( |
| "Wrong response: wrong header in [" + line + "]"); |
| |
| headerDone = true; |
| } |
| else if(!codeDone) { |
| if(line.length() < 3) |
| throw new ModelException( |
| "Wrong response: code too short [" + line + "]"); |
| if(line.length() >= 4 && line.charAt(3) != ' ') |
| throw new ModelException( |
| "Wrong response: cannot get code from [" + line + "]"); |
| |
| int code; |
| try { |
| code = Integer.parseInt(line.substring(0, 3)); |
| } |
| catch(NumberFormatException ex) { |
| throw new ModelException( |
| "Wrong response: cannot parse code from [" + line + "]"); |
| } |
| |
| String response = (line.length() >= 5) ? line.substring(4) : null; |
| |
| if(code >= 200 && code < 300) { |
| logger.info("Response from backend [" + line + "]"); |
| } |
| else if(code >= 400 && code < 600) { |
| throw new ModelException( |
| "Error from backend [" + line + "]"); |
| } |
| |
| codeDone = true; |
| } |
| else { |
| if(!line.equals("")) |
| throw new ModelException( |
| "Wrong response: no more lines expected [" + line + "]"); |
| } |
| } |
| |
| // done |
| socket.close(); |
| } |
| catch(Exception ex) { |
| logger.error("Cannot send message over TCP", ex); |
| 127,126 → 196,127 |
|---|
| } |
| } |
| |
| //=== user ==================================================================================== |
| //=== user ==================================================================================== |
| |
| public void userCreated(User editor, User user) |
| throws ModelException |
| { |
| send("user\tcreate\t" + escape(user.getLogin()) + "\t" |
| + escape(/* FIXME user.getPassword() */ "") + "\t" |
| + user.getEnabled() + "\t" |
| + escape(user.getComment())); |
| send("user\tcreate\tlogin=" + escape(user.getLogin()) |
| + "\tpassword=" + escape(user.getPassword(editor, PASSWORD_DIGEST)) |
| + "\tenabled=" + user.getEnabled() |
| + "\tcomment=" + escape(user.getComment())); |
| } |
| |
| public void userModified(User editor, User user, User oldUser) |
| throws ModelException |
| { |
| send("user\tmodify\t" + escape(oldUser.getLogin()) + "\t" |
| + escape(user.getLogin()) + "\t" |
| + escape(/* FIXME user.getPassword() */ "") + "\t" |
| + user.getEnabled() + "\t" |
| + escape(user.getComment())); |
| send("user\tmodify\toldLogin=" + escape(oldUser.getLogin()) |
| + "\tlogin=" + escape(user.getLogin()) |
| + "\tpassword=" + escape(user.getPassword(editor, PASSWORD_DIGEST)) |
| + "\tenabled=" + user.getEnabled() |
| + "\tcomment=" + escape(user.getComment())); |
| } |
| |
| public void userDeleted(User editor, User user) |
| throws ModelException |
| { |
| send("user\tdelete\t" + escape(user.getLogin())); |
| send("user\tdelete\tlogin=" + escape(user.getLogin())); |
| } |
| |
| //=== inet domain ============================================================================= |
| //=== inet domain ============================================================================= |
| |
| public void inetDomainCreated(User editor, InetDomain domain) |
| throws ModelException |
| { |
| send("inetDomain\tcreate\t" + escape(domain.getName()) + "\t" |
| + domain.getEnabled() + "\t" |
| + escape(domain.getComment())); |
| send("inetDomain\tcreate\tname=" + escape(domain.getName()) |
| + "\tenabled=" + domain.getEnabled() |
| + "\tcomment=" + escape(domain.getComment())); |
| } |
| |
| public void inetDomainModified(User editor, InetDomain domain, InetDomain oldDomain) |
| throws ModelException |
| { |
| send("inetDomain\tmodify\t" + escape(oldDomain.getName()) + "\t" |
| + escape(domain.getName()) + "\t" |
| + domain.getEnabled() + "\t" |
| + escape(domain.getComment())); |
| send("inetDomain\tmodify\toldName=" + escape(oldDomain.getName()) |
| + "\tname=" + escape(domain.getName()) |
| + "\tenabled=" + domain.getEnabled() |
| + "\tcomment=" + escape(domain.getComment())); |
| } |
| |
| public void inetDomainDeleted(User editor, InetDomain domain) |
| throws ModelException |
| { |
| send("inetDomain\tdelete\t" + escape(domain.getName())); |
| send("inetDomain\tdelete\tname=" + escape(domain.getName())); |
| } |
| |
| //=== system user ============================================================================= |
| //=== system user ============================================================================= |
| |
| public void systemUserCreated(User editor, SystemUser systemUser) |
| throws ModelException |
| { |
| send("systemUser\tcreate\t" + systemUser.getUid() + "\t" |
| + escape(systemUser.getName()) + "\t" |
| + systemUser.getEnabled() + "\t" |
| + escape(systemUser.getComment())); |
| send("systemUser\tcreate\tuid=" + systemUser.getUid() |
| + "\tname=" + escape(systemUser.getName()) |
| + "\tenabled=" + systemUser.getEnabled() |
| + "\tcomment=" + escape(systemUser.getComment())); |
| } |
| |
| public void systemUserModified(User editor, SystemUser systemUser, SystemUser oldSystemUser) |
| throws ModelException |
| { |
| send("systemUser\tmodify\t" + oldSystemUser.getUid() + "\t" |
| + escape(oldSystemUser.getName()) + "\t" |
| + systemUser.getUid() + "\t" |
| + escape(systemUser.getName()) + "\t" |
| + systemUser.getEnabled() + "\t" |
| + escape(systemUser.getComment())); |
| send("systemUser\tmodify\toldUid=" + oldSystemUser.getUid() |
| + "\toldName=" + escape(oldSystemUser.getName()) |
| + "\tuid=" + systemUser.getUid() |
| + "\tname=" + escape(systemUser.getName()) |
| + "\tenabled=" + systemUser.getEnabled() |
| + "\tcomment=" + escape(systemUser.getComment())); |
| } |
| |
| public void systemUserDeleted(User editor, SystemUser systemUser) |
| throws ModelException |
| { |
| send("systemUser\tdelete\t" + systemUser.getUid() + "\t" + escape(systemUser.getName())); |
| send("systemUser\tdelete\tuid=" + systemUser.getUid() |
| + "\tname=" + escape(systemUser.getName())); |
| } |
| |
| //=== mailbox ================================================================================= |
| //=== mailbox ================================================================================= |
| |
| public void mailboxCreated(User editor, Mailbox mailbox) |
| throws ModelException |
| { |
| send("mailbox\tcreate\t" + escape(mailbox.getLogin()) + "\t" |
| + escape(/* FIXME user.getPassword() */ "") + "\t" |
| + escape(mailbox.getDomain().getName()) + "\t" |
| + mailbox.getVirusCheck() + "\t" |
| + mailbox.getSpamCheck() + "\t" |
| + (mailbox.getSystemUser() == null ? "" : mailbox.getSystemUser().getUid().toString()) |
| + "\t" |
| + mailbox.getEnabled() + "\t" |
| + escape(mailbox.getComment())); |
| send("mailbox\tcreate\tlogin=" + escape(mailbox.getLogin()) |
| + "\tpassword=" + escape(mailbox.getPassword(editor, PASSWORD_DIGEST)) |
| + "\tdomain=" + escape(mailbox.getDomain().getName()) |
| + "\tvirusCheck=" + mailbox.getVirusCheck() |
| + "\tspamCheck=" + mailbox.getSpamCheck() |
| + "\tsystemUser=" + (mailbox.getSystemUser() == null |
| ? "" : mailbox.getSystemUser().getUid().toString()) |
| + "\tenabled=" + mailbox.getEnabled() |
| + "\tcomment=" + escape(mailbox.getComment())); |
| } |
| |
| public void mailboxModified(User editor, Mailbox mailbox, Mailbox oldMailbox) |
| throws ModelException |
| { |
| send("mailbox\tmodify\t" + escape(oldMailbox.getLogin()) + "\t" |
| + escape(oldMailbox.getDomain().getName()) + "\t" |
| + escape(mailbox.getLogin()) + "\t" |
| + escape(/* FIXME user.getPassword() */ "") + "\t" |
| + escape(mailbox.getDomain().getName()) + "\t" |
| + mailbox.getVirusCheck() + "\t" |
| + mailbox.getSpamCheck() + "\t" |
| + (mailbox.getSystemUser() == null ? "" : mailbox.getSystemUser().getUid().toString()) |
| + "\t" |
| + mailbox.getEnabled() + "\t" |
| + escape(mailbox.getComment())); |
| send("mailbox\tmodify\toldLogin=" + escape(oldMailbox.getLogin()) |
| + "\toldDomain=" + escape(oldMailbox.getDomain().getName()) |
| + "\tlogin=" + escape(mailbox.getLogin()) |
| + "\tpassword=" + escape(mailbox.getPassword(editor, PASSWORD_DIGEST)) |
| + "\tdomain=" + escape(mailbox.getDomain().getName()) |
| + "\tvirusCheck=" + mailbox.getVirusCheck() |
| + "\tspamCheck=" + mailbox.getSpamCheck() |
| + "\tsystemUser=" + (mailbox.getSystemUser() == null |
| ? "" : mailbox.getSystemUser().getUid().toString()) |
| + "\tenabled=" + mailbox.getEnabled() |
| + "\tcomment=" + escape(mailbox.getComment())); |
| } |
| |
| public void mailboxDeleted(User editor, Mailbox mailbox) |
| throws ModelException |
| { |
| send("mailbox\tdelete\t" + escape(mailbox.getLogin()) + "\t" |
| + escape(mailbox.getDomain().getName())); |
| send("mailbox\tdelete\tlogin=" + escape(mailbox.getLogin()) |
| + "\tdomain=" + escape(mailbox.getDomain().getName())); |
| } |
| |
| //=== mail alias ============================================================================== |
| //=== mail alias ============================================================================== |
| |
| private String formMailAliasDestinations(User editor, MailAlias mailAlias) |
| throws ModelException |
| 271,29 → 341,29 |
|---|
| public void mailAliasCreated(User editor, MailAlias mailAlias) |
| throws ModelException |
| { |
| send(" mailAlias\tcreate\t" + escape(mailAlias.getAddress()) + "\t" |
| + escape(mailAlias.getDomain().getName()) + "\t" |
| + mailAlias.getEnabled() + "\t" |
| + escape(mailAlias.getComment()) |
| + formMailAliasDestinations(editor, mailAlias)); |
| send("mailAlias\tcreate\taddress=" + escape(mailAlias.getAddress()) |
| + "\tdomain=" + escape(mailAlias.getDomain().getName()) |
| + "\tenabled=" + mailAlias.getEnabled() |
| + "\tcomment=" + escape(mailAlias.getComment()) |
| + formMailAliasDestinations(editor, mailAlias)); |
| } |
| |
| public void mailAliasModified(User editor, MailAlias mailAlias, MailAlias oldMailAlias) |
| throws ModelException |
| { |
| send(" mailAlias\tmodify\t" + escape(oldMailAlias.getAddress()) + "\t" |
| + escape(oldMailAlias.getDomain().getName()) + "\t" |
| + escape(mailAlias.getAddress()) + "\t" |
| + escape(mailAlias.getDomain().getName()) + "\t" |
| + mailAlias.getEnabled() + "\t" |
| + escape(mailAlias.getComment()) |
| + formMailAliasDestinations(editor, mailAlias)); |
| send("mailAlias\tmodify\toldAddress=" + escape(oldMailAlias.getAddress()) |
| + "\toldDomain=" + escape(oldMailAlias.getDomain().getName()) |
| + "\taddress=" + escape(mailAlias.getAddress()) |
| + "\tdomain=" + escape(mailAlias.getDomain().getName()) |
| + "\tenabled=" + mailAlias.getEnabled() |
| + "\tcomment=" + escape(mailAlias.getComment()) |
| + formMailAliasDestinations(editor, mailAlias)); |
| } |
| |
| public void mailAliasDeleted(User editor, MailAlias mailAlias) |
| throws ModelException |
| { |
| send(" mailAlias\tdelete\t" + escape(mailAlias.getAddress())+ "\t" |
| + escape(mailAlias.getDomain().getName())); |
| send("mailAlias\tdelete\taddress=" + escape(mailAlias.getAddress()) |
| + "\tdomain=" + escape(mailAlias.getDomain().getName())); |
| } |
| } |