GPSLogger/myserver.cpp at main · kbarni/GPSLogger · 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
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
#include "myserver.h"

#include <QDebug>

//#define FUTURES
#ifdef FUTURES
#include <QtConcurrent/QtConcurrent>
#endif

MyServer::MyServer(QString servername, int port, QObject *parent) : QObject(parent)
{
    wsServer = new QWebSocketServer(servername,QWebSocketServer::NonSecureMode);
    opened=false;
    if (!wsServer->listen(QHostAddress::Any, port)) {
        qDebug()<<"MyServer: Unable to start the server:"<<wsServer->errorString();
        return;
    }
    port=wsServer->serverPort();
    connect(wsServer, SIGNAL(newConnection()), this, SLOT(newConnection()));
    opened=true;
    imagecounter=0;
    sending=false;
}

MyServer::~MyServer()
{
    if(opened)
        Close();
    delete wsServer;
}

void MyServer::Close()
{
    qDebug()<<"Closing server";
    wsServer->close();
    qDeleteAll(m_clients.begin(), m_clients.end());
    opened = false;
}
void MyServer::newConnection()
{
    QWebSocket *pSocket = wsServer->nextPendingConnection();

    connect(pSocket, &QWebSocket::textMessageReceived, this, &MyServer::readyRead);
    connect(pSocket, &QWebSocket::disconnected, this, &MyServer::clientLeft);

    m_clients << pSocket;
    emit clientConnected();
}


bool MyServer::isServerListening(){return opened;}

void MyServer::clientLeft()
{
    QWebSocket *pClient = qobject_cast<QWebSocket *>(sender());
    qDebug() << "socketDisconnected:" << pClient;
    if (pClient) {
        pClient->disconnect();
        m_clients.removeAll(pClient);
        pClient->deleteLater();
    }
}

void MyServer::readyRead(QString message)
{
    qDebug()<<"Message received: "<<message;
    emit gotMessage(message);
}

bool MyServer::sendMessage(QString msg)
{
    if(m_clients.size()==0)return false;
    for(auto client : m_clients){
#ifdef FUTURES
        QFuture<qint64> future = QtConcurrent::run(client,&QWebSocket::sendTextMessage,msg);
        future.waitForFinished();
#else
        client->sendTextMessage(msg);
#endif
    }
    qDebug()<<"Sending: "+msg;
    return true;
}

bool MyServer::sendMessage(QString cmd, QString param)
{
    return sendMessage(cmd+" "+param);
}

void MyServer::sendImage(QByteArray ba)
{
    for(auto client : m_clients)
        client->sendBinaryMessage(ba);
}