--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/smf/smfservermodule/smfclient/smfpostprovider_p.cpp Thu Aug 05 16:48:48 2010 +0530
@@ -0,0 +1,502 @@
+/**
+ * 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");
+ }
+ }