/***************************************************************************
- * Copyright (C) 2005-09 by the Quassel Project *
+ * Copyright (C) 2005-2020 by the Quassel Project *
* devel@quassel-irc.org *
* *
* This program is free software; you can redistribute it and/or modify *
* You should have received a copy of the GNU General Public License *
* along with this program; if not, write to the *
* Free Software Foundation, Inc., *
- * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
***************************************************************************/
#include "corebacklogmanager.h"
+
+#include <algorithm>
+#include <iterator>
+
+#include <QDebug>
+
#include "core.h"
#include "coresession.h"
-#include <QDebug>
+CoreBacklogManager::CoreBacklogManager(CoreSession* coreSession)
+ : BacklogManager(coreSession)
+ , _coreSession(coreSession)
+{}
-CoreBacklogManager::CoreBacklogManager(CoreSession *coreSession)
- : BacklogManager(coreSession),
- _coreSession(coreSession)
+QVariantList CoreBacklogManager::requestBacklog(BufferId bufferId, MsgId first, MsgId last, int limit, int additional)
{
-}
+ QVariantList backlog;
+ auto msgList = Core::requestMsgs(coreSession()->user(), bufferId, first, last, limit);
-QVariantList CoreBacklogManager::requestBacklog(BufferId bufferId, MsgId first, MsgId last, int limit, int additional) {
- QVariantList backlog;
- QList<Message> msgList;
- msgList = Core::requestMsgs(coreSession()->user(), bufferId, first, last, limit);
-
- QList<Message>::const_iterator msgIter = msgList.constBegin();
- QList<Message>::const_iterator msgListEnd = msgList.constEnd();
- while(msgIter != msgListEnd) {
- backlog << qVariantFromValue(*msgIter);
- msgIter++;
- }
-
- if(additional) {
- MsgId oldestMessage;
- if(!msgList.isEmpty()) {
- if(msgList.first().msgId() < msgList.last().msgId())
- oldestMessage = msgList.first().msgId();
- else
- oldestMessage = msgList.last().msgId();
- }
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
+
+ if (additional && limit != 0) {
+ MsgId oldestMessage = first;
+ if (!msgList.empty()) {
+ if (msgList.front().msgId() < msgList.back().msgId())
+ oldestMessage = msgList.front().msgId();
+ else
+ oldestMessage = msgList.back().msgId();
+ }
- if(first != -1) {
- last = first;
- } else {
- last = oldestMessage;
+ if (first != -1) {
+ last = first;
+ }
+ else {
+ last = oldestMessage;
+ }
+
+ // only fetch additional messages if they continue seemlessly
+ // that is, if the list of messages is not truncated by the limit
+ if (last == oldestMessage) {
+ msgList = Core::requestMsgs(coreSession()->user(), bufferId, -1, last, additional);
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
+ }
}
- // only fetch additional messages if they continue seemlessly
- // that is, if the list of messages is not truncated by the limit
- if(last == oldestMessage) {
- msgList = Core::requestMsgs(coreSession()->user(), bufferId, -1, last, additional);
- msgIter = msgList.constBegin();
- msgListEnd = msgList.constEnd();
- while(msgIter != msgListEnd) {
- backlog << qVariantFromValue(*msgIter);
- msgIter++;
- }
+ return backlog;
+}
+
+QVariantList CoreBacklogManager::requestBacklogFiltered(BufferId bufferId, MsgId first, MsgId last, int limit, int additional, int type, int flags)
+{
+ QVariantList backlog;
+ auto msgList = Core::requestMsgsFiltered(coreSession()->user(), bufferId, first, last, limit, Message::Types{type}, Message::Flags{flags});
+
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
+
+ if (additional && limit != 0) {
+ MsgId oldestMessage = first;
+ if (!msgList.empty()) {
+ if (msgList.front().msgId() < msgList.back().msgId())
+ oldestMessage = msgList.front().msgId();
+ else
+ oldestMessage = msgList.back().msgId();
+ }
+
+ if (first != -1) {
+ last = first;
+ }
+ else {
+ last = oldestMessage;
+ }
+
+ // only fetch additional messages if they continue seemlessly
+ // that is, if the list of messages is not truncated by the limit
+ if (last == oldestMessage) {
+ msgList = Core::requestMsgsFiltered(coreSession()->user(), bufferId, -1, last, additional, Message::Types{type}, Message::Flags{flags});
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
+ }
}
- }
- return backlog;
+ return backlog;
+}
+
+QVariantList CoreBacklogManager::requestBacklogForward(BufferId bufferId, MsgId first, MsgId last, int limit, int type, int flags)
+{
+ QVariantList backlog;
+ auto msgList = Core::requestMsgsForward(coreSession()->user(), bufferId, first, last, limit, Message::Types{type}, Message::Flags{flags});
+
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
+
+ return backlog;
}
-QVariantList CoreBacklogManager::requestBacklogAll(MsgId first, MsgId last, int limit, int additional) {
- qDebug() << "CoreBacklogManager::requestBacklogAll" << first << last << limit << additional;
- QVariantList backlog;
- QList<Message> msgList;
- msgList = Core::requestAllMsgs(coreSession()->user(), first, last, limit);
-
- QList<Message>::const_iterator msgIter = msgList.constBegin();
- QList<Message>::const_iterator msgListEnd = msgList.constEnd();
- while(msgIter != msgListEnd) {
- backlog << qVariantFromValue(*msgIter);
- msgIter++;
- }
-
- if(additional) {
- if(first != -1) {
- last = first;
- } else {
- last = -1;
- if(!msgList.isEmpty()) {
- if(msgList.first().msgId() < msgList.last().msgId())
- last = msgList.first().msgId();
- else
- last = msgList.last().msgId();
- }
+QVariantList CoreBacklogManager::requestBacklogAll(MsgId first, MsgId last, int limit, int additional)
+{
+ QVariantList backlog;
+ auto msgList = Core::requestAllMsgs(coreSession()->user(), first, last, limit);
+
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
+
+ if (additional) {
+ if (first != -1) {
+ last = first;
+ }
+ else {
+ last = -1;
+ if (!msgList.empty()) {
+ if (msgList.front().msgId() < msgList.back().msgId())
+ last = msgList.front().msgId();
+ else
+ last = msgList.back().msgId();
+ }
+ }
+ msgList = Core::requestAllMsgs(coreSession()->user(), -1, last, additional);
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
}
- msgList = Core::requestAllMsgs(coreSession()->user(), -1, last, additional);
- msgIter = msgList.constBegin();
- msgListEnd = msgList.constEnd();
- while(msgIter != msgListEnd) {
- backlog << qVariantFromValue(*msgIter);
- msgIter++;
+
+ return backlog;
+}
+
+QVariantList CoreBacklogManager::requestBacklogAllFiltered(MsgId first, MsgId last, int limit, int additional, int type, int flags)
+{
+ QVariantList backlog;
+ auto msgList = Core::requestAllMsgsFiltered(coreSession()->user(), first, last, limit, Message::Types{type}, Message::Flags{flags});
+
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
+
+ if (additional) {
+ if (first != -1) {
+ last = first;
+ }
+ else {
+ last = -1;
+ if (!msgList.empty()) {
+ if (msgList.front().msgId() < msgList.back().msgId())
+ last = msgList.front().msgId();
+ else
+ last = msgList.back().msgId();
+ }
+ }
+ msgList = Core::requestAllMsgsFiltered(coreSession()->user(), -1, last, additional, Message::Types{type}, Message::Flags{flags});
+ std::transform(msgList.cbegin(), msgList.cend(), std::back_inserter(backlog), [](auto&& msg) {
+ return QVariant::fromValue(msg);
+ });
}
- }
- return backlog;
+ return backlog;
}