/*
 * Name        : HttpClient.cpp
 * Description : HTTP helper class
 * Project     : This file is part of OpenMAR, an Open Mobile Augmented Reality browser
 * Website     : http://OpenMAR.org
 *
 * Copyright (c) 2010 David Caabeiro
 *
 * All rights reserved. This program and the accompanying materials are made available 
 * under the terms of the Eclipse Public License v1.0 which accompanies this 
 * distribution, and is available at http://www.eclipse.org/legal/epl-v10.html
 *
 */

#include "HttpClient.h"

#include <Http.h>
#include <http/RHttpHeaders.h>

#include <cmmanager.h>
#include <cmdestination.h>
#include <CommDbConnPref.h> 

#include <es_enum.h>

#include "Logger.h"

CHttpClient* CHttpClient::NewL(MHTTPTransactionCallback& aCallback)
{
    CHttpClient* self = new(ELeave) CHttpClient(aCallback);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);

    return self;
}

CHttpClient::~CHttpClient()
{
    iSession.Close();
    iConnection.Close();
    iSocketServ.Close();
}

CHttpClient::CHttpClient(MHTTPTransactionCallback& aCallback)
    : iCallback(aCallback)
{
}

void CHttpClient::ConstructL()
{
    User::LeaveIfError(iSocketServ.Connect());

    User::LeaveIfError(iConnection.Open(iSocketServ));

    TUint connectionCount = 0;
    TInt error = iConnection.EnumerateConnections(connectionCount);

//    if (error || connectionCount < 1)

    TPckgBuf<TConnectionInfo> connectionInfo;
    error = iConnection.GetConnectionInfo(1, connectionInfo); // First connection

//    if (error)
//        LOGARG("Error %d retrieving connection info", error);

    error = iConnection.Attach(connectionInfo, RConnection::EAttachTypeNormal);

//    LOGARG("Connection attached %d", error);

//    LOGTXT("Opening http session");

    iSession.OpenL();

    RStringPool strPool = iSession.StringPool();
    RHTTPConnectionInfo connInfo = iSession.ConnectionInfo();
    connInfo.SetPropertyL(strPool.StringF(HTTP::EHttpSocketServ,
        RHTTPSession::GetTable()), THTTPHdrVal(iSocketServ.Handle()));
    TInt connPtr = reinterpret_cast<TInt>(&iConnection);
    connInfo.SetPropertyL(strPool.StringF(HTTP::EHttpSocketConnection,
        RHTTPSession::GetTable()), THTTPHdrVal(connPtr));
}

RHTTPTransaction CHttpClient::GetL(const TDesC8& aUri)
{
    TUriParser8 uri;
    uri.Parse(aUri);

    LOGARG("URI submitted is %S", &aUri);

    RStringPool strP = iSession.StringPool();
    RStringF method = strP.StringF(HTTP::EGET, RHTTPSession::GetTable());

    RHTTPTransaction transaction = iSession.OpenTransactionL(uri, iCallback, method);

    _LIT8(KUserAgent, "OpenMAR/1.0 (Symbian)");
    _LIT8(KAccept, "*/*");

    RHTTPHeaders hdr = transaction.Request().GetHeaderCollection();
    // Add headers appropriate to all methods
    SetHeaderL(hdr, HTTP::EUserAgent, KUserAgent);
    SetHeaderL(hdr, HTTP::EAccept, KAccept);

    transaction.SubmitL();

    return transaction;
}

void CHttpClient::Stop(RHTTPTransaction& aTransaction)
{
    aTransaction.Cancel();
}

void CHttpClient::SetHeaderL(RHTTPHeaders aHeaders, TInt aHdrField, const TDesC8& aHdrValue)
{
    RStringF valStr = iSession.StringPool().OpenFStringL(aHdrValue);
    THTTPHdrVal val(valStr);
    aHeaders.SetFieldL(iSession.StringPool().StringF(aHdrField, RHTTPSession::GetTable()), val);
    valStr.Close();
}