// This Source Code is in the Public Domain per: http://unlicense.org
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.commonfoundation.base.*;

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

        Confirm.isNotNull( "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();
    }
}