/*

* 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 TCatalogsHttpResponseComposer

*

*/

#include "catalogshttpresponsecomposer.h"

#include "catalogshttpincludes.h"

#include "catalogsutils.h"

#include "catalogskeyvaluepair.h"

#include "catalogshttpmessageconstants.h"

#include "catalogsdebug.h"

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

// 

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

//

HBufC8* TCatalogsHttpResponseComposer::ComposeResponseL( 

    const MCatalogsHttpOperation& aOperation,

    const TDesC8& aBody ) const

    {

    DLTRACEIN((""));

    RCatalogsBufferWriter writer;

    writer.OpenLC();

    WriteStatusLineL( aOperation, writer() );

    WriteHeadersL( aOperation, writer() );

    writer().WriteL( aBody );

    HBufC8* result = writer.PtrL().AllocL();

    CleanupStack::PopAndDestroy( &writer );

    DLINFO(("result: %S", result ));

    return result;

    }

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

// 

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

//

void TCatalogsHttpResponseComposer::WriteStatusLineL(   

    const MCatalogsHttpOperation& aOperation,

    RWriteStream& aStream ) const

    {

    // HTTP-version SP Status-Code SP Reason-Phrase CRLF

    aStream.WriteL( CatalogsHttpMessageConstants::KHttpVersion );

    aStream.WriteL( CatalogsHttpMessageConstants::KSpace );

    TBuf8<3> statusBuf;

    statusBuf.Num( aOperation.StatusCode() );

    aStream.WriteL( statusBuf );

    aStream.WriteL( CatalogsHttpMessageConstants::KSpace );

    aStream.WriteL( aOperation.StatusText() );

    aStream.WriteL( CatalogsHttpMessageConstants::KCrLf );    

    }

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

// 

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

//

void TCatalogsHttpResponseComposer::WriteHeadersL(   

    const MCatalogsHttpOperation& aOperation,

    RWriteStream& aStream ) const

    {

    DLTRACEIN((""));

    const RPointerArray<CCatalogsKeyValuePair>& headers( 

        aOperation.ResponseHeadersL().Headers() );

    DLTRACE(("Writing %d headers", headers.Count() ));

    for ( TInt i = 0; i < headers.Count(); ++i ) 

        {

        WriteHeaderL( *headers[i], aStream );

        }

    // End of headers

    aStream.WriteL( CatalogsHttpMessageConstants::KCrLf );

    }

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

// 

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

//

void TCatalogsHttpResponseComposer::WriteHeaderL(   

    const CCatalogsKeyValuePair& aHeader,

    RWriteStream& aStream ) const

    {

    aStream.WriteL( aHeader.Key() );

    aStream.WriteL( CatalogsHttpMessageConstants::KColon );

    aStream.WriteL( CatalogsHttpMessageConstants::KSpace );

    aStream.WriteL( aHeader.Value() );

    aStream.WriteL( CatalogsHttpMessageConstants::KCrLf );

    }