79 lines
2.7 KiB
C++
79 lines
2.7 KiB
C++
#include "ipctun2socksprocess.h"
|
|
#include "ipc.h"
|
|
#include <QProcess>
|
|
#include <QString>
|
|
|
|
#include "../protocols/protocols_defs.h"
|
|
|
|
#ifndef Q_OS_IOS
|
|
|
|
IpcProcessTun2Socks::IpcProcessTun2Socks(QObject *parent) :
|
|
IpcProcessTun2SocksSource(parent),
|
|
m_t2sProcess(QSharedPointer<QProcess>(new QProcess()))
|
|
{
|
|
qDebug() << "IpcProcessTun2Socks::IpcProcessTun2Socks()";
|
|
|
|
}
|
|
|
|
IpcProcessTun2Socks::~IpcProcessTun2Socks()
|
|
{
|
|
qDebug() << "IpcProcessTun2Socks::~IpcProcessTun2Socks()";
|
|
}
|
|
|
|
void IpcProcessTun2Socks::start()
|
|
{
|
|
connect(m_t2sProcess.data(), &QProcess::stateChanged, this, &IpcProcessTun2Socks::stateChanged);
|
|
qDebug() << "IpcProcessTun2Socks::start()";
|
|
m_t2sProcess->setProgram(amnezia::permittedProcessPath(static_cast<amnezia::PermittedProcess>(amnezia::PermittedProcess::Tun2Socks)));
|
|
|
|
QString XrayConStr = "socks5://127.0.0.1:10808";
|
|
|
|
#ifdef Q_OS_WIN
|
|
QStringList arguments({"-device", "tun://tun2", "-proxy", XrayConStr, "-tun-post-up",
|
|
QString("cmd /c netsh interface ip set address name=\"tun2\" static %1 255.255.255.255")
|
|
.arg(amnezia::protocols::xray::defaultLocalAddr)});
|
|
#endif
|
|
#ifdef Q_OS_LINUX
|
|
QStringList arguments({"-device", "tun://tun2", "-proxy", XrayConStr});
|
|
#endif
|
|
#ifdef Q_OS_MAC
|
|
QStringList arguments({"-device", "utun22", "-proxy", XrayConStr});
|
|
#endif
|
|
|
|
m_t2sProcess->setArguments(arguments);
|
|
|
|
if (Utils::processIsRunning(Utils::executable("tun2socks", false))) {
|
|
qDebug().noquote() << "kill previos tun2socks";
|
|
Utils::killProcessByName(Utils::executable("tun2socks", false));
|
|
}
|
|
|
|
m_t2sProcess->start();
|
|
|
|
connect(m_t2sProcess.data(), &QProcess::readyReadStandardOutput, this, [this]() {
|
|
QString line = m_t2sProcess.data()->readAllStandardOutput();
|
|
if (line.contains("[STACK] tun://") && line.contains("<-> socks5://127.0.0.1")) {
|
|
emit setConnectionState(Vpn::ConnectionState::Connected);
|
|
}
|
|
});
|
|
|
|
connect(m_t2sProcess.data(), QOverload<int, QProcess::ExitStatus>::of(&QProcess::finished), this, [this](int exitCode, QProcess::ExitStatus exitStatus) {
|
|
qDebug().noquote() << "tun2socks finished, exitCode, exiStatus" << exitCode << exitStatus;
|
|
emit setConnectionState(Vpn::ConnectionState::Disconnected);
|
|
if ((exitStatus != QProcess::NormalExit) || (exitCode != 0)) {
|
|
emit setConnectionState(Vpn::ConnectionState::Error);
|
|
}
|
|
|
|
});
|
|
|
|
m_t2sProcess->start();
|
|
m_t2sProcess->waitForStarted();
|
|
}
|
|
|
|
void IpcProcessTun2Socks::stop()
|
|
{
|
|
qDebug() << "IpcProcessTun2Socks::stop()";
|
|
m_t2sProcess->disconnect();
|
|
m_t2sProcess->kill();
|
|
m_t2sProcess->waitForFinished(3000);
|
|
}
|
|
#endif
|