X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fmessage.cpp;h=8cf74d2ce6f2c7bc5e14ff00457f8f0e545bc7ed;hp=911c93539f2c093e111e744ebe9547d65eaa3b89;hb=3a3e844f9fcfd12235a0086af75ecd503b621ef4;hpb=f353beded3963b67da6ac0878700dee8e61abfc4 diff --git a/src/common/message.cpp b/src/common/message.cpp index 911c9353..8cf74d2c 100644 --- a/src/common/message.cpp +++ b/src/common/message.cpp @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2016 by the Quassel Project * + * Copyright (C) 2005-2018 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -25,25 +25,33 @@ #include "signalproxy.h" #include +#include -Message::Message(const BufferInfo &bufferInfo, Type type, const QString &contents, const QString &sender, const QString &senderPrefixes, Flags flags) +Message::Message(BufferInfo bufferInfo, Type type, QString contents, QString sender, + QString senderPrefixes, QString realName, QString avatarUrl, Flags flags) : _timestamp(QDateTime::currentDateTime().toUTC()), - _bufferInfo(bufferInfo), - _contents(contents), - _sender(sender), - _senderPrefixes(senderPrefixes), + _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(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), +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) { @@ -52,17 +60,32 @@ Message::Message(const QDateTime &ts, const BufferInfo &bufferInfo, Type type, c QDataStream &operator<<(QDataStream &out, const Message &msg) { + Q_ASSERT(SignalProxy::current()); + Q_ASSERT(SignalProxy::current()->targetPeer()); + // We do not serialize the sender prefixes until we have a new protocol or client-features implemented - out << msg.msgId() - << (quint32) msg.timestamp().toTime_t() - << (quint32) msg.type() + out << msg.msgId(); + + 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(); + } + + out << (quint32) msg.type() << (quint8) msg.flags() << msg.bufferInfo() << msg.sender().toUtf8(); - if (SignalProxy::current()->targetPeer()->features().testFlag(Quassel::Feature::SenderPrefixes)) + 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; } @@ -70,11 +93,21 @@ QDataStream &operator<<(QDataStream &out, const Message &msg) QDataStream &operator>>(QDataStream &in, Message &msg) { + Q_ASSERT(SignalProxy::current()); + Q_ASSERT(SignalProxy::current()->sourcePeer()); + in >> msg._msgId; - quint32 timeStamp; - in >> timeStamp; - msg._timestamp = QDateTime::fromTime_t(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 { + quint32 timeStamp; + in >> timeStamp; + msg._timestamp = QDateTime::fromTime_t(timeStamp); + } quint32 type; in >> type; @@ -91,10 +124,19 @@ QDataStream &operator>>(QDataStream &in, Message &msg) msg._sender = QString::fromUtf8(sender); QByteArray senderPrefixes; - if (SignalProxy::current()->sourcePeer()->features().testFlag(Quassel::Feature::SenderPrefixes)) + if (SignalProxy::current()->sourcePeer()->hasFeature(Quassel::Feature::SenderPrefixes)) 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); @@ -108,7 +150,9 @@ 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(", RealName:")) << msg.realName() + << qPrintable(QString(", AvatarURL:")) << msg.avatarUrl() << qPrintable(QString(", Flags:")) << msg.flags() << qPrintable(QString(")")) - << msg.sender() << ":" << msg.contents(); + << msg.senderPrefixes() << msg.sender() << ":" << msg.contents(); return dbg; }