Collin Kidder
ee287eac4b
library that I was able to integrate into the codebase so there aren't any external dependencies. Both external projects have their own open source licenses. Those licenses are included. Also in this commit is some preliminary work to start adding MQTT support to SavvyCAN.
49 lines
1.2 KiB
C++
49 lines
1.2 KiB
C++
#ifdef QT_WEBSOCKETS_LIB
|
|
|
|
#include "qmqtt_websocketiodevice_p.h"
|
|
|
|
#include <QWebSocket>
|
|
|
|
QMQTT::WebSocketIODevice::WebSocketIODevice(QWebSocket *socket, QObject *parent)
|
|
: QIODevice(parent)
|
|
, _webSocket(socket)
|
|
{
|
|
connect(_webSocket, &QWebSocket::bytesWritten, this, &WebSocketIODevice::bytesWritten);
|
|
connect(_webSocket, &QWebSocket::binaryMessageReceived,
|
|
this, &WebSocketIODevice::binaryMessageReceived);
|
|
}
|
|
|
|
bool QMQTT::WebSocketIODevice::connectToHost(const QNetworkRequest &request)
|
|
{
|
|
_webSocket->open(request);
|
|
return QIODevice::open(QIODevice::ReadWrite);
|
|
}
|
|
|
|
qint64 QMQTT::WebSocketIODevice::bytesAvailable() const
|
|
{
|
|
return _buffer.count();
|
|
}
|
|
|
|
void QMQTT::WebSocketIODevice::binaryMessageReceived(const QByteArray &frame)
|
|
{
|
|
_buffer.append(frame);
|
|
emit readyRead();
|
|
}
|
|
|
|
qint64 QMQTT::WebSocketIODevice::readData(char *data, qint64 maxSize)
|
|
{
|
|
int size = qMin(static_cast<int>(maxSize), _buffer.count());
|
|
for (int i=0; i<size; ++ i)
|
|
data[i] = _buffer[i];
|
|
_buffer.remove(0, size);
|
|
return size;
|
|
}
|
|
|
|
qint64 QMQTT::WebSocketIODevice::writeData(const char *data, qint64 maxSize)
|
|
{
|
|
QByteArray d(data, static_cast<int>(maxSize));
|
|
return _webSocket->sendBinaryMessage(d);
|
|
}
|
|
|
|
#endif // QT_WEBSOCKETS_LIB
|