// This Source Code is in the Public Domain per: http://unlicense.org
package org.litesoft.GWT.eventbus.server.nonpublic;

import javax.servlet.http.*;

import org.litesoft.GWT.eventbus.server.*;
import org.litesoft.logger.*;

public class ServerEventBusSessionMapper
{
    private static final Logger LOGGER = LoggerFactory.getLogger( ServerEventBusSessionMapper.class );

    private static void addServletBrowserData( HttpServletRequest pRequest, ServerEventBus pServerEventBus )
    {
        if ( pServerEventBus instanceof NonTemporaryServerEventBus )
        {
            pServerEventBus.setClientWindowInstanceData( ServerEventBus.TRANSLATED_PATH,
                                                         pRequest.getPathTranslated() );
            pServerEventBus.setClientWindowInstanceData( ServerEventBus.REMOTE_ADDR,
                                                         pRequest.getRemoteAddr() );
        }
    }

    public static ServerEventBus getServerEventBus( HttpServletRequest pRequest,
                                                    ThreadLocalContextFactory pThreadLocalContextFactory,
                                                    int pClientIdNumber )
            throws InvalidSessionException
    {
        ServerEventBus zServerEventBus = ServerEventBusManager.INSTANCE.getServerEventBus( pClientIdNumber );
        if ( null != zServerEventBus )
        {
            if ( !verifyRelatedBusCommonObject( pRequest, pThreadLocalContextFactory, zServerEventBus ) )
            {
                String zProblem = "Cross Session Request for ClientID '" + pClientIdNumber + "' from '" +
                                  pRequest.getRemoteUser() + "' at: " + pRequest.getRemoteAddr();
                LOGGER.warn.log( zProblem );
                throw new InvalidSessionException( zProblem );
            }
            // getRelatedBusCommonObject() == null passes
        }
        return zServerEventBus;
    }

    private static synchronized boolean verifyRelatedBusCommonObject( HttpServletRequest pRequest,
                                                                      ThreadLocalContextFactory pThreadLocalContextFactory,
                                                                      ServerEventBus pServerEventBus )
    {
        Object zRelatedBusCommonObject = pServerEventBus.getRelatedBusCommonObject();
        return (zRelatedBusCommonObject == null) ||
               (zRelatedBusCommonObject == getSessionTracker( pRequest, pThreadLocalContextFactory ));
    }

    private static final String SERVER_EVENT_BUSES = "ServerEventBuses";

    public static synchronized Integer[] getSessionServerEventBusClientIdNumbers( HttpServletRequest pRequest,
                                                                                  ThreadLocalContextFactory pThreadLocalContextFactory )
    {
        return getSessionTracker( pRequest, pThreadLocalContextFactory ).getClientIdNumbers();
    }

    private static synchronized SEBSessionTracker getSessionTracker( HttpServletRequest pRequest,
                                                                     ThreadLocalContextFactory pThreadLocalContextFactory )
    {
        HttpSession session = pRequest.getSession();
        SEBSessionTracker tracker = (SEBSessionTracker) session.getAttribute( SERVER_EVENT_BUSES );
        if ( tracker == null )
        {
            session.setAttribute( SERVER_EVENT_BUSES,
                                  tracker = new SEBSessionTracker( pThreadLocalContextFactory ) );
        }
        return tracker;
    }

    public static void addServerEventBus( ServerEventBus pParent, ServerEventBus pServerEventBus )
    {
        // Force use of same stuff
        SEBSessionTracker tracker = (SEBSessionTracker) pParent.getRelatedBusCommonObject();

        pServerEventBus.setRelatedBusCommonObject( tracker );
        tracker.addServerEventBus( pServerEventBus );
    }

    public static void addServerEventBus( HttpServletRequest pRequest,
                                          ThreadLocalContextFactory pThreadLocalContextFactory,
                                          ServerEventBus pServerEventBus )
    {
        SEBSessionTracker tracker = getSessionTracker( pRequest, pThreadLocalContextFactory );
        addServletBrowserData( pRequest, pServerEventBus );

        pServerEventBus.setRelatedBusCommonObject( tracker );
        tracker.addServerEventBus( pServerEventBus );
    }

    public static SEBSessionTracker addTrackerToServerEventBus( HttpServletRequest pRequest,
                                                                ThreadLocalContextFactory pThreadLocalContextFactory,
                                                                ServerEventBus pServerEventBus )
    {
        SEBSessionTracker tracker = getSessionTracker( pRequest, pThreadLocalContextFactory );
        addServletBrowserData( pRequest, pServerEventBus );
        pServerEventBus.setRelatedBusCommonObject( tracker );
        return tracker;
    }

    public static String getLogoutMessage( HttpServletRequest pRequest,
                                           ThreadLocalContextFactory pThreadLocalContextFactory )
    {
        return getSessionTracker( pRequest, pThreadLocalContextFactory ).getLogoutMessage();
    }

    public static void setLogoutMessage( HttpServletRequest pRequest,
                                         ThreadLocalContextFactory pThreadLocalContextFactory,
                                         String pLogoutMessage )
    {
        getSessionTracker( pRequest, pThreadLocalContextFactory ).setLogoutMessage( pLogoutMessage );
    }

    public static boolean anyServerEventBusesFor( HttpServletRequest pRequest,
                                                  ThreadLocalContextFactory pThreadLocalContextFactory )
    {
        return getSessionTracker( pRequest, pThreadLocalContextFactory ).anyServerEventBuses();
    }

    public static void dropAllServerEventBusesFor( HttpServletRequest pRequest,
                                                   ThreadLocalContextFactory pThreadLocalContextFactory,
                                                   String pWhy )
    {
        getSessionTracker( pRequest, pThreadLocalContextFactory ).dropAllServerEventBuses( pWhy );
    }
}