Subversion Repositories general

package ak.hostadmiral.core.model;

import java.util.*;

import net.sf.hibernate.*;

import net.sf.hibernate.type.Type;

import ak.hostadmiral.util.CollectionInfo;

import ak.hostadmiral.util.HibernateUtil;

import ak.hostadmiral.util.ModelException;

import ak.hostadmiral.util.ModelSecurityException;

public class MailAliasManager

	implements

		UserBeforeDeleteListener,

		UserDeletingListener,

		InetDomainBeforeDeleteListener,

		InetDomainDeletingListener

{

	private static MailAliasManager mailAliasManager = null;

	private static boolean registered = false;

	public static MailAliasManager getInstance()

	{

		if(mailAliasManager == null)

			mailAliasManager = new MailAliasManager();

		return mailAliasManager;

	}

	protected static void register()

	{

		synchronized(MailAliasManager.class) {

			if(registered) return;

			registered = true;

			try {

				HibernateUtil.getConfiguration().addResource(

					"ak/hostadmiral/core/model/MailAlias.hbm.xml");

			}

			catch(Exception ex) {

				ex.printStackTrace();

				throw new RuntimeException(ex.getMessage());

			}

		}

	}

	static {

		register();

	}

	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();

	private MailAliasManager()

	{

		UserManager.getInstance().addBeforeDeleteListener(this);

	}

	public MailAlias create(User editor)

		throws ModelException

	{

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

		MailAlias alias = new MailAlias();

		alias.setDestinations(new ArrayList());

		return alias;

	}

	public boolean allowedToCreate(User editor)

		throws ModelException

	{

		return MailAlias.allowedToCreate(this, editor);

	}

	public MailAlias get(User editor, Long id)

		throws ModelException

	{

		MailAlias alias;

		try {

			alias = (MailAlias)HibernateUtil.currentSession().load(MailAlias.class, id);

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

		if(!alias.viewableBy(editor))

			throw new ModelSecurityException();

		return alias;

	}

	public boolean addressExists(User editor, MailAlias alias, String address)

		throws ModelException

	{

		if(alias.getDomain() == null)

			throw new ModelException("Cannot check unique address for mail alias without domain");

		try {

			if(alias.getId() == null)

				return ((Integer)HibernateUtil.currentSession().iterate(

					"select count(*) from MailAlias where address = ? and domain = ?",

					new Object[] { address, alias.getDomain() },

					new Type[] { Hibernate.STRING, Hibernate.entity(InetDomain.class) } )

					.next()).intValue() > 0;

			else

				return ((Integer)HibernateUtil.currentSession().iterate(

					"select count(*) from MailAlias a where address = ? and domain = ? and a != ?",

					new Object[] { address, alias.getDomain(), alias },

					new Type[] { Hibernate.STRING, Hibernate.entity(InetDomain.class),

						Hibernate.entity(MailAlias.class) } )

					.next()).intValue() > 0;

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

	}

	protected MailAlias findForName(String name)

		throws ModelException

	{

		try {

			List list = HibernateUtil.currentSession().find(

				"select a from MailAlias a left join fetch a.domain"

				+ " left join fetch a.owner where a.name=?", name, Hibernate.STRING);

			if(list.size() == 0)

				return null;

			else

				return (MailAlias)list.get(0);

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

	}

	public void save(User editor, MailAlias mailAlias)

		throws ModelException

	{

		if(!mailAlias.editableBy(editor))

			throw new ModelSecurityException();

        boolean isNew = mailAlias.isNew();

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

		try {

			HibernateUtil.currentSession().saveOrUpdate(mailAlias);

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

        // inform listeners

        if(isNew) {

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

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

    			listener.mailAliasCreated(editor, mailAlias);

        	}

        }

        else {

            MailAlias oldMailAlias = mailAlias.getOrigin();

            if(oldMailAlias == null) oldMailAlias = mailAlias;

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

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

    			listener.mailAliasModified(editor, mailAlias, oldMailAlias);

        	}

        }

	}

    public void addCreatedListener(MailAliasCreatedListener listener)

    {

    	createdListeners.add(listener);

    }

    public void removeCreatedListener(MailAliasCreatedListener listener)

    {

    	createdListeners.remove(listener);

    }

    public void addModifiedListener(MailAliasModifiedListener listener)

    {

    	modifiedListeners.add(listener);

    }

    public void removeModifiedListener(MailAliasModifiedListener listener)

    {

    	modifiedListeners.remove(listener);

    }

    public void addBeforeDeleteListener(MailAliasBeforeDeleteListener listener)

    {

    	beforeDeleteListeners.add(listener);

    }

    public void removeBeforeDeleteListener(MailAliasBeforeDeleteListener listener)

    {

    	beforeDeleteListeners.remove(listener);

    }

    public void addDeletingListener(MailAliasDeletingListener listener)

    {

    	deletingListeners.add(listener);

    }

    public void removeDeletingListener(MailAliasDeletingListener listener)

    {

    	deletingListeners.remove(listener);

    }

    public void addDeletedListener(MailAliasDeletedListener listener)

    {

    	deletedListeners.add(listener);

    }

    public void removeDeletedListener(MailAliasDeletedListener listener)

    {

    	deletedListeners.remove(listener);

    }

    public Collection beforeDelete(User editor, MailAlias mailAlias, Collection known)

		throws ModelException

    {

    	Collection cascade = new ArrayList();

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

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

			Collection subcascade = listener.mailAliasBeforeDelete(editor, mailAlias, known);

    		if(subcascade != null)

    			cascade.addAll(subcascade);

    	}

    	return cascade;

    }

	public void delete(User editor, MailAlias mailAlias)

		throws ModelException

	{

	    // check rights

		if(!mailAlias.deleteableBy(editor))

			throw new ModelSecurityException();

        // inform deleting listeners

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

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

			listener.mailAliasDeleting(editor, mailAlias);

    	}

        // backup copy

        MailAlias oldMailAlias = new MailAlias(mailAlias);

        // delete it

		try {

			HibernateUtil.currentSession().delete(mailAlias);

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

        // inform deleted listeners

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

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

			listener.mailAliasDeleted(editor, oldMailAlias);

    	}

	}

	public Collection listMailAliases(User editor)

		throws ModelException

	{

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

	}

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

			Integer[] sortingKeys, User editor)

		throws ModelException

	{

		try {

			if(editor.isSuperuser()) {

				if(info != null) {

					info.init(((Integer)HibernateUtil.currentSession().iterate(

						"select count(*) from MailAlias").next()).intValue(),

						pageNumber, rowsPerPage);

				}

				return HibernateUtil.pageableList(rowsPerPage, pageNumber,

					"select a from MailAlias a left join fetch a.domain as d"

					+ " left join fetch a.owner"

					+ HibernateUtil.formOrderClause(sortingKeys, sortKeys), null, null);

			}

			else {

				if(info != null) {

					List countlist = HibernateUtil.sqlQuery(

						"select count(*) from ("

						+ " select a.id from mailaliases a"

						+ "   where a.owner=?"

						+ " union"

						+ " select a.id from mailaliases a"

						+ "   left join domains as d on a.domain = d.id"

						+ "   where d.owner=?"

						+ ") as count_table",

						new Object[] { editor.getId(), editor.getId() });

					info.init(((Long)countlist.get(0)).intValue(),

						pageNumber, rowsPerPage);

				}

				return HibernateUtil.pageableListSql(rowsPerPage, pageNumber,

					"(select {a.*}, {d.*}, {o.*}"

					+ "   from      mailaliases as a"

					+ "   left join domains     as d on a.domain = d.id"

					+ "   left join users       as o on a.owner  = o.id"

					+ " where a.owner=?)"

					+ " union "

					+ "(select {a.*}, {d.*}, {o.*}"

					+ "   from      mailaliases as a"

					+ "   left join domains     as d on a.domain = d.id"

					+ "   left join users       as o on a.owner  = o.id"

					+ " where d.owner=?)"

					+ HibernateUtil.formOrderClause(sortingKeys, sortKeysSql),

					new String[] { "a", "d", "o" },

					new Class[] { MailAlias.class, InetDomain.class, User.class },

					new Object[] { editor, editor },

					new Type[] { Hibernate.entity(User.class), Hibernate.entity(User.class) });

			}

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

	}

	public boolean areMailAliasesAvailable(User editor)

		throws ModelException

	{

		try {

			if(editor.isSuperuser()

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

			{

				return true;

			}

			else {

				return ((Integer)HibernateUtil.currentSession().iterate(

					"select count(*) from MailAlias a left join a.domain as d"

					+ " where d.owner=? or a.owner=?",

					new Object[] { editor, editor },

					new Type[] { Hibernate.entity(User.class), Hibernate.entity(User.class) })

					.next()).intValue() > 0;

			}

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

	}

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

		throws ModelException

	{

        Collection mailAliases;

		try {

			mailAliases = HibernateUtil.currentSession().find(

				"select a from MailAlias a left join fetch a.domain where a.owner = ?",

				user, Hibernate.entity(User.class) );

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

		return iterateBeforeDelete(editor, mailAliases, known);

    }

	public void userDeleting(User editor, User user)

		throws ModelException

	{

        Collection mailAliases;

		try {

			mailAliases = HibernateUtil.currentSession().find(

				"select a from MailAlias a left join fetch a.domain where a.owner = ?",

				user, Hibernate.entity(User.class) );

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

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

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

		}

    }

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

		throws ModelException

	{

        Collection mailAliases;

		try {

			mailAliases = HibernateUtil.currentSession().find(

				"select a from MailAlias a left join fetch a.owner where a.domain = ?",

				domain, Hibernate.entity(InetDomain.class) );

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

		return iterateBeforeDelete(editor, mailAliases, known);

    }

	public void inetDomainDeleting(User editor, InetDomain domain)

		throws ModelException

	{

        Collection mailAliases;

		try {

			mailAliases = HibernateUtil.currentSession().find(

				"select a from MailAlias a left join fetch a.owner where a.domain = ?",

				domain, Hibernate.entity(InetDomain.class) );

		}

		catch(HibernateException ex)

		{

			throw new ModelException(ex);

		}

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

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

		}

    }

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

		throws ModelException

	{

    	Collection cascade = new ArrayList();

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

			MailAlias mailAlias = (MailAlias)i.next();

            if(mailAlias.viewableBy(editor)) {

				if(mailAlias.deleteableBy(editor))

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

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

				else

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

						null));

			}

			else {

				cascade.add(new CascadeDeleteElement(MailAlias.createLimitedCopy(mailAlias),

					CascadeDeleteElement.FORBIDDEN, null));

			}

		}

    	return cascade;

	}

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

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

	protected static Map sortKeys = new HashMap();

	static {

		sortKeys.put(SORT_ADDRESS, "a.address");

		sortKeys.put(SORT_DOMAIN, "d.name");

	}

	protected static Map sortKeysSql = new HashMap();

	static {

		sortKeysSql.put(SORT_ADDRESS, "address0_");

		sortKeysSql.put(SORT_DOMAIN,  "name1_");

	}

	public static final Comparator ADDRESS_COMPARATOR = new AddressComparator();

	private static class AddressComparator

		implements Comparator

	{

		public int compare(Object o1, Object o2)

		{

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

				throw new ClassCastException("not a MailAlias");

		    MailAlias a1 = (MailAlias)o1;

		    MailAlias a2 = (MailAlias)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.getAddress().compareToIgnoreCase(a2.getAddress());

		}

		public boolean equals(Object obj)

		{

			return (obj instanceof AddressComparator);

		}

	}

}