--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/emailuis/nmframeworkadapter/src/nmfwamessagepartsfetchingoperation.cpp Tue Aug 31 15:04:17 2010 +0300
@@ -0,0 +1,162 @@
+/*
+ * Copyright (c) 2010 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:
+ *
+ */
+
+#include "nmframeworkadapterheaders.h"
+
+/*!
+
+ */
+NmFwaMessagePartsFetchingOperation::NmFwaMessagePartsFetchingOperation(
+ const NmId &mailboxId,
+ const NmId &folderId,
+ const NmId &messageId,
+ const QList<NmId> &messagePartIds,
+ CFSMailClient &mailClient)
+ : mMailboxId(mailboxId),
+ mFolderId(folderId),
+ mMessageId(messageId),
+ mMailClient(mailClient),
+ mLastProgressValue(0),
+ mRequestId(0)
+{
+ NM_FUNCTION;
+
+ // Take own copy of the message part id list.
+ mMessagePartIds.Reset();
+ for (int i=0; i<messagePartIds.count(); ++i) {
+ // let's ignore .Append return value here, the failing messages
+ // just won't be handled at this time
+ int ignore = mMessagePartIds.Append(
+ NmConverter::nmIdToMailMsgId(
+ messagePartIds.at(i)));
+ }
+}
+
+/*!
+
+ */
+NmFwaMessagePartsFetchingOperation::~NmFwaMessagePartsFetchingOperation()
+{
+ NM_FUNCTION;
+
+ doCancelOperation();
+}
+
+/*!
+
+ */
+void NmFwaMessagePartsFetchingOperation::RequestResponseL(TFSProgress aEvent, TInt aRequestId)
+{
+ NM_FUNCTION;
+
+ if (aRequestId == mRequestId) {
+ if (aEvent.iProgressStatus == TFSProgress::EFSStatus_RequestComplete ) {
+ completeOperation(aEvent.iError);
+ }
+ else if (aEvent.iProgressStatus == TFSProgress::EFSStatus_RequestCancelled) {
+ completeOperation(NmCancelError);
+ }
+ else if (aEvent.iProgressStatus == TFSProgress::EFSStatus_Status) {
+ int progress = 0;
+ if (aEvent.iMaxCount > 0) {
+ // calculate progress per cents
+ qreal counterValue = aEvent.iCounter;
+ qreal maxCount = aEvent.iMaxCount;
+ progress = (counterValue / maxCount)*100;
+ }
+ if (progress > mLastProgressValue) {
+ // send only increasing values to prevent downward changing percentage
+ mLastProgressValue = progress;
+ updateOperationProgress(mLastProgressValue);
+ }
+ }
+ }
+}
+
+/*!
+
+ */
+void NmFwaMessagePartsFetchingOperation::doRunAsyncOperation()
+{
+ NM_FUNCTION;
+
+ TRAPD(err, doRunAsyncOperationL());
+ if (err != KErrNone) {
+ completeOperation(NmGeneralError);
+ }
+}
+
+/*!
+ Leaving version from doRunAsyncOperation
+ */
+void NmFwaMessagePartsFetchingOperation::doRunAsyncOperationL()
+{
+ NM_FUNCTION;
+
+ if (mMessagePartIds.Count() > 0) {
+
+ const TFSMailMsgId mailboxId(mMailboxId.pluginId32(), mMailboxId.id32());
+ const TFSMailMsgId folderId(mFolderId.pluginId32(), mFolderId.id32());
+ const TFSMailMsgId messageId(mMessageId.pluginId32(), mMessageId.id32());
+
+ CFSMailMessage *message(NULL);
+ message = mMailClient.GetMessageByUidL(mailboxId, folderId, messageId, EFSMsgDataEnvelope);
+ CleanupStack::PushL(message);
+
+ if (message) {
+ CFSMailMessagePart* messagePart = message->ChildPartL( mMessagePartIds[0] );
+ CleanupStack::PushL(messagePart);
+ if (messagePart) {
+ mRequestId = messagePart->FetchMessagesPartsL(mMessagePartIds,*this,0);
+ }
+ else {
+ completeOperation(NmNotFoundError);
+ }
+ CleanupStack::PopAndDestroy(messagePart);
+ }
+ else {
+ completeOperation(NmNotFoundError);
+ }
+ CleanupStack::PopAndDestroy(message);
+ }
+ else {
+ completeOperation(NmNotFoundError);
+ }
+}
+
+/*!
+ * Complete the operation
+ */
+void NmFwaMessagePartsFetchingOperation::doCompleteOperation()
+{
+ NM_FUNCTION;
+
+ mRequestId = NmNotFoundError;
+}
+
+/*!
+ Cancels the async operation. \sa NmOperation
+ */
+void NmFwaMessagePartsFetchingOperation::doCancelOperation()
+{
+ NM_FUNCTION;
+
+ if (mRequestId >= 0) {
+ TRAP_IGNORE(mMailClient.CancelL(mRequestId));
+ mRequestId = NmNotFoundError;
+ }
+}