X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fmessage.cpp;h=8cf74d2ce6f2c7bc5e14ff00457f8f0e545bc7ed;hp=9875473a57b0db60910da53cad1ce20e92858375;hb=8582c2ad5708a1972c85bea1cf8d81ad3ece4814;hpb=2ee32e7f7707349d12c98181bbe6842f6d19f60e diff --git a/src/common/message.cpp b/src/common/message.cpp index 9875473a..8cf74d2c 100644 --- a/src/common/message.cpp +++ b/src/common/message.cpp @@ -1,11 +1,11 @@ /*************************************************************************** - * Copyright (C) 2005/06 by The Quassel Team * + * Copyright (C) 2005-2018 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * * it under the terms of the GNU General Public License as published by * * the Free Software Foundation; either version 2 of the License, or * - * (at your option) any later version. * + * (at your option) version 3. * * * * This program is distributed in the hope that it will be useful, * * but WITHOUT ANY WARRANTY; without even the implied warranty of * @@ -15,73 +15,144 @@ * 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 "message.h" -#include -Message::Message(BufferId __buffer, Type __type, QString __text, QString __sender, quint8 __flags) - : _buffer(__buffer), _text(__text), _sender(__sender), _type(__type), _flags(__flags) { - _timeStamp = QDateTime::currentDateTime().toUTC(); +#include "util.h" +#include "peer.h" +#include "signalproxy.h" + +#include +#include + +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, BufferId __buffer, Type __type, QString __text, QString __sender, quint8 __flags) - : _timeStamp(__ts), _buffer(__buffer), _text(__text), _sender(__sender), _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) +{ } -MsgId Message::msgId() const { - return _msgId; -} -void Message::setMsgId(MsgId _id) { - _msgId = _id; -} +QDataStream &operator<<(QDataStream &out, const Message &msg) +{ + Q_ASSERT(SignalProxy::current()); + Q_ASSERT(SignalProxy::current()->targetPeer()); -BufferId Message::buffer() const { - return _buffer; -} + // We do not serialize the sender prefixes until we have a new protocol or client-features implemented + out << msg.msgId(); -QString Message::text() const { - return _text; -} + 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(); + } -QString Message::sender() const { - return _sender; -} + out << (quint32) msg.type() + << (quint8) msg.flags() + << msg.bufferInfo() + << msg.sender().toUtf8(); -Message::Type Message::type() const { - return _type; -} + if (SignalProxy::current()->targetPeer()->hasFeature(Quassel::Feature::SenderPrefixes)) + out << msg.senderPrefixes().toUtf8(); -quint8 Message::flags() const { - return _flags; -} + if (SignalProxy::current()->targetPeer()->hasFeature(Quassel::Feature::RichMessages)) { + out << msg.realName().toUtf8(); + out << msg.avatarUrl().toUtf8(); + } -QDateTime Message::timeStamp() const { - return _timeStamp; + out << msg.contents().toUtf8(); + return out; } -QDataStream &operator<<(QDataStream &out, const Message &msg) { - out << (quint32)msg.timeStamp().toTime_t() << (quint8)msg.type() << (quint8)msg.flags() - << msg.buffer() << msg.sender().toUtf8() << msg.text().toUtf8(); - return out; +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::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; + msg._type = Message::Type(type); + + quint8 flags; + in >> flags; + msg._flags = Message::Flags(flags); + + in >> msg._bufferInfo; + + QByteArray sender; + in >> sender; + msg._sender = QString::fromUtf8(sender); + + QByteArray 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); + + return in; } -QDataStream &operator>>(QDataStream &in, Message &msg) { - quint8 t, f; - quint32 ts; - QByteArray s, m; - BufferId buf; - in >> ts >> t >> f >> buf >> s >> m; - msg._type = (Message::Type)t; - msg._flags = (quint8)f; - msg._buffer = buf; - msg._timeStamp = QDateTime::fromTime_t(ts); - msg._sender = QString::fromUtf8(s); - msg._text = QString::fromUtf8(m); - return in; -} +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.senderPrefixes() << msg.sender() << ":" << msg.contents(); + return dbg; +}