Separate each VpnCore protocol into files

Author: pkongkha

lib/vpnclient_engine/core.dart

@@ -2,8 +2,6 @@ import 'dart:async';
 import 'dart:convert';
 import 'package:http/http.dart' as http;
 import 'package:dart_ping/dart_ping.dart';
-import 'package:vpnclient_engine_flutter/vpnclient_engine/core.dart';
-
 import 'package:flutter/foundation.dart';
 import 'package:flutter_v2ray/flutter_v2ray.dart';
 import 'package:rxdart/rxdart.dart';
@@ -96,17 +94,6 @@ class RoutingRule {
   RoutingRule({this.appName, this.domain, required this.action});
 }
 
-class WireGuardCore implements VpnCore {
-  @override
-  Future<void> connect({
-    required int subscriptionIndex,
-    required int serverIndex,
-  }) {
-    // TODO: implement connect
-    throw UnimplementedError();
-  }
-}
-
 abstract class VpnCore {
   Future<void> connect({
     required int subscriptionIndex,
@@ -122,300 +109,3 @@ abstract class VpnCore {
   void setAutoConnect({required bool enable});
   void setKillSwitch({required bool enable});
 }
-
-class V2RayCore implements VpnCore {
-  final FlutterV2ray _flutterV2ray = FlutterV2ray(
-    onStatusChanged: (status) {
-      // do something
-    },
-  );
-  List<List<String>> _subscriptionServers = [];
-  List<String> _subscriptions = [];
-
-  final _connectionStatusSubject = BehaviorSubject<ConnectionStatus>();
-  Stream<ConnectionStatus> get onConnectionStatusChanged =>
-      _connectionStatusSubject.stream;
-
-  final _errorSubject = BehaviorSubject<ErrorDetails>();
-  Stream<ErrorDetails> get onError => _errorSubject.stream;
-
-  final _serverSwitchedSubject = BehaviorSubject<String>();
-  Stream<String> get onServerSwitched => _serverSwitchedSubject.stream;
-
-  final _pingResultSubject = BehaviorSubject<PingResult>();
-  Stream<PingResult> get onPingResult => _pingResultSubject.stream;
-
-  final _subscriptionLoadedSubject = BehaviorSubject<SubscriptionDetails>();
-  Stream<SubscriptionDetails> get onSubscriptionLoaded =>
-      _subscriptionLoadedSubject.stream;
-
-  final _dataUsageUpdatedSubject = BehaviorSubject<SessionStatistics>();
-  Stream<SessionStatistics> get onDataUsageUpdated =>
-      _dataUsageUpdatedSubject.stream;
-
-  final _routingRulesAppliedSubject = BehaviorSubject<List<RoutingRule>>();
-  Stream<List<RoutingRule>> get onRoutingRulesApplied =>
-      _routingRulesAppliedSubject.stream;
-
-  final _killSwitchTriggeredSubject = BehaviorSubject<void>();
-  Stream<void> get onKillSwitchTriggered => _killSwitchTriggeredSubject.stream;
-
-  void _emitError(ErrorCode code, String message) {
-    _errorSubject.add(ErrorDetails(errorCode: code, errorMessage: message));
-  }
-
-  void initialize() {
-    print('V2RayCore initialized');
-  }
-
-  void clearSubscriptions() {
-    _subscriptions.clear();
-    print('All subscriptions cleared');
-  }
-
-  void addSubscription({required String subscriptionURL}) {
-    _subscriptions.add(subscriptionURL);
-    print('Subscription added: $subscriptionURL');
-  }
-
-  void addSubscriptions({required List<String> subscriptionURLs}) {
-    _subscriptions.addAll(subscriptionURLs);
-    print('Subscriptions added: ${subscriptionURLs.join(", ")}');
-  }
-
-  Future<void> updateSubscription({required int subscriptionIndex}) async {
-    if (subscriptionIndex < 0 || subscriptionIndex >= _subscriptions.length) {
-      print('Invalid subscription index');
-      return;
-    }
-
-    final url = _subscriptions[subscriptionIndex];
-    print('Fetching subscription data from: $url');
-
-    try {
-      final response = await http.get(Uri.parse(url));
-
-      if (response.statusCode != 200) {
-        print('Failed to fetch subscription: HTTP ${response.statusCode}');
-        return;
-      }
-
-      final content = response.body.trim();
-
-      List<String> servers = [];
-
-      if (content.startsWith('[')) {
-        final jsonList = jsonDecode(content) as List<dynamic>;
-        for (var server in jsonList) {
-          servers.add(server.toString());
-        }
-        print('Parsed JSON subscription: ${servers.length} servers loaded');
-      } else {
-        servers =
-            content
-                .split('\n')
-                .where((line) => line.trim().isNotEmpty)
-                .toList();
-        print('Parsed NEWLINE subscription: ${servers.length} servers loaded');
-      }
-
-      while (_subscriptionServers.length <= subscriptionIndex) {
-        _subscriptionServers.add([]);
-      }
-
-      _subscriptionServers[subscriptionIndex] = servers;
-      _subscriptionLoadedSubject.add(SubscriptionDetails());
-
-      print('Subscription #$subscriptionIndex servers updated successfully');
-    } catch (e) {
-      print('Error updating subscription: $e');
-      _emitError(ErrorCode.unknownError, 'Error updating subscription: $e');
-    }
-  }
-
-  @override
-  Future<void> connect({
-    required int subscriptionIndex,
-    required int serverIndex,
-  }) async {
-    try {
-      if (subscriptionIndex < 0 ||
-          subscriptionIndex >= _subscriptionServers.length) {
-        print('Invalid subscription index');
-        return;
-      }
-      if (serverIndex < 0 ||
-          serverIndex >= _subscriptionServers[subscriptionIndex].length) {
-        print('Invalid server index');
-        return;
-      }
-
-      await _flutterV2ray.initializeV2Ray();
-
-      final serverAddress =
-          _subscriptionServers[subscriptionIndex][serverIndex];
-      V2RayURL parser = FlutterV2ray.parseFromURL(serverAddress);
-
-      _connectionStatusSubject.add(ConnectionStatus.connecting);
-      if (await _flutterV2ray.requestPermission()) {
-        _flutterV2ray.startV2Ray(
-          remark: parser.remark,
-          config: parser.getFullConfiguration(),
-          blockedApps: null,
-          bypassSubnets: null,
-          proxyOnly: false,
-        );
-      }
-      _serverSwitchedSubject.add(serverAddress);
-      _connectionStatusSubject.add(ConnectionStatus.connected);
-      print('Successfully connected');
-    } catch (e) {
-      _emitError(ErrorCode.unknownError, 'Error connecting: $e');
-      _connectionStatusSubject.add(ConnectionStatus.error);
-    }
-  }
-
-  @override
-  Future<void> disconnect() async {
-    _flutterV2ray.stopV2Ray();
-    _connectionStatusSubject.add(ConnectionStatus.disconnected);
-    print('Disconnected successfully');
-  }
-
-  @override
-  void setRoutingRules({required List<RoutingRule> rules}) {
-    for (var rule in rules) {
-      if (rule.appName != null) {
-        print('Routing rule for app ${rule.appName}: ${rule.action}');
-      } else if (rule.domain != null) {
-        print('Routing rule for domain ${rule.domain}: ${rule.action}');
-      }
-    }
-  }
-
-  @override
-  void pingServer({required int subscriptionIndex, required int index}) async {
-    if (subscriptionIndex < 0 ||
-        subscriptionIndex >= _subscriptionServers.length) {
-      print('Invalid subscription index');
-      _emitError(ErrorCode.unknownError, 'Invalid subscription index');
-      return;
-    }
-    if (index < 0 || index >= _subscriptionServers[subscriptionIndex].length) {
-      print('Invalid server index');
-      _emitError(ErrorCode.unknownError, 'Invalid server index');
-      return;
-    }
-    final serverAddress = _subscriptionServers[subscriptionIndex][index];
-    print('Pinging server: $serverAddress');
-    try {
-      final ping = Ping(serverAddress, count: 3);
-      final pingData = await ping.stream.firstWhere(
-        (data) => data.response != null,
-      );
-      if (pingData.response != null) {
-        final latency = pingData.response!.time!.inMilliseconds;
-        final result = PingResult(
-          subscriptionIndex: subscriptionIndex,
-          serverIndex: index,
-          latencyInMs: latency,
-        );
-        _pingResultSubject.add(result);
-        print(
-          'Ping result: sub=${result.subscriptionIndex}, server=${result.serverIndex}, latency=${result.latencyInMs} ms',
-        );
-      } else {
-        print('Ping failed: No response');
-        _pingResultSubject.add(
-          PingResult(
-            subscriptionIndex: subscriptionIndex,
-            serverIndex: index,
-            latencyInMs: -1,
-          ),
-        );
-        _emitError(ErrorCode.serverUnavailable, 'Ping failed: No response');
-      }
-    } catch (e) {
-      print('Ping error: $e');
-      _pingResultSubject.add(
-        PingResult(
-          subscriptionIndex: subscriptionIndex,
-          serverIndex: index,
-          latencyInMs: -1,
-        ),
-      );
-      _emitError(ErrorCode.unknownError, 'Ping error: $e');
-    }
-  }
-
-  @override
-  String getConnectionStatus() {
-    return 'disconnected';
-  }
-
-  @override
-  List<Server> getServerList() {
-    return [
-      Server(
-        address: 'server1.com',
-        latency: 50,
-        location: 'USA',
-        isPreferred: true,
-      ),
-      Server(
-        address: 'server2.com',
-        latency: 100,
-        location: 'UK',
-        isPreferred: false,
-      ),
-      Server(
-        address: 'server3.com',
-        latency: 75,
-        location: 'Canada',
-        isPreferred: false,
-      ),
-    ];
-  }
-
-  @override
-  Future<void> loadSubscriptions({
-    required List<String> subscriptionLinks,
-  }) async {
-    print('loadSubscriptions: ${subscriptionLinks.join(", ")}');
-    _subscriptions.addAll(subscriptionLinks);
-    print('Subscriptions added: ${subscriptionLinks.join(", ")}');
-    for (var index = 0; index < subscriptionLinks.length; index++) {
-      await updateSubscription(subscriptionIndex: index);
-    }
-  }
-
-  @override
-  SessionStatistics getSessionStatistics() {
-    return SessionStatistics(
-      sessionDuration: Duration(minutes: 30),
-      dataInBytes: 1024 * 1024 * 100,
-      dataOutBytes: 1024 * 1024 * 50,
-    );
-  }
-
-  @override
-  void setAutoConnect({required bool enable}) {
-    print('setAutoConnect: $enable');
-  }
-
-  @override
-  void setKillSwitch({required bool enable}) {
-    print('setKillSwitch: $enable');
-  }
-}
-
-class OpenVPNCore implements VpnCore {
-  @override
-  Future<void> connect({
-    required int subscriptionIndex,
-    required int serverIndex,
-  }) {
-    // TODO: implement connect
-    throw UnimplementedError();
-  }
-}

lib/vpnclient_engine/engine.dart

@@ -6,6 +6,9 @@ import 'package:dart_ping/dart_ping.dart';
 import 'package:rxdart/rxdart.dart';
 import 'package:vpnclient_engine_flutter/vpnclient_engine_flutter.dart';
 import 'package:vpnclient_engine_flutter/vpnclient_engine/core.dart';
+import 'package:vpnclient_engine_flutter/vpnclient_engine/protocols/openvpn.dart';
+import 'package:vpnclient_engine_flutter/vpnclient_engine/protocols/v2ray.dart';
+import 'package:vpnclient_engine_flutter/vpnclient_engine/protocols/wireguard.dart';
 
 enum Action { block, allow, routeThroughVPN, direct, proxy }
 
@@ -131,7 +134,7 @@ class VPNclientEngine {
     _vpnCore ??= V2RayCore();
   }
 
-  static void ClearSubscriptions() {
+  static void clearSubscriptions() {
     _subscriptions.clear();
     print('All subscriptions cleared');
   }

lib/vpnclient_engine/protocols/openvpn.dart

@@ -0,0 +1,12 @@
+import 'package:vpnclient_engine_flutter/vpnclient_engine/core.dart';
+
+class OpenVPNCore implements VpnCore {
+  @override
+  Future<void> connect({
+    required int subscriptionIndex,
+    required int serverIndex,
+  }) {
+    // TODO: implement connect
+    throw UnimplementedError();
+  }
+}