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

#include "chttpcontentreader.h"

#include "chttpclienttransaction.h"

#include <thttpevent.h>

CHttpDataSender* CHttpDataSender::New(RHTTPTransaction aTrans, CHttpClientTransaction& aClientTrans, MHttpContentSource* aSource)

    {

    return new CHttpDataSender(aTrans, aClientTrans, aSource);

    }

CHttpDataSender* CHttpDataSender::New(RHTTPTransaction aTrans, CHttpClientTransaction& aClientTrans, RFile& aFile)

    {

    CHttpDataSender* self = new CHttpDataSender(aTrans, aClientTrans);

    if(self)

        {

        if(self->Construct(aFile) != KErrNone)

            {

            delete self;

            self = NULL;

            }

        }

    return self;

    }

CHttpDataSender::CHttpDataSender(RHTTPTransaction aTrans, CHttpClientTransaction& aClientTrans)

: iTransaction(aTrans),iClientTrans(aClientTrans),

iDynamicContentLen(KErrNotFound)

	{

	}

CHttpDataSender::CHttpDataSender(RHTTPTransaction aTrans, CHttpClientTransaction& aClientTrans, MHttpContentSource* aSource)

: iTransaction(aTrans),iDynamicSource(aSource),

iClientTrans(aClientTrans)

    {

    }

CHttpDataSender::~CHttpDataSender()

    {

    delete iFileReader;

    }

TInt CHttpDataSender::Construct(RFile& aFile)

    {

    iFileReader = CHttpFileReader::New(aFile, *this);

    return iFileReader ? KErrNone : KErrNoMemory;

    }

// From MHttpDataSender

void CHttpDataSender::Notify(const TDesC8& aData, TBool aLast)

	{

	__ASSERT_DEBUG(iDataPtr.Length() == 0, User::Invariant());

	iDataPtr.Set(aData.Ptr(), aData.Length());

	iLastPart = aLast;

	if(!iInCallback)

	    {

	    iTransaction.SendEvent(THTTPEvent::ENotifyNewRequestBodyPart, THTTPEvent::EOutgoing, THTTPFilterHandle::EClient);

	    }

	}

void CHttpDataSender::Error(TInt aError)

	{

	THTTPEvent evt(aError);

	iTransaction.SendEvent(evt, THTTPEvent::EIncoming, THTTPFilterHandle::EClient);

	}

// From MHTTPDataSupplier

TBool CHttpDataSender::GetNextDataPart(TPtrC8& aDataPart)

	{

	aDataPart.Set(KNullDesC8());

	iInCallback = ETrue;

	if(iDataPtr.Length() == 0)

	    {

	    RequestData();

	    }

	if(iDataPtr.Length() > 0)

	    {

	    iTransfferedDataSize += iDataPtr.Length();

	    iClientTrans.OnTransferProgress(iTransaction.Request().Body()->OverallDataSize(), iTransfferedDataSize);

	    aDataPart.Set(iDataPtr);

	    iWaitingForRelease = ETrue;

	    }

	iInCallback = EFalse;

	return iLastPart;

	}

void CHttpDataSender::ReleaseData()

	{

	if(iWaitingForRelease)

	    {

	    iDataPtr.Set(NULL, 0);

	    if(!iLastPart)

	        RequestData();

	    iWaitingForRelease = EFalse;

	    }

	}

TInt CHttpDataSender::OverallDataSize()

	{

	if(iFileReader)

	    return iFileReader->Size();

	return iDynamicContentLen;

	}

TInt CHttpDataSender::Reset()

	{

	return KErrNone;

	}

void CHttpDataSender::RequestData()

    {

    if(iDynamicSource)

        {

        THttpContentSourceOp op(this);

        iDynamicSource->OnData(op);

        }

    else if(iFileReader)

        {

        iFileReader->Read();

        }

    }

void CHttpDataSender::SetDynamicContentLen(TInt aLen)

    {

    iDynamicContentLen = aLen;

    }