fixed GxsChannelGroupItem

This commit is contained in:
csoler 2025-11-01 17:24:58 +01:00
parent c8dbf34a14
commit 785a83f625
4 changed files with 64 additions and 49 deletions

View file

@ -36,20 +36,22 @@
GxsChannelGroupItem::GxsChannelGroupItem(FeedHolder *feedHolder, uint32_t feedId, const RsGxsGroupId &groupId, bool isHome, bool autoUpdate) : GxsChannelGroupItem::GxsChannelGroupItem(FeedHolder *feedHolder, uint32_t feedId, const RsGxsGroupId &groupId, bool isHome, bool autoUpdate) :
GxsGroupFeedItem(feedHolder, feedId, groupId, isHome, rsGxsChannels, autoUpdate) GxsGroupFeedItem(feedHolder, feedId, groupId, isHome, rsGxsChannels, autoUpdate)
{ {
mIsLoading = false; mLoadingGroup = false;
mLoadingStatus = NO_DATA;
setup(); setup();
requestGroup(); requestGroup();
addEventHandler(); addEventHandler();
} }
GxsChannelGroupItem::GxsChannelGroupItem(FeedHolder *feedHolder, uint32_t feedId, const RsGxsChannelGroup &group, bool isHome, bool autoUpdate) : //GxsChannelGroupItem::GxsChannelGroupItem(FeedHolder *feedHolder, uint32_t feedId, const RsGxsChannelGroup &group, bool isHome, bool autoUpdate) :
GxsGroupFeedItem(feedHolder, feedId, group.mMeta.mGroupId, isHome, rsGxsChannels, autoUpdate) // GxsGroupFeedItem(feedHolder, feedId, group.mMeta.mGroupId, isHome, rsGxsChannels, autoUpdate)
{ //{
mIsLoading = false; // mIsLoading = false;
setup(); // setup();
setGroup(group); // setGroup(group);
addEventHandler(); // addEventHandler();
} //}
void GxsChannelGroupItem::addEventHandler() void GxsChannelGroupItem::addEventHandler()
{ {
@ -68,7 +70,7 @@ void GxsChannelGroupItem::addEventHandler()
case RsChannelEventCode::SUBSCRIBE_STATUS_CHANGED: case RsChannelEventCode::SUBSCRIBE_STATUS_CHANGED:
case RsChannelEventCode::UPDATED_CHANNEL: case RsChannelEventCode::UPDATED_CHANNEL:
case RsChannelEventCode::RECEIVED_PUBLISH_KEY: case RsChannelEventCode::RECEIVED_PUBLISH_KEY:
loadGroup(); mLoadingStatus = NO_DATA;
break; break;
default: default:
break; break;
@ -77,11 +79,37 @@ void GxsChannelGroupItem::addEventHandler()
}, mEventHandlerId, RsEventType::GXS_CHANNELS ); }, mEventHandlerId, RsEventType::GXS_CHANNELS );
} }
void GxsChannelGroupItem::paintEvent(QPaintEvent *e)
{
/* This method employs a trick to trigger a deferred loading. The post and group is requested only
* when actually displayed on the screen. */
if(mLoadingStatus != FILLED && !mGroup.mMeta.mGroupId.isNull())
mLoadingStatus = HAS_DATA;
if(mGroup.mMeta.mGroupId.isNull() && !mLoadingGroup)
loadGroup();
switch(mLoadingStatus)
{
case FILLED:
case NO_DATA:
default:
break;
case HAS_DATA:
fill();
mLoadingStatus = FILLED;
break;
}
GxsGroupFeedItem::paintEvent(e) ;
}
GxsChannelGroupItem::~GxsChannelGroupItem() GxsChannelGroupItem::~GxsChannelGroupItem()
{ {
auto timeout = std::chrono::steady_clock::now() + std::chrono::milliseconds(GROUP_ITEM_LOADING_TIMEOUT_ms); auto timeout = std::chrono::steady_clock::now() + std::chrono::milliseconds(GROUP_ITEM_LOADING_TIMEOUT_ms);
while( mIsLoading && std::chrono::steady_clock::now() < timeout ) while( mLoadingGroup && std::chrono::steady_clock::now() < timeout )
{ {
RsDbg() << __PRETTY_FUNCTION__ << " is Waiting for data to load " << std::endl; RsDbg() << __PRETTY_FUNCTION__ << " is Waiting for data to load " << std::endl;
std::this_thread::sleep_for(std::chrono::milliseconds(100)); std::this_thread::sleep_for(std::chrono::milliseconds(100));
@ -115,23 +143,9 @@ void GxsChannelGroupItem::setup()
ui->expandFrame->hide(); ui->expandFrame->hide();
} }
bool GxsChannelGroupItem::setGroup(const RsGxsChannelGroup &group)
{
if (groupId() != group.mMeta.mGroupId) {
std::cerr << "GxsChannelGroupItem::setContent() - Wrong id, cannot set post";
std::cerr << std::endl;
return false;
}
mGroup = group;
fill();
return true;
}
void GxsChannelGroupItem::loadGroup() void GxsChannelGroupItem::loadGroup()
{ {
mIsLoading = true; mLoadingGroup = true;
RsThread::async([this]() RsThread::async([this]()
{ {
@ -143,7 +157,7 @@ void GxsChannelGroupItem::loadGroup()
if(!rsGxsChannels->getChannelsInfo(groupIds,groups)) if(!rsGxsChannels->getChannelsInfo(groupIds,groups))
{ {
RsErr() << "PostedItem::loadGroup() ERROR getting data" << std::endl; RsErr() << "PostedItem::loadGroup() ERROR getting data" << std::endl;
mIsLoading = false; mLoadingGroup = false;
return; return;
} }
@ -151,7 +165,7 @@ void GxsChannelGroupItem::loadGroup()
{ {
std::cerr << "GxsGxsChannelGroupItem::loadGroup() Wrong number of Items"; std::cerr << "GxsGxsChannelGroupItem::loadGroup() Wrong number of Items";
std::cerr << std::endl; std::cerr << std::endl;
mIsLoading = false; mLoadingGroup = false;
return; return;
} }
RsGxsChannelGroup group(groups[0]); RsGxsChannelGroup group(groups[0]);
@ -162,8 +176,8 @@ void GxsChannelGroupItem::loadGroup()
* thread, for example to update the data model with new information * thread, for example to update the data model with new information
* after a blocking call to RetroShare API complete */ * after a blocking call to RetroShare API complete */
setGroup(group); mGroup = group;
mIsLoading = false; mLoadingGroup = false;
}, this ); }, this );
}); });

View file

@ -37,19 +37,27 @@ class GxsChannelGroupItem : public GxsGroupFeedItem
public: public:
/** Default Constructor */ /** Default Constructor */
GxsChannelGroupItem(FeedHolder *feedHolder, uint32_t feedId, const RsGxsGroupId &groupId, bool isHome, bool autoUpdate); GxsChannelGroupItem(FeedHolder *feedHolder, uint32_t feedId, const RsGxsGroupId &groupId, bool isHome, bool autoUpdate);
GxsChannelGroupItem(FeedHolder *feedHolder, uint32_t feedId, const RsGxsChannelGroup &group, bool isHome, bool autoUpdate); //GxsChannelGroupItem(FeedHolder *feedHolder, uint32_t feedId, const RsGxsChannelGroup &group, bool isHome, bool autoUpdate);
~GxsChannelGroupItem(); virtual ~GxsChannelGroupItem();
bool setGroup(const RsGxsChannelGroup &group);
uint64_t uniqueIdentifier() const override { return hash_64bits("GxsChannelGroupItem " + groupId().toStdString()) ; } uint64_t uniqueIdentifier() const override { return hash_64bits("GxsChannelGroupItem " + groupId().toStdString()) ; }
protected: protected:
enum LoadingStatus {
NO_DATA = 0x00,
HAS_DATA = 0x01,
FILLED = 0x02
};
/* FeedItem */ /* FeedItem */
virtual void doExpand(bool open); virtual void doExpand(bool open) override;
virtual void paintEvent(QPaintEvent *) override;
/* GxsGroupFeedItem */ /* GxsGroupFeedItem */
virtual QString groupName(); virtual QString groupName() override;
virtual void loadGroup() override; virtual void loadGroup() override;
virtual RetroShareLink::enumType getLinkType() { return RetroShareLink::TYPE_CHANNEL; } virtual RetroShareLink::enumType getLinkType() override { return RetroShareLink::TYPE_CHANNEL; }
private slots: private slots:
/* default stuff */ /* default stuff */
@ -62,7 +70,8 @@ private:
void setup(); void setup();
void addEventHandler(); void addEventHandler();
bool mIsLoading; LoadingStatus mLoadingStatus;
bool mLoadingGroup;
private: private:
RsGxsChannelGroup mGroup; RsGxsChannelGroup mGroup;

View file

@ -198,12 +198,6 @@ void GxsChannelPostItem::setup()
} }
bool GxsChannelPostItem::setPost(const RsGxsChannelPost &post)
{
mPost = post;
return true;
}
QString GxsChannelPostItem::getTitleLabel() QString GxsChannelPostItem::getTitleLabel()
{ {
return QString::fromUtf8(mPost.mMeta.mMsgName.c_str()); return QString::fromUtf8(mPost.mMeta.mMsgName.c_str());
@ -296,7 +290,7 @@ void GxsChannelPostItem::loadMessage()
RsQThreadUtils::postToObject( [post,this]() RsQThreadUtils::postToObject( [post,this]()
{ {
setPost(post); mPost = post;
mLoadingMessage = false; mLoadingMessage = false;
update(); // this triggers a paintEvent if needed. update(); // this triggers a paintEvent if needed.

View file

@ -62,8 +62,6 @@ protected:
FILLED = 0x02 FILLED = 0x02
}; };
bool setPost(const RsGxsChannelPost& post);
//void setFileCleanUpWarning(uint32_t time_left); //void setFileCleanUpWarning(uint32_t time_left);
QString getTitleLabel(); QString getTitleLabel();