chris/js8call
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed network messages to include an id so they are both 1) indexable and 2) do not cache in the network buffer

Browse Source
This commit is contained in:
Jordan Sherer 2019-01-03 13:32:37 -05:00
parent 68c15aa83e
commit 489d5c7c1c
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
Message.cpp
View File

@ -19,6 +19,18 @@
**/ **/
#include "Message.h" #include "Message.h"
#include "DriftingDateTime.h"
const quint32 EPOCH = 1499299200000; // July 6, 2017
#if USE_SNOWFLAKE
quint64 snowflake(quint64 epoch, quint16 machine, quint16 sequence){
quint64 value = (DriftingDateTime::currentMSecsSinceEpoch() - epoch) << 22;
value |= machine & 0x3FF << 12;
value |= sequence & 0xFFF;
return value;
}
#endif
Message::Message() Message::Message()
{ {
@ -28,6 +40,7 @@ Message::Message(QString const &type, QString const &value):
type_{ type }, type_{ type },
value_{ value } value_{ value }
{ {
params_["_ID"] = QString::number(DriftingDateTime::currentMSecsSinceEpoch()-EPOCH);
} }
Message::Message(QString const &type, QString const &value, QMap<QString, QVariant> const &params): Message::Message(QString const &type, QString const &value, QMap<QString, QVariant> const &params):
@ -35,6 +48,7 @@ Message::Message(QString const &type, QString const &value, QMap<QString, QVari
value_{ value }, value_{ value },
params_{ params } params_{ params }
{ {
params_["_ID"] = QString::number(DriftingDateTime::currentMSecsSinceEpoch()-EPOCH);
} }
void Message::read(const QJsonObject &json){ void Message::read(const QJsonObject &json){