EDIT

// $Id$

/**

* Copyright (C) 2014 EDIT

* European Distributed Institute of Taxonomy

* http://www.e-taxonomy.eu

*

* The contents of this file are subject to the Mozilla Public License Version 1.1

* See LICENSE.TXT at the top of this package for the full license terms.

*/

package eu.etaxonomy.taxeditor.session;

import java.util.ArrayList;

import java.util.Collection;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.apache.log4j.Logger;

import org.springframework.stereotype.Component;

import eu.etaxonomy.cdm.model.common.CdmBase;

/**

 * @author cmathew

 * @date 16 Oct 2014

 *

 */

@Component

public class CdmEntitySessionManager implements ICdmEntitySessionManager {

	private static final Logger logger = Logger.getLogger(CdmEntitySessionManager.class);

    private final Map<ICdmEntitySessionEnabled, ICdmEntitySession> ownerSessionMap =

    		new HashMap<ICdmEntitySessionEnabled, ICdmEntitySession>();

    private final List<ICdmEntitySessionManagerObserver> sessionObservers = new ArrayList<ICdmEntitySessionManagerObserver>();

    private ICdmEntitySession activeSession;

    @Override

	public ICdmEntitySession newSession(ICdmEntitySessionEnabled sessionOwner, boolean setAsActive) {

		ICdmEntitySession session = ownerSessionMap.get(sessionOwner);

		if(session == null) {

			session = new CdmEntitySession(sessionOwner, this);

			addToOwnerSessionMap(sessionOwner, session);

		}

		if(setAsActive) {

			activeSession = session;

		}

		return session;

	}

    @Override

    public ICdmEntitySession getActiveSession() {

        return activeSession;

    }

    /* (non-Javadoc)

     * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#getSessions()

     */

    @Override

    public Collection<ICdmEntitySession> getSessions() {

        return ownerSessionMap.values();

    }

	/* (non-Javadoc)

	 * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#bind(eu.etaxonomy.taxeditor.session.ISessionEventListener)

	 */

	@Override

	public void bind(ICdmEntitySessionEnabled sessionOwner) {

		if(sessionOwner == null) {

			activeSession = null;

			return;

		}

		ICdmEntitySession session  = ownerSessionMap.get(sessionOwner);

		if(session == null) {

			session = newSession(sessionOwner,true);

		}

		activeSession = session;

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#load(T)

	 */

	@Override

	public <T extends Object> T load(T obj) {

		if(activeSession == null) {

			return obj;

		} else {

			return activeSession.load(obj);

		}

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#load(T)

	 */

	@Override

	public <T extends CdmBase> T load(T cdmBase) {

		if(activeSession == null) {

			return cdmBase;

		}

		return activeSession.load(cdmBase);

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#load(java.util.Collection)

	 */

	@Override

	public <T extends CdmBase> Collection<T> load(Collection<T> cdmBaseList) {

		if(activeSession == null) {

			return cdmBaseList;

		}

		return activeSession.load(cdmBaseList);

	}

	/* (non-Javadoc)

	 * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#dispose(eu.etaxonomy.taxeditor.session.ISessionEventListener)

	 */

	void dispose(ICdmEntitySessionEnabled owner) {

		ICdmEntitySession session = ownerSessionMap.get(owner);

		if(session == null) {

			logger.info("No Session connected to owner, nothing to dispose");

			return;

		}

		if(session == activeSession) {

		    activeSession = null;

		}

		ownerSessionMap.remove(owner);

		notifyObservers();

	}

	 void addToOwnerSessionMap(ICdmEntitySessionEnabled owner, ICdmEntitySession session) {

		ownerSessionMap.put(owner, session);

	}

    /* (non-Javadoc)

     * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#addSessionListener()

     */

    @Override

    public void addSessionObserver(ICdmEntitySessionManagerObserver sessionObserver) {

        sessionObservers.add(sessionObserver);

    }

    public void notifyObservers() {

        for(ICdmEntitySessionManagerObserver sessionObserver : sessionObservers) {

            sessionObserver.changed();

        }

    }

    /* (non-Javadoc)

     * @see eu.etaxonomy.taxeditor.session.ICdmEntitySessionManager#isRemoting()

     */

    @Override

    public boolean isRemoting() {

        // FIXME:Remoting stupid method to check whether we are in remoting

        return true;

    }

}