/*
* Copyright (c) 2005-2009 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: Notifier client side active object
*
*/
// INCLUDE FILES
#include "mdenotifierao.h"
#include "mdcresult.h"
#include "mdeenginesession.h"
#include "mdesessionimpl.h"
#include "mdenamespacedef.h"
#include "mdcserializationbuffer.h"
#include "mdccommon.pan"
// ========================= MEMBER FUNCTIONS ==================================
CMdENotifierAO* CMdENotifierAO::NewL(
CMdESessionImpl& aSessionImpl, RMdEEngineSession& aSession )
{
CMdENotifierAO* self = CMdENotifierAO::NewLC( aSessionImpl, aSession );
CleanupStack::Pop( self );
return self;
}
CMdENotifierAO* CMdENotifierAO::NewLC(
CMdESessionImpl& aSessionImpl, RMdEEngineSession& aSession )
{
CMdENotifierAO* self =
new ( ELeave ) CMdENotifierAO( aSessionImpl, aSession );
CleanupStack::PushL( self );
self->ConstructL();
return self;
}
CMdENotifierAO::CMdENotifierAO(
CMdESessionImpl& aSessionImpl, RMdEEngineSession& aSession )
: CActive( CActive::EPriorityUserInput )
, iSessionImpl( aSessionImpl )
, iSession( aSession )
{
CActiveScheduler::Add( this );
}
void CMdENotifierAO::ConstructL()
{
}
CMdENotifierAO::~CMdENotifierAO()
{
Cancel(); // Causes call to DoCancel()
delete iDataBuffer;
iIdArray.Close();
iRelationItemArray.Close();
}
void CMdENotifierAO::RegisterL( TUint32 aType, TAny* aObserver,
CMdECondition* aCondition, CMdENamespaceDef& aNamespaceDef )
{
iObserver = aObserver;
iType = aType;
iNamespaceDefId = aNamespaceDef.Id();
CMdCSerializationBuffer* buffer = NULL;
if( aCondition )
{
buffer = CMdCSerializationBuffer::NewLC( aCondition->RequiredBufferSize() );
// only needed, because method needs it as parameter
TUint32 freespaceOffset = 0;
aCondition->SerializeL( *buffer, freespaceOffset );
}
else
{
// create empty serialized condition buffer
buffer = CMdCSerializationBuffer::NewLC( 0 );
}
iSession.DoRegisterL( Id(), iType, *buffer, iNamespaceDefId );
CleanupStack::PopAndDestroy( buffer );
// listen for first event
iSession.DoListen( Id(), &iResultSize, iStatus );
SetActive();
}
TBool CMdENotifierAO::Match( TUint32 aType, TAny* aObserver, CMdENamespaceDef& aNamespaceDef )
{
if( aNamespaceDef.Id() != iNamespaceDefId )
{
return EFalse;
}
if ( iObserver != aObserver )
{
return EFalse;
}
return ( iType & aType );
}
TInt CMdENotifierAO::Id()
{
return (TInt)this;
}
void CMdENotifierAO::DoCancel()
{
TRAP_IGNORE( iSession.DoUnregisterL( Id() ) );
}
void CMdENotifierAO::RunL()
{
const TInt status = iStatus.Int();
if ( status >= KErrNone )
{
if ( status & ( EObjectNotifyAdd | EObjectNotifyModify | EObjectNotifyRemove
| EObjectNotifyPresent | EObjectNotifyNotPresent
| ERelationNotifyAdd | ERelationNotifyModify | ERelationNotifyRemove
| ERelationNotifyPresent | ERelationNotifyNotPresent
| EEventNotifyAdd | EEventNotifyRemove ) )
{
if( !iDataBuffer )
{
iDataBuffer = CMdCSerializationBuffer::NewL( iResultSize() );
}
else if( iDataBuffer->Buffer().MaxSize() < iResultSize() )
{
delete iDataBuffer;
iDataBuffer = NULL;
iDataBuffer = CMdCSerializationBuffer::NewL( iResultSize() );
}
if( iResultSize() )
{
iSession.DoGetDataL( *iDataBuffer, Id() ); // reads ids to the buffer
DecodeIdBufferL(); // decodes ids from the data buffer and puts them to iIdArray
delete iDataBuffer;
iDataBuffer = NULL;
DoNotifyObserver(); // notifies the observer about the event with an array of ids
}
iSession.DoListen( Id(), &iResultSize, iStatus ); // continue listening for events
SetActive();
}
else if ( status & ( ERelationItemNotifyRemove ) ) // a relation was removed
{
if( !iDataBuffer )
{
iDataBuffer = CMdCSerializationBuffer::NewL(iResultSize());
}
else if( iDataBuffer->Size() < (TUint32)iResultSize() )
{
delete iDataBuffer;
iDataBuffer = NULL;
iDataBuffer = CMdCSerializationBuffer::NewL(iResultSize());
}
if(iResultSize())
{
iSession.DoGetDataL( *iDataBuffer, Id() ); // reads ids to the buffer
DecodeRelationItemBufferL(); // decodes ids from the data buffer and puts them to iIdArray
delete iDataBuffer;
iDataBuffer = NULL;
DoNotifyObserver(); // notifies the observer about the event with an array of ids
}
iSession.DoListen( Id(), &iResultSize, iStatus ); // continue listening for events
SetActive();
}
else if ( status == ESchemaModify ) // schema has been modified
{
DoNotifyObserver(); // notifies the observer about the event with an array of ids
iSession.DoListen( Id(), &iResultSize, iStatus ); // continue listening for events
SetActive();
}
else if ( status & ( EObjectNotifyAddWithUri | EObjectNotifyModifyWithUri
| EObjectNotifyRemoveWithUri ) )
{
if( !iDataBuffer )
{
iDataBuffer = CMdCSerializationBuffer::NewL( iResultSize() );
}
else if( iDataBuffer->Buffer().MaxSize() < iResultSize() )
{
delete iDataBuffer;
iDataBuffer = NULL;
iDataBuffer = CMdCSerializationBuffer::NewL( iResultSize() );
}
if( iResultSize() )
{
iSession.DoGetDataL( *iDataBuffer, Id() ); // reads data to the buffer
DecodeDataBufferL(); // decodes ids and uri from the data buffer
delete iDataBuffer;
iDataBuffer = NULL;
DoNotifyObserver(); // notifies the observer about the event
}
iSession.DoListen( Id(), &iResultSize, iStatus ); // continue listening for events
SetActive();
}
}
else
{
// error in notifier mechanism
if( status != KErrServerTerminated )
{
iSession.DoUnregisterL( Id() ); // no response expected
}
else
{
iSessionImpl.NotifyError( status );
}
iSessionImpl.NotifierInError( this );
}
}
TInt CMdENotifierAO::RunError(TInt aError)
{
if( aError == KErrServerTerminated )
{
iSessionImpl.NotifyError( aError );
}
// notifying observer failed - continue listening anyway.
iSessionImpl.NotifierInError( this );
return KErrNone;
}
void CMdENotifierAO::DoNotifyObserver()
{
if( !iObserver )
{
return;
}
const TInt status = iStatus.Int();
switch( iType & status )
{
case EObjectNotifyAdd:
{
MMdEObjectObserver* obs = static_cast<MMdEObjectObserver*>( iObserver );
obs->HandleObjectNotification( iSessionImpl, ENotifyAdd, iIdArray );
break;
}
case EObjectNotifyModify:
{
MMdEObjectObserver* obs = static_cast<MMdEObjectObserver*>( iObserver );
obs->HandleObjectNotification( iSessionImpl, ENotifyModify, iIdArray );
break;
}
case EObjectNotifyRemove:
{
MMdEObjectObserver* obs = static_cast<MMdEObjectObserver*>( iObserver );
obs->HandleObjectNotification( iSessionImpl, ENotifyRemove, iIdArray );
break;
}
case EObjectNotifyPresent:
{
MMdEObjectPresentObserver* obs = static_cast<MMdEObjectPresentObserver*>( iObserver );
obs->HandleObjectPresentNotification( iSessionImpl, ETrue, iIdArray );
break;
}
case EObjectNotifyNotPresent:
{
MMdEObjectPresentObserver* obs = static_cast<MMdEObjectPresentObserver*>( iObserver );
obs->HandleObjectPresentNotification( iSessionImpl, EFalse, iIdArray );
break;
}
case ERelationNotifyAdd:
{
MMdERelationObserver* obs = static_cast<MMdERelationObserver*>( iObserver );
obs->HandleRelationNotification( iSessionImpl, ENotifyAdd, iIdArray );
break;
}
case ERelationNotifyModify:
{
MMdERelationObserver* obs = static_cast<MMdERelationObserver*>( iObserver );
obs->HandleRelationNotification( iSessionImpl, ENotifyModify, iIdArray );
break;
}
case ERelationNotifyRemove:
{
MMdERelationObserver* obs = static_cast<MMdERelationObserver*>( iObserver );
obs->HandleRelationNotification( iSessionImpl, ENotifyRemove, iIdArray );
break;
}
case ERelationNotifyPresent:
{
MMdERelationPresentObserver* obs = static_cast<MMdERelationPresentObserver*>( iObserver );
obs->HandleRelationPresentNotification( iSessionImpl, ETrue, iIdArray );
break;
}
case ERelationNotifyNotPresent:
{
MMdERelationPresentObserver* obs = static_cast<MMdERelationPresentObserver*>( iObserver );
obs->HandleRelationPresentNotification( iSessionImpl, EFalse, iIdArray );
break;
}
case ERelationItemNotifyRemove:
{
MMdERelationItemObserver* obs = static_cast<MMdERelationItemObserver*>( iObserver );
obs->HandleRelationItemNotification( iSessionImpl, ENotifyRemove, iRelationItemArray );
iRelationItemArray.Reset();
iRelationItemArray.Compress();
break;
}
case EEventNotifyAdd:
{
MMdEEventObserver* obs = static_cast<MMdEEventObserver*>( iObserver );
obs->HandleEventNotification( iSessionImpl, ENotifyAdd, iIdArray);
break;
}
case EEventNotifyRemove:
{
MMdEEventObserver* obs = static_cast<MMdEEventObserver*>( iObserver );
obs->HandleEventNotification( iSessionImpl, ENotifyRemove, iIdArray);
break;
}
case ESchemaModify:
{
MMdESchemaObserver* obs = static_cast<MMdESchemaObserver*>( iObserver );
obs->HandleSchemaModified();
break;
}
case EObjectNotifyAddWithUri:
{
MMdEObjectObserverWithUri* obs = static_cast<MMdEObjectObserverWithUri*>( iObserver );
obs->HandleUriObjectNotification( iSessionImpl, ENotifyAdd, iIdArray, iUriArray );
iUriArray.ResetAndDestroy();
iUriArray.Compress();
break;
}
case EObjectNotifyModifyWithUri:
{
MMdEObjectObserverWithUri* obs = static_cast<MMdEObjectObserverWithUri*>( iObserver );
obs->HandleUriObjectNotification( iSessionImpl, ENotifyModify, iIdArray, iUriArray );
iUriArray.ResetAndDestroy();
iUriArray.Compress();
break;
}
case EObjectNotifyRemoveWithUri:
{
MMdEObjectObserverWithUri* obs = static_cast<MMdEObjectObserverWithUri*>( iObserver );
obs->HandleUriObjectNotification( iSessionImpl, ENotifyRemove, iIdArray, iUriArray );
iUriArray.ResetAndDestroy();
iUriArray.Compress();
break;
}
default:
// no observer to call - this should be skipped on server side!
break;
}
iIdArray.Reset();
iIdArray.Compress();
}
void CMdENotifierAO::DecodeIdBufferL()
{
// IDs are always stored in object IDs,
// even if those are actually relation or event IDs
iIdArray.Reset();
iDataBuffer->PositionL( KNoOffset );
const TMdCItemIds& itemIds = TMdCItemIds::GetFromBufferL( *iDataBuffer );
__ASSERT_DEBUG( iNamespaceDefId == itemIds.iNamespaceDefId, User::Panic( _L("Incorrect namespaceDef from returned items!"), KErrCorrupt ) );
iDataBuffer->PositionL( itemIds.iObjectIds.iPtr.iOffset );
iIdArray.ReserveL( itemIds.iObjectIds.iPtr.iCount );
for( TUint32 i = 0; i < itemIds.iObjectIds.iPtr.iCount; ++i )
{
TItemId id;
iDataBuffer->ReceiveL( id );
iIdArray.AppendL( id );
}
}
void CMdENotifierAO::DecodeDataBufferL()
{
iIdArray.Reset();
iUriArray.ResetAndDestroy();
iDataBuffer->PositionL( KNoOffset );
const TMdCItemIds& itemIds = TMdCItemIds::GetFromBufferL( *iDataBuffer );
__ASSERT_DEBUG( iNamespaceDefId == itemIds.iNamespaceDefId, User::Panic( _L("Incorrect namespaceDef from returned items!"), KErrCorrupt ) );
// Get IDs
iDataBuffer->PositionL( itemIds.iObjectIds.iPtr.iOffset );
iIdArray.ReserveL( itemIds.iObjectIds.iPtr.iCount );
for( TUint32 i = 0; i < itemIds.iObjectIds.iPtr.iCount; ++i )
{
TItemId id;
iDataBuffer->ReceiveL( id );
iIdArray.AppendL( id );
}
// Get uri count
TUint32 uriCount ( 0 );
iDataBuffer->ReceiveL( uriCount );
HBufC* uri = NULL;
for( TInt i( 0 ); i < uriCount; i++ )
{
//Get uri
uri = iDataBuffer->ReceiveDes16L();
CleanupStack::PushL( uri );
iUriArray.AppendL( uri );
CleanupStack::Pop( uri );
}
}
void CMdENotifierAO::DecodeRelationItemBufferL()
{
iRelationItemArray.Reset();
iDataBuffer->PositionL( KNoOffset );
const TMdCItems& items = TMdCItems::GetFromBufferL( *iDataBuffer );
__ASSERT_DEBUG( iNamespaceDefId == items.iNamespaceDefId, User::Panic( _L("Incorrect namespaceDef from returned items!"), KErrCorrupt ) );
CMdENamespaceDef& namespaceDef = iSessionImpl.GetNamespaceDefL( iNamespaceDefId );
iDataBuffer->PositionL( items.iRelations.iPtr.iOffset );
TMdERelation relation;
iRelationItemArray.ReserveL( items.iRelations.iPtr.iCount );
for (TInt i = 0; i < items.iRelations.iPtr.iCount; ++i )
{
relation.DeSerializeL( *iDataBuffer, namespaceDef );
if ( relation.Id() )
{
iRelationItemArray.AppendL( relation );
}
}
}