// Copyright (c) 2008-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 "cupnpmessagecomposer.h"
#include <http/thttphdrfielditer.h>
#include "mcomposerobserver.h"

__FLOG_STMT(_LIT8(KSubsys,"UPnPComposer");)
__FLOG_STMT(_LIT8(KComponent,"UPnPMessage");)

CUPnPMessageComposer ::~CUPnPMessageComposer ()
	{
	Cancel ();
	iMessageComposer.Close ();
	iDataChain.Close();
	__FLOG(_L8("-> Request composer destroyed"));
	__FLOG_CLOSE;		
	}
CUPnPMessageComposer::CUPnPMessageComposer (MComposerObserver& aObserver)
: CActive (EPriorityNormal),
iObserver ( aObserver )
	{
	CActiveScheduler::Add(this);
	}

void CUPnPMessageComposer::ConstructL ()
	{
	iMessageComposer.OpenL(*this);
	__FLOG_OPEN(KSubsys, KComponent);
	__FLOG(_L8("-> Response composer created"));		
	}

EXPORT_C void CUPnPMessageComposer::NotifyNewBodyData()
	{
	if ( !IsActive () )
		CompleteSelf();
	else
		return;
	}

// From MHttpMessageComposerObserver
void CUPnPMessageComposer::MessageComplete()
	{
	__FLOG(_L8("-> Message complete\n"));
	iFieldIterPos = 0;
	iObserver.ComposingConcluded();
	}

void CUPnPMessageComposer::MessageDataReadyL()
	{
	__FLOG(_L8("-> Got composed request"));
	TPtrC8 dataPtr;
	iMessageComposer.GetMessageData(dataPtr);

	__FLOG_1(_L8("%S"), &dataPtr);
	
	// Notify the observer that there is message data ready to send.
	iDataChain.Close();
	iDataChain.CreateL(dataPtr);
	iObserver.MessageDataReadyL(iDataChain);
	}

TInt CUPnPMessageComposer::HandleComposeError(TInt aError)
	{
	// The Message Composer has found a problem. Report to error to the observer.
	__FLOG_1(_L8("-> HTTP message composer received error: %d"), aError);
	iFieldIterPos = 0;
	iObserver.ComposerError(aError);
	return KErrNone;
	}

//void CUPnPMessageComposer::StartLineL(TPtrC8& /*aVersion*/, TPtrC8& /*aStatusCode*/, TPtrC8& /*aStatusText*/)
//	{
//	ASSERT(0);		
//	}

//TInt CUPnPMessageComposer::NextHeaderL(TPtrC8& /*aHeaderName*/, TPtrC8& /*aHeaderValue*/)
//	{
//	ASSERT(0);	
//	return KErrNone;	
//	}

//MHTTPDataSupplier* CUPnPMessageComposer::HasBodyL()	
//	{
//	ASSERT(0);	
//	return NULL;	
//	}

//TInt CUPnPMessageComposer::NextTrailerL(TPtrC8& /*aHeaderName*/, TPtrC8& /*aHeaderValue*/)
//	{
//	ASSERT(0);	
//	return 0;	
//	}

// From CActive
void CUPnPMessageComposer::RunL ()
	{
	__FLOG_1(_L8("-> HTTP message composer RunL called: %d"), iStatus.Int());
	User::LeaveIfError (iStatus.Int());
	iMessageComposer.MessageInfoAvailable ();		
	}

TInt CUPnPMessageComposer::RunError ()
	{
	__FLOG_0(_L8("-> Composer called RunError"));
	iFieldIterPos = 0;
	iObserver.ComposerError(KErrUnknown);
	return KErrNone;		
	}

void CUPnPMessageComposer::CompleteSelf ()
	{
	TRequestStatus* pStat = &iStatus;
	User::RequestComplete(pStat, KErrNone);
	SetActive();		
	}