package org.litesoft.GWT.eventbus.server;

import org.litesoft.GWT.eventbus.client.*;
import org.litesoft.GWT.eventbus.client.eventpackages.*;
import org.litesoft.GWT.eventbus.client.nonpublic.*;
import org.litesoft.GWT.eventbus.server.nonpublic.*;
import org.litesoft.*;
import org.litesoft.util.*;

public class AuthenticatedServerEventBus extends NonTemporaryServerEventBus
{
    private AuthenticatedServerEventBusSupport mSupport;
    private IAuthenticationService mAuthenticationService;

    public Type getType()
    {
        return Type.Authenticated;
    }

    public AuthenticatedServerEventBus( int pClientIdNumber, AuthenticatedServerEventBusSupport pSupport,
                                        IAuthenticationService pAuthenticationService )
    {
        super( pClientIdNumber );

        Utils.assertNotNull( "AuthenticatedServerEventBusSupport", mSupport = pSupport );
        mAuthenticationService = (pAuthenticationService != null) ? //
                                 pAuthenticationService : //
                                 IAuthenticationService.Null.INSTANCE;
    }

    public ISystemUser getLoggedInUser()
    {
        return mSupport.getLoggedInUserFromSEB( this );
    }

    public AuthenticationData getAuthenticationData()
    {
        ISystemUser user = getLoggedInUser();
        if ( user == null )
        {
            String zLogoutMessage = mSupport.getLogoutMessageFromSEB( this );
            return new AuthenticationData( zLogoutMessage );
        }

        AppXtraLoginData zData = mSupport.getCurrentAppXtraLoginDataFromSEB( this );

        return createSuccessfulAuthenticationData( user, zData );
    }

    protected AuthenticationData createSuccessfulAuthenticationData( ISystemUser pUser,
                                                                     AppXtraLoginData pAppXtraLoginData )
    {
        String zLoginUser = pUser.getLoginName();
        String zUserKeyAsOpaqueString = pUser.getKeyAsOpaqueString();
        String zUserDisplayName = pUser.getDisplayName();
        String zThemeCode = pUser.getTheme();

        return new AuthenticationData( zLoginUser, zUserKeyAsOpaqueString, zUserDisplayName, zThemeCode, //
                                       pAppXtraLoginData );
    }

    public String isLocalDistributionFromPeerOK( EventPackage pPackage )
    {
        try
        {
            if ( pPackage instanceof AuthenticationEventPackage )
            {
                if ( pPackage instanceof SignOutEventPackage )
                {
                    SignOutEventPackage zSignOutRequest = (SignOutEventPackage) pPackage;
                    signOut( zSignOutRequest.getMessage() );
                    return null;
                }
                if ( pPackage instanceof SignInRequestEventPackage )
                {
                    SignInRequestEventPackage zSignInRequest = (SignInRequestEventPackage) pPackage;
                    signIn( zSignInRequest.getLoginName(), zSignInRequest.getPassword() );
                    return null;
                }
                return null;
            }

            return (mSupport.getLoggedInUserFromSEB( this ) != null) ? null : "Not Authenticated";
        }
        catch ( RuntimeException e )
        {
            // Fail on every kind of exception
            return "Exception: " + e.getMessage();
        }
    }

    private void signOut( String pLogoutMessage )
    {
        mSupport.clearLoggedInUserInformationOnSEB( this );
        mSupport.setLogoutMessageOnSEB( this, pLogoutMessage );
        mSupport.logoutRequestComplete( this );
    }

    private void signIn( String pLoginName, String pPassword )
    {
        mSupport.clearLogoutMessageOnSEB( this );

        ISystemUser zSystemUser;
        try
        {
            zSystemUser = mSupport.authenticate( pLoginName, pPassword );
            if ( zSystemUser == null )
            {
                signInError( "Invalid User" );
                return;
            }
            mAuthenticationService.adjustExistingClientWindowInstanceDataForNewUser(
                    getClientWindowInstanceDataManager(), zSystemUser );
        }
        catch ( AuthenticationException e )
        {
            signInError( e.getMessage() );
            return;
        }
        catch ( IllegalArgumentException e )
        {
            signInError( e.getMessage() );
            return;
        }
        catch ( RuntimeException e )
        {
            mLogger.error.log( e );
            signInError( "Authentication Issue" );
            return;
        }

        AppXtraLoginData zData = mSupport.getCurrentAppXtraLoginDataFromSEB( this );

        AuthenticationData zAuthenticationData = createSuccessfulAuthenticationData( zSystemUser, zData );

        SignInResponseEventPackage.send( this, zAuthenticationData );
    }

    private void signInError( String pError )
    {
        SignInResponseEventPackage.send( this, new AuthenticationData( pError ) );
    }

    public String toString()
    {
        return "Authenticated" + super.toString();
    }
}