/**

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

}

SmfRelationId DataStoreManager::create(SmfProvider *aProvider, SmfContact *aContact){

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

	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 = QString::number( (int)presence.presenceState() );

	presenceText = presence.presenceStateText();

	statusText = presence.customMessage();

	QString snsName = aProvider->serviceName();

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

	QString snsDesc = aProvider->description();

	const int contactID = addContactToTable( userId, contactUrl, localId, managerUri, snsName, snsDesc, snsUrl, presenceState, presenceText , statusText, timeStampInSeconds);

	return QString::number( addRelationToTable( contactID ) );

}

SmfError DataStoreManager::associate( 	SmfRelationId aRelation,	

										const SmfContact* aContact, 

										SmfProvider* aProvider){

	if( ! relationIfExist( aRelation.toInt()) )

		return SmfErrInvalidRelation;

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

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

	const int contactID = addContactToTable( userId, contactUrl, localId, managerUri, snsName, snsDesc, snsUrl, presenceState, presenceText , statusText, timeStampInSeconds);

	if( socialProfileBaseID <= addRelationToTable( contactID,  aRelation.toInt() )  )

		return  SmfNoError ;

	else

		return SmfDbOpeningError;

}

/** remove contact from a relation */

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

	int contactId, relationId;

	QString userId, contactUrl, localId, managerUri;

	relationId = aRelation.toInt();

	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

	{

		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(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 contactId, 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() )

	{

		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

	{

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

	if(qry.next())

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

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

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

	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;

	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(0).toString() );

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

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

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

	QContactId qContactId;

	qContactId.setLocalId( StrLocalId.toInt() );

	qContactId.setManagerUri( StrManagerUri );	    

	QVariant contactId = QVariant::fromValue(qContactId);	

	int presenceState = aQry.value(7).toInt() ; 	

	QString presenceStateText = aQry.value(8).toString() ;

	QString statusText = aQry.value(9).toString();

	QContactPresence qContactPresence;

	qContactPresence.setPresenceState(static_cast<QContactPresence::PresenceState>(presenceState));

	qContactPresence.setPresenceStateText(presenceStateText);

	qContactPresence.setCustomMessage(statusText);

	QVariant contactPresence  = QVariant::fromValue(qContactPresence);

	QDateTime dateTime;	

	dateTime.setTime_t ( aQry.value(10).toLongLong() ) ;

	QContactTimestamp qContactTimestamp;

	qContactTimestamp.setCreated(dateTime);

	QVariant timeStamp = QVariant::fromValue( qContactTimestamp );

	smfContact = new SmfContact;

	smfContact->setValue("Guid", userId);

	smfContact->setValue("Url", contactUrl);

	smfContact->setValue("ContactId", contactId);

	smfContact->setValue("Presence", contactPresence);	

	smfContact->setValue("Timestamp", timeStamp);

	smfProvider = new SmfProvider;

	snsName = aQry.value(4).toString();

	snsDesc = aQry.value(5).toString();;

	snsUrl = aQry.value(6).toUrl();

	smfProvider->setServiceName( snsName );

	smfProvider->setDescription( snsDesc );

	smfProvider->setServiceUrl( snsUrl );

	iSmsfRelationItem = new SmfRelationItem;	

	iSmsfRelationItem->setIndex( aIndex );

	iSmsfRelationItem->setProvider(*(smfProvider) );

	iSmsfRelationItem->setContact(*( smfContact ));	

}

uint DataStoreManager::count(SmfRelationId relation){

	const int relationId = relation.toInt();

	return count( relationId );

}

SmfError DataStoreManager::deleteRelation(SmfRelationId relation){

	const int relationId = relation.toInt();

	return deleteRelationFromTable( relationId );

}

QList<SmfRelationId> DataStoreManager::getAllRelations(){

	QList<SmfRelationId> relationList;

	if(SmfDbOpeningError == openDB())

		return relationList;

	QSqlQuery qry;

	qry.prepare("SELECT DISTINCT relationId FROM relation");	

	if(SmfDbQueryExecutonError == executeQuery(qry))

		return relationList; 

	while(qry.next()){

		relationList << qry.value(0).toString();

	}

	qry.finish();

	db.close();

	return relationList;			

}