Update version

Add lightBlue theme color

Fix start unable to update profile issues

android/app/src/main/kotlin/com/follow/clash/extensions/Drawable.kt

@@ -1,17 +1,18 @@
 package com.follow.clash.extensions
 
-import java.net.InetSocketAddress
-
 import android.graphics.Bitmap
 import android.graphics.drawable.Drawable
 import android.system.OsConstants.IPPROTO_TCP
 import android.system.OsConstants.IPPROTO_UDP
 import android.util.Base64
+import java.net.URL
 import androidx.core.graphics.drawable.toBitmap
 import com.follow.clash.models.Metadata
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.withContext
 import java.io.ByteArrayOutputStream
+import java.net.InetAddress
+import java.net.InetSocketAddress
 
 
 suspend fun Drawable.getBase64(): String {
@@ -29,3 +30,8 @@ fun Metadata.getProtocol(): Int? {
     if (network.startsWith("udp")) return IPPROTO_UDP
     return null
 }
+
+fun String.getInetSocketAddress(): InetSocketAddress {
+    val url = URL("https://$this")
+    return InetSocketAddress(InetAddress.getByName(url.host), url.port)
+}

android/app/src/main/kotlin/com/follow/clash/models/Process.kt

@@ -1,11 +1,15 @@
 package com.follow.clash.models
 
+data class Process(
+    val id: Int,
+    val metadata: Metadata,
+)
+
 data class Metadata(
     val network: String,
     val sourceIP: String,
     val sourcePort: Int,
     val destinationIP: String,
     val destinationPort: Int,
-    val remoteDestination: String,
     val host: String
 )

android/app/src/main/kotlin/com/follow/clash/plugins/AppPlugin.kt

@@ -6,13 +6,16 @@ import android.content.Context
 import android.content.pm.ApplicationInfo
 import android.content.pm.PackageManager
 import android.net.ConnectivityManager
+import android.net.Uri
 import android.os.Build
 import android.widget.Toast
 import androidx.annotation.RequiresApi
 import androidx.core.content.getSystemService
+import androidx.core.graphics.drawable.toBitmap
 import com.follow.clash.extensions.getBase64
+import com.follow.clash.extensions.getInetSocketAddress
 import com.follow.clash.extensions.getProtocol
-import com.follow.clash.models.Metadata
+import com.follow.clash.models.Process
 import com.follow.clash.models.Package
 import com.google.gson.Gson
 import io.flutter.embedding.engine.plugins.FlutterPlugin
@@ -78,21 +81,34 @@ class AppPlugin : FlutterPlugin, MethodChannel.MethodCallHandler, ActivityAware
             "getPackageIcon" -> {
                 scope.launch {
                     val packageName = call.argument<String>("packageName")
-                    if (packageName != null) {
-                        result.success(getPackageIcon(packageName))
-                    } else {
+                    if (packageName == null) {
                         result.success(null)
+                        return@launch
+                    }
+                    val packageIcon = getPackageIcon(packageName)
+                    packageIcon.let {
+                        if (it != null) {
+                            result.success(it)
+                            return@launch
+                        }
+                        if (iconMap["default"] == null) {
+                            iconMap["default"] =
+                                context?.packageManager?.defaultActivityIcon?.getBase64()
+                        }
+                        result.success(iconMap["default"])
+                        return@launch
                     }
                 }
             }
 
-            "getPackageName" -> {
+            "resolverProcess" -> {
                 val data = call.argument<String>("data")
-                val metadata =
+                val process =
                     if (data != null) Gson().fromJson(
                         data,
-                        Metadata::class.java
+                        Process::class.java
                     ) else null
+                val metadata = process?.metadata
                 val protocol = metadata?.getProtocol()
                 if (protocol == null) {
                     result.success(null)
@@ -100,17 +116,27 @@ class AppPlugin : FlutterPlugin, MethodChannel.MethodCallHandler, ActivityAware
                 }
                 scope.launch {
                     withContext(Dispatchers.Default) {
-                        if (context == null) result.success(null)
-                        val source = InetSocketAddress(metadata.sourceIP, metadata.sourcePort)
-                        val target = InetSocketAddress(
-                            metadata.host.ifEmpty { metadata.destinationIP },
-                            metadata.destinationPort
-                        )
+                        if (Build.VERSION.SDK_INT < Build.VERSION_CODES.Q){
+                            result.success(null)
+                            return@withContext
+                        }
+                        if (context == null) {
+                            result.success(null)
+                            return@withContext
+                        }
                         if (connectivity == null) {
                             connectivity = context!!.getSystemService<ConnectivityManager>()
                         }
-                        val uid =
-                            connectivity?.getConnectionOwnerUid(protocol, source, target)
+                        val src = InetSocketAddress(metadata.sourceIP, metadata.sourcePort)
+                        val dst = InetSocketAddress(
+                            metadata.destinationIP.ifEmpty { metadata.host },
+                            metadata.destinationPort
+                        )
+                        val uid = try {
+                            connectivity?.getConnectionOwnerUid(protocol, src, dst)
+                        } catch (_: Exception) {
+                            null
+                        }
                         if (uid == null || uid == -1) {
                             result.success(null)
                             return@withContext
@@ -137,7 +163,12 @@ class AppPlugin : FlutterPlugin, MethodChannel.MethodCallHandler, ActivityAware
     private suspend fun getPackageIcon(packageName: String): String? {
         val packageManager = context?.packageManager
         if (iconMap[packageName] == null) {
-            iconMap[packageName] = packageManager?.getApplicationIcon(packageName)?.getBase64()
+            iconMap[packageName] = try {
+                packageManager?.getApplicationIcon(packageName)?.getBase64()
+            } catch (_: Exception) {
+                null
+            }
+
         }
         return iconMap[packageName]
     }
@@ -163,7 +194,7 @@ class AppPlugin : FlutterPlugin, MethodChannel.MethodCallHandler, ActivityAware
     }
 
     fun requestGc() {
-        channel.invokeMethod("gc",null)
+        channel.invokeMethod("gc", null)
     }
 
     override fun onAttachedToActivity(binding: ActivityPluginBinding) {

android/app/src/main/kotlin/com/follow/clash/plugins/ProxyPlugin.kt

@@ -16,7 +16,6 @@ import androidx.core.app.ActivityCompat
 import androidx.core.content.ContextCompat
 import com.follow.clash.GlobalState
 import com.follow.clash.RunState
-import com.follow.clash.models.AccessControl
 import com.follow.clash.models.Props
 import com.follow.clash.services.FlClashVpnService
 import com.google.gson.Gson

android/app/src/main/kotlin/com/follow/clash/services/FlClashTileService.kt

@@ -44,7 +44,7 @@ class FlClashTileService : TileService() {
 
     private fun activityTransfer() {
         val intent = Intent(this, TempActivity::class.java)
-        intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK)
+        intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK or Intent.FLAG_ACTIVITY_MULTIPLE_TASK)
         val pendingIntent = if (Build.VERSION.SDK_INT >= 31) {
             PendingIntent.getActivity(
                 this,

core/common.go

@@ -2,26 +2,24 @@ package main
 
 import "C"
 import (
+	"github.com/metacubex/mihomo/adapter"
 	"github.com/metacubex/mihomo/adapter/inbound"
 	ap "github.com/metacubex/mihomo/adapter/provider"
 	"github.com/metacubex/mihomo/component/dialer"
-	"github.com/metacubex/mihomo/component/process"
 	"github.com/metacubex/mihomo/component/resolver"
 	"github.com/metacubex/mihomo/config"
-	"github.com/metacubex/mihomo/constant/provider"
-	"github.com/metacubex/mihomo/dns"
+	"github.com/metacubex/mihomo/constant"
 	"github.com/metacubex/mihomo/hub"
 	"github.com/metacubex/mihomo/hub/executor"
+	"github.com/metacubex/mihomo/hub/route"
 	"github.com/metacubex/mihomo/listener"
 	"github.com/metacubex/mihomo/log"
 	"github.com/metacubex/mihomo/tunnel"
-	"math"
 	"os"
 	"os/exec"
 	"path/filepath"
 	"runtime"
 	"strings"
-	"sync"
 	"syscall"
 	"time"
 )
@@ -84,10 +82,13 @@ type Delay struct {
 }
 
 type Process struct {
-	Uid     uint32 `json:"uid"`
-	Network string `json:"network"`
-	Source  string `json:"source"`
-	Target  string `json:"target"`
+	Id       int64              `json:"id"`
+	Metadata *constant.Metadata `json:"metadata"`
+}
+
+type ProcessMapItem struct {
+	Id    int64  `json:"id"`
+	Value string `json:"value"`
 }
 
 type Now struct {
@@ -334,7 +335,7 @@ func overwriteConfig(targetConfig *config.RawConfig, patchConfig config.RawConfi
 	targetConfig.Port = 0
 	targetConfig.SocksPort = 0
 	targetConfig.MixedPort = patchConfig.MixedPort
-	targetConfig.FindProcessMode = process.FindProcessAlways
+	targetConfig.FindProcessMode = patchConfig.FindProcessMode
 	targetConfig.AllowLan = patchConfig.AllowLan
 	targetConfig.Mode = patchConfig.Mode
 	targetConfig.Tun.Enable = patchConfig.Tun.Enable
@@ -346,11 +347,11 @@ func overwriteConfig(targetConfig *config.RawConfig, patchConfig config.RawConfi
 	if targetConfig.DNS.Enable == false {
 		targetConfig.DNS = patchConfig.DNS
 	}
-	if runtime.GOOS == "android" {
-		targetConfig.DNS.NameServer = append(targetConfig.DNS.NameServer, "dhcp://"+dns.SystemDNSPlaceholder)
-	} else if runtime.GOOS == "windows" {
-		targetConfig.DNS.NameServer = append(targetConfig.DNS.NameServer, dns.SystemDNSPlaceholder)
-	}
+	//if runtime.GOOS == "android" {
+	//	targetConfig.DNS.NameServer = append(targetConfig.DNS.NameServer, "dhcp://"+dns.SystemDNSPlaceholder)
+	//} else if runtime.GOOS == "windows" {
+	//	targetConfig.DNS.NameServer = append(targetConfig.DNS.NameServer, dns.SystemDNSPlaceholder)
+	//}
 	if compatible == false {
 		targetConfig.ProxyProvider = make(map[string]map[string]any)
 		targetConfig.RuleProvider = make(map[string]map[string]any)
@@ -360,14 +361,17 @@ func overwriteConfig(targetConfig *config.RawConfig, patchConfig config.RawConfi
 
 func patchConfig(general *config.General) {
 	log.Infoln("[Apply] patch")
+	route.ReStartServer(general.ExternalController)
 	listener.SetAllowLan(general.AllowLan)
 	inbound.SetSkipAuthPrefixes(general.SkipAuthPrefixes)
 	inbound.SetAllowedIPs(general.LanAllowedIPs)
 	inbound.SetDisAllowedIPs(general.LanDisAllowedIPs)
 	listener.SetBindAddress(general.BindAddress)
 	tunnel.SetSniffing(general.Sniffing)
+	tunnel.SetFindProcessMode(general.FindProcessMode)
 	dialer.SetTcpConcurrent(general.TCPConcurrent)
 	dialer.DefaultInterface.Store(general.Interface)
+	adapter.UnifiedDelay.Store(general.UnifiedDelay)
 	listener.ReCreateHTTP(general.Port, tunnel.Tunnel)
 	listener.ReCreateSocks(general.SocksPort, tunnel.Tunnel)
 	listener.ReCreateRedir(general.RedirPort, tunnel.Tunnel)
@@ -380,31 +384,10 @@ func patchConfig(general *config.General) {
 	listener.ReCreateTuic(general.TuicServer, tunnel.Tunnel)
 	tunnel.SetMode(general.Mode)
 	log.SetLevel(general.LogLevel)
+
 	resolver.DisableIPv6 = !general.IPv6
 }
 
-const concurrentCount = math.MaxInt
-
-func hcCompatibleProvider(proxyProviders map[string]provider.ProxyProvider) {
-	wg := sync.WaitGroup{}
-	ch := make(chan struct{}, concurrentCount)
-	for _, proxyProvider := range proxyProviders {
-		proxyProvider := proxyProvider
-		if proxyProvider.VehicleType() == provider.Compatible {
-			log.Infoln("Start initial Compatible provider %s", proxyProvider.Name())
-			wg.Add(1)
-			ch <- struct{}{}
-			go func() {
-				defer func() { <-ch; wg.Done() }()
-				if err := proxyProvider.Initial(); err != nil {
-					log.Errorln("initial Compatible provider %s error: %v", proxyProvider.Name(), err)
-				}
-			}()
-		}
-
-	}
-}
-
 func applyConfig(isPatch bool) {
 	cfg, err := config.ParseRawConfig(currentConfig)
 	if err != nil {
@@ -414,6 +397,5 @@ func applyConfig(isPatch bool) {
 		patchConfig(cfg.General)
 	} else {
 		hub.UltraApplyConfig(cfg, true)
-		hcCompatibleProvider(tunnel.Providers())
 	}
 }

core/dart-bridge/message.go

@@ -12,6 +12,8 @@ const (
 	Delay   MessageType = "delay"
 	Now     MessageType = "now"
 	Process MessageType = "process"
+	Request MessageType = "request"
+	Run     MessageType = "run"
 )
 
 type Message struct {
@@ -19,11 +21,18 @@ type Message struct {
 	Data interface{} `json:"data"`
 }
 
-func (message *Message) Json() string {
-	data, _ := json.Marshal(message)
-	return string(data)
+func (message *Message) Json() (string, error) {
+	data, err := json.Marshal(message)
+	return string(data), err
 }
 
 func SendMessage(message Message) {
-	SendToPort(*Port, message.Json())
+	if Port == nil {
+		return
+	}
+	s, err := message.Json()
+	if err != nil {
+		return
+	}
+	SendToPort(*Port, s)
 }

core/hub.go

@@ -188,6 +188,21 @@ func getTraffic() *C.char {
 	return C.CString(string(data))
 }
 
+//export getTotalTraffic
+func getTotalTraffic() *C.char {
+	up, down := statistic.DefaultManager.Total()
+	traffic := map[string]int64{
+		"up":   up,
+		"down": down,
+	}
+	data, err := json.Marshal(traffic)
+	if err != nil {
+		fmt.Println("Error:", err)
+		return C.CString("")
+	}
+	return C.CString(string(data))
+}
+
 //export asyncTestDelay
 func asyncTestDelay(s *C.char, port C.longlong) {
 	i := int64(port)
@@ -404,4 +419,10 @@ func init() {
 			Data: delayData,
 		})
 	}
+	statistic.DefaultRequestNotify = func(c statistic.Tracker) {
+		bridge.SendMessage(bridge.Message{
+			Type: bridge.Request,
+			Data: c,
+		})
+	}
 }

core/log.go

@@ -18,6 +18,9 @@ func startLog() {
 	logSubscriber = log.Subscribe()
 	go func() {
 		for logData := range logSubscriber {
+			if logData.LogLevel < log.Level() {
+				continue
+			}
 			message := &bridge.Message{
 				Type: bridge.Log,
 				Data: logData,

core/process.go

@@ -1,3 +1,82 @@
 //go:build android
 
 package main
+
+import "C"
+import (
+	bridge "core/dart-bridge"
+	"encoding/json"
+	"errors"
+	"github.com/metacubex/mihomo/component/process"
+	"github.com/metacubex/mihomo/constant"
+	"sync"
+	"sync/atomic"
+	"time"
+)
+
+type ProcessMap struct {
+	m sync.Map
+}
+
+func (cm *ProcessMap) Store(key int64, value string) {
+	cm.m.Store(key, value)
+}
+
+func (cm *ProcessMap) Load(key int64) (string, bool) {
+	value, ok := cm.m.Load(key)
+	if !ok || value == nil {
+		return "", false
+	}
+	return value.(string), true
+}
+
+var counter int64 = 0
+
+var processMap ProcessMap
+
+func init() {
+	process.DefaultPackageNameResolver = func(metadata *constant.Metadata) (string, error) {
+		if metadata == nil {
+			return "", process.ErrInvalidNetwork
+		}
+		id := atomic.AddInt64(&counter, 1)
+
+		timeout := time.After(200 * time.Millisecond)
+
+		bridge.SendMessage(bridge.Message{
+			Type: bridge.Process,
+			Data: Process{
+				Id:       id,
+				Metadata: metadata,
+			},
+		})
+
+		for {
+			select {
+			case <-timeout:
+				return "", errors.New("package resolver timeout")
+			default:
+				value, exists := processMap.Load(id)
+				if exists {
+					return value, nil
+				}
+				time.Sleep(20 * time.Millisecond)
+			}
+		}
+	}
+}
+
+//export setProcessMap
+func setProcessMap(s *C.char) {
+	if s == nil {
+		return
+	}
+	go func() {
+		paramsString := C.GoString(s)
+		var processMapItem = &ProcessMapItem{}
+		err := json.Unmarshal([]byte(paramsString), processMapItem)
+		if err == nil {
+			processMap.Store(processMapItem.Id, processMapItem.Value)
+		}
+	}()
+}

core/tun.go

@@ -35,8 +35,6 @@ func startTUN(fd C.int) {
 
 		closer, err := t.Start(f, gateway, portal, dns)
 
-		applyConfig(true)
-
 		if err != nil {
 			log.Errorln("startTUN error: %v", err)
 			tempTun.Close()
@@ -48,16 +46,6 @@ func startTUN(fd C.int) {
 	}()
 }
 
-//export updateMarkSocketPort
-func updateMarkSocketPort(markSocketPort C.longlong) bool {
-	tunLock.Lock()
-	defer tunLock.Unlock()
-	//if tun != nil {
-	//	tun.MarkSocketPort = int64(markSocketPort)
-	//}
-	return true
-}
-
 //export stopTun
 func stopTun() {
 	go func() {
@@ -66,7 +54,6 @@ func stopTun() {
 
 		if tun != nil {
 			tun.Close()
-			applyConfig(true)
 			tun = nil
 		}
 	}()

lib/application.dart

@@ -82,6 +82,10 @@ class ApplicationState extends State<Application> {
     super.initState();
     globalState.appController = AppController(context);
     WidgetsBinding.instance.addPostFrameCallback((timeStamp) async {
+      final currentContext = globalState.navigatorKey.currentContext;
+      if (currentContext != null) {
+        globalState.appController = AppController(currentContext);
+      }
       await globalState.appController.init();
       globalState.appController.initLink();
       _updateGroups();

lib/clash/core.dart

@@ -46,8 +46,8 @@ class ClashCore {
 
   bool init(String homeDir) {
     return clashFFI.initClash(
-          homeDir.toNativeUtf8().cast(),
-        ) ==
+      homeDir.toNativeUtf8().cast(),
+    ) ==
         1;
   }
 
@@ -99,8 +99,9 @@ class ClashCore {
       final groupNames = [
         UsedProxy.GLOBAL.name,
         ...(proxies[UsedProxy.GLOBAL.name]["all"] as List).where((e) {
-          final proxy = proxies[e];
-          return GroupTypeExtension.valueList.contains(proxy['type']);
+          final proxy = proxies[e] ?? {};
+          return GroupTypeExtension.valueList.contains(proxy['type']) &&
+              proxy['hidden'] != true;
         })
       ];
       final groupsRaw = groupNames.map((groupName) {
@@ -108,7 +109,7 @@ class ClashCore {
         group["all"] = ((group["all"] ?? []) as List)
             .map(
               (name) => proxies[name],
-            )
+        )
             .toList();
         return group;
       }).toList();
@@ -119,14 +120,14 @@ class ClashCore {
   Future<List<ExternalProvider>> getExternalProviders() {
     final externalProvidersRaw = clashFFI.getExternalProviders();
     final externalProvidersRawString =
-        externalProvidersRaw.cast<Utf8>().toDartString();
+    externalProvidersRaw.cast<Utf8>().toDartString();
     return Isolate.run<List<ExternalProvider>>(() {
       final externalProviders =
-          (json.decode(externalProvidersRawString) as List<dynamic>)
-              .map(
-                (item) => ExternalProvider.fromJson(item),
-              )
-              .toList();
+      (json.decode(externalProvidersRawString) as List<dynamic>)
+          .map(
+            (item) => ExternalProvider.fromJson(item),
+      )
+          .toList();
       return externalProviders;
     });
   }
@@ -198,6 +199,13 @@ class ClashCore {
     return Traffic.fromMap(trafficMap);
   }
 
+
+  Traffic getTotalTraffic() {
+    final trafficRaw = clashFFI.getTotalTraffic();
+    final trafficMap = json.decode(trafficRaw.cast<Utf8>().toDartString());
+    return Traffic.fromMap(trafficMap);
+  }
+
   void startLog() {
     clashFFI.startLog();
   }
@@ -210,7 +218,7 @@ class ClashCore {
     clashFFI.startTUN(fd);
   }
 
-  requestGc(){
+  requestGc() {
     clashFFI.forceGc();
   }
 
@@ -218,10 +226,20 @@ class ClashCore {
     clashFFI.stopTun();
   }
 
+  void setProcessMap(ProcessMapItem processMapItem) {
+    clashFFI.setProcessMap(json.encode(processMapItem).toNativeUtf8().cast());
+  }
+
+  // DateTime? getRunTime() {
+  //   final runTimeString = clashFFI.getRunTime().cast<Utf8>().toDartString();
+  //   if (runTimeString.isEmpty) return null;
+  //   return DateTime.fromMillisecondsSinceEpoch(int.parse(runTimeString));
+  // }
+
   List<Connection> getConnections() {
     final connectionsDataRaw = clashFFI.getConnections();
     final connectionsData =
-        json.decode(connectionsDataRaw.cast<Utf8>().toDartString()) as Map;
+    json.decode(connectionsDataRaw.cast<Utf8>().toDartString()) as Map;
     final connectionsRaw = connectionsData['connections'] as List? ?? [];
     return connectionsRaw.map((e) => Connection.fromJson(e)).toList();
   }

lib/clash/generated/clash_ffi.dart

@@ -983,6 +983,16 @@ class ClashFFI {
   late final _getTraffic =
       _getTrafficPtr.asFunction<ffi.Pointer<ffi.Char> Function()>();
 
+  ffi.Pointer<ffi.Char> getTotalTraffic() {
+    return _getTotalTraffic();
+  }
+
+  late final _getTotalTrafficPtr =
+      _lookup<ffi.NativeFunction<ffi.Pointer<ffi.Char> Function()>>(
+          'getTotalTraffic');
+  late final _getTotalTraffic =
+      _getTotalTrafficPtr.asFunction<ffi.Pointer<ffi.Char> Function()>();
+
   void asyncTestDelay(
     ffi.Pointer<ffi.Char> s,
     int port,
@@ -1130,6 +1140,20 @@ class ClashFFI {
       _lookup<ffi.NativeFunction<ffi.Void Function()>>('stopLog');
   late final _stopLog = _stopLogPtr.asFunction<void Function()>();
 
+  void setProcessMap(
+    ffi.Pointer<ffi.Char> s,
+  ) {
+    return _setProcessMap(
+      s,
+    );
+  }
+
+  late final _setProcessMapPtr =
+      _lookup<ffi.NativeFunction<ffi.Void Function(ffi.Pointer<ffi.Char>)>>(
+          'setProcessMap');
+  late final _setProcessMap =
+      _setProcessMapPtr.asFunction<void Function(ffi.Pointer<ffi.Char>)>();
+
   void startTUN(
     int fd,
   ) {
@@ -1142,20 +1166,6 @@ class ClashFFI {
       _lookup<ffi.NativeFunction<ffi.Void Function(ffi.Int)>>('startTUN');
   late final _startTUN = _startTUNPtr.asFunction<void Function(int)>();
 
-  int updateMarkSocketPort(
-    int markSocketPort,
-  ) {
-    return _updateMarkSocketPort(
-      markSocketPort,
-    );
-  }
-
-  late final _updateMarkSocketPortPtr =
-      _lookup<ffi.NativeFunction<GoUint8 Function(ffi.LongLong)>>(
-          'updateMarkSocketPort');
-  late final _updateMarkSocketPort =
-      _updateMarkSocketPortPtr.asFunction<int Function(int)>();
-
   void stopTun() {
     return _stopTun();
   }

lib/clash/message.dart

@@ -14,9 +14,13 @@ abstract mixin class ClashMessageListener {
 
   void onDelay(Delay delay) {}
 
-  void onProcess(Metadata metadata) {}
+  void onProcess(Process process) {}
+
+  void onRequest(Connection connection) {}
 
   void onNow(Now now) {}
+
+  void onRun(String runTime) {}
 }
 
 class ClashMessage {
@@ -41,11 +45,17 @@ class ClashMessage {
             listener.onDelay(Delay.fromJson(m.data));
             break;
           case MessageType.process:
-            listener.onProcess(Metadata.fromJson(m.data));
+            listener.onProcess(Process.fromJson(m.data));
             break;
           case MessageType.now:
             listener.onNow(Now.fromJson(m.data));
             break;
+          case MessageType.request:
+            listener.onRequest(Connection.fromJson(m.data));
+            break;
+          case MessageType.run:
+            listener.onRun(m.data);
+            break;
         }
       }
     });

lib/common/android.dart

@@ -7,6 +7,7 @@ class Android {
   init() async {
     app?.onExit = () {
       clashCore.shutdown();
+      print("adsadda==>");
       exit(0);
     };
   }

lib/common/navigation.dart

@@ -29,6 +29,13 @@ class Navigation {
         label: "profiles",
         fragment: ProfilesFragment(),
       ),
+      const NavigationItem(
+        icon:  Icon(Icons.ballot),
+        label: "requests",
+        fragment:  RequestFragment(),
+        description: "requestsDesc",
+        modes: [NavigationItemMode.desktop, NavigationItemMode.more],
+      ),
       const NavigationItem(
         icon: Icon(Icons.swap_vert_circle),
         label: "resources",

lib/controller.dart

@@ -31,6 +31,7 @@ class AppController {
   Future<void> updateSystemProxy(bool isStart) async {
     if (isStart) {
       await globalState.startSystemProxy(
+        appState: appState,
         config: config,
         clashConfig: clashConfig,
       );
@@ -145,7 +146,16 @@ class AppController {
       if (isNotNeedUpdate == false || profile.type == ProfileType.file) {
         continue;
       }
-      await updateProfile(profile.id);
+      try {
+        await updateProfile(profile.id);
+      } catch (e) {
+        appState.addLog(
+          Log(
+            logLevel: LogLevel.info,
+            payload: e.toString(),
+          ),
+        );
+      }
     }
   }
 
@@ -222,20 +232,21 @@ class AppController {
       final tagName = data['tag_name'];
       final body = data['body'];
       final submits = other.parseReleaseBody(body);
+      final textTheme = context.textTheme;
       globalState.showMessage(
         title: appLocalizations.discoverNewVersion,
         message: TextSpan(
           text: "$tagName \n",
-          style: context.textTheme.headlineSmall,
+          style: textTheme.headlineSmall,
           children: [
             TextSpan(
               text: "\n",
-              style: context.textTheme.bodyMedium,
+              style: textTheme.bodyMedium,
             ),
             for (final submit in submits)
               TextSpan(
                 text: "- $submit \n",
-                style: context.textTheme.bodyMedium,
+                style: textTheme.bodyMedium,
               ),
           ],
         ),
@@ -261,15 +272,15 @@ class AppController {
       window?.show();
     }
     final commonScaffoldState = globalState.homeScaffoldKey.currentState;
-    if(commonScaffoldState?.mounted == true){
+    if (commonScaffoldState?.mounted == true) {
       await commonScaffoldState?.loadingRun(() async {
         await globalState.applyProfile(
           appState: appState,
           config: config,
           clashConfig: clashConfig,
         );
-      });
-    }else{
+      },title: appLocalizations.init);
+    } else {
       await globalState.applyProfile(
         appState: appState,
         config: config,

lib/enum/enum.dart

@@ -56,7 +56,9 @@ enum ProfileType { file, url }
 
 enum ResultType { success, error }
 
-enum MessageType { log, tun, delay, process, now }
+enum MessageType { log, tun, delay, process, now, request, run }
+
+enum FindProcessMode { always, off }
 
 enum RecoveryOption {
   all,

lib/fragments/config.dart

@@ -39,14 +39,7 @@ class _ConfigFragmentState extends State<ConfigFragment> {
     }
   }
 
-  _updateLoglevel(LogLevel? logLevel) {
-    if (logLevel == null ||
-        logLevel == globalState.appController.clashConfig.logLevel) return;
-    globalState.appController.clashConfig.logLevel = logLevel;
-    globalState.appController.updateClashConfigDebounce();
-  }
-
-  _buildAppSection() {
+  Widget _buildAppSection() {
     final items = [
       if (Platform.isAndroid)
         Selector<Config, bool>(
@@ -121,34 +114,56 @@ class _ConfigFragmentState extends State<ConfigFragment> {
     );
   }
 
-  _buildGeneralSection() {
-    final items = [
-      Padding(
-        padding: kMaterialListPadding,
-        child: Selector<ClashConfig, LogLevel>(
-          selector: (_, clashConfig) => clashConfig.logLevel,
-          builder: (_, value, __) {
-            return ListItem(
-              leading: const Icon(Icons.info_outline),
-              title: Text(appLocalizations.logLevel),
-              trailing: SizedBox(
-                height: 48,
-                child: DropdownMenu<LogLevel>(
-                  width: 124,
-                  initialSelection: value,
-                  dropdownMenuEntries: [
-                    for (final logLevel in LogLevel.values)
-                      DropdownMenuEntry<LogLevel>(
-                        value: logLevel,
-                        label: logLevel.name,
-                      )
-                  ],
-                  onSelected: _updateLoglevel,
-                ),
-              ),
-            );
-          },
+  _showLogLevelDialog(LogLevel value) {
+    globalState.showCommonDialog(
+      child: AlertDialog(
+        title: Text(appLocalizations.logLevel),
+        contentPadding: const EdgeInsets.symmetric(
+          horizontal: 8,
+          vertical: 16,
         ),
+        content: SizedBox(
+          width: 250,
+          child: Wrap(
+            children: [
+              for (final logLevel in LogLevel.values)
+                ListItem.radio(
+                  delegate: RadioDelegate<LogLevel>(
+                    value: logLevel,
+                    groupValue: value,
+                    onChanged: (LogLevel? value) {
+                      if (value == null) {
+                        return;
+                      }
+                      final appController = globalState.appController;
+                      appController.clashConfig.logLevel = value;
+                      appController.updateClashConfigDebounce();
+                      Navigator.of(context).pop();
+                    },
+                  ),
+                  title: Text(logLevel.name),
+                )
+            ],
+          ),
+        ),
+      ),
+    );
+  }
+
+  Widget _buildGeneralSection() {
+    final items = [
+      Selector<ClashConfig, LogLevel>(
+        selector: (_, clashConfig) => clashConfig.logLevel,
+        builder: (_, value, __) {
+          return ListItem(
+            leading: const Icon(Icons.info_outline),
+            title: Text(appLocalizations.logLevel),
+            subtitle: Text(value.name),
+            onTab: () {
+              _showLogLevelDialog(value);
+            },
+          );
+        },
       ),
       Selector<ClashConfig, int>(
         selector: (_, clashConfig) => clashConfig.mixedPort,
@@ -225,6 +240,26 @@ class _ConfigFragmentState extends State<ConfigFragment> {
           );
         },
       ),
+      Selector<ClashConfig, bool>(
+        selector: (_, clashConfig) =>
+            clashConfig.findProcessMode == FindProcessMode.always,
+        builder: (_, findProcess, __) {
+          return ListItem.switchItem(
+            leading: const Icon(Icons.polymer_outlined),
+            title: Text(appLocalizations.findProcessMode),
+            subtitle: Text(appLocalizations.findProcessModeDesc),
+            delegate: SwitchDelegate(
+              value: findProcess,
+              onChanged: (bool value) async {
+                final appController = globalState.appController;
+                appController.clashConfig.findProcessMode =
+                    value ? FindProcessMode.always : FindProcessMode.off;
+                appController.updateClashConfigDebounce();
+              },
+            ),
+          );
+        },
+      ),
       Selector<ClashConfig, bool>(
         selector: (_, clashConfig) => clashConfig.tcpConcurrent,
         builder: (_, tcpConcurrent, __) {
@@ -258,7 +293,7 @@ class _ConfigFragmentState extends State<ConfigFragment> {
                 appController.clashConfig.geodataLoader = value
                     ? geodataLoaderMemconservative
                     : geodataLoaderStandard;
-                appController.updateClashConfigDebounce;
+                appController.updateClashConfigDebounce();
               },
             ),
           );
@@ -277,7 +312,7 @@ class _ConfigFragmentState extends State<ConfigFragment> {
                 final appController = globalState.appController;
                 appController.clashConfig.externalController =
                     value ? defaultExternalController : '';
-                appController.updateClashConfigDebounce;
+                appController.updateClashConfigDebounce();
               },
             ),
           );
@@ -300,14 +335,56 @@ class _ConfigFragmentState extends State<ConfigFragment> {
     );
   }
 
+  Widget _buildMoreSection() {
+    final items = [
+      if (false)
+        Selector<ClashConfig, bool>(
+          selector: (_, clashConfig) => clashConfig.tun.enable,
+          builder: (_, tunEnable, __) {
+            return ListItem.switchItem(
+              leading: const Icon(
+                Icons.important_devices_outlined
+              ),
+              title: Text(appLocalizations.tun),
+              subtitle: Text(appLocalizations.tunDesc),
+              delegate: SwitchDelegate(
+                value: tunEnable,
+                onChanged: (bool value) async {
+                  final clashConfig = context.read<ClashConfig>();
+                  clashConfig.tun = Tun(enable: value);
+                  globalState.appController.updateClashConfigDebounce();
+                },
+              ),
+            );
+          },
+        ),
+    ];
+    if(items.isEmpty) return Container();
+    return Section(
+      title: appLocalizations.general,
+      child: Column(
+        children: [
+          for (final item in items) ...[
+            item,
+            if (items.last != item)
+              const Divider(
+                height: 0,
+              )
+          ]
+        ],
+      ),
+    );
+  }
+
   @override
   Widget build(BuildContext context) {
     List<Widget> items = [
       _buildAppSection(),
       _buildGeneralSection(),
+      _buildMoreSection(),
     ];
     return ListView.builder(
-      padding: const EdgeInsets.only(bottom: 16),
+      padding: const EdgeInsets.only(bottom: 32),
       itemBuilder: (_, index) {
         return Container(
           alignment: Alignment.center,

lib/fragments/connections.dart

@@ -1,140 +1,140 @@
-import 'dart:async';
-
-import 'package:fl_clash/clash/core.dart';
-import 'package:fl_clash/models/models.dart';
-import 'package:fl_clash/plugins/app.dart';
-import 'package:fl_clash/state.dart';
-import 'package:fl_clash/widgets/widgets.dart';
-import 'package:flutter/material.dart';
-
-class ConnectionsFragment extends StatefulWidget {
-  const ConnectionsFragment({super.key});
-
-  @override
-  State<ConnectionsFragment> createState() => _ConnectionsFragmentState();
-}
-
-class _ConnectionsFragmentState extends State<ConnectionsFragment> {
-  final connectionsNotifier = ValueNotifier<List<Connection>>([]);
-  Map<String, String?> idPackageNameMap = {};
-
-  Timer? timer;
-
-  @override
-  void initState() {
-    super.initState();
-    WidgetsBinding.instance.addPostFrameCallback((timeStamp) {
-      _getConnections();
-      if (timer != null) {
-        timer?.cancel();
-        timer = null;
-      }
-      timer = Timer.periodic(const Duration(seconds: 3), (timer) {
-        if (mounted) {
-          _getConnections();
-        }
-      });
-    });
-  }
-
-  _getConnections() {
-    connectionsNotifier.value = clashCore
-        .getConnections();
-  }
-
-  @override
-  void dispose() {
-    super.dispose();
-    timer?.cancel();
-    timer = null;
-  }
-
-  Future<ImageProvider?> _getPackageIconWithConnection(
-      Connection connection) async {
-    final uid = connection.metadata.uid;
-    // if(globalState.packageNameMap[uid] == null){
-    //   globalState.packageNameMap[uid] = await app?.getPackageName(connection.metadata);
-    // }
-    final packageName = globalState.packageNameMap[uid];
-    if(packageName == null) return null;
-    return await app?.getPackageIcon(packageName);
-  }
-
-  @override
-  Widget build(BuildContext context) {
-    return ValueListenableBuilder<List<Connection>>(
-      valueListenable: connectionsNotifier,
-      builder: (_, List<Connection> connections, __) {
-        if (connections.isEmpty) {
-          return const NullStatus(
-            label: "未开启代理,或者没有连接数据",
-          );
-        }
-        return ListView.separated(
-          physics: const AlwaysScrollableScrollPhysics(),
-          itemBuilder: (_, index) {
-            final connection = connections[index];
-            return ListTile(
-              titleAlignment: ListTileTitleAlignment.top,
-              leading: Container(
-                margin: const EdgeInsets.only(top: 4),
-                width: 48,
-                height: 48,
-                child: FutureBuilder<ImageProvider?>(
-                  future: _getPackageIconWithConnection(connection),
-                  builder: (_, snapshot) {
-                    if (!snapshot.hasData && snapshot.data == null) {
-                      return Container();
-                    } else {
-                      return Image(
-                        image: snapshot.data!,
-                        gaplessPlayback: true,
-                        width: 48,
-                        height: 48,
-                      );
-                    }
-                  },
-                ),
-              ),
-              contentPadding:
-                  const EdgeInsets.symmetric(vertical: 12, horizontal: 16),
-              title: Column(
-                crossAxisAlignment: CrossAxisAlignment.start,
-                children: [
-                  Text(connection.metadata.host.isNotEmpty
-                      ? connection.metadata.host
-                      : connection.metadata.destinationIP),
-                  Padding(
-                    padding: const EdgeInsets.only(
-                      top: 12,
-                    ),
-                    child: Wrap(
-                      runSpacing: 8,
-                      spacing: 8,
-                      children: [
-                        for (final chain in connection.chains)
-                          CommonChip(
-                            label: chain,
-                          ),
-                      ],
-                    ),
-                  ),
-                ],
-              ),
-              trailing: IconButton(
-                icon: const Icon(Icons.block),
-                onPressed: () {},
-              ),
-            );
-          },
-          separatorBuilder: (BuildContext context, int index) {
-            return const Divider(
-              height: 0,
-            );
-          },
-          itemCount: connections.length,
-        );
-      },
-    );
-  }
-}
+// import 'dart:async';
+//
+// import 'package:fl_clash/clash/core.dart';
+// import 'package:fl_clash/models/models.dart';
+// import 'package:fl_clash/plugins/app.dart';
+// import 'package:fl_clash/state.dart';
+// import 'package:fl_clash/widgets/widgets.dart';
+// import 'package:flutter/material.dart';
+//
+// class ConnectionsFragment extends StatefulWidget {
+//   const ConnectionsFragment({super.key});
+//
+//   @override
+//   State<ConnectionsFragment> createState() => _ConnectionsFragmentState();
+// }
+//
+// class _ConnectionsFragmentState extends State<ConnectionsFragment> {
+//   final connectionsNotifier = ValueNotifier<List<Connection>>([]);
+//   Map<String, String?> idPackageNameMap = {};
+//
+//   Timer? timer;
+//
+//   @override
+//   void initState() {
+//     super.initState();
+//     WidgetsBinding.instance.addPostFrameCallback((timeStamp) {
+//       _getConnections();
+//       if (timer != null) {
+//         timer?.cancel();
+//         timer = null;
+//       }
+//       timer = Timer.periodic(const Duration(seconds: 3), (timer) {
+//         if (mounted) {
+//           _getConnections();
+//         }
+//       });
+//     });
+//   }
+//
+//   _getConnections() {
+//     connectionsNotifier.value = clashCore
+//         .getConnections();
+//   }
+//
+//   @override
+//   void dispose() {
+//     super.dispose();
+//     timer?.cancel();
+//     timer = null;
+//   }
+//
+//   Future<ImageProvider?> _getPackageIconWithConnection(
+//       Connection connection) async {
+//     final uid = connection.metadata.uid;
+//     // if(globalState.packageNameMap[uid] == null){
+//     //   globalState.packageNameMap[uid] = await app?.getPackageName(connection.metadata);
+//     // }
+//     final packageName = globalState.packageNameMap[uid];
+//     if(packageName == null) return null;
+//     return await app?.getPackageIcon(packageName);
+//   }
+//
+//   @override
+//   Widget build(BuildContext context) {
+//     return ValueListenableBuilder<List<Connection>>(
+//       valueListenable: connectionsNotifier,
+//       builder: (_, List<Connection> connections, __) {
+//         if (connections.isEmpty) {
+//           return const NullStatus(
+//             label: "未开启代理,或者没有连接数据",
+//           );
+//         }
+//         return ListView.separated(
+//           physics: const AlwaysScrollableScrollPhysics(),
+//           itemBuilder: (_, index) {
+//             final connection = connections[index];
+//             return ListTile(
+//               titleAlignment: ListTileTitleAlignment.top,
+//               leading: Container(
+//                 margin: const EdgeInsets.only(top: 4),
+//                 width: 48,
+//                 height: 48,
+//                 child: FutureBuilder<ImageProvider?>(
+//                   future: _getPackageIconWithConnection(connection),
+//                   builder: (_, snapshot) {
+//                     if (!snapshot.hasData && snapshot.data == null) {
+//                       return Container();
+//                     } else {
+//                       return Image(
+//                         image: snapshot.data!,
+//                         gaplessPlayback: true,
+//                         width: 48,
+//                         height: 48,
+//                       );
+//                     }
+//                   },
+//                 ),
+//               ),
+//               contentPadding:
+//                   const EdgeInsets.symmetric(vertical: 12, horizontal: 16),
+//               title: Column(
+//                 crossAxisAlignment: CrossAxisAlignment.start,
+//                 children: [
+//                   Text(connection.metadata.host.isNotEmpty
+//                       ? connection.metadata.host
+//                       : connection.metadata.destinationIP),
+//                   Padding(
+//                     padding: const EdgeInsets.only(
+//                       top: 12,
+//                     ),
+//                     child: Wrap(
+//                       runSpacing: 8,
+//                       spacing: 8,
+//                       children: [
+//                         for (final chain in connection.chains)
+//                           CommonChip(
+//                             label: chain,
+//                           ),
+//                       ],
+//                     ),
+//                   ),
+//                 ],
+//               ),
+//               trailing: IconButton(
+//                 icon: const Icon(Icons.block),
+//                 onPressed: () {},
+//               ),
+//             );
+//           },
+//           separatorBuilder: (BuildContext context, int index) {
+//             return const Divider(
+//               height: 0,
+//             );
+//           },
+//           itemCount: connections.length,
+//         );
+//       },
+//     );
+//   }
+// }

lib/fragments/dashboard/network_speed.dart

@@ -21,26 +21,17 @@ class _NetworkSpeedState extends State<NetworkSpeed> {
         .asMap()
         .map(
           (index, e) => MapEntry(
-        index,
-        Point(
-          (index + initPoints.length).toDouble(),
-          e.speed.toDouble(),
-        ),
-      ),
-    )
+            index,
+            Point(
+              (index + initPoints.length).toDouble(),
+              e.speed.toDouble(),
+            ),
+          ),
+        )
         .values
         .toList();
-    var pointsRaw = [...initPoints, ...trafficPoints];
-    List<Point> points;
-    if (pointsRaw.length > 60) {
-      points = pointsRaw
-          .getRange(pointsRaw.length - 61, pointsRaw.length - 1)
-          .toList();
-    } else {
-      points = pointsRaw;
-    }
 
-    return points;
+    return [...initPoints, ...trafficPoints];
   }
 
   Traffic _getLastTraffic(List<Traffic> traffics) {
@@ -53,11 +44,10 @@ class _NetworkSpeedState extends State<NetworkSpeed> {
     required IconData iconData,
     required TrafficValue value,
   }) {
-
     final showValue = value.showValue;
     final showUnit = "${value.showUnit}/s";
     final titleLargeSoftBold =
-    Theme.of(context).textTheme.titleLarge?.toSoftBold();
+        Theme.of(context).textTheme.titleLarge?.toSoftBold();
     final bodyMedium = Theme.of(context).textTheme.bodySmall?.toLight();
     final valueText = Text(
       showValue,
@@ -121,7 +111,7 @@ class _NetworkSpeedState extends State<NetworkSpeed> {
   @override
   Widget build(BuildContext context) {
     return CommonCard(
-      info:  Info(
+      info: Info(
         label: appLocalizations.networkSpeed,
         iconData: Icons.speed,
       ),
@@ -172,4 +162,4 @@ class _NetworkSpeedState extends State<NetworkSpeed> {
       ),
     );
   }
-}
+}

lib/fragments/dashboard/traffic_usage.dart

@@ -55,21 +55,11 @@ class TrafficUsage extends StatelessWidget {
         label: appLocalizations.trafficUsage,
         iconData: Icons.data_saver_off,
       ),
-      child: Selector<AppState, List<Traffic>>(
-        selector: (_, appState) => appState.traffics,
-        builder: (_, traffics, __) {
-          final trafficTotal = traffics.isNotEmpty
-              ? traffics.reduce(
-                  (value, element) {
-                    return Traffic(
-                      up: element.up.value + value.up.value,
-                      down: element.down.value + value.down.value,
-                    );
-                  },
-                )
-              : Traffic();
-          final upTrafficValue = trafficTotal.up;
-          final downTrafficValue = trafficTotal.down;
+      child: Selector<AppState, Traffic>(
+        selector: (_, appState) => appState.totalTraffic,
+        builder: (_, totalTraffic, __) {
+          final upTotalTrafficValue = totalTraffic.up;
+          final downTotalTrafficValue = totalTraffic.down;
           return Padding(
             padding: const EdgeInsets.all(16).copyWith(top: 0),
             child: Column(
@@ -80,7 +70,7 @@ class TrafficUsage extends StatelessWidget {
                   child: getTrafficDataItem(
                     context,
                     Icons.arrow_upward,
-                    upTrafficValue,
+                    upTotalTrafficValue,
                   ),
                 ),
                 const SizedBox(
@@ -91,7 +81,7 @@ class TrafficUsage extends StatelessWidget {
                   child: getTrafficDataItem(
                     context,
                     Icons.arrow_downward,
-                    downTrafficValue,
+                    downTotalTrafficValue,
                   ),
                 ),
               ],

lib/fragments/fragments.dart

@@ -9,4 +9,5 @@ export 'config.dart';
 export 'application_setting.dart';
 export 'about.dart';
 export 'backup_and_recovery.dart';
-export 'resources.dart';
+export 'resources.dart';
+export 'requests.dart';

lib/fragments/logs.dart

@@ -1,5 +1,6 @@
 import 'dart:async';
 
+import 'package:collection/collection.dart';
 import 'package:fl_clash/common/common.dart';
 import 'package:fl_clash/enum/enum.dart';
 import 'package:fl_clash/state.dart';
@@ -22,14 +23,21 @@ class _LogsFragmentState extends State<LogsFragment> {
   @override
   void initState() {
     super.initState();
-    WidgetsBinding.instance.addPostFrameCallback((timeStamp) {
-      logsNotifier.value = context.read<AppState>().logs;
+    WidgetsBinding.instance.addPostFrameCallback((_) {
+      final appState = globalState.appController.appState;
+      logsNotifier.value = List<Log>.from(appState.logs);
       if (timer != null) {
         timer?.cancel();
         timer = null;
       }
       timer = Timer.periodic(const Duration(milliseconds: 200), (timer) {
-        logsNotifier.value = globalState.appController.appState.logs;
+        final logs = List<Log>.from(appState.logs);
+        if (!const ListEquality<Log>().equals(
+          logsNotifier.value,
+          logs,
+        )) {
+          logsNotifier.value = logs;
+        }
       });
     });
   }

lib/fragments/profiles/profiles.dart

@@ -1,5 +1,6 @@
 import 'package:fl_clash/enum/enum.dart';
 import 'package:fl_clash/fragments/profiles/edit_profile.dart';
+import 'package:fl_clash/fragments/profiles/view_profile.dart';
 import 'package:fl_clash/models/models.dart';
 import 'package:fl_clash/common/common.dart';
 import 'package:fl_clash/state.dart';
@@ -15,6 +16,7 @@ enum ProfileActions {
   edit,
   update,
   delete,
+  view,
 }
 
 class ProfilesFragment extends StatefulWidget {
@@ -198,6 +200,16 @@ class _ProfileItemState extends State<ProfileItem> {
     );
   }
 
+  _handleViewProfile(Profile profile) {
+    Navigator.of(context).push(
+      MaterialPageRoute(
+        builder: (context) => ViewProfile(
+          profile: profile.copyWith(),
+        ),
+      ),
+    );
+  }
+
   _buildTitle(Profile profile) {
     final textTheme = context.textTheme;
     final userInfo = profile.userInfo ?? UserInfo();
@@ -207,7 +219,7 @@ class _ProfileItemState extends State<ProfileItem> {
     final totalShow = TrafficValue(value: total).show;
     final progress = total == 0 ? 0.0 : use / total;
     final expireShow = userInfo.expire == 0
-        ? "长期有效"
+        ? appLocalizations.infiniteTime
         : DateTime.fromMillisecondsSinceEpoch(userInfo.expire * 1000).show;
     return Container(
       padding: const EdgeInsets.symmetric(vertical: 4),
@@ -255,7 +267,7 @@ class _ProfileItemState extends State<ProfileItem> {
               Row(
                 children: [
                   Text(
-                    "到期时间:",
+                    appLocalizations.expirationTime,
                     style: textTheme.labelMedium?.toLighter(),
                   ),
                   const SizedBox(
@@ -316,6 +328,11 @@ class _ProfileItemState extends State<ProfileItem> {
               label: appLocalizations.delete,
               iconData: Icons.delete,
             ),
+            // CommonPopupMenuItem(
+            //   action: ProfileActions.view,
+            //   label: "查看",
+            //   iconData: Icons.visibility,
+            // ),
           ],
           onSelected: (ProfileActions? action) async {
             switch (action) {
@@ -328,6 +345,9 @@ class _ProfileItemState extends State<ProfileItem> {
               case ProfileActions.update:
                 _handleUpdateProfile(profile.id);
                 break;
+              case ProfileActions.view:
+                _handleViewProfile(profile);
+                break;
               case null:
                 break;
             }

lib/fragments/profiles/view_profile.dart

@@ -0,0 +1,171 @@
+import 'dart:io';
+
+import 'package:fl_clash/common/common.dart';
+import 'package:fl_clash/models/models.dart';
+import 'package:fl_clash/widgets/scaffold.dart';
+import 'package:flutter/material.dart';
+import 'package:re_editor/re_editor.dart';
+import 'package:re_highlight/languages/yaml.dart';
+import 'package:re_highlight/styles/intellij-light.dart';
+
+class ViewProfile extends StatefulWidget {
+  final Profile profile;
+
+  const ViewProfile({
+    super.key,
+    required this.profile,
+  });
+
+  @override
+  State<ViewProfile> createState() => _ViewProfileState();
+}
+
+class _ViewProfileState extends State<ViewProfile> {
+  bool readOnly = true;
+  final controller = CodeLineEditingController();
+
+  @override
+  void initState() {
+    super.initState();
+    WidgetsBinding.instance.addPostFrameCallback((_) async {
+      final profilePath = await appPath.getProfilePath(widget.profile.id);
+      if (profilePath == null) {
+        return;
+      }
+      final file = File(profilePath);
+      final text = await file.readAsString();
+      controller.text = text;
+      // _codeController.text = text;
+    });
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return CommonScaffold(
+      actions: [
+        IconButton(
+          onPressed: controller.undo,
+          icon: const Icon(Icons.undo),
+        ),
+        IconButton(
+          onPressed: controller.redo,
+          icon: const Icon(Icons.redo),
+        ),
+        const SizedBox(
+          width: 8,
+        )
+      ],
+      body: CodeEditor(
+        autofocus: false,
+        readOnly: readOnly,
+        scrollbarBuilder: (context, child, details) {
+          return Scrollbar(
+            controller: details.controller,
+            thumbVisibility: true,
+            interactive: true,
+            child: child,
+          );
+        },
+        showCursorWhenReadOnly: false,
+        controller: controller,
+        toolbarController: const ContextMenuControllerImpl(),
+        shortcutsActivatorsBuilder:
+            const DefaultCodeShortcutsActivatorsBuilder(),
+        indicatorBuilder:
+            (context, editingController, chunkController, notifier) {
+          return Row(
+            children: [
+              DefaultCodeLineNumber(
+                controller: editingController,
+                notifier: notifier,
+              ),
+              DefaultCodeChunkIndicator(
+                width: 20,
+                controller: chunkController,
+                notifier: notifier,
+              )
+            ],
+          );
+        },
+        style: CodeEditorStyle(
+          fontSize: 14,
+          codeTheme: CodeHighlightTheme(
+            languages: {
+              'yaml': CodeHighlightThemeMode(
+                mode: langYaml,
+              )
+            },
+            theme: intellijLightTheme,
+          ),
+        ),
+      ),
+      title: "查看",
+      floatingActionButton: FloatingActionButton(
+        onPressed: () {
+          setState(() {
+            readOnly = !readOnly;
+          });
+        },
+        child: readOnly ? const Icon(Icons.edit) : const Icon(Icons.save),
+      ),
+    );
+  }
+}
+
+class ContextMenuItemWidget extends PopupMenuItem<void> {
+  ContextMenuItemWidget({
+    super.key,
+    required String text,
+    required VoidCallback super.onTap,
+  }) : super(child: Text(text));
+}
+
+class ContextMenuControllerImpl implements SelectionToolbarController {
+  const ContextMenuControllerImpl();
+
+  @override
+  void hide(BuildContext context) {}
+
+  @override
+  void show({
+    required BuildContext context,
+    required CodeLineEditingController controller,
+    required TextSelectionToolbarAnchors anchors,
+    Rect? renderRect,
+    required LayerLink layerLink,
+    required ValueNotifier<bool> visibility,
+  }) {
+    if (controller.selectedText.isEmpty) {
+      return;
+    }
+    showMenu(
+      context: context,
+      popUpAnimationStyle: AnimationStyle.noAnimation,
+      position: RelativeRect.fromSize(
+        (anchors.secondaryAnchor ?? anchors.primaryAnchor) &
+            const Size(150, double.infinity),
+        MediaQuery.of(context).size,
+      ),
+      items: [
+        ContextMenuItemWidget(
+          text: 'Cut',
+          onTap: () {
+            controller.cut();
+          },
+        ),
+        ContextMenuItemWidget(
+          text: 'Copy',
+          onTap: () {
+            controller.copy();
+          },
+        ),
+        ContextMenuItemWidget(
+          text: 'Paste',
+          onTap: () {
+            controller.paste();
+          },
+        ),
+      ],
+    );
+  }
+}

lib/fragments/proxies.dart

@@ -1,3 +1,4 @@
+import 'package:collection/collection.dart';
 import 'package:fl_clash/clash/clash.dart';
 import 'package:fl_clash/state.dart';
 import 'package:flutter/material.dart';
@@ -59,6 +60,23 @@ class _ProxiesFragmentState extends State<ProxiesFragment>
     });
   }
 
+  _handleTabControllerChange() {
+    final indexIsChanging = _tabController?.indexIsChanging ?? false;
+    if (indexIsChanging) return;
+    final index = _tabController?.index;
+    if (index == null) return;
+    final appController = globalState.appController;
+    final currentGroups = appController.appState.currentGroups;
+    if (currentGroups.length > index) {
+      appController.config.updateCurrentGroupName(currentGroups[index].name);
+    }
+  }
+  @override
+  void dispose() {
+    super.dispose();
+    _tabController?.dispose();
+  }
+
   @override
   Widget build(BuildContext context) {
     return Selector<AppState, bool>(
@@ -69,26 +87,34 @@ class _ProxiesFragmentState extends State<ProxiesFragment>
         }
         return child!;
       },
-      child: Selector3<AppState, Config, ClashConfig, ProxiesSelectorState>(
-        selector: (_, appState, config, clashConfig) {
+      child: Selector2<AppState, Config, ProxiesSelectorState>(
+        selector: (_, appState, config) {
           final currentGroups = appState.currentGroups;
           final groupNames = currentGroups.map((e) => e.name).toList();
           return ProxiesSelectorState(
             groupNames: groupNames,
+            currentGroupName: config.currentGroupName,
           );
         },
         shouldRebuild: (prev, next) {
-          if (prev.groupNames.length != next.groupNames.length) {
+          if (!const ListEquality<String>()
+              .equals(prev.groupNames, next.groupNames)) {
+            _tabController?.removeListener(_handleTabControllerChange);
             _tabController?.dispose();
             _tabController = null;
+            return true;
           }
-          return prev != next;
+          return false;
         },
         builder: (_, state, __) {
+          final index = state.groupNames.indexWhere(
+            (item) => item == state.currentGroupName,
+          );
           _tabController ??= TabController(
             length: state.groupNames.length,
+            initialIndex: index == -1 ? 0 : index,
             vsync: this,
-          );
+          )..addListener(_handleTabControllerChange);
           return Column(
             mainAxisAlignment: MainAxisAlignment.start,
             crossAxisAlignment: CrossAxisAlignment.start,
@@ -99,7 +125,8 @@ class _ProxiesFragmentState extends State<ProxiesFragment>
                 dividerColor: Colors.transparent,
                 isScrollable: true,
                 tabAlignment: TabAlignment.start,
-                overlayColor: const WidgetStatePropertyAll(Colors.transparent),
+                overlayColor:
+                const WidgetStatePropertyAll(Colors.transparent),
                 tabs: [
                   for (final groupName in state.groupNames)
                     Tab(
@@ -200,7 +227,8 @@ class ProxiesTabView extends StatelessWidget {
   _delayTest(List<Proxy> proxies) async {
     for (final proxy in proxies) {
       final appController = globalState.appController;
-      final proxyName = appController.appState.getRealProxyName(proxy.name) ?? proxy.name;
+      final proxyName =
+          appController.appState.getRealProxyName(proxy.name) ?? proxy.name;
       globalState.appController.setDelay(
         Delay(
           name: proxyName,

lib/fragments/requests.dart

@@ -0,0 +1,178 @@
+import 'dart:async';
+import 'dart:io';
+
+import 'package:collection/collection.dart';
+import 'package:fl_clash/common/common.dart';
+import 'package:fl_clash/models/models.dart';
+import 'package:fl_clash/plugins/app.dart';
+import 'package:fl_clash/state.dart';
+import 'package:fl_clash/widgets/widgets.dart';
+import 'package:flutter/material.dart';
+
+class RequestFragment extends StatefulWidget {
+  const RequestFragment({super.key});
+
+  @override
+  State<RequestFragment> createState() => _RequestFragmentState();
+}
+
+class _RequestFragmentState extends State<RequestFragment> {
+  final requestsNotifier = ValueNotifier<List<Connection>>([]);
+  final ScrollController _scrollController = ScrollController(
+    keepScrollOffset: false,
+  );
+
+  Timer? timer;
+
+  @override
+  void initState() {
+    super.initState();
+    WidgetsBinding.instance.addPostFrameCallback((_) {
+      final appState = globalState.appController.appState;
+      requestsNotifier.value = List<Connection>.from(appState.requests);
+      if (timer != null) {
+        timer?.cancel();
+        timer = null;
+      }
+      timer = Timer.periodic(const Duration(milliseconds: 200), (timer) {
+        final requests = List<Connection>.from(appState.requests);
+        if (!const ListEquality<Connection>().equals(
+          requestsNotifier.value,
+          requests,
+        )) {
+          requestsNotifier.value = requests;
+        }
+      });
+    });
+  }
+
+  @override
+  void dispose() {
+    super.dispose();
+    timer?.cancel();
+    _scrollController.dispose();
+    timer = null;
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return ValueListenableBuilder<List<Connection>>(
+      valueListenable: requestsNotifier,
+      builder: (_, List<Connection> connections, __) {
+        if (connections.isEmpty) {
+          return NullStatus(
+            label: appLocalizations.nullRequestsDesc,
+          );
+        }
+        connections = connections.reversed.toList();
+        return ListView.separated(
+          controller: _scrollController,
+          itemBuilder: (_, index) {
+            final connection = connections[index];
+            return RequestItem(
+              key: Key(connection.id),
+              connection: connection,
+            );
+          },
+          separatorBuilder: (BuildContext context, int index) {
+            return const Divider(
+              height: 0,
+            );
+          },
+          itemCount: connections.length,
+        );
+      },
+    );
+  }
+}
+
+class RequestItem extends StatelessWidget {
+  final Connection connection;
+
+  const RequestItem({
+    super.key,
+    required this.connection,
+  });
+
+  Future<ImageProvider?> _getPackageIcon(Connection connection) async {
+    return await app?.getPackageIcon(connection.metadata.process);
+  }
+
+  String _getRequestText(Metadata metadata) {
+    var text = "${metadata.network}:://";
+    final ips = [
+      metadata.host,
+      metadata.destinationIP,
+    ].where((ip) => ip.isNotEmpty);
+    text += ips.join("/");
+    text += ":${metadata.destinationPort}";
+    return text;
+  }
+
+  String _getSourceText(Connection connection) {
+    final metadata = connection.metadata;
+    if (metadata.process.isEmpty) {
+      return connection.start.lastUpdateTimeDesc;
+    }
+    return "${metadata.process} · ${connection.start.lastUpdateTimeDesc}";
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return ListTile(
+      titleAlignment: ListTileTitleAlignment.top,
+      leading: Platform.isAndroid
+          ? Container(
+              margin: const EdgeInsets.only(top: 4),
+              width: 48,
+              height: 48,
+              child: FutureBuilder<ImageProvider?>(
+                future: _getPackageIcon(connection),
+                builder: (_, snapshot) {
+                  if (!snapshot.hasData && snapshot.data == null) {
+                    return Container();
+                  } else {
+                    return Image(
+                      image: snapshot.data!,
+                      gaplessPlayback: true,
+                      width: 48,
+                      height: 48,
+                    );
+                  }
+                },
+              ),
+            )
+          : null,
+      title: Text(
+        _getRequestText(connection.metadata),
+      ),
+      subtitle: Column(
+        crossAxisAlignment: CrossAxisAlignment.start,
+        children: [
+          const SizedBox(
+            height: 12,
+          ),
+          Text(
+            _getSourceText(connection),
+          ),
+          const SizedBox(
+            height: 12,
+          ),
+          Wrap(
+            runSpacing: 8,
+            spacing: 8,
+            children: [
+              for (final chain in connection.chains)
+                CommonChip(
+                  label: chain,
+                ),
+            ],
+          ),
+          const SizedBox(
+            height: 12,
+          ),
+        ],
+      ),
+    );
+  }
+}

lib/fragments/theme.dart

@@ -111,9 +111,10 @@ class ThemeFragment extends StatelessWidget {
       null,
       defaultPrimaryColor,
       Colors.pinkAccent,
+      Colors.lightBlue,
       Colors.greenAccent,
       Colors.yellowAccent,
-      Colors.purple
+      Colors.purple,
     ];
     return Column(
       children: [

lib/l10n/arb/intl_en.arb

@@ -176,5 +176,13 @@
   "tcpConcurrent": "Tcp concurrent",
   "tcpConcurrentDesc": "Enabling it will allow tcp concurrency",
   "geodataLoader": "Geo Low Memory Mode",
-  "geodataLoaderDesc": "Enabling will use the Geo low memory loader"
+  "geodataLoaderDesc": "Enabling will use the Geo low memory loader",
+  "requests": "Requests",
+  "requestsDesc": "View recently requested data",
+  "nullRequestsDesc": "No proxy or no request",
+  "findProcessMode": "Find process",
+  "findProcessModeDesc": "There is a risk of flashback after opening",
+  "init": "Init",
+  "infiniteTime": "Long term effective",
+  "expirationTime": "Expiration time"
 }

lib/l10n/arb/intl_zh_CN.arb

@@ -176,5 +176,13 @@
   "tcpConcurrent": "TCP并发",
   "tcpConcurrentDesc": "开启后允许tcp并发",
   "geodataLoader": "Geo低内存模式",
-  "geodataLoaderDesc": "开启将使用Geo低内存加载器"
+  "geodataLoaderDesc": "开启将使用Geo低内存加载器",
+  "requests": "请求",
+  "requestsDesc": "查看最近请求数据",
+  "nullRequestsDesc": "未开启代理或者没有请求",
+  "findProcessMode": "查找进程",
+  "findProcessModeDesc": "开启后存在闪退风险",
+  "init": "初始化",
+  "infiniteTime": "长期有效",
+  "expirationTime": "到期时间"
 }

lib/l10n/intl/messages_en.dart

@@ -117,6 +117,8 @@ class MessageLookup extends MessageLookupByLibrary {
         "edit": MessageLookupByLibrary.simpleMessage("Edit"),
         "en": MessageLookupByLibrary.simpleMessage("English"),
         "exit": MessageLookupByLibrary.simpleMessage("Exit"),
+        "expirationTime":
+            MessageLookupByLibrary.simpleMessage("Expiration time"),
         "externalController":
             MessageLookupByLibrary.simpleMessage("ExternalController"),
         "externalControllerDesc": MessageLookupByLibrary.simpleMessage(
@@ -128,6 +130,9 @@ class MessageLookup extends MessageLookupByLibrary {
             MessageLookupByLibrary.simpleMessage("Directly upload profile"),
         "filterSystemApp":
             MessageLookupByLibrary.simpleMessage("Filter system app"),
+        "findProcessMode": MessageLookupByLibrary.simpleMessage("Find process"),
+        "findProcessModeDesc": MessageLookupByLibrary.simpleMessage(
+            "There is a risk of flashback after opening"),
         "general": MessageLookupByLibrary.simpleMessage("General"),
         "geoData": MessageLookupByLibrary.simpleMessage("GeoData"),
         "geodataLoader":
@@ -139,6 +144,9 @@ class MessageLookup extends MessageLookupByLibrary {
         "hours": MessageLookupByLibrary.simpleMessage("Hours"),
         "importFromURL":
             MessageLookupByLibrary.simpleMessage("Import from URL"),
+        "infiniteTime":
+            MessageLookupByLibrary.simpleMessage("Long term effective"),
+        "init": MessageLookupByLibrary.simpleMessage("Init"),
         "ipCheckTimeout":
             MessageLookupByLibrary.simpleMessage("Ip check timeout"),
         "ipv6Desc": MessageLookupByLibrary.simpleMessage(
@@ -176,6 +184,8 @@ class MessageLookup extends MessageLookupByLibrary {
         "nullLogsDesc": MessageLookupByLibrary.simpleMessage("No logs"),
         "nullProfileDesc": MessageLookupByLibrary.simpleMessage(
             "No profile, Please add a profile"),
+        "nullRequestsDesc":
+            MessageLookupByLibrary.simpleMessage("No proxy or no request"),
         "other": MessageLookupByLibrary.simpleMessage("Other"),
         "outboundMode": MessageLookupByLibrary.simpleMessage("Outbound mode"),
         "override": MessageLookupByLibrary.simpleMessage("Override"),
@@ -225,6 +235,9 @@ class MessageLookup extends MessageLookupByLibrary {
             MessageLookupByLibrary.simpleMessage("Only recovery profiles"),
         "recoverySuccess":
             MessageLookupByLibrary.simpleMessage("Recovery success"),
+        "requests": MessageLookupByLibrary.simpleMessage("Requests"),
+        "requestsDesc": MessageLookupByLibrary.simpleMessage(
+            "View recently requested data"),
         "resources": MessageLookupByLibrary.simpleMessage("Resources"),
         "resourcesDesc": MessageLookupByLibrary.simpleMessage(
             "External resource related info"),

lib/l10n/intl/messages_zh_CN.dart

@@ -97,6 +97,7 @@ class MessageLookup extends MessageLookupByLibrary {
         "edit": MessageLookupByLibrary.simpleMessage("编辑"),
         "en": MessageLookupByLibrary.simpleMessage("英语"),
         "exit": MessageLookupByLibrary.simpleMessage("退出"),
+        "expirationTime": MessageLookupByLibrary.simpleMessage("到期时间"),
         "externalController": MessageLookupByLibrary.simpleMessage("外部控制器"),
         "externalControllerDesc":
             MessageLookupByLibrary.simpleMessage("开启后将可以通过9090端口控制clash内核"),
@@ -104,6 +105,9 @@ class MessageLookup extends MessageLookupByLibrary {
         "file": MessageLookupByLibrary.simpleMessage("文件"),
         "fileDesc": MessageLookupByLibrary.simpleMessage("直接上传配置文件"),
         "filterSystemApp": MessageLookupByLibrary.simpleMessage("过滤系统应用"),
+        "findProcessMode": MessageLookupByLibrary.simpleMessage("查找进程"),
+        "findProcessModeDesc":
+            MessageLookupByLibrary.simpleMessage("开启后存在闪退风险"),
         "general": MessageLookupByLibrary.simpleMessage("基础"),
         "geoData": MessageLookupByLibrary.simpleMessage("地理数据"),
         "geodataLoader": MessageLookupByLibrary.simpleMessage("Geo低内存模式"),
@@ -113,6 +117,8 @@ class MessageLookup extends MessageLookupByLibrary {
         "goDownload": MessageLookupByLibrary.simpleMessage("前往下载"),
         "hours": MessageLookupByLibrary.simpleMessage("小时"),
         "importFromURL": MessageLookupByLibrary.simpleMessage("从URL导入"),
+        "infiniteTime": MessageLookupByLibrary.simpleMessage("长期有效"),
+        "init": MessageLookupByLibrary.simpleMessage("初始化"),
         "ipCheckTimeout": MessageLookupByLibrary.simpleMessage("Ip检测超时"),
         "ipv6Desc": MessageLookupByLibrary.simpleMessage("开启后将可以接收ipv6流量"),
         "just": MessageLookupByLibrary.simpleMessage("刚刚"),
@@ -143,6 +149,7 @@ class MessageLookup extends MessageLookupByLibrary {
         "nullLogsDesc": MessageLookupByLibrary.simpleMessage("暂无日志"),
         "nullProfileDesc":
             MessageLookupByLibrary.simpleMessage("没有配置文件,请先添加配置文件"),
+        "nullRequestsDesc": MessageLookupByLibrary.simpleMessage("未开启代理或者没有请求"),
         "other": MessageLookupByLibrary.simpleMessage("其他"),
         "outboundMode": MessageLookupByLibrary.simpleMessage("出站模式"),
         "override": MessageLookupByLibrary.simpleMessage("覆写"),
@@ -180,6 +187,8 @@ class MessageLookup extends MessageLookupByLibrary {
         "recoveryDesc": MessageLookupByLibrary.simpleMessage("从WebDAV恢复数据"),
         "recoveryProfiles": MessageLookupByLibrary.simpleMessage("仅恢复配置文件"),
         "recoverySuccess": MessageLookupByLibrary.simpleMessage("恢复成功"),
+        "requests": MessageLookupByLibrary.simpleMessage("请求"),
+        "requestsDesc": MessageLookupByLibrary.simpleMessage("查看最近请求数据"),
         "resources": MessageLookupByLibrary.simpleMessage("资源"),
         "resourcesDesc": MessageLookupByLibrary.simpleMessage("外部资源相关信息"),
         "rule": MessageLookupByLibrary.simpleMessage("规则"),

lib/l10n/l10n.dart

@@ -1829,6 +1829,86 @@ class AppLocalizations {
       args: [],
     );
   }
+
+  /// `Requests`
+  String get requests {
+    return Intl.message(
+      'Requests',
+      name: 'requests',
+      desc: '',
+      args: [],
+    );
+  }
+
+  /// `View recently requested data`
+  String get requestsDesc {
+    return Intl.message(
+      'View recently requested data',
+      name: 'requestsDesc',
+      desc: '',
+      args: [],
+    );
+  }
+
+  /// `No proxy or no request`
+  String get nullRequestsDesc {
+    return Intl.message(
+      'No proxy or no request',
+      name: 'nullRequestsDesc',
+      desc: '',
+      args: [],
+    );
+  }
+
+  /// `Find process`
+  String get findProcessMode {
+    return Intl.message(
+      'Find process',
+      name: 'findProcessMode',
+      desc: '',
+      args: [],
+    );
+  }
+
+  /// `There is a risk of flashback after opening`
+  String get findProcessModeDesc {
+    return Intl.message(
+      'There is a risk of flashback after opening',
+      name: 'findProcessModeDesc',
+      desc: '',
+      args: [],
+    );
+  }
+
+  /// `Init`
+  String get init {
+    return Intl.message(
+      'Init',
+      name: 'init',
+      desc: '',
+      args: [],
+    );
+  }
+
+  /// `Long term effective`
+  String get infiniteTime {
+    return Intl.message(
+      'Long term effective',
+      name: 'infiniteTime',
+      desc: '',
+      args: [],
+    );
+  }
+
+  /// `Expiration time`
+  String get expirationTime {
+    return Intl.message(
+      'Expiration time',
+      name: 'expirationTime',
+      desc: '',
+      args: [],
+    );
+  }
 }
 
 class AppLocalizationDelegate extends LocalizationsDelegate<AppLocalizations> {

lib/main.dart

@@ -31,7 +31,6 @@ Future<void> main() async {
     config: config,
     clashConfig: clashConfig,
   );
-
   runAppWithPreferences(
     const Application(),
     appState: appState,
@@ -55,21 +54,18 @@ Future<void> vpnService() async {
       int.parse(fd),
     );
   }));
+
   await globalState.init(
     appState: appState,
     config: config,
     clashConfig: clashConfig,
   );
 
-  if (appState.isInit) {
-    await globalState.applyProfile(
-      appState: appState,
-      config: config,
-      clashConfig: clashConfig,
-    );
-  } else {
-    exit(0);
-  }
+  await globalState.applyProfile(
+    appState: appState,
+    config: config,
+    clashConfig: clashConfig,
+  );
 
   final appLocalizations = await AppLocalizations.load(
     other.getLocaleForString(config.locale) ??
@@ -79,6 +75,7 @@ Future<void> vpnService() async {
   handleStart() async {
     await app?.tip(appLocalizations.startVpn);
     await globalState.startSystemProxy(
+      appState: appState,
       config: config,
       clashConfig: clashConfig,
     );
@@ -90,19 +87,18 @@ Future<void> vpnService() async {
     ];
   }
 
-  if (appState.isInit) {
-    handleStart();
-    tile?.addListener(
-      TileListenerWithVpn(
-        onStop: () async {
-          await app?.tip(appLocalizations.stopVpn);
-          await globalState.stopSystemProxy();
-          clashCore.shutdown();
-          exit(0);
-        },
-      ),
-    );
-  }
+  handleStart();
+
+  tile?.addListener(
+    TileListenerWithVpn(
+      onStop: () async {
+        await app?.tip(appLocalizations.stopVpn);
+        await globalState.stopSystemProxy();
+        clashCore.shutdown();
+        exit(0);
+      },
+    ),
+  );
 }
 
 class ClashMessageListenerWithVpn with ClashMessageListener {

lib/models/app.dart

@@ -1,7 +1,10 @@
+import 'dart:io';
+
 import 'package:collection/collection.dart';
 import 'package:fl_clash/common/common.dart';
 import 'package:fl_clash/enum/enum.dart';
 import 'package:flutter/material.dart';
+import 'connection.dart';
 import 'ffi.dart';
 import 'log.dart';
 import 'navigation.dart';
@@ -19,6 +22,7 @@ class AppState with ChangeNotifier {
   bool _isInit;
   VersionInfo? _versionInfo;
   List<Traffic> _traffics;
+  Traffic _totalTraffic;
   List<Log> _logs;
   String _currentLabel;
   SystemColorSchemes _systemColorSchemes;
@@ -29,6 +33,7 @@ class AppState with ChangeNotifier {
   bool _isCompatible;
   List<Group> _groups;
   double _viewWidth;
+  List<Connection> _requests;
 
   AppState({
     required Mode mode,
@@ -42,7 +47,9 @@ class AppState with ChangeNotifier {
         _viewWidth = 0,
         _selectedMap = selectedMap,
         _sortNum = 0,
+        _requests = [],
         _mode = mode,
+        _totalTraffic = Traffic(),
         _delayMap = {},
         _groups = [],
         _isCompatible = isCompatible,
@@ -152,8 +159,39 @@ class AppState with ChangeNotifier {
     }
   }
 
-  addTraffic(Traffic value) {
-    _traffics = List.from(_traffics)..add(value);
+  addTraffic(Traffic traffic) {
+    _traffics = List.from(_traffics)..add(traffic);
+    const maxLength = 60;
+    if (_traffics.length > maxLength) {
+      _traffics = _traffics.sublist(_traffics.length - maxLength);
+    }
+    notifyListeners();
+  }
+
+  Traffic get totalTraffic => _totalTraffic;
+
+  set totalTraffic(Traffic value) {
+    if (_totalTraffic != value) {
+      _totalTraffic = value;
+      notifyListeners();
+    }
+  }
+
+  List<Connection> get requests => _requests;
+
+  set requests(List<Connection> value) {
+    if (_requests != value) {
+      _requests = value;
+      notifyListeners();
+    }
+  }
+
+  addRequest(Connection value) {
+    _requests.add(value);
+    final maxLength = Platform.isAndroid ? 1000 : 60;
+    if (_requests.length > maxLength) {
+      _requests = _requests.sublist(_requests.length - maxLength);
+    }
     notifyListeners();
   }
 
@@ -168,8 +206,9 @@ class AppState with ChangeNotifier {
 
   addLog(Log log) {
     _logs.add(log);
-    if (_logs.length > 60) {
-      _logs = _logs.sublist(_logs.length - 60);
+    final maxLength = Platform.isAndroid ? 1000 : 60;
+    if (_logs.length > maxLength) {
+      _logs = _logs.sublist(_logs.length - maxLength);
     }
     notifyListeners();
   }

lib/models/clash_config.dart

@@ -113,39 +113,29 @@ class ClashConfig extends ChangeNotifier {
   LogLevel _logLevel;
   String _externalController;
   Mode _mode;
+  FindProcessMode _findProcessMode;
   bool _unifiedDelay;
   bool _tcpConcurrent;
   Tun _tun;
   Dns _dns;
   List<String> _rules;
 
-  ClashConfig({
-    int? mixedPort,
-    Mode? mode,
-    bool? allowLan,
-    bool? ipv6,
-    LogLevel? logLevel,
-    String? externalController,
-    String? geodataLoader,
-    bool? unifiedDelay,
-    Tun? tun,
-    Dns? dns,
-    bool? tcpConcurrent,
-    List<String>? rules,
-  })  : _mixedPort = mixedPort ?? 7890,
-        _mode = mode ?? Mode.rule,
-        _ipv6 = ipv6 ?? false,
-        _allowLan = allowLan ?? false,
-        _tcpConcurrent = tcpConcurrent ?? false,
-        _logLevel = logLevel ?? LogLevel.info,
-        _tun = tun ?? const Tun(),
-        _unifiedDelay = unifiedDelay ?? false,
-        _geodataLoader = geodataLoader ?? geodataLoaderMemconservative,
-        _externalController = externalController ?? '',
-        _dns = dns ?? Dns(),
-        _rules = rules ?? [];
+  ClashConfig()
+      : _mixedPort = 7890,
+        _mode = Mode.rule,
+        _ipv6 = false,
+        _findProcessMode = FindProcessMode.off,
+        _allowLan = false,
+        _tcpConcurrent = false,
+        _logLevel = LogLevel.info,
+        _tun = const Tun(),
+        _unifiedDelay = false,
+        _geodataLoader = geodataLoaderMemconservative,
+        _externalController = '',
+        _dns = Dns(),
+        _rules = [];
 
-  @JsonKey(name: "mixed-port")
+  @JsonKey(name: "mixed-port", defaultValue: 7890)
   int get mixedPort => _mixedPort;
 
   set mixedPort(int value) {
@@ -155,6 +145,7 @@ class ClashConfig extends ChangeNotifier {
     }
   }
 
+  @JsonKey(defaultValue: Mode.rule)
   Mode get mode => _mode;
 
   set mode(Mode value) {
@@ -164,6 +155,16 @@ class ClashConfig extends ChangeNotifier {
     }
   }
 
+  @JsonKey(name: "find-process-mode", defaultValue: FindProcessMode.off)
+  FindProcessMode get findProcessMode => _findProcessMode;
+
+  set findProcessMode(FindProcessMode value) {
+    if (_findProcessMode != value) {
+      _findProcessMode = value;
+      notifyListeners();
+    }
+  }
+
   @JsonKey(name: "allow-lan")
   bool get allowLan => _allowLan;
 
@@ -174,7 +175,7 @@ class ClashConfig extends ChangeNotifier {
     }
   }
 
-  @JsonKey(name: "log-level")
+  @JsonKey(name: "log-level", defaultValue: LogLevel.info)
   LogLevel get logLevel => _logLevel;
 
   set logLevel(LogLevel value) {
@@ -282,17 +283,6 @@ class ClashConfig extends ChangeNotifier {
     return _$ClashConfigFromJson(json);
   }
 
-  ClashConfig copyWith({Tun? tun}) {
-    return ClashConfig(
-      mixedPort: mixedPort,
-      mode: mode,
-      logLevel: logLevel,
-      tun: tun ?? this.tun,
-      dns: dns,
-      allowLan: allowLan,
-    );
-  }
-
   @override
   String toString() {
     return 'ClashConfig{_mixedPort: $_mixedPort, _allowLan: $_allowLan, _mode: $_mode, _logLevel: $_logLevel, _tun: $_tun, _dns: $_dns, _rules: $_rules}';

lib/models/config.dart

@@ -32,8 +32,7 @@ class Props with _$Props {
     bool? systemProxy,
   }) = _Props;
 
-  factory Props.fromJson(Map<String, Object?> json) =>
-      _$PropsFromJson(json);
+  factory Props.fromJson(Map<String, Object?> json) => _$PropsFromJson(json);
 }
 
 @JsonSerializable()
@@ -71,7 +70,7 @@ class Config extends ChangeNotifier {
         _isMinimizeOnExit = true,
         _isAccessControl = false,
         _autoCheckUpdate = true,
-        _systemProxy = false,
+        _systemProxy = true,
         _accessControl = const AccessControl(),
         _isAnimateToPage = true,
         _allowBypass = true;
@@ -151,6 +150,15 @@ class Config extends ChangeNotifier {
     }
   }
 
+  String? get currentGroupName => currentProfile?.currentGroupName;
+
+  updateCurrentGroupName(String groupName) {
+    if (currentProfile?.currentGroupName != groupName) {
+      currentProfile?.currentGroupName = groupName;
+      notifyListeners();
+    }
+  }
+
   SelectedMap get currentSelectedMap {
     return currentProfile?.selectedMap ?? {};
   }

lib/models/connection.dart

@@ -14,6 +14,7 @@ class Metadata with _$Metadata {
     required String destinationIP,
     required String destinationPort,
     required String host,
+    required String process,
     required String remoteDestination,
   }) = _Metadata;
 

lib/models/ffi.dart

@@ -2,6 +2,7 @@
 
 import 'package:fl_clash/enum/enum.dart';
 import 'package:fl_clash/models/clash_config.dart';
+import 'package:fl_clash/models/connection.dart';
 import 'package:freezed_annotation/freezed_annotation.dart';
 
 part 'generated/ffi.g.dart';
@@ -66,16 +67,25 @@ class Now with _$Now {
 @freezed
 class Process with _$Process {
   const factory Process({
-    required int uid,
-    required String network,
-    required String source,
-    required String target,
+    required int id,
+    required Metadata metadata,
   }) = _Process;
 
   factory Process.fromJson(Map<String, Object?> json) =>
       _$ProcessFromJson(json);
 }
 
+@freezed
+class ProcessMapItem with _$ProcessMapItem {
+  const factory ProcessMapItem({
+    required int id,
+    required String value,
+  }) = _ProcessMapItem;
+
+  factory ProcessMapItem.fromJson(Map<String, Object?> json) =>
+      _$ProcessMapItemFromJson(json);
+}
+
 @freezed
 class ExternalProvider with _$ExternalProvider {
   const factory ExternalProvider({

lib/models/generated/clash_config.g.dart

@@ -35,30 +35,29 @@ Map<String, dynamic> _$DnsToJson(Dns instance) => <String, dynamic>{
       'fake-ip-filter': instance.fakeIpFilter,
     };
 
-ClashConfig _$ClashConfigFromJson(Map<String, dynamic> json) => ClashConfig(
-      mixedPort: (json['mixed-port'] as num?)?.toInt(),
-      mode: $enumDecodeNullable(_$ModeEnumMap, json['mode']),
-      allowLan: json['allow-lan'] as bool?,
-      ipv6: json['ipv6'] as bool? ?? false,
-      logLevel: $enumDecodeNullable(_$LogLevelEnumMap, json['log-level']),
-      externalController: json['external-controller'] as String? ?? '',
-      geodataLoader: json['geodata-loader'] as String? ?? 'memconservative',
-      unifiedDelay: json['unified-delay'] as bool? ?? false,
-      tun: json['tun'] == null
-          ? null
-          : Tun.fromJson(json['tun'] as Map<String, dynamic>),
-      dns: json['dns'] == null
-          ? null
-          : Dns.fromJson(json['dns'] as Map<String, dynamic>),
-      tcpConcurrent: json['tcp-concurrent'] as bool? ?? false,
-      rules:
-          (json['rules'] as List<dynamic>?)?.map((e) => e as String).toList(),
-    );
+ClashConfig _$ClashConfigFromJson(Map<String, dynamic> json) => ClashConfig()
+  ..mixedPort = (json['mixed-port'] as num?)?.toInt() ?? 7890
+  ..mode = $enumDecodeNullable(_$ModeEnumMap, json['mode']) ?? Mode.rule
+  ..findProcessMode = $enumDecodeNullable(
+          _$FindProcessModeEnumMap, json['find-process-mode']) ??
+      FindProcessMode.off
+  ..allowLan = json['allow-lan'] as bool
+  ..logLevel =
+      $enumDecodeNullable(_$LogLevelEnumMap, json['log-level']) ?? LogLevel.info
+  ..externalController = json['external-controller'] as String? ?? ''
+  ..ipv6 = json['ipv6'] as bool? ?? false
+  ..geodataLoader = json['geodata-loader'] as String? ?? 'memconservative'
+  ..unifiedDelay = json['unified-delay'] as bool? ?? false
+  ..tcpConcurrent = json['tcp-concurrent'] as bool? ?? false
+  ..tun = Tun.fromJson(json['tun'] as Map<String, dynamic>)
+  ..dns = Dns.fromJson(json['dns'] as Map<String, dynamic>)
+  ..rules = (json['rules'] as List<dynamic>).map((e) => e as String).toList();
 
 Map<String, dynamic> _$ClashConfigToJson(ClashConfig instance) =>
     <String, dynamic>{
       'mixed-port': instance.mixedPort,
       'mode': _$ModeEnumMap[instance.mode]!,
+      'find-process-mode': _$FindProcessModeEnumMap[instance.findProcessMode]!,
       'allow-lan': instance.allowLan,
       'log-level': _$LogLevelEnumMap[instance.logLevel]!,
       'external-controller': instance.externalController,
@@ -77,6 +76,11 @@ const _$ModeEnumMap = {
   Mode.direct: 'direct',
 };
 
+const _$FindProcessModeEnumMap = {
+  FindProcessMode.always: 'always',
+  FindProcessMode.off: 'off',
+};
+
 const _$LogLevelEnumMap = {
   LogLevel.debug: 'debug',
   LogLevel.info: 'info',

lib/models/generated/connection.freezed.dart

@@ -27,6 +27,7 @@ mixin _$Metadata {
   String get destinationIP => throw _privateConstructorUsedError;
   String get destinationPort => throw _privateConstructorUsedError;
   String get host => throw _privateConstructorUsedError;
+  String get process => throw _privateConstructorUsedError;
   String get remoteDestination => throw _privateConstructorUsedError;
 
   Map<String, dynamic> toJson() => throw _privateConstructorUsedError;
@@ -48,6 +49,7 @@ abstract class $MetadataCopyWith<$Res> {
       String destinationIP,
       String destinationPort,
       String host,
+      String process,
       String remoteDestination});
 }
 
@@ -71,6 +73,7 @@ class _$MetadataCopyWithImpl<$Res, $Val extends Metadata>
     Object? destinationIP = null,
     Object? destinationPort = null,
     Object? host = null,
+    Object? process = null,
     Object? remoteDestination = null,
   }) {
     return _then(_value.copyWith(
@@ -102,6 +105,10 @@ class _$MetadataCopyWithImpl<$Res, $Val extends Metadata>
           ? _value.host
           : host // ignore: cast_nullable_to_non_nullable
               as String,
+      process: null == process
+          ? _value.process
+          : process // ignore: cast_nullable_to_non_nullable
+              as String,
       remoteDestination: null == remoteDestination
           ? _value.remoteDestination
           : remoteDestination // ignore: cast_nullable_to_non_nullable
@@ -126,6 +133,7 @@ abstract class _$$MetadataImplCopyWith<$Res>
       String destinationIP,
       String destinationPort,
       String host,
+      String process,
       String remoteDestination});
 }
 
@@ -147,6 +155,7 @@ class __$$MetadataImplCopyWithImpl<$Res>
     Object? destinationIP = null,
     Object? destinationPort = null,
     Object? host = null,
+    Object? process = null,
     Object? remoteDestination = null,
   }) {
     return _then(_$MetadataImpl(
@@ -178,6 +187,10 @@ class __$$MetadataImplCopyWithImpl<$Res>
           ? _value.host
           : host // ignore: cast_nullable_to_non_nullable
               as String,
+      process: null == process
+          ? _value.process
+          : process // ignore: cast_nullable_to_non_nullable
+              as String,
       remoteDestination: null == remoteDestination
           ? _value.remoteDestination
           : remoteDestination // ignore: cast_nullable_to_non_nullable
@@ -197,6 +210,7 @@ class _$MetadataImpl implements _Metadata {
       required this.destinationIP,
       required this.destinationPort,
       required this.host,
+      required this.process,
       required this.remoteDestination});
 
   factory _$MetadataImpl.fromJson(Map<String, dynamic> json) =>
@@ -217,11 +231,13 @@ class _$MetadataImpl implements _Metadata {
   @override
   final String host;
   @override
+  final String process;
+  @override
   final String remoteDestination;
 
   @override
   String toString() {
-    return 'Metadata(uid: $uid, network: $network, sourceIP: $sourceIP, sourcePort: $sourcePort, destinationIP: $destinationIP, destinationPort: $destinationPort, host: $host, remoteDestination: $remoteDestination)';
+    return 'Metadata(uid: $uid, network: $network, sourceIP: $sourceIP, sourcePort: $sourcePort, destinationIP: $destinationIP, destinationPort: $destinationPort, host: $host, process: $process, remoteDestination: $remoteDestination)';
   }
 
   @override
@@ -240,14 +256,24 @@ class _$MetadataImpl implements _Metadata {
             (identical(other.destinationPort, destinationPort) ||
                 other.destinationPort == destinationPort) &&
             (identical(other.host, host) || other.host == host) &&
+            (identical(other.process, process) || other.process == process) &&
             (identical(other.remoteDestination, remoteDestination) ||
                 other.remoteDestination == remoteDestination));
   }
 
   @JsonKey(ignore: true)
   @override
-  int get hashCode => Object.hash(runtimeType, uid, network, sourceIP,
-      sourcePort, destinationIP, destinationPort, host, remoteDestination);
+  int get hashCode => Object.hash(
+      runtimeType,
+      uid,
+      network,
+      sourceIP,
+      sourcePort,
+      destinationIP,
+      destinationPort,
+      host,
+      process,
+      remoteDestination);
 
   @JsonKey(ignore: true)
   @override
@@ -272,6 +298,7 @@ abstract class _Metadata implements Metadata {
       required final String destinationIP,
       required final String destinationPort,
       required final String host,
+      required final String process,
       required final String remoteDestination}) = _$MetadataImpl;
 
   factory _Metadata.fromJson(Map<String, dynamic> json) =
@@ -292,6 +319,8 @@ abstract class _Metadata implements Metadata {
   @override
   String get host;
   @override
+  String get process;
+  @override
   String get remoteDestination;
   @override
   @JsonKey(ignore: true)

lib/models/generated/connection.g.dart

@@ -15,6 +15,7 @@ _$MetadataImpl _$$MetadataImplFromJson(Map<String, dynamic> json) =>
       destinationIP: json['destinationIP'] as String,
       destinationPort: json['destinationPort'] as String,
       host: json['host'] as String,
+      process: json['process'] as String,
       remoteDestination: json['remoteDestination'] as String,
     );
 
@@ -27,6 +28,7 @@ Map<String, dynamic> _$$MetadataImplToJson(_$MetadataImpl instance) =>
       'destinationIP': instance.destinationIP,
       'destinationPort': instance.destinationPort,
       'host': instance.host,
+      'process': instance.process,
       'remoteDestination': instance.remoteDestination,
     };
 

lib/models/generated/ffi.freezed.dart

@@ -848,10 +848,8 @@ Process _$ProcessFromJson(Map<String, dynamic> json) {
 
 /// @nodoc
 mixin _$Process {
-  int get uid => throw _privateConstructorUsedError;
-  String get network => throw _privateConstructorUsedError;
-  String get source => throw _privateConstructorUsedError;
-  String get target => throw _privateConstructorUsedError;
+  int get id => throw _privateConstructorUsedError;
+  Metadata get metadata => throw _privateConstructorUsedError;
 
   Map<String, dynamic> toJson() => throw _privateConstructorUsedError;
   @JsonKey(ignore: true)
@@ -863,7 +861,9 @@ abstract class $ProcessCopyWith<$Res> {
   factory $ProcessCopyWith(Process value, $Res Function(Process) then) =
       _$ProcessCopyWithImpl<$Res, Process>;
   @useResult
-  $Res call({int uid, String network, String source, String target});
+  $Res call({int id, Metadata metadata});
+
+  $MetadataCopyWith<$Res> get metadata;
 }
 
 /// @nodoc
@@ -879,30 +879,28 @@ class _$ProcessCopyWithImpl<$Res, $Val extends Process>
   @pragma('vm:prefer-inline')
   @override
   $Res call({
-    Object? uid = null,
-    Object? network = null,
-    Object? source = null,
-    Object? target = null,
+    Object? id = null,
+    Object? metadata = null,
   }) {
     return _then(_value.copyWith(
-      uid: null == uid
-          ? _value.uid
-          : uid // ignore: cast_nullable_to_non_nullable
+      id: null == id
+          ? _value.id
+          : id // ignore: cast_nullable_to_non_nullable
               as int,
-      network: null == network
-          ? _value.network
-          : network // ignore: cast_nullable_to_non_nullable
-              as String,
-      source: null == source
-          ? _value.source
-          : source // ignore: cast_nullable_to_non_nullable
-              as String,
-      target: null == target
-          ? _value.target
-          : target // ignore: cast_nullable_to_non_nullable
-              as String,
+      metadata: null == metadata
+          ? _value.metadata
+          : metadata // ignore: cast_nullable_to_non_nullable
+              as Metadata,
     ) as $Val);
   }
+
+  @override
+  @pragma('vm:prefer-inline')
+  $MetadataCopyWith<$Res> get metadata {
+    return $MetadataCopyWith<$Res>(_value.metadata, (value) {
+      return _then(_value.copyWith(metadata: value) as $Val);
+    });
+  }
 }
 
 /// @nodoc
@@ -912,7 +910,10 @@ abstract class _$$ProcessImplCopyWith<$Res> implements $ProcessCopyWith<$Res> {
       __$$ProcessImplCopyWithImpl<$Res>;
   @override
   @useResult
-  $Res call({int uid, String network, String source, String target});
+  $Res call({int id, Metadata metadata});
+
+  @override
+  $MetadataCopyWith<$Res> get metadata;
 }
 
 /// @nodoc
@@ -926,28 +927,18 @@ class __$$ProcessImplCopyWithImpl<$Res>
   @pragma('vm:prefer-inline')
   @override
   $Res call({
-    Object? uid = null,
-    Object? network = null,
-    Object? source = null,
-    Object? target = null,
+    Object? id = null,
+    Object? metadata = null,
   }) {
     return _then(_$ProcessImpl(
-      uid: null == uid
-          ? _value.uid
-          : uid // ignore: cast_nullable_to_non_nullable
+      id: null == id
+          ? _value.id
+          : id // ignore: cast_nullable_to_non_nullable
               as int,
-      network: null == network
-          ? _value.network
-          : network // ignore: cast_nullable_to_non_nullable
-              as String,
-      source: null == source
-          ? _value.source
-          : source // ignore: cast_nullable_to_non_nullable
-              as String,
-      target: null == target
-          ? _value.target
-          : target // ignore: cast_nullable_to_non_nullable
-              as String,
+      metadata: null == metadata
+          ? _value.metadata
+          : metadata // ignore: cast_nullable_to_non_nullable
+              as Metadata,
     ));
   }
 }
@@ -955,27 +946,19 @@ class __$$ProcessImplCopyWithImpl<$Res>
 /// @nodoc
 @JsonSerializable()
 class _$ProcessImpl implements _Process {
-  const _$ProcessImpl(
-      {required this.uid,
-      required this.network,
-      required this.source,
-      required this.target});
+  const _$ProcessImpl({required this.id, required this.metadata});
 
   factory _$ProcessImpl.fromJson(Map<String, dynamic> json) =>
       _$$ProcessImplFromJson(json);
 
   @override
-  final int uid;
+  final int id;
   @override
-  final String network;
-  @override
-  final String source;
-  @override
-  final String target;
+  final Metadata metadata;
 
   @override
   String toString() {
-    return 'Process(uid: $uid, network: $network, source: $source, target: $target)';
+    return 'Process(id: $id, metadata: $metadata)';
   }
 
   @override
@@ -983,15 +966,14 @@ class _$ProcessImpl implements _Process {
     return identical(this, other) ||
         (other.runtimeType == runtimeType &&
             other is _$ProcessImpl &&
-            (identical(other.uid, uid) || other.uid == uid) &&
-            (identical(other.network, network) || other.network == network) &&
-            (identical(other.source, source) || other.source == source) &&
-            (identical(other.target, target) || other.target == target));
+            (identical(other.id, id) || other.id == id) &&
+            (identical(other.metadata, metadata) ||
+                other.metadata == metadata));
   }
 
   @JsonKey(ignore: true)
   @override
-  int get hashCode => Object.hash(runtimeType, uid, network, source, target);
+  int get hashCode => Object.hash(runtimeType, id, metadata);
 
   @JsonKey(ignore: true)
   @override
@@ -1009,27 +991,176 @@ class _$ProcessImpl implements _Process {
 
 abstract class _Process implements Process {
   const factory _Process(
-      {required final int uid,
-      required final String network,
-      required final String source,
-      required final String target}) = _$ProcessImpl;
+      {required final int id,
+      required final Metadata metadata}) = _$ProcessImpl;
 
   factory _Process.fromJson(Map<String, dynamic> json) = _$ProcessImpl.fromJson;
 
   @override
-  int get uid;
+  int get id;
   @override
-  String get network;
-  @override
-  String get source;
-  @override
-  String get target;
+  Metadata get metadata;
   @override
   @JsonKey(ignore: true)
   _$$ProcessImplCopyWith<_$ProcessImpl> get copyWith =>
       throw _privateConstructorUsedError;
 }
 
+ProcessMapItem _$ProcessMapItemFromJson(Map<String, dynamic> json) {
+  return _ProcessMapItem.fromJson(json);
+}
+
+/// @nodoc
+mixin _$ProcessMapItem {
+  int get id => throw _privateConstructorUsedError;
+  String get value => throw _privateConstructorUsedError;
+
+  Map<String, dynamic> toJson() => throw _privateConstructorUsedError;
+  @JsonKey(ignore: true)
+  $ProcessMapItemCopyWith<ProcessMapItem> get copyWith =>
+      throw _privateConstructorUsedError;
+}
+
+/// @nodoc
+abstract class $ProcessMapItemCopyWith<$Res> {
+  factory $ProcessMapItemCopyWith(
+          ProcessMapItem value, $Res Function(ProcessMapItem) then) =
+      _$ProcessMapItemCopyWithImpl<$Res, ProcessMapItem>;
+  @useResult
+  $Res call({int id, String value});
+}
+
+/// @nodoc
+class _$ProcessMapItemCopyWithImpl<$Res, $Val extends ProcessMapItem>
+    implements $ProcessMapItemCopyWith<$Res> {
+  _$ProcessMapItemCopyWithImpl(this._value, this._then);
+
+  // ignore: unused_field
+  final $Val _value;
+  // ignore: unused_field
+  final $Res Function($Val) _then;
+
+  @pragma('vm:prefer-inline')
+  @override
+  $Res call({
+    Object? id = null,
+    Object? value = null,
+  }) {
+    return _then(_value.copyWith(
+      id: null == id
+          ? _value.id
+          : id // ignore: cast_nullable_to_non_nullable
+              as int,
+      value: null == value
+          ? _value.value
+          : value // ignore: cast_nullable_to_non_nullable
+              as String,
+    ) as $Val);
+  }
+}
+
+/// @nodoc
+abstract class _$$ProcessMapItemImplCopyWith<$Res>
+    implements $ProcessMapItemCopyWith<$Res> {
+  factory _$$ProcessMapItemImplCopyWith(_$ProcessMapItemImpl value,
+          $Res Function(_$ProcessMapItemImpl) then) =
+      __$$ProcessMapItemImplCopyWithImpl<$Res>;
+  @override
+  @useResult
+  $Res call({int id, String value});
+}
+
+/// @nodoc
+class __$$ProcessMapItemImplCopyWithImpl<$Res>
+    extends _$ProcessMapItemCopyWithImpl<$Res, _$ProcessMapItemImpl>
+    implements _$$ProcessMapItemImplCopyWith<$Res> {
+  __$$ProcessMapItemImplCopyWithImpl(
+      _$ProcessMapItemImpl _value, $Res Function(_$ProcessMapItemImpl) _then)
+      : super(_value, _then);
+
+  @pragma('vm:prefer-inline')
+  @override
+  $Res call({
+    Object? id = null,
+    Object? value = null,
+  }) {
+    return _then(_$ProcessMapItemImpl(
+      id: null == id
+          ? _value.id
+          : id // ignore: cast_nullable_to_non_nullable
+              as int,
+      value: null == value
+          ? _value.value
+          : value // ignore: cast_nullable_to_non_nullable
+              as String,
+    ));
+  }
+}
+
+/// @nodoc
+@JsonSerializable()
+class _$ProcessMapItemImpl implements _ProcessMapItem {
+  const _$ProcessMapItemImpl({required this.id, required this.value});
+
+  factory _$ProcessMapItemImpl.fromJson(Map<String, dynamic> json) =>
+      _$$ProcessMapItemImplFromJson(json);
+
+  @override
+  final int id;
+  @override
+  final String value;
+
+  @override
+  String toString() {
+    return 'ProcessMapItem(id: $id, value: $value)';
+  }
+
+  @override
+  bool operator ==(Object other) {
+    return identical(this, other) ||
+        (other.runtimeType == runtimeType &&
+            other is _$ProcessMapItemImpl &&
+            (identical(other.id, id) || other.id == id) &&
+            (identical(other.value, value) || other.value == value));
+  }
+
+  @JsonKey(ignore: true)
+  @override
+  int get hashCode => Object.hash(runtimeType, id, value);
+
+  @JsonKey(ignore: true)
+  @override
+  @pragma('vm:prefer-inline')
+  _$$ProcessMapItemImplCopyWith<_$ProcessMapItemImpl> get copyWith =>
+      __$$ProcessMapItemImplCopyWithImpl<_$ProcessMapItemImpl>(
+          this, _$identity);
+
+  @override
+  Map<String, dynamic> toJson() {
+    return _$$ProcessMapItemImplToJson(
+      this,
+    );
+  }
+}
+
+abstract class _ProcessMapItem implements ProcessMapItem {
+  const factory _ProcessMapItem(
+      {required final int id,
+      required final String value}) = _$ProcessMapItemImpl;
+
+  factory _ProcessMapItem.fromJson(Map<String, dynamic> json) =
+      _$ProcessMapItemImpl.fromJson;
+
+  @override
+  int get id;
+  @override
+  String get value;
+  @override
+  @JsonKey(ignore: true)
+  _$$ProcessMapItemImplCopyWith<_$ProcessMapItemImpl> get copyWith =>
+      throw _privateConstructorUsedError;
+}
+
 ExternalProvider _$ExternalProviderFromJson(Map<String, dynamic> json) {
   return _ExternalProvider.fromJson(json);
 }

lib/models/generated/ffi.g.dart

@@ -56,6 +56,8 @@ const _$MessageTypeEnumMap = {
   MessageType.delay: 'delay',
   MessageType.process: 'process',
   MessageType.now: 'now',
+  MessageType.request: 'request',
+  MessageType.run: 'run',
 };
 
 _$DelayImpl _$$DelayImplFromJson(Map<String, dynamic> json) => _$DelayImpl(
@@ -81,18 +83,27 @@ Map<String, dynamic> _$$NowImplToJson(_$NowImpl instance) => <String, dynamic>{
 
 _$ProcessImpl _$$ProcessImplFromJson(Map<String, dynamic> json) =>
     _$ProcessImpl(
-      uid: (json['uid'] as num).toInt(),
-      network: json['network'] as String,
-      source: json['source'] as String,
-      target: json['target'] as String,
+      id: (json['id'] as num).toInt(),
+      metadata: Metadata.fromJson(json['metadata'] as Map<String, dynamic>),
     );
 
 Map<String, dynamic> _$$ProcessImplToJson(_$ProcessImpl instance) =>
     <String, dynamic>{
-      'uid': instance.uid,
-      'network': instance.network,
-      'source': instance.source,
-      'target': instance.target,
+      'id': instance.id,
+      'metadata': instance.metadata,
+    };
+
+_$ProcessMapItemImpl _$$ProcessMapItemImplFromJson(Map<String, dynamic> json) =>
+    _$ProcessMapItemImpl(
+      id: (json['id'] as num).toInt(),
+      value: json['value'] as String,
+    );
+
+Map<String, dynamic> _$$ProcessMapItemImplToJson(
+        _$ProcessMapItemImpl instance) =>
+    <String, dynamic>{
+      'id': instance.id,
+      'value': instance.value,
     };
 
 _$ExternalProviderImpl _$$ExternalProviderImplFromJson(

lib/models/generated/profile.g.dart

@@ -24,10 +24,10 @@ Profile _$ProfileFromJson(Map<String, dynamic> json) => Profile(
       id: json['id'] as String?,
       label: json['label'] as String?,
       url: json['url'] as String?,
+      currentGroupName: json['currentGroupName'] as String?,
       userInfo: json['userInfo'] == null
           ? null
           : UserInfo.fromJson(json['userInfo'] as Map<String, dynamic>),
-      proxyName: json['proxyName'] as String?,
       lastUpdateDate: json['lastUpdateDate'] == null
           ? null
           : DateTime.parse(json['lastUpdateDate'] as String),
@@ -43,7 +43,7 @@ Profile _$ProfileFromJson(Map<String, dynamic> json) => Profile(
 Map<String, dynamic> _$ProfileToJson(Profile instance) => <String, dynamic>{
       'id': instance.id,
       'label': instance.label,
-      'proxyName': instance.proxyName,
+      'currentGroupName': instance.currentGroupName,
       'url': instance.url,
       'lastUpdateDate': instance.lastUpdateDate?.toIso8601String(),
       'autoUpdateDuration': instance.autoUpdateDuration.inMicroseconds,

lib/models/generated/selector.freezed.dart

@@ -1583,6 +1583,7 @@ abstract class _ProxiesCardSelectorState implements ProxiesCardSelectorState {
 /// @nodoc
 mixin _$ProxiesSelectorState {
   List<String> get groupNames => throw _privateConstructorUsedError;
+  String? get currentGroupName => throw _privateConstructorUsedError;
 
   @JsonKey(ignore: true)
   $ProxiesSelectorStateCopyWith<ProxiesSelectorState> get copyWith =>
@@ -1595,7 +1596,7 @@ abstract class $ProxiesSelectorStateCopyWith<$Res> {
           $Res Function(ProxiesSelectorState) then) =
       _$ProxiesSelectorStateCopyWithImpl<$Res, ProxiesSelectorState>;
   @useResult
-  $Res call({List<String> groupNames});
+  $Res call({List<String> groupNames, String? currentGroupName});
 }
 
 /// @nodoc
@@ -1613,12 +1614,17 @@ class _$ProxiesSelectorStateCopyWithImpl<$Res,
   @override
   $Res call({
     Object? groupNames = null,
+    Object? currentGroupName = freezed,
   }) {
     return _then(_value.copyWith(
       groupNames: null == groupNames
           ? _value.groupNames
           : groupNames // ignore: cast_nullable_to_non_nullable
               as List<String>,
+      currentGroupName: freezed == currentGroupName
+          ? _value.currentGroupName
+          : currentGroupName // ignore: cast_nullable_to_non_nullable
+              as String?,
     ) as $Val);
   }
 }
@@ -1631,7 +1637,7 @@ abstract class _$$ProxiesSelectorStateImplCopyWith<$Res>
       __$$ProxiesSelectorStateImplCopyWithImpl<$Res>;
   @override
   @useResult
-  $Res call({List<String> groupNames});
+  $Res call({List<String> groupNames, String? currentGroupName});
 }
 
 /// @nodoc
@@ -1646,12 +1652,17 @@ class __$$ProxiesSelectorStateImplCopyWithImpl<$Res>
   @override
   $Res call({
     Object? groupNames = null,
+    Object? currentGroupName = freezed,
   }) {
     return _then(_$ProxiesSelectorStateImpl(
       groupNames: null == groupNames
           ? _value._groupNames
           : groupNames // ignore: cast_nullable_to_non_nullable
               as List<String>,
+      currentGroupName: freezed == currentGroupName
+          ? _value.currentGroupName
+          : currentGroupName // ignore: cast_nullable_to_non_nullable
+              as String?,
     ));
   }
 }
@@ -1659,7 +1670,8 @@ class __$$ProxiesSelectorStateImplCopyWithImpl<$Res>
 /// @nodoc
 
 class _$ProxiesSelectorStateImpl implements _ProxiesSelectorState {
-  const _$ProxiesSelectorStateImpl({required final List<String> groupNames})
+  const _$ProxiesSelectorStateImpl(
+      {required final List<String> groupNames, required this.currentGroupName})
       : _groupNames = groupNames;
 
   final List<String> _groupNames;
@@ -1670,9 +1682,12 @@ class _$ProxiesSelectorStateImpl implements _ProxiesSelectorState {
     return EqualUnmodifiableListView(_groupNames);
   }
 
+  @override
+  final String? currentGroupName;
+
   @override
   String toString() {
-    return 'ProxiesSelectorState(groupNames: $groupNames)';
+    return 'ProxiesSelectorState(groupNames: $groupNames, currentGroupName: $currentGroupName)';
   }
 
   @override
@@ -1681,12 +1696,14 @@ class _$ProxiesSelectorStateImpl implements _ProxiesSelectorState {
         (other.runtimeType == runtimeType &&
             other is _$ProxiesSelectorStateImpl &&
             const DeepCollectionEquality()
-                .equals(other._groupNames, _groupNames));
+                .equals(other._groupNames, _groupNames) &&
+            (identical(other.currentGroupName, currentGroupName) ||
+                other.currentGroupName == currentGroupName));
   }
 
   @override
-  int get hashCode => Object.hash(
-      runtimeType, const DeepCollectionEquality().hash(_groupNames));
+  int get hashCode => Object.hash(runtimeType,
+      const DeepCollectionEquality().hash(_groupNames), currentGroupName);
 
   @JsonKey(ignore: true)
   @override
@@ -1699,11 +1716,14 @@ class _$ProxiesSelectorStateImpl implements _ProxiesSelectorState {
 
 abstract class _ProxiesSelectorState implements ProxiesSelectorState {
   const factory _ProxiesSelectorState(
-      {required final List<String> groupNames}) = _$ProxiesSelectorStateImpl;
+      {required final List<String> groupNames,
+      required final String? currentGroupName}) = _$ProxiesSelectorStateImpl;
 
   @override
   List<String> get groupNames;
   @override
+  String? get currentGroupName;
+  @override
   @JsonKey(ignore: true)
   _$$ProxiesSelectorStateImplCopyWith<_$ProxiesSelectorStateImpl>
       get copyWith => throw _privateConstructorUsedError;

lib/models/profile.dart

@@ -62,7 +62,7 @@ class UserInfo {
 class Profile {
   String id;
   String? label;
-  String? proxyName;
+  String? currentGroupName;
   String? url;
   DateTime? lastUpdateDate;
   Duration autoUpdateDuration;
@@ -74,8 +74,8 @@ class Profile {
     String? id,
     this.label,
     this.url,
+    this.currentGroupName,
     this.userInfo,
-    this.proxyName,
     this.lastUpdateDate,
     SelectedMap? selectedMap,
     Duration? autoUpdateDuration,
@@ -134,6 +134,7 @@ class Profile {
     return _$ProfileFromJson(json);
   }
 
+
   @override
   bool operator ==(Object other) =>
       identical(this, other) ||
@@ -141,34 +142,31 @@ class Profile {
           runtimeType == other.runtimeType &&
           id == other.id &&
           label == other.label &&
-          proxyName == other.proxyName &&
+          currentGroupName == other.currentGroupName &&
           url == other.url &&
           lastUpdateDate == other.lastUpdateDate &&
           autoUpdateDuration == other.autoUpdateDuration &&
           userInfo == other.userInfo &&
-          autoUpdate == other.autoUpdate;
+          autoUpdate == other.autoUpdate &&
+          selectedMap == other.selectedMap;
 
   @override
   int get hashCode =>
       id.hashCode ^
       label.hashCode ^
-      proxyName.hashCode ^
+      currentGroupName.hashCode ^
       url.hashCode ^
       lastUpdateDate.hashCode ^
       autoUpdateDuration.hashCode ^
       userInfo.hashCode ^
-      autoUpdate.hashCode;
-
-  @override
-  String toString() {
-    return 'Profile{id: $id, label: $label, proxyName: $proxyName, url: $url, lastUpdateDate: $lastUpdateDate, autoUpdateDuration: $autoUpdateDuration, userInfo: $userInfo, autoUpdate: $autoUpdate}';
-  }
+      autoUpdate.hashCode ^
+      selectedMap.hashCode;
 
   Profile copyWith({
     String? label,
     String? url,
     UserInfo? userInfo,
-    String? groupName,
+    String? currentGroupName,
     String? proxyName,
     DateTime? lastUpdateDate,
     Duration? autoUpdateDuration,
@@ -179,7 +177,7 @@ class Profile {
       id: id,
       label: label ?? this.label,
       url: url ?? this.url,
-      proxyName: proxyName ?? this.proxyName,
+      currentGroupName: currentGroupName ?? this.currentGroupName,
       userInfo: userInfo ?? this.userInfo,
       selectedMap: selectedMap ?? this.selectedMap,
       lastUpdateDate: lastUpdateDate ?? this.lastUpdateDate,

lib/models/selector.dart

@@ -94,6 +94,7 @@ class ProxiesCardSelectorState with _$ProxiesCardSelectorState {
 class ProxiesSelectorState with _$ProxiesSelectorState {
   const factory ProxiesSelectorState({
     required List<String> groupNames,
+    required String? currentGroupName,
   }) = _ProxiesSelectorState;
 }
 

lib/plugins/app.dart

@@ -18,6 +18,11 @@ class App {
       methodChannel = const MethodChannel("app");
       methodChannel!.setMethodCallHandler((call) async {
         switch (call.method) {
+          case "exit":
+            if (onExit != null) {
+              await onExit!();
+            }
+            break;
           case "gc":
             clashCore.requestGc();
             break;
@@ -63,9 +68,9 @@ class App {
     });
   }
 
-  Future<String?> getPackageName(Metadata metadata) async {
-    return await methodChannel?.invokeMethod<String>("getPackageName", {
-      "data": json.encode(metadata),
+  Future<String?> resolverProcess(Process process) async {
+    return await methodChannel?.invokeMethod<String>("resolverProcess", {
+      "data": json.encode(process),
     });
   }
 }

lib/plugins/proxy.dart

@@ -79,6 +79,10 @@ class Proxy extends ProxyPlatform {
     }
   }
 
+  // updateStartTime() async {
+  //   startTime = clashCore.getRunTime();
+  // }
+
   updateStartTime() async {
     startTime = await getRunTime();
   }

lib/state.dart

@@ -17,7 +17,6 @@ class GlobalState {
   Function? updateCurrentDelayDebounce;
   PageController? pageController;
   final navigatorKey = GlobalKey<NavigatorState>();
-  final Map<int, String?> packageNameMap = {};
   late AppController appController;
   GlobalKey<CommonScaffoldState> homeScaffoldKey = GlobalKey();
   List<Function> updateFunctionLists = [];
@@ -58,6 +57,7 @@ class GlobalState {
   }
 
   Future<void> startSystemProxy({
+    required AppState appState,
     required Config config,
     required ClashConfig clashConfig,
   }) async {
@@ -74,6 +74,11 @@ class GlobalState {
       args: args,
     );
     startListenUpdate();
+    applyProfile(
+      appState: appState,
+      config: config,
+      clashConfig: clashConfig,
+    );
   }
 
   Future<void> stopSystemProxy() async {
@@ -196,6 +201,7 @@ class GlobalState {
     final traffic = clashCore.getTraffic();
     if (appState != null) {
       appState.addTraffic(traffic);
+      appState.totalTraffic = clashCore.getTotalTraffic();
     }
     if (Platform.isAndroid) {
       final currentProfile = config.currentProfile;
@@ -212,30 +218,30 @@ class GlobalState {
     required String message,
     SnackBarAction? action,
   }) {
-    final width = context.width;
-    EdgeInsets margin;
-    if (width < 600) {
-      margin = const EdgeInsets.only(
-        bottom: 96,
-        right: 16,
-        left: 16,
-      );
-    } else {
-      margin = EdgeInsets.only(
-        bottom: 16,
-        left: 16,
-        right: width - 316,
-      );
-    }
-    ScaffoldMessenger.of(context).showSnackBar(
-      SnackBar(
-        action: action,
-        content: Text(message),
-        behavior: SnackBarBehavior.floating,
-        duration: const Duration(milliseconds: 1500),
-        margin: margin,
-      ),
-    );
+    // final width = context.width;
+    // EdgeInsets margin;
+    // if (width < 600) {
+    //   margin = const EdgeInsets.only(
+    //     bottom: 96,
+    //     right: 16,
+    //     left: 16,
+    //   );
+    // } else {
+    //   margin = EdgeInsets.only(
+    //     bottom: 16,
+    //     left: 16,
+    //     right: width - 316,
+    //   );
+    // }
+    // ScaffoldMessenger.of(context).showSnackBar(
+    //   SnackBar(
+    //     action: action,
+    //     content: Text(message),
+    //     behavior: SnackBarBehavior.floating,
+    //     duration: const Duration(milliseconds: 1500),
+    //     margin: margin,
+    //   ),
+    // );
   }
 
   Future<T?> safeRun<T>(

lib/widgets/clash_message_container.dart

@@ -1,6 +1,7 @@
 import 'package:fl_clash/clash/clash.dart';
 import 'package:fl_clash/common/common.dart';
 import 'package:fl_clash/models/models.dart';
+import 'package:fl_clash/plugins/proxy.dart';
 import 'package:fl_clash/state.dart';
 import 'package:flutter/material.dart';
 import 'package:fl_clash/plugins/app.dart';
@@ -56,9 +57,26 @@ class _ClashMessageContainerState extends State<ClashMessageContainer>
   }
 
   @override
-  void onProcess(Metadata metadata) async {
-    var packageName = await app?.getPackageName(metadata);
-    globalState.packageNameMap[metadata.uid] = packageName;
-    super.onProcess(metadata);
+  void onProcess(Process process) async {
+    var packageName = await app?.resolverProcess(process);
+    clashCore.setProcessMap(
+      ProcessMapItem(
+        id: process.id,
+        value: packageName ?? "",
+      ),
+    );
+    super.onProcess(process);
+  }
+
+  @override
+  void onRequest(Connection connection) async {
+    globalState.appController.appState.addRequest(connection);
+    super.onRequest(connection);
+  }
+
+  @override
+  void onRun(String runTime) async {
+    // proxy?.updateStartTime();
+    super.onRun(runTime);
   }
 }

lib/widgets/scaffold.dart

@@ -7,6 +7,7 @@ import 'package:flutter/services.dart';
 class CommonScaffold extends StatefulWidget {
   final Widget body;
   final Widget? bottomNavigationBar;
+  final Widget? floatingActionButton;
   final String title;
   final Widget? leading;
   final List<Widget>? actions;
@@ -19,6 +20,7 @@ class CommonScaffold extends StatefulWidget {
     this.leading,
     required this.title,
     this.actions,
+    this.floatingActionButton,
     this.automaticallyImplyLeading = true,
   });
 
@@ -116,12 +118,14 @@ class CommonScaffoldState extends State<CommonScaffold> {
   Widget build(BuildContext context) {
     return _platformContainer(
       child: Scaffold(
-        floatingActionButton: ValueListenableBuilder(
-          valueListenable: _floatingActionButton,
-          builder: (_, floatingActionButton, __) {
-            return floatingActionButton ?? Container();
-          },
-        ),
+        floatingActionButton: widget.floatingActionButton ??
+            ValueListenableBuilder(
+              valueListenable: _floatingActionButton,
+              builder: (_, floatingActionButton, __) {
+                return floatingActionButton ?? Container();
+              },
+            ),
+        resizeToAvoidBottomInset: true,
         appBar: PreferredSize(
           preferredSize: const Size.fromHeight(kToolbarHeight),
           child: Stack(

pubspec.yaml

@@ -1,7 +1,7 @@
 name: fl_clash
 description: A multi-platform proxy client based on ClashMeta, simple and easy to use, open-source and ad-free.
 publish_to: 'none'
-version: 0.8.21
+version: 0.8.25
 environment:
   sdk: '>=3.1.0 <4.0.0'
 
@@ -17,7 +17,7 @@ dependencies:
   provider: ^6.0.5
   window_manager: ^0.3.8
   ffi: ^2.1.0
-  dynamic_color: ^1.6.0
+  dynamic_color: ^1.7.0
   proxy:
     path: plugins/proxy
   launch_at_startup: ^0.2.2
@@ -39,6 +39,8 @@ dependencies:
   webdav_client: ^1.2.2
   dio: ^5.4.3+1
   country_flags: ^2.2.0
+  re_editor: ^0.3.0
+  re_highlight: ^0.0.3
 dev_dependencies:
   flutter_test:
     sdk: flutter