removed most of the token queue system from GxsFeedItems

retroshare-gui/src/gui/feeds/GxsChannelGroupItem.cpp

@@ -23,6 +23,7 @@
 #include "ui_GxsChannelGroupItem.h"
 
 #include "FeedHolder.h"
+#include "util/qtthreadsutils.h"
 #include "gui/NewsFeed.h"
 #include "gui/RetroShareLink.h"
 
@@ -89,29 +90,39 @@ bool GxsChannelGroupItem::setGroup(const RsGxsChannelGroup &group)
 	return true;
 }
 
-void GxsChannelGroupItem::loadGroup(const uint32_t &token)
+void GxsChannelGroupItem::loadGroup()
 {
-#ifdef DEBUG_ITEM
-	std::cerr << "GxsChannelGroupItem::loadGroup()";
-	std::cerr << std::endl;
-#endif
-
-	std::vector<RsGxsChannelGroup> groups;
-	if (!rsGxsChannels->getGroupData(token, groups))
+	RsThread::async([this]()
 	{
-		std::cerr << "GxsChannelGroupItem::loadGroup() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
+		// 1 - get group data
 
-	if (groups.size() != 1)
-	{
-		std::cerr << "GxsChannelGroupItem::loadGroup() Wrong number of Items";
-		std::cerr << std::endl;
-		return;
-	}
+		std::vector<RsGxsChannelGroup> groups;
+		const std::list<RsGxsGroupId> groupIds = { groupId() };
 
-	setGroup(groups[0]);
+		if(!rsGxsChannels->getChannelsInfo(groupIds,groups))
+		{
+			RsErr() << "GxsGxsChannelGroupItem::loadGroup() ERROR getting data" << std::endl;
+			return;
+		}
+
+		if (groups.size() != 1)
+		{
+			std::cerr << "GxsGxsChannelGroupItem::loadGroup() Wrong number of Items";
+			std::cerr << std::endl;
+			return;
+		}
+		RsGxsChannelGroup group(groups[0]);
+
+		RsQThreadUtils::postToObject( [group,this]()
+		{
+			/* Here it goes any code you want to be executed on the Qt Gui
+			 * thread, for example to update the data model with new information
+			 * after a blocking call to RetroShare API complete */
+
+			setGroup(group);
+
+		}, this );
+	});
 }
 
 QString GxsChannelGroupItem::groupName()

retroshare-gui/src/gui/feeds/GxsChannelGroupItem.h

@@ -48,7 +48,7 @@ protected:
 
 	/* GxsGroupFeedItem */
 	virtual QString groupName();
-	virtual void loadGroup(const uint32_t &token);
+	virtual void loadGroup() override;
 	virtual RetroShareLink::enumType getLinkType() { return RetroShareLink::TYPE_CHANNEL; }
 
 private slots:

retroshare-gui/src/gui/feeds/GxsChannelPostItem.cpp

@@ -30,6 +30,7 @@
 #include "FeedHolder.h"
 #include "SubFileItem.h"
 #include "util/misc.h"
+#include "util/qtthreadsutils.h"
 #include "gui/RetroShareLink.h"
 #include "util/HandleRichText.h"
 #include "util/DateTime.h"
@@ -230,107 +231,149 @@ void GxsChannelPostItem::loadComments()
 	comments(title);
 }
 
-void GxsChannelPostItem::loadGroup(const uint32_t &token)
+void GxsChannelPostItem::loadGroup()
 {
 #ifdef DEBUG_ITEM
 	std::cerr << "GxsChannelGroupItem::loadGroup()";
 	std::cerr << std::endl;
 #endif
 
-	std::vector<RsGxsChannelGroup> groups;
-	if (!rsGxsChannels->getGroupData(token, groups))
+	RsThread::async([this]()
 	{
-		std::cerr << "GxsChannelGroupItem::loadGroup() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
+		// 1 - get group data
 
-	if (groups.size() != 1)
-	{
-		std::cerr << "GxsChannelGroupItem::loadGroup() Wrong number of Items";
-		std::cerr << std::endl;
-		return;
-	}
+		std::vector<RsGxsChannelGroup> groups;
+		const std::list<RsGxsGroupId> groupIds = { groupId() };
 
-	setGroup(groups[0]);
+		if(!rsGxsChannels->getChannelsInfo(groupIds,groups))
+		{
+			RsErr() << "GxsGxsChannelGroupItem::loadGroup() ERROR getting data" << std::endl;
+			return;
+		}
+
+		if (groups.size() != 1)
+		{
+			std::cerr << "GxsGxsChannelGroupItem::loadGroup() Wrong number of Items";
+			std::cerr << std::endl;
+			return;
+		}
+		RsGxsChannelGroup group(groups[0]);
+
+		RsQThreadUtils::postToObject( [group,this]()
+		{
+			/* Here it goes any code you want to be executed on the Qt Gui
+			 * thread, for example to update the data model with new information
+			 * after a blocking call to RetroShare API complete */
+
+			setGroup(group);
+
+		}, this );
+	});
 }
 
-void GxsChannelPostItem::loadMessage(const uint32_t &token)
+void GxsChannelPostItem::loadMessage()
 {
 #ifdef DEBUG_ITEM
 	std::cerr << "GxsChannelPostItem::loadMessage()";
 	std::cerr << std::endl;
 #endif
-
-	std::vector<RsGxsChannelPost> posts;
-	std::vector<RsGxsComment> cmts;
-	if (!rsGxsChannels->getPostData(token, posts, cmts))
+	RsThread::async([this]()
 	{
-		std::cerr << "GxsChannelPostItem::loadMessage() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
+		// 1 - get group data
 
-	if (posts.size() == 1)
-	{
-        std::cerr << (void*)this << ": Obtained post, with msgId = " << posts[0].mMeta.mMsgId << std::endl;
-		setPost(posts[0]);
-	}
-	else if (cmts.size() == 1)
-	{
-		RsGxsComment cmt = cmts[0];
+		std::vector<RsGxsChannelPost> posts;
+		std::vector<RsGxsComment> comments;
 
-        std::cerr << (void*)this << ": Obtained comment, setting messageId to threadID = " << cmt.mMeta.mThreadId << std::endl;
-		ui->newCommentLabel->show();
-		ui->commLabel->show();
-		ui->commLabel->setText(QString::fromUtf8(cmt.mComment.c_str()));
+		if(! rsGxsChannels->getChannelContent( groupId(), std::set<RsGxsMessageId>( { messageId() } ),posts,comments))
+		{
+			RsErr() << "GxsGxsChannelGroupItem::loadGroup() ERROR getting data" << std::endl;
+			return;
+		}
 
-		//Change this item to be uploaded with thread element.
-		setMessageId(cmt.mMeta.mThreadId);
-		requestMessage();
-	}
-	else
-	{
-		std::cerr << "GxsChannelPostItem::loadMessage() Wrong number of Items. Remove It.";
-		std::cerr << std::endl;
-		removeItem();
-		return;
-	}
+		if (posts.size() == 1)
+		{
+			std::cerr << (void*)this << ": Obtained post, with msgId = " << posts[0].mMeta.mMsgId << std::endl;
+            const RsGxsChannelPost& post(posts[0]);
+
+			RsQThreadUtils::postToObject( [post,this]() { setPost(post);  }, this );
+		}
+		else if(comments.size() == 1)
+		{
+			const RsGxsComment& cmt = comments[0];
+			std::cerr << (void*)this << ": Obtained comment, setting messageId to threadID = " << cmt.mMeta.mThreadId << std::endl;
+
+			RsQThreadUtils::postToObject( [cmt,this]()
+			{
+				ui->newCommentLabel->show();
+				ui->commLabel->show();
+				ui->commLabel->setText(QString::fromUtf8(cmt.mComment.c_str()));
+
+				//Change this item to be uploaded with thread element.
+				setMessageId(cmt.mMeta.mThreadId);
+				requestMessage();
+
+			}, this );
+
+		}
+		else
+		{
+			std::cerr << "GxsChannelPostItem::loadMessage() Wrong number of Items. Remove It.";
+			std::cerr << std::endl;
+
+			RsQThreadUtils::postToObject( [this]() {  removeItem(); }, this );
+		}
+	});
 }
 
-void GxsChannelPostItem::loadComment(const uint32_t &token)
+void GxsChannelPostItem::loadComment()
 {
 #ifdef DEBUG_ITEM
 	std::cerr << "GxsChannelPostItem::loadComment()";
 	std::cerr << std::endl;
 #endif
 
-	std::vector<RsGxsComment> cmts;
-	if (!rsGxsChannels->getRelatedComments(token, cmts))
+	RsThread::async([this]()
 	{
-		std::cerr << "GxsChannelPostItem::loadComment() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
+		// 1 - get group data
 
-	size_t comNb = cmts.size();
-	QString sComButText = tr("Comment");
-	if (comNb == 1) {
-		sComButText = sComButText.append("(1)");
-	} else if (comNb > 1) {
-		sComButText = tr("Comments ").append("(%1)").arg(comNb);
-	}
-	ui->commentButton->setText(sComButText);
+        std::set<RsGxsMessageId> msgIds;
+
+        for(auto MsgId: messageVersions())
+            msgIds.insert(MsgId);
+
+		std::vector<RsGxsChannelPost> posts;
+		std::vector<RsGxsComment> comments;
+
+		if(! rsGxsChannels->getChannelContent( groupId(),msgIds,posts,comments))
+		{
+			RsErr() << "GxsGxsChannelGroupItem::loadGroup() ERROR getting data" << std::endl;
+			return;
+		}
+
+        int comNb = comments.size();
+
+		RsQThreadUtils::postToObject( [comNb,this]()
+		{
+			QString sComButText = tr("Comment");
+			if (comNb == 1)
+				sComButText = sComButText.append("(1)");
+			else if(comNb > 1)
+				sComButText = tr("Comments ").append("(%1)").arg(comNb);
+
+			ui->commentButton->setText(sComButText);
+
+		}, this );
+	});
 }
 
 void GxsChannelPostItem::fill()
 {
 	/* fill in */
 
-	if (isLoading()) {
-		/* Wait for all requests */
-		return;
-	}
+//	if (isLoading()) {
+	//	/* Wait for all requests */
+		//return;
+//	}
 
 #ifdef DEBUG_ITEM
 	std::cerr << "GxsChannelPostItem::fill()";

retroshare-gui/src/gui/feeds/GxsChannelPostItem.h

@@ -81,13 +81,13 @@ protected:
 
 	/* GxsGroupFeedItem */
 	virtual QString groupName();
-	virtual void loadGroup(const uint32_t &token);
+	virtual void loadGroup() override;
 	virtual RetroShareLink::enumType getLinkType() { return RetroShareLink::TYPE_CHANNEL; }
 
 	/* GxsFeedItem */
 	virtual QString messageName();
-	virtual void loadMessage(const uint32_t &token);
-	virtual void loadComment(const uint32_t &token);
+	virtual void loadMessage();
+	virtual void loadComment();
 
 private slots:
 	/* default stuff */

retroshare-gui/src/gui/feeds/GxsForumGroupItem.cpp

@@ -23,6 +23,7 @@
 
 #include "FeedHolder.h"
 #include "gui/RetroShareLink.h"
+#include "util/qtthreadsutils.h"
 
 /****
  * #define DEBUG_ITEM 1
@@ -87,29 +88,43 @@ bool GxsForumGroupItem::setGroup(const RsGxsForumGroup &group)
 	return true;
 }
 
-void GxsForumGroupItem::loadGroup(const uint32_t &token)
+void GxsForumGroupItem::loadGroup()
 {
-#ifdef DEBUG_ITEM
-	std::cerr << "GxsForumGroupItem::loadGroup()";
-	std::cerr << std::endl;
+ 	RsThread::async([this]()
+	{
+		// 1 - get group data
+
+#ifdef DEBUG_FORUMS
+		std::cerr << "Retrieving post data for post " << mThreadId << std::endl;
 #endif
 
-	std::vector<RsGxsForumGroup> groups;
-	if (!rsGxsForums->getGroupData(token, groups))
-	{
-		std::cerr << "GxsForumGroupItem::loadGroup() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
+		std::vector<RsGxsForumGroup> groups;
+		const std::list<RsGxsGroupId> forumIds = { groupId() };
 
-	if (groups.size() != 1)
-	{
-		std::cerr << "GxsForumGroupItem::loadGroup() Wrong number of Items";
-		std::cerr << std::endl;
-		return;
-	}
+		if(!rsGxsForums->getForumsInfo(forumIds,groups))
+		{
+			RsErr() << "GxsForumGroupItem::loadGroup() ERROR getting data" << std::endl;
+			return;
+		}
 
-	setGroup(groups[0]);
+		if (groups.size() != 1)
+		{
+			std::cerr << "GxsForumGroupItem::loadGroup() Wrong number of Items";
+			std::cerr << std::endl;
+			return;
+		}
+		const RsGxsForumGroup& group(groups[0]);
+
+		RsQThreadUtils::postToObject( [group,this]()
+		{
+			/* Here it goes any code you want to be executed on the Qt Gui
+			 * thread, for example to update the data model with new information
+			 * after a blocking call to RetroShare API complete */
+
+			setGroup(group);
+
+		}, this );
+	});
 }
 
 QString GxsForumGroupItem::groupName()

retroshare-gui/src/gui/feeds/GxsForumGroupItem.h

@@ -50,7 +50,7 @@ protected:
 
 	/* GxsGroupFeedItem */
 	virtual QString groupName();
-	virtual void loadGroup(const uint32_t &token);
+	virtual void loadGroup() override;
 	virtual RetroShareLink::enumType getLinkType() { return RetroShareLink::TYPE_FORUM; }
 
 private slots:

retroshare-gui/src/gui/feeds/GxsForumMsgItem.cpp

@@ -30,6 +30,7 @@
 #include "gui/RetroShareLink.h"
 #include "gui/gxs/GxsIdDetails.h"
 #include "util/HandleRichText.h"
+#include "util/qtthreadsutils.h"
 #include "util/DateTime.h"
 
 #include <retroshare/rsidentity.h>
@@ -94,7 +95,6 @@ void GxsForumMsgItem::setup()
 
 	mInFill = false;
 	mCloseOnRead = false;
-	mTokenTypeParentMessage = nextTokenType();
 
 	/* clear ui */
 	ui->titleLabel->setText(tr("Loading"));
@@ -154,13 +154,10 @@ bool GxsForumMsgItem::setMessage(const RsGxsForumMsg &msg, bool doFill)
 
 	mMessage = msg;
 
-	if (!isTop()) {
-		requestParentMessage(mMessage.mMeta.mParentId);
-	} else {
-		if (doFill) {
-			fill();
-		}
-	}
+	if (!isTop())
+		loadParentMessage(mMessage.mMeta.mParentId);
+	 else if(doFill)
+		fill();
 
 	return true;
 }
@@ -170,91 +167,144 @@ QString GxsForumMsgItem::groupName()
 	return QString::fromUtf8(mGroup.mMeta.mGroupName.c_str());
 }
 
-void GxsForumMsgItem::loadGroup(const uint32_t &token)
+void GxsForumMsgItem::loadGroup()
 {
-#ifdef DEBUG_ITEM
-	std::cerr << "GxsForumGroupItem::loadGroup()";
-	std::cerr << std::endl;
+	RsThread::async([this]()
+	{
+		// 1 - get group data
+
+#ifdef DEBUG_FORUMS
+		std::cerr << "Retrieving post data for post " << mThreadId << std::endl;
 #endif
 
-	std::vector<RsGxsForumGroup> groups;
-	if (!rsGxsForums->getGroupData(token, groups))
-	{
-		std::cerr << "GxsForumGroupItem::loadGroup() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
+		std::vector<RsGxsForumGroup> groups;
+		const std::list<RsGxsGroupId> forumIds = { groupId() };
 
-	if (groups.size() != 1)
-	{
-		std::cerr << "GxsForumGroupItem::loadGroup() Wrong number of Items";
-		std::cerr << std::endl;
-		return;
-	}
+		if(!rsGxsForums->getForumsInfo(forumIds,groups))
+		{
+			RsErr() << "GxsForumGroupItem::loadGroup() ERROR getting data" << std::endl;
+			return;
+		}
 
-	setGroup(groups[0]);
+		if (groups.size() != 1)
+		{
+			std::cerr << "GxsForumGroupItem::loadGroup() Wrong number of Items";
+			std::cerr << std::endl;
+			return;
+		}
+		RsGxsForumGroup group(groups[0]);
+
+		RsQThreadUtils::postToObject( [group,this]()
+		{
+			/* Here it goes any code you want to be executed on the Qt Gui
+			 * thread, for example to update the data model with new information
+			 * after a blocking call to RetroShare API complete */
+
+			setGroup(group);
+
+		}, this );
+	});
 }
 
-void GxsForumMsgItem::loadMessage(const uint32_t &token)
+void GxsForumMsgItem::loadMessage()
 {
 #ifdef DEBUG_ITEM
 	std::cerr << "GxsForumMsgItem::loadMessage()";
 	std::cerr << std::endl;
 #endif
 
-	std::vector<RsGxsForumMsg> msgs;
-	if (!rsGxsForums->getMsgData(token, msgs))
+	RsThread::async([this]()
 	{
-		std::cerr << "GxsForumMsgItem::loadMessage() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
-	
-	if (msgs.size() != 1)
-	{
-		std::cerr << "GxsForumMsgItem::loadMessage() Wrong number of Items";
-		std::cerr << std::endl;
-		return;
-	}
+		// 1 - get group data
 
-	setMessage(msgs[0]);
+#ifdef DEBUG_FORUMS
+		std::cerr << "Retrieving post data for post " << mThreadId << std::endl;
+#endif
+
+		std::vector<RsGxsForumMsg> msgs;
+		const std::list<RsGxsGroupId> forumIds = { groupId() };
+
+		if(!rsGxsForums->getForumContent(groupId(),std::set<RsGxsMessageId>( { messageId() } ),msgs))
+		{
+			std::cerr << "GxsForumMsgItem::loadMessage() ERROR getting data";
+			std::cerr << std::endl;
+			return;
+		}
+
+		if (msgs.size() != 1)
+		{
+			std::cerr << "GxsForumMsgItem::loadMessage() Wrong number of Items";
+			std::cerr << std::endl;
+			return;
+		}
+		const RsGxsForumMsg& msg(msgs[0]);
+
+		RsQThreadUtils::postToObject( [msg,this]()
+		{
+			/* Here it goes any code you want to be executed on the Qt Gui
+			 * thread, for example to update the data model with new information
+			 * after a blocking call to RetroShare API complete */
+
+			setMessage(msg);
+
+		}, this );
+	});
 }
 
-void GxsForumMsgItem::loadParentMessage(const uint32_t &token)
+void GxsForumMsgItem::loadParentMessage(const RsGxsMessageId& parent_msg)
 {
 #ifdef DEBUG_ITEM
 	std::cerr << "GxsForumMsgItem::loadParentMessage()";
 	std::cerr << std::endl;
 #endif
 
-	std::vector<RsGxsForumMsg> msgs;
-	if (!rsGxsForums->getMsgData(token, msgs))
+	RsThread::async([parent_msg,this]()
 	{
-		std::cerr << "GxsForumMsgItem::loadParentMessage() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
+		// 1 - get group data
 
-	if (msgs.size() != 1)
-	{
-		std::cerr << "GxsForumMsgItem::loadParentMessage() Wrong number of Items";
-		std::cerr << std::endl;
-		return;
-	}
+#ifdef DEBUG_FORUMS
+		std::cerr << "Retrieving post data for post " << mThreadId << std::endl;
+#endif
 
-	mParentMessage = msgs[0];
+		std::vector<RsGxsForumMsg> msgs;
+		const std::list<RsGxsGroupId> forumIds = { groupId() };
 
-	fill();
+		if(!rsGxsForums->getForumContent(groupId(),std::set<RsGxsMessageId>( { parent_msg } ),msgs))
+		{
+			std::cerr << "GxsForumMsgItem::loadMessage() ERROR getting data";
+			std::cerr << std::endl;
+			return;
+		}
+
+		if (msgs.size() != 1)
+		{
+			std::cerr << "GxsForumMsgItem::loadMessage() Wrong number of Items";
+			std::cerr << std::endl;
+			return;
+		}
+		const RsGxsForumMsg& msg(msgs[0]);
+
+		RsQThreadUtils::postToObject( [msg,this]()
+		{
+			/* Here it goes any code you want to be executed on the Qt Gui
+			 * thread, for example to update the data model with new information
+			 * after a blocking call to RetroShare API complete */
+
+			mParentMessage = msg;
+			fill();
+
+		}, this );
+	});
 }
 
 void GxsForumMsgItem::fill()
 {
 	/* fill in */
 
-	if (isLoading()) {
-		/* Wait for all requests */
-		return;
-	}
+//	if (isLoading()) {
+//		/* Wait for all requests */
+//		return;
+//	}
 
 #ifdef DEBUG_ITEM
 	std::cerr << "GxsForumMsgItem::fill()";
@@ -307,18 +357,6 @@ void GxsForumMsgItem::fill()
 
 	ui->nameLabel->setId(mMessage.mMeta.mAuthorId);
 
-//	ui->avatar->setId(msg.srcId, true);
-
-//	if (rsPeers->getPeerName(msg.srcId) != "") {
-//		RetroShareLink linkMessage;
-//		linkMessage.createMessage(msg.srcId, "");
-//		nameLabel->setText(linkMessage.toHtml());
-//	}
-//	else
-//	{
-//		nameLabel->setText(tr("Anonymous"));
-//	}
-
 	RetroShareLink msgLink = RetroShareLink::createGxsMessageLink(RetroShareLink::TYPE_FORUM, mMessage.mMeta.mGroupId, mMessage.mMeta.mMsgId, messageName());
 	ui->subLabel->setText(msgLink.toHtml());
 	if (wasExpanded() || ui->expandFrame->isVisible()) {
@@ -330,14 +368,13 @@ void GxsForumMsgItem::fill()
 	if (isTop()) {
 		ui->parentFrame->hide();
 	} else {
-//		ui->parentAvatar->setId(msgParent.srcId, true);
 
 		RetroShareLink linkParent = RetroShareLink::createGxsMessageLink(RetroShareLink::TYPE_FORUM, mParentMessage.mMeta.mGroupId, mParentMessage.mMeta.mMsgId, QString::fromUtf8(mParentMessage.mMeta.mMsgName.c_str()));
 		ui->parentSubLabel->setText(linkParent.toHtml());
 		ui->parentMsgLabel->setText(RsHtml().formatText(NULL, QString::fromUtf8(mParentMessage.mMsg.c_str()), RSHTML_FORMATTEXT_EMBED_SMILEYS | RSHTML_FORMATTEXT_EMBED_LINKS));
 
 		ui->parentNameLabel->setId(mParentMessage.mMeta.mAuthorId);
-		
+
 		RsIdentityDetails idDetails ;
 		rsIdentity->getIdDetails(mParentMessage.mMeta.mAuthorId,idDetails);
 		
@@ -348,16 +385,6 @@ void GxsForumMsgItem::fill()
 			
 		ui->parentAvatar->setPixmap(pixmap);
 
-//		if (rsPeers->getPeerName(msgParent.srcId) !="")
-//		{
-//			RetroShareLink linkMessage;
-//			linkMessage.createMessage(msgParent.srcId, "");
-//			ui->parentNameLabel->setText(linkMessage.toHtml());
-//		}
-//		else
-//		{
-//			ui->parentNameLabel->setText(tr("Anonymous"));
-//		}
 	}
 
 	/* header stuff */
@@ -440,63 +467,6 @@ void GxsForumMsgItem::setReadStatus(bool isNew, bool /*isUnread*/)
 	ui->frame->style()->polish(  ui->frame);
 }
 
-void GxsForumMsgItem::requestParentMessage(const RsGxsMessageId &msgId)
-{
-#ifdef DEBUG_ITEM
-	std::cerr << "GxsFeedItem::requestMessage()";
-	std::cerr << std::endl;
-#endif
-
-	if (!initLoadQueue()) {
-		return;
-	}
-
-	if (mLoadQueue->activeRequestExist(mTokenTypeParentMessage)) {
-		/* Request already running */
-		return;
-	}
-
-	RsTokReqOptions opts;
-	opts.mReqType = GXS_REQUEST_TYPE_MSG_DATA;
-
-	GxsMsgReq msgIds;
-	std::set<RsGxsMessageId> &vect_msgIds = msgIds[groupId()];
-	vect_msgIds.insert(msgId);
-
-	uint32_t token;
-	mLoadQueue->requestMsgInfo(token, RS_TOKREQ_ANSTYPE_DATA, opts, msgIds, mTokenTypeParentMessage);
-}
-
-void GxsForumMsgItem::loadRequest(const TokenQueue *queue, const TokenRequest &req)
-{
-#ifdef DEBUG_ITEM
-	std::cerr << "GxsFeedItem::loadRequest()";
-	std::cerr << std::endl;
-#endif
-
-	if (queue == mLoadQueue) {
-		if (req.mUserType == mTokenTypeParentMessage) {
-			loadParentMessage(req.mToken);
-			return;
-		}
-	}
-
-	GxsFeedItem::loadRequest(queue, req);
-}
-
-bool GxsForumMsgItem::isLoading()
-{
-	if (GxsFeedItem::isLoading()) {
-		return true;
-	}
-
-	if (mLoadQueue && mLoadQueue->activeRequestExist(mTokenTypeParentMessage)) {
-		return true;
-	}
-
-	return false;
-}
-
 /*********** SPECIFIC FUNCTIONS ***********************/
 
 void GxsForumMsgItem::readAndClearItem()

retroshare-gui/src/gui/feeds/GxsForumMsgItem.h

@@ -50,20 +50,18 @@ protected:
 	virtual void expandFill(bool first);
 
 	/* load message data */
-	void requestParentMessage(const RsGxsMessageId &msgId);
-	virtual void loadParentMessage(const uint32_t &token);
+	virtual void loadParentMessage(const RsGxsMessageId &parent_msg);
 
 	/* GxsGroupFeedItem */
 	virtual QString groupName();
-	virtual void loadGroup(const uint32_t &token);
-	virtual void loadRequest(const TokenQueue *queue, const TokenRequest &req);
+	virtual void loadGroup() override;
 	virtual RetroShareLink::enumType getLinkType() { return RetroShareLink::TYPE_FORUM; }
-	virtual bool isLoading();
+	//virtual bool isLoading();
 
 	/* GxsFeedItem */
 	virtual QString messageName();
-	virtual void loadMessage(const uint32_t &token);
-	virtual void loadComment(const uint32_t &/*token*/){ return;}
+	virtual void loadMessage() override;
+	virtual void loadComment() override { return; }
 
 private slots:
 	/* default stuff */
@@ -90,7 +88,6 @@ private:
 	RsGxsForumGroup mGroup;
 	RsGxsForumMsg mMessage;
 	RsGxsForumMsg mParentMessage;
-	uint32_t mTokenTypeParentMessage;
 
 	/** Qt Designer generated object */
 	Ui::GxsForumMsgItem *ui;

retroshare-gui/src/gui/feeds/PostedGroupItem.cpp

@@ -22,6 +22,7 @@
 #include "ui_PostedGroupItem.h"
 
 #include "FeedHolder.h"
+#include "util/qtthreadsutils.h"
 #include "gui/RetroShareLink.h"
 #include "gui/gxs/GxsIdDetails.h"
 
@@ -90,29 +91,46 @@ bool PostedGroupItem::setGroup(const RsPostedGroup &group)
 	return true;
 }
 
-void PostedGroupItem::loadGroup(const uint32_t &token)
+void PostedGroupItem::loadGroup()
 {
-#ifdef DEBUG_ITEM
-	std::cerr << "PostedGroupItem::loadGroup()";
-	std::cerr << std::endl;
+	RsThread::async([this]()
+	{
+		// 1 - get group data
+
+#ifdef DEBUG_FORUMS
+		std::cerr << "Retrieving post data for post " << mThreadId << std::endl;
 #endif
 
-	std::vector<RsPostedGroup> groups;
-	if (!rsPosted->getGroupData(token, groups))
-	{
-		std::cerr << "PostedGroupItem::loadGroup() ERROR getting data";
-		std::cerr << std::endl;
-		return;
-	}
+		std::vector<RsPostedGroup> groups;
+		const std::list<RsGxsGroupId> groupIds = { groupId() };
 
-	if (groups.size() != 1)
-	{
-		std::cerr << "PostedGroupItem::loadGroup() Wrong number of Items";
-		std::cerr << std::endl;
-		return;
-	}
+#warning Code needed in rsPosted
+#ifdef TODO
+		if(!rsPosted->getPostedGroupInfo(groupIds,groups))
+#endif
+		{
+			RsErr() << "GxsPostedGroupItem::loadGroup() ERROR getting data" << std::endl;
+			return;
+		}
 
-	setGroup(groups[0]);
+		if (groups.size() != 1)
+		{
+			std::cerr << "GxsPostedGroupItem::loadGroup() Wrong number of Items";
+			std::cerr << std::endl;
+			return;
+		}
+		RsPostedGroup group(groups[0]);
+
+		RsQThreadUtils::postToObject( [group,this]()
+		{
+			/* Here it goes any code you want to be executed on the Qt Gui
+			 * thread, for example to update the data model with new information
+			 * after a blocking call to RetroShare API complete */
+
+			setGroup(group);
+
+		}, this );
+	});
 }
 
 QString PostedGroupItem::groupName()

retroshare-gui/src/gui/feeds/PostedGroupItem.h

@@ -50,7 +50,7 @@ protected:
 
 	/* GxsGroupFeedItem */
 	virtual QString groupName();
-	virtual void loadGroup(const uint32_t &token);
+	virtual void loadGroup() override;
 	virtual RetroShareLink::enumType getLinkType() { return RetroShareLink::TYPE_UNKNOWN; }
 
 private slots: