/**

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

 * SMF Server component which handles the client requests and delegates 

 * them properly to the appropriate component

 * 

 */

#include <QDebug>

#include <qglobal.h>

#include <smfcontact.h>

#include <smfgroup.h>

#include <smfpost.h>

#include <smflocation.h>

#include <smfpicture.h>

#include <smfcomment.h>

#include <smfcredmgrclient.h>

#include <smfrelationmgr.h>

#include "smfserver.h"

#include "smfpluginmanager.h"

#include "smftransportmanager.h"

#include "dsm.h"

#ifdef Q_OS_SYMBIAN

	#include "smfserversymbian_p.h"

#else

	#include "smfserverqt_p.h"

	#include "smfserverqtsession.h"

#endif

SmfServer::SmfServer(QObject* parent)

    : QObject(parent)

	{

	m_transportManager = NULL;

	m_pluginManager = NULL;

	m_credentialMngr = NULL;

	}

SmfServer::~SmfServer()

	{

	qDebug()<<"Inside Smfserver::~SmfServer()";

	if(m_transportManager)

		delete m_transportManager;

	if(m_pluginManager)

		delete m_pluginManager;

	if(m_credentialMngr)

		delete m_credentialMngr;

	if(m_SmfServerPrivate)

		{

		delete m_SmfServerPrivate;

		m_SmfServerPrivate = NULL;

		}

	}

bool SmfServer::startServer()

	{

	bool success = false;

	//Initialize all the component handles

	SmfTransportInitializeResult networkStatus = prepareTransport();

	m_pluginManager = SmfPluginManager::getInstance(this);

	qDebug()<<"After m_pluginManager construction";

	//	m_dataStoreManager = new SmfDataStoreManager();

#ifdef Q_OS_SYMBIAN

	//Initialize private implementation

	TRAPD(err, m_SmfServerPrivate = SmfServerSymbian::NewL(CActive::EPriorityStandard,this));

	qDebug()<<"SmfServerSymbian::NewL() = "<<err;

	if( KErrNone != err )

		return success;

	TInt error = m_SmfServerPrivate->Start( KSmfServerName );

	qDebug()<<"m_SmfServerPrivate->Start = "<<error;

    RSemaphore semaphore;

    User::LeaveIfError( semaphore.OpenGlobal( KSmfServerSemaphoreName ) );

    // Semaphore opened ok

    semaphore.Signal();

    semaphore.Close();

	if( KErrNone == error ) 

		{

		success = true;

		}

	else 

		{

		//error

		return success;

		}

#else

	// For non-symbian platforms

	m_SmfServerPrivate = new SmfServerQt(this);

	success = m_SmfServerPrivate->start();

	if (!success) 

		{

		return success;

		}

#endif

	m_credentialMngr = new SmfCredMgrClient();

    return success;

	}

//Note:- Almost all the following APIs are called by private impl via the handle

/**

 * This API is called by the private impl when client is authorized

 * @param interfaceID Interface id, provided by the private impl (it gets it from client)

 * @param pluginIDMap Map of plugins who implement this interface and corresponding provider,

 * this is returned to the private impl

 * It calls PM to get the list. Note:- PM may return SmfProviderBase which is superset of SmfProvider.

 * TODO:- session should store this map for future ref?

 */

void SmfServer::getPlugins(const SmfInterfaceID& interfaceID, QMap<SmfPluginID,SmfProvider>& pluginIDMap)

	{

	qDebug()<<"Inside SmfServer::getPlugins()";

	m_pluginManager->getPlugins(interfaceID,pluginIDMap);

	}

SmfPluginID SmfServer::getPlugin(const SmfInterfaceID& interfaceID,SmfProvider provider)

	{

	qDebug()<<"Inside SmfServer::getPlugin()";

	SmfPluginID id;

	m_pluginManager->getPluginId(interfaceID,provider, id);

	return id;

	}

/**

 * This API is called by the private impl to get a list of authorized plugins from CM

 * @param list List of plugins to be filtered

 * @param authList List of authorised plugins filled by CM

 * this is returned to the private impl

 * It calls CMclient to get the list synchronously

 * TODO:- session should store this for future ref?

 */

void SmfServer::getAuthorizedPlugins(QList<SmfPluginID>& list,QList<SmfPluginID>& authList)

	{

	qDebug()<<"Inside SmfServer::getAuthorizedPlugins()";

	authList.clear();

	for(int i=0;i<list.count();i++)

		{

		bool isAuthorized = false;

		isAuthorized = m_credentialMngr->CheckPluginAuthentication(list[i]);

		if(isAuthorized)

			authList.append(list[i]);

		}

	}

SmfTransportInitializeResult SmfServer::prepareTransport()

	{

	m_transportManager = SmfTransportManager::getInstance();

	//checking the network status

	SmfTransportInitializeResult networkStatus = m_transportManager->initializeTransport();

	qDebug()<<"m_transportManager->initializeTransport() return = "<<networkStatus;

	return networkStatus;

	}

SmfError SmfServer::sendToPluginManager ( int requestID, SmfPluginID pluginID, 

		SmfInterfaceID interfaceID, SmfRequestTypeID requestTypeID, 

		QByteArray dataForPlugin )

	{

	qDebug()<<"Inside SmfServer::sendToPluginManager()";

	Q_UNUSED(interfaceID)

#ifdef DETAILEDDEBUGGING

	qDebug()<<"Request ID = "<<requestID;

	qDebug()<<"PluginID = "<<pluginID;

	qDebug()<<"Interface = "<<interfaceID;

	qDebug()<<"RequestType = "<<requestTypeID;

#endif

	//TODO:-PM should take page info too

	SmfError err = m_pluginManager->createRequest(requestID,pluginID,requestTypeID,dataForPlugin);

	qDebug()<<"m_pluginManager->createRequest() ret value = "<<err;

	return err;

	}

/**

 * Request the Plugin manager to get the data.

 * @param requestID Corresponds to a client's session

 * @param pluginID Plugin for which the request is intended

 * @param interfaceID Interface name

 * @param dataForPlugin Data to be sent for this request

 */

SmfError SmfServer::sendToPluginManager ( SmfPluginID pluginID, 

		SmfInterfaceID interfaceID, SmfRequestTypeID requestTypeID,

		QByteArray dataForPlugin, QByteArray &outputData)

	{

	qDebug()<<"Inside SmfServer::sendToPluginManager() for sync req";

	Q_UNUSED(interfaceID)

#ifdef DETAILEDDEBUGGING

	qDebug()<<"PluginID = "<<pluginID;

	qDebug()<<"Interface = "<<interfaceID;

	qDebug()<<"RequestType = "<<requestTypeID;

#endif

	//TODO:-PM should take page info too

	SmfError err = m_pluginManager->createSyncRequest(pluginID,requestTypeID,dataForPlugin, outputData);

	qDebug()<<"m_pluginManager->createSyncRequest() = "<<err;

	return err;

	}

SmfError SmfServer::sendToDSM ( QByteArray qtdataForDSM, SmfRequestTypeID opcode,

		QByteArray& qtdataFromDSM )

	{

	qDebug()<<"Inside SmfServer::sendToDSM()";

	SmfError err = SmfNoError;

	DataStoreManager* dsm = DataStoreManager::getDataStoreManager();

	//Note:- deserialization and formation of user profile and social profile are done by server

	QDataStream readStream(&qtdataForDSM,QIODevice::ReadOnly);

	QDataStream writeStream(&qtdataFromDSM,QIODevice::WriteOnly);

	quint8 flag = 0;

	switch(opcode)

		{

		case SmfRelationCreate:

			{

			//read the incoming data

			SmfProvider *provider = new SmfProvider();

			SmfContact *contact = new SmfContact();

			readStream>>flag;

			if(flag)

				readStream>>*provider;

			else 

				{

				delete provider;

				provider = NULL;

				}

			readStream>>flag;

			if(flag)

				readStream>>*contact;

			else 

				{

				delete contact;

				contact = NULL;

				}

			SmfRelationId relnId;

			relnId.clear();

			err = dsm->create(relnId,provider,contact);

			writeStream<<relnId;

			if(provider != NULL)

				delete provider;

			if(contact != NULL)

				delete contact;

			}

			break;

		case SmfRelationAssociate:

			{

			SmfRelationId relnId;

			SmfContact *contact = new SmfContact();

			SmfProvider *provider = new SmfProvider();

			readStream>>relnId;

			readStream>>flag;

			if(flag)

				readStream>>*contact;

			else 

				{

				delete contact;

				contact = NULL;

				}

			readStream>>flag;

			if(flag)

				readStream>>*provider;

			else 

				{

				delete provider;

				provider = NULL;

				}

			err = dsm->associate(relnId,contact,provider);

			int errInt = err;

			writeStream<<errInt;

			if(contact != NULL)

				delete contact;

			if(provider != NULL)

				delete provider;

			}

			break;

		case SmfRelationRemove:

			{

			SmfRelationId relnId;

			SmfContact *contact = new SmfContact();

			readStream>>relnId;

			readStream>>flag;

			if(flag)

				readStream>>*contact;

			else 

				{

				delete contact;

				contact = NULL;

				}

			err = dsm->remove(relnId, contact);

			int errInt = err;

			writeStream<<errInt;

			if(NULL != contact)

				delete contact;

			break;

			}

		case SmfRelationSearchById:

			{

			SmfRelationId relnId;

			readStream>>relnId;

			SmfRelationItem* relnItem = dsm->searchById(relnId);

			quint8 flag = 1;

			if(relnItem)

				{

				writeStream<<flag;

				writeStream<<*(relnItem);

				}

			else

				{

				flag = 0;

				writeStream<<flag;

				}

			}

			break;

		case SmfRelationSearchByContact:

			{

			SmfContact contact;

			readStream>>contact;

			SmfRelationId relnId = dsm->searchByContact(contact);

			writeStream<<relnId;

			break;

			}

		case SmfRelationCount:

			{

			SmfRelationId relationId;

			readStream>>relationId;

			int cnt = dsm->count(relationId);

			writeStream<<cnt;

			}

			break;

		case SmfRelationGet:

			{

			SmfRelationId relationId;

			quint32 index;

			readStream>>relationId;

			readStream>>index;

			SmfRelationItem* relnItem = dsm->getContact(relationId,index);

			quint8 flag = 1;

			if(relnItem)

				{

				writeStream<<flag;

				writeStream<<*(relnItem);

				}

			else

				{

				flag = 0;

				writeStream<<flag;

				}

			break;

			}

		case SmfRelationGetAll:

			{

			SmfRelationId relationId;

			readStream>>relationId;

			QList<SmfRelationItem> relnIditemList = dsm->getAll(relationId);

			writeStream<<relnIditemList;

			}

			break;

		case SmfRelationGetAllRelations:

			{

			QList<SmfRelationId> relnIdList = dsm->getAllRelations();

			writeStream<<relnIdList;

			}

			break;

		case SmfRelationDeleteRelation:

			{

			SmfRelationId relnId;

			readStream>>relnId;

			err = dsm->deleteRelation(relnId);

			int errInt = err;

			writeStream<<errInt;

			break;

			}

		default:

			break;

		}

	return err;

	}

#ifdef Q_FOR_FUTURE 

/**

 * This slot is invoked when CM finishes the authorization of the client.

 * @param authID As it contains the session ptr, sever directly invokes the session's API to notify success

 */

void SmfServer::clientAuthorizationFinished(bool success,SmfClientAuthID authID )

	{

	qDebug()<<"Inside SmfServer::clientAuthorizationFinished()";

	//TODO:- implement this api in session class

	//note:- in case success is false client completes the request with SmfErrClientAuthFailed

	//TODO:- define set of smf wide error after consulting with other module owners

	authID.session->clientAuthorizationFinished(success);

	}

#endif

/**

 * This API is called by PM once its done with request and parsing

 * @param requestID The request id which is completed

 * @param parsedData Serialized data(as per request type) filled by PM

 * @param error Error occured

 * TODO:- should use smf wide global errors instead

 */

void SmfServer::resultsAvailable ( int requestID, QByteArray* parsedData, SmfError error )

	{

	qDebug()<<"Inside SmfServer::resultsAvailable()";

#ifdef DETAILEDDEBUGGING

	qDebug()<<"requestID = "<<requestID;

	qDebug()<<"parsedData->size() = "<<parsedData->size();

	qDebug()<<"Error = "<<error;

#endif

	//Serialize error followed by actual data

	QByteArray dataWithError;

	QDataStream writer(&dataWithError,QIODevice::WriteOnly);

	writer<<error;

	if(parsedData->size())

		{

		writer<<*(parsedData);

		}

	//find out the appropriate session and request id and service that

	m_SmfServerPrivate->findAndServiceclient(requestID,&dataWithError,error);

	}

/**

 * This is called when CMclient notifies client expiry.

 * @param type notification type, set of enums for future expansion

 * @param id Plugin Id for which the authentication has expired

 */

void SmfServer::authenticationKeysExpired(NotificationType type,SmfPluginID id)

	{

	Q_UNUSED(type)

	Q_UNUSED(id)

	//resend the notify request

	//CMclient->requestAuthExpiryNotify();

	}