Merge pull request #8 from Qv2ray/dev

QxQ · web-flow · commit 172f253c775d · 2020-07-09T23:33:11.000+08:00
diff --git a/.gitmodules b/.gitmodules
@@ -1,6 +1,6 @@
 [submodule "interface"]
 	path = interface
-	url = https://github.com/Qv2ray/QvPlugin-Host/
+	url = https://github.com/Qv2ray/QvPlugin-Interface
 [submodule "3rdparty/shadowsocksr-uvw"]
 	path = 3rdparty/shadowsocksr-uvw
 	url = https://github.com/Qv2ray/shadowsocksr-uvw
diff --git a/3rdparty/shadowsocksr-uvw b/3rdparty/shadowsocksr-uvw
@@ -1 +1 @@
-Subproject commit 857fe00910854c9a74d8d5446e9e30af6149a411
+Subproject commit 6c2f5e2bb758382a489ed3f9f444684c23c195e9
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -49,3 +49,5 @@ target_link_libraries(${PROJECT_NAME}
     Qt5::Widgets
     Qt5::Network
     ${SHADOWSOCKSR_UVW_LIBRARY})
+
+install(TARGETS ${PROJECT_NAME} DESTINATION share/qv2ray/plugins)
diff --git a/SSRPlugin.cpp b/SSRPlugin.cpp
@@ -8,9 +8,9 @@
 #include <QMetaEnum>
 namespace SSRPlugin
 {
-    std::shared_ptr<QvPluginKernel> QvSSRPlugin::GetKernel()
+    std::unique_ptr<QvPluginKernel> QvSSRPlugin::CreateKernel()
     {
-        return kernel;
+        return std::make_unique<SSRKernelInstance>();
     }
 
     std::shared_ptr<QvPluginSerializer> QvSSRPlugin::GetSerializer()
@@ -29,7 +29,6 @@ namespace SSRPlugin
         emit PluginLog("Initialize plugin.");
         this->settings = settings;
         eventHandler = std::make_shared<SSRPluginEventHandler>(this);
-        kernel = std::make_shared<SSRKernelInstance>(this);
         serializer = std::make_shared<SSRSerializer>(this);
         return true;
     }
diff --git a/SSRPlugin.hpp b/SSRPlugin.hpp
@@ -24,7 +24,7 @@ namespace SSRPlugin
         // Basic metainfo of this plugin
         const QvPluginMetadata GetMetadata() const override
         {
-            return QvPluginMetadata{
+            auto x = QvPluginMetadata{
                 "SSR Plugin",                         //
                 "Qv2ray Development Group",           //
                 "qvplugin_ssr",                       //
@@ -34,11 +34,13 @@ namespace SSRPlugin
                 { SPECIAL_TYPE_KERNEL,                //
                   SPECIAL_TYPE_SERIALIZOR }           //
             };
+            x.KernelOutboundCapabilities = { { "ShadowSocksR", "shadowsocksr" } };
+            return x;
         }
         //
         std::unique_ptr<QWidget> GetSettingsWidget() override;
         std::unique_ptr<QvPluginEditor> GetEditorWidget(UI_TYPE) override;
-        std::shared_ptr<QvPluginKernel> GetKernel() override;
+        std::unique_ptr<QvPluginKernel> CreateKernel() override;
         std::shared_ptr<QvPluginSerializer> GetSerializer() override;
         std::shared_ptr<QvPluginEventHandler> GetEventHandler() override;
         //
@@ -54,6 +56,5 @@ namespace SSRPlugin
         QJsonObject settings;
         std::shared_ptr<SSRPluginEventHandler> eventHandler;
         std::shared_ptr<SSRSerializer> serializer;
-        std::shared_ptr<SSRKernelInstance> kernel;
     };
 } // namespace SSRPlugin
diff --git a/core/kernel/SSRInstance.cpp b/core/kernel/SSRInstance.cpp
@@ -14,17 +14,25 @@ namespace SSRPlugin
     {
     }
 
-    void SSRKernelInstance::SetConnectionSettings(const QString &listenAddress, const QMap<QString, int> &inbound, const QJsonObject &settings)
+    void SSRKernelInstance::SetConnectionSettings(const QMap<KernelSetting, QVariant> &options, const QJsonObject &settings)
     {
-        this->listen_address = listenAddress;
-        socks_local_port = inbound["socks"];
-        http_local_port = inbound["http"];
-        enable_udp = inbound["enable_udp"];
+        this->listen_address = options[KERNEL_LISTEN_ADDRESS].toString();
+        socks_local_port = options[KERNEL_SOCKS_ENABLED].toBool() ? options[KERNEL_SOCKS_PORT].toInt() : 0;
+        http_local_port = options[KERNEL_HTTP_ENABLED].toBool() ? options[KERNEL_HTTP_PORT].toInt() : 0;
+        enable_udp = options[KERNEL_SOCKS_UDP_ENABLED].toBool();
         outbound.loadJson(settings);
     }
 
     bool SSRKernelInstance::StartKernel()
     {
+        if (socks_local_port == 0 && http_local_port == 0)
+        {
+            emit OnKernelCrashed("Both HTTP and SOCKS are not enabled");
+            return false;
+        }
+        // If the socks has been disabled
+        if (socks_local_port == 0)
+            socks_local_port = http_local_port + 100;
         auto remotePort = outbound.port;
         auto remote_host = outbound.address.toStdString();
         auto method = outbound.method.toStdString();
@@ -36,9 +44,7 @@ namespace SSRPlugin
         auto mode = static_cast<SSRThread::SSR_WORK_MODE>(enable_udp);
         ssrThread = std::make_unique<SSRThread>(socks_local_port,             //
                                                 remotePort,                   //
-                                                60000,
-                                                1500,
-                                                mode,
+                                                60000, 1500, mode,            //
                                                 listen_address.toStdString(), //
                                                 remote_host,                  //
                                                 method,                       //
@@ -47,7 +53,7 @@ namespace SSRPlugin
                                                 obfs_param,                   //
                                                 protocol,                     //
                                                 protocol_param);
-        ssrThread->connect(ssrThread.get(), &SSRThread::onSSRThreadLog, this, &SSRKernelInstance::OnKernelLogAvaliable);
+        ssrThread->connect(ssrThread.get(), &SSRThread::onSSRThreadLog, this, &SSRKernelInstance::OnKernelLogAvailable);
         ssrThread->connect(ssrThread.get(), &SSRThread::OnDataReady, this, &SSRKernelInstance::OnKernelStatsAvailable);
         ssrThread->start();
         if (http_local_port != 0)
diff --git a/core/kernel/SSRInstance.hpp b/core/kernel/SSRInstance.hpp
@@ -11,11 +11,7 @@ namespace SSRPlugin
         explicit SSRKernelInstance(QObject *parent = nullptr);
         bool StartKernel() override;
         bool StopKernel() override;
-        void SetConnectionSettings(const QString &listen_address, const QMap<QString, int> &inbound, const QJsonObject &settings) override;
-        const QList<Qv2rayPlugin::QvPluginOutboundProtocolObject> KernelOutboundCapabilities() const override
-        {
-            return { { "ShadowSocksR", "shadowsocksr" } };
-        }
+        void SetConnectionSettings(const QMap<KernelSetting, QVariant> &options, const QJsonObject &settings) override;
 
       private:
         int socks_local_port;
diff --git a/interface b/interface
@@ -1 +1 @@
-Subproject commit 8ec800431c7ca133e3d6fa1270a263b0e0f836c1
+Subproject commit 24d6cdeabb50cf753e23efea225f66c59f23c06e

Original file line number	Diff line number	Diff line change
`@@ -8,9 +8,9 @@`
`8`	`8`	`#include <QMetaEnum>`
`9`	`9`	`namespace SSRPlugin`
`10`	`10`	`{`
`11`		`- std::shared_ptr<QvPluginKernel> QvSSRPlugin::GetKernel()`
	`11`	`+ std::unique_ptr<QvPluginKernel> QvSSRPlugin::CreateKernel()`
`12`	`12`	`{`
`13`		`- return kernel;`
	`13`	`+ return std::make_unique<SSRKernelInstance>();`
`14`	`14`	`}`
`15`	`15`
`16`	`16`	`std::shared_ptr<QvPluginSerializer> QvSSRPlugin::GetSerializer()`
`@@ -29,7 +29,6 @@ namespace SSRPlugin`
`29`	`29`	`emit PluginLog("Initialize plugin.");`
`30`	`30`	`this->settings = settings;`
`31`	`31`	`eventHandler = std::make_shared<SSRPluginEventHandler>(this);`
`32`		`- kernel = std::make_shared<SSRKernelInstance>(this);`
`33`	`32`	`serializer = std::make_shared<SSRSerializer>(this);`
`34`	`33`	`return true;`
`35`	`34`	`}`