#include "importController.h" #include #include #include "core/errorstrings.h" namespace { enum class ConfigTypes { Amnezia, OpenVpn, WireGuard }; ConfigTypes checkConfigFormat(const QString &config) { const QString openVpnConfigPatternCli = "client"; const QString openVpnConfigPatternProto1 = "proto tcp"; const QString openVpnConfigPatternProto2 = "proto udp"; const QString openVpnConfigPatternDriver1 = "dev tun"; const QString openVpnConfigPatternDriver2 = "dev tap"; const QString wireguardConfigPatternSectionInterface = "[Interface]"; const QString wireguardConfigPatternSectionPeer = "[Peer]"; if (config.contains(openVpnConfigPatternCli) && (config.contains(openVpnConfigPatternProto1) || config.contains(openVpnConfigPatternProto2)) && (config.contains(openVpnConfigPatternDriver1) || config.contains(openVpnConfigPatternDriver2))) { return ConfigTypes::OpenVpn; } else if (config.contains(wireguardConfigPatternSectionInterface) && config.contains(wireguardConfigPatternSectionPeer)) { return ConfigTypes::WireGuard; } return ConfigTypes::Amnezia; } } // namespace ImportController::ImportController(const QSharedPointer &serversModel, const QSharedPointer &containersModel, const std::shared_ptr &settings, QObject *parent) : QObject(parent), m_serversModel(serversModel), m_containersModel(containersModel), m_settings(settings) { } void ImportController::extractConfigFromFile(const QUrl &fileUrl) { QFile file(fileUrl.toLocalFile()); if (file.open(QIODevice::ReadOnly)) { QString data = file.readAll(); auto configFormat = checkConfigFormat(data); if (configFormat == ConfigTypes::OpenVpn) { m_config = extractOpenVpnConfig(data); } else if (configFormat == ConfigTypes::WireGuard) { m_config = extractWireGuardConfig(data); } else { m_config = extractAmneziaConfig(data); } m_configFileName = QFileInfo(file.fileName()).fileName(); } } void ImportController::extractConfigFromCode(QString code) { m_config = extractAmneziaConfig(code); m_configFileName = ""; } QString ImportController::getConfig() { return QJsonDocument(m_config).toJson(QJsonDocument::Indented); } QString ImportController::getConfigFileName() { return m_configFileName; } void ImportController::importConfig() { ServerCredentials credentials; credentials.hostName = m_config.value(config_key::hostName).toString(); credentials.port = m_config.value(config_key::port).toInt(); credentials.userName = m_config.value(config_key::userName).toString(); credentials.secretData = m_config.value(config_key::password).toString(); if (credentials.isValid() || m_config.contains(config_key::containers)) { m_serversModel->addServer(m_config); if (!m_config.value(config_key::containers).toArray().isEmpty()) { m_serversModel->setDefaultServerIndex(m_serversModel->getServersCount() - 1); } emit importFinished(); } else { qDebug() << "Failed to import profile"; qDebug().noquote() << QJsonDocument(m_config).toJson(); emit importErrorOccurred(errorString(ErrorCode::ImportInvalidConfigError)); } m_config = {}; m_configFileName.clear(); } QJsonObject ImportController::extractAmneziaConfig(QString &data) { data.replace("vpn://", ""); QByteArray ba = QByteArray::fromBase64(data.toUtf8(), QByteArray::Base64UrlEncoding | QByteArray::OmitTrailingEquals); QByteArray ba_uncompressed = qUncompress(ba); if (!ba_uncompressed.isEmpty()) { ba = ba_uncompressed; } return QJsonDocument::fromJson(ba).object(); } // bool ImportController::importConnectionFromQr(const QByteArray &data) //{ // QJsonObject dataObj = QJsonDocument::fromJson(data).object(); // if (!dataObj.isEmpty()) { // return importConnection(dataObj); // } // QByteArray ba_uncompressed = qUncompress(data); // if (!ba_uncompressed.isEmpty()) { // return importConnection(QJsonDocument::fromJson(ba_uncompressed).object()); // } // return false; //} QJsonObject ImportController::extractOpenVpnConfig(const QString &data) { QJsonObject openVpnConfig; openVpnConfig[config_key::config] = data; QJsonObject lastConfig; lastConfig[config_key::last_config] = QString(QJsonDocument(openVpnConfig).toJson()); lastConfig[config_key::isThirdPartyConfig] = true; QJsonObject containers; containers.insert(config_key::container, QJsonValue("amnezia-openvpn")); containers.insert(config_key::openvpn, QJsonValue(lastConfig)); QJsonArray arr; arr.push_back(containers); QString hostName; const static QRegularExpression hostNameRegExp("remote (.*) [0-9]*"); QRegularExpressionMatch hostNameMatch = hostNameRegExp.match(data); if (hostNameMatch.hasMatch()) { hostName = hostNameMatch.captured(1); } QJsonObject config; config[config_key::containers] = arr; config[config_key::defaultContainer] = "amnezia-openvpn"; config[config_key::description] = m_settings->nextAvailableServerName(); const static QRegularExpression dnsRegExp("dhcp-option DNS (\\b\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\b)"); QRegularExpressionMatchIterator dnsMatch = dnsRegExp.globalMatch(data); if (dnsMatch.hasNext()) { config[config_key::dns1] = dnsMatch.next().captured(1); } if (dnsMatch.hasNext()) { config[config_key::dns2] = dnsMatch.next().captured(1); } config[config_key::hostName] = hostName; return config; } QJsonObject ImportController::extractWireGuardConfig(const QString &data) { QJsonObject lastConfig; lastConfig[config_key::config] = data; const static QRegularExpression hostNameAndPortRegExp("Endpoint = (.*):([0-9]*)"); QRegularExpressionMatch hostNameAndPortMatch = hostNameAndPortRegExp.match(data); QString hostName; QString port; if (hostNameAndPortMatch.hasMatch()) { hostName = hostNameAndPortMatch.captured(1); port = hostNameAndPortMatch.captured(2); } QJsonObject wireguardConfig; wireguardConfig[config_key::last_config] = QString(QJsonDocument(lastConfig).toJson()); wireguardConfig[config_key::isThirdPartyConfig] = true; wireguardConfig[config_key::port] = port; wireguardConfig[config_key::transport_proto] = "udp"; QJsonObject containers; containers.insert(config_key::container, QJsonValue("amnezia-wireguard")); containers.insert(config_key::wireguard, QJsonValue(wireguardConfig)); QJsonArray arr; arr.push_back(containers); QJsonObject config; config[config_key::containers] = arr; config[config_key::defaultContainer] = "amnezia-wireguard"; config[config_key::description] = m_settings->nextAvailableServerName(); const static QRegularExpression dnsRegExp( "DNS = " "(\\b\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\b).*(\\b\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\b)"); QRegularExpressionMatch dnsMatch = dnsRegExp.match(data); if (dnsMatch.hasMatch()) { config[config_key::dns1] = dnsMatch.captured(1); config[config_key::dns2] = dnsMatch.captured(2); } config[config_key::hostName] = hostName; return config; }