/*

 * Copyright (c) 2009 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:  

 *   

 */

#include "cpthemeclient_p_p.h"

#include <QLocalSocket>

#include <QProcess>

#include <QFile>

#include <QCoreApplication>

#include <QDebug>

#include <QDir>

#include <hbinstance.h>

#define WAIT_TIME_TO_CONNECT_TO_SERVER 500

#define WAIT_TIME_TO_START_SERVER 5000

/**

 * Constructor

 */

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

{

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO ;

#endif

}

/**

 * connectToServer

 */

bool CpThemeClientPrivate::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 

// Stub shouldn't try starting the theme server yet again.

#if 0

    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

        }

    }

#endif

    if (success) {

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

    }

    return clientConnected = success;

}

/**

 * isConnected

 */

bool CpThemeClientPrivate::isConnected() const

{

    return clientConnected;

}

/**

 * Destructor

 */

CpThemeClientPrivate::~CpThemeClientPrivate()

{

    localSocket->disconnectFromServer();

    delete localSocket;

}

/**

 * CpThemeClientPrivate::themeChanged()

 */

void CpThemeClientPrivate::themeChanged()

{

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO;

#endif

    QByteArray inputByteArray = localSocket->readAll();

    QDataStream inputDataStream(inputByteArray);

    int request;

    inputDataStream >> request;

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO << "recognizer: "<<request;

#endif

    if(EThemeSelection==request) {

        QString themeName;

        handleThemeChangeRequest(inputDataStream);

    }

#if 0

    // TODO determine if we need this for the control panel app

    if(EThemeContentUpdate == request) {

        hbInstance->theme()->d_ptr->clearCache();

    }

#endif

}

/**

 * CpThemeClientPrivate::handleThemeChangeRequest()

 */

void CpThemeClientPrivate::handleThemeChangeRequest(QDataStream &dataStream)

{

    QString themeName;

    dataStream >> themeName;

#ifdef THEME_SERVER_TRACES

    qDebug() << Q_FUNC_INFO <<"themeName is : " <<themeName;

#endif

    if(!(hbInstance->theme()->name() == themeName)) {

#ifdef THEME_SERVER_TRACES

        qDebug() << Q_FUNC_INFO <<"themeChanged(): called";

#endif

#if 0

        // TODO determine if we need this for the control panel app

        hbInstance->theme()->d_ptr->handleThemeChange();

#endif

    }

}

/**

 * changeTheme

 */

bool CpThemeClientPrivate::changeTheme(const QString &newTheme)

{

#ifdef THEME_CHANGER_TRACES

    qDebug() <<"ThemeClientQt::changeTheme("<<newTheme<<") called";

#endif

    if( (themeName==newTheme) || (newTheme.isEmpty()) ) {

#ifdef THEME_CHANGER_TRACES

        qDebug() <<"ThemeClientQt:: return Sametheme applied";

#endif

        return false;

    }

    QByteArray outputByteArray;

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

    ThemeServerRequest requestType = EThemeSelection;

    outputDataStream << (int)requestType;

    outputDataStream << newTheme;

    themeName = newTheme;

    int expected = outputByteArray.size();

    int count = localSocket->write(outputByteArray);

#ifdef THEME_CHANGER_TRACES

    qDebug()<<"ThemeClientQt::ThemeName written to server";

#endif

    localSocket->flush();

    return count == expected;

}