/**
* 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:
* Private implementation of SmfPostProvider
*
*/
#include <qdebug.h>
#include "smfpostprovider.h"
#include "smfpostprovider_p.h"
#ifdef Q_OS_SYMBIAN
#include "smfclientsymbian.h"
#else
#include "SmfClientQt.h"
#endif
SmfPostProviderPrivate::SmfPostProviderPrivate(SmfPostProvider* postProvider)
: m_postProvider(postProvider)
{
#ifdef Q_OS_SYMBIAN
//private impl for symbian
m_SmfClientPrivate = CSmfClientSymbian::NewL(this);
#endif
}
SmfPostProviderPrivate::~SmfPostProviderPrivate()
{
if(m_SmfClientPrivate)
{
delete m_SmfClientPrivate;
m_SmfClientPrivate = NULL;
}
}
/**
* returns maximum no of chars (unicode) that service provider can post without truncation
* negative value means no limit
*/
qint32 SmfPostProviderPrivate::maxCharsInPost()
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
//SmfProvider
write<<*m_baseProvider;
QString intfName(postProviderInterface);
//setting max size to 10
//call private impl's send method
QByteArray data = m_SmfClientPrivate->sendSyncRequest(intfName,
SmfPostGetMaxCharsInPost, 10, m_serializedDataToServer);
//De-serialize it into qint32
QDataStream reader(&data,QIODevice::ReadOnly);
qint32 val;
reader>>val;
return val;
}
/**
* returns maximum no of items that can be returned in a single query to getPosts
* negative value means feature not supported.
*/
qint32 SmfPostProviderPrivate::maxItems()
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
//SmfProvider
write<<*m_baseProvider;
QString intfName(postProviderInterface);
//setting max size to 10
//call private impl's send method
QByteArray data = m_SmfClientPrivate->sendSyncRequest(intfName,
SmfPostGetMaxItems, 10, m_serializedDataToServer);
//De-serialize it into qint32
QDataStream reader(&data,QIODevice::ReadOnly);
qint32 val;
reader>>val;
return val;
}
/**
* returns all the formatting of posts that this service provider supports.
* May return 0 items to mean only QString is supported.
*/
QVector<QTextFormat> SmfPostProviderPrivate::supportedFormats ()
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
//SmfProvider
write<<*m_baseProvider;
QString intfName(postProviderInterface);
//ToDo :- Setting maxsize to 1000
//call private impl's send method
QByteArray data = m_SmfClientPrivate->sendSyncRequest(intfName,
SmfPostGetSupportedFormats, 1000, m_serializedDataToServer);
//De-serialize it into QVector<QTextFormat>
QDataStream reader(&data,QIODevice::ReadOnly);
QVector<QTextFormat> val;
reader>>val;
return val;
}
/**
* returns whether this SP supports Appearence @see SmfAppearenceInfo
*/
bool SmfPostProviderPrivate::supportsAppearence ()
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
//SmfProvider
write<<*m_baseProvider;
QString intfName(postProviderInterface);
//we are not mentioning the max size, as we'll receive only bool
//call private impl's send method
QByteArray data = m_SmfClientPrivate->sendSyncRequest(intfName,
SmfPostGetAppearanceSupport, 10, m_serializedDataToServer);
//De-serialize it into bool
QDataStream reader(&data,QIODevice::ReadOnly);
bool val;
reader>>val;
return val;
}
/**
* 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
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
write<<*m_baseProvider;
m_argFlag = 1;
if(user)
{
write<<m_argFlag;
write<<*user;
}
else
{
m_argFlag = 0;
write<<m_argFlag;
}
m_argFlag = 1;
write<<m_argFlag;
write<<pageNum;
write<<m_argFlag;
write<<perPage;
QString intfName(postProviderInterface);
int maxAllocation = MaxSmfPostSize*perPage;
//call private impl's send method
m_SmfClientPrivate->sendRequest(m_serializedDataToServer, intfName,
SmfContactRetrievePosts, maxAllocation);
}
/**
* 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_serializedDataToServer.clear();
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
//SmfProvider
write<<*m_baseProvider;
m_argFlag = 1;
write<<m_argFlag;
write<<postData;
write<<m_argFlag;
write<<location;
QString intfName(postProviderInterface);
//we are not mentioning the max size, as we'll receive only bool
//call private impl's send method
m_SmfClientPrivate->sendRequest(m_serializedDataToServer, intfName,
SmfContactPost, 10);
}
/**
* 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)
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
//SmfProvider
write<<*m_baseProvider;
m_argFlag = 1;
write<<m_argFlag;
write<<postData;
QString intfName(postProviderInterface);
//we are not mentioning the max size, as we'll receive only bool
//call private impl's send method
m_SmfClientPrivate->sendRequest(m_serializedDataToServer, intfName,
SmfContactUpdatePost, 10);
}
/**
* 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)
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
//SmfProvider
write<<*m_baseProvider;
m_argFlag = 1;
write<<m_argFlag;
write<<postData;
write<<m_argFlag;
write<<contact;
if(location)
{
write<<m_argFlag;
write<<*location;
}
else
{
m_argFlag = 0;
write<<m_argFlag;
}
QString intfName(postProviderInterface);
//we are not mentioning the max size, as we'll receive only bool
//call private impl's send method
m_SmfClientPrivate->sendRequest(m_serializedDataToServer, intfName,
SmfContactPostDirected, 10);
}
/**
* Method to post a comment on a post.
* @param aTarget Post on which comment has to be posted
* @param aComment comment to be posted
* @param aLocation location data
*/
void SmfPostProviderPrivate::commentOnAPost( SmfPost &aTarget, SmfPost &aComment,
SmfLocation *aLocation)
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
//SmfProvider
write<<*m_baseProvider;
m_argFlag = 1;
write<<m_argFlag;
write<<aTarget;
write<<m_argFlag;
write<<aComment;
if(aLocation)
{
write<<m_argFlag;
write<<*aLocation;
}
else
{
m_argFlag = 0;
write<<m_argFlag;
}
QString intfName(postProviderInterface);
//we are not mentioning the max size, as we'll receive only bool
//call private impl's send method
m_SmfClientPrivate->sendRequest(m_serializedDataToServer, intfName,
SmfContactCommentOnAPost, 10);
}
/**
* 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
*/
bool SmfPostProviderPrivate::postAppearence(SmfAppearenceInfo appearence,
const QString &status)
{
//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
m_serializedDataToServer.clear();
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
write<<*m_baseProvider;
m_argFlag = 1;
write<<m_argFlag;
write<<appearence;
write<<m_argFlag;
write<<status;
QString intfName(postProviderInterface);
//we are not mentioning the max size, as we'll receive only bool
//call private impl's send method
m_SmfClientPrivate->sendRequest(m_serializedDataToServer, intfName,
SmfContactPostAppearence, 10);
return true;
}
/**
* 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)
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
write<<*m_baseProvider;
m_argFlag = 1;
write<<m_argFlag;
write<<postData;
write<<m_argFlag;
write<<contact;
write<<m_argFlag;
write<<edited;
QString intfName(postProviderInterface);
//we are not mentioning the max size, as we'll receive only bool
//call private impl's send method
m_SmfClientPrivate->sendRequest(m_serializedDataToServer, intfName,
SmfContactSharePost, 10);
}
/**
* Request for a custom operation. The signal customDataAvailable() is emitted
* when the result is available.
* @param operationId OperationId
* @param customData Custom data to be sent
* Note:-Interpretation of operationId and customData is upto the concerned
* plugin and client application. service provider should provide some
* serializing-deserializing utilities for these custom data
*/
void SmfPostProviderPrivate::customRequest ( const int& operationId, QByteArray* customData )
{
SmfProvider* m_baseProvider = m_postProvider->getProvider();
//serialize start
m_serializedDataToServer.clear();
QDataStream write(&m_serializedDataToServer,QIODevice::WriteOnly);
write<<*m_baseProvider;
m_argFlag = 1;
write<<m_argFlag;
write<<operationId;
if(customData)
{
write<<m_argFlag;
write<<*customData;
}
else
{
m_argFlag = 0;
write<<m_argFlag;
}
QString intfName(postProviderInterface);
//ToDo:- How much size to allocate for custo data? keeping MaxSmfPostSize for now
int maxAllocation = MaxSmfPostSize;
//call private impl's send method
m_SmfClientPrivate->sendRequest(m_serializedDataToServer, intfName,
SmfContactPostCustomRequest, maxAllocation);
}
/**
* From smfobserver
*/
void SmfPostProviderPrivate::resultsAvailable(QByteArray result,SmfRequestTypeID opcode,SmfError error)
{
qDebug()<<"Inside SmfPostProviderPrivate::resultsAvailable()";
qDebug()<<"opcode = "<<opcode;
QDataStream reader(&result,QIODevice::ReadOnly);
//Now de-serialize it based on opcode
switch(opcode)
{
case SmfContactRetrievePosts:
{
SmfPostList* m_postList = new SmfPostList;
reader>>*(m_postList);
qDebug()<<"postList.count="<<m_postList->count();
//not incorporating paging now
SmfResultPage page;
emit m_postProvider->postsAvailable(m_postList,error,page);
}
break;
case SmfContactPost:
case SmfContactUpdatePost:
case SmfContactPostDirected:
case SmfContactCommentOnAPost:
case SmfContactPostAppearence:
case SmfContactSharePost:
{
int errInt;
reader>>errInt;
qDebug()<<"success = "<<errInt;
SmfError success = (SmfError)errInt;
emit m_postProvider->postFinished(success);
}
break;
case SmfContactPostCustomRequest:
{
int operationId;
QByteArray *data = new QByteArray;
reader>>operationId;
reader>>*data;
qDebug()<<"operationId = "<<operationId;
qDebug()<<"data size = "<<data->size();
emit m_postProvider->customDataAvailable(operationId, data);
}
break;
default:
Q_ASSERT_X(1,"PostProvider Private Unknown opcode","default case");
}
}