serviceproviders/sapi_messaging/messagingservice/src/messagingservice.cpp
changeset 5 989d2f495d90
child 10 fc9cf246af83
--- /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;
+			}
+		}
+	}
+