/*
* Copyright (c) 2002-2005 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:
* commander class for im.
*
*/
// INCLUDE FILES
#include <e32std.h>
#include "impsimcli.h"
#include "impsimcommand.h"
#include "impsfields.h"
#include "impspacked.h"
#include "impsutils.h"
#include "impsdataaccessor.h"
#include "impscdatautils.h"
#include "impsdetailed.h"
// MACROS
#ifndef _DEBUG
#define _NO_IMPS_LOGGING_
#endif
// ================= MEMBER FUNCTIONS =======================
// ----------------------------------------------------------------------------
// CImpsImCommand2::CImpsImCommand2
// ----------------------------------------------------------------------------
CImpsImCommand2::CImpsImCommand2(
TInt aPriority,
RImpsImClient2& aClient ) :
CActive( aPriority ), iClient( aClient )
{
CActiveScheduler::Add( this );
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::NewL
// ----------------------------------------------------------------------------
CImpsImCommand2* CImpsImCommand2::NewL( RImpsImClient2& aClient )
{
// Perform the construction.
CImpsImCommand2* self = new (ELeave)
CImpsImCommand2( EPriorityUserInput, aClient);
CleanupStack::PushL( self );
self->ConstructL();
CleanupStack::Pop(1); // self
return self;
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::ConstructL
// ----------------------------------------------------------------------------
void CImpsImCommand2::ConstructL( )
{
iDetailed = new (ELeave) CImpsDetailed(1);
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::~CImpsImCommand2
// ----------------------------------------------------------------------------
CImpsImCommand2::~CImpsImCommand2()
{
// Cancel any outstanding requests
Cancel();
delete iMessageStream;
delete iDetailed;
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::StartRunL
// ----------------------------------------------------------------------------
void CImpsImCommand2::StartRunL(
TInt aOpId,
TImpsServRequest aType )
{
iOpId = aOpId;
iType = aType;
iState = 0;
if ( IsActive() )
{
User::Leave( KErrServerBusy );
}
// Set this active object active
iStatus = KRequestPending;
SetActive();
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::SetParametersL
// version for newtextmessage
// ----------------------------------------------------------------------------
void CImpsImCommand2::SetParametersL(
const TDesC* aSenderSn,
const MDesCArray* aUserIds,
const TDesC* aGroupId,
const MDesCArray* aScreenNames,
const TDesC& aContent,
TBool aDeliveryReportWanted )
{
// Generate one flat message presentation
if ( IsActive() )
{
User::Leave( KErrServerBusy );
}
if ( !iMessageStream )
{
iMessageStream = HBufC8::NewL( KImpsStreamSize );
}
*iMessageStream = KNullDesC8;
// Initialize internal structure
CImpsFields* fields = CImpsFields::NewL();
CleanupStack::PushL( fields ); // <<< fields
fields->SetMessageType( EImpsSendMessageReq );
CImpsDataAccessor* myAccess = CImpsDataAccessor::NewL( fields );
CleanupStack::PushL( myAccess ); // <<< myAccess
CImpsKey* myKey = CImpsKey::NewLC(); // <<< myKey
CPtrC16Array* grs = new (ELeave) CPtrC16Array(4);
CleanupStack::PushL( grs ); // <<< grs
CPtrC16Array* grns = new (ELeave) CPtrC16Array(4);
CleanupStack::PushL( grns ); // <<< grns
TImpsCDataUtils::AddValuesFromArrayL(
myKey,
KSendMessageElements,
sizeof( KSendMessageElements ) /
sizeof( KSendMessageElements[0] ) );
// add delivery report
myKey->AddL( CREATEKEY( EImpsKeyDeliveryReport, 0 ) );
myAccess->StoreBooleanL( myKey, aDeliveryReportWanted );
myKey->PopL();
if ( aScreenNames )
{
TInt count = aScreenNames->MdcaCount();
for ( TInt i = 0; i < count ; i++ )
{
grns->AppendL( *aGroupId );
}
// GroupID is used as Recipient( Group ( GroupID ) ) also
// if aScreenNames is empty
if ( count == 0 && aGroupId )
{
grs->AppendL( *aGroupId );
}
}
// GroupID is used as Recipient( Group ( GroupID ) ) if
// aScreenNames is omitted.
else if ( aGroupId )
{
grs->AppendL( *aGroupId );
}
myKey->AddL( CREATEKEY( EImpsKeyMessageInfo, 0 ) );
TImpsCDataUtils::SetRecipientsL(
myKey,
myAccess,
grs,
aUserIds,
grns, // ScreenName( GroupId )
aScreenNames ); // ScreenName( SName );
TImpsCDataUtils::SetSenderL(
myKey,
myAccess,
aSenderSn,
NULL );
myKey->PopL();
// notice: MessageInfo:ContentType is default now
// Add actual ContentData
TImpsCDataUtils::SetContentDataL(
myKey, myAccess, aContent );
// Set sender
// This is a "fuzzy" logic.
// aSenderSn + aGroupId -> Sender ( ScreenName( SName, GroupID ) )
// !aSenderSn + !aGroupId -> Sender ( User ( UserID )) added by engine!
// aSenderSn + !aGroupId -> Sender ( User ( UserID ))
// !aSenderSn + aGroupId -> Sender ( Group ( GroupID ))
CleanupStack::PopAndDestroy(4); // >>> grns, grs, myKey, myAccess
// pack, or actullay serialize the message data
TImpsPackedEntity packedMessage( iMessageStream );
TInt myError = packedMessage.PackEntity( *fields );
// Allocate more memory if needed
if ( ( myError != KErrNone ) &&
( iMessageStream->Des().Size() < fields->Size() ) )
{
// notice: consider how to shrink buffer later
// increase the size of the buffer and try again
iMessageStream->Des().SetLength(0); // to avoid copying contents
iMessageStream = iMessageStream->ReAllocL( fields->Size() + 10 );
myError = packedMessage.PackEntity( *fields );
User::LeaveIfError( myError );
}
CleanupStack::PopAndDestroy( 1 ); // fields
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::SetParametersL
// version for newcontentmessage
// ----------------------------------------------------------------------------
void CImpsImCommand2::SetParametersL(
const TDesC* aSenderSn,
const MDesCArray* aUserIds,
const TDesC* aGroupId,
const MDesCArray* aScreenNames,
const TDesC& aContentType,
const TDesC8& aContent,
TBool aDeliveryReportWanted )
{
// Generate one flat message presentation
if ( IsActive() )
{
User::Leave( KErrServerBusy );
}
if ( !iMessageStream )
{
iMessageStream = HBufC8::NewL( KImpsStreamSize );
}
*iMessageStream = KNullDesC8;
// Initialize internal structure
CImpsFields* fields = CImpsFields::NewL();
CleanupStack::PushL( fields ); // <<< fields
fields->SetMessageType( EImpsSendMessageReq );
CImpsDataAccessor* myAccess = CImpsDataAccessor::NewL( fields );
CleanupStack::PushL( myAccess ); // <<< myAccess
CImpsKey* myKey = CImpsKey::NewLC(); // <<< myKey
CPtrC16Array* grs = new (ELeave) CPtrC16Array(4);
CleanupStack::PushL( grs ); // <<< grs
CPtrC16Array* grns = new (ELeave) CPtrC16Array(4);
CleanupStack::PushL( grns ); // <<< grns
TImpsCDataUtils::AddValuesFromArrayL(
myKey,
KSendMessageElements,
sizeof( KSendMessageElements ) /
sizeof( KSendMessageElements[0] ) );
// add delivery report
myKey->AddL( CREATEKEY( EImpsKeyDeliveryReport, 0 ) );
myAccess->StoreBooleanL( myKey, aDeliveryReportWanted );
myKey->PopL();
if ( aScreenNames )
{
TInt count = aScreenNames->MdcaCount();
for ( TInt i = 0; i < count ; i++ )
{
grns->AppendL( *aGroupId );
}
// GroupID is used as Recipient( Group ( GroupID ) ) also
// if aScreenNames is empty
if ( count == 0 && aGroupId )
{
grs->AppendL( *aGroupId );
}
}
// GroupID is used as Recipient( Group ( GroupID ) ) only if
// aScreenNames is omitted.
else if ( aGroupId )
{
grs->AppendL( *aGroupId );
}
myKey->AddL( CREATEKEY( EImpsKeyMessageInfo, 0 ) );
TImpsCDataUtils::SetRecipientsL(
myKey,
myAccess,
grs,
aUserIds,
grns, // ScreenName( GroupId )
aScreenNames ); // ScreenName( SName );
TImpsCDataUtils::SetSenderL(
myKey,
myAccess,
aSenderSn,
NULL );
TPtrC myContentType( aContentType );
TImpsCDataUtils::SetContentTypeL( myAccess, myContentType );
TImpsCDataUtils::SetBinaryContentDataL(
myKey, myAccess, aContent );
// Set sender
// This is a "fuzzy" logic.
// aSenderSn + aGroupId -> Sender ( ScreenName( SName, GroupID ) )
// !aSenderSn + !aGroupId -> Sender ( User ( UserID )) added by engine!
// aSenderSn + !aGroupId -> Sender ( User ( UserID ))
// !aSenderSn + aGroupId -> Sender ( Group ( GroupID ))
CleanupStack::PopAndDestroy(4); // >>> grns, grs, myKey, myAccess
// pack, or actullay serialize the message data
TImpsPackedEntity packedMessage( iMessageStream );
TInt myError = packedMessage.PackEntity( *fields );
// Allocate more memory if needed
if ( ( myError != KErrNone ) &&
( iMessageStream->Des().Size() < fields->Size() ) )
{
// notice: consider how to shrink buffer later
// increase the size of the buffer and try again
iMessageStream->Des().SetLength(0); // to avoid copying contents
iMessageStream = iMessageStream->ReAllocL( fields->Size() + 10 );
myError = packedMessage.PackEntity( *fields );
User::LeaveIfError( myError );
}
CleanupStack::PopAndDestroy( 1 ); // fields
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::SetParametersL
// ----------------------------------------------------------------------------
void CImpsImCommand2::SetParametersL(
const MDesCArray* aBlockEntity,
const MDesCArray* aUnBlockEntity,
TBool aBlockedListInUse,
const MDesCArray* aGrantedEntityList,
const MDesCArray* aUnGrantEntity,
TBool aGrantedListInUse )
{
// Generate one flat message presentation
if ( IsActive() )
{
User::Leave( KErrServerBusy );
}
if ( !iMessageStream )
{
iMessageStream = HBufC8::NewL( KImpsStreamSize );
}
*iMessageStream = KNullDesC8;
// Initialize internal structure
CImpsFields* fields = CImpsFields::NewL();
CleanupStack::PushL( fields ); // <<< fields
fields->SetMessageType( EImpsBlockEntityReq );
CImpsDataAccessor* myAccess = CImpsDataAccessor::NewL( fields );
CleanupStack::PushL( myAccess ); // <<< myAccess
CImpsKey* myKey = CImpsKey::NewLC(); // <<< myKey
TImpsCDataUtils::SetBlockedListRequestL(
myKey,
myAccess,
aBlockEntity,
aUnBlockEntity,
aBlockedListInUse,
aGrantedEntityList,
aUnGrantEntity,
aGrantedListInUse );
CleanupStack::PopAndDestroy(2); // >>> myKey, myAccess
// pack, or actullay serialize the message data
TImpsPackedEntity packedMessage( iMessageStream );
TInt myError = packedMessage.PackEntity( *fields );
// Allocate more memory if needed
if ( ( myError != KErrNone ) &&
( iMessageStream->Des().Size() < fields->Size() ) )
{
// notice: consider how to shrink buffer later
// increase the size of the buffer and try again
iMessageStream->Des().SetLength(0); // to avoid copying contents
iMessageStream = iMessageStream->ReAllocL( fields->Size() + 10 );
myError = packedMessage.PackEntity( *fields );
User::LeaveIfError( myError );
}
CleanupStack::PopAndDestroy( 1 ); // fields
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::RunL
// ----------------------------------------------------------------------------
void CImpsImCommand2::RunL()
{
#ifndef _NO_IMPS_LOGGING_
CImpsClientLogger::Log(_L("CImpsImCommand2: RunL stat=%d h=%d cli=%d"),
iStatus.Int(), (TInt)this, (TInt)&iClient );
#endif
MImpsErrorHandler2* ehandler = iClient.ErrorHandler();
// Errors are handled here only.
// Successful cases are handled by CImpsImHandler.
if ( iStatus == KErrNone )
{
return;
}
// Handler should be registered
if ( ehandler )
{
TInt err( KErrNone );
TRAP( err, ehandler->HandleErrorL(
iStatus.Int(),
iOpId,
NULL,
NULL,
*iClient.CspIdentifier() ));
}
}
// ----------------------------------------------------------------------------
// CImpsImCommand2::DoCancel
// Before calling this the Cancel should have sent to the engine!
// ----------------------------------------------------------------------------
void CImpsImCommand2::DoCancel()
{
}
// End of File