-
Notifications
You must be signed in to change notification settings - Fork 0
/
chess24messageparser.cpp
134 lines (109 loc) · 3.5 KB
/
chess24messageparser.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
#include "chess24messageparser.h"
#include <QString>
#include <QtDebug>
#include "chess24messages.h"
#include <QJsonDocument>
#include <QJsonArray>
using namespace Chess24Messages::Helpers;
Chess24MessageParser::Chess24MessageParser(QObject *parent, Chess24SqlHandler &sqlHandler):
QObject(parent),
sqlHandler(sqlHandler)
{
}
void Chess24MessageParser::parseEvent(const QString &model,const QJsonObject &root){
if(model.startsWith("webTournamentRedisAR:")){
QString tournament = model.mid(model.indexOf(":")+1);
if(!root.keys().contains("args")){
qDebug() << "Event does not contain args";
return;
}
QJsonArray argsWrapper = root.value("args").toArray();
QVariantMap map = argsWrapper.at(0).toObject().toVariantMap();
if(map.keys().contains("diffs")){
QVariantMap transform = Chess24Messages::transformWebTournament(map.value("diffs").toMap());
QVariantMap changes = sqlHandler.updateTournament(tournament,transform,true);
emit tournamentMatchUpdates(changes.value("TournamentPk").toInt(),changes.value("match").toMap(),changes.value("matchPks").toMap());
}
}
else{
qDebug() << "Unknown model name";
}
}
void Chess24MessageParser::parseMessage(QString msg)
{
QString header = getHeader(msg);
QStringList parts = header.split(":");
bool ok;
int msgType = parts[0].toInt(&ok);
if(!ok){
qDebug() << "Error in parsing websocket msg: ";
return;
}
auto type = static_cast<MessageType>(msgType);
switch(type){
case(MessageType::disconnect):
emit messageParsed(Message(type));
break;
case(MessageType::connect):
{
emit messageParsed(Message(type));
return;
}
case(MessageType::heartbeat):
{
Message m(type);
m.data = msg;
emit messageParsed(m);
}
return;
case(MessageType::message):
emit messageParsed(Message(type));
return;
case(MessageType::json):
emit messageParsed(Message(type));
return;
case(MessageType::event):
{
QString data = getData(msg);
QJsonDocument doc = QJsonDocument::fromJson(data.toUtf8());
QJsonObject root = doc.object();
if(!root.keys().contains("name")){
qDebug() << "Event does not contain name";
return;
}
QString name = root.value("name").toString();
if(!name.startsWith("model:")){
qDebug() << "Unknown event name";
qDebug() << data;
return;
}
QString model = name.mid(6);
parseEvent(model,root);
return;
}
case(MessageType::ack):
{
//Id to the left of "+" and data to the right
QString data = getData(msg);
int ipluss = data.indexOf("+");
if(ipluss<0){return;}
QString before = data.mid(0,ipluss);
bool ok = false;
int id = before.toInt(&ok);//Get the msg id
if(!ok){return;}
//QString json = data.mid(ipluss+1,data.size()-ipluss+1);
QString json = data.mid(ipluss+1);//From + to eol
Message m(type);
m.data = json;
m.id = id;
emit messageParsed(m);
return;
}
case(MessageType::error):
emit messageParsed(Message(type));
return;
case(MessageType::noop):
emit messageParsed(Message(type));
return;
}
}