// 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 <http.h>
#include "chttpclienttransaction.h"
#include "chttprequestcomposer.h"
#include "chttpresponseparser.h"
#include "chttpconnectionmanager.h"

CHttpClientTransaction* CHttpClientTransaction::NewL(RHTTPTransaction aTransaction)
	{
	CHttpClientTransaction* self = new (ELeave) CHttpClientTransaction(aTransaction);
	return self;	
	}
	
CHttpClientTransaction::~CHttpClientTransaction()
	{
	}

CHttpClientTransaction::CHttpClientTransaction(RHTTPTransaction aTransaction)
: CProtTransaction(aTransaction), iStringTable(RHTTPSession::GetTable())
	{
	}
	
void CHttpClientTransaction::SetConnectionManager(CHttpConnectionManager& aConnectionManager)
	{
	__ASSERT_DEBUG( iConnectionManager == NULL, User::Invariant() );
	
	// A connection manager has been supplied - add this object to it.	
	iConnectionManager = &aConnectionManager;
	}

CHttpConnectionManager* CHttpClientTransaction::ConnectionManager() const
	{
	return iConnectionManager;
	}

void CHttpClientTransaction::RemoveConnectionManager()
	{
	iConnectionManager = NULL;
	}
	
/*
 *	Methods from CProtTransaction
 */

void CHttpClientTransaction::CreateTxDataL()
	{
	__ASSERT_DEBUG( iConnectionManager != NULL, User::Invariant() );

	delete iTxData;
	iTxData = NULL;
	iTxData = CHttpRequestComposer::NewL(*this, *iConnectionManager);
	}
	
void CHttpClientTransaction::CreateRxDataL(MRxDataObserver& aObserver)
	{
	__ASSERT_DEBUG( iConnectionManager != NULL, User::Invariant() );

	delete iRxData;
	iRxData = NULL;
	iRxData = CHttpResponseParser::NewL(*this, aObserver, *iConnectionManager);
	}
	
void CHttpClientTransaction::IncRetryCount ()
	{
	++iRetryCount;		
	}

TBool CHttpClientTransaction::RetryNeeded ()
	{
	const TInt KMaxRetryCount = 3;	
	return ( ( iTransactionState != ECancelled ) && 
			( iTransactionState != ECompleted ) && 
			( iRetryCount < KMaxRetryCount) );
	}
	
TBool CHttpClientTransaction::NeedDisconnectNotification () const
    {
    TBool needDisconnectNotification = EFalse;
	RHTTPTransaction myTransaction = Transaction (); 
	RHTTPSession mySession = myTransaction.Session ();
	RStringPool myStringPool ( mySession.StringPool () );
	RStringF notifyOnDisconnect = myStringPool.StringF( HTTP::ENotifyOnDisconnect, iStringTable );

	RHTTPPropertySet transactionProperties = myTransaction.PropertySet();
	RHTTPPropertySet sessionProperties = mySession.ConnectionInfo();
    
	THTTPHdrVal hdrVal;
	
	// Check the transaction properties for the disconnect notification
	// If it is set then it should be used.
	if ( transactionProperties.Property ( notifyOnDisconnect, hdrVal ) || sessionProperties.Property ( notifyOnDisconnect, hdrVal ) )	
		{
		__ASSERT_DEBUG( hdrVal.Type() == THTTPHdrVal::KStrFVal, User::Invariant() );
		
		needDisconnectNotification = ( hdrVal.StrF().Index(iStringTable) == HTTP::EEnableDisconnectNotification );
		}
	return needDisconnectNotification;	
	}


TBool CHttpClientTransaction::PropogateDefaultError() const
    {
    TBool noRetry=EFalse;
    RHTTPTransaction myTransaction = Transaction (); 
    RHTTPSession mySession = myTransaction.Session ();
    RStringPool myStringPool ( mySession.StringPool () );
    RStringF retrySet = myStringPool.StringF( HTTP::ENotifyOnDisconnect, iStringTable );

    RHTTPPropertySet transactionProperties = myTransaction.PropertySet();
    RHTTPPropertySet sessionProperties = mySession.ConnectionInfo();
        
    THTTPHdrVal hdrVal;
        
    // Check the transaction properties for the disconnect notification
    // If it is set then it should be used.
    if ( transactionProperties.Property ( retrySet, hdrVal ) || sessionProperties.Property ( retrySet, hdrVal ) )   
        {
        __ASSERT_DEBUG( hdrVal.Type() == THTTPHdrVal::KStrFVal, User::Invariant() );
            
        noRetry = ( hdrVal.StrF().Index(iStringTable) == HTTP::EHttpPropagateDefaultError );
        }
    return noRetry;  
    }