/**

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

 * 

 */

#include <dsm.h>

#include <QDebug>

// Static data initialization

DataStoreManager* DataStoreManager::dsmInstance = NULL;

const QString DataStoreManager::dbName = "dsm.db";

DataStoreManagerState DataStoreManager::state = CLOSED;

//! \fn getDataStoreManager()

/*!

    \brief  To get a handle on the datastore instantiation.

    \brief  This function returns a pointer to the existing DataStoreManager instantiation(object).

            If no object exists, a new one is created.

    \return Pointer to the current instantiation of DataStoreManager.

*/

DataStoreManager* DataStoreManager::getDataStoreManager(){

    if(dsmInstance == NULL){

    dsmInstance = new DataStoreManager(DataStoreManager::dbName);

        if(!(dsmInstance->InitializeDataBase())){

            return NULL;

        }

    }

    return  dsmInstance;

}

//! \fn ~DataStoreManager()

/*!

    \brief  Destructor for DataStoreManager class.

    \note   Should this be public?

*/

DataStoreManager::~DataStoreManager(){

    db.close();

    state = CLOSED;

    delete dsmInstance;

}

//! \fn getState()

/*!

    \brief  Get the current state of the DataStoreManager object.

    \return The state of the DSM object.

*/

DataStoreManagerState DataStoreManager::getState() const{

    return state;

}

//! \fn getError()

/*!

    \brief  Get the last error message from the DataStoreManager object.

    \return The last error message string of the DSM object.

*/

QString DataStoreManager::getErrorText() const{

    return lastMsg;

}

	{

	if(NULL == aProvider || NULL == aContact)

	QString userId, contactUrl, localId, managerUri, presenceState, presenceText, statusText;

	QDateTime dateTime;

	Int64 timeStampInSeconds;

	QContactGuid guid = aContact->value("Guid").value<QContactGuid>();

	userId = guid.guid();

	qDebug()<<"Inside DSM: userID "<<userId;

	QContactUrl url = aContact->value("Url").value<QContactUrl>();

	contactUrl = url.url();

	qDebug()<<"Inside Test DSM: contactUrl "<<contactUrl;

	QContactId contactId = aContact->value("ContactId").value<QContactId>();

	localId =  contactId.localId() ;

	managerUri = contactId.managerUri();

	qDebug()<<"Inside Test DSM: localId"<<localId;

	qDebug()<<"Inside Test DSM: managerUri"<<managerUri;

	QContactTimestamp time = aContact->value("Timestamp").value<QContactTimestamp>();

	dateTime = time.created();

	//Returns the datetime as the number of seconds that have passed since 1970-01-01T00:00:00, Coordinated Universal Time (Qt::UTC).

	timeStampInSeconds =  dateTime.toTime_t() ;

	QContactPresence presence = aContact->value("Presence").value<QContactPresence>();	

	presenceState = QString::number( (int)presence.presenceState() );

	presenceText = presence.presenceStateText();

	statusText = presence.customMessage();

	qDebug()<<"Inside Test DSM: presenceState"<<presenceState;

	qDebug()<<"Inside Test DSM: presenceText"<<presenceText;

	qDebug()<<"Inside Test DSM: statusText"<<statusText;

	QString snsName = aProvider->serviceName();

	QString snsUrl = (aProvider->serviceUrl()).toString();

	QString snsDesc = aProvider->description();

	qDebug()<<"Inside Test DSM Create: snsName"<<snsName;

	qDebug()<<"Inside Test DSM Create: snsUrl"<<snsUrl;

	qDebug()<<"Inside Test DSM Create: snsDesc"<<snsDesc;

}

SmfError DataStoreManager::associate( 	SmfRelationId aPhoneId,	

										const SmfContact* aContact, 

										SmfProvider* aProvider){

	if(NULL == aProvider || NULL == aContact)

			return SmfError(-1);//SmfUnknownError

	if( ! relationIfExist( aPhoneId.toInt()) )

		return SmfErrInvalidRelation;

	QString userId, contactUrl, localId, managerUri, presenceState, presenceText, statusText, name;

	QDateTime dateTime;

	Int64 timeStampInSeconds;

	QContactGuid guid = aContact->value("Guid").value<QContactGuid>();

	userId = guid.guid();

	QContactUrl url = aContact->value("Url").value<QContactUrl>();

	contactUrl = url.url();

	QContactId contactId = aContact->value("ContactId").value<QContactId>();

	localId =  contactId.localId() ;

	managerUri = contactId.managerUri();

	QContactTimestamp time = aContact->value("Timestamp").value<QContactTimestamp>();

	dateTime = time.created();

	//Returns the datetime as the number of seconds that have passed since 1970-01-01T00:00:00, Coordinated Universal Time (Qt::UTC).

	timeStampInSeconds =  dateTime.toTime_t() ;

	QContactPresence presence = aContact->value("Presence").value<QContactPresence>();	

	presenceState = presence.presenceState();

	presenceText = presence.presenceStateText();

	statusText = presence.customMessage();

	QString snsName = aProvider->serviceName();

	QString snsUrl = (aProvider->serviceUrl()).toString();

	QString snsDesc = aProvider->description();

	qDebug()<<"Inside Test DSM Associate: snsName"<<snsName;

	qDebug()<<"Inside Test DSM Associate: snsUrl"<<snsUrl;

	qDebug()<<"Inside Test DSM Associate: snsDesc"<<snsDesc;

	TInt Id = addRelationToTable( contactID,  aPhoneId.toInt()); 

	if(Id == aPhoneId.toInt())

	else

}

/** remove contact from a relation */

SmfError DataStoreManager::remove(SmfRelationId aRelation, const SmfContact* aContact){

	int contactId, relationId;

	QString userId, contactUrl, localId, managerUri;

	//to check validity of relationId

	if(aRelation.size() == 0)

			return SmfErrInvalidRelation;

	relationId = aRelation.toInt();

	//to check validity of SmfContact

	if(NULL == aContact)

		return SmfDbContactNotExist;

	if(SmfDbOpeningError == openDB())

			return SmfDbOpeningError;

	QSqlQuery qry;

	QContactGuid guid = aContact->value("Guid").value<QContactGuid>();

	userId = guid.guid();

	if ( ! userId.isNull() )

		{

		QContactUrl url = aContact->value("Url").value<QContactUrl>();

		contactUrl = url.url();				

		qry.prepare("SELECT contactId FROM contact where userId=:userId AND contactUrl=:contactUrl");	

		qry.bindValue(":userId", userId);

		qry.bindValue(":contactUrl", contactUrl);

		}

	else

		{

		//if userId is invalid then it shoudl return SmfError

		return SmfDbContactNotExist;

		/*QContactId contactId = aContact->value("ContactId").value<QContactId>();

		localId =  contactId.localId() ;

		managerUri = contactId.managerUri();

		qry.prepare("SELECT contactId FROM contact where localId=:localId AND managerUri=:managerUri");	

		qry.bindValue(":localId", localId);

		qry.bindValue(":managerUri", managerUri);*/

		}

	if(SmfDbQueryExecutonError == executeQuery(qry))

		return SmfDbQueryExecutonError; 

	if(qry.next())

		contactId = qry.value(0).toInt();

	deleteContactFromTable(relationId, contactId);

	qry.finish();

	db.close();

	return 	SmfNoError;		

}

/** returns first relation item in the relation when exists, NULL otherwise */

SmfRelationItem* DataStoreManager::searchById(const SmfRelationId aRelation){

	const int relationId = aRelation.toInt();

	int contactId, contactIndex;

	if(0 == aRelation.size())

		return NULL;

	if(SmfDbOpeningError == openDB())

			return NULL;

	QSqlQuery qry;

	qry.prepare("SELECT contactId, contactIndex FROM relation where relationId=:relationId LIMIT 1");	

	qry.bindValue(":relationId", relationId);

	if(SmfDbQueryExecutonError == executeQuery(qry))

		return NULL; 

	if(qry.next()){

		contactId = qry.value(0).toInt();

		contactIndex = qry.value(1).toInt();

	}

	qry.prepare("SELECT * FROM contact where contactId=:contactId");

	qry.bindValue(":contactId", contactId);

	if(SmfDbQueryExecutonError == executeQuery(qry))

			return NULL; 

	if(qry.next())

		createRelationItem(qry, contactIndex);	

	qry.finish();

	db.close();

	return iSmsfRelationItem;

}

SmfRelationItem* DataStoreManager::getContact(SmfRelationId aRelation, quint32 aIndex){

	const int relationId = aRelation.toInt();

	int contactId;

	if(SmfDbOpeningError == openDB())

			return NULL;

	QSqlQuery qry;

	qry.prepare("SELECT contactId FROM relation where relationId=:relationId AND contactIndex=:contactIndex");	

	qry.bindValue(":relationId", relationId);

	qry.bindValue(":contactIndex", aIndex);

	if(SmfDbQueryExecutonError == executeQuery(qry))

		return NULL; 

	if(qry.next()){

		contactId = qry.value(0).toInt();

	}

	qry.prepare("SELECT * FROM contact where contactId=:contactId");

	qry.bindValue(":contactId", contactId);

	if(SmfDbQueryExecutonError == executeQuery(qry))

			return NULL; 

	if(qry.next())

		createRelationItem(qry, aIndex);	

	qry.finish();

	db.close();

	return iSmsfRelationItem;	

}

/** returns relation Id for a given contacts if exists, NULL otherwise */

SmfRelationId DataStoreManager::searchByContact( SmfContact aContact){

	int contId,relationId;/* */

	QString userId, contactUrl, localId, managerUri;

	if(SmfDbOpeningError == openDB())

			return QString();

	QSqlQuery qry;

	QContactGuid guid = aContact.value("Guid").value<QContactGuid>();

	userId = guid.guid();

	if (userId.isNull() )

		{

		QContactId contactId = aContact.value("ContactId").value<QContactId>();

		localId =  contactId.localId() ;

		managerUri = contactId.managerUri();

		qry.prepare("SELECT contactId FROM contact where localId=:localId AND managerUri=:managerUri");	

		qry.bindValue(":localId", localId);

		qry.bindValue(":managerUri", managerUri);	

		}

	else

		{

		QContactUrl url = aContact.value("Url").value<QContactUrl>();

		contactUrl = url.url();				

		qry.prepare("SELECT contactId FROM contact where userId=:userId ");	/*AND contactUrl=:contactUrl*/

		qry.bindValue(":userId", userId);

		//qry.bindValue(":contactUrl", contactUrl);

		}

	if(SmfDbQueryExecutonError == executeQuery(qry))

		return QString(); 

	if(qry.next()){

		contId = qry.value(0).toInt();

	}

	qry.prepare("SELECT relationId FROM relation where contactId=:contactId");	

	qry.bindValue(":contactId", contId);	

	if(SmfDbQueryExecutonError == executeQuery(qry))

			return QString(); 

	if(qry.next()){

		relationId = qry.value(0).toInt();	

	}

	qry.finish();

	db.close();

	return QString::number( relationId );			

}

/** contacts and their provider */

DSMContactPckg* DataStoreManager::get(SmfRelationId aRelation, quint32 aIndex){

	const int relationId = aRelation.toInt();

	int contactId;

	if(SmfDbOpeningError == openDB())

			return NULL;

	QSqlQuery qry;

	qry.prepare("SELECT contactId FROM relation where relationId=:relationId AND contactIndex=:contactIndex");	

	qry.bindValue(":relationId", relationId);

	qry.bindValue(":contactIndex", aIndex);

	if(SmfDbQueryExecutonError == executeQuery(qry))

		return NULL; 

	if(qry.next()){

		contactId = qry.value(0).toInt();

	}

	qry.prepare("SELECT * FROM contact where contactId=:contactId");

	qry.bindValue(":contactId", contactId);

	if(SmfDbQueryExecutonError == executeQuery(qry))

			return NULL; 

	if(qry.next()){

		iDSMContactPckgItem = new DSMContactPckg;

		iDSMContactPckgItem->userId = qry.value(0).toString(); 

		iDSMContactPckgItem->contactUrl = qry.value(1).toString(); 

		iDSMContactPckgItem->localId = qry.value(2).toString(); 

		iDSMContactPckgItem->managerUri = qry.value(3).toString(); 

		iDSMContactPckgItem->snsName = qry.value(4).toString(); 

		iDSMContactPckgItem->snsDesc = qry.value(5).toString();  

		iDSMContactPckgItem->snsUrl = qry.value(6).toString(); 

		iDSMContactPckgItem->presenceState = qry.value(7).toString(); 

		iDSMContactPckgItem->presenceText = qry.value(8).toString(); 

		iDSMContactPckgItem->statusText = qry.value(9).toString(); 

		iDSMContactPckgItem->timeStamp = qry.value(10).toLongLong(); 

		iDSMContactPckgItem->contactIndex = relationId;

		iDSMContactPckgItem->relationId = aIndex;

	}

	qry.finish();

	db.close();

	return iDSMContactPckgItem;

}

/** list of contacts and their provider */

QList<SmfRelationItem> DataStoreManager::getAll(SmfRelationId aRelation){

	QList<SmfRelationItem> relationItemList;

	if(aRelation.size() == 0)

		return relationItemList;

	const int relationId = aRelation.toInt();

	int contactId, contactIndex;

	if(SmfDbOpeningError == openDB())

			return relationItemList;

	QSqlQuery qry;

	qry.prepare("SELECT contactId, contactIndex FROM relation where relationId=:relationId");	

	qry.bindValue(":relationId", relationId);

	if(SmfDbQueryExecutonError == executeQuery(qry))

		return relationItemList; 

	while(qry.next()){

		contactId = qry.value(0).toInt();

		contactIndex = qry.value(1).toInt();

		QSqlQuery innerqry;

		innerqry.prepare("SELECT * FROM contact where contactId=:contactId");

		innerqry.bindValue(":contactId", contactId);

		if(SmfDbQueryExecutonError == executeQuery(innerqry))

				return relationItemList; 

		if(innerqry.next()){

			createRelationItem(innerqry, contactIndex);

			relationItemList << *iSmsfRelationItem;

		}

		innerqry.finish();

	}// end while

	qry.finish();

	db.close();

	return relationItemList;	

}

void DataStoreManager::createRelationItem( QSqlQuery & aQry, int aIndex){

	SmfContact * smfContact;

	SmfProvider * smfProvider;

	QString snsName, snsDesc;

	QUrl snsUrl;

	QVariant userId = QVariant::fromValue( aQry.value(1).toString() );

	QVariant contactUrl = QVariant::fromValue(aQry.value(2).toString() ); 

	QString StrLocalId =  aQry.value(3).toString() ;

	QString StrManagerUri = aQry.value(4).toString() ;	

	QContactId qContactId;

	qContactId.setLocalId( StrLocalId.toInt() );

	qContactId.setManagerUri( StrManagerUri );