/*

* Copyright (c) 2002-2005 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 FILES

#include <http.h>

#include "senrfiletxnstate.h"

#include "senhttpchannel.h"

#include "sendebug.h"

#include "senlogger.h"

#include "senasynctimeout.h"

// MACROS

const TInt KDataPartLength = 1024;

// =========================== MEMBER FUNCTIONS ===============================

// ----------------------------------------------------------------------------

// CSenRfileTxnState::CSenRfileTxnState

// C++ default constructor can NOT contain any code, that

// might leave.

// ----------------------------------------------------------------------------

//

CSenRfileTxnState::CSenRfileTxnState(MSenResponseObserver& aObserver)//,

                           //RFileLogger* aLog)

    : CSenTxnState (aObserver/*, iLog(aLog)*/)

    {

    }

// ----------------------------------------------------------------------------

// CSenRfileTxnState::NewLC

// ----------------------------------------------------------------------------

//

CSenRfileTxnState* CSenRfileTxnState::NewLC(MSenResponseObserver& aObserver,

                                  //RFileLogger* aLog,

                                  const TDesC8* aUri,

                                  CSenHttpChannelImpl* aHttpClient,

                                  const TDesC8& aContentType,

                                  const RFile& aContent)

    {

    CSenRfileTxnState* pNew = new (ELeave) CSenRfileTxnState(aObserver);//, aLog);

    CleanupStack::PushL(pNew);

    pNew->ConstructL(aUri, aHttpClient,aContentType, aContent);

    return pNew;

    }

// ----------------------------------------------------------------------------

// CSenRfileTxnState::NewL

// ----------------------------------------------------------------------------

//

CSenRfileTxnState* CSenRfileTxnState::NewL(MSenResponseObserver& aObserver,

                                 //RFileLogger* aLog,

                                 const TDesC8* aUri,

                                 CSenHttpChannelImpl* aHttpClient,

                                 const TDesC8& aContentType,

                                 const RFile& aContent)

    {

    CSenRfileTxnState* pNew = NewLC( aObserver, /*aLog,*/ aUri,

                                aHttpClient,aContentType, aContent );

    CleanupStack::Pop(pNew);

    return pNew;

    }

// ----------------------------------------------------------------------------

// CSenRfileTxnState::ConstructL

// ----------------------------------------------------------------------------

//

void CSenRfileTxnState::ConstructL(const TDesC8* aUri,

                              CSenHttpChannelImpl* aHttpClient,

                              const TDesC8& aContentType,

                              const RFile& aContent)

    {

    __ASSERT_ALWAYS(aUri != NULL,

                    User::Panic(KRequestUriNullPanicText,

                                CSenHttpChannel::ERequestUriNull));

    iRequestUri = aUri->AllocL();

    iFile = aContent;

    iHttpClient = aHttpClient ;

    iSize = 0 ;

    TInt err = iFile.Size(iSize) ;

    if(iSize >0)

        {

            iHasRequestBody = ETrue;

            iPostContentType = aContentType.AllocL();

        }    

    }

// ----------------------------------------------------------------------------

// CSenRfileTxnState::~CSenRfileTxnState

// ----------------------------------------------------------------------------

//

CSenRfileTxnState::~CSenRfileTxnState()

    {

    iFile.Close();

    }

// ----------------------------------------------------------------------------

// CSenRfileTxnState::GetNextDataPart

// Implementation of the pure virtual method from MHTTPDataSupplier

// ----------------------------------------------------------------------------

//

TBool CSenRfileTxnState::GetNextDataPart(TPtrC8& aDataPart)

    {

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenRfileTxnState::GetNextDataPart")));

    TBool noMoreData = ETrue;   // No more data

    TInt retVal(KErrNone);

    if ( iFile.SubSessionHandle() )    // Send in a chunked mode from file

        {        

        if ( !iReadData )

            {

            TRAP(retVal,

		            iReadData = HBufC8::NewL( KDataPartLength );  

		            TPtr8 ptr = iReadData->Des();

		            User::LeaveIfError( iFile.Read( ptr, KDataPartLength ) );

            		);

            // More content remains if buffer is full

            // If buffer is not full (!EOF) => no more data

            if (iReadData->Length() == KDataPartLength)

	            {

	            iMoreContent = ETrue ;	

	            }

	            else

	            {

	            iMoreContent = EFalse ;

	            }

            }

        // Check if more content to be send (false = more data)  

        noMoreData = !MoreBody();        

        }

    aDataPart.Set( *iReadData );

    return noMoreData;

    }

// ----------------------------------------------------------------------------

// CSenRfileTxnState::ReleaseData

// Implementation of the pure virtual method from MHTTPDataSupplier

// ----------------------------------------------------------------------------

//

void CSenRfileTxnState::ReleaseData()

    {

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenRfileTxnState::ReleaseData")));

    if ( MoreBody() )    // More data

        {

        TRAP_IGNORE( iHttpClient->NotifyMoreBodyL() );

        }

    delete iReadData;

    iReadData = NULL;   

    }

// ----------------------------------------------------------------------------

// CSenRfileTxnState::OverallDataSize

// Implementation of the pure virtual method from MHTTPDataSupplier

// ----------------------------------------------------------------------------

//

TInt CSenRfileTxnState::OverallDataSize()

    {

	// File is uploaded in chunked mode.

    TLSLOG_FORMAT((KSenHttpChannelLogChannelBase , KNormalLogLevel, _L8("CSenRfileTxnState::OverallDataSize() [%d]"), iSize));	

	    if(iFile.SubSessionHandle())

		    {

		    return iSize;	

		    }

	    else

			{

			return KErrNotFound;	

			}

    }

// ----------------------------------------------------------------------------

// CSenRfileTxnState::Reset

// Implementation of the pure virtual method from MHTTPDataSupplier

// ----------------------------------------------------------------------------

//

TInt CSenRfileTxnState::Reset()

    {

    TLSLOG(KSenHttpChannelLogChannelBase , KMinLogLevel,(_L("CSenRfileTxnState::Reset")));

    if ( iFile.SubSessionHandle() )

        {

        TInt pos;

        return iFile.Seek( ESeekStart, pos );   // Go to

        }

    return KErrNone;     // KErrNone if reset succeeded

    }

// ---------------------------------------------------------------------------

// Return flag if more body exist to be send in chunked mode.

// ---------------------------------------------------------------------------

//

TBool CSenRfileTxnState::MoreBody() const

    {

    // File == chunked mode

    return ( iFile.SubSessionHandle() && iMoreContent );

    }

//  End of File