protocol: Implement 64-bit message timestamps
[quassel.git] / src / common / message.cpp
1 /***************************************************************************
2  *   Copyright (C) 2005-2018 by the Quassel Project                        *
3  *   devel@quassel-irc.org                                                 *
4  *                                                                         *
5  *   This program is free software; you can redistribute it and/or modify  *
6  *   it under the terms of the GNU General Public License as published by  *
7  *   the Free Software Foundation; either version 2 of the License, or     *
8  *   (at your option) version 3.                                           *
9  *                                                                         *
10  *   This program is distributed in the hope that it will be useful,       *
11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
12  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
13  *   GNU General Public License for more details.                          *
14  *                                                                         *
15  *   You should have received a copy of the GNU General Public License     *
16  *   along with this program; if not, write to the                         *
17  *   Free Software Foundation, Inc.,                                       *
18  *   51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.         *
19  ***************************************************************************/
20
21 #include "message.h"
22
23 #include "util.h"
24 #include "peer.h"
25 #include "signalproxy.h"
26
27 #include <QDataStream>
28
29 Message::Message(const BufferInfo &bufferInfo, Type type, const QString &contents, const QString &sender, const QString &senderPrefixes, Flags flags)
30     : _timestamp(QDateTime::currentDateTime().toUTC()),
31     _bufferInfo(bufferInfo),
32     _contents(contents),
33     _sender(sender),
34     _senderPrefixes(senderPrefixes),
35     _type(type),
36     _flags(flags)
37 {
38 }
39
40
41 Message::Message(const QDateTime &ts, const BufferInfo &bufferInfo, Type type, const QString &contents, const QString &sender, const QString &senderPrefixes, Flags flags)
42     : _timestamp(ts),
43     _bufferInfo(bufferInfo),
44     _contents(contents),
45     _sender(sender),
46     _senderPrefixes(senderPrefixes),
47     _type(type),
48     _flags(flags)
49 {
50 }
51
52
53 QDataStream &operator<<(QDataStream &out, const Message &msg)
54 {
55     Q_ASSERT(SignalProxy::current());
56     Q_ASSERT(SignalProxy::current()->targetPeer());
57
58     // We do not serialize the sender prefixes until we have a new protocol or client-features implemented
59     out << msg.msgId();
60
61     if (SignalProxy::current()->targetPeer()->hasFeature(Quassel::Feature::LongMessageTime)) {
62         out << (quint64) msg.timestamp().toMSecsSinceEpoch();
63     } else {
64         out << (quint32) msg.timestamp().toTime_t();
65     }
66
67     out << (quint32) msg.type()
68         << (quint8) msg.flags()
69         << msg.bufferInfo()
70         << msg.sender().toUtf8();
71
72     if (SignalProxy::current()->targetPeer()->hasFeature(Quassel::Feature::SenderPrefixes))
73         out << msg.senderPrefixes().toUtf8();
74
75     out << msg.contents().toUtf8();
76     return out;
77 }
78
79
80 QDataStream &operator>>(QDataStream &in, Message &msg)
81 {
82     Q_ASSERT(SignalProxy::current());
83     Q_ASSERT(SignalProxy::current()->sourcePeer());
84
85     in >> msg._msgId;
86
87     if (SignalProxy::current()->sourcePeer()->hasFeature(Quassel::Feature::LongMessageTime)) {
88         quint64 timeStamp;
89         in >> timeStamp;
90         msg._timestamp = QDateTime::fromMSecsSinceEpoch(timeStamp);
91     } else {
92         quint32 timeStamp;
93         in >> timeStamp;
94         msg._timestamp = QDateTime::fromTime_t(timeStamp);
95     }
96
97     quint32 type;
98     in >> type;
99     msg._type = Message::Type(type);
100
101     quint8 flags;
102     in >> flags;
103     msg._flags = Message::Flags(flags);
104
105     in >> msg._bufferInfo;
106
107     QByteArray sender;
108     in >> sender;
109     msg._sender = QString::fromUtf8(sender);
110
111     QByteArray senderPrefixes;
112     if (SignalProxy::current()->sourcePeer()->hasFeature(Quassel::Feature::SenderPrefixes))
113         in >> senderPrefixes;
114     msg._senderPrefixes = QString::fromUtf8(senderPrefixes);
115
116     QByteArray contents;
117     in >> contents;
118     msg._contents = QString::fromUtf8(contents);
119
120     return in;
121 }
122
123
124 QDebug operator<<(QDebug dbg, const Message &msg)
125 {
126     dbg.nospace() << qPrintable(QString("Message(MsgId:")) << msg.msgId()
127     << qPrintable(QString(",")) << msg.timestamp()
128     << qPrintable(QString(", Type:")) << msg.type()
129     << qPrintable(QString(", Flags:")) << msg.flags() << qPrintable(QString(")"))
130     << msg.sender() << ":" << msg.contents();
131     return dbg;
132 }