Subversion Repositories general

package ak.hostadmiral.core.model;

import java.util.Collection;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.Map;

import java.util.Comparator;

import ak.hostadmiral.util.ConfigInit;

import ak.hostadmiral.util.CollectionInfo;

import ak.hostadmiral.util.ModelException;

import ak.hostadmiral.util.ModelSecurityException;

import ak.hostadmiral.core.model.store.MailboxStore;

public class MailboxManager

	implements

		ConfigInit,

		UserBeforeDeleteListener,

		UserDeletingListener,

		SystemUserBeforeDeleteListener,

		SystemUserDeletingListener,

		InetDomainBeforeDeleteListener,

		InetDomainDeletingListener

{

	private MailboxStore store;

	private Class[]      passwordStores;

	private Collection validateListeners     = new ArrayList();

	private Collection createdListeners      = new ArrayList();

	private Collection modifiedListeners     = new ArrayList();

	private Collection beforeDeleteListeners = new ArrayList();

	private Collection deletingListeners     = new ArrayList();

	private Collection deletedListeners      = new ArrayList();

	public MailboxManager()

		throws ModelException

	{

		UserManager.getInstance().addBeforeDeleteListener(this);

		UserManager.getInstance().addDeletingListener(this);

		SystemUserManager.getInstance().addBeforeDeleteListener(this);

		SystemUserManager.getInstance().addDeletingListener(this);

		InetDomainManager.getInstance().addBeforeDeleteListener(this);

		InetDomainManager.getInstance().addDeletingListener(this);

	}

	public Mailbox create(User editor)

		throws ModelException

	{

		if(!allowedToCreate(editor)) throw new ModelSecurityException();

		Mailbox mailbox = new Mailbox();

        setMailboxPasswordStores(mailbox);

		return mailbox;

	}

	public boolean allowedToCreate(User editor)

		throws ModelException

	{

		return Mailbox.allowedToCreate(this, editor);

	}

	public Mailbox get(User editor, Long id)

		throws ModelException

	{

		Mailbox mailbox = store.get(id);

		if(!mailbox.viewableBy(editor))

			throw new ModelSecurityException();

		return mailbox;

	}

	public boolean loginExists(User editor, Mailbox mailbox, String login)

		throws ModelException

	{

		if(mailbox.getDomain() == null)

			throw new ModelException("Cannot check unique login for mailbox without domain");

		return store.loginExists(mailbox, login);

	}

	public Mailbox findForLogin(User editor, String login)

		throws ModelException

	{

		Mailbox mailbox = store.findForLogin(login);

		if(!mailbox.viewableBy(editor))

			throw new ModelSecurityException();

		return mailbox;

	}

	public void save(User editor, Mailbox mailbox)

		throws ModelException

	{

		// security check

		if(!mailbox.editableBy(editor))

			throw new ModelSecurityException();

		//mailbox.setModUser(editor); // FIXME

        boolean isNew = mailbox.isNew();

        Mailbox oldMailbox = mailbox.getOrigin();

        if(oldMailbox == null) oldMailbox = mailbox;

		// validate

    	for(Iterator i = validateListeners.iterator(); i.hasNext(); ) {

    		MailboxValidateListener listener = (MailboxValidateListener)i.next();

			listener.mailboxValidate(editor, mailbox, oldMailbox);

    	}

		store.save(mailbox);

        // inform listeners

        if(isNew) {

        	for(Iterator i = createdListeners.iterator(); i.hasNext(); ) {

        		MailboxCreatedListener listener = (MailboxCreatedListener)i.next();

    			listener.mailboxCreated(editor, mailbox);

        	}

        }

        else {

        	for(Iterator i = modifiedListeners.iterator(); i.hasNext(); ) {

        		MailboxModifiedListener listener = (MailboxModifiedListener)i.next();

    			listener.mailboxModified(editor, mailbox, oldMailbox);

        	}

        }

        // reset backup

        mailbox.resetOrigin();

	}

    public void addValidateListener(MailboxValidateListener listener)

    {

    	validateListeners.add(listener);

    }

    public void removeValidateListener(MailboxValidateListener listener)

    {

    	validateListeners.remove(listener);

    }

    public void addCreatedListener(MailboxCreatedListener listener)

    {

    	createdListeners.add(listener);

    }

    public void removeCreatedListener(MailboxCreatedListener listener)

    {

    	createdListeners.remove(listener);

    }

    public void addModifiedListener(MailboxModifiedListener listener)

    {

    	modifiedListeners.add(listener);

    }

    public void removeModifiedListener(MailboxModifiedListener listener)

    {

    	modifiedListeners.remove(listener);

    }

    public void addBeforeDeleteListener(MailboxBeforeDeleteListener listener)

    {

    	beforeDeleteListeners.add(listener);

    }

    public void removeBeforeDeleteListener(MailboxBeforeDeleteListener listener)

    {

    	beforeDeleteListeners.remove(listener);

    }

    public void addDeletingListener(MailboxDeletingListener listener)

    {

    	deletingListeners.add(listener);

    }

    public void removeDeletingListener(MailboxDeletingListener listener)

    {

    	deletingListeners.remove(listener);

    }

    public void addDeletedListener(MailboxDeletedListener listener)

    {

    	deletedListeners.add(listener);

    }

    public void removeDeletedListener(MailboxDeletedListener listener)

    {

    	deletedListeners.remove(listener);

    }

    public Collection beforeDelete(User editor, Mailbox mailbox, Collection known)

		throws ModelException

    {

    	Collection cascade = new ArrayList();

    	for(Iterator i = beforeDeleteListeners.iterator(); i.hasNext(); ) {

    		MailboxBeforeDeleteListener listener = (MailboxBeforeDeleteListener)i.next();

			Collection subcascade = listener.mailboxBeforeDelete(editor, mailbox, known);

    		if(subcascade != null)

    			cascade.addAll(subcascade);

    	}

    	return cascade;

    }

	public void delete(User editor, Mailbox mailbox)

		throws ModelException

	{

	    // check rights

		if(!mailbox.deleteableBy(editor))

			throw new ModelSecurityException();

        // inform deleting listeners

    	for(Iterator i = deletingListeners.iterator(); i.hasNext(); ) {

    		MailboxDeletingListener listener = (MailboxDeletingListener)i.next();

			listener.mailboxDeleting(editor, mailbox);

    	}

        // backup copy

        Mailbox oldMailbox = new Mailbox(mailbox);

        // delete it

		store.delete(mailbox);

        // inform deleted listeners

    	for(Iterator i = deletedListeners.iterator(); i.hasNext(); ) {

    		MailboxDeletedListener listener = (MailboxDeletedListener)i.next();

			listener.mailboxDeleted(editor, oldMailbox);

    	}

	}

	public Collection listMailboxes(User editor)

		throws ModelException

	{

		return listMailboxes(null, 0, 0, null, editor);

	}

	public Collection listMailboxes(CollectionInfo info, int rowsPerPage, int pageNumber,

			Integer[] sortingKeys, User editor)

		throws ModelException

	{

		if(editor.isSuperuser())

			return store.listAllMailboxes(info, rowsPerPage, pageNumber, sortingKeys);

		else

			return store.listMailboxes(info, rowsPerPage, pageNumber, sortingKeys, editor);

	}

	public boolean areMailboxesAvailable(User editor)

		throws ModelException

	{

		if(editor.isSuperuser() || InetDomainManager.getInstance().areInetDomainsAvailable(editor))

			return true;

		else

			return store.countMailboxesAvailable(editor) > 0;

	}

	public Collection userBeforeDelete(User editor, User user, Collection known)

		throws ModelException

	{

        Collection mailboxes = store.listOwnMailboxes(user);

		return iterateBeforeDelete(editor, mailboxes, known);

    }

	public void userDeleting(User editor, User user)

		throws ModelException

	{

        Collection mailboxes = store.listOwnMailboxes(user);

		for(Iterator i = mailboxes.iterator(); i.hasNext(); ) {

			delete(editor, (Mailbox)i.next());

		}

    }

	public Collection inetDomainBeforeDelete(User editor, InetDomain domain, Collection known)

		throws ModelException

	{

        Collection mailboxes = store.listMailboxesForDomain(domain);

		return iterateBeforeDelete(editor, mailboxes, known);

    }

	public void inetDomainDeleting(User editor, InetDomain domain)

		throws ModelException

	{

        Collection mailboxes = store.listMailboxesForDomain(domain);

		for(Iterator i = mailboxes.iterator(); i.hasNext(); ) {

			delete(editor, (Mailbox)i.next());

		}

    }

	public Collection systemUserBeforeDelete(User editor, SystemUser user, Collection known)

		throws ModelException

	{

        Collection mailboxes = store.listMailboxesForSystemUser(user);

		return iterateBeforeDelete(editor, mailboxes, known);

    }

	public void systemUserDeleting(User editor, SystemUser user)

		throws ModelException

	{

        Collection mailboxes = store.listMailboxesForSystemUser(user);

		for(Iterator i = mailboxes.iterator(); i.hasNext(); ) {

			// FIXME do not delete, just reset system user (?)

			delete(editor, (Mailbox)i.next());

		}

    }

	private Collection iterateBeforeDelete(User editor, Collection mailboxes, Collection known)

		throws ModelException

	{

    	Collection cascade = new ArrayList();

		for(Iterator i = mailboxes.iterator(); i.hasNext(); ) {

			Mailbox mailbox = (Mailbox)i.next();

			if(known.contains(mailbox)) continue;

			known.add(mailbox);

            if(mailbox.viewableBy(editor)) {

				if(mailbox.deleteableBy(editor))

					cascade.add(new CascadeDeleteElement(mailbox, CascadeDeleteElement.DELETE,

						this.beforeDelete(editor, mailbox, known)));

				else

					cascade.add(new CascadeDeleteElement(mailbox, CascadeDeleteElement.FORBIDDEN,

						null));

			}

			else {

				cascade.add(new CascadeDeleteElement(Mailbox.createLimitedCopy(mailbox),

					CascadeDeleteElement.FORBIDDEN, null));

			}

		}

    	return cascade;

	}

	protected void setMailboxPasswordStores(Mailbox mailbox)

		throws ModelException

	{

		if(passwordStores == null) return;

   		try {

			for(int i = 0; i < passwordStores.length; i++)

				mailbox.addPasswordStore((PasswordStore)passwordStores[i].newInstance());

        }

        catch(Exception ex) {

        	throw new ModelException(ex);

        }

	}

	public static final Integer SORT_LOGIN  = new Integer(1);

	public static final Integer SORT_DOMAIN = new Integer(2);

	public static final Comparator LOGIN_COMPARATOR  = new LoginComparator();

	public static final Comparator DOMAIN_COMPARATOR = new DomainComparator();

	private static class LoginComparator

		implements Comparator

	{

		public int compare(Object o1, Object o2)

		{

			if(!(o1 instanceof Mailbox) || !(o2 instanceof Mailbox))

				throw new ClassCastException("not a Mailbox");

		    Mailbox a1 = (Mailbox)o1;

		    Mailbox a2 = (Mailbox)o2;

		    if(a1 == null && a2 == null)

		    	return 0;

		    else if(a1 == null && a2 != null)

		    	return -1;

		    else if(a1 != null && a2 == null)

		    	return 1;

		    else

		    	return a1.getLogin().compareToIgnoreCase(a2.getLogin());

		}

		public boolean equals(Object obj)

		{

			return (obj instanceof LoginComparator);

		}

	}

	private static class DomainComparator

		implements Comparator

	{

		public int compare(Object o1, Object o2)

		{

			if(!(o1 instanceof Mailbox) || !(o2 instanceof Mailbox))

				throw new ClassCastException("not a Mailbox");

		    Mailbox a1 = (Mailbox)o1;

		    Mailbox a2 = (Mailbox)o2;

		    if(a1 == null && a2 == null)

		    	return 0;

		    else if(a1 == null && a2 != null)

		    	return -1;

		    else if(a1 != null && a2 == null)

		    	return 1;

		    else

		    	return a1.getDomain().getName().compareToIgnoreCase(a2.getDomain().getName());

		}

		public boolean equals(Object obj)

		{

			return (obj instanceof DomainComparator);

		}

	}

	public void init(Map params)

		throws ModelException

	{

		try {

    		mailboxManager = this;

			Class c = Class.forName(((String[])params.get("store"))[0]);

			store = (MailboxStore)c.newInstance();

			String[] passwordStoreNames = (String[])params.get("passwordStore");

			if(passwordStoreNames != null) {

				passwordStores = new Class[passwordStoreNames.length];

				for(int i = 0; i < passwordStoreNames.length; i++) {

					passwordStores[i] = Class.forName(passwordStoreNames[i]);

				}

			}

        }

        catch(Exception ex) {

        	throw new ModelException(ex);

        }

	}

	private static MailboxManager mailboxManager = null;

	public static MailboxManager getInstance()

	{

		return mailboxManager;

	}

}