/*
* Copyright (c) 2007-2008 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:   Implements CCatalogsHttpRequestAdapter
*
*/


#include "catalogshttprequestadapter.h"

#include "catalogshttprequestparser.h"
#include "catalogshttpsession.h"
#include "catalogshttpoperation.h"
#include "catalogshttpobserver.h"
#include "catalogshttpconfig.h"
#include "catalogshttpheaders.h"

#include "catalogsdebug.h"


// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
CCatalogsHttpRequestAdapter* CCatalogsHttpRequestAdapter::NewL(
    MCatalogsHttpSession& aHttpSession )
    {
    CCatalogsHttpRequestAdapter* self = new( ELeave ) 
        CCatalogsHttpRequestAdapter( aHttpSession );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;    
    }
    
    
// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
CCatalogsHttpRequestAdapter::~CCatalogsHttpRequestAdapter()
    {
    DLTRACEIN((""));
    delete iParser;
    if ( iTransaction ) 
        {
        iTransaction->Release();
        }
    iHttpSession.Release();
    }



// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
MCatalogsHttpOperation* CCatalogsHttpRequestAdapter::CreateTransactionL(
    const TDesC8& aUri,
    const TDesC8& aRequest,
    MCatalogsHttpObserver& aObserver )
    {
    DLTRACEIN((""));
    iHttpObserver = &aObserver;
    DASSERT( !iTransaction );
    iUri.Set( aUri );
    
    // Request parsing leads to callbacks to ParsedHttpXXX methods which
    // create the transaction to iTransaction
    TRAPD( err, iParser->ParseRequestL( aRequest, *this ) );
    
    iHttpObserver = NULL;
    if ( err != KErrNone ) 
        {
        DLERROR(("Error %d occurred, leaving", err ));
        if ( iTransaction ) 
            {
            iTransaction->Release();
            iTransaction = NULL;
            }
        User::Leave( err );
        }
    
    if ( !iTransaction ) 
        {
        DLERROR(("Transaction creation failed"));
        User::Leave( KErrCorrupt );
        }
        
    MCatalogsHttpOperation* operation = iTransaction;
    iTransaction = NULL;
    
    return operation;
    }


// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CCatalogsHttpRequestAdapter::ParsedHttpRequestLineL( 
    const TDesC8& aMethod, 
    const TDesC8& aUri,
    const TDesC8& aVersion )
    {
    DLTRACEIN(("Method: %S, URI: %S, version: %S",
        &aMethod, &aUri, &aVersion ));
    
    DASSERT( iHttpObserver );
    (void) aUri;
    (void) aVersion;
    
    iTransaction = iHttpSession.CreateTransactionL( 
        iUri, 
        iHttpObserver );
    
    // Set the correct HTTP method
    TCatalogsHttpMethod method( ECatalogsHttpPost );
    
    if ( aMethod.Compare( KCatalogsHttpGet ) == 0 ) 
        {
        method = ECatalogsHttpGet;
        }
    else if ( aMethod.Compare( KCatalogsHttpHead ) == 0 ) 
        {
        method = ECatalogsHttpHead;
        }
    
    iTransaction->Config().SetHttpMethod( method );    
    
    
    }


// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CCatalogsHttpRequestAdapter::ParsedHttpHeaderL( 
    const TDesC8& aHeader,
    const TDesC8& aHeaderData )
    {
    DLTRACEIN(("Header: %S data: %S", &aHeader, &aHeaderData ));
    DASSERT( iTransaction );
    
    // skip host, host header is generated by the platform
    if ( aHeader.CompareF( KCatalogsHttpHeaderHost ) != 0 )
        {
        iTransaction->RequestHeadersL().AddHeaderL( aHeader, aHeaderData );        
        }
    }
    

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CCatalogsHttpRequestAdapter::ParsedHttpBodyL(
    const TDesC8& aBody )
    {
    DLTRACEIN(("Body: %S", &aBody ));
    DASSERT( iTransaction );
    iTransaction->SetBodyL( aBody );
    }


// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
CCatalogsHttpRequestAdapter::CCatalogsHttpRequestAdapter( 
    MCatalogsHttpSession& aHttpSession ) 
    : iHttpSession( aHttpSession )
    {
    iHttpSession.AddRef();
    }
    
    
// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CCatalogsHttpRequestAdapter::ConstructL()
    {
    DLTRACEIN((""));
    iParser = CCatalogsHttpRequestParser::NewL();
    }