--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/pushmtm/Plugins/PushContentHandler/CMultiPartRelAndAltContentHandler.cpp	Wed Sep 01 12:31:04 2010 +0100
@@ -0,0 +1,335 @@
+/*
+* Copyright (c) 2002 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:  Implementation of CMultiPartRelAndAltContentHandler.
+*
+*/
+
+// INCLUDE FILES
+
+#include "CMultiPartRelAndAltContentHandler.h"
+#include <push/cmultipartiteratorbase.h>
+#include <msvids.h>
+
+// Constants
+
+_LIT(KReserved, "Reserved");
+
+/**
+ * Static Factory Construction
+ *
+ * version of NewLC which leaves nothing
+ * on the cleanup stack
+ */
+CMultiPartRelAndAltContentHandler* CMultiPartRelAndAltContentHandler::NewL()
+	{
+	CMultiPartRelAndAltContentHandler* self = new (ELeave) CMultiPartRelAndAltContentHandler;
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CleanupStack::Pop(self);
+	return self;
+	}
+
+/**
+ * Default d'tor
+ */
+CMultiPartRelAndAltContentHandler::~CMultiPartRelAndAltContentHandler()
+	{
+    Cancel();
+	delete iMultiMessage;
+    delete iMsvSession;
+	}
+
+/**
+ * The Multipart Related Content handler 
+ * Index number : ESLContentHandlerIndex 
+ */ 
+CMultiPartRelAndAltContentHandler::CMultiPartRelAndAltContentHandler()
+:   CContentHandlerBase(), 
+    iSavedMsgId( KMsvNullIndexEntryId )
+	{
+	}
+
+/**
+ *  This will complete initialization of the object
+ */
+void CMultiPartRelAndAltContentHandler::ConstructL()
+	{
+    iMsvSession = CMsvSession::OpenSyncL( *this );
+	CActiveScheduler::Add(this);
+	}
+
+#ifdef __TEST_MULTIPART_REL_SUPP
+
+/**
+* Setup the multipart message.
+*/
+void CMultiPartRelAndAltContentHandler::LoadMultiPartMsgL()
+	{
+#ifdef _DEBUG
+	_LIT(KNullMsg,"NULL CPushMessage");
+	__ASSERT_DEBUG( iMessage != 0 , User::Panic(KNullMsg,0));
+#endif
+	TPtrC contentType;
+	iMessage->GetContentType(contentType);
+	if (!contentType.FindF(KMultipartText))
+		iMultiMessage = CMultipartTextIterator::NewL(*iMessage);
+	else if (!contentType.FindF(KMultipartBin))
+		iMultiMessage = CMultipartBinIterator::NewL(*iMessage);
+	else
+		User::Leave(KErrCorrupt);
+	iMultiMessage->FirstL();
+	IdleComplete();
+	}
+
+/**
+ *	Saves message part to messaging server
+ */
+void CMultiPartRelAndAltContentHandler::HandlePartL()
+	{
+	CPushMessage* msgPart = iMultiMessage->PartL();
+	CleanupStack::PushL(msgPart);
+
+	// Create a new Unknown Push Entry to hold the header and body data
+	CUnknownPushMsgEntry* msgEntry=CUnknownPushMsgEntry::NewL();
+	CleanupStack::PushL(msgEntry);
+	// Get the header
+	TPtrC8 header;
+	msgPart->GetHeader(header);
+	//Get the From field
+	TPtrC8 from;
+	if (!msgPart->GetBinaryHeaderField(EHttpFrom,from) &&
+		!msgPart->GetBinaryHeaderField(EHttpXWapInitiatorURI,from) &&
+		!msgPart->GetBinaryHeaderField(EHttpContentLocation,from) )
+		{
+		from.Set(KNullDesC8);
+		}
+	// Get the body
+	TPtrC8 body;
+	msgPart->GetMessageBody(body);
+	TPtrC content;
+	msgPart->GetContentType(content);
+
+	//Set fields of the Unknown Entry
+	msgEntry->SetHeaderL(header);
+	msgEntry->SetMessageDataL(body);	
+	msgEntry->SetFromL(from);
+	//Need this next  bit so UI knows what to do with the data in the Push Entry
+	msgEntry->SetContentTypeL( content );
+
+	msgEntry->SaveL( *iMsvSession, iSavedMsgId );
+	CleanupStack::PopAndDestroy( 2 ); //msgEntry, msgPart
+	
+	iState = ENextPart;
+	IdleComplete();
+
+	}
+
+/**
+ *	Move multipart iterator to the next part
+ */
+void CMultiPartRelAndAltContentHandler::NextPartL()
+	{
+	if (iMultiMessage->NextL())
+		{
+		iState = EHandlePart;
+		}
+	else 
+		{
+		iState = EDone;
+		}
+	IdleComplete();
+	}
+
+/**
+ * 
+ */
+void CMultiPartRelAndAltContentHandler::SaveMsgRootL()
+	{
+	TPtrC8 msgHeaderPtr;
+	iMessage->GetHeader(msgHeaderPtr);
+	CMultiPartPushMsgEntry* msgEntry=CMultiPartPushMsgEntry::NewL();
+	CleanupStack::PushL(msgEntry);
+	msgEntry->SetHeaderL(msgHeaderPtr); //Top level entry
+	TPtrC contentType;
+	iMessage->GetContentType(contentType);
+	msgEntry->SetContentTypeL(contentType);
+
+	iSavedMsgId = msgEntry->SaveL(*iMsvSession, 
+                                  KMsvGlobalInBoxIndexEntryId);
+	CleanupStack::PopAndDestroy();//msgEntry
+	}
+
+/**
+ * Loads multipart data and creates multipart head entry in the message 
+ * server index.
+ * @throw KErrCorrupt - message data is corrupt 
+ * @throw KErrNoMemory - insufficient free memory to complete operations
+ */
+
+void CMultiPartRelAndAltContentHandler::LoadMsgDataL()
+	{
+	LoadMultiPartMsgL();
+	SaveMsgRootL();
+	iState = EHandlePart;
+	}
+
+void CMultiPartRelAndAltContentHandler::SetMsgCorruptFlagL()
+	{
+	CMsvEntry* msvEntry = iMsvSession->GetEntryL( iSavedMsgId );
+	CleanupStack::PushL( msvEntry );
+	TMsvEntry entry = msvEntry->Entry();
+	// get the iMtmData1 value & zero bits 0-3 then add new status
+	TInt32 mtmdata1 = ( entry.iMtmData1 & 0xFFFFFFF0 );
+	mtmdata1 += CPushMsgEntryBase::EPushMsgStatusCorrupt;
+	// Now set values for TMsvEntry and update the server entry
+	entry.iMtmData1 = mtmdata1;
+	msvEntry->ChangeL( entry );
+
+	CleanupStack::PopAndDestroy( msvEntry );
+	}
+
+#endif // __TEST_MULTIPART_REL_SUPP
+
+/**
+ * Async. Version
+ */
+void CMultiPartRelAndAltContentHandler::HandleMessageL( CPushMessage* aPushMsg, 
+                                                        TRequestStatus& aStatus )
+	{
+#ifdef __TEST_MULTIPART_REL_SUPP
+	iAcknowledge=ETrue;
+	SetConfirmationStatus(aStatus);
+	iMessage = aPushMsg;
+	iState = ELoadMsgData;
+	IdleComplete();
+#else // __TEST_MULTIPART_REL_SUPP
+	iAcknowledge=ETrue;
+	SetConfirmationStatus(aStatus);
+	iMessage = aPushMsg;
+    // Drop all multipart messages.
+    iState = EDone;
+	IdleComplete();
+#endif // __TEST_MULTIPART_REL_SUPP
+	}
+
+/**
+ * Sync. Version
+ */
+void CMultiPartRelAndAltContentHandler::HandleMessageL( CPushMessage* aPushMsg )
+	{
+#ifdef __TEST_MULTIPART_REL_SUPP
+	iAcknowledge=EFalse;
+	iMessage = aPushMsg;
+	iState = ELoadMsgData;
+	IdleComplete();
+#else // __TEST_MULTIPART_REL_SUPP
+	iAcknowledge=EFalse;
+	iMessage = aPushMsg;
+    // Drop all multipart messages.
+    iState = EDone;
+	IdleComplete();
+#endif // __TEST_MULTIPART_REL_SUPP
+	}
+
+void CMultiPartRelAndAltContentHandler::CancelHandleMessage()
+	{
+    Cancel();
+	}
+
+void CMultiPartRelAndAltContentHandler::CPushHandlerBase_Reserved1()
+	{
+	User::Panic(KReserved, KErrNotSupported);
+	}
+
+void CMultiPartRelAndAltContentHandler::CPushHandlerBase_Reserved2()
+	{
+	User::Panic(KReserved, KErrNotSupported);
+	}
+
+void CMultiPartRelAndAltContentHandler::DoCancel()
+	{
+	Complete( KErrCancel );
+	}
+
+/**
+*RunL handles each part separately
+*/
+void CMultiPartRelAndAltContentHandler::RunL()
+	{
+	switch(iState)
+		{
+
+#ifdef __TEST_MULTIPART_REL_SUPP
+
+        case ELoadMsgData:
+            {
+			LoadMsgDataL();
+			break;
+            }
+		case EHandlePart:
+            {
+			HandlePartL();
+			break;
+            }
+		case ENextPart:
+            {
+			NextPartL();
+			break;
+            }
+
+#endif // __TEST_MULTIPART_REL_SUPP
+
+        case EDone:
+            {
+			Complete(KErrNone);
+			break;
+            }
+		default:
+            {
+			break;
+            }
+		}
+	}
+
+/** 
+ * Clean up
+ */
+TInt CMultiPartRelAndAltContentHandler::RunError(TInt aError)
+	{
+	iState=EDone;
+
+#ifdef __TEST_MULTIPART_REL_SUPP
+
+    if (iSavedMsgId != KMsvNullIndexEntryId)
+		{
+		TRAPD(error, SetMsgCorruptFlagL());
+		}
+
+#endif // __TEST_MULTIPART_REL_SUPP
+
+	Complete(aError);
+	return KErrNone;
+	}
+
+// ---------------------------------------------------------
+// CMultiPartRelAndAltContentHandler::HandleSessionEventL
+// ---------------------------------------------------------
+//
+void CMultiPartRelAndAltContentHandler::HandleSessionEventL( 
+                                             TMsvSessionEvent /*aEvent*/, 
+                                             TAny* /*aArg1*/, 
+                                             TAny* /*aArg2*/, 
+                                             TAny* /*aArg3*/ )
+    {}
+