- when looking for a catch all config, only consider configs that can…

… route to the given ip
celzero · Sep 19, 2024 · f47f53f · f47f53f
1 parent f8357a8
commit f47f53f
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 7 deletions.
diff --git a/app/src/full/java/com/celzero/bravedns/service/WireguardManager.kt b/app/src/full/java/com/celzero/bravedns/service/WireguardManager.kt
@@ -495,7 +495,9 @@ object WireguardManager : KoinComponent {
             }
         }
         Logger.d(LOG_TAG_PROXY, "optimalCatchAllConfig: fetching new wgId for uid: $uid")
-        val catchAllList = mappings.filter { it.isActive && it.isCatchAll }
+        val catchAllList = mappings.filter {
+            val id = ProxyManager.ID_WG_BASE + it.id
+            it.isActive && it.isCatchAll && VpnController.canRouteIp(id, ip, false) }
         catchAllList.forEach {
             if (isProxyConnectionValid(it.id, ip)) {
                 // note the uid and wgid in a cache, so that we can use it for further requests
@@ -507,7 +509,7 @@ object WireguardManager : KoinComponent {
         // none of the catch-all has valid connection, send ping to all catch-all configs
         pingCatchAllConfigs(catchAllList)
         // return any catch-all config
-        return catchAllList.random().id
+        return catchAllList.randomOrNull()?.id
     }
 
     private fun pingCatchAllConfigs(catchAllConfigs: List<WgConfigFilesImmutable>) {
@@ -934,8 +936,10 @@ object WireguardManager : KoinComponent {
         return mappings.find { it.oneWireGuard && it.isActive }?.id
     }
 
-    suspend fun getOptimalCatchAllConfigId(): Int? {
-        val configs = mappings.filter { it.isCatchAll && it.isActive }
+    suspend fun getOptimalCatchAllConfigId(ip: String?): Int? {
+        val configs = mappings.filter {
+            val id = ProxyManager.ID_WG_BASE + it.id
+            it.isCatchAll && it.isActive && ((ip == null) || VpnController.canRouteIp(id, ip, false)) }
         configs.forEach {
             if (isValidLastOk(it.id)) {
                 Logger.d(LOG_TAG_PROXY, "found optimal catch all config: ${it.id}")
@@ -944,7 +948,7 @@ object WireguardManager : KoinComponent {
         }
         Logger.d(LOG_TAG_PROXY, "no optimal catch all config found, returning any catchall")
         // if no catch-all config is active, return any catch-all config
-        return configs.random()?.id
+        return configs.randomOrNull()?.id
     }
 
     private fun io(f: suspend () -> Unit) {

diff --git a/app/src/main/java/com/celzero/bravedns/service/BraveVPNService.kt b/app/src/main/java/com/celzero/bravedns/service/BraveVPNService.kt
@@ -3025,15 +3025,17 @@ class BraveVPNService :
                 ProxyManager.ID_WG_BASE + id
             } else if (WireguardManager.catchAllEnabled()) {
                 // if the enabled wireguard is catchall-wireguard, then return wireguard id
-                val id = WireguardManager.getOptimalCatchAllConfigId() ?: return Backend.Base
+                val endpoint = appConfig.getSelectedDnsProxyDetails()
+                val id = WireguardManager.getOptimalCatchAllConfigId(endpoint?.proxyIP) ?: return Backend.Base
                 ProxyManager.ID_WG_BASE + id
             } else {
                 // if the enabled wireguard is not one-wireguard, then return base
                 Backend.Base
             }
         } else if (WireguardManager.catchAllEnabled()) { // check even if wireguard is not enabled
             // if the enabled wireguard is catchall-wireguard, then return wireguard id
-            val id = WireguardManager.getOptimalCatchAllConfigId() ?: return Backend.Base
+            val endpoint = appConfig.getSelectedDnsProxyDetails()
+            val id = WireguardManager.getOptimalCatchAllConfigId(endpoint?.proxyIP) ?: return Backend.Base
             // in this case, no need to check if the proxy is available
             ProxyManager.ID_WG_BASE + id
         } else {