X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fbuffersyncer.cpp;h=fe69db71d2918d0361da005b136ca7c36544c27e;hp=d4c6918c68328366932ffbeddaf3f28923a441fd;hb=9f9d207ecf28dd5470ecef9d4076a3f447662a20;hpb=351e8bd985011abf721e2beffd9b8eeee74bf4e1 diff --git a/src/common/buffersyncer.cpp b/src/common/buffersyncer.cpp index d4c6918c..fe69db71 100644 --- a/src/common/buffersyncer.cpp +++ b/src/common/buffersyncer.cpp @@ -20,45 +20,53 @@ #include "buffersyncer.h" -BufferSyncer::BufferSyncer(QObject *parent) : SyncableObject(parent) { - - +BufferSyncer::BufferSyncer(QObject *parent) + : SyncableObject(parent) +{ } -QDateTime BufferSyncer::lastSeen(BufferId buffer) const { - if(_lastSeen.contains(buffer)) return _lastSeen[buffer]; - return QDateTime(); +MsgId BufferSyncer::lastSeenMsg(BufferId buffer) const { + if(_lastSeenMsg.contains(buffer)) + return _lastSeenMsg[buffer]; + return MsgId(); } -bool BufferSyncer::setLastSeen(BufferId buffer, const QDateTime &time) { - if(!time.isValid()) return false; - if(!lastSeen(buffer).isValid() || lastSeen(buffer) < time) { - _lastSeen[buffer] = time; - emit lastSeenSet(buffer, time); +bool BufferSyncer::setLastSeenMsg(BufferId buffer, const MsgId &msgId) { + if(!msgId.isValid()) + return false; + + const MsgId oldLastSeenMsg = lastSeenMsg(buffer); + if(!oldLastSeenMsg.isValid() || oldLastSeenMsg < msgId) { + _lastSeenMsg[buffer] = msgId; + emit lastSeenMsgSet(buffer, msgId); return true; } return false; } -QVariantList BufferSyncer::initLastSeen() const { +QVariantList BufferSyncer::initLastSeenMsg() const { QVariantList list; - foreach(BufferId id, _lastSeen.keys()) { - list << QVariant::fromValue(id) << _lastSeen[id]; + QHash::const_iterator iter = _lastSeenMsg.constBegin(); + while(iter != _lastSeenMsg.constEnd()) { + list << QVariant::fromValue(iter.key()) + << QVariant::fromValue(iter.value()); + iter++; } return list; } -void BufferSyncer::initSetLastSeen(const QVariantList &list) { - _lastSeen.clear(); +void BufferSyncer::initSetLastSeenMsg(const QVariantList &list) { + _lastSeenMsg.clear(); Q_ASSERT(list.count() % 2 == 0); for(int i = 0; i < list.count(); i += 2) { - setLastSeen(list[i].value(), list[i+1].toDateTime()); + setLastSeenMsg(list[i].value(), list[i+1].value()); } } -void BufferSyncer::requestSetLastSeen(BufferId buffer, const QDateTime &time) { - if(setLastSeen(buffer, time)) emit setLastSeenRequested(buffer, time); +void BufferSyncer::requestSetLastSeenMsg(BufferId buffer, const MsgId &msgId) { + if(setLastSeenMsg(buffer, msgId)) + emit setLastSeenMsgRequested(buffer, msgId); } @@ -67,8 +75,8 @@ void BufferSyncer::requestRemoveBuffer(BufferId buffer) { } void BufferSyncer::removeBuffer(BufferId buffer) { - if(_lastSeen.contains(buffer)) - _lastSeen.remove(buffer); + if(_lastSeenMsg.contains(buffer)) + _lastSeenMsg.remove(buffer); emit bufferRemoved(buffer); }