-
Notifications
You must be signed in to change notification settings - Fork 13
/
qchatupdateserver.cpp
65 lines (54 loc) · 1.65 KB
/
qchatupdateserver.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
#include <QWebSocketServer>
#include <QWebSocket>
#include "qchatupdateserver.h"
QChatUpdateServer::QChatUpdateServer( unsigned short port, QObject *parent )
: QObject( parent )
, server_( new QWebSocketServer( "BroChat Update Server", QWebSocketServer::NonSecureMode, this ) )
, clientsList_()
{
if( server_->listen( QHostAddress::Any, port ) )
{
qDebug() << "BroChat Update Server listening on port" << port;
connect( server_, SIGNAL( newConnection() ), this, SLOT( onNewConnection() ) );
}
}
QChatUpdateServer::~QChatUpdateServer()
{
server_->close();
}
void QChatUpdateServer::onNewConnection()
{
QWebSocket *socket = server_->nextPendingConnection();
//connect( socket, SIGNAL( textMessageReceived( const QString& ) ), this, SLOT( onTextMessageRecieved( const QString & ) ) );
connect( socket, SIGNAL( disconnected() ), this, SLOT( onSocketDisconnected() ) );
clientsList_ << socket;
}
/*
void QChatUpdateServer::onTextMessageRecieved( const QString& message )
{
}
*/
void QChatUpdateServer::onSocketDisconnected()
{
QWebSocket *socket = qobject_cast< QWebSocket * >( sender() );
if( socket )
{
clientsList_.removeAll( socket );
socket->deleteLater();
qDebug() << "websocket removed";
}
}
void QChatUpdateServer::sendMessage( const QString& message )
{
foreach( QWebSocket *socket, clientsList_ )
{
if( socket && socket->state() == QAbstractSocket::ConnectedState )
{
socket->sendTextMessage( message );
}
}
}
void QChatUpdateServer::close()
{
server_->close();
}