dns2socks integrated

.gitmodules

@@ -18,3 +18,7 @@
 	path = core/src/main/jni/fake-dlfcn
 	url = https://github.com/ssrlive/fake-dlfcn.git
 	branch = master
+[submodule "rust/dns2socks"]
+	path = rust/dns2socks
+	url = https://github.com/tun2proxy/dns2socks.git
+	branch = master

core/build.gradle

@@ -62,7 +62,7 @@ cargo {
     profile = gradle.startParameter.taskNames.any{it.toLowerCase().contains("release")} ? "release" : "debug"
     prebuiltToolchains = true
     apiLevel = 24
-    targetIncludes = ['libovertls.so', 'libtun2proxy.so']
+    targetIncludes = ['libovertls.so', 'libtun2proxy.so', 'libdns2socks.so']
 }
 
 preBuild.dependsOn "cargoBuild"

core/src/main/java/com/github/shadowsocks/bg/Dns2socks.kt

@@ -0,0 +1,21 @@
+package com.github.shadowsocks.bg
+
+object Dns2socks {
+    init {
+        System.loadLibrary("dns2socks")
+    }
+
+    @JvmStatic
+    external fun start(listen_addr: String?,
+                       dns_remote_server: String?,
+                       socks5_server: String?,
+                       username: String?,
+                       password: String?,
+                       force_tcp: Boolean,
+                       cache_records: Boolean,
+                       verbosity: Int,
+                       timeout: Int): Int
+
+    @JvmStatic
+    external fun stop(): Int
+}

core/src/main/java/com/github/shadowsocks/bg/SsrVpnService.kt

@@ -92,6 +92,10 @@ class SsrVpnService : VpnService(), BaseService.Interface {
     override fun onRevoke() = stopRunner()
 
     override fun killProcesses(scope: CoroutineScope) {
+        dns2socksThread?.terminate()
+        dns2socksThread?.join()
+        dns2socksThread = null
+
         tunThread?.terminate()
         tunThread?.join()
         tunThread = null
@@ -186,6 +190,30 @@ class SsrVpnService : VpnService(), BaseService.Interface {
         tunThread = Tun2proxyThread(proxyUrl, tunFd, tunMtu, verbose, dnsOverTcp)
         tunThread?.isDaemon = true
         tunThread?.start()
+
+        val listenAddr = "${PRIVATE_VLAN4_ROUTER}:53"
+        val dnsRemoteServer = profile.remoteDns
+        val socks5Server = "${DataStore.listenAddress}:${DataStore.portProxy}"
+        val username = null
+        val password = null
+        val forceTcp = true
+        val cacheRecords = false
+        val verbosity = if (verbose) 5 else 3
+        val timeout = 10
+
+        dns2socksThread = Dns2socksThread(
+            listenAddr,
+            dnsRemoteServer,
+            socks5Server,
+            username,
+            password,
+            forceTcp,
+            cacheRecords,
+            verbosity,
+            timeout
+        )
+        dns2socksThread?.isDaemon = true
+        dns2socksThread?.start()
     }
 
     override fun onDestroy() {
@@ -212,4 +240,36 @@ class SsrVpnService : VpnService(), BaseService.Interface {
             Tun2proxy.stop()
         }
     }
+
+    private var dns2socksThread: Dns2socksThread? = null
+
+    internal class Dns2socksThread(
+        private val listenAddr: String?,
+        private val dnsRemoteServer: String?,
+        private val socks5Server: String?,
+        private val username: String?,
+        private val password: String?,
+        private val forceTcp: Boolean,
+        private val cacheRecords: Boolean,
+        private val verbosity: Int,
+        private val timeout: Int
+    ) : Thread() {
+        override fun run() {
+            Dns2socks.start(
+                listenAddr,
+                dnsRemoteServer,
+                socks5Server,
+                username,
+                password,
+                forceTcp,
+                cacheRecords,
+                verbosity,
+                timeout
+            )
+        }
+
+        fun terminate() {
+            Dns2socks.stop()
+        }
+    }
 }

rust/Cargo.toml

@@ -1,3 +1,3 @@
 [workspace]
 resolver = "2"
-members = ["./overtls", "./tun2proxy"]
+members = ["./overtls", "./tun2proxy", "./dns2socks"]