/****************************************************************************

**

** Copyright (C) 2008-2010 Nokia Corporation and/or its subsidiary(-ies).

** All rights reserved.

** Contact: Nokia Corporation (developer.feedback@nokia.com)

**

** This file is part of the HbCore module of the UI Extensions for Mobile.

**

** GNU Lesser General Public License Usage

** This file may be used under the terms of the GNU Lesser General Public

** License version 2.1 as published by the Free Software Foundation and

** appearing in the file LICENSE.LGPL included in the packaging of this file.

** Please review the following information to ensure the GNU Lesser General

** Public License version 2.1 requirements will be met:

** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.

**

** In addition, as a special exception, Nokia gives you certain additional

** rights.  These rights are described in the Nokia Qt LGPL Exception

** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.

**

** If you have questions regarding the use of this file, please contact

** Nokia at developer.feedback@nokia.com.

**

****************************************************************************/

#include "hbthemeclient_p_p.h"

#include <QLocalSocket>

#include <QProcess>

#include <QFile>

#include <QCoreApplication>

#include <QDebug>

#include <QDir>

#include <hbinstance.h>

#include <hbtheme_p.h>

#include <hbtheme.h>

#include <hbevent.h>

#include "hbthemecommon_p.h"

#include "hbmemorymanager_p.h"

#define WAIT_TIME_TO_CONNECT_TO_SERVER 500

#define WAIT_TIME_TO_START_SERVER 5000

static const QString SERVERFILEPATH = QLatin1String(HB_BIN_DIR) + QDir::separator() + QLatin1String("hbthemeserver");

/**

 * Constructor

 */

HbThemeClientPrivate::HbThemeClientPrivate():clientConnected( false ),localSocket( new QLocalSocket() )

{

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO ;

#endif

}

/**

 * connectToServer

 */

bool HbThemeClientPrivate::connectToServer()

{

    localSocket->connectToServer(THEME_SERVER_NAME);

    // This logic needs to be improved

    bool success = localSocket->waitForConnected( WAIT_TIME_TO_CONNECT_TO_SERVER );

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO << "Socket Connect status: " << success;

#endif 

    if(!success) {

        QProcess *newProcess = new QProcess();

        newProcess->start(SERVERFILEPATH);

        success = newProcess->waitForStarted( WAIT_TIME_TO_START_SERVER );

#ifdef THEME_SERVER_TRACES

        qDebug() << Q_FUNC_INFO << "Server Start Status: " << success << "Error = " << newProcess->error ();

#endif

        // If server started

        if (success) {

            // ToDo: This is to wait for server to start running. Logic needs to be improved.

            newProcess->waitForFinished(3000);

#ifdef THEME_SERVER_TRACES

            qDebug() <<Q_FUNC_INFO<< " Server Start Wait is over" ;

#endif

            localSocket->connectToServer(THEME_SERVER_NAME);

            success = localSocket->waitForConnected();

#ifdef THEME_SERVER_TRACES

            qDebug() <<Q_FUNC_INFO<< "socketconnected : "<<success;

#endif

        }

    }

    if (success) {

        connect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    }

    return clientConnected = success;

}

/**

 * Destructor

 */

HbThemeClientPrivate::~HbThemeClientPrivate()

{

    localSocket->disconnectFromServer();

    delete localSocket;

}

QSizeF HbThemeClientPrivate::getSharedIconDefaultSize(const QString& iconPath)

{

    // Not implemented atm...

    Q_UNUSED(iconPath)

    return QSizeF();

}

/**

 * HbThemeClientPrivate::getSharedIconInfo()

 */

HbSharedIconInfo HbThemeClientPrivate::getSharedIconInfo(const QString& iconPath ,

                                                         const QSizeF &size,

                                                         Qt::AspectRatioMode aspectRatioMode,

                                                         QIcon::Mode mode,

                                                         bool mirrored,

                                                         HbIconLoader::IconLoaderOptions options,

                                                         const QColor &color)

{

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO;

#endif

    HbSharedIconInfo iconInfo;

    iconInfo.type = INVALID_FORMAT;

    if ( !clientConnected ) {

        return iconInfo;

    }

    QByteArray outputByteArray;

    QDataStream outputDataStream(&outputByteArray, QIODevice::WriteOnly);

    HbThemeServerRequest requestType;

    requestType = EIconLookup;

    outputDataStream << (int)requestType;

    outputDataStream << iconPath;

    outputDataStream << size;

    outputDataStream << aspectRatioMode;

    outputDataStream << mode;

    outputDataStream << mirrored;

    outputDataStream << options;

    outputDataStream << color;	

    //@to do  block the segment upto the connect

    // changeTheme() slot should not be called for pixmap lookup case. So disconnecting.

    disconnect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    localSocket->write(outputByteArray);

    localSocket->flush();

    localSocket->waitForReadyRead();

#ifdef THEME_SERVER_TRACES

    qDebug() <<"image req : " <<iconPath;

#endif

    QByteArray inputByteArray = localSocket->readAll();

    QDataStream inputDataStream(inputByteArray);

    HbThemeServerRequest request;

    int temp;

    inputDataStream >> temp;

    request = (HbThemeServerRequest)temp;

    // Need to handle the situation when both themechange 

    // request and pixmap info comes at the same time

    // Just posting the ThemeChnaged event so that it can be handled

    // as next event and current pixmap load is not interrupted

    if (EIconLookup==request) {

        readIconInfo(inputDataStream, iconInfo);

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EThemeSelection==request) {

                QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

            }

        }

    }

    else if (EThemeSelection==request){

        // Asked for pixmap, got theme change request.. clean theme name

        QString themeName;

        inputDataStream >> themeName;

        QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EIconLookup==request) {

                readIconInfo(inputDataStream, iconInfo);

            }

        }

    }

    // connecting again to handle theme change request from server

    connect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    return iconInfo;

}

/*

 * HbThemeClientPrivate::getSharedLayoutDefs()

 * 

 * Returns the layout definition for the given file name,layout name,section name

*/

LayoutDefinition *HbThemeClientPrivate::getSharedLayoutDefs(const QString &fileName,const QString &layout,const QString &section)

{

    if ( !clientConnected ) {

        return 0;

    }

    QByteArray outputByteArray;

    QDataStream outputDataStream(&outputByteArray, QIODevice::WriteOnly);

    HbThemeServerRequest requestType = EWidgetMLLookup;

    outputDataStream << (int)requestType;

    outputDataStream << fileName;

    outputDataStream << layout;

    outputDataStream << section;

    disconnect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    localSocket->write(outputByteArray);

    localSocket->flush();

    localSocket->waitForReadyRead();

    QByteArray inputByteArray = localSocket->readAll();

    QDataStream inputDataStream(&inputByteArray,QIODevice::ReadOnly);

    HbThemeServerRequest request;

    int temp;

    int sharedMLOffset = -1;

    inputDataStream >> temp;

    request = (HbThemeServerRequest)temp;

     if (EWidgetMLLookup==request) {

        inputDataStream >> sharedMLOffset;

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EThemeSelection==request) {

                QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

            }

        }

    }else if (EThemeSelection==request){

        QString themeName;

        inputDataStream >> themeName;

        QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EWidgetMLLookup==request) {

                inputDataStream >> sharedMLOffset;

            }

        }

    }

    // connecting again to handle theme change request from server

    connect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    if (sharedMLOffset >= 0) {

        return HbMemoryUtils::getAddress<LayoutDefinition>(

                HbMemoryManager::SharedMemory, sharedMLOffset);

    } else {

        return 0;

    }

}

/**

 * HbThemeClientPrivate::getSharedStyleSheet()

 */

HbCss::StyleSheet *HbThemeClientPrivate::getSharedStyleSheet(const QString &fileName, HbLayeredStyleLoader::LayerPriority priority)

{

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO;

#endif

    if ( !clientConnected ) {

        return 0;

    }

    QByteArray outputByteArray;

    QDataStream outputDataStream(&outputByteArray, QIODevice::WriteOnly);

    HbThemeServerRequest requestType = EStyleSheetLookup;

    outputDataStream << (int)requestType;

    outputDataStream << fileName;

    outputDataStream << priority;

    disconnect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    localSocket->write(outputByteArray);

    localSocket->flush();

    localSocket->waitForReadyRead();

#ifdef THEME_SERVER_TRACES

    qDebug() <<"stylesheet req : " <<fileName;

#endif

    QByteArray inputByteArray = localSocket->readAll();

    QDataStream inputDataStream(inputByteArray);

    HbThemeServerRequest request;

    int temp;

    //-1 represents invalid offset

    int cssOffset = -1;

    inputDataStream >> temp;

    request = (HbThemeServerRequest)temp;

    // Need to handle the situation when both themechange 

    // request and stylesheet lookup info comes at the same time

    // Just posting the ThemeChanged event so that it can be handled

    // as next event and current stylesheet load is not interrupted

    if (EStyleSheetLookup==request) {

        inputDataStream >> cssOffset;

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EThemeSelection==request) {

                QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

            }

        }

    }

    else if (EThemeSelection==request){

        // Asked for stylesheet, got theme change request.. clean theme name

        QString themeName;

        inputDataStream >> themeName;

        QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EStyleSheetLookup==request) {

                inputDataStream >> cssOffset;

            }

        }

    }

    // connecting again to handle theme change request from server

    connect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    //if a valid offset is obtained from the server return this offset

    if (cssOffset >= 0) {

        return HbMemoryUtils::getAddress<HbCss::StyleSheet>(

            HbMemoryManager::SharedMemory, cssOffset);

    } else {

        return 0;

    }

}

/**

 * HbThemeClientPrivate::deviceProfiles()

 */ 

HbDeviceProfileList *HbThemeClientPrivate::deviceProfiles()

{

#ifdef THEME_SERVER_TRACES

	qDebug() << Q_FUNC_INFO;

#endif

    if ( !clientConnected ) {

        return 0;

    }

    QByteArray outputByteArray;

    QDataStream outputDataStream(&outputByteArray, QIODevice::WriteOnly);

    HbThemeServerRequest requestType = EDeviceProfileOffset;

    outputDataStream << (int)requestType;

    disconnect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    localSocket->write(outputByteArray);

    localSocket->flush();

    localSocket->waitForReadyRead();

    QByteArray inputByteArray = localSocket->readAll();

    QDataStream inputDataStream(inputByteArray);

    HbThemeServerRequest request;

    int temp;

    //-1 represents invalid offset

    int deviceProfileOffset = -1;

    inputDataStream >> temp;

    request = (HbThemeServerRequest)temp;

    if (EDeviceProfileOffset == request) {

        inputDataStream >> deviceProfileOffset;

    	if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EThemeSelection==request) {

                QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

            }

        }

    }else if (EThemeSelection==request){

        // Asked for DeviceProfiles Offset, got theme change request.. 

		// clean theme name

        QString themeName;

        inputDataStream >> themeName;

        QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EDeviceProfileOffset== request) {

                inputDataStream >> deviceProfileOffset;

            }

        }

    }

    // connecting again to handle theme change request from server

    connect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    //if a valid offset is obtained from the server return this offset

    if (deviceProfileOffset >= 0) {

        return HbMemoryUtils::getAddress<HbDeviceProfileList>(

            HbMemoryManager::SharedMemory, deviceProfileOffset);

    } else {

        return 0;

    }

}

/**

 * HbThemeClientPrivate::globalCacheOffset()

 */

int HbThemeClientPrivate::globalCacheOffset()

{

#ifdef THEME_SERVER_TRACES

        qDebug() << Q_FUNC_INFO;

#endif

    QByteArray outputByteArray;

    QDataStream outputDataStream(&outputByteArray, QIODevice::WriteOnly);

    HbThemeServerRequest requestType = ESecondaryCacheOffset;

    outputDataStream << (int)requestType;

    disconnect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    localSocket->write(outputByteArray);

    localSocket->flush();

    localSocket->waitForReadyRead();

    QByteArray inputByteArray = localSocket->readAll();

    QDataStream inputDataStream(inputByteArray);

    HbThemeServerRequest request;

    int temp;

    //-1 represents invalid offset

    int sharedCacheOffset = -1;

    inputDataStream >> temp;

    request = (HbThemeServerRequest)temp;

    if (ESecondaryCacheOffset == request) {

        inputDataStream >> sharedCacheOffset;

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EThemeSelection==request) {

                QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

            }

        }

    }else if (EThemeSelection == request){

        QString themeName;

        inputDataStream >> themeName;

        QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (ESecondaryCacheOffset== request) {

                inputDataStream >> sharedCacheOffset;

            }

        }

    }

    // connecting again to handle theme change request from server

    connect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    return sharedCacheOffset;

}

/**

 * HbThemeClientPrivate::getSharedEffect()

 */

HbEffectFxmlData *HbThemeClientPrivate::getSharedEffect(const QString &filePath)

{

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO;

#endif

    if ( !clientConnected ) {

        return 0;

    }

    QByteArray outputByteArray;

    QDataStream outputDataStream(&outputByteArray, QIODevice::WriteOnly);

    HbThemeServerRequest requestType = EEffectLookupFilePath;

    outputDataStream << (int)requestType;

    outputDataStream << filePath;

    disconnect(localSocket, SIGNAL(readyRead()), this, SLOT(changeTheme()));

    localSocket->write(outputByteArray);

    localSocket->flush();

    localSocket->waitForReadyRead();

#ifdef THEME_SERVER_TRACES

    qDebug() <<"EEffectLookupFilePath req : " <<filePath;

#endif

    QByteArray inputByteArray = localSocket->readAll();

    QDataStream inputDataStream(inputByteArray);

    HbThemeServerRequest request;

    int temp;

    //-1 represents invalid offset

    int effectOffset = -1;

    inputDataStream >> temp;

    request = (HbThemeServerRequest)temp;

    // Need to handle the situation when both themechange 

    // request and effect lookup info comes at the same time

    // Just posting the ThemeChanged event so that it can be handled

    // as next event and current effect load is not interrupted

    if (request==EEffectLookupFilePath) {

        inputDataStream >> effectOffset;

        if (!inputDataStream.atEnd()) {

            inputDataStream >> temp;

            request = (HbThemeServerRequest)temp;

            if (EThemeSelection==request) {

                QCoreApplication::postEvent(this, new HbEvent(HbEvent::ThemeChanged));

            }

        }

    }

    else if (EThemeSelection==request){

        // Asked for effect, got theme change request.. clean theme name