diff options
author | Loïc Collignon <loic.collignon@iot.bzh> | 2018-04-17 15:27:14 +0200 |
---|---|---|
committer | Loïc Collignon <loic.collignon@iot.bzh> | 2018-04-18 10:49:33 +0200 |
commit | 41ac48501b9070c6ca31fee324218dfd8e05466d (patch) | |
tree | 90702362d6fcb2dd3cfa3eed834c3b4000aad971 /qafbwebsocketclient.h | |
parent | 523bcf9c0b44214130ef619bda4bd1be50abfbcf (diff) |
Added a Qt's websocket client to AFB into helpers
This add a single Qt class to serve as a client
to Application Framework Binder.
It's optional, not enabled by default.
To enable you have to set AFB_HELPERS_QTWSCLIENT
to ON.
Change-Id: Ia0759a95688e48183e6661082693c410a575b14b
Signed-off-by: Loïc Collignon <loic.collignon@iot.bzh>
Diffstat (limited to 'qafbwebsocketclient.h')
-rw-r--r-- | qafbwebsocketclient.h | 69 |
1 files changed, 69 insertions, 0 deletions
diff --git a/qafbwebsocketclient.h b/qafbwebsocketclient.h new file mode 100644 index 0000000..71e719d --- /dev/null +++ b/qafbwebsocketclient.h @@ -0,0 +1,69 @@ +/* + * Copyright (C) 2018 Iot.Bzh + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef QAFBWEBSOCKETCLIENT_H +#define QAFBWEBSOCKETCLIENT_H + +#include <QObject> +#include <QWebSocket> +#include <QJsonValue> +#include <functional> + +/*! + * \brief A WebSocket client to an Application Framework Binder. + */ +class QAfbWebsocketClient + : public QObject +{ + Q_OBJECT + +public: + using closure_t = std::function<void(bool, const QJsonValue&)>; + + explicit QAfbWebsocketClient(QObject* parent = nullptr); + + QAbstractSocket::SocketError error() const; + QString errorString() const; + bool isValid() const; + + void call(const QString& api, const QString& verb, const QJsonValue& arg = QJsonValue(), closure_t closure = nullptr); + +public slots: + void open(const QUrl& u); + void close(); + void sendTextMessage(QString msg); + +private slots: + void onSocketConnected(); + void onSocketDisconnected(); + void onSocketError(QAbstractSocket::SocketError e); + void onSocketTextReceived(QString msg); + +signals: + void connected(); + void disconnected(); + void error(QAbstractSocket::SocketError); + void textReceived(QString msg); + void textSent(QString msg); + void event(QString eventName, const QJsonValue& data); + +private: + int m_nextCallId; + QWebSocket m_socket; + QMap<QString, closure_t> m_closures; +}; + +#endif // QAFBWEBSOCKETCLIENT_H |