X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fmessage.cpp;h=1367b40cc9e9f4e26016e16f081744a82ae4a8cb;hp=34990c6442bca5a44b98db8ec41be8445dab9f22;hb=579e559a6322209df7cd51c34801fecff5fe734b;hpb=458c3278a4b9102bcc470d48816fac379492a588 diff --git a/src/common/message.cpp b/src/common/message.cpp index 34990c64..1367b40c 100644 --- a/src/common/message.cpp +++ b/src/common/message.cpp @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2018 by the Quassel Project * + * Copyright (C) 2005-2019 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -18,39 +18,55 @@ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * ***************************************************************************/ -#include "message.h" - -#include "util.h" -#include "peer.h" -#include "signalproxy.h" +#include #include -Message::Message(const BufferInfo &bufferInfo, Type type, const QString &contents, const QString &sender, const QString &senderPrefixes, Flags flags) - : _timestamp(QDateTime::currentDateTime().toUTC()), - _bufferInfo(bufferInfo), - _contents(contents), - _sender(sender), - _senderPrefixes(senderPrefixes), - _type(type), - _flags(flags) -{ -} - - -Message::Message(const QDateTime &ts, const BufferInfo &bufferInfo, Type type, const QString &contents, const QString &sender, const QString &senderPrefixes, Flags flags) - : _timestamp(ts), - _bufferInfo(bufferInfo), - _contents(contents), - _sender(sender), - _senderPrefixes(senderPrefixes), - _type(type), - _flags(flags) -{ -} - +#include "message.h" +#include "peer.h" +#include "signalproxy.h" +#include "util.h" -QDataStream &operator<<(QDataStream &out, const Message &msg) +Message::Message(BufferInfo bufferInfo, + Type type, + QString contents, + QString sender, + QString senderPrefixes, + QString realName, + QString avatarUrl, + Flags flags) + : _timestamp(QDateTime::currentDateTime().toUTC()) + , _bufferInfo(std::move(bufferInfo)) + , _contents(std::move(contents)) + , _sender(std::move(sender)) + , _senderPrefixes(std::move(senderPrefixes)) + , _realName(std::move(realName)) + , _avatarUrl(std::move(avatarUrl)) + , _type(type) + , _flags(flags) +{} + +Message::Message(QDateTime ts, + BufferInfo bufferInfo, + Type type, + QString contents, + QString sender, + QString senderPrefixes, + QString realName, + QString avatarUrl, + Flags flags) + : _timestamp(std::move(ts)) + , _bufferInfo(std::move(bufferInfo)) + , _contents(std::move(contents)) + , _sender(std::move(sender)) + , _senderPrefixes(std::move(senderPrefixes)) + , _realName(std::move(realName)) + , _avatarUrl(std::move(avatarUrl)) + , _type(type) + , _flags(flags) +{} + +QDataStream& operator<<(QDataStream& out, const Message& msg) { Q_ASSERT(SignalProxy::current()); Q_ASSERT(SignalProxy::current()->targetPeer()); @@ -58,9 +74,11 @@ QDataStream &operator<<(QDataStream &out, const Message &msg) // We do not serialize the sender prefixes until we have a new protocol or client-features implemented out << msg.msgId(); - if (SignalProxy::current()->targetPeer()->hasFeature(Quassel::Feature::LongMessageTime)) { - out << (quint64) msg.timestamp().toMSecsSinceEpoch(); - } else { + if (SignalProxy::current()->targetPeer()->hasFeature(Quassel::Feature::LongTime)) { + // toMSecs returns a qint64, signed rather than unsigned + out << (qint64) msg.timestamp().toMSecsSinceEpoch(); + } + else { out << (quint32) msg.timestamp().toTime_t(); } @@ -72,23 +90,29 @@ QDataStream &operator<<(QDataStream &out, const Message &msg) if (SignalProxy::current()->targetPeer()->hasFeature(Quassel::Feature::SenderPrefixes)) out << msg.senderPrefixes().toUtf8(); + if (SignalProxy::current()->targetPeer()->hasFeature(Quassel::Feature::RichMessages)) { + out << msg.realName().toUtf8(); + out << msg.avatarUrl().toUtf8(); + } + out << msg.contents().toUtf8(); return out; } - -QDataStream &operator>>(QDataStream &in, Message &msg) +QDataStream& operator>>(QDataStream& in, Message& msg) { Q_ASSERT(SignalProxy::current()); Q_ASSERT(SignalProxy::current()->sourcePeer()); in >> msg._msgId; - if (SignalProxy::current()->sourcePeer()->hasFeature(Quassel::Feature::LongMessageTime)) { - quint64 timeStamp; + if (SignalProxy::current()->sourcePeer()->hasFeature(Quassel::Feature::LongTime)) { + // timestamp is a qint64, signed rather than unsigned + qint64 timeStamp; in >> timeStamp; msg._timestamp = QDateTime::fromMSecsSinceEpoch(timeStamp); - } else { + } + else { quint32 timeStamp; in >> timeStamp; msg._timestamp = QDateTime::fromTime_t(timeStamp); @@ -113,6 +137,15 @@ QDataStream &operator>>(QDataStream &in, Message &msg) in >> senderPrefixes; msg._senderPrefixes = QString::fromUtf8(senderPrefixes); + QByteArray realName; + QByteArray avatarUrl; + if (SignalProxy::current()->sourcePeer()->hasFeature(Quassel::Feature::RichMessages)) { + in >> realName; + in >> avatarUrl; + } + msg._realName = QString::fromUtf8(realName); + msg._avatarUrl = QString::fromUtf8(avatarUrl); + QByteArray contents; in >> contents; msg._contents = QString::fromUtf8(contents); @@ -120,13 +153,16 @@ QDataStream &operator>>(QDataStream &in, Message &msg) return in; } - -QDebug operator<<(QDebug dbg, const Message &msg) +QDebug operator<<(QDebug dbg, const Message& msg) { dbg.nospace() << qPrintable(QString("Message(MsgId:")) << msg.msgId() - << qPrintable(QString(",")) << msg.timestamp() - << qPrintable(QString(", Type:")) << msg.type() - << qPrintable(QString(", Flags:")) << msg.flags() << qPrintable(QString(")")) - << msg.sender() << ":" << msg.contents(); + << qPrintable(QString(",")) << msg.timestamp() + << qPrintable(QString(", Type:")) << msg.type() + << qPrintable(QString(", RealName:")) << msg.realName() + << qPrintable(QString(", AvatarURL:")) << msg.avatarUrl() + << qPrintable(QString(", Flags:")) << msg.flags() + << qPrintable(QString(")")) + << msg.senderPrefixes() << msg.sender() << ":" + << msg.contents(); return dbg; }