/*
* Copyright (c) 2010 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: Implementation of CPosRevGeoCodePlugin class.
*
*/

#include "posrevgeocodeplugin.h"
#include "posrevgeocodelogger.h"

#include <lbsposition.h>

//Maximum length for the response buffer size
const int KMaxResponseLength = 2048;
//Authentication token for the Maps server
//This authentication in specific to our photo-tagging feature
_LIT8( KAuthenticationToken, "88dedc61fb43c924aa39a873dadd41f4" );
//Static RefererURL which shows that request has been made from this app
_LIT8( KRefererURL, "nokia_positioningIndicator" );

//Language option for the REST request
_LIT8( KDefaultLanguage, "eng" );


//Format of the HTTP request for the reverse geocode
_LIT8( KRequestFormat, "http://loc.mobile.maps.svc.ovi.com/geocoder/rgc/1.0?token=%S&referer=%S&n=10&lat=%f&long=%f&lg=%S&output=xml" );


// http://www.loc.gov/marc/languages/
// These are the nokia language id converted to MARC language strings.
 static const char Marc_Table[ 104 ][ 4 ] = {
        "   ", // dummy
        "ENG", // 1 English
        "FRE", // 2 French
        "GER", // 3 German
        "SPA", // 4 Spanish
        "ITA", // 5 Italian
        "SWE", // 6 Swedish
        "DAN", // 7 Danish
        "NOR", // 8 Norwegian
        "FIN", // 9 Finnish
        "010", // 10 American
        "011", // 11 Swiss French
        "GSW", // 12 Swiss German
        "POR", // 13 Portuguese
        "TUR", // 14 Turkish
        "ICE", // 15 Icelandic
        "RUS", // 16 Russian
        "HUN", // 17 Hungarian
        "DUT", // 18 Dutch
        "019", // 19 Flemish
        "020", // 20 Australian English
        "021", // 21 Belgian French
        "022", // 22 Austrian German
        "023", // 23 New Zealand English
        "FRE", // 24 International French
        "CZE", // 25 Czech
        "SLO", // 26 Slovak
        "POL", // 27 Polish
        "SLV", // 28 Slovenian
        "029", // 29 TaiwanChinese
        "CHT", // 30 HongKongChinese
        "CHI", // 31 PeoplesRepublicOfChina Chinese
        "JPN", // 32 Japanese
        "THA", // 33 Thai
        "AFR", // 34 Afrikaans
        "ALB", // 35 Albanian
        "AMH", // 36 Amharic
        "ARA", // 37 Arabic
        "ARM", // 38 Armenian
        "TGL", // 39 Tagalog
        "BEL", // 40 Belarusian
        "BEN", // 41 Bengali
        "BUL", // 42 Bulgarian
        "BUR", // 43 Burmese
        "CAT", // 44 Catalan
        "SCR", // 45 Croatian
        "046", // 46 Canadian English
        "ENG", // 47 International English
        "048", // 48 SouthAfrican English
        "EST", // 49 Estonian
        "PER", // 50 Persian (Farsi)
        "051", // 51 Canadian French
        "GAE", // 52 Scots Gaelic
        "GEO", // 53 Georgian
        "GRE", // 54 Greek
        "055", // 55 Cyprus Greek
        "GUJ", // 56 Gujarati
        "HEB", // 57 Hebrew
        "HIN", // 58 Hindi
        "IND", // 59 Bahasa indonesia
        "GLE", // 60 Irish
        "061", // 61 Swiss Italian
        "KAN", // 62 Kannada
        "KAZ", // 63 Kazakh
        "KHM", // 64 Khmer
        "KOR", // 65 Korean
        "LAO", // 66 Lao
        "LAV", // 67 Latvian
        "LIT", // 68 Lithuanian
        "MAC", // 69 Macedonian
        "070", // 70 Bahasa Malaysia
        "MAL", // 71 Malayalam
        "MAR", // 72 Marathi
        "MOL", // 73 Moldavian
        "MON", // 74 Mongolian
        "NNO", // 75 Norwegian Nynorsk
        "076", // 76 Brazilian Portuguese
        "PAN", // 77 Punjabi
        "RUM", // 78 Romanian
        "SCC", // 79 Serbian
        "SNH", // 80 Sinhalese
        "SOM", // 81 Somali
        "082", // 82 International Spanish
        "083", // 83 LatinAmerican Spanish
        "SWA", // 84 Swahili
        "085", // 85 Finland Swedish
        "TAJ", // 86 Tajik
        "TAM", // 87 Tamil
        "TEL", // 88 Telugu
        "TIB", // 89 Tibetan
        "TIR", // 90 Tigrinya
        "091", // 91 Cyprus Turkish
        "TUK", // 92 Turkmen
        "UKR", // 93 Ukrainian
        "URD", // 94 Urdu
        "UZB", // 95 Uzbek
        "VIE", // 96 Vietnamese
        "WEL", // 97 Welsh
        "ZUL", // 98 Zulu
        "UND", // 99 Other
        "UND", // 100 Undef
        "UND", // 101 Undef
        "BAQ", // 102 Basque
        "103", // 103 Galician
    };

// Timer interval
const TInt KTimeOutInterval = 60000000;  // 60 seconds


// ECOM implementation specifics
static const TImplementationProxy implTable[] =
    {
    IMPLEMENTATION_PROXY_ENTRY( 0x2002E693, CPosRevGeoCodePlugin::NewL )
    }; 


EXPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount)
    {
    aTableCount = sizeof(implTable) / sizeof(TImplementationProxy);

    return implTable;
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::NewL
//------------------------------------------------------------------------------
CPosRevGeoCodePlugin* CPosRevGeoCodePlugin::NewL( MPosReverseGeocodeObserver& aObserver )
    {
    FUNC("CPosRevGeoCodePlugin::NewL");
    CPosRevGeoCodePlugin *self = new (ELeave) CPosRevGeoCodePlugin( aObserver );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::CPosRevGeoCodePlugin
//------------------------------------------------------------------------------
CPosRevGeoCodePlugin::CPosRevGeoCodePlugin( MPosReverseGeocodeObserver& aObserver ):
	 																					iObserver( aObserver ),
	 																					iHTTPClientEngine ( NULL ),
                                            iXmlParser ( NULL ),                                           
                                            iConnectionTimer( NULL ),
                                            iXMLBuf ( NULL )        
    {
    FUNC("CPosRevGeoCodePlugin::CPosRevGeoCodePlugin");
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::~CPosRevGeoCodePlugin
//------------------------------------------------------------------------------
CPosRevGeoCodePlugin::~CPosRevGeoCodePlugin()
    {
    FUNC("CPosRevGeoCodePlugin::~CPosRevGeoCodePlugin");
     
    delete iConnectionTimer;
    iConnectionTimer = NULL;
    
    delete iXMLBuf;
    iXMLBuf = NULL;
    
    delete iXmlParser;
    iXmlParser = NULL;
    
    delete iHTTPClientEngine;
    iHTTPClientEngine = NULL;
    FUNC("out>>CPosRevGeoCodePlugin");
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::GetAddressByCoordinateL
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::GetAddressByCoordinateL( CPosLandmark& aLandmark )
    {
    FUNC("CPosRevGeoCodePlugin::GetAddressByCoordinateL");
    // Store the landmark object.
    iClientLandmark = &aLandmark;
    
    TLocality locality;
    User::LeaveIfError( aLandmark.GetPosition( locality ) );
    TReal64 latitude = locality.Latitude();
    TReal64 longitude = locality.Longitude();
    
    iAuthCode.Copy( KAuthenticationToken );
    iRefURL.Copy( KRefererURL );
    
    GetLanguageForTheRequest( iLang );
    
    //Form the request URI
    iQueryString.Format( KRequestFormat, &iAuthCode, &iRefURL, latitude, longitude, &iLang );
    
    iHTTPClientEngine->IssueHTTPGetL( iQueryString );
    
    if ( iConnectionTimer && iConnectionTimer->IsActive() )
        {
        iConnectionTimer->Cancel();
        }
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::Cancel()
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::Cancel()
    {
    if( iHTTPClientEngine->IsActive() )
        {
        iHTTPClientEngine->CancelTransaction();
        }
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::ConstructL
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::ConstructL()
    {
    FUNC("CPosRevGeoCodePlugin::ConstructL");
    iXMLBuf = HBufC8::NewL( KMaxResponseLength );

    iXmlParser = CPosRevGeoCodeXmlParser::NewL( *this );
    
    iHTTPClientEngine = CPosRevGeoCodeHTTPClientEngine::NewL( *this );
    
    iConnectionTimer = CPosRevGeoCodeConnectionTimer::NewL(*this);
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::OnParseCompletedL
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::OnParseCompletedL( TInt aError )
    {
    FUNC("CPosRevGeoCodePlugin::OnParseCompletedL");
    StartTimer();
    iObserver.ReverseGeocodeComplete( aError );
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::ClientEvent
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::ClientEvent( const THttpStatus& aEvent )
    {
    FUNC("CPosRevGeoCodePlugin::ClientEvent");
    TInt error;
    switch( aEvent )
        {
        case EHttpTxCompleted:
            //Reading is done
            //Parse the String and get the restults
            if( iXmlParser )
            {
             TRAP_IGNORE( iXmlParser->StartParsingL( iXMLBuf,iClientLandmark ) );
            }
            break;
        //All these cases will in turn lead to
        //generic failure due to connection/Tx related problems    
        case EHttpConnectionFailure:
            // May happen if Socket connection fails
            error = KErrCouldNotConnect;
            iObserver.ReverseGeocodeComplete( error );
            break;
        case EHttpTxFailed:
        case EHttpMhfRunError:
            // May happen if Socket connection fails
            // Complete the RGC with generic error.
            error = KErrGeneral;
            iObserver.ReverseGeocodeComplete( error );
            break;
        case EHttpTxCancelled:
            //On Cancellation of request.
            error = KErrCancel;
            iObserver.ReverseGeocodeComplete( error );
            break;
        case EHttpAuthFailed:
            //On authentication failed.
            error = KErrPermissionDenied;
            iObserver.ReverseGeocodeComplete( error );
            break;
        }
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::ClientBodyReceived
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::ClientBodyReceived( const TDesC8& aBodyData )
    {
    FUNC("CPosRevGeoCodePlugin::ClientBodyReceived");
    //Dump the contents here
    TPtr8 ptr = iXMLBuf->Des();
    ptr.Zero();
    ptr.Append( aBodyData );
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::GetLanguageForTheRequest
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::GetLanguageForTheRequest( TDes8& aLanguage )
    {
    FUNC("CPosRevGeoCodePlugin::GetLanguageForTheRequest");
    // Get the current phone langauge  
    TInt phoneLangIndex = User::Language();

    // Get the converted language 
    if (  phoneLangIndex < sizeof( Marc_Table ) / sizeof( Marc_Table[ 0 ]  ) )
        {
        aLanguage = (const TUint8*) Marc_Table[ phoneLangIndex ];
        }
    else
        {
         //By default language will be Eng
        aLanguage.Copy( KDefaultLanguage );
        }
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::CloseConnection
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::CloseConnection()
    {
    FUNC("CPosRevGeoCodePlugin::CloseConnection");
    if( iHTTPClientEngine )
        {
        iHTTPClientEngine->CloseConnection();
        }
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::StartTimer
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::StartTimer()
    {
    FUNC("CPosRevGeoCodePlugin::StartTimer");
    if( iConnectionTimer )
        {
        iConnectionTimer->StartTimer( KTimeOutInterval );
        }
    }

//------------------------------------------------------------------------------
// CPosRevGeoCodePlugin::HandleTimedoutEvent
//------------------------------------------------------------------------------
void CPosRevGeoCodePlugin::HandleTimedoutEvent(TInt /*aErrorCode*/)
    {
    FUNC("CPosRevGeoCodePlugin::HandleTimedoutEvent");
    CloseConnection();
    }

//end of file