P2PoolManager: add proxy support

Author: selsta

pages/Mining.qml

@@ -309,6 +309,7 @@ Rectangle {
                                         confirmationDialog.cancelText = qsTr("No") + translationManager.emptyString;
                                         confirmationDialog.okText = qsTr("Yes") + translationManager.emptyString;
                                         confirmationDialog.onAcceptedCallback = function() {
+                                            p2poolManager.proxyAddress = persistentSettings.getProxyAddress();
                                             p2poolManager.download();
                                             statusMessageText.text = "Downloading P2Pool...";
                                             statusMessage.visible = true
@@ -652,6 +653,7 @@ allArgs = allArgs.filter( ( el ) => !defaultArgs.includes( el.split(" ")[0] ) )
             chain = "nano"
         }
         var p2poolArgs = persistentSettings.p2poolFlags;
+        p2poolManager.proxyAddress = persistentSettings.getProxyAddress();
         var success = p2poolManager.start(p2poolArgs, address, chain, threads);
         if (success) 
         {

pages/settings/SettingsLayout.qml

@@ -275,7 +275,7 @@ Rectangle {
             }
             text: qsTr("Socks5 proxy (%1%2)")
                 .arg(appWindow.walletMode >= 2 ? qsTr("remote node connections, ") : "")
-                .arg(qsTr("updates downloading, fetching price sources")) + translationManager.emptyString
+                .arg(qsTr("updates downloading, fetching price sources, P2Pool")) + translationManager.emptyString
         }
 
         MoneroComponents.RemoteNodeEdit {

src/p2pool/P2PoolManager.cpp

@@ -73,6 +73,18 @@ void P2PoolManager::download() {
         #endif
         QFile file(fileName);
         epee::net_utils::http::http_simple_client http_client;
+        QString proxyAddress;
+        {
+            QMutexLocker locker(&m_proxyMutex);
+            proxyAddress = m_proxyAddress;
+        }
+
+        if (!proxyAddress.isEmpty() && !http_client.set_proxy(proxyAddress.toStdString())) {
+            qCritical() << "Failed to set p2pool download proxy address" << proxyAddress;
+            emit p2poolDownloadFailure(ConnectionIssue);
+            return;
+        }
+
         const epee::net_utils::http::http_response_info* response = NULL;
         std::string userAgent = randomUserAgent().toStdString();
         std::chrono::milliseconds timeout = std::chrono::seconds(10);
@@ -196,6 +208,15 @@ bool P2PoolManager::start(const QString &flags, const QString &address, const QS
         arguments << "--wallet" << address;
     }
 
+    {
+        QMutexLocker locker(&m_proxyMutex);
+        if (!m_proxyAddress.isEmpty()) {
+            if (!arguments.contains("--socks5")) {
+                arguments << "--socks5" << m_proxyAddress;
+            }
+        }
+    }
+
     qDebug() << "starting p2pool " + m_p2pool;
     qDebug() << "With command line arguments " << arguments;
 
@@ -220,6 +241,25 @@ bool P2PoolManager::start(const QString &flags, const QString &address, const QS
     return true;
 }
 
+QString P2PoolManager::proxyAddress() const
+{
+    QMutexLocker locker(&m_proxyMutex);
+    return m_proxyAddress;
+}
+
+void P2PoolManager::setProxyAddress(QString address)
+{
+    {
+        QMutexLocker locker(&m_proxyMutex);
+        if (m_proxyAddress == address) {
+            return;
+        }
+        m_proxyAddress = address;
+    }
+
+    emit proxyAddressChanged();
+}
+
 void P2PoolManager::exit()
 {
     qDebug("P2PoolManager: exit()");

src/p2pool/P2PoolManager.h

@@ -41,6 +41,7 @@
 class P2PoolManager : public QObject
 {
     Q_OBJECT
+    Q_PROPERTY(QString proxyAddress READ proxyAddress WRITE setProxyAddress NOTIFY proxyAddressChanged)
 
 public:
     explicit P2PoolManager(QObject *parent = 0);
@@ -63,17 +64,22 @@ class P2PoolManager : public QObject
 private:
 
     bool running(NetworkType::Type nettype) const;
+    QString proxyAddress() const;
+    void setProxyAddress(QString address);
 signals:
     void p2poolStartFailure() const;
     void p2poolStatus(bool isMining, int hashrate) const;
     void p2poolDownloadFailure(int errorCode) const;
     void p2poolDownloadSuccess() const;
+    void proxyAddressChanged() const;
 
 private:
     std::unique_ptr<QProcess> m_p2poold;
     QMutex m_p2poolMutex;
     QString m_p2pool;
     QString m_p2poolPath;
+    QString m_proxyAddress;
+    mutable QMutex m_proxyMutex;
     bool started = false;
 
     mutable FutureScheduler m_scheduler;