/*

* Copyright (c) 2007-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: uscontextobserver.cpp

*

*/

#include "uscontextobserver.h"

#include <ximpidentity.h>

#include <presenceinfofieldvaluetext.h>

#include <presenceinfofieldvalueenum.h>

#include <ximpstatus.h>

#include <ximpcontextstateevent.h>

#include <ximprequestcompleteevent.h>

#include <presentitypresenceevent.h>

#include <presentitygrouplistevent.h>

#include <presentitygroupinfo.h>

#include <presentitygroupcontentevent.h>

#include <presentitygroupmemberinfo.h>

#include <presencegrantrequestlistevent.h>

#include <presenceblocklistevent.h>

#include <presentitypresenceevent.h>

#include <presencewatcherlistevent.h>

#include "ossadapmt.h"

#include <ximpdatasubscriptionstate.h>

#include <presencewatcherinfo.h>

#include "ximpcontextstate.h"

#include <presenceinfo.h>

#include <servicepresenceinfo.h>

#include <devicepresenceinfo.h>

#include <presencegrantrequestinfo.h>

#include <presenceblockinfo.h>

#include <presenceinfofieldcollection.h>

#include <personpresenceinfo.h>

#include <presenceinfofield.h>

#include "imconversationevent.h"

#include <searchevent.h>

#include "imconversationinfo.h"

#include <searchinfo.h>

#include <searchkeysevent.h>

#include <searchkeyinfo.h>

#include <e32math.h>

#include <f32file.h>

#include <utf.h>

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

// CONSTRUCTION

CUSContextObserver* CUSContextObserver::NewLC()

	{

	CUSContextObserver* self = new ( ELeave ) CUSContextObserver();

	CleanupStack::PushL ( self );

	return self;

	}

CUSContextObserver::~CUSContextObserver()

	{

	}

CUSContextObserver::CUSContextObserver()

	{

	}

// ===========================================================================

// PUBLIC FUNCTIONS

// ===========================================================================

//

void CUSContextObserver::WaitOpToCompleteL ( const TXIMPRequestId& aOpToWait )

	{

	iReqToWait = aOpToWait;

	iWait.Start();

	}

/*void CUSContextObserver::WaitCompleteL()

 {

 iWait.AsyncStop();

 }*/

// ===========================================================================

// FROM MXIMPContextObserver

// ===========================================================================

//

void CUSContextObserver::HandlePresenceContextEvent (

    const MXIMPContext& /*aContext*/,

    const MXIMPBase& aEvent )

	{

	TOssAdapMtLogger::Log ( _L ( "HandlePresenceContextEvent called" ) );

	TInt32 eventId = aEvent.GetInterfaceId();

	switch ( aEvent.GetInterfaceId() )

		{

			_LIT ( KDir, "EVENT_LOG" );  // here we hv to write a folder name in wch we want to create log file

			_LIT ( KFile, "event.txt" );          //here we hv to write a file name in wch we want to log default path is  " c:/Logs/"

		case MXIMPRequestCompleteEvent::KInterfaceId:

				{

				TOssAdapMtLogger::Log ( _L ( "CUSContextObserver::MXIMPRequestCompleteEvent() start" ) );

				const MXIMPRequestCompleteEvent* complEvent =

				    TXIMPGetInterface< const MXIMPRequestCompleteEvent >::From ( aEvent,

				            MXIMPBase::EPanicIfUnknown );

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "*************BEGIN******************" ) );

				_LIT ( KMsg, "Recvd RequestCompleteEvent " );         // here we hv to write message or text wch we want to write in log file

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, KMsg );

				if ( iWait.IsStarted() && ( complEvent->RequestId() == iReqToWait ) )

					{

					iReqResult = complEvent->CompletionResult().ResultCode();

					RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "Error code for the request is %d " ), iReqResult );

					iWait.AsyncStop();

					}

				TOssAdapMtLogger::Log ( _L ( "CUSContextObserver::MXIMPRequestCompleteEvent() end" ) );

				break;

				}

		case MXIMPContextStateEvent::KInterfaceId:

				{

				const MXIMPContextStateEvent* ctxtStateEvent =

				    TXIMPGetInterface< const MXIMPContextStateEvent >::From ( aEvent,

				            MXIMPBase::EPanicIfUnknown );

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "*************BEGIN******************" ) );

				_LIT ( KMsg, "Recvd PresenceContextStateEvent " );         // here we hv to write message or text wch we want to write in log file

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, KMsg );

				const MXIMPStatus* fwStatus = ctxtStateEvent->StateChangeReason();

				const MXIMPContextState& cState = ctxtStateEvent->ContextState();

				MXIMPContextState::TState state = cState.ContextState();

				break;

				}

		case MPresentityGroupListEvent::KInterfaceId:

				{

				const MPresentityGroupListEvent* groupListEvent =

				    TXIMPGetInterface< const MPresentityGroupListEvent >::From ( aEvent,

				            MXIMPBase::EPanicIfUnknown );

				TBuf<100> sdstate;

				TBuf<100> ssstate;

				_LIT ( Kna, "   Susbcription state is unavailable" );

				_LIT ( Kava, "   Susbcription state is available" );

				_LIT ( KDef, "   Susbcription state is ERROR" );

				const  MXIMPDataSubscriptionState&  dstate = groupListEvent->DataSubscriptionState();

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						ssstate.Copy ( Kna );

						break;

					case 1:

						ssstate.Copy ( Kava );

						break;

					default:

						ssstate.Copy ( KDef );

						break;

					}

				_LIT ( Kdna, "   Data state is unavailable" );

				_LIT ( Kdava, "   Data state is available" );

				_LIT ( KdDef, "   Data state is ERROR" );

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						sdstate.Copy ( Kdna );

						break;

					case 1:

						sdstate.Copy ( Kdava );

						break;

					default:

						sdstate.Copy ( KdDef );

						break;

					}

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "*************BEGIN******************" ) );

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "Recvd PresentityGroupListEvent New:%d, Updt:%d, Disappeared:%d, Current:%d, SubscrState:%d, DataState:%d" ), groupListEvent->NewGroupsCount(), groupListEvent->UpdatedGroupsCount(), groupListEvent->DisappearedGroupsCount(), groupListEvent->CurrentGroupsCount(), dstate.SubscriptionState(), dstate.DataState() );//KMsg);

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, sdstate );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, ssstate );

				break;

				}

		case MPresentityGroupContentEvent::KInterfaceId:

				{

				const MPresentityGroupContentEvent* groupContentEvent =

				    TXIMPGetInterface< const MPresentityGroupContentEvent >::From ( aEvent,

				            MXIMPBase::EPanicIfUnknown );

				TBuf<100> sdstate;

				TBuf<100> ssstate;

				_LIT ( Kna, "   Susbcription state is unavailable" );

				_LIT ( Kava, "   Susbcription state is available" );

				_LIT ( KDef, "   Susbcription state is ERROR" );

				const MXIMPDataSubscriptionState&  dstate = groupContentEvent->DataSubscriptionState();

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						ssstate.Copy ( Kna );

						break;

					case 1:

						ssstate.Copy ( Kava );

						break;

					default:

						ssstate.Copy ( KDef );

						break;

					}

				_LIT ( Kdna, "   Data state is unavailable" );

				_LIT ( Kdava, "   Data state is available" );

				_LIT ( KdDef, "   Data state is ERROR" );

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						sdstate.Copy ( Kdna );

						break;

					case 1:

						sdstate.Copy ( Kdava );

						break;

					default:

						sdstate.Copy ( KdDef );

						break;

					}

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "*************BEGIN******************" ) );

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "Recvd PresentityGroupContentEvent New:%d, Updt:%d, Disappeared:%d, Current:%d, SubscrState:%d, DataState:%d" ), groupContentEvent->NewMembersCount(), groupContentEvent->UpdatedMembersCount(), groupContentEvent->DisappearedMembersCount(), groupContentEvent->CurrentMembersCount(), dstate.SubscriptionState(), dstate.DataState() );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, sdstate );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, ssstate );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, groupContentEvent->GroupId().Identity() );

				// print the list contents

				for ( TInt i = 0; i < groupContentEvent->CurrentMembersCount(); i++ )

					{

					const MPresentityGroupMemberInfo& gi = groupContentEvent->CurrentMember ( i );

					RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "Id and displayname for cur group member %d X" ), i );

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, gi.GroupMemberId().Identity() );

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, gi.GroupMemberDisplayName() );

//     EUNIT_ASSERT_EQUALS_DESC( gi.GroupMemberId().Identity(), iContactid[i], "contact id's does'nt match");

//     EUNIT_ASSERT_EQUALS_DESC( gi.GroupMemberDisplayName(), iNickname[i], "contact nickname  does'nt match");

					}

				// print the list contents

				for ( TInt i = 0; i < groupContentEvent->NewMembersCount(); i++ )

					{

					const MPresentityGroupMemberInfo& gi = groupContentEvent->NewMember ( i );

					RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "Id and displayname for new group member %d X" ), i );

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, gi.GroupMemberId().Identity() );

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, gi.GroupMemberDisplayName() );

//     EUNIT_ASSERT_EQUALS_DESC( gi.GroupMemberId().Identity(), iContactid[i], "contact id's does'nt match");

//     EUNIT_ASSERT_EQUALS_DESC( gi.GroupMemberDisplayName(), iNickname[i], "contact nickname  does'nt match");

					}

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "*************END*******************" ) );

				break;

				}

		case MPresenceGrantRequestListEvent::KInterfaceId:

				{

				const MPresenceGrantRequestListEvent* grantreqEvent =

				    TXIMPGetInterface< const MPresenceGrantRequestListEvent >::From ( aEvent,

				            MXIMPBase::EPanicIfUnknown );

				TBuf<100> sdstate;

				TBuf<100> ssstate;

				_LIT ( Kna, "   Susbcription state is unavailable" );

				_LIT ( Kava, "   Susbcription state is available" );

				_LIT ( KDef, "   Susbcription state is ERROR" );

				const  MXIMPDataSubscriptionState&  dstate = grantreqEvent->DataSubscriptionState();

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						ssstate.Copy ( Kna );

						break;

					case 1:

						ssstate.Copy ( Kava );

						break;

					default:

						ssstate.Copy ( KDef );

						break;

					}

				_LIT ( Kdna, "   Data state is unavailable" );

				_LIT ( Kdava, "   Data state is available" );

				_LIT ( KdDef, "   Data state is ERROR" );

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						sdstate.Copy ( Kdna );

						break;

					case 1:

						sdstate.Copy ( Kdava );

						break;

					default:

						sdstate.Copy ( KdDef );

						break;

					}

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "*************BEGIN******************" ) );

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "Recvd Presentity Grant event" ) );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, sdstate );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, ssstate );

				TInt index = grantreqEvent->NewRequestsCount();

				for ( TInt i = 0; i < index; i++ )

					{

					const MPresenceGrantRequestInfo& grantinfo = grantreqEvent->NewRequest ( i );

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, grantinfo.RequestorId().Identity() );

					const TDesC16 dispname = grantinfo.RequestorDisplayName();

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, dispname );

					}

				index = grantreqEvent->CurrentRequestsCount();

				for ( TInt i = 0; i < index; i++ )

					{

					const MPresenceGrantRequestInfo& grantinfo = grantreqEvent->CurrentRequest ( i );

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, grantinfo.RequestorId().Identity() );

					const TDesC16 dispname = grantinfo.RequestorDisplayName();

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, dispname );

					}

				break;

				}

		case MPresenceBlockListEvent::KInterfaceId:

				{

				const MPresenceBlockListEvent* blockListEvent =

				    TXIMPGetInterface< const MPresenceBlockListEvent >::From ( aEvent,

				            MXIMPBase::EPanicIfUnknown );

				TBuf<100> sdstate;

				TBuf<100> ssstate;

				_LIT ( Kna, "   Susbcription state is unavailable" );

				_LIT ( Kava, "   Susbcription state is available" );

				_LIT ( KDef, "   Susbcription state is ERROR" );

				const  MXIMPDataSubscriptionState&  dstate = blockListEvent->DataSubscriptionState();

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						ssstate.Copy ( Kna );

						break;

					case 1:

						ssstate.Copy ( Kava );

						break;

					default:

						ssstate.Copy ( KDef );

						break;

					}

				_LIT ( Kdna, "   Data state is unavailable" );

				_LIT ( Kdava, "   Data state is available" );

				_LIT ( KdDef, "   Data state is ERROR" );

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						sdstate.Copy ( Kdna );

						break;

					case 1:

						sdstate.Copy ( Kdava );

						break;

					default:

						sdstate.Copy ( KdDef );

						break;

					}

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "*************BEGIN******************" ) );

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "Recvd Presentity Grant event" ) );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, sdstate );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, ssstate );

				TInt index = blockListEvent->NewBlocksCount();

				for ( TInt i = 0; i < index; i++ )

					{

					const MPresenceBlockInfo& blockinfo = blockListEvent->NewBlock ( i );

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, blockinfo.BlockedEntityId().Identity() );

					const TDesC16& dispname = blockinfo.BlockedEntityDisplayName();

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, dispname );

					}

				index = blockListEvent->CurrentBlocksCount();

				for ( TInt i = 0; i < index; i++ )

					{

					const MPresenceBlockInfo& blockinfo = blockListEvent->CurrentBlock ( i );

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, blockinfo.BlockedEntityId().Identity() );

					const TDesC16& dispname = blockinfo.BlockedEntityDisplayName();

					RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, dispname );

					}

				break;

				}

		case MPresentityPresenceEvent::KInterfaceId:

				{

				const MPresentityPresenceEvent* PresentityPresenceEvent =

				    TXIMPGetInterface< const MPresentityPresenceEvent >::From ( aEvent,

				            MXIMPBase::EPanicIfUnknown );

				TBuf<100> sdstate;

				TBuf<100> ssstate;

				_LIT ( Kna, "   Susbcription state is unavailable" );

				_LIT ( Kava, "   Susbcription state is available" );

				_LIT ( KDef, "   Susbcription state is ERROR" );

				const  MXIMPDataSubscriptionState&  dstate = PresentityPresenceEvent->DataSubscriptionState();

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						ssstate.Copy ( Kna );

						break;

					case 1:

						ssstate.Copy ( Kava );

						break;

					default:

						ssstate.Copy ( KDef );

						break;

					}

				_LIT ( Kdna, "   Data state is unavailable" );

				_LIT ( Kdava, "   Data state is available" );

				_LIT ( KdDef, "   Data state is ERROR" );

				switch ( dstate.SubscriptionState() )

					{

					case 0:

						sdstate.Copy ( Kdna );

						break;

					case 1:

						sdstate.Copy ( Kdava );

						break;

					default:

						sdstate.Copy ( KdDef );

						break;

					}

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "*************BEGIN******************" ) );

				RFileLogger::WriteFormat ( KDir, KFile, EFileLoggingModeAppend, _L ( "Recvd Presentity PresenceEvent" ) );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, sdstate );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, ssstate );

				RFileLogger::Write ( KDir, KFile, EFileLoggingModeAppend, PresentityPresenceEvent->PresentityId().Identity() );

				const MPresenceInfo& pi = PresentityPresenceEvent->SubscribedPresence();