/**

 * 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

 *

 *

 * Description: Session implementation for Qt desktop builds

 *

 */

#include "smfserverqtsession.h"

#include "smfserverqt_p.h"

#include "smfserver.h"

SmfServerQtSession::SmfServerQtSession(QLocalSocket *clientConnection, SmfServerQt *server)

    : m_opCode(-1), m_clientConnection(clientConnection), m_server(server)

{

    connect(m_clientConnection, SIGNAL(readyRead()), this, SLOT(readDataFromClient()));

    connect(m_clientConnection, SIGNAL(error(QLocalSocket::LocalSocketError)),

            this, SLOT(socketError(QLocalSocket::LocalSocketError)));

}

SmfServerQtSession::~SmfServerQtSession()

{

    // The socket has the QLocalServer as a parent, but it should be deleted to

    // save unnecessary accumulation of these objects in memory. It won't be double deleted.

    delete m_clientConnection;

}

void SmfServerQtSession::readDataFromClient()

{

    // TODO: This needs to be much safer.

    if(m_clientConnection->bytesAvailable() < sizeof(typeof(SmfRequestTypeID)))

    {

        // Don't read yet, haven't received opcode

        return;

    }

    if (m_opCode == -1)

    {

        QDataStream in(m_clientConnection);

        in >> m_opCode;

    }

    // m_opCode set, so handle request

    handleRequest();

}

/**

 * Call the appropriate handler function

 */

void SmfServerQtSession::handleRequest()

{

    switch (m_opCode)

    {

    case SmfGetService:

        handleGetService();

        break;

    default:

        m_server->writeLog(QString("Bad Request received: ") + m_opCode);

    }

}

/**

 * Find available services for specified interface and return list to client.

 */

void SmfServerQtSession::handleGetService()

{

    m_server->writeLog("SmfServerQtSession::handleGetService()");

    QDataStream in(m_clientConnection);

    // Get interface type requested

    SmfInterfaceID ifName;

    in >> ifName;

    m_server->writeLog("Requested: " + ifName);

    // Get the available services for this interface

    QMap<SmfPluginID, SmfProvider> services;

    m_server->wrapper()->getPlugins(ifName, services);

    // write back the results

    QDataStream out(m_clientConnection);

    out << services;

}

void SmfServerQtSession::clientAuthorizationFinished(bool success)

{

    Q_UNUSED(success);

}

void SmfServerQtSession::socketError(QLocalSocket::LocalSocketError error)

{

    switch (error)

    {

    case QLocalSocket::PeerClosedError:

        m_server->writeLog("Peer closed connection.");

        break;

    case QLocalSocket::SocketTimeoutError:

        m_server->writeLog("error: connection timed out.");

        break;

    default:

        m_server->writeLog("error: unkown socket error: " + error);

        break;

    }

}