Add ip info fetcher

lib/features/proxy/data/proxy_data_providers.dart

@@ -1,3 +1,4 @@
+import 'package:hiddify/core/http_client/http_client_provider.dart';
 import 'package:hiddify/features/proxy/data/proxy_repository.dart';
 import 'package:hiddify/singbox/service/singbox_service_provider.dart';
 import 'package:riverpod_annotation/riverpod_annotation.dart';
@@ -8,5 +9,6 @@ part 'proxy_data_providers.g.dart';
 ProxyRepository proxyRepository(ProxyRepositoryRef ref) {
   return ProxyRepositoryImpl(
     singbox: ref.watch(singboxServiceProvider),
+    client: ref.watch(httpClientProvider),
   );
 }

lib/features/proxy/data/proxy_repository.dart

@@ -1,5 +1,7 @@
 import 'package:fpdart/fpdart.dart';
+import 'package:hiddify/core/http_client/dio_http_client.dart';
 import 'package:hiddify/core/utils/exception_handler.dart';
+import 'package:hiddify/features/proxy/model/ip_info_entity.dart';
 import 'package:hiddify/features/proxy/model/proxy_entity.dart';
 import 'package:hiddify/features/proxy/model/proxy_failure.dart';
 import 'package:hiddify/singbox/service/singbox_service.dart';
@@ -7,6 +9,7 @@ import 'package:hiddify/utils/custom_loggers.dart';
 
 abstract interface class ProxyRepository {
   Stream<Either<ProxyFailure, List<ProxyGroupEntity>>> watchProxies();
+  TaskEither<ProxyFailure, IpInfo> getCurrentIpInfo();
   TaskEither<ProxyFailure, Unit> selectProxy(
     String groupTag,
     String outboundTag,
@@ -17,13 +20,18 @@ abstract interface class ProxyRepository {
 class ProxyRepositoryImpl
     with ExceptionHandler, InfraLogger
     implements ProxyRepository {
-  ProxyRepositoryImpl({required this.singbox});
+  ProxyRepositoryImpl({
+    required this.singbox,
+    required this.client,
+  });
 
   final SingboxService singbox;
+  final DioHttpClient client;
 
   @override
   Stream<Either<ProxyFailure, List<ProxyGroupEntity>>> watchProxies() {
     return singbox.watchOutbounds().map((event) {
+      print("outbounds: $event");
       final groupWithSelected = {
         for (final group in event) group.tag: group.selected,
       };
@@ -76,4 +84,32 @@ class ProxyRepositoryImpl
       ProxyUnexpectedFailure.new,
     );
   }
+
+  final Map<String, IpInfo Function(Map<String, dynamic> response)>
+      _ipInfoSources = {
+    "https://ipapi.co/json/": IpInfo.fromIpApiCoJson,
+    "https://ipinfo.io/json/": IpInfo.fromIpInfoIoJson,
+  };
+
+  @override
+  TaskEither<ProxyFailure, IpInfo> getCurrentIpInfo() {
+    return TaskEither.tryCatch(
+      () async {
+        for (final source in _ipInfoSources.entries) {
+          try {
+            loggy.debug("getting current ip info using [${source.key}]");
+            final response = await client.get<Map<String, dynamic>>(source.key);
+            if (response.statusCode == 200 && response.data != null) {
+              return source.value(response.data!);
+            }
+          } catch (e) {
+            loggy.debug("failed getting ip info using [${source.key}]", e);
+            continue;
+          }
+        }
+        throw const ProxyFailure.unexpected();
+      },
+      ProxyUnexpectedFailure.new,
+    );
+  }
 }