#include "dsm.h"

#include <SmfCredMgrClient.h>

#include <smfrelationmgr.h>

#include <smfclientglobal.h> 

	if(m_SmfServerPrivate)

		{

		delete m_SmfServerPrivate;

		m_SmfServerPrivate = NULL;

		}

	SmfTransportInitializeResult networkStatus = prepareTransport();

	qDebug()<<("Before m_pluginManager construction");

	m_pluginManager = SmfPluginManager::getInstance(this);

	qDebug()<<("After m_pluginManager construction");

	//	m_dataStoreManager = new SmfDataStoreManager();

	//Initialize private implementation

	#ifdef Q_OS_SYMBIAN

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

	QString log("SmfServer::startServer=");

	int errorQ = err ;

	log += errorQ;

	 qDebug()<<(log);

	if( KErrNone != err )

		return success;

	TInt error = m_SmfServerPrivate->Start( KSmfServerName );

    RSemaphore semaphore;

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

    // Semaphore opened ok

    semaphore.Signal();

    semaphore.Close();

	errorQ = error ;

	log.clear();

	log = QString("m_SmfServerPrivate->Start=");

	log += QString::number(error);

	 qDebug()<<(log);

	if( KErrNone == error ) 

		{

		success = true;

		}

	else 

		{

		//error

		return success;

		}

	#else

			m_SmfServerPrivate = new SmfServerQt(this);

	success = m_SmfServerPrivate->start();

	if (!success) 

		{

		return success;

		}

	#endif

	m_credentialMngr = new SmfCredMgrClient();

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

	//TODO:-Uncomment the following once authorization flow of plugin is implemented 

/*	authList.clear();

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

		{

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

		if(isAuthorized)

			{

			authList.append(list[i]);

			}

		}*/

	}

SmfTransportInitializeResult SmfServer::prepareTransport()

	{

	qDebug()<<("Before SmfTransportManager::getInstance");

	m_transportManager = SmfTransportManager::getInstance();

	qDebug()<<("Before m_transportManager->initializeTransport");

	//checking the network status

	SmfTransportInitializeResult networkStatus = m_transportManager->initializeTransport();

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

	return networkStatus;

void SmfServer::sendToPluginManager(int requestID,SmfPluginID pluginID,SmfInterfaceID interfaceID,SmfRequestTypeID requestTypeID,QByteArray dataForPlugin ,int pageno,int perpage)

	{

	qDebug()<<("SmfServer::delegateToPluginManager");

	qDebug()<<(QString::number(requestID));

	qDebug()<<(pluginID);

	qDebug()<<(interfaceID);

	qDebug()<<(QString::number(requestTypeID));

	//TODO:-PM should take page info too

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

	}

SmfError SmfServer::sendToDSM(QByteArray qtdataForDSM,SmfRequestTypeID opcode,QByteArray& qtdataFromDSM)

	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::ReadOnly);

	switch(opcode)

		{

		case SmfRelationCreate:

			{

			//read the incoming data

			SmfProvider provider;

			SmfContact contact;

			readStream>>provider;

			readStream>>contact;

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

			writeStream<<relnId;

			}

			break;

		case SmfRelationAssociate:

			SmfRelationId relnId;

			SmfContact contact;

			SmfProvider provider;

			readStream>>relnId;

			readStream>>contact;

			readStream>>provider;

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

			int errInt = err;

			writeStream<<errInt;

			}

			break;

		case SmfRelationSearchById:

			{

			SmfRelationId relnId;

			readStream>>relnId;

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

			writeStream<<*(relnItem);

			}

			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);

			writeStream<<relnItem;

			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;

		default:

			break;

		}

	return SmfNoError;

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

	authID.session->clientathorizationFinished(success);

 * TODO:- should use smf wide global errors instead

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

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

	qDebug()<<(QString::number(requestID));

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

	qDebug()<<(QString::number(parsedData->size()));

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

	qDebug()<<(QString::number(error));

	if(parsedData->size())

		{

		writer<<*(parsedData);

		}

 * Seems reduntant

	Q_UNUSED(parsedData)

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

	Q_UNUSED(type)

	Q_UNUSED(id)

/*void SmfServer::writeLog(QString log) const

    Q_UNUSED(log)

	}*/

//#ifdef CLIENT_SERVER_TEST

dummyPM::dummyPM(SmfServer* server,QObject* parent)

: m_server(server),QObject(parent)

	{

	m_timer = new QTimer(this);

	connect(m_timer, SIGNAL(timeout()), this, SLOT(responseAvailable()));

SmfError dummyPM::createRequest ( const quint32& aSessionID, 

		const QString& aPluginID, 

		const SmfRequestTypeID& aOperation, 

		QByteArray& aInputData )

	{

	qDebug()<<QString::number(aSessionID);

	qDebug()<<aPluginID;

	qDebug()<<QString::number(aOperation);

	qDebug()<<QString::number(aInputData.size());

	m_timer->start(1000);

	}

void dummyPM::responseAvailable()

	{

	}

//#endif