/**
 * Copyright (c) 2010 Sasken Communication Technologies Ltd.
 * All rights reserved.
 * This component 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 the URL "http://www.eclipse.org/legal/epl-v10.html"
 *
 * Initial Contributors:
 * Chandradeep Gandhi, Sasken Communication Technologies Ltd - Initial contribution
 *
 * Contributors:
 * Manasij Roy, Nalina Hariharan
 */

#include "smfclientqt.h"

SmfClientQt::SmfClientQt(QObject *parent)
    : QObject(parent)
{
    m_serverConnection = new QLocalSocket();

    connect(m_serverConnection, SIGNAL(connected()), this, SLOT(connectionEstablished()));
    connect(m_serverConnection, SIGNAL(readyRead()), this, SLOT(readIncomingData()));
    connect(m_serverConnection, SIGNAL(error(QLocalSocket::LocalSocketError)),
            this, SLOT(handleError(QLocalSocket::LocalSocketError)));

    m_serverConnection->connectToServer("SmfServerQt", QIODevice::ReadWrite);
}

SmfClientQt::~SmfClientQt()
{
    m_serverConnection->close();
    delete m_serverConnection;
}

/**
 * Send a request to the server.
 * @param aSerializedData serialized by the caller.
 * @param aInterfaceName Interface name
 * @param requestType Opcode
 */
int SmfClientQt::sendRequest(QByteArray& serializedData, QString interfaceName,
                             SmfRequestTypeID requestType)
{
    QDataStream out(m_serverConnection);
    out << requestType;
    out << interfaceName;
    out << serializedData.size();
    out << serializedData;
}

/**
 * This overloaded API is for ESmfGetServices, where data should be
 * fetched synchronously
 */
QByteArray SmfClientQt::sendRequest(QString interfaceName,
            SmfRequestTypeID requestType)
{
    QDataStream out(m_serverConnection);
    out << requestType;
    out << interfaceName;

    // TODO: This needs to be asynchronous. Remove this wait when user API is updated.
    m_serverConnection->waitForBytesWritten(-1);

    QByteArray in;
    out >> in;
    return in;
}

/**
 * For testing purpose only
 */
int SmfClientQt::sendDummyRequest(QByteArray* provider,QString aInterfaceName,
            SmfRequestTypeID requestType)
{
    Q_UNUSED(provider);
    Q_UNUSED(aInterfaceName);
    Q_UNUSED(requestType);
    // ToDo :-
}

/**
* CancelRequest.
* Cancels an outstanding request.
*/
void SmfClientQt::CancelRequest()
{
// ToDo :-
}

void SmfClientQt::connectionEstablished()
{
    qDebug() << "Connected to server successfully.";
    // ToDo :-
}

void SmfClientQt::readIncomingData()
{
	// ToDo :-
}

void SmfClientQt::handleError(QLocalSocket::LocalSocketError error)
{
    switch(error)
    {
    case QLocalSocket::ServerNotFoundError:
        qDebug() << "Server not found.";
        break;
        
    default:
        qDebug() << "Unhandled socket error";
        break;
    }
}