/*
* Copyright (c) 2007 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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:  
*
*/


#include <msvids.h>

#include "messageheader.h"
#include "messagenotify.h"

#ifdef __WINS__
const TMsvId KObservedFolderId = KMsvDraftEntryId;
#else
const TMsvId KObservedFolderId =  KMsvGlobalInBoxIndexEntryId;
#endif


// ---------------------------------------------------------------------------
// two-phased constructor
// ---------------------------------------------------------------------------
CMessageObserver* CMessageObserver::NewL( CMsvSession* aSession, 
											CMsgCallbackBase* aNotifyCallback )
	{
	return new(ELeave) CMessageObserver( aSession, aNotifyCallback );
	}
	
// ---------------------------------------------------------------------------
// destructor
// ---------------------------------------------------------------------------
CMessageObserver::~CMessageObserver()
	{
	delete iNotifyCallback;
	}

// ---------------------------------------------------------------------------
// default constructor
// ---------------------------------------------------------------------------
CMessageObserver::CMessageObserver( CMsvSession* aSession, 
									CMsgCallbackBase* aNotifyCallback ) :
					iServerSession( aSession ),
					iNotifyCallback( aNotifyCallback ),
					iNewMessageId( -1 )
	{
		
	}


// ---------------------------------------------------------------------------
// CMessageObserver::HandleSessionEventL
// Indicates the event of arrival of new message.
// ---------------------------------------------------------------------------
void CMessageObserver::HandleSessionEventL( TMsvSessionEvent aEvent, 
											TAny* aArg1, 
											TAny* aArg2, 
											TAny* /*aArg3*/ )
	{
		//if there is a callback request registered
		if ( iNotifyCallback )
			{
			switch ( aEvent )
				{
				// if there is a new entry created	
				case EMsvEntriesCreated:
					{
					//aArg2 specifies the parent ID of the entry
					// entry is created in observed folder
					if ( aArg2 && *(static_cast<TMsvId*> (aArg2)) == KObservedFolderId )
						{
						CMsvEntrySelection* entries = static_cast<CMsvEntrySelection*>( aArg1 );
						//one or more new entries created
						if ( entries->Count() > 0 )
							{
							// get the message ID of the first entry 
							iNewMessageId = entries->At(0);
							}
						}
					}
					break; 
				
				// one or more index entries are changed
				case EMsvEntriesChanged:
					{
					//change in index entry in the observed folder
					if ( aArg2 && *(static_cast<TMsvId*>(aArg2)) == KObservedFolderId )
						{
						CMsvEntrySelection* entries = static_cast<CMsvEntrySelection*>( aArg1 );
						if( entries->Count() > 0 && iNewMessageId == entries->At(0) )
							{
							CMessageHeader* newEntryHeader;
							// set the message header fields
							newEntryHeader = MessageHeaderL( iNewMessageId );
							if( newEntryHeader )
								{
								CleanupStack::PushL( newEntryHeader );
								//notify new header entry created
								iNotifyCallback->NotifyResultL( KErrNone, (TAny*)newEntryHeader );
								CleanupStack::PopAndDestroy(newEntryHeader);
								iNewMessageId = -1;
								}
							}
						}
					}
					break;
				
				default: break;
			}
		}
	}
	
// ---------------------------------------------------------------------------
// CMessageObserver::SetSession
// sets the iServersession member variable with a message server session
// ---------------------------------------------------------------------------
void CMessageObserver::SetSession( CMsvSession* aSession )
	{ 
	iServerSession = aSession; 
	}
		
// ---------------------------------------------------------------------------
// CMessageObserver::SetCallbackL
// registers a new callback request
// returns the old callback request
// ---------------------------------------------------------------------------
CMsgCallbackBase* CMessageObserver::SetCallback( CMsgCallbackBase* aCallback ) 
	{ 
	CMsgCallbackBase* oldCallback = iNotifyCallback;
	// get the new callback request
	iNotifyCallback = aCallback; 
	return oldCallback;
	}
	
// ---------------------------------------------------------------------------
// Checks if Notification is activated
// return True if notification request is active.
// ---------------------------------------------------------------------------
TBool CMessageObserver::IsActive()
	{
	if ( iNotifyCallback )
		return ETrue;
	
	return EFalse;
	}


// ---------------------------------------------------------------------------
// CMessageObserver::GetMessageHeaderL
// sets the header fields of a message
// returns an header object.
// ---------------------------------------------------------------------------
CMessageHeader* CMessageObserver::MessageHeaderL( TMsvId aMessageId )
	{
	TMsvEntry newEntry;
	TMsvId serviceId;

	//gets index of the specified message ID
	if( iServerSession->GetEntry( aMessageId, serviceId, newEntry ) == KErrNone )
		{
		CMessageHeader* newEntryHeader = CMessageHeader::NewL();
		CleanupStack::PushL( newEntryHeader );
		
		newEntryHeader->SetMtmId( newEntry.iMtm );
		newEntryHeader->SetTime( newEntry.iDate );
		newEntryHeader->SetMessageId( aMessageId );
		newEntryHeader->SetFromL( newEntry.iDetails );
		newEntryHeader->SetSubjectL( newEntry.iDescription );
		newEntryHeader->SetAttachFlag( newEntry.Attachment() );
		newEntryHeader->SetPriorityFlag( newEntry.Priority() );
		newEntryHeader->SetUnreadFlag( newEntry.Unread() );

		CleanupStack::Pop(newEntryHeader); 

		return newEntryHeader;
		}
	
	return NULL;
	}