webSocketChat/websocket.cpp at master · DanilAe/webSocketChat · GitHub

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
#include "websocket.h"

webSocket::webSocket(const QUrl url, QObject *parent) : QObject(parent)
{
	webSock = new QWebSocket();
	connect(webSock, SIGNAL(connected()), this, SLOT(onConnected()));
	connect(webSock, SIGNAL(disconnected()), this, SLOT(onDisconnected()));
	connect(webSock, SIGNAL(textMessageReceived(QString)), this, SLOT(onReadyRead(QString)));
	webSock->open(url);
	m_url = url;
}

void webSocket::onConnected()
{
	qDebug() << "Connected!";
	Isconnected = true;
	emit this->connected();
}

void webSocket::onDisconnected()
{
	qDebug() << "Disconnected!";
	Isconnected = false;
	emit this->disconnected();
}

void webSocket::loginIn(QString userName)
{
	QJsonDocument doc;
	QJsonObject root;
	root.insert("type", "login");
	root.insert("username", userName);
	doc.setObject(root);
	webSock->sendTextMessage(doc.toJson(QJsonDocument::Compact));
	this->m_usrName = userName;
}

void webSocket::sendMessage(QString message)
{
	QJsonDocument doc;
	QJsonObject root;
	root.insert("type", "message");
	root.insert("message", message);
	doc.setObject(root);
	webSock->sendTextMessage(doc.toJson(QJsonDocument::Compact));
}

void webSocket::onReadyRead(QString data)
{
	qDebug() << "Readed: " << data.toStdString().c_str();
	QJsonDocument doc = QJsonDocument::fromJson(QByteArray().append(data));
	if(doc.object().value("type") == "login")
		emit this->onLogined(doc.object().value("body").toObject().value("result").toBool());
	else if(doc.object().value("type") == "messages")
		emit this->onNewMessage(doc);
}