// Copyright (c) 2007-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 "chttpclientoptimiser.h"

CHttpClientOptimiser* CHttpClientOptimiser::NewL(MOutputStream& aOutputStream, MInputStreamObserver& aInputStreamObserver)

	{

	CHttpClientOptimiser* me = new(ELeave) CHttpClientOptimiser(aOutputStream, aInputStreamObserver);

	return me;

	}

CHttpClientOptimiser::CHttpClientOptimiser(MOutputStream& aOutputStream, MInputStreamObserver& aInputStreamObserver)

:iOutputStream(&aOutputStream), 

	iInputStreamObserver(&aInputStreamObserver)

	{

	}

CHttpClientOptimiser::~CHttpClientOptimiser()

	{

	delete iDecodedBuffer;

	delete iEncodedBuffer;

	}

void CHttpClientOptimiser::BindOptimiser(MHttpDataOptimiser& aOptimiser)

	{

	iDataOptimiser = &aOptimiser;

	}

// methods from MOutputStream

void CHttpClientOptimiser::SendDataReqL(const TDesC8& aBuffer)

	{

	delete iEncodedBuffer;

	iEncodedBuffer = NULL;

	iDataOptimiser->EncodeL(aBuffer, iEncodedBuffer);

	__ASSERT_ALWAYS(iEncodedBuffer != NULL, User::Invariant() ); // Need to add panic code

	iOutputStream->SendDataReqL(iEncodedBuffer->Des()); // Calls CSocketWriter::SendDataReq()

	}

void CHttpClientOptimiser::Bind(MOutputStreamObserver& aObserver)

	{

	iOutputStream->Bind(aObserver);

	}

void CHttpClientOptimiser::ShutdownReq()

	{

	iOutputStream->ShutdownReq();

	}

void CHttpClientOptimiser::SecureClientReq(const TDesC8& aHostName)

	{

	__ASSERT_ALWAYS((aHostName.Length() > 0), User::Invariant());

	iOutputStream->SecureClientReq(aHostName);

	}

void CHttpClientOptimiser::Close()

	{

	iOutputStream->Close();

	}

const CX509Certificate* CHttpClientOptimiser::ServerCert()

	{

	return (iOutputStream->ServerCert());

	}

TInt CHttpClientOptimiser::CipherSuite(TDes8& aCipherSuite)

	{

	__ASSERT_ALWAYS((aCipherSuite.Length() > 0), User::Invariant());

	return (iOutputStream->CipherSuite(aCipherSuite));

	}

void CHttpClientOptimiser::Reset ()

	{

	iOutputStream->Reset();

	}

void CHttpClientOptimiser::MOutputStream_Reserved()

	{

	User::Invariant();

	}

// methods from MInputStreamObserver

void CHttpClientOptimiser::ReceivedDataIndL(const TDesC8& aBuffer)

	{

	delete iDecodedBuffer;	

	iDecodedBuffer = NULL;

	TBool transFail = EFalse;	

	iDataOptimiser->DecodeL(aBuffer, iDecodedBuffer, transFail);

	if(transFail)

		{

		CurrentResponse()->FailTransactionL();

		}

	else

		{

		__ASSERT_ALWAYS(iDecodedBuffer != NULL, User::Invariant());	

		iInputStreamObserver->ReceivedDataIndL(iDecodedBuffer->Des());		

		}

	}

void CHttpClientOptimiser::SecureServerCnf()

	{

	iInputStreamObserver->SecureServerCnf();

	}

void CHttpClientOptimiser::InputStreamCloseInd(TInt aError)

	{

	iInputStreamObserver->InputStreamCloseInd(aError);

	}

void CHttpClientOptimiser::MInputStreamObserver_Reserved()

	{

	User::Invariant();

	}

void CHttpClientOptimiser::OnReceiveTimeOut()

	{

	}

MHttpResponse* CHttpClientOptimiser::CurrentResponse()

	{

	return (iInputStreamObserver->CurrentResponse());

	}

void CHttpClientOptimiser::SetTCPCorking(TBool /* aValue */)

    {

    }