/**

 * 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 <qdebug.h>

#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:

			qDebug()<<"Bad Request received =  "<<m_opCode);

		}

	}

/**

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

 */

void SmfServerQtSession::handleGetService()

	{

    qDebug()<<"SmfServerQtSession::handleGetService()";

    QDataStream in(m_clientConnection);

    // Get interface type requested

    SmfInterfaceID ifName;

    in >> ifName;

    qDebug()<<"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:

			qDebug()<<"Peer closed connection.";

			break;

		case QLocalSocket::SocketTimeoutError:

			qDebug()<<"error: connection timed out.";

			break;

		default:

			qDebug()<<"error: unkown socket error: "<<error;

			break;

		}

	}