--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/serviceproviders/sapi_messaging/messagingservice/src/messagingservice.cpp Fri Jul 03 15:51:24 2009 +0100
@@ -0,0 +1,325 @@
+/*
+* 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: Interface to messaging provider
+*
+*/
+
+
+#include <e32base.h>
+#include <msvstd.h>
+#include <msvapi.h>
+#include <msvids.h>
+
+#include "messageheader.h"
+#include "messagingservice.h"
+#include "messagenotify.h"
+#include "sendmessage.h"
+#include "accessfolder.h"
+#include "messagedetail.h"
+#include "changestatus.h"
+
+
+#ifdef __WINSCW__
+ #define KFolderId KMsvDraftEntryId;
+#else
+ #define KFolderId KMsvGlobalInBoxIndexEntryId;
+#endif
+
+
+// ---------------------------------------------------------------------------
+// Two-phased constructor.
+// ---------------------------------------------------------------------------
+//
+EXPORT_C CMessagingService* CMessagingService::NewL()
+ {
+ CMessagingService* self = new (ELeave) CMessagingService;
+ CleanupStack::PushL( self );
+ self->ConstructL();
+ CleanupStack::Pop( self );
+ return self;
+ }
+
+// ---------------------------------------------------------------------------
+// Destructor.
+// ---------------------------------------------------------------------------
+//
+CMessagingService::~CMessagingService()
+ {
+ DeleteAsyncObjects();//deletes all Asychronous objects
+ iAsyncObjArray.Reset();
+ delete iMsgServerSession;
+ delete iSessionObserver;
+ }
+
+// ---------------------------------------------------------------------------
+// Constructor.
+// ---------------------------------------------------------------------------
+//
+CMessagingService::CMessagingService()
+ {
+ }
+
+// ---------------------------------------------------------------------------
+// Constructor.
+// ---------------------------------------------------------------------------
+//
+void CMessagingService::ConstructL()
+ {
+ iSessionObserver = CMessageObserver::NewL();
+
+ iMsgServerSession = CMsvSession::OpenSyncL( *iSessionObserver );
+
+ ((CMessageObserver*)iSessionObserver)->SetSession( iMsgServerSession );
+ }
+
+// ---------------------------------------------------------------------------
+// Sends Message
+// ---------------------------------------------------------------------------
+//
+EXPORT_C void CMessagingService::SendMessageL( CSendMessageParams* aMessageParam,
+ CMsgCallbackBase* aCallback )
+ {
+ CMessageDetailInfo* templateDetail = NULL;
+
+ if ( aMessageParam->TemplateId() > 0 )
+ {
+ CMessageDetail* detailObj = NULL;
+
+ detailObj = CMessageDetail::NewL( *iMsgServerSession );
+
+ CleanupStack::PushL( detailObj );
+
+ detailObj->GetMessageDetailL( aMessageParam->TemplateId(), templateDetail );
+
+ CleanupStack::PopAndDestroy( detailObj );
+ }
+ else if ( aMessageParam->TemplateId() < 0 )
+ {
+ User::Leave( KErrNotSupported );
+ }
+
+
+ CSendMessage* sendMessageObj = CSendMessage::NewL( *iMsgServerSession );
+
+ CleanupStack::PushL( sendMessageObj );
+
+ // aCallback, templateDetail ownership passes to CSendMessage
+ sendMessageObj->SetInputParamsL( aMessageParam, templateDetail, aCallback, this );
+
+ if ( aCallback )
+ {
+ AddAsyncObjL( aCallback->iTransactionId, sendMessageObj );
+ }
+
+ sendMessageObj->SendMessageL();
+
+ CleanupStack::Pop( sendMessageObj );
+
+ if ( !aCallback )
+ delete sendMessageObj;
+ }
+
+// ---------------------------------------------------------------------------
+// Deletes Message
+// ---------------------------------------------------------------------------
+//
+EXPORT_C void CMessagingService::DeleteMessageL( const TMsvId aMessageId,
+ CMsgCallbackBase* /*aCallback*/ )
+ {
+ CMessageChangeStatus* obj = NULL;
+
+ obj = CMessageChangeStatus::NewL( *iMsgServerSession );
+
+ CleanupStack::PushL( obj );
+
+ obj->DeleteMessageL( aMessageId );
+
+ CleanupStack::PopAndDestroy( obj );
+ }
+
+// ---------------------------------------------------------------------------
+// Chages status of message entry
+// ---------------------------------------------------------------------------
+//
+EXPORT_C void CMessagingService::ChangeStatusL( const TMsvId aMessageId,
+ const TMessageStatusFlag aStatusFlag,
+ const TBool aFlagValue,
+ CMsgCallbackBase* /*aCallback*/ )
+ {
+ CMessageChangeStatus* obj = CMessageChangeStatus::NewL( *iMsgServerSession );
+
+ CleanupStack::PushL( obj );
+
+ obj->ChangeStatusL( aMessageId, aStatusFlag, aFlagValue );
+
+ CleanupStack::PopAndDestroy( obj );
+ }
+
+// ---------------------------------------------------------------------------
+// Gives notification for new messages
+// ---------------------------------------------------------------------------
+//
+EXPORT_C TInt CMessagingService::RequestNotification( const TNotificationType /*aNotification*/,
+ CMsgCallbackBase* aCallback )
+ {
+ // Only one object can get the new message notification
+ if( ( (CMessageObserver*)iSessionObserver )->IsActive() )
+ return KErrAlreadyExists;
+
+ CMsgCallbackBase* oldCallback = iSessionObserver->SetCallback( aCallback );
+
+ delete oldCallback;
+
+ return KErrNone;
+ }
+
+// ---------------------------------------------------------------------------
+// Cancels notification
+// ---------------------------------------------------------------------------
+//
+EXPORT_C TInt CMessagingService::CancelNotification( const TNotificationType /*aNotification*/,
+ CMsgCallbackBase* /*aCallback*/ )
+ {
+ CMsgCallbackBase* oldCallback = iSessionObserver->SetCallback( NULL );
+
+ delete oldCallback;
+
+ return KErrNone;
+ }
+
+// ---------------------------------------------------------------------------
+// Gives a sorted list of message Ids
+// ---------------------------------------------------------------------------
+//
+EXPORT_C void CMessagingService::GetIdListL( CFilterParamInfo* aFilterParams,
+ TMsvId /*aFolderId*/,
+ CMsgCallbackBase* /*aCallback*/,
+ CMsvEntrySelection*& aEntrySelection )
+ {
+ // Hard coding for Inbox/Draft
+ // Folder Id can be passed as input parameter, to support access any folder
+ TMsvId folderId = KFolderId;
+
+ CMessagingAccessFolder* obj = CMessagingAccessFolder::NewL( *iMsgServerSession );
+
+ CleanupStack::PushL( obj );
+
+ obj->GetIdListL( folderId, aFilterParams, aEntrySelection );
+
+ CleanupStack::PopAndDestroy( obj );
+ }
+
+EXPORT_C void CMessagingService::GetNextHeaderL( CFilterParamInfo* aFilterParams,
+ CMsvEntrySelection* aEntrySelection,
+ TInt& aIndex,
+ CMsgCallbackBase* /*aCallback*/,
+ CMessageHeader*& aHeader )
+ {
+ CMessagingAccessFolder* obj = CMessagingAccessFolder::NewL( *iMsgServerSession );
+
+ CleanupStack::PushL( obj );
+
+ obj->GetNextHeaderL( aFilterParams, aEntrySelection, aIndex, aHeader );
+
+ CleanupStack::PopAndDestroy( obj );
+ }
+
+// ---------------------------------------------------------------------------
+// Gives details of the message
+// ---------------------------------------------------------------------------
+//
+EXPORT_C void CMessagingService::GetMessageDetailL( const TMsvId aMessageId,
+ CMsgCallbackBase* /*aCallback*/,
+ CMessageDetailInfo*& aResult )
+ {
+ CMessageDetail* obj = CMessageDetail::NewL( *iMsgServerSession );
+
+ CleanupStack::PushL( obj );
+
+ obj->GetMessageDetailL( aMessageId, aResult );
+
+ CleanupStack::PopAndDestroy( obj );
+ }
+
+// ---------------------------------------------------------------------------
+// Adds asynchronous request object
+// ---------------------------------------------------------------------------
+//
+void CMessagingService::AddAsyncObjL( const TInt32 aTransactionId, CActive* aAsyncObj )
+ {
+ TAsyncRequestInfo asyncRequestInfo;
+ asyncRequestInfo.iTransactionId = aTransactionId;
+ asyncRequestInfo.iAsyncObj = aAsyncObj;
+ User::LeaveIfError( iAsyncObjArray.Append( asyncRequestInfo ) );
+ }
+
+// ---------------------------------------------------------------------------
+// Deletes all the asynchronous request objects
+// ---------------------------------------------------------------------------
+//
+void CMessagingService::DeleteAsyncObjects()
+ {
+ TInt pos = iAsyncObjArray.Count() - 1;
+ TAsyncRequestInfo obj;
+ for ( ; pos >= 0; pos-- )
+ {
+ obj = iAsyncObjArray[pos];
+ (obj.iAsyncObj)->Cancel();
+ delete obj.iAsyncObj;
+ }
+ }
+
+
+// ---------------------------------------------------------------------------
+// Cancels asynchronous request
+// ---------------------------------------------------------------------------
+//
+EXPORT_C TInt CMessagingService::Cancel( const TInt32 aTransactionId )
+ {
+ TInt pos = iAsyncObjArray.Count() - 1;
+ TAsyncRequestInfo obj;
+ for ( ; pos >= 0; pos-- )
+ {
+ obj = iAsyncObjArray[pos];
+ if( obj.iTransactionId == aTransactionId )
+ {
+ obj.iAsyncObj->Cancel();
+ delete obj.iAsyncObj;
+ return KErrNone;
+ }
+ }
+ return KErrNotFound;
+ }
+
+
+// ---------------------------------------------------------------------------
+// Notifies Messaging service about the completeion of the request
+// ---------------------------------------------------------------------------
+//
+void CMessagingService::RequestComplete( const TInt32 aTransactionId )
+ {
+ TInt pos = iAsyncObjArray.Count() - 1;
+ TAsyncRequestInfo obj;
+ for ( ; pos >= 0; pos-- )
+ {
+ obj = iAsyncObjArray[pos];
+ if( obj.iTransactionId == aTransactionId )
+ {
+ iAsyncObjArray.Remove(pos);
+ iAsyncObjArray.Compress();
+ return;
+ }
+ }
+ }
+