/**

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

 * The SmfEvent class represents an event

 *

 */

#include "smfpostprovider_p.h"

//logging headers

#ifdef WRITE_LOG

#include <QTextStream>

#include <QFile>

#endif

#ifdef Q_OS_SYMBIAN

#include "smfclientsymbian.h"

#else

#include "smfclientqt.h"

#endif

SmfPostProviderPrivate::SmfPostProviderPrivate(SmfPostProvider* postProvider)

: m_postProvider(postProvider),m_postList(NULL)

	{

	  //private impl for symbian

	#ifdef Q_OS_SYMBIAN

	m_SmfClientPrivate = CSmfClientSymbian::NewL(this);

	#endif

	}

SmfPostProviderPrivate::~SmfPostProviderPrivate()

	{

	if(m_SmfClientPrivate)

		{

		delete m_SmfClientPrivate;

		m_SmfClientPrivate = NULL;

		}

	}

/**

 * Gets the posts asynchronously. The signal postsAvailable()with SmfPostList is emitted

 * once the post lists are available

 * @param user user's contact in this SP, omit for self contact

 * @param pageNum Page number to download, SMF_FIRST_PAGE denotes fresh query.

 * @param perPage Item per page, default is SMF_ITEMS_PER_PAGE 

 * @see postsAvailable()

 */

void SmfPostProviderPrivate::posts(SmfContact* user ,int pageNum,int perPage)

{

	  //We need to pass Opcode and SmfProvider+SmfContact

	  // (when user is not NULL) serialized into bytearray 

	  m_baseProvider = m_postProvider->getProvider();

	  //serialize start

	  QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);

	  write<<*(m_baseProvider);

	  //TODO:- use different opcode incase post retreival is for other user

	  //serialize SmfContact if post retrieval is for other user

	  if(user)

		  {

		  //now serialize SmfContact 

		  write<<*(user);

		  }

	  //serialize end

	  QString intfName(postProviderInterface);

	  //call private impl's send method

	  m_SmfClientPrivate->sendRequest(m_serializedDataToServer,intfName,SmfContactRetrievePosts);

}

/**

 * Updates a post to own area, the success of the post can be checked with signal

 * updatePostFinished() signal

 * @param postData data to be posted

 * @param location location data

 */

void SmfPostProviderPrivate::post(SmfPost& postData,SmfLocation& location) 

	{

	  m_baseProvider = m_postProvider->getProvider();

	  //serialize start

	  QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);

	  //SmfProvider

	  write<<*(m_baseProvider);

	  //SmfPost

	  write<<postData;

	  //SmfPlace

	  write<<location;

	  //serialize end

	  QString intfName(postProviderInterface);

	  //call private impl's send method

	  m_SmfClientPrivate->sendRequest(m_serializedDataToServer,intfName,SmfContactPost);

	}

/**

 * Updates the last post to own area with new data, the success of the post can be checked with signal

 * updatePostFinished() signal

 * @param postData edited/new data to be posted

 * @param location location data

 */

void SmfPostProviderPrivate::updatePost(SmfPost& postData)

	{

	  m_baseProvider = m_postProvider->getProvider();

	  //serialize start

	  QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);

	  //SmfProvider

	  write<<*(m_baseProvider);

	  //SmfPost

	  write<<postData;

	  //serialize end

	  QString intfName(postProviderInterface);

	  //call private impl's send method

	  m_SmfClientPrivate->sendRequest(m_serializedDataToServer,intfName,SmfContactUpdatePost);

	}

/**

 * Updates a post to a particular Smf contact. the success of the post can be checked with signal

 * updatePostFinished() signal.

 * @param postData data to be posted

 * @param contact contact to which the post is to be directed

 * @param location location data

 */

void SmfPostProviderPrivate::postDirected(SmfPost& postData,SmfContact& contact,SmfLocation* location)

	{

	  m_baseProvider = m_postProvider->getProvider();

	  //serialize start

	  QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);

	  //SmfProvider

	  write<<*(m_baseProvider);

	  //SmfPost

	  write<<postData;

	  //SmfContact

	  write<<contact;

	  //SmfPlace

	  write<<location;

	  //serialize end

	  QString intfName(postProviderInterface);

	  //call private impl's send method

	  m_SmfClientPrivate->sendRequest(m_serializedDataToServer,intfName,SmfContactPostDirected);

	}

/**

 * Posts appearance info of the user.e.g. appear offline, busy, do-not-disturb

 * @param appearence user appearance

 * @see SmfPresenceInfo

 * @return False on Failure/Not supported 

 */

//TODO:-How to return "supported" value? should it be synchronous?

//Currently doing it asynchronously with the assumption of always supported

//TODO:- implement some signal completion API

bool SmfPostProviderPrivate::postAppearence(SmfAppearenceInfo appearence)

	{

	  m_baseProvider = m_postProvider->getProvider();

	  //serialize start

	  QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);

	  write<<*(m_baseProvider);

	  write<<appearence;

	  QString intfName(postProviderInterface);

	  //call private impl's send method

	  m_SmfClientPrivate->sendRequest(m_serializedDataToServer,intfName,SmfContactPostAppearence);

	}

/**

 * Share /a contact's post to user's friends and followers (e.g. retweet in twitter, share on facebook)

 * emits updatePostFinished() signal when done.

 * @param postData data to be posted

 * @param contact contact to which the post belonged

 * @param bool whether user changed items within the post

 */

void SmfPostProviderPrivate::sharePost(SmfPost& postData,SmfContact& contact,bool edited)

	{

	  m_baseProvider = m_postProvider->getProvider();

	  //serialize start

	  QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);

	  write<<*(m_baseProvider);

	  write<<postData;

	  write<<contact;

	  write<<edited;

	  QString intfName(postProviderInterface);

	  //call private impl's send method

	  m_SmfClientPrivate->sendRequest(m_serializedDataToServer,intfName,SmfContactSharePost);

	}

/**

* From smfobserver

*/

void SmfPostProviderPrivate::resultsAvailable(QByteArray result,SmfRequestTypeID opcode,SmfError error)

   {

	writeLog("SmfPostProviderPrivate::resultsAvailable");

	//note:- "result" is serialized and we need to de-serialize it as per opcode

	//TODO:- order of serialization Error value followed by data

	QDataStream reader(&result,QIODevice::ReadOnly);

	//Now de-serialize it based on opcode

	switch(opcode)

		{

		case SmfContactRetrievePostsComplete:

			{

				if(m_postList)

					{

					delete m_postList;

					m_postList = NULL;

					}

				m_postList = new SmfPostList;

				//TODO

	//   			SmfError error;

	//   			reader>>error;

	//   			writeLog("Error=");

	//   			writeLog(QString::number(error));

	//   			SmfError err = (SmfError)error;

				reader>>*(m_postList);

				writeLog("postList.count=");

				writeLog(QString::number(m_postList->count()));

				foreach(SmfPost post,*m_postList)

					{

					writeLog(post.description());

					}

				//not incorporating paging now

				SmfResultPage page;

				emit m_postProvider->postsAvailable(m_postList,error,page);

			}

			break;

		case SmfContactPostComplete:

			{

				bool success;

				reader>>success;

				writeLog("success=");

				if(success)

					writeLog("true");

				emit m_postProvider->postFinished(success);

			}

			break;

		case SmfContactUpdatePostComplete:

		case SmfContactPostDirectedComplete:

		case SmfContactSharePostComplete:

			{

			bool success;

			reader>>success;

			writeLog("success=");

			if(success)

				writeLog("true");

			emit m_postProvider->postFinished(success);

			}

//		default:

//			//should panic?

//			

		}

   }

void SmfPostProviderPrivate::writeLog(QString log) const

	{

#ifdef WRITE_LOG

	QFile file("c:\\data\\SmfClientLogs.txt");

    if (!file.open(QIODevice::Append | QIODevice::Text))

	         return;

    QTextStream out(&file);

    out << log << "\n";

    file.close();

#endif

	}