SkCore: Create WBroadcastClient

dist/changes/1.9.0.md

@@ -54,6 +54,8 @@
 
 - Create WBroadcastServer.
 
+- Create WBroadcastClient.
+
 - Sk: Add the W_FOREACH macro.
 
 - WControllerApplication: Add the 'getLine' function.

include/SkCore/WBroadcastClient

@@ -0,0 +1 @@
+#include "../../src/SkCore/src/network/WBroadcastClient.h"

include/SkCore/WBroadcastClient.h

@@ -0,0 +1 @@
+#include "../../src/SkCore/src/network/WBroadcastClient.h"

include/SkCore/private/WBroadcastClient_p

@@ -0,0 +1 @@
+#include "../../../src/SkCore/src/network/WBroadcastClient_p.h"

include/SkCore/private/WBroadcastClient_p.h

@@ -0,0 +1 @@
+#include "../../../src/SkCore/src/network/WBroadcastClient_p.h"

src/SkCore/src/io/WCache.cpp

@@ -450,7 +450,7 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 {
     QEvent::Type type = event->type();
 
-    if (type == static_cast<QEvent::Type> (WCacheThread::EventGet))
+    if (type == static_cast<QEvent::Type> (EventGet))
     {
         WCacheThreadEventFile * eventFile = static_cast<WCacheThreadEventFile *> (event);
 
@@ -475,7 +475,7 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventAdd))
+    else if (type == static_cast<QEvent::Type> (EventAdd))
     {
         WCacheThreadEventFile * eventFile = static_cast<WCacheThreadEventFile *> (event);
 
@@ -495,15 +495,15 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventWrite))
+    else if (type == static_cast<QEvent::Type> (EventWrite))
     {
         WCacheThreadEventWrite * eventWrite = static_cast<WCacheThreadEventWrite *> (event);
 
         writeData(eventWrite->url, eventWrite->extension, eventWrite->array);
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventAbort))
+    else if (type == static_cast<QEvent::Type> (EventAbort))
     {
         WCacheThreadEvent * eventCache = static_cast<WCacheThreadEvent *> (event);
 
@@ -548,7 +548,7 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventPop))
+    else if (type == static_cast<QEvent::Type> (EventPop))
     {
         WCacheThreadEventUrls * eventUrls = static_cast<WCacheThreadEventUrls *> (event);
 
@@ -566,7 +566,7 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventRemove))
+    else if (type == static_cast<QEvent::Type> (EventRemove))
     {
         WCacheThreadEventUrls * eventUrls = static_cast<WCacheThreadEventUrls *> (event);
 
@@ -601,7 +601,7 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventRemoveFile))
+    else if (type == static_cast<QEvent::Type> (EventRemoveFile))
     {
         WCacheThreadEventUrls * eventUrls = static_cast<WCacheThreadEventUrls *> (event);
 
@@ -614,7 +614,7 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventProxy))
+    else if (type == static_cast<QEvent::Type> (EventProxy))
     {
         WCacheThreadEventProxy * eventProxy = static_cast<WCacheThreadEventProxy *> (event);
 
@@ -625,13 +625,13 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventClearProxy))
+    else if (type == static_cast<QEvent::Type> (EventClearProxy))
     {
         manager->setProxy(QNetworkProxy());
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventSizeMax))
+    else if (type == static_cast<QEvent::Type> (EventSizeMax))
     {
         WCacheThreadEvent * eventCache = static_cast<WCacheThreadEvent *> (event);
 
@@ -641,15 +641,15 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventMaxJobs))
+    else if (type == static_cast<QEvent::Type> (EventMaxJobs))
     {
         WCacheThreadEvent * eventCache = static_cast<WCacheThreadEvent *> (event);
 
         maxJobs = eventCache->value.toInt();
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventClearDatas))
+    else if (type == static_cast<QEvent::Type> (EventClearDatas))
     {
         timer->stop();
 
@@ -667,7 +667,7 @@ WCacheThread::WCacheThread(WCache * cache, const QString & path, qint64 sizeMax)
 
         return true;
     }
-    else if (type == static_cast<QEvent::Type> (WCacheThread::EventClearAll))
+    else if (type == static_cast<QEvent::Type> (EventClearAll))
     {
         timer->stop();
 

src/SkCore/src/network/WBroadcastClient.cpp

@@ -0,0 +1,247 @@
+//=================================================================================================
+/*
+    Copyright (C) 2015-2020 Sky kit authors. <http://omega.gg/Sky>
+
+    Author: Benjamin Arnaud. <http://bunjee.me> <[email protected]>
+
+    This file is part of SkCore.
+
+    - GNU Lesser General Public License Usage:
+    This file may be used under the terms of the GNU Lesser General Public License version 3 as
+    published by the Free Software Foundation and appearing in the LICENSE.md file included in the
+    packaging of this file. Please review the following information to ensure the GNU Lesser
+    General Public License requirements will be met: https://www.gnu.org/licenses/lgpl.html.
+
+    - Private License Usage:
+    Sky kit licensees holding valid private licenses may use this file in accordance with the
+    private license agreement provided with the Software or, alternatively, in accordance with the
+    terms contained in written agreement between you and Sky kit authors. For further information
+    contact us at [email protected].
+*/
+//=================================================================================================
+
+#include "WBroadcastClient.h"
+
+#ifndef SK_NO_BROADCASTCLIENT
+
+// Qt includes
+#include <QCoreApplication>
+#include <QThread>
+#include <QEvent>
+#include <QTcpSocket>
+#include <QHostInfo>
+
+//=================================================================================================
+// WBroadcastClientThread
+//=================================================================================================
+
+class WBroadcastClientThread : public QThread
+{
+    Q_OBJECT
+
+public: // Enums
+    enum EventType
+    {
+        EventConnect = QEvent::User,
+        EventDisconnect
+    };
+
+public:
+    WBroadcastClientThread();
+
+protected: // QThread reimplementation
+    /* virtual */ void run();
+
+protected: // Events
+    /* virtual */ bool event(QEvent * event);
+
+private: // Functions
+    void clearSocket();
+
+private slots:
+    void onConnected   ();
+    void onDisconnected();
+
+    void onRead();
+
+private:
+    QTcpSocket * socket;
+};
+
+//=================================================================================================
+// WBroadcastClientConnect
+//=================================================================================================
+
+class WBroadcastClientConnect : public QEvent
+{
+public:
+    WBroadcastClientConnect(const QString & address, int port)
+        : QEvent(static_cast<QEvent::Type> (WBroadcastClientThread::EventConnect))
+    {
+        this->address = address;
+        this->port    = port;
+    }
+
+public: // Variables
+    QString address;
+    int     port;
+};
+
+//=================================================================================================
+// WBroadcastClientThread
+//=================================================================================================
+
+WBroadcastClientThread::WBroadcastClientThread()
+{
+    socket = NULL;
+
+    moveToThread(this);
+
+    start(QThread::IdlePriority);
+}
+
+//-------------------------------------------------------------------------------------------------
+// Protected QThread reimplementation
+//-------------------------------------------------------------------------------------------------
+
+/* virtual */ void WBroadcastClientThread::run()
+{
+    exec();
+}
+
+//-------------------------------------------------------------------------------------------------
+// Events
+//-------------------------------------------------------------------------------------------------
+
+/* virtual */ bool WBroadcastClientThread::event(QEvent * event)
+{
+    QEvent::Type type = event->type();
+
+    if (type == static_cast<QEvent::Type> (EventConnect))
+    {
+        WBroadcastClientConnect * eventConnect = static_cast<WBroadcastClientConnect *> (event);
+
+        QString address = eventConnect->address;
+        int     port    = eventConnect->port;
+
+        qDebug("WBroadcastClientThread: Connecting [%s] on port %d...",
+               address.toLatin1().constData(), port);
+
+        if (socket) clearSocket();
+
+        socket = new QTcpSocket(this);
+
+        socket->connectToHost(QHostAddress(address), port);
+
+        connect(socket, SIGNAL(connected   ()), this, SLOT(onConnected   ()));
+        connect(socket, SIGNAL(disconnected()), this, SLOT(onDisconnected()));
+
+        connect(socket, SIGNAL(readyRead()), this, SLOT(onRead()));
+
+        return true;
+    }
+    else if (type == static_cast<QEvent::Type> (EventDisconnect))
+    {
+        qDebug("WBroadcastClientThread: Disconnecting...");
+
+        return true;
+    }
+    else return QThread::event(event);
+}
+
+//-------------------------------------------------------------------------------------------------
+// Private slots
+//-------------------------------------------------------------------------------------------------
+
+void WBroadcastClientThread::onConnected()
+{
+
+}
+
+void WBroadcastClientThread::onDisconnected()
+{
+    qDebug("WBroadcastClientThread: Disconnected.");
+
+    if (socket == NULL) return;
+
+    disconnect(socket, 0, this, 0);
+
+    socket->deleteLater();
+
+    socket = NULL;
+}
+
+void WBroadcastClientThread::onRead()
+{
+
+}
+
+//-------------------------------------------------------------------------------------------------
+// Private functions
+//-------------------------------------------------------------------------------------------------
+
+void WBroadcastClientThread::clearSocket()
+{
+    // NOTE: We need to disconnect to avoid receiving a disconnect signal upon deletion.
+    disconnect(socket, 0, this, 0);
+
+    delete socket;
+
+    socket = NULL;
+}
+
+//=================================================================================================
+// WBroadcastClientPrivate
+//=================================================================================================
+
+#include "WBroadcastClient_p.h"
+
+WBroadcastClientPrivate::WBroadcastClientPrivate(WBroadcastClient * p) : WPrivate(p) {}
+
+/* virtual */ WBroadcastClientPrivate::~WBroadcastClientPrivate()
+{
+    thread->quit();
+    thread->wait();
+
+    delete thread;
+}
+
+//-------------------------------------------------------------------------------------------------
+
+void WBroadcastClientPrivate::init()
+{
+    thread = new WBroadcastClientThread();
+}
+
+//=================================================================================================
+// WBroadcastClient
+//=================================================================================================
+
+/* explicit */ WBroadcastClient::WBroadcastClient(QObject * parent)
+    : QObject(parent), WPrivatable(new WBroadcastClientPrivate(this))
+{
+    Q_D(WBroadcastClient); d->init();
+}
+
+//-------------------------------------------------------------------------------------------------
+// Interface
+//-------------------------------------------------------------------------------------------------
+
+/* Q_INVOKABLE */ void WBroadcastClient::connectHost(const QString & address, int port)
+{
+    Q_D(WBroadcastClient);
+
+    QCoreApplication::postEvent(d->thread, new WBroadcastClientConnect(address, port));
+}
+
+/* Q_INVOKABLE */ void WBroadcastClient::disconnectHost()
+{
+    Q_D(WBroadcastClient);
+
+    QCoreApplication::postEvent(d->thread, new QEvent(static_cast<QEvent::Type>
+                                                      (WBroadcastClientThread::EventDisconnect)));
+}
+
+#endif // SK_NO_BROADCASTCLIENT
+
+#include "WBroadcastClient.moc"