/*

* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:  Class that capsulates single service data members

*

*/

//  INCLUDES

#include "cvimpstengineimsubservice.h"

#include "cvimpstenginecchhandler.h"

#include "cvimpstengineservicetablefetcher.h"

#include "mvimpstengineimsubserviceeventobserver.h"

#include "mvimpstengineserviceconnectioneventobserver.h"

#include <e32std.h>

#include <barsc.h>

#include <gulutil.h>

#include <coemain.h>

#include <e32base.h>

#include "tvimpstconsts.h"

// imcache  related headers

#include "cimcachefactory.h"

#include "mimcacheaccessor.h"

//system includes

#include <e32property.h>

// ================= MEMBER FUNCTIONS =======================

// ---------------------------------------------------------

// CVIMPSTEngineIMSubService::NewL

// 

// ---------------------------------------------------------

CVIMPSTEngineIMSubService* CVIMPSTEngineIMSubService::NewL(

								TUint aServiceId,

								CVIMPSTEngineCchHandler& aCchHandler,

								CVIMPSTEngineServiceTableFetcher& aTableFetcher,

								MVIMPSTEngineServiceConnectionEventObserver& aObserver

								 )

    {

    CVIMPSTEngineIMSubService* self = CVIMPSTEngineIMSubService::NewLC(

    												aServiceId,

    												aCchHandler,

    												aTableFetcher,    												

    												aObserver );

    CleanupStack::Pop( self );

    return self;

    }

// ---------------------------------------------------------

// CVIMPSTEngineIMSubService::NewLC

// 

// ---------------------------------------------------------

CVIMPSTEngineIMSubService* CVIMPSTEngineIMSubService::NewLC(

								TUint aServiceId,

								CVIMPSTEngineCchHandler& aCchHandler,

								CVIMPSTEngineServiceTableFetcher& aTableFetcher,

								MVIMPSTEngineServiceConnectionEventObserver& aObserver

								 )

	{

    CVIMPSTEngineIMSubService* self = new (ELeave) CVIMPSTEngineIMSubService(aServiceId, 

    												aCchHandler, aTableFetcher,

    												aObserver );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

	}

// ---------------------------------------------------------

// CVIMPSTEngineIMSubService::~CVIMPSTEngineIMSubService

// 

// ---------------------------------------------------------

CVIMPSTEngineIMSubService::~CVIMPSTEngineIMSubService()

	{

	iChatObserver.Reset();

    iChatObserver.Close();

	iCchHandler.UnRegisterCchObserver(ECCHIMSub);

	ReleaseIMCacheAccessor();	

 	}

// ---------------------------------------------------------

// CVIMPSTEngineIMSubService::ConstructL

// 

// ---------------------------------------------------------

void CVIMPSTEngineIMSubService::ConstructL()

	{			

	TCCHSubserviceState serviceState = ECCHUninitialized;    

    TInt error = iCchHandler.GetServiceState( 

        			iServiceId, ECCHIMSub, serviceState );

	iServiceState = ResolveServiceStateL(serviceState, error);    	

	iCchHandler.RegisterCchObserverL(this,ECCHIMSub);       

    }

// ---------------------------------------------------------

// CVIMPSTEngineIMSubService::CVIMPSTEngine

// 

// ---------------------------------------------------------

CVIMPSTEngineIMSubService::CVIMPSTEngineIMSubService( TUint aServiceId,

								CVIMPSTEngineCchHandler& aCchHandler,

								CVIMPSTEngineServiceTableFetcher& aTableFetcher,

								MVIMPSTEngineServiceConnectionEventObserver& aObserver) :

	iServiceId(aServiceId),

	iCchHandler(aCchHandler),

	iTableFetcher(aTableFetcher),	

	iObserver(aObserver),

	iType (TVIMPSTEnums::EIM)

	{

	}

// ---------------------------------------------------------

// CVIMPSTEngineIMSubService::RegisterChatObserver

// 

// ---------------------------------------------------------	

void CVIMPSTEngineIMSubService::RegisterChatObserver(MVIMPSTEngineIMSubServiceEventObserver* aObserver)

	{

	if (aObserver)

		{

		TInt index = iChatObserver.Find(aObserver);

		        if( index == KErrNotFound )

		            {

		            iChatObserver.Append( aObserver );   

		            }

		}    	

	}

// ---------------------------------------------------------

// CVIMPSTEngineIMSubService::UnRegisterChatObserver

// 

// ---------------------------------------------------------	

void CVIMPSTEngineIMSubService::UnRegisterChatObserver(MVIMPSTEngineIMSubServiceEventObserver* aObserver)

	{

	if (aObserver)

		{

		TInt index = iChatObserver.Find(aObserver);

		        if( index >=0 )

		            {

		            iChatObserver.Remove( index );

		            iChatObserver.Compress();

		            }

		}

	}

//-----------------------------------------------------------------------------

//-----------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::HandleIMCacheEventL

// ( Other items commented in header )

//-----------------------------------------------------------------------------  

void CVIMPSTEngineIMSubService::HandleIMCacheEventL(TIMCacheEventType aEventType, TAny* aChatMessage  )

	{

	switch( aEventType )

	    {

	    case EIMCacheUnreadMessage :

	        {

	        if (!aChatMessage)

	            {

	            return;	

	            }

	        SIMCacheMessageData* chatData = static_cast<SIMCacheMessageData*>( aChatMessage ) ;

	        // check that buddy id exists

	        if ( chatData->iBuddyId )

	            {

	            TPtrC buddyId = chatData->iBuddyId->Des();

	            NotifyObserversL(TVIMPSTEnums::EIMUnreadMessage,buddyId);               

	            }

	        break;	

	        }

	    case EIMCacheUnreadChange :

	        {

	        if (!aChatMessage)

	            {

	            return; 

	            }

	        SIMCacheChatItem* chatItem =  static_cast<SIMCacheChatItem*>( aChatMessage ) ;

	        if( iServiceId != chatItem->iServiceId )

	            {

	            return;

	            }

	        TPtrC buddyId = chatItem->iBuddyId->Des();

	        NotifyObserversL(TVIMPSTEnums::EIMUnreadChange, buddyId );  // ETrue for Closed conversation

	        break;

	        }

	    case EIMCacheChatStarted :

	        {

	        if (!aChatMessage)

	            {

	            return; 

	            }

	        SIMCacheChatItem* chatItem =  static_cast<SIMCacheChatItem*>( aChatMessage ) ;

	        if( iServiceId != chatItem->iServiceId )

	            {

	            return;

	            }

	        TPtrC buddyId = chatItem->iBuddyId->Des();

	        NotifyObserversL(TVIMPSTEnums::EIMChatStarted, buddyId );  // ETrue for Closed conversation 

	        break;  

	        }

	    case EIMCacheChatClosed:

	        {

	        if (!aChatMessage)

	            {

	            return; 

	            }

	        SIMCacheChatItem* chatItem =  static_cast<SIMCacheChatItem*>( aChatMessage ) ;

	        if( iServiceId != chatItem->iServiceId )

	            {

	            return;

	            }

	        TPtrC buddyId = chatItem->iBuddyId->Des();

	        NotifyObserversL(TVIMPSTEnums::EIMChatClosed, buddyId );                     

	        break;  

	        }

	    case EIMCacheAllChatClosed:

	        {

	        NotifyObserversL(TVIMPSTEnums::EIMAllChatClosed, KNullDesC );                 

	        break;  

	        }

	    case EIMCacheRequestCompleted:

	        {

	        NotifyObserversL(TVIMPSTEnums::EIMRequestCompleted, KNullDesC );  

	        break;

	        }

	    default:

	        {

	        break;

	        }

	    }

	}

//-----------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::GetUnreadCountL

// ( Other items commented in header )

//-----------------------------------------------------------------------------    

TInt CVIMPSTEngineIMSubService::GetUnreadCountL(const TDesC& aBuddyId ) 

	{

	TInt count = 0;

	if( iIMCacheAccessor )

		{

		count = iIMCacheAccessor->GetUnreadMessageCountL(aBuddyId);

		}

	return count;

	}

// ---------------------------------------------------------

// CVIMPSTEngineIMSubService::SubServiceState

// ---------------------------------------------------------------------------

// 

TVIMPSTEnums::TVIMPSTRegistrationState CVIMPSTEngineIMSubService::SubServiceState() const

	{

	return iServiceState;

	}

//-----------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::IsConversationExistL

// ( Other items commented in header )

//-----------------------------------------------------------------------------    

TBool CVIMPSTEngineIMSubService::IsConversationExistL(const TDesC& aBuddyId) const

	{

	TInt exist = EFalse;

	if( iIMCacheAccessor )

		{

		exist = iIMCacheAccessor->IsConversationExistL( aBuddyId );	

		}

	return exist; 

  	}

//-----------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::CloseConversationL

// ( Other items commented in header )

//-----------------------------------------------------------------------------

void CVIMPSTEngineIMSubService::CloseConversationL( const TDesC& aContactId )

    {

    if( IsConversationExistL(aContactId) )

        {

        iIMCacheAccessor->CloseConversationL( aContactId );

        }

    }

//-----------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::GetOpenChatListL

// ( Other items commented in header )

//-----------------------------------------------------------------------------

RArray<SIMCacheChatItem> CVIMPSTEngineIMSubService::GetOpenChatListL()

    {

    RArray<SIMCacheChatItem> item;

    if(iIMCacheAccessor)

        {

        item =  iIMCacheAccessor->GetChatListL( iServiceId );

        }

    return item;

    }

// ---------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::ResolveServiceStateL

// ---------------------------------------------------------------------------

// 

TVIMPSTEnums::TVIMPSTRegistrationState CVIMPSTEngineIMSubService::ResolveServiceStateL(

										TCCHSubserviceState aState, 

            							TInt aServiceError )

    {

    TVIMPSTEnums::TVIMPSTRegistrationState state = TVIMPSTEnums::ESVCENotRegistered;       

    TBool handleServiceStates = ETrue;

    if ( aServiceError && ECCHDisabled != aState )

        {    

		//Only if the Service supports ALR, the state can goto WaitingForNetwork

		//Still API from CCH is required to know whether ALR is supported or not

        if ( (KCCHErrorInvalidSettings != aServiceError) && (ECCHConnecting == aState) )        

            {   

            handleServiceStates = EFalse;  

            state = TVIMPSTEnums::ESVCEWaitingForNetwork;	           

            }

        }

    if ( handleServiceStates )

        {        

        switch ( aState )

            {

            case ECCHEnabled:

                {

                CreateIMCacheAccessorL();

                state = TVIMPSTEnums::ESVCERegistered;

                }

                break;

            case ECCHDisconnecting:      

                {

                state = TVIMPSTEnums::ESVCENetworkDisConnecting;

                }

                break;

            case ECCHUninitialized:

            case ECCHDisabled:  

                {

                ReleaseIMCacheAccessor();

                state = TVIMPSTEnums::ESVCENotRegistered;

                }

                break;

            case ECCHConnecting:               

                {

                state = TVIMPSTEnums::ESVCENetworkConnecting;

                }

                break;

            default:

                break;

            }

        }        

    return state;  

    }

// ---------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::Type

// ---------------------------------------------------------------------------

//

TVIMPSTEnums::SubServiceType CVIMPSTEngineIMSubService::Type() const	

	{

	return iType;	

	}

// ---------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::CchEventOccuredL

// ---------------------------------------------------------------------------

//

void CVIMPSTEngineIMSubService::CchEventOccuredL( 

            TUint /*aServiceId*/, 

            TCCHSubserviceState aState, 

            TInt aServiceError )

	{

    if ( aServiceError && ECCHDisabled != aState )

        {

        //we might even end up in waiting for connection state for all

        //those service which are ALR enabled

        //So better check here if you get any CCH errors

        iServiceState = ResolveServiceStateL( aState, aServiceError );

        iObserver.HandleServceConnectionEventL();

        DoHandleCchErrorL( aServiceError );

        }

    else

        {

        iServiceState = ResolveServiceStateL( aState, aServiceError );    

        iObserver.HandleServceConnectionEventL();

        }	

	}

// ---------------------------------------------------------------------------

// CVIMPSTEngineIMSubService::DoHandleCchErrorL()

// ---------------------------------------------------------------------------

// 

void CVIMPSTEngineIMSubService::DoHandleCchErrorL( 

    TInt aServiceError )

    {

    switch ( aServiceError )

        {

        case KCCHErrorNetworkLost:

        case KCCHErrorBandwidthInsufficient:

        case KCCHErrorInvalidIap: 

            {

            //Should be fwded to CCHUI to show the appropriate Notes

            //TBD

            }

            break;