fixed conflicts after merge

This commit is contained in:
vladimir.kuznetsov 2023-08-28 22:03:28 +03:00
parent 36a2482165
commit 8f6aa950cd
6 changed files with 140 additions and 104 deletions

View file

@ -21,8 +21,8 @@
#include "protocols/qml_register_protocols.h" #include "protocols/qml_register_protocols.h"
#if defined(Q_OS_IOS) #if defined(Q_OS_IOS)
#include "platforms/ios/QtAppDelegate-C-Interface.h" #include "platforms/ios/QtAppDelegate-C-Interface.h"
#include "platforms/ios/ios_controller.h" #include "platforms/ios/ios_controller.h"
#endif #endif
#if defined(Q_OS_ANDROID) || defined(Q_OS_IOS) #if defined(Q_OS_ANDROID) || defined(Q_OS_IOS)
@ -108,6 +108,9 @@ void AmneziaApplication::init()
&ImportController::extractConfigFromData); &ImportController::extractConfigFromData);
connect(AndroidController::instance(), &AndroidController::importConfigFromOutside, m_pageController.get(), connect(AndroidController::instance(), &AndroidController::importConfigFromOutside, m_pageController.get(),
&PageController::goToPageViewConfig); &PageController::goToPageViewConfig);
#endif
#ifdef Q_OS_IOS
IosController::Instance()->initialize(); IosController::Instance()->initialize();
#endif #endif

View file

@ -10,6 +10,9 @@
#include "../../platforms/android/androidutils.h" #include "../../platforms/android/androidutils.h"
#include <QJniObject> #include <QJniObject>
#endif #endif
#ifdef Q_OS_IOS
#include <CoreFoundation/CoreFoundation.h>
#endif
#include "fileUtilites.h" #include "fileUtilites.h"
namespace namespace
@ -88,6 +91,18 @@ void ImportController::extractConfigFromFile()
QStandardPaths::writableLocation(QStandardPaths::DocumentsLocation), QStandardPaths::writableLocation(QStandardPaths::DocumentsLocation),
"*.vpn *.ovpn *.conf"); "*.vpn *.ovpn *.conf");
QFile file(fileName); QFile file(fileName);
#ifdef Q_OS_IOS
CFURLRef url = CFURLCreateWithFileSystemPath(
kCFAllocatorDefault,
CFStringCreateWithCharacters(0, reinterpret_cast<const UniChar *>(fileName.unicode()), fileName.length()),
kCFURLPOSIXPathStyle, 0);
if (!CFURLStartAccessingSecurityScopedResource(url)) {
qDebug() << "Could not access path " << QUrl::fromLocalFile(fileName).toString();
}
#endif
if (file.open(QIODevice::ReadOnly)) { if (file.open(QIODevice::ReadOnly)) {
QString data = file.readAll(); QString data = file.readAll();

View file

@ -95,6 +95,18 @@ void SettingsController::restoreAppConfig()
} }
QFile file(fileName); QFile file(fileName);
#ifdef Q_OS_IOS
CFURLRef url = CFURLCreateWithFileSystemPath(
kCFAllocatorDefault,
CFStringCreateWithCharacters(0, reinterpret_cast<const UniChar *>(fileName.unicode()), fileName.length()),
kCFURLPOSIXPathStyle, 0);
if (!CFURLStartAccessingSecurityScopedResource(url)) {
qDebug() << "Could not access path " << QUrl::fromLocalFile(fileName).toString();
}
#endif
file.open(QIODevice::ReadOnly); file.open(QIODevice::ReadOnly);
QByteArray data = file.readAll(); QByteArray data = file.readAll();

View file

@ -90,6 +90,18 @@ void SitesController::importSites(bool replaceExisting)
} }
QFile file(fileName); QFile file(fileName);
#ifdef Q_OS_IOS
CFURLRef url = CFURLCreateWithFileSystemPath(
kCFAllocatorDefault,
CFStringCreateWithCharacters(0, reinterpret_cast<const UniChar *>(fileName.unicode()), fileName.length()),
kCFURLPOSIXPathStyle, 0);
if (!CFURLStartAccessingSecurityScopedResource(url)) {
qDebug() << "Could not access path " << QUrl::fromLocalFile(fileName).toString();
}
#endif
if (!file.open(QIODevice::ReadOnly)) { if (!file.open(QIODevice::ReadOnly)) {
emit errorOccurred(tr("Can't open file: ") + fileName); emit errorOccurred(tr("Can't open file: ") + fileName);
return; return;

View file

@ -19,17 +19,10 @@
#endif #endif
#ifdef Q_OS_IOS #ifdef Q_OS_IOS
#include <CoreFoundation/CoreFoundation.h> #include <CoreFoundation/CoreFoundation.h>
#endif #endif
namespace { namespace
enum class ConfigTypes {
Amnezia,
OpenVpn,
WireGuard
};
ConfigTypes checkConfigFormat(const QString &config)
{ {
enum class ConfigTypes { enum class ConfigTypes {
Amnezia, Amnezia,
@ -200,18 +193,18 @@ void StartPageLogic::onPushButtonImportOpenFile()
return; return;
QFile file(fileName); QFile file(fileName);
#ifdef Q_OS_IOS #ifdef Q_OS_IOS
CFURLRef url = CFURLCreateWithFileSystemPath( CFURLRef url = CFURLCreateWithFileSystemPath(
kCFAllocatorDefault, CFStringCreateWithCharacters(0, reinterpret_cast<const UniChar *>(fileName.unicode()), kCFAllocatorDefault,
fileName.length()), CFStringCreateWithCharacters(0, reinterpret_cast<const UniChar *>(fileName.unicode()), fileName.length()),
kCFURLPOSIXPathStyle, 0); kCFURLPOSIXPathStyle, 0);
if (!CFURLStartAccessingSecurityScopedResource(url)) { if (!CFURLStartAccessingSecurityScopedResource(url)) {
qDebug() << "Could not access path " << QUrl::fromLocalFile(fileName).toString(); qDebug() << "Could not access path " << QUrl::fromLocalFile(fileName).toString();
} }
#endif #endif
file.open(QIODevice::ReadOnly); file.open(QIODevice::ReadOnly);
QByteArray data = file.readAll(); QByteArray data = file.readAll();

View file

@ -5,41 +5,40 @@
#include <QHostInfo> #include <QHostInfo>
#include <QJsonObject> #include <QJsonObject>
#include <configurators/openvpn_configurator.h>
#include <configurators/cloak_configurator.h> #include <configurators/cloak_configurator.h>
#include <configurators/openvpn_configurator.h>
#include <configurators/shadowsocks_configurator.h> #include <configurators/shadowsocks_configurator.h>
#include <configurators/wireguard_configurator.h>
#include <configurators/vpn_configurator.h> #include <configurators/vpn_configurator.h>
#include <configurators/wireguard_configurator.h>
#include <core/servercontroller.h> #include <core/servercontroller.h>
#ifdef AMNEZIA_DESKTOP #ifdef AMNEZIA_DESKTOP
#include "ipc.h" #include "core/ipcclient.h"
#include "core/ipcclient.h" #include "ipc.h"
#include <protocols/wireguardprotocol.h> #include <protocols/wireguardprotocol.h>
#endif #endif
#ifdef Q_OS_ANDROID #ifdef Q_OS_ANDROID
#include "../../platforms/android/android_controller.h" #include "../../platforms/android/android_controller.h"
#endif #endif
#ifdef Q_OS_IOS #ifdef Q_OS_IOS
#include "platforms/ios/ios_controller.h" #include "platforms/ios/ios_controller.h"
#endif #endif
#include "utilities.h" #include "utilities.h"
#include "vpnconnection.h" #include "vpnconnection.h"
VpnConnection::VpnConnection(std::shared_ptr<Settings> settings, VpnConnection::VpnConnection(std::shared_ptr<Settings> settings, std::shared_ptr<VpnConfigurator> configurator,
std::shared_ptr<VpnConfigurator> configurator, QObject* parent) : QObject(parent), QObject *parent)
m_settings(settings), : QObject(parent), m_settings(settings), m_configurator(configurator), m_checkTimer(new QTimer(this))
m_configurator(configurator),
m_checkTimer(new QTimer(this))
{ {
m_checkTimer.setInterval(1000); m_checkTimer.setInterval(1000);
#ifdef Q_OS_IOS #ifdef Q_OS_IOS
connect(IosController::Instance(), &IosController::connectionStateChanged, this, &VpnConnection::onConnectionStateChanged); connect(IosController::Instance(), &IosController::connectionStateChanged, this,
&VpnConnection::onConnectionStateChanged);
connect(IosController::Instance(), &IosController::bytesChanged, this, &VpnConnection::onBytesChanged); connect(IosController::Instance(), &IosController::bytesChanged, this, &VpnConnection::onBytesChanged);
#endif #endif
} }
@ -60,27 +59,23 @@ void VpnConnection::onConnectionStateChanged(Vpn::ConnectionState state)
#ifdef AMNEZIA_DESKTOP #ifdef AMNEZIA_DESKTOP
if (IpcClient::Interface()) { if (IpcClient::Interface()) {
if (state == Vpn::ConnectionState::Connected){ if (state == Vpn::ConnectionState::Connected) {
IpcClient::Interface()->resetIpStack(); IpcClient::Interface()->resetIpStack();
IpcClient::Interface()->flushDns(); IpcClient::Interface()->flushDns();
if (m_settings->routeMode() != Settings::VpnAllSites) { if (m_settings->routeMode() != Settings::VpnAllSites) {
IpcClient::Interface()->routeDeleteList(m_vpnProtocol->vpnGateway(), QStringList() << "0.0.0.0"); IpcClient::Interface()->routeDeleteList(m_vpnProtocol->vpnGateway(), QStringList() << "0.0.0.0");
//qDebug() << "VpnConnection::onConnectionStateChanged :: adding custom routes, count:" << forwardIps.size(); // qDebug() << "VpnConnection::onConnectionStateChanged :: adding custom routes, count:" << forwardIps.size();
} }
QString dns1 = m_vpnConfiguration.value(config_key::dns1).toString(); QString dns1 = m_vpnConfiguration.value(config_key::dns1).toString();
QString dns2 = m_vpnConfiguration.value(config_key::dns1).toString(); QString dns2 = m_vpnConfiguration.value(config_key::dns1).toString();
IpcClient::Interface()->routeAddList(m_vpnProtocol->vpnGateway(), IpcClient::Interface()->routeAddList(m_vpnProtocol->vpnGateway(), QStringList() << dns1 << dns2);
QStringList() << dns1 << dns2);
if (m_settings->routeMode() == Settings::VpnOnlyForwardSites) { if (m_settings->routeMode() == Settings::VpnOnlyForwardSites) {
QTimer::singleShot(1000, m_vpnProtocol.data(), [this](){ QTimer::singleShot(1000, m_vpnProtocol.data(),
addSitesRoutes(m_vpnProtocol->vpnGateway(), m_settings->routeMode()); [this]() { addSitesRoutes(m_vpnProtocol->vpnGateway(), m_settings->routeMode()); });
}); } else if (m_settings->routeMode() == Settings::VpnAllExceptSites) {
}
else if (m_settings->routeMode() == Settings::VpnAllExceptSites) {
IpcClient::Interface()->routeAddList(m_vpnProtocol->vpnGateway(), QStringList() << "0.0.0.0/1"); IpcClient::Interface()->routeAddList(m_vpnProtocol->vpnGateway(), QStringList() << "0.0.0.0/1");
IpcClient::Interface()->routeAddList(m_vpnProtocol->vpnGateway(), QStringList() << "128.0.0.0/1"); IpcClient::Interface()->routeAddList(m_vpnProtocol->vpnGateway(), QStringList() << "128.0.0.0/1");
@ -88,9 +83,7 @@ void VpnConnection::onConnectionStateChanged(Vpn::ConnectionState state)
addSitesRoutes(m_vpnProtocol->routeGateway(), m_settings->routeMode()); addSitesRoutes(m_vpnProtocol->routeGateway(), m_settings->routeMode());
} }
} else if (state == Vpn::ConnectionState::Error) {
}
else if (state == Vpn::ConnectionState::Error) {
IpcClient::Interface()->flushDns(); IpcClient::Interface()->flushDns();
if (m_settings->routeMode() == Settings::VpnOnlyForwardSites) { if (m_settings->routeMode() == Settings::VpnOnlyForwardSites) {
@ -103,8 +96,7 @@ void VpnConnection::onConnectionStateChanged(Vpn::ConnectionState state)
#ifdef Q_OS_IOS #ifdef Q_OS_IOS
if (state == Vpn::ConnectionState::Connected) { if (state == Vpn::ConnectionState::Connected) {
m_checkTimer.start(); m_checkTimer.start();
} } else {
else {
m_checkTimer.stop(); m_checkTimer.stop();
} }
#endif #endif
@ -125,8 +117,7 @@ void VpnConnection::addSitesRoutes(const QString &gw, Settings::RouteMode mode)
for (auto i = m.constBegin(); i != m.constEnd(); ++i) { for (auto i = m.constBegin(); i != m.constEnd(); ++i) {
if (Utils::checkIpSubnetFormat(i.key())) { if (Utils::checkIpSubnetFormat(i.key())) {
ips.append(i.key()); ips.append(i.key());
} } else {
else {
if (Utils::checkIpSubnetFormat(i.value().toString())) { if (Utils::checkIpSubnetFormat(i.value().toString())) {
ips.append(i.value().toString()); ips.append(i.value().toString());
} }
@ -139,24 +130,24 @@ void VpnConnection::addSitesRoutes(const QString &gw, Settings::RouteMode mode)
IpcClient::Interface()->routeAddList(gw, ips); IpcClient::Interface()->routeAddList(gw, ips);
// re-resolve domains // re-resolve domains
for (const QString &site: sites) { for (const QString &site : sites) {
const auto &cbResolv = [this, site, gw, mode, ips](const QHostInfo &hostInfo){ const auto &cbResolv = [this, site, gw, mode, ips](const QHostInfo &hostInfo) {
const QList<QHostAddress> &addresses = hostInfo.addresses(); const QList<QHostAddress> &addresses = hostInfo.addresses();
QString ipv4Addr; QString ipv4Addr;
for (const QHostAddress &addr: hostInfo.addresses()) { for (const QHostAddress &addr : hostInfo.addresses()) {
if (addr.protocol() == QAbstractSocket::NetworkLayerProtocol::IPv4Protocol) { if (addr.protocol() == QAbstractSocket::NetworkLayerProtocol::IPv4Protocol) {
const QString &ip = addr.toString(); const QString &ip = addr.toString();
//qDebug() << "VpnConnection::addSitesRoutes updating site" << site << ip; // qDebug() << "VpnConnection::addSitesRoutes updating site" << site << ip;
if (!ips.contains(ip)) { if (!ips.contains(ip)) {
IpcClient::Interface()->routeAddList(gw, QStringList() << ip); IpcClient::Interface()->routeAddList(gw, QStringList() << ip);
m_settings->addVpnSite(mode, site, ip); m_settings->addVpnSite(mode, site, ip);
}
flushDns();
break;
} }
flushDns();
break;
} }
}; }
QHostInfo::lookupHost(site, this, cbResolv); };
QHostInfo::lookupHost(site, this, cbResolv);
} }
#endif #endif
} }
@ -172,8 +163,7 @@ void VpnConnection::addRoutes(const QStringList &ips)
if (connectionState() == Vpn::ConnectionState::Connected && IpcClient::Interface()) { if (connectionState() == Vpn::ConnectionState::Connected && IpcClient::Interface()) {
if (m_settings->routeMode() == Settings::VpnOnlyForwardSites) { if (m_settings->routeMode() == Settings::VpnOnlyForwardSites) {
IpcClient::Interface()->routeAddList(m_vpnProtocol->vpnGateway(), ips); IpcClient::Interface()->routeAddList(m_vpnProtocol->vpnGateway(), ips);
} } else if (m_settings->routeMode() == Settings::VpnAllExceptSites) {
else if (m_settings->routeMode() == Settings::VpnAllExceptSites) {
IpcClient::Interface()->routeAddList(m_vpnProtocol->routeGateway(), ips); IpcClient::Interface()->routeAddList(m_vpnProtocol->routeGateway(), ips);
} }
} }
@ -186,8 +176,7 @@ void VpnConnection::deleteRoutes(const QStringList &ips)
if (connectionState() == Vpn::ConnectionState::Connected && IpcClient::Interface()) { if (connectionState() == Vpn::ConnectionState::Connected && IpcClient::Interface()) {
if (m_settings->routeMode() == Settings::VpnOnlyForwardSites) { if (m_settings->routeMode() == Settings::VpnOnlyForwardSites) {
IpcClient::Interface()->routeDeleteList(vpnProtocol()->vpnGateway(), ips); IpcClient::Interface()->routeDeleteList(vpnProtocol()->vpnGateway(), ips);
} } else if (m_settings->routeMode() == Settings::VpnAllExceptSites) {
else if (m_settings->routeMode() == Settings::VpnAllExceptSites) {
IpcClient::Interface()->routeDeleteList(m_vpnProtocol->routeGateway(), ips); IpcClient::Interface()->routeDeleteList(m_vpnProtocol->routeGateway(), ips);
} }
} }
@ -197,7 +186,8 @@ void VpnConnection::deleteRoutes(const QStringList &ips)
void VpnConnection::flushDns() void VpnConnection::flushDns()
{ {
#ifdef AMNEZIA_DESKTOP #ifdef AMNEZIA_DESKTOP
if (IpcClient::Interface()) IpcClient::Interface()->flushDns(); if (IpcClient::Interface())
IpcClient::Interface()->flushDns();
#endif #endif
} }
@ -213,18 +203,22 @@ ErrorCode VpnConnection::lastError() const
QMap<Proto, QString> VpnConnection::getLastVpnConfig(const QJsonObject &containerConfig) QMap<Proto, QString> VpnConnection::getLastVpnConfig(const QJsonObject &containerConfig)
{ {
QMap<Proto, QString> configs; QMap<Proto, QString> configs;
for (Proto proto: ProtocolProps::allProtocols()) { for (Proto proto : ProtocolProps::allProtocols()) {
QString cfg = containerConfig.value(ProtocolProps::protoToString(proto)).toObject().value(config_key::last_config).toString(); QString cfg = containerConfig.value(ProtocolProps::protoToString(proto))
.toObject()
.value(config_key::last_config)
.toString();
if (!cfg.isEmpty()) configs.insert(proto, cfg); if (!cfg.isEmpty())
configs.insert(proto, cfg);
} }
return configs; return configs;
} }
QString VpnConnection::createVpnConfigurationForProto(int serverIndex, QString VpnConnection::createVpnConfigurationForProto(int serverIndex, const ServerCredentials &credentials,
const ServerCredentials &credentials, DockerContainer container, const QJsonObject &containerConfig, Proto proto, DockerContainer container, const QJsonObject &containerConfig,
ErrorCode *errorCode) Proto proto, ErrorCode *errorCode)
{ {
QMap<Proto, QString> lastVpnConfig = getLastVpnConfig(containerConfig); QMap<Proto, QString> lastVpnConfig = getLastVpnConfig(containerConfig);
@ -232,10 +226,8 @@ QString VpnConnection::createVpnConfigurationForProto(int serverIndex,
if (lastVpnConfig.contains(proto)) { if (lastVpnConfig.contains(proto)) {
configData = lastVpnConfig.value(proto); configData = lastVpnConfig.value(proto);
configData = m_configurator->processConfigWithLocalSettings(serverIndex, container, proto, configData); configData = m_configurator->processConfigWithLocalSettings(serverIndex, container, proto, configData);
} } else {
else { configData = m_configurator->genVpnProtocolConfig(credentials, container, containerConfig, proto, errorCode);
configData = m_configurator->genVpnProtocolConfig(credentials,
container, containerConfig, proto, errorCode);
if (errorCode && *errorCode) { if (errorCode && *errorCode) {
return ""; return "";
@ -246,7 +238,8 @@ QString VpnConnection::createVpnConfigurationForProto(int serverIndex,
configData = m_configurator->processConfigWithLocalSettings(serverIndex, container, proto, configData); configData = m_configurator->processConfigWithLocalSettings(serverIndex, container, proto, configData);
if (serverIndex >= 0) { if (serverIndex >= 0) {
qDebug() << "VpnConnection::createVpnConfiguration: saving config for server #" << serverIndex << container << proto; qDebug() << "VpnConnection::createVpnConfiguration: saving config for server #" << serverIndex << container
<< proto;
QJsonObject protoObject = m_settings->protocolConfig(serverIndex, container, proto); QJsonObject protoObject = m_settings->protocolConfig(serverIndex, container, proto);
protoObject.insert(config_key::last_config, configDataBeforeLocalProcessing); protoObject.insert(config_key::last_config, configDataBeforeLocalProcessing);
m_settings->setProtocolConfig(serverIndex, container, proto, protoObject); m_settings->setProtocolConfig(serverIndex, container, proto, protoObject);
@ -256,17 +249,18 @@ QString VpnConnection::createVpnConfigurationForProto(int serverIndex,
return configData; return configData;
} }
QJsonObject VpnConnection::createVpnConfiguration(int serverIndex, QJsonObject VpnConnection::createVpnConfiguration(int serverIndex, const ServerCredentials &credentials,
const ServerCredentials &credentials, DockerContainer container, DockerContainer container, const QJsonObject &containerConfig,
const QJsonObject &containerConfig, ErrorCode *errorCode) ErrorCode *errorCode)
{ {
QJsonObject vpnConfiguration; QJsonObject vpnConfiguration;
for (ProtocolEnumNS::Proto proto : ContainerProps::protocolsForContainer(container)) { for (ProtocolEnumNS::Proto proto : ContainerProps::protocolsForContainer(container)) {
QJsonObject vpnConfigData = QJsonDocument::fromJson( QJsonObject vpnConfigData =
createVpnConfigurationForProto( QJsonDocument::fromJson(createVpnConfigurationForProto(serverIndex, credentials, container,
serverIndex, credentials, container, containerConfig, proto, errorCode).toUtf8()). containerConfig, proto, errorCode)
object(); .toUtf8())
.object();
if (errorCode && *errorCode) { if (errorCode && *errorCode) {
return {}; return {};
@ -293,12 +287,14 @@ QJsonObject VpnConnection::createVpnConfiguration(int serverIndex,
return vpnConfiguration; return vpnConfiguration;
} }
void VpnConnection::connectToVpn(int serverIndex, void VpnConnection::connectToVpn(int serverIndex, const ServerCredentials &credentials, DockerContainer container,
const ServerCredentials &credentials, DockerContainer container, const QJsonObject &containerConfig) const QJsonObject &containerConfig)
{ {
qDebug() << QString("ConnectToVpn, Server index is %1, container is %2, route mode is") qDebug() << QString("ConnectToVpn, Server index is %1, container is %2, route mode is")
.arg(serverIndex).arg(ContainerProps::containerToString(container)) << m_settings->routeMode(); .arg(serverIndex)
#if !defined (Q_OS_ANDROID) && !defined (Q_OS_IOS) .arg(ContainerProps::containerToString(container))
<< m_settings->routeMode();
#if !defined(Q_OS_ANDROID) && !defined(Q_OS_IOS)
if (!m_IpcClient) { if (!m_IpcClient) {
m_IpcClient = new IpcClient(this); m_IpcClient = new IpcClient(this);
} }
@ -331,8 +327,8 @@ void VpnConnection::connectToVpn(int serverIndex,
emit connectionStateChanged(Vpn::ConnectionState::Error); emit connectionStateChanged(Vpn::ConnectionState::Error);
return; return;
} }
#if !defined (Q_OS_ANDROID) && !defined (Q_OS_IOS) #if !defined(Q_OS_ANDROID) && !defined(Q_OS_IOS)
m_vpnProtocol.reset(VpnProtocol::factory(container, m_vpnConfiguration)); m_vpnProtocol.reset(VpnProtocol::factory(container, m_vpnConfiguration));
if (!m_vpnProtocol) { if (!m_vpnProtocol) {
emit connectionStateChanged(Vpn::ConnectionState::Error); emit connectionStateChanged(Vpn::ConnectionState::Error);
@ -354,17 +350,21 @@ void VpnConnection::connectToVpn(int serverIndex,
createProtocolConnections(); createProtocolConnections();
e = m_vpnProtocol.data()->start(); e = m_vpnProtocol.data()->start();
if (e) emit connectionStateChanged(Vpn::ConnectionState::Error); if (e)
emit connectionStateChanged(Vpn::ConnectionState::Error);
} }
void VpnConnection::createProtocolConnections() { void VpnConnection::createProtocolConnections()
{
connect(m_vpnProtocol.data(), &VpnProtocol::protocolError, this, &VpnConnection::vpnProtocolError); connect(m_vpnProtocol.data(), &VpnProtocol::protocolError, this, &VpnConnection::vpnProtocolError);
connect(m_vpnProtocol.data(), SIGNAL(connectionStateChanged(Vpn::ConnectionState)), this, SLOT(onConnectionStateChanged(Vpn::ConnectionState))); connect(m_vpnProtocol.data(), SIGNAL(connectionStateChanged(Vpn::ConnectionState)), this,
SLOT(onConnectionStateChanged(Vpn::ConnectionState)));
connect(m_vpnProtocol.data(), SIGNAL(bytesChanged(quint64, quint64)), this, SLOT(onBytesChanged(quint64, quint64))); connect(m_vpnProtocol.data(), SIGNAL(bytesChanged(quint64, quint64)), this, SLOT(onBytesChanged(quint64, quint64)));
} }
#ifdef Q_OS_ANDROID #ifdef Q_OS_ANDROID
void VpnConnection::restoreConnection() { void VpnConnection::restoreConnection()
{
createAndroidConnections(); createAndroidConnections();
m_vpnProtocol.reset(androidVpnProtocol); m_vpnProtocol.reset(androidVpnProtocol);
@ -384,11 +384,13 @@ void VpnConnection::createAndroidConnections(DockerContainer container)
{ {
androidVpnProtocol = createDefaultAndroidVpnProtocol(container); androidVpnProtocol = createDefaultAndroidVpnProtocol(container);
connect(AndroidController::instance(), &AndroidController::connectionStateChanged, androidVpnProtocol, &AndroidVpnProtocol::setConnectionState); connect(AndroidController::instance(), &AndroidController::connectionStateChanged, androidVpnProtocol,
connect(AndroidController::instance(), &AndroidController::statusUpdated, androidVpnProtocol, &AndroidVpnProtocol::connectionDataUpdated); &AndroidVpnProtocol::setConnectionState);
connect(AndroidController::instance(), &AndroidController::statusUpdated, androidVpnProtocol,
&AndroidVpnProtocol::connectionDataUpdated);
} }
AndroidVpnProtocol* VpnConnection::createDefaultAndroidVpnProtocol(DockerContainer container) AndroidVpnProtocol *VpnConnection::createDefaultAndroidVpnProtocol(DockerContainer container)
{ {
Proto proto = ContainerProps::defaultProtocol(container); Proto proto = ContainerProps::defaultProtocol(container);
AndroidVpnProtocol *androidVpnProtocol = new AndroidVpnProtocol(proto, m_vpnConfiguration); AndroidVpnProtocol *androidVpnProtocol = new AndroidVpnProtocol(proto, m_vpnConfiguration);
@ -415,8 +417,6 @@ void VpnConnection::disconnectFromVpn()
} }
#endif #endif
if (!m_vpnProtocol.data()) {
emit connectionStateChanged(Vpn::ConnectionState::Disconnected);
#ifdef Q_OS_ANDROID #ifdef Q_OS_ANDROID
AndroidController::instance()->stop(); AndroidController::instance()->stop();
#endif #endif
@ -427,7 +427,7 @@ void VpnConnection::disconnectFromVpn()
#endif #endif
if (!m_vpnProtocol.data()) { if (!m_vpnProtocol.data()) {
emit connectionStateChanged(VpnProtocol::Disconnected); emit connectionStateChanged(Vpn::ConnectionState::Disconnected);
return; return;
} }
@ -439,7 +439,8 @@ void VpnConnection::disconnectFromVpn()
Vpn::ConnectionState VpnConnection::connectionState() Vpn::ConnectionState VpnConnection::connectionState()
{ {
if (!m_vpnProtocol) return Vpn::ConnectionState::Disconnected; if (!m_vpnProtocol)
return Vpn::ConnectionState::Disconnected;
return m_vpnProtocol->connectionState(); return m_vpnProtocol->connectionState();
} }