jzy/zerotier-magisk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[feat] add i18n localization: en/zh; add peers display; ui refresh

Browse Source
This commit is contained in:
eventlOwOp
2025-04-06 20:20:14 +08:00
parent 0405277231
commit bacea863bf
22 changed files with 3487 additions and 446 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/lib/services/auth_service.dart
+120
View File
@@ -0,0 +1,120 @@
import 'dart:io';
import 'package:dio/dio.dart';
import 'package:path_provider/path_provider.dart';
import 'dart:developer' as developer;
/// 带有ZeroTier认证的HTTP客户端
class AuthedDioClient {
final String _authToken;
final Dio _dio;
/// 创建带有ZeroTier认证的HTTP客户端
///
/// [authToken] - ZeroTier认证令牌
/// [baseUrl] - API基础URL
AuthedDioClient(this._authToken, String baseUrl) : _dio = Dio(BaseOptions(
baseUrl: 'http://$baseUrl',
connectTimeout: const Duration(seconds: 5),
receiveTimeout: const Duration(seconds: 5),
)) {
// 添加拦截器以处理身份验证
_dio.interceptors.add(InterceptorsWrapper(
onRequest: (options, handler) {
// 添加ZeroTier特定认证头
options.headers['X-ZT1-Auth'] = _authToken;
return handler.next(options);
},
));
}
/// 获取底层的Dio实例
Dio get dio => _dio;
/// 发送GET请求
Future<Response> get(String path) {
return _dio.get(path);
}
/// 发送POST请求
Future<Response> post(String path, {dynamic data}) {
return _dio.post(path, data: data);
}
/// 发送PUT请求
Future<Response> put(String path, {dynamic data}) {
return _dio.put(path, data: data);
}
/// 发送DELETE请求
Future<Response> delete(String path) {
return _dio.delete(path);
}
/// 关闭客户端
void close() {
_dio.close();
}
}
/// ZeroTier认证服务，用于管理认证和客户端创建
class AuthService {
static const String API_HOST = 'localhost:9993';
/// 缓存的HTTP客户端实例
AuthedDioClient? _cachedClient;
/// 获取已认证的HTTP客户端
Future<AuthedDioClient> get client async {
// 如果我们已经有缓存的客户端，直接返回
if (_cachedClient != null) {
return _cachedClient!;
}
try {
final authToken = await _loadAuthToken();
_cachedClient = AuthedDioClient(authToken, API_HOST);
return _cachedClient!;
} catch (e) {
developer.log('加载认证令牌失败', error: e.toString());
rethrow;
}
}
/// 清理资源
void dispose() {
if (_cachedClient != null) {
_cachedClient!.close();
_cachedClient = null;
}
}
/// 加载认证令牌
Future<String> _loadAuthToken() async {
try {
final path = (await getApplicationDocumentsDirectory()).path;
final file = File('$path/run/authtoken');
// 检查文件是否存在
if (!await file.exists()) {
throw FileSystemException('认证令牌文件未找到', file.path);
}
final token = await file.readAsString();
return token.trim();
} catch (e) {
developer.log('读取认证令牌失败', error: e.toString());
rethrow;
}
}
}
/// 超时异常类
class TimeoutException implements Exception {
final String message;
TimeoutException(this.message);
@override
String toString() => message;
}
app/lib/services/zerotier_service.dart
+305
View File
@@ -0,0 +1,305 @@
import 'dart:io';
import 'dart:developer' as developer;
import 'package:path_provider/path_provider.dart';
import 'package:dio/dio.dart';
import 'auth_service.dart';
import '../models/peer_info.dart';
/// ZeroTier服务状态详情
class ZerotierStatus {
final String address;
final String version;
final bool online;
final int primaryPort;
final List<String> listeningOn;
ZerotierStatus({
required this.address,
required this.version,
required this.online,
required this.primaryPort,
required this.listeningOn,
});
/// 从JSON创建状态对象
factory ZerotierStatus.fromJson(Map<String, dynamic> json) {
// 提取监听地址列表
List<String> listeningAddresses = [];
if (json['config'] != null &&
json['config']['settings'] != null &&
json['config']['settings']['listeningOn'] != null) {
listeningAddresses = List<String>.from(json['config']['settings']['listeningOn']);
}
// 提取主端口
int port = 0;
if (json['config'] != null &&
json['config']['settings'] != null &&
json['config']['settings']['primaryPort'] != null) {
port = json['config']['settings']['primaryPort'];
}
return ZerotierStatus(
address: json['address'] ?? '',
version: json['version'] ?? '',
online: json['online'] ?? false,
primaryPort: port,
listeningOn: listeningAddresses,
);
}
}
/// ZeroTier服务，提供所有ZeroTier相关功能
class ZerotierService {
final AuthService _authService = AuthService();
// 内部成员变量，存储最后一次加载的数据
List<String> _networkList = [];
List<PeerInfo> _peersList = [];
ZerotierStatus? _statusInfo;
// 表示ZeroTier服务是否正在运行
bool runningStatus = false;
// 允许外部访问最新数据的getter方法
List<String> get networkList => _networkList;
List<PeerInfo> get peersList => _peersList;
ZerotierStatus? get statusInfo => _statusInfo;
/// 向ZeroTier服务发送命令
Future<bool> zerotierCommand(String command) async {
try {
final path = (await getApplicationDocumentsDirectory()).path;
final file = File('$path/run/pipe');
if (!await file.exists()) {
developer.log('未找到ZeroTier命令管道: ${file.path}');
runningStatus = false;
// 特定错误，表示Magisk模块未运行
throw const FileSystemException('MODULE_NOT_RUNNING');
}
await file.writeAsString(command);
developer.log('已发送ZeroTier命令: $command');
return true;
} on FileSystemException catch (e) {
if (e.message == 'MODULE_NOT_RUNNING') {
developer.log('ZeroTier Magisk模块未运行');
} else {
developer.log('未找到ZeroTier命令管道，服务可能未运行');
}
runningStatus = false;
return false;
} catch (e) {
developer.log('发送ZeroTier命令失败', error: e.toString());
return false;
}
}
/// 加载网络列表
Future<List<String>?> loadNetwork() async {
developer.log('开始加载网络列表');
try {
final client = await _authService.client;
// 使用相对路径，基础URL已在客户端中配置
final resp = await client.get('/network');
if (resp.statusCode != 200) {
throw HttpException('加载网络列表失败: ${resp.statusCode}');
}
final body = resp.data;
_networkList = List<String>.from(body.map((u) => u['id']));
developer.log('成功加载网络列表: ${_networkList.length} 个网络');
return _networkList;
} on DioException catch (e) {
if (e.type == DioExceptionType.connectionTimeout ||
e.type == DioExceptionType.connectionError) {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
} else {
developer.log('加载网络列表失败', error: e.toString());
}
_networkList = [];
return null;
} on SocketException {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
_networkList = [];
return null;
} catch (e) {
developer.log('加载网络列表失败', error: e.toString());
_networkList = [];
return null;
}
}
/// 离开指定网络
Future<bool> leaveNetwork(String id) async {
try {
final client = await _authService.client;
// 使用相对路径
final resp = await client.delete('/network/$id');
final success = resp.statusCode == 200;
if (success) {
developer.log('成功离开网络: $id');
} else {
developer.log('离开网络失败: $id, 状态码: ${resp.statusCode}');
}
return success;
} on DioException catch (e) {
if (e.type == DioExceptionType.connectionTimeout ||
e.type == DioExceptionType.connectionError) {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
// 更新运行状态
runningStatus = false;
} else {
developer.log('离开网络错误', error: e.toString());
}
return false;
} on SocketException {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
// 更新运行状态
runningStatus = false;
return false;
} catch (e) {
developer.log('离开网络错误', error: e.toString());
return false;
}
}
/// 加入指定网络
Future<bool> joinNetwork(String id) async {
try {
if (id.isEmpty) {
developer.log('无法加入空网络ID');
return false;
}
final client = await _authService.client;
// 使用相对路径
final resp = await client.put('/network/$id');
final success = resp.statusCode == 200;
if (success) {
developer.log('成功加入网络: $id');
} else {
developer.log('加入网络失败: $id, 状态码: ${resp.statusCode}');
}
return success;
} on DioException catch (e) {
if (e.type == DioExceptionType.connectionTimeout ||
e.type == DioExceptionType.connectionError) {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
// 更新运行状态
runningStatus = false;
} else {
developer.log('加入网络错误', error: e.toString());
}
return false;
} on SocketException {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
// 更新运行状态
runningStatus = false;
return false;
} catch (e) {
developer.log('加入网络错误', error: e.toString());
return false;
}
}
/// 加载 Peer 列表
Future<List<PeerInfo>?> loadPeers() async {
developer.log('开始加载 Peer 列表');
try {
final client = await _authService.client;
final resp = await client.get('/peer');
if (resp.statusCode != 200) {
throw HttpException('加载 Peer 列表失败: ${resp.statusCode}');
}
final List<dynamic> rawPeers = resp.data;
_peersList = rawPeers
.map((p) => PeerInfo.fromJson(p as Map<String, dynamic>))
.toList();
// Sort the list (PLANETs first, then LEAFs by address)
_peersList.sort();
developer.log('成功加载 Peer 列表: ${_peersList.length} 个 Peers');
return _peersList;
} on DioException catch (e) {
if (e.type == DioExceptionType.connectionTimeout ||
e.type == DioExceptionType.connectionError) {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
} else {
developer.log('加载 Peer 列表 Dio 错误', error: e.toString(), stackTrace: e.stackTrace);
}
_peersList = [];
return null;
} on SocketException {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
_peersList = [];
return null;
} catch (e, s) {
developer.log('加载 Peer 列表失败', error: e.toString(), stackTrace: s);
_peersList = [];
return null;
}
}
/// 加载ZeroTier服务状态
Future<ZerotierStatus?> loadStatus() async {
developer.log('检查ZeroTier服务状态');
Map<String, dynamic>? statusData;
try {
// 尝试获取状态信息
final client = await _authService.client;
final response = await client.get('/status');
if (response.statusCode == 200) {
statusData = response.data;
developer.log('已获取ZeroTier状态信息');
} else {
developer.log('获取ZeroTier状态信息失败: ${response.statusCode}');
statusData = null;
}
} on DioException catch (e) {
if (e.type == DioExceptionType.connectionTimeout ||
e.type == DioExceptionType.connectionError) {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
} else {
developer.log('获取ZeroTier状态信息错误', error: e.toString());
}
statusData = null;
} on SocketException {
developer.log('无法连接到ZeroTier服务：服务可能未运行');
statusData = null;
} catch (e) {
developer.log('检查ZeroTier状态错误', error: e.toString());
statusData = null;
}
// 根据获取的状态信息更新运行状态和详情
if (statusData != null) {
runningStatus = true;
_statusInfo = ZerotierStatus.fromJson(statusData);
developer.log('ZeroTier服务状态: 运行中');
developer.log('已加载ZeroTier详细状态信息');
return _statusInfo;
} else {
runningStatus = false;
_statusInfo = null;
developer.log('ZeroTier服务状态: 未运行');
return null;
}
}
/// 释放资源
void dispose() {
_authService.dispose();
}
}