/*
* 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:  message handler notification
 *                
 *
*/

 
#include "cservicewidgetmessagehandler.h"
#include "mservicewidgetobservers.h"
#include "swpdebugtrace.h"
//im cache
#include  <cimcachefactory.h>
#include  <mimcacheaccessor.h>
#include <apgtask.h> 
#include <coemain.h>

// ---------------------------------------------------------------------------
// CServiceWidgetMessageHandler::CServiceWidgetMessageHandler
// ---------------------------------------------------------------------------
// 
CServiceWidgetMessageHandler::CServiceWidgetMessageHandler(
						MServiceWidgetNewMessageObserver& aMessageObserver )
	:iMessageObserver( aMessageObserver )
   {
   TRACE_SWP(TXT("CServiceWidgetMessageHandler::CServiceWidgetMessageHandler") );
   }

// ---------------------------------------------------------------------------
// CServiceWidgetMessageHandler::NewL
// ---------------------------------------------------------------------------
// 
CServiceWidgetMessageHandler* CServiceWidgetMessageHandler::NewL( 
						MServiceWidgetNewMessageObserver& aMessageObserver,
						TInt aServiceId, 
     				    const TDesC& aOwnUserId )
    {
    TRACE_SWP(TXT("CServiceWidgetMessageHandler::NewL() start") );
    CServiceWidgetMessageHandler* self = NewLC(aMessageObserver,
    									aServiceId,
    									aOwnUserId);
    CleanupStack::Pop(self);
    TRACE_SWP(TXT("CServiceWidgetMessageHandler::NewL() end") );
    return self;
    }

// ---------------------------------------------------------------------------
// CServiceWidgetMessageHandler::NewLC
// ---------------------------------------------------------------------------
// 
CServiceWidgetMessageHandler* CServiceWidgetMessageHandler::NewLC( 
					   MServiceWidgetNewMessageObserver& aMessageObserver,
						TInt aServiceId, 
				 		const TDesC& aOwnUserId )
    {
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::NewLC() start") );
    CServiceWidgetMessageHandler* self =
        new (ELeave) CServiceWidgetMessageHandler(aMessageObserver );
    CleanupStack::PushL(self);
    self->ConstructL( aOwnUserId ,aServiceId );
    TRACE_SWP(TXT("CServiceWidgetMessageHandler::NewLC() end") );
    return self;
    }

// ---------------------------------------------------------------------------
// CServiceWidgetMessageHandler::ConstructL
// ---------------------------------------------------------------------------
// 
void CServiceWidgetMessageHandler::ConstructL( const TDesC& aOwnUserId, TInt aServiceId )
    {
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::ConstructL() start") );
   	iIMCacheFactory = CIMCacheFactory::InstanceL(); 
	iAccessor = iIMCacheFactory->CreateAccessorL( aServiceId, aOwnUserId );
	iAccessor->RegisterObserverL(*this);
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::ConstructL() end") );
	}

// ---------------------------------------------------------------------------
// CServiceWidgetMessageHandler::~CServiceWidgetMessageHandler
// ---------------------------------------------------------------------------
// 
CServiceWidgetMessageHandler::~CServiceWidgetMessageHandler()
    {
    TRACE_SWP(TXT("CServiceWidgetMessageHandler::~CServiceWidgetMessageHandler() start") );
  	if( iIMCacheFactory )
		{
		if( iAccessor )
		    {
	    	iAccessor->UnRegisterObserver(*this);	
	    	}
		CIMCacheFactory::Release();  	
		}
	iSendersArray.ResetAndDestroy();
	
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::~CServiceWidgetMessageHandler() end") );
    }

// -----------------------------------------------------------------------------
// CServiceWidgetMessageHandler::GetUnreadMessageCountL
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//	
TInt CServiceWidgetMessageHandler::GetUnreadMessageCountL()
	{
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::GetUnreadMessageCountL()") );
	return iAccessor->GetAllUnreadMessageCountL() ;
	}
//-----------------------------------------------------------------------------
// CServiceWidgetMessageHandler::HandleIMCacheEventL
// ( Other items commented in header )
//-----------------------------------------------------------------------------  

void CServiceWidgetMessageHandler::HandleIMCacheEventL(TIMCacheEventType aEventType, TAny* aChatMessage  )
	{
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::HandleIMCacheEventL() start") );
	switch( aEventType )
		{
		case EIMCacheUnreadMessage :
			{
			TRACE_SWP(TXT("CServiceWidgetMessageHandler::HandleIMCacheEventL() EIMCacheUnreadMessage ") );
			if (!aChatMessage)
				{
				return;	
				}
			SIMCacheMessageData* chatData = static_cast<SIMCacheMessageData*>( aChatMessage ) ;
			// check that buddy id exists
			if ( chatData->iBuddyId )
			    {
			    TPtrC buddyId = chatData->iBuddyId->Des();
				TPtrC messageText = chatData->iText->Des();
				if( !IsExistInSendersArrayL( buddyId ) ) // append only if not exist 
					{
					HBufC* sender = buddyId.AllocLC();
					if( sender )
						{
						iSendersArray.InsertL( sender ,0 ); // ownership to array
						CleanupStack::Pop(sender); //	
						}
					}
				iMessageObserver.HandleNewMessageL( buddyId, messageText );
			    }
			break;	
			}
		case EIMCacheUnreadChange :
			{
			TRACE_SWP(TXT("CServiceWidgetMessageHandler::HandleIMCacheEventL() EIMCacheUnreadChange ") );
			SynchronizeSendersArrayL();
		    iMessageObserver.HandleCountChangedL();
			break;	
			}
		default:
			{
			break;
			}
		}
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::HandleIMCacheEventL() end ") );
	}

// -----------------------------------------------------------------------------
// CServiceWidgetMessageHandler::GetUnreadSenderId
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
const TDesC& CServiceWidgetMessageHandler::GetUnreadSenderId() 
	{
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::GetUnreadSenderId() start") );
	if( iSendersArray.Count() )
		{
		TRACE_SWP(TXT("CServiceWidgetMessageHandler::GetUnreadSenderId() end") );
		return *( iSendersArray[ 0 ] ); //  latest sender always on top
		}
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::GetUnreadSenderId() end") );
	return KNullDesC;
	}

// -----------------------------------------------------------------------------
// CServiceWidgetMessageHandler::IsSingleMessageSender
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TBool CServiceWidgetMessageHandler::IsSingleMessageSender() 
	{
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::IsSingleMessageSender()") );
	return ( iSendersArray.Count() == 1 );
	}
	
// -----------------------------------------------------------------------------
// CServiceWidgetMessageHandler::IsExistInSendersArrayL
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
TBool CServiceWidgetMessageHandler::IsExistInSendersArrayL( const TDesC& aNewSenderId ) 
	{
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::IsExistInSendersArrayL() start") );
	TInt count = iSendersArray.Count();
	for( TInt i=0; i<count; i++ )
		{
		HBufC* senderId = iSendersArray[i];
		if( senderId && aNewSenderId.Compare( *senderId ) == 0 )	
			{
			TRACE_SWP(TXT("CServiceWidgetMessageHandler::IsExistInSendersArrayL() end") );
			return  ETrue;	
			}
		}
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::IsExistInSendersArrayL() end") );
	return EFalse;
	}
// -----------------------------------------------------------------------------
// CServiceWidgetMessageHandler::SynchronizeSendersArrayL
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CServiceWidgetMessageHandler::SynchronizeSendersArrayL() 
	{
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::SynchronizeSendersArrayL() start") );
	TInt count = iSendersArray.Count();
	for( TInt i=0; i < count; i++ )
		{
		HBufC* senderId = iSendersArray[i];
		if( senderId )	
			{
			TInt unreadCount = iAccessor->GetUnreadMessageCountL(*senderId  ) ;
			if( !unreadCount )
				{
				iSendersArray.Remove( i );
				delete 	senderId;
				senderId = NULL;
				iSendersArray.Compress();
				break;
				}
			}
		}
	TRACE_SWP(TXT("CServiceWidgetMessageHandler::SynchronizeSendersArrayL() end") );
	}		
	
// end of file