301 lines
12 KiB
C++
301 lines
12 KiB
C++
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
|
|
*
|
|
* Copyright 2013 - 2020, nymea GmbH
|
|
* Contact: contact@nymea.io
|
|
*
|
|
* This file is part of nymea.
|
|
* This project including source code and documentation is protected by
|
|
* copyright law, and remains the property of nymea GmbH. All rights, including
|
|
* reproduction, publication, editing and translation, are reserved. The use of
|
|
* this project is subject to the terms of a license agreement to be concluded
|
|
* with nymea GmbH in accordance with the terms of use of nymea GmbH, available
|
|
* under https://nymea.io/license
|
|
*
|
|
* GNU General Public License Usage
|
|
* Alternatively, this project may be redistributed and/or modified under the
|
|
* terms of the GNU General Public License as published by the Free Software
|
|
* Foundation, GNU version 3. This project is distributed in the hope that it
|
|
* will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty
|
|
* of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General
|
|
* Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License along with
|
|
* this project. If not, see <https://www.gnu.org/licenses/>.
|
|
*
|
|
* For any further details and any questions please contact us under
|
|
* contact@nymea.io or see our FAQ/Licensing Information on
|
|
* https://nymea.io/license/faq
|
|
*
|
|
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
|
|
|
#include "networkmanager.h"
|
|
#include "types/networkdevices.h"
|
|
#include "types/networkdevice.h"
|
|
#include "types/wirelessaccesspoint.h"
|
|
#include "types/wirelessaccesspoints.h"
|
|
|
|
#include "engine.h"
|
|
#include "jsonrpc/jsonrpcclient.h"
|
|
|
|
#include <QMetaEnum>
|
|
#include <QJsonDocument>
|
|
|
|
NetworkManager::NetworkManager(QObject *parent):
|
|
JsonHandler(parent),
|
|
m_wiredNetworkDevices(new WiredNetworkDevices(this)),
|
|
m_wirelessNetworkDevices(new WirelessNetworkDevices(this))
|
|
{
|
|
}
|
|
|
|
NetworkManager::~NetworkManager()
|
|
{
|
|
if (m_engine) {
|
|
m_engine->jsonRpcClient()->unregisterNotificationHandler(this);
|
|
}
|
|
}
|
|
|
|
void NetworkManager::setEngine(Engine *engine)
|
|
{
|
|
if (m_engine && m_engine != engine) {
|
|
// clean up
|
|
m_engine->jsonRpcClient()->unregisterNotificationHandler(this);
|
|
}
|
|
|
|
m_engine = engine;
|
|
emit engineChanged();
|
|
|
|
m_engine->jsonRpcClient()->registerNotificationHandler(this, "notificationReceived");
|
|
init();
|
|
|
|
connect(m_engine->jsonRpcClient(), &JsonRpcClient::connectedChanged, this, &NetworkManager::init);
|
|
}
|
|
|
|
Engine *NetworkManager::engine() const
|
|
{
|
|
return m_engine;
|
|
}
|
|
|
|
QString NetworkManager::nameSpace() const
|
|
{
|
|
return "NetworkManager";
|
|
}
|
|
|
|
void NetworkManager::init()
|
|
{
|
|
m_wiredNetworkDevices->clear();
|
|
m_wirelessNetworkDevices->clear();
|
|
|
|
if (!m_engine->jsonRpcClient()->connected()) {
|
|
// Not ready yet...
|
|
return;
|
|
}
|
|
|
|
m_engine->jsonRpcClient()->sendCommand("NetworkManager.GetNetworkStatus", QVariantMap(), this, "getStatusReply");
|
|
m_engine->jsonRpcClient()->sendCommand("NetworkManager.GetNetworkDevices", QVariantMap(), this, "getDevicesReply");
|
|
}
|
|
|
|
NetworkManager::NetworkManagerState NetworkManager::state() const
|
|
{
|
|
return m_state;
|
|
}
|
|
|
|
bool NetworkManager::networkingEnabled() const
|
|
{
|
|
return m_networkingEnabled;
|
|
}
|
|
|
|
bool NetworkManager::wirelessNetworkingEnabled() const
|
|
{
|
|
return m_wirelessNetworkingEnabled;
|
|
}
|
|
|
|
WiredNetworkDevices *NetworkManager::wiredNetworkDevices() const
|
|
{
|
|
return m_wiredNetworkDevices;
|
|
}
|
|
|
|
WirelessNetworkDevices *NetworkManager::wirelessNetworkDevices() const
|
|
{
|
|
return m_wirelessNetworkDevices;
|
|
}
|
|
|
|
void NetworkManager::enableNetworking(bool enable)
|
|
{
|
|
QVariantMap params;
|
|
params.insert("enable", enable);
|
|
m_engine->jsonRpcClient()->sendCommand("NetworkManager.EnableNetworking", params, this, "enableNetworkingReply");
|
|
}
|
|
|
|
void NetworkManager::enableWirelessNetworking(bool enable)
|
|
{
|
|
QVariantMap params;
|
|
params.insert("enable", enable);
|
|
m_engine->jsonRpcClient()->sendCommand("NetworkManager.EnableWirelessNetworking", params, this, "enableNetworkingReply");
|
|
}
|
|
|
|
void NetworkManager::refreshWifis(const QString &interface)
|
|
{
|
|
QVariantMap params;
|
|
params.insert("interface", interface);
|
|
int requestId = m_engine->jsonRpcClient()->sendCommand("NetworkManager.GetWirelessAccessPoints", params, this, "getAccessPointsReply");
|
|
m_apRequests.insert(requestId, interface);
|
|
}
|
|
|
|
void NetworkManager::connectToWiFi(const QString &interface, const QString &ssid, const QString &passphrase)
|
|
{
|
|
QVariantMap params;
|
|
params.insert("interface", interface);
|
|
params.insert("ssid", ssid);
|
|
params.insert("password", passphrase);
|
|
m_engine->jsonRpcClient()->sendCommand("NetworkManager.ConnectWifiNetwork", params, this, "connectToWiFiReply");
|
|
}
|
|
|
|
void NetworkManager::disconnectInterface(const QString &interface)
|
|
{
|
|
QVariantMap params;
|
|
params.insert("interface", interface);
|
|
m_engine->jsonRpcClient()->sendCommand("NetworkManager.DisconnectInterface", params, this, "disconnectReply");
|
|
}
|
|
|
|
void NetworkManager::getStatusReply(const QVariantMap ¶ms)
|
|
{
|
|
// qDebug() << "NetworkManager reply" << qUtf8Printable(QJsonDocument::fromVariant(params).toJson(QJsonDocument::Indented));
|
|
|
|
QVariantMap statusMap = params.value("params").toMap().value("status").toMap();
|
|
|
|
QMetaEnum stateEnum = QMetaEnum::fromType<NetworkManager::NetworkManagerState>();
|
|
NetworkManagerState state = static_cast<NetworkManager::NetworkManagerState>(stateEnum.keyToValue(params.value("params").toMap().value("status").toMap().value("state").toString().toUtf8()));
|
|
if (m_state != state) {
|
|
m_state = state;
|
|
emit stateChanged();
|
|
}
|
|
|
|
bool networkingEnabled = statusMap.value("networkingEnabled").toBool();
|
|
if (m_networkingEnabled != networkingEnabled) {
|
|
m_networkingEnabled = networkingEnabled;
|
|
emit networkingEnabledChanged();
|
|
}
|
|
bool wirelessNetworkingEnabled = statusMap.value("wirelessNetworkingEnabled").toBool();
|
|
if (m_wirelessNetworkingEnabled != wirelessNetworkingEnabled) {
|
|
m_wirelessNetworkingEnabled = wirelessNetworkingEnabled;
|
|
emit wirelessNetworkingEnabledChanged();
|
|
}
|
|
}
|
|
|
|
void NetworkManager::getDevicesReply(const QVariantMap ¶ms)
|
|
{
|
|
// qDebug() << "Devices reply" << qUtf8Printable(QJsonDocument::fromVariant(params).toJson(QJsonDocument::Indented));
|
|
|
|
foreach (const QVariant &deviceVariant, params.value("params").toMap().value("wiredNetworkDevices").toList()) {
|
|
QVariantMap deviceMap = deviceVariant.toMap();
|
|
WiredNetworkDevice *device = new WiredNetworkDevice(deviceMap.value("macAddress").toString(), deviceMap.value("interface").toString(), this);
|
|
device->setBitRate(deviceMap.value("bitRate").toString());
|
|
QMetaEnum stateEnum = QMetaEnum::fromType<NetworkDevice::NetworkDeviceState>();
|
|
device->setState(static_cast<NetworkDevice::NetworkDeviceState>(stateEnum.keyToValue(deviceMap.value("state").toString().toUtf8())));
|
|
device->setPluggedIn(deviceMap.value("pluggedIn").toBool());
|
|
m_wiredNetworkDevices->addNetworkDevice(device);
|
|
}
|
|
foreach (const QVariant &deviceVariant, params.value("params").toMap().value("wirelessNetworkDevices").toList()) {
|
|
QVariantMap deviceMap = deviceVariant.toMap();
|
|
WirelessNetworkDevice *device = new WirelessNetworkDevice(deviceMap.value("macAddress").toString(), deviceMap.value("interface").toString(), this);
|
|
device->setBitRate(deviceMap.value("bitRate").toString());
|
|
QMetaEnum stateEnum = QMetaEnum::fromType<NetworkDevice::NetworkDeviceState>();
|
|
device->setState(static_cast<NetworkDevice::NetworkDeviceState>(stateEnum.keyToValue(deviceMap.value("state").toString().toUtf8())));
|
|
|
|
QVariantMap currentApMap = deviceMap.value("currentAccessPoint").toMap();
|
|
device->currentAccessPoint()->setSsid(currentApMap.value("ssid").toString());
|
|
device->currentAccessPoint()->setMacAddress(currentApMap.value("macAddress").toString());
|
|
device->currentAccessPoint()->setProtected(currentApMap.value("protected").toBool());
|
|
device->currentAccessPoint()->setSignalStrength(currentApMap.value("signalStrength").toInt());
|
|
m_wirelessNetworkDevices->addNetworkDevice(device);
|
|
}
|
|
}
|
|
|
|
void NetworkManager::getAccessPointsReply(const QVariantMap ¶ms)
|
|
{
|
|
qDebug() << "Access points reply" << qUtf8Printable(QJsonDocument::fromVariant(params).toJson(QJsonDocument::Indented));
|
|
|
|
int requestId = params.value("id").toInt();
|
|
if (!m_apRequests.contains(requestId)) {
|
|
qWarning() << "NetworkManager received a reply for a request we don't know!";
|
|
return;
|
|
}
|
|
QString interface = m_apRequests.take(requestId);
|
|
|
|
WirelessNetworkDevice *dev = m_wirelessNetworkDevices->getWirelessNetworkDevice(interface);
|
|
if (!dev) {
|
|
qWarning() << "NetworkManager received wifi list for" << interface << "but device disappeared";
|
|
return;
|
|
}
|
|
|
|
dev->accessPoints()->clearModel();
|
|
|
|
foreach (const QVariant &apVariant, params.value("params").toMap().value("wirelessAccessPoints").toList()) {
|
|
QVariantMap apMap = apVariant.toMap();
|
|
WirelessAccessPoint* ap = new WirelessAccessPoint(this);
|
|
ap->setMacAddress(apMap.value("macAddress").toString());
|
|
ap->setSsid(apMap.value("ssid").toString());
|
|
ap->setProtected(apMap.value("protected").toBool());
|
|
ap->setSignalStrength(apMap.value("signalStrength").toInt());
|
|
dev->accessPoints()->addWirelessAccessPoint(ap);
|
|
}
|
|
|
|
}
|
|
|
|
void NetworkManager::connectToWiFiReply(const QVariantMap ¶ms)
|
|
{
|
|
qDebug() << "connect to wifi reply" << qUtf8Printable(QJsonDocument::fromVariant(params).toJson(QJsonDocument::Indented));
|
|
}
|
|
|
|
void NetworkManager::disconnectReply(const QVariantMap ¶ms)
|
|
{
|
|
qDebug() << "disconnect reply" << qUtf8Printable(QJsonDocument::fromVariant(params).toJson(QJsonDocument::Indented));
|
|
}
|
|
|
|
void NetworkManager::enableNetworkingReply(const QVariantMap ¶ms)
|
|
{
|
|
qDebug() << "enable networking reply" << qUtf8Printable(QJsonDocument::fromVariant(params).toJson(QJsonDocument::Indented));
|
|
}
|
|
|
|
void NetworkManager::notificationReceived(const QVariantMap ¶ms)
|
|
{
|
|
QString notification = params.value("notification").toString();
|
|
if (notification == "NetworkManager.WirelessNetworkDeviceChanged") {
|
|
QVariantMap deviceMap = params.value("params").toMap().value("wirelessNetworkDevice").toMap();
|
|
WirelessNetworkDevice* device = m_wirelessNetworkDevices->getWirelessNetworkDevice(deviceMap.value("interface").toString());
|
|
if (!device) {
|
|
qWarning() << "Received a notification for a WiFi device we don't know" << deviceMap;
|
|
return;
|
|
}
|
|
device->setBitRate(deviceMap.value("bitRate").toString());
|
|
QMetaEnum stateEnum = QMetaEnum::fromType<NetworkDevice::NetworkDeviceState>();
|
|
device->setState(static_cast<NetworkDevice::NetworkDeviceState>(stateEnum.keyToValue(deviceMap.value("state").toString().toUtf8())));
|
|
|
|
QVariantMap currentApMap = deviceMap.value("currentAccessPoint").toMap();
|
|
device->currentAccessPoint()->setSsid(currentApMap.value("ssid").toString());
|
|
device->currentAccessPoint()->setMacAddress(currentApMap.value("macAddress").toString());
|
|
device->currentAccessPoint()->setProtected(currentApMap.value("protected").toBool());
|
|
device->currentAccessPoint()->setSignalStrength(currentApMap.value("signalStrength").toInt());
|
|
} else if (notification == "NetworkManager.NetworkStatusChanged") {
|
|
QMetaEnum stateEnum = QMetaEnum::fromType<NetworkManager::NetworkManagerState>();
|
|
NetworkManagerState state = static_cast<NetworkManager::NetworkManagerState>(stateEnum.keyToValue(params.value("params").toMap().value("status").toMap().value("state").toString().toUtf8()));
|
|
bool networkingEnabled = params.value("params").toMap().value("status").toMap().value("networkingEnabled").toBool();
|
|
bool wirelessNetworkingEnabled = params.value("params").toMap().value("status").toMap().value("wirelessNetworkingEnabled").toBool();
|
|
if (m_state != state) {
|
|
m_state = state;
|
|
emit stateChanged();
|
|
}
|
|
if (m_networkingEnabled != networkingEnabled) {
|
|
m_networkingEnabled = networkingEnabled;
|
|
emit networkingEnabledChanged();
|
|
}
|
|
if (m_wirelessNetworkingEnabled != wirelessNetworkingEnabled) {
|
|
m_wirelessNetworkingEnabled = wirelessNetworkingEnabled;
|
|
emit wirelessNetworkingEnabledChanged();
|
|
}
|
|
|
|
} else {
|
|
qDebug() << "notification received" << qUtf8Printable(QJsonDocument::fromVariant(params).toJson(QJsonDocument::Indented));
|
|
}
|
|
}
|