567 lines
23 KiB
C++
567 lines
23 KiB
C++
// SPDX-License-Identifier: LGPL-3.0-or-later
|
|
|
|
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
|
|
*
|
|
* Copyright (C) 2013 - 2024, nymea GmbH
|
|
* Copyright (C) 2024 - 2025, chargebyte austria GmbH
|
|
*
|
|
* This file is part of libnymea-app.
|
|
*
|
|
* libnymea-app is free software: you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public License
|
|
* as published by the Free Software Foundation, either version 3
|
|
* of the License, or (at your option) any later version.
|
|
*
|
|
* libnymea-app 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 Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* along with libnymea-app. If not, see <https://www.gnu.org/licenses/>.
|
|
*
|
|
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
|
|
|
#include "nymeaconnection.h"
|
|
#include "nymeahost.h"
|
|
|
|
#include <QUrl>
|
|
#include <QDebug>
|
|
#include <QSslKey>
|
|
#include <QUrlQuery>
|
|
#include <QSettings>
|
|
#include <QMetaEnum>
|
|
#include <QStandardPaths>
|
|
#include <QFile>
|
|
#include <QDir>
|
|
#include <QTimer>
|
|
#include <QGuiApplication>
|
|
|
|
#include "networkreachabilitymonitor.h"
|
|
#include "nymeatransportinterface.h"
|
|
#include "logging.h"
|
|
|
|
NYMEA_LOGGING_CATEGORY(dcNymeaConnection, "NymeaConnection")
|
|
|
|
NymeaConnection::NymeaConnection(QObject *parent) : QObject(parent)
|
|
{
|
|
m_networkReachabilityMonitor = new NetworkReachabilityMonitor(this);
|
|
connect(m_networkReachabilityMonitor, &NetworkReachabilityMonitor::availableBearerTypesChanged, this, &NymeaConnection::availableBearerTypesChanged);
|
|
connect(m_networkReachabilityMonitor, &NetworkReachabilityMonitor::availableBearerTypesUpdated, this, &NymeaConnection::onAvailableBearerTypesUpdated);
|
|
|
|
#ifdef Q_OS_IOS
|
|
connect(m_networkReachabilityMonitor, &NetworkReachabilityMonitor::availableBearerTypesChanged, this, [this](){
|
|
if (m_currentTransport) {
|
|
qCInfo(dcNymeaConnection()) << "Available bearer types changed:" << m_networkReachabilityMonitor->availableBearerTypes() << "currently used:" << m_usedBearerType;
|
|
if (!m_networkReachabilityMonitor->availableBearerTypes().testFlag(m_usedBearerType)) {
|
|
qCInfo(dcNymeaConnection()) << "Used bearer type" << m_usedBearerType << "isn't available any more. Reconnecting.";
|
|
m_currentTransport->disconnect();
|
|
}
|
|
}
|
|
});
|
|
#endif
|
|
|
|
QGuiApplication *app = static_cast<QGuiApplication*>(QGuiApplication::instance());
|
|
QObject::connect(app, &QGuiApplication::applicationStateChanged, this, [app, this](Qt::ApplicationState state) {
|
|
qCDebug(dcNymeaConnection()) << "Application state changed to:" << state;
|
|
|
|
// On android, when the device is suspended with display off for a while, it happens that the app is still woken up
|
|
// occationally and it would try to reconnect, but the WiFi is in deep sleep and the connection attempts time out in 5 seconds
|
|
// or so. So it happens that the device is woken up and the app would try to reconnect, but there are still ongoing
|
|
// connection attempts on all the transports. In order to not wait for them time out, let's abort all the currently
|
|
// pending attempts so we try again immediately, now that wifi should be up again.
|
|
if (app->applicationState() == Qt::ApplicationActive) {
|
|
foreach (NymeaTransportInterface *transport, m_transportCandidates.keys()) {
|
|
if (transport != m_currentTransport) {
|
|
transport->disconnect();
|
|
}
|
|
}
|
|
}
|
|
});
|
|
|
|
m_reconnectTimer.setInterval(500);
|
|
m_reconnectTimer.setSingleShot(true);
|
|
connect(&m_reconnectTimer, &QTimer::timeout, this, [this](){
|
|
if (m_currentHost && !m_currentTransport) {
|
|
qCInfo(dcNymeaConnection()) << "Reconnecting...";
|
|
connectInternal(m_currentHost);
|
|
}
|
|
});
|
|
}
|
|
|
|
NymeaConnection::~NymeaConnection()
|
|
{
|
|
QList<NymeaTransportInterfaceFactory*> deletedTransports;
|
|
foreach (NymeaTransportInterfaceFactory* transport, m_transportFactories) {
|
|
if (!deletedTransports.contains(transport)) {
|
|
delete transport;
|
|
deletedTransports.append(transport);
|
|
}
|
|
}
|
|
}
|
|
|
|
NymeaConnection::BearerTypes NymeaConnection::availableBearerTypes() const
|
|
{
|
|
return m_networkReachabilityMonitor->availableBearerTypes();
|
|
}
|
|
|
|
bool NymeaConnection::connected()
|
|
{
|
|
return m_currentHost && m_currentTransport && m_currentTransport->connectionState() == NymeaTransportInterface::ConnectionStateConnected;
|
|
}
|
|
|
|
NymeaConnection::ConnectionStatus NymeaConnection::connectionStatus() const
|
|
{
|
|
return m_connectionStatus;
|
|
}
|
|
|
|
NymeaHost *NymeaConnection::currentHost() const
|
|
{
|
|
return m_currentHost;
|
|
}
|
|
|
|
void NymeaConnection::setCurrentHost(NymeaHost *host)
|
|
{
|
|
if (m_currentHost == host) {
|
|
return;
|
|
}
|
|
|
|
if (host && m_preferredConnection) {
|
|
if (host->connections()->find(m_preferredConnection->url())) {
|
|
qCInfo(dcNymeaConnection()) << "Setting preferred connection to" << m_preferredConnection->url();
|
|
// Unset the preferred connection when it is removed
|
|
connect(m_preferredConnection, &Connection::destroyed, this, [=](){
|
|
qCWarning(dcNymeaConnection()) << "Unsetting preferred connection as it was destroyed.";
|
|
m_preferredConnection = nullptr;
|
|
});
|
|
} else {
|
|
qCWarning(dcNymeaConnection()) << "Connection" << m_preferredConnection << "is not a candidate for" << host->name() << "Not setting preferred connection.";
|
|
m_preferredConnection = nullptr;
|
|
}
|
|
}
|
|
|
|
|
|
if (m_currentTransport) {
|
|
m_currentTransport = nullptr;
|
|
emit currentConnectionChanged();
|
|
emit connectedChanged(false);
|
|
}
|
|
|
|
while (!m_transportCandidates.isEmpty()) {
|
|
NymeaTransportInterface *transport = m_transportCandidates.keys().first();
|
|
m_transportCandidates.remove(transport);
|
|
transport->deleteLater();
|
|
}
|
|
if (m_currentHost) {
|
|
disconnect(m_currentHost, &NymeaHost::connectionChanged, this, &NymeaConnection::hostConnectionsUpdated);
|
|
m_currentHost = nullptr;
|
|
}
|
|
|
|
|
|
m_currentHost = host;
|
|
emit currentHostChanged();
|
|
|
|
if (!m_currentHost) {
|
|
qCInfo(dcNymeaConnection()) << "Current host cleared. Not connecting.";
|
|
return;
|
|
}
|
|
|
|
qCInfo(dcNymeaConnection()) << "Nymea host set to:" << m_currentHost->name() << m_currentHost->uuid();
|
|
|
|
connect(m_currentHost, &NymeaHost::connectionChanged, this, &NymeaConnection::hostConnectionsUpdated);
|
|
|
|
m_connectionStatus = ConnectionStatusConnecting;
|
|
emit connectionStatusChanged();
|
|
|
|
connectInternal(m_currentHost);
|
|
}
|
|
|
|
Connection *NymeaConnection::currentConnection() const
|
|
{
|
|
if (!m_currentHost || !m_currentTransport) {
|
|
return nullptr;
|
|
}
|
|
return m_transportCandidates.value(m_currentTransport);
|
|
}
|
|
|
|
void NymeaConnection::sendData(const QByteArray &data)
|
|
{
|
|
if (connected()) {
|
|
m_currentTransport->sendData(data);
|
|
} else {
|
|
qCWarning(dcNymeaConnection()) << "Connection: Not connected. Cannot send.";
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::onSslErrors(const QList<QSslError> &errors)
|
|
{
|
|
NymeaTransportInterface *transport = qobject_cast<NymeaTransportInterface*>(sender());
|
|
|
|
qCDebug(dcNymeaConnection()) << "SSL errors for url:" << transport->url();
|
|
QList<QSslError> ignoredErrors;
|
|
foreach (const QSslError &error, errors) {
|
|
qDebug() << error.errorString();
|
|
if (error.error() == QSslError::HostNameMismatch) {
|
|
qCInfo(dcNymeaConnection()) << "Ignoring host mismatch on certificate.";
|
|
ignoredErrors.append(error);
|
|
} else if (error.error() == QSslError::SelfSignedCertificate || error.error() == QSslError::CertificateUntrusted) {
|
|
qCInfo(dcNymeaConnection()) << "Ignoring self signed certificate.";
|
|
ignoredErrors.append(error);
|
|
} else {
|
|
// Reject the connection on all other errors...
|
|
qCritical(dcNymeaConnection()) << "SSL Error:" << error.errorString() << error.certificate();
|
|
}
|
|
}
|
|
if (ignoredErrors == errors) {
|
|
// Note, due to a workaround in the WebSocketTransport we must not call this
|
|
// unless we've handled all the errors or the websocket will ignore unhandled errors too...
|
|
transport->ignoreSslErrors(ignoredErrors);
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::onError(QAbstractSocket::SocketError error)
|
|
{
|
|
QMetaEnum errorEnum = QMetaEnum::fromType<QAbstractSocket::SocketError>();
|
|
QString errorString = errorEnum.valueToKey(error);
|
|
|
|
NymeaTransportInterface* transport = qobject_cast<NymeaTransportInterface*>(sender());
|
|
|
|
ConnectionStatus errorStatus = ConnectionStatusUnknownError;
|
|
switch (error) {
|
|
case QAbstractSocket::ConnectionRefusedError:
|
|
errorStatus = ConnectionStatusConnectionRefused;
|
|
break;
|
|
case QAbstractSocket::HostNotFoundError:
|
|
errorStatus = ConnectionStatusHostNotFound;
|
|
break;
|
|
case QAbstractSocket::NetworkError:
|
|
errorStatus = ConnectionStatusBearerFailed;
|
|
break;
|
|
case QAbstractSocket::RemoteHostClosedError:
|
|
errorStatus = ConnectionStatusRemoteHostClosed;
|
|
break;
|
|
case QAbstractSocket::SocketTimeoutError:
|
|
errorStatus = ConnectionStatusTimeout;
|
|
break;
|
|
case QAbstractSocket::SslInternalError:
|
|
case QAbstractSocket::SslInvalidUserDataError:
|
|
errorStatus = ConnectionStatusSslError;
|
|
break;
|
|
case QAbstractSocket::SslHandshakeFailedError:
|
|
errorStatus = ConnectionStatusSslUntrusted;
|
|
break;
|
|
default:
|
|
errorStatus = ConnectionStatusUnknownError;
|
|
}
|
|
|
|
if (transport == m_currentTransport) {
|
|
qCCritical(dcNymeaConnection()) << "Current transport failed:" << error;
|
|
// The current transport failed, forward the error
|
|
m_connectionStatus = errorStatus;
|
|
emit connectionStatusChanged();
|
|
return;
|
|
}
|
|
|
|
if (!m_currentTransport) {
|
|
// We're trying to connect and one of the transports failed...
|
|
if (m_transportCandidates.contains(transport)) {
|
|
m_transportCandidates.remove(transport);
|
|
transport->deleteLater();
|
|
}
|
|
qCWarning(dcNymeaConnection()) << "A transport error happened for" << transport->url() << error << "(Still trying on" << m_transportCandidates.count() << "connections)";
|
|
foreach (Connection *c, m_transportCandidates) {
|
|
qCDebug(dcNymeaConnection()) << "Connection candidate:" << c->url();
|
|
}
|
|
|
|
if (m_connectionStatus != ConnectionStatusSslUntrusted && !m_reconnectTimer.isActive()) {
|
|
m_reconnectTimer.start();
|
|
}
|
|
|
|
if (m_transportCandidates.isEmpty()) {
|
|
m_connectionStatus = errorStatus;
|
|
emit connectionStatusChanged();
|
|
}
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::onConnected()
|
|
{
|
|
NymeaTransportInterface* newTransport = qobject_cast<NymeaTransportInterface*>(sender());
|
|
if (!m_currentTransport) {
|
|
m_currentTransport = newTransport;
|
|
qCInfo(dcNymeaConnection()) << "Connected to" << m_currentHost->name() << "via" << m_currentTransport->url() << m_currentTransport->isEncrypted();
|
|
#ifdef Q_OS_IOS
|
|
// We can't know for sure which transport we're actually using, but let's assume the OS picked from the available ones in the order LAN, WiFi, MobileData
|
|
if (m_networkReachabilityMonitor->availableBearerTypes().testFlag(NymeaConnection::BearerTypeEthernet)) {
|
|
m_usedBearerType = NymeaConnection::BearerTypeEthernet;
|
|
} else if (m_networkReachabilityMonitor->availableBearerTypes().testFlag(NymeaConnection::BearerTypeWiFi)) {
|
|
m_usedBearerType = NymeaConnection::BearerTypeWiFi;
|
|
} else {
|
|
m_usedBearerType = NymeaConnection::BearerTypeMobileData;
|
|
}
|
|
qCDebug(dcNymeaConnection()) << "iOS: Assuming used bearer type:" << m_usedBearerType;
|
|
#endif
|
|
emit currentConnectionChanged();
|
|
emit connectedChanged(true);
|
|
return;
|
|
}
|
|
|
|
if (m_currentTransport != newTransport) {
|
|
// In theory, we could roam from one connection to another.
|
|
// However, in practice it turns out there are too many issues for this to be reliable
|
|
// So lets just tear down any alternative connection that comes up again.
|
|
|
|
qCInfo(dcNymeaConnection()) << "Dropping successfully established alternative connection to" << newTransport->url() << "again...";
|
|
m_transportCandidates.remove(newTransport);
|
|
newTransport->deleteLater();
|
|
|
|
|
|
// Connection *existingConnection = m_transportCandidates.value(m_currentTransport);
|
|
// Connection *alternativeConnection = m_transportCandidates.value(newTransport);
|
|
// if (alternativeConnection->priority() > existingConnection->priority()) {
|
|
// qDebug() << "New connection has higher priority! Roaming from" << existingConnection->url() << existingConnection->priority() << "to" << alternativeConnection->url() << alternativeConnection->priority();
|
|
// m_transportCandidates.remove(m_currentTransport);
|
|
// m_currentTransport->deleteLater();
|
|
// m_currentTransport = newTransport;
|
|
// } else {
|
|
// qDebug() << "Connection" << alternativeConnection->url() << alternativeConnection->priority() << "has lower priority than existing" << existingConnection->url() << existingConnection->priority();
|
|
// m_transportCandidates.remove(newTransport);
|
|
// newTransport->deleteLater();
|
|
// }
|
|
return;
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::onDisconnected()
|
|
{
|
|
NymeaTransportInterface* t = qobject_cast<NymeaTransportInterface*>(sender());
|
|
qCInfo(dcNymeaConnection()) << "Disconnected from" << t->url().toString();
|
|
if (m_currentTransport != t) {
|
|
qCDebug(dcNymeaConnection()) << "An inactive transport for url" << t->url() << "disconnected... Cleaning up...";
|
|
if (m_transportCandidates.contains(t)) {
|
|
m_transportCandidates.remove(t);
|
|
}
|
|
t->deleteLater();
|
|
|
|
qCDebug(dcNymeaConnection()) << "Current transport:" << m_currentTransport << "Remaining connections:" << m_transportCandidates.count() << "Current host:" << m_currentHost;
|
|
|
|
if (!m_currentTransport && m_transportCandidates.isEmpty()) {
|
|
qCInfo(dcNymeaConnection()) << "Last connection dropped.";
|
|
if (!m_reconnectTimer.isActive()) {
|
|
m_reconnectTimer.start();
|
|
}
|
|
}
|
|
|
|
return;
|
|
}
|
|
m_transportCandidates.remove(m_currentTransport);
|
|
m_currentTransport->deleteLater();
|
|
m_currentTransport = nullptr;
|
|
|
|
foreach (NymeaTransportInterface *candidate, m_transportCandidates.keys()) {
|
|
if (candidate->connectionState() == NymeaTransportInterface::ConnectionStateConnected) {
|
|
qCInfo(dcNymeaConnection()) << "Alternative connection is still up. Roaming to:" << candidate->url();
|
|
m_currentTransport = candidate;
|
|
break;
|
|
}
|
|
}
|
|
|
|
emit currentConnectionChanged();
|
|
|
|
if (!m_currentTransport) {
|
|
qCInfo(dcNymeaConnection()) << "Disconnected.";
|
|
emit connectedChanged(false);
|
|
}
|
|
|
|
|
|
if (!m_currentHost) {
|
|
return;
|
|
}
|
|
|
|
// Try to reconnect, only if we're not waiting for SSL certs to be trusted.
|
|
if (m_connectionStatus != ConnectionStatusSslUntrusted && !m_reconnectTimer.isActive()) {
|
|
qCInfo(dcNymeaConnection()) << "Trying to reconnect after disconnect...";
|
|
m_reconnectTimer.start();
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::onDataAvailable(const QByteArray &data)
|
|
{
|
|
NymeaTransportInterface *t = static_cast<NymeaTransportInterface*>(sender());
|
|
if (t == m_currentTransport) {
|
|
// qCDebug(dcNymeaConnection()) << "Data available";
|
|
emit dataAvailable(data);
|
|
} else {
|
|
qCDebug(dcNymeaConnection()) << "Received data from a transport that is not the current one:" << t->url();
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::onAvailableBearerTypesUpdated()
|
|
{
|
|
if (!m_currentHost) {
|
|
// No host set... Nothing to do...
|
|
qCInfo(dcNymeaConnection()) << "No current host... Nothing to do...";
|
|
return;
|
|
}
|
|
|
|
// In theory we could try to connect via any different/new bearers now. However, in practice
|
|
// I have observed the following issues:
|
|
// - When roaming from WiFi to mobile data, we've already lost WiFi at this point
|
|
// (Unless aggressive WiFi to mobile handover is enabled on the phone)
|
|
// - When roaming from mobile to Wifi, for some reason, any new connection attempts
|
|
// fail as long as the mobile data isn't shut down by the OS.
|
|
// Those issues prevent roaming from working properly, so let's just not do anything at
|
|
// this point if there already is a connected channel, try reconnecting otherwise.
|
|
|
|
if (!m_currentTransport) {
|
|
// There's a host but no connection. Try connecting now...
|
|
qCInfo(dcNymeaConnection()) << "There's a host but no connection. Trying to connect now...";
|
|
//connectInternal(m_currentHost);
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::hostConnectionsUpdated()
|
|
{
|
|
if (!m_currentTransport) {
|
|
qCInfo(dcNymeaConnection()) << "Possible connections for host" << m_currentHost->name() << "updated.";
|
|
connectInternal(m_currentHost);
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::registerTransport(NymeaTransportInterfaceFactory *transportFactory)
|
|
{
|
|
foreach (const QString &scheme, transportFactory->supportedSchemes()) {
|
|
m_transportFactories[scheme] = transportFactory;
|
|
}
|
|
}
|
|
|
|
void NymeaConnection::connectToHost(NymeaHost *nymeaHost, Connection *connection)
|
|
{
|
|
if (!nymeaHost) {
|
|
return;
|
|
}
|
|
|
|
m_preferredConnection = connection;
|
|
|
|
setCurrentHost(nymeaHost);
|
|
}
|
|
|
|
void NymeaConnection::connectInternal(NymeaHost *host)
|
|
{
|
|
if (m_preferredConnection) {
|
|
if (isConnectionBearerAvailable(m_preferredConnection->bearerType())) {
|
|
qCInfo(dcNymeaConnection()) << "Preferred connection is set. Using" << m_preferredConnection->url();
|
|
connectInternal(m_preferredConnection);
|
|
return;
|
|
}
|
|
qCWarning(dcNymeaConnection()) << "Preferred connection set but no bearer available for it.";
|
|
}
|
|
|
|
Connection *loopbackConnection = host->connections()->bestMatch(Connection::BearerTypeLoopback);
|
|
if (loopbackConnection) {
|
|
qCDebug(dcNymeaConnection()) << "Best candidate Loopback connection:" << loopbackConnection->url();
|
|
connectInternal(loopbackConnection);
|
|
|
|
} else if (m_networkReachabilityMonitor->availableBearerTypes().testFlag(NymeaConnection::BearerTypeWiFi)
|
|
|| m_networkReachabilityMonitor->availableBearerTypes().testFlag(NymeaConnection::BearerTypeEthernet)) {
|
|
Connection* lanConnection = host->connections()->bestMatch(Connection::BearerTypeLan | Connection::BearerTypeWan);
|
|
if (lanConnection) {
|
|
qCDebug(dcNymeaConnection()) << "Best candidate LAN/WAN connection:" << lanConnection->url();
|
|
connectInternal(lanConnection);
|
|
} else {
|
|
qCDebug(dcNymeaConnection()) << "No available LAN/WAN connection to" << host->name();
|
|
}
|
|
|
|
} else if (m_networkReachabilityMonitor->availableBearerTypes().testFlag(NymeaConnection::BearerTypeMobileData)) {
|
|
Connection* wanConnection = host->connections()->bestMatch(Connection::BearerTypeWan);
|
|
if (wanConnection) {
|
|
qCDebug(dcNymeaConnection()) << "Best candidate WAN connection:" << wanConnection->url();
|
|
connectInternal(wanConnection);
|
|
} else {
|
|
qCDebug(dcNymeaConnection()) << "No available WAN connection to" << host->name();
|
|
}
|
|
}
|
|
|
|
Connection* cloudConnection = host->connections()->bestMatch(Connection::BearerTypeCloud);
|
|
if (cloudConnection) {
|
|
qCDebug(dcNymeaConnection()) << "Best candidate Cloud connection:" << cloudConnection->url();
|
|
connectInternal(cloudConnection);
|
|
} else {
|
|
qCDebug(dcNymeaConnection()) << "No available Cloud connection to" << host->name();
|
|
}
|
|
|
|
if (m_transportCandidates.isEmpty()) {
|
|
qCWarning(dcNymeaConnection()) << "No available bearers available for host:" << host->name() << host->uuid();
|
|
m_connectionStatus = ConnectionStatusNoBearerAvailable;
|
|
} else {
|
|
m_connectionStatus = ConnectionStatusConnecting;
|
|
}
|
|
emit connectionStatusChanged();
|
|
}
|
|
|
|
bool NymeaConnection::connectInternal(Connection *connection)
|
|
{
|
|
if (!m_transportFactories.contains(connection->url().scheme())) {
|
|
qCCritical(dcNymeaConnection()) << "Cannot connect to urls of scheme" << connection->url().scheme() << "Supported schemes are" << m_transportFactories.keys();
|
|
return false;
|
|
}
|
|
|
|
if (m_transportCandidates.values().contains(connection)) {
|
|
qCInfo(dcNymeaConnection()) << "Already have a connection (or connection attempt) for" << connection->url();
|
|
return false;
|
|
}
|
|
|
|
// Create a new transport
|
|
NymeaTransportInterface* newTransport = m_transportFactories.value(connection->url().scheme())->createTransport(this);
|
|
QObject::connect(newTransport, &NymeaTransportInterface::sslErrors, this, &NymeaConnection::onSslErrors);
|
|
QObject::connect(newTransport, &NymeaTransportInterface::error, this, &NymeaConnection::onError);
|
|
QObject::connect(newTransport, &NymeaTransportInterface::connected, this, &NymeaConnection::onConnected);
|
|
QObject::connect(newTransport, &NymeaTransportInterface::disconnected, this, &NymeaConnection::onDisconnected);
|
|
QObject::connect(newTransport, &NymeaTransportInterface::dataReady, this, &NymeaConnection::onDataAvailable, Qt::QueuedConnection);
|
|
|
|
m_transportCandidates.insert(newTransport, connection);
|
|
qCInfo(dcNymeaConnection()) << "Connecting to:" << connection->url() << newTransport << m_transportCandidates.value(newTransport);
|
|
return newTransport->connect(connection->url());
|
|
}
|
|
|
|
bool NymeaConnection::isConnectionBearerAvailable(Connection::BearerType connectionBearerType) const
|
|
{
|
|
switch (connectionBearerType) {
|
|
case Connection::BearerTypeLan:
|
|
return availableBearerTypes().testFlag(BearerTypeEthernet)
|
|
|| availableBearerTypes().testFlag(BearerTypeWiFi);
|
|
case Connection::BearerTypeWan:
|
|
case Connection::BearerTypeCloud:
|
|
return availableBearerTypes().testFlag(BearerTypeEthernet)
|
|
|| availableBearerTypes().testFlag(BearerTypeWiFi)
|
|
|| availableBearerTypes().testFlag(BearerTypeMobileData);
|
|
case Connection::BearerTypeBluetooth:
|
|
return availableBearerTypes().testFlag(BearerTypeBluetooth);
|
|
case Connection::BearerTypeUnknown:
|
|
return true;
|
|
case Connection::BearerTypeNone:
|
|
return false;
|
|
case Connection::BearerTypeLoopback:
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
void NymeaConnection::disconnectFromHost()
|
|
{
|
|
setCurrentHost(nullptr);
|
|
}
|
|
|
|
bool NymeaConnection::isEncrypted() const
|
|
{
|
|
return m_currentTransport && m_currentTransport->isEncrypted();
|
|
}
|
|
|
|
QSslCertificate NymeaConnection::sslCertificate() const
|
|
{
|
|
if (!m_currentTransport) {
|
|
return QSslCertificate();
|
|
}
|
|
return m_currentTransport->serverCertificate();
|
|
}
|