--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/ipsservices/ipssosplugin/src/ipsplgmessagepartstoreroperation.cpp	Fri Apr 16 14:51:52 2010 +0300
@@ -0,0 +1,247 @@
+/*
+ * Copyright (c) 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: 
+ *
+ */
+
+#include <utf.h>
+
+#include "ipsplgmessagepartstoreroperation.h"
+#include "CFSMailPlugin.h"
+#include "emailtrace.h"
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+CIpsPlgMessagePartStorerOperation* CIpsPlgMessagePartStorerOperation::NewL(
+        CMsvSession& aMsvSession, TRequestStatus& aObserverRequestStatus,
+        CFSMailPlugin& aPlugin,
+        RPointerArray<CFSMailMessagePart> &aMessageParts,
+        MFSMailRequestObserver& aFSOperationObserver, const TInt aRequestId)
+    {
+    FUNC_LOG;
+    CIpsPlgMessagePartStorerOperation* self =
+            new (ELeave) CIpsPlgMessagePartStorerOperation(aMsvSession,
+                    aObserverRequestStatus, aPlugin, aMessageParts,
+                    aFSOperationObserver, aRequestId);
+
+    CleanupStack::PushL(self);
+    self->ConstructL();
+    CleanupStack::Pop(self);
+    return self;
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+CIpsPlgMessagePartStorerOperation* CIpsPlgMessagePartStorerOperation::NewLC(
+        CMsvSession& aMsvSession, TRequestStatus& aObserverRequestStatus,
+        CFSMailPlugin& aPlugin,
+        RPointerArray<CFSMailMessagePart> &aMessageParts,
+        MFSMailRequestObserver& aFSOperationObserver, const TInt aRequestId)
+    {
+    FUNC_LOG;
+    CIpsPlgMessagePartStorerOperation* self =
+            CIpsPlgMessagePartStorerOperation::NewL(aMsvSession,
+                    aObserverRequestStatus, aPlugin, aMessageParts,
+                    aFSOperationObserver, aRequestId);
+    CleanupStack::PushL(self);
+    return self;
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+CIpsPlgMessagePartStorerOperation::~CIpsPlgMessagePartStorerOperation()
+	{
+	FUNC_LOG;
+	// Cancel outstanding request, clear data buffers
+	Cancel();
+    iMessageParts.ResetAndDestroy();
+    iMessageParts.Close();
+	if (iDataBuffer)
+		{
+		delete iDataBuffer;
+		iDataBuffer = NULL;
+		}
+	}
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+void CIpsPlgMessagePartStorerOperation::DoCancel()
+    {
+    FUNC_LOG;
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+const TDesC8& CIpsPlgMessagePartStorerOperation::ProgressL()
+    {
+    FUNC_LOG;
+    return KNullDesC8;
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+CIpsPlgMessagePartStorerOperation::CIpsPlgMessagePartStorerOperation(
+        CMsvSession& aMsvSession, TRequestStatus& aObserverRequestStatus,
+        CFSMailPlugin& aPlugin,
+        RPointerArray<CFSMailMessagePart> &aMessageParts,
+        MFSMailRequestObserver& aFSOperationObserver, const TInt aRequestId) :
+    CMsvOperation(aMsvSession, CActive::EPriorityStandard,
+            aObserverRequestStatus), iPlugin(aPlugin), iMessageParts(
+            aMessageParts), iFSOperationObserver(aFSOperationObserver),
+            iRequestId(aRequestId), iExecutionIndex(0), iDataBuffer(NULL)
+    {
+    FUNC_LOG;
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+void CIpsPlgMessagePartStorerOperation::ConstructL()
+    {
+    FUNC_LOG;
+    CActiveScheduler::Add(this);
+    iStatus = KRequestPending;
+    SetActive();
+    TRequestStatus* status = &iStatus;
+    User::RequestComplete(status, KErrNone);
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+void CIpsPlgMessagePartStorerOperation::RunL()
+	{
+	FUNC_LOG;
+	
+	// Clear data buffer if it was used in last request
+	if (iDataBuffer)
+		{
+		delete iDataBuffer;
+		iDataBuffer = NULL;
+		}
+	
+	if (!StoreNextPartL())
+		{
+		if (&iFSOperationObserver)
+			{
+			TFSProgress prog =
+				{
+				TFSProgress::EFSStatus_RequestComplete, 0, 0, 0
+				};
+			TRAP_IGNORE( iFSOperationObserver.RequestResponseL( prog, iRequestId ) );
+			}
+		TRequestStatus* status = &iObserverRequestStatus;
+		User::RequestComplete(status, KErrNone);
+		}
+	}
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+TInt CIpsPlgMessagePartStorerOperation::RunError(TInt aError)
+    {
+    FUNC_LOG;
+    TInt error = aError;
+    switch (aError)
+        {
+        // Handling RunL errors can be done here
+        default:
+            error = KErrNone;
+        }
+    return error;
+    }
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+TBool CIpsPlgMessagePartStorerOperation::StoreNextPartL()
+	{
+	TBool partFound = EFalse;
+	TRequestStatus* status;
+	TInt partsCount = iMessageParts.Count();
+	if (partsCount && iExecutionIndex < partsCount)
+		{
+		partFound = ETrue;
+		CFSMailMessagePart* part = iMessageParts[iExecutionIndex];
+
+		// Change execution index to point next part
+		iExecutionIndex++;
+
+		// Check if part was found
+		if (part)
+			{
+			if (part->GetContentType().Compare(KFSMailContentTypeTextPlain) == 0)
+				{
+				StoreTextPlainPartL(part);
+				}
+			else if (part->GetContentType().Compare(KFSMailContentTypeTextHtml) == 0)
+				{
+				StoreTextHtmlPartL(part);
+				}
+			}
+		else
+			{
+			status = &iObserverRequestStatus;
+			iStatus = KRequestPending;
+			SetActive();
+			User::RequestComplete(status, KErrNotFound);
+			}
+		}
+	return partFound;
+	}
+	
+
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+void CIpsPlgMessagePartStorerOperation::StoreTextPlainPartL(
+		CFSMailMessagePart* aPart)
+	{
+	User::LeaveIfNull(aPart);
+	TRequestStatus* status;
+	
+	// Text buffer for plain text content - synchronous function
+	HBufC* contentBuffer = aPart->GetLocalTextContentLC();
+	iPlugin.SetContentL(*contentBuffer, aPart->GetMailBoxId(),
+			aPart->GetFolderId(), aPart->GetMessageId(), aPart->GetPartId());
+	CleanupStack::PopAndDestroy(contentBuffer);
+
+	// Request should be completed immediately, because sync function was used
+	status = &iStatus;
+	iStatus = KRequestPending;
+	SetActive();
+	User::RequestComplete(status, KErrNone);
+	}
+
+// ---------------------------------------------------------------------------
+// ---------------------------------------------------------------------------
+void CIpsPlgMessagePartStorerOperation::StoreTextHtmlPartL(
+		CFSMailMessagePart* aPart)
+	{
+	User::LeaveIfNull(aPart);
+	
+	// Text buffer for html text content
+	HBufC* data16 = aPart->GetLocalTextContentLC();
+
+	// Convert from 16 to 8 bit data - data must exist until request is completed
+	iDataBuffer = HBufC8::NewL((data16->Length() * 2) + 1);
+	TPtr8 ptr8(iDataBuffer->Des());
+	CnvUtfConverter::ConvertFromUnicodeToUtf8(ptr8, *data16);
+
+	// Get text/html part file for write
+	RFile file = aPart->GetContentFileL();
+	CleanupClosePushL(file);
+
+	// Write new content to text/html part file - async function
+	file.Write(0, *iDataBuffer, iDataBuffer->Length(), iStatus);
+
+	CleanupStack::PopAndDestroy(2, data16);
+	SetActive();
+	}