Compare commits

...

3 Commits

Author SHA1 Message Date
dom
bac0769933 add split settings model
Signed-off-by: dom <githubaccount56556@proton.me>
2026-04-18 12:28:40 +08:00
dom
24f2cfa4e9 tweaks
Signed-off-by: dom <githubaccount56556@proton.me>
2026-04-18 12:28:40 +08:00
0x535A
970ee679f1 fix: reset Dio adapters on iOS network switch (#1885)
* fix reset Dio adapters on iOS network switch

* improve iOS connectivity adapter reset safeguards

* refa

---------

Co-authored-by: My-Responsitories <107370289+My-Responsitories@users.noreply.github.com>
2026-04-18 12:26:24 +08:00
5 changed files with 234 additions and 93 deletions

View File

@@ -16,10 +16,11 @@ import 'package:PiliPlus/utils/storage_pref.dart';
import 'package:PiliPlus/utils/utils.dart';
import 'package:archive/archive.dart';
import 'package:brotli/brotli.dart';
import 'package:connectivity_plus/connectivity_plus.dart';
import 'package:dio/dio.dart';
import 'package:dio/io.dart';
import 'package:dio_http2_adapter/dio_http2_adapter.dart';
import 'package:flutter/foundation.dart' show kDebugMode;
import 'package:flutter/foundation.dart' show kDebugMode, listEquals;
class Request {
static const _gzipDecoder = GZipDecoder();
@@ -115,28 +116,24 @@ class Request {
return h11;
}
/*
* config it and create
*/
Request._internal() {
//BaseOptions、Options、RequestOptions 都可以配置参数,优先级别依次递增,且可以根据优先级别覆盖参数
BaseOptions options = BaseOptions(
//请求基地址,可以包含子路径
baseUrl: HttpString.apiBaseUrl,
//连接服务器超时时间,单位是毫秒.
connectTimeout: const Duration(milliseconds: 10000),
//响应流上前后两次接受到数据的间隔,单位为毫秒。
receiveTimeout: const Duration(milliseconds: 10000),
//Http请求头.
headers: {
'user-agent': 'Dart/3.6 (dart:io)', // Http2Adapter不会自动添加标头
if (!_enableHttp2) 'connection': 'keep-alive',
'accept-encoding': 'br,gzip',
},
responseDecoder: _responseDecoder, // Http2Adapter没有自动解压
persistentConnection: true,
);
static Timer? _networkChangeDebounce;
static void _onConnectivityChanged(List<ConnectivityResult> result) {
if (listEquals(result, const [ConnectivityResult.none])) {
return;
}
_networkChangeDebounce?.cancel();
_networkChangeDebounce = Timer(
const Duration(milliseconds: 500),
_resetAdaptersForNetworkChange,
);
}
static void _watchConnectivity() {
Connectivity().onConnectivityChanged.skip(1).listen(_onConnectivityChanged);
}
static (IOHttpClientAdapter, ConnectionManager?) _createPool() {
final bool enableSystemProxy;
late final String systemProxyHost;
late final int? systemProxyPort;
@@ -160,30 +157,72 @@ class Request {
..autoUncompress = false, // Http2Adapter没有自动解压, 统一行为
);
final connectionManager = _enableHttp2
? ConnectionManager(
idleTimeout: const Duration(seconds: 15),
onClientCreate: enableSystemProxy
? (_, config) => config
..proxy = Uri(
scheme: 'http',
host: systemProxyHost,
port: systemProxyPort,
)
..onBadCertificate = (_) => true
: Pref.badCertificateCallback
? (_, config) => config.onBadCertificate = (_) => true
: null,
)
: null;
return (http11Adapter, connectionManager);
}
@pragma('vm:notify-debugger-on-exception')
static void _resetAdaptersForNetworkChange() {
try {
final (h11, connectionManager) = _createPool();
if (connectionManager != null) {
(dio.httpClientAdapter as Http2Adapter)
..connectionManager.close(force: true)
..connectionManager = connectionManager
..fallbackAdapter.close(force: true)
..fallbackAdapter = h11;
_http11Dio?.httpClientAdapter = h11;
} else {
dio
..httpClientAdapter.close(force: true)
..httpClientAdapter = h11;
}
} catch (_) {}
}
/*
* config it and create
*/
Request._internal() {
//BaseOptions、Options、RequestOptions 都可以配置参数,优先级别依次递增,且可以根据优先级别覆盖参数
BaseOptions options = BaseOptions(
//请求基地址,可以包含子路径
baseUrl: HttpString.apiBaseUrl,
//连接服务器超时时间,单位是毫秒.
connectTimeout: const Duration(milliseconds: 10000),
//响应流上前后两次接受到数据的间隔,单位为毫秒。
receiveTimeout: const Duration(milliseconds: 10000),
//Http请求头.
headers: {
'user-agent': 'Dart/3.6 (dart:io)', // Http2Adapter不会自动添加标头
if (!_enableHttp2) 'connection': 'keep-alive',
'accept-encoding': 'br,gzip',
},
responseDecoder: _responseDecoder, // Http2Adapter没有自动解压
persistentConnection: true,
);
final (h11, connectionManager) = _createPool();
dio = Dio(options)
..httpClientAdapter = _enableHttp2
? Http2Adapter(
ConnectionManager(
idleTimeout: const Duration(seconds: 15),
onClientCreate: enableSystemProxy
? (_, config) {
config
..proxy = Uri(
scheme: 'http',
host: systemProxyHost,
port: systemProxyPort,
)
..onBadCertificate = (_) => true;
}
: Pref.badCertificateCallback
? (_, config) {
config.onBadCertificate = (_) => true;
}
: null,
),
fallbackAdapter: http11Adapter,
)
: http11Adapter;
? Http2Adapter(connectionManager, fallbackAdapter: h11)
: h11;
// 先于其他Interceptor
if (Pref.retryCount != 0) {
@@ -208,6 +247,8 @@ class Request {
..options.validateStatus = (int? status) {
return status != null && status >= 200 && status < 300;
};
if (Platform.isIOS) _watchConnectivity();
}
/*

View File

@@ -70,19 +70,23 @@ List<SettingsModel> get extraSettings => [
onTap: _showDownPathDialog,
),
],
SwitchModel(
title: '空降助手',
subtitle: '点击配置',
setKey: SettingBoxKey.enableSponsorBlock,
defaultVal: false,
onTap: (context) => Get.toNamed('/sponsorBlock'),
leading: const Stack(
clipBehavior: Clip.none,
alignment: Alignment.center,
children: [
Icon(Icons.shield_outlined),
Icon(Icons.play_arrow_rounded, size: 15),
],
SplitModel(
normalModel: const NormalModel.split(
title: '空降助手',
subtitle: '点击配置',
leading: Stack(
clipBehavior: Clip.none,
alignment: Alignment.center,
children: [
Icon(Icons.shield_outlined),
Icon(Icons.play_arrow_rounded, size: 15),
],
),
),
switchModel: SwitchModel.split(
defaultVal: false,
setKey: SettingBoxKey.enableSponsorBlock,
onTap: (context) => Get.toNamed('/sponsorBlock'),
),
),
PopupModel<SkipType>(
@@ -94,14 +98,18 @@ List<SettingsModel> get extraSettings => [
.put(SettingBoxKey.pgcSkipType, value.index)
.whenComplete(setState),
),
SwitchModel(
title: '检查未读动态',
subtitle: '点击设置检查周期(min)',
leading: const Icon(Icons.notifications_none),
setKey: SettingBoxKey.checkDynamic,
defaultVal: true,
onChanged: (value) => Get.find<MainController>().checkDynamic = value,
onTap: _showDynDialog,
SplitModel(
normalModel: const NormalModel.split(
title: '检查未读动态',
subtitle: '点击设置检查周期(min)',
leading: Icon(Icons.notifications_none),
),
switchModel: SwitchModel.split(
defaultVal: true,
setKey: SettingBoxKey.checkDynamic,
onChanged: (value) => Get.find<MainController>().checkDynamic = value,
onTap: _showDynDialog,
),
),
SwitchModel(
title: '显示视频分段信息',
@@ -615,12 +623,17 @@ List<SettingsModel> get extraSettings => [
defaultVal: false,
onChanged: (value) => MemberTabType.showMemberShop = value,
),
const SwitchModel(
leading: Icon(Icons.airplane_ticket_outlined),
title: '设置代理',
subtitle: '设置代理 host:port',
setKey: SettingBoxKey.enableSystemProxy,
onTap: _showProxyDialog,
const SplitModel(
normalModel: NormalModel.split(
title: '设置代理',
subtitle: '设置代理 host:port',
leading: Icon(Icons.airplane_ticket_outlined),
),
switchModel: SwitchModel.split(
defaultVal: false,
setKey: SettingBoxKey.enableSystemProxy,
onTap: _showProxyDialog,
),
),
const SwitchModel(
title: '自动清除缓存',

View File

@@ -30,6 +30,43 @@ sealed class SettingsModel {
});
}
class SplitModel extends SettingsModel {
const SplitModel({
super.contentPadding,
super.titleStyle,
required this.normalModel,
required this.switchModel,
});
@override
String? get effectiveSubtitle => normalModel.effectiveSubtitle;
@override
String get effectiveTitle => normalModel.effectiveTitle;
@override
String? get title => normalModel.title;
final NormalModel normalModel;
final SwitchModel switchModel;
@override
Widget get widget => SetSwitchItem(
title: effectiveTitle,
subtitle: effectiveSubtitle,
setKey: switchModel.setKey,
defaultVal: switchModel.defaultVal,
onChanged: switchModel.onChanged,
needReboot: switchModel.needReboot,
leading: normalModel.leading,
onTap: switchModel.onTap,
contentPadding: contentPadding,
titleStyle: titleStyle,
isSplit: true,
);
}
class PopupModel<T extends EnumWithLabel> extends SettingsModel {
const PopupModel({
required this.title,
@@ -88,6 +125,18 @@ class NormalModel extends SettingsModel {
this.onTap,
}) : assert(title != null || getTitle != null);
const NormalModel.split({
super.subtitle,
super.leading,
super.contentPadding,
super.titleStyle,
this.title,
this.getTitle,
this.getSubtitle,
this.getTrailing,
}) : onTap = null,
assert(title != null || getTitle != null);
@override
String get effectiveTitle => title ?? getTitle!();
@override
@@ -109,7 +158,7 @@ class NormalModel extends SettingsModel {
class SwitchModel extends SettingsModel {
@override
final String title;
final String? title;
final String setKey;
final bool defaultVal;
final ValueChanged<bool>? onChanged;
@@ -121,7 +170,7 @@ class SwitchModel extends SettingsModel {
super.leading,
super.contentPadding,
super.titleStyle,
required this.title,
required String this.title,
required this.setKey,
this.defaultVal = false,
this.onChanged,
@@ -129,14 +178,22 @@ class SwitchModel extends SettingsModel {
this.onTap,
});
const SwitchModel.split({
required this.setKey,
this.defaultVal = false,
this.needReboot = false,
this.onChanged,
this.onTap,
}) : title = null;
@override
String get effectiveTitle => title;
String get effectiveTitle => title!;
@override
String? get effectiveSubtitle => subtitle;
@override
Widget get widget => SetSwitchItem(
title: title,
title: title!,
subtitle: subtitle,
setKey: setKey,
defaultVal: defaultVal,

View File

@@ -82,14 +82,18 @@ List<SettingsModel> get styleSettings => [
defaultVal: false,
needReboot: true,
),
SwitchModel(
title: 'App字体字重',
subtitle: '点击设置',
setKey: SettingBoxKey.appFontWeight,
defaultVal: false,
leading: const Icon(Icons.text_fields),
onChanged: (_) => Get.updateMyAppTheme(),
onTap: _showFontWeightDialog,
SplitModel(
normalModel: const NormalModel.split(
title: 'App字体字重',
subtitle: '点击设置',
leading: Icon(Icons.text_fields),
),
switchModel: SwitchModel.split(
defaultVal: false,
setKey: SettingBoxKey.appFontWeight,
onChanged: (_) => Get.updateMyAppTheme(),
onTap: _showFontWeightDialog,
),
),
NormalModel(
title: '界面缩放',

View File

@@ -17,8 +17,10 @@ class SetSwitchItem extends StatefulWidget {
final void Function(BuildContext context)? onTap;
final EdgeInsetsGeometry? contentPadding;
final TextStyle? titleStyle;
final bool isSplit;
const SetSwitchItem({
super.key,
required this.title,
this.subtitle,
required this.setKey,
@@ -29,7 +31,7 @@ class SetSwitchItem extends StatefulWidget {
this.onTap,
this.contentPadding,
this.titleStyle,
super.key,
this.isSplit = false,
});
@override
@@ -103,7 +105,17 @@ class _SetSwitchItemState extends State<SetSwitchItem> {
final subTitleStyle = theme.textTheme.labelMedium!.copyWith(
color: theme.colorScheme.outline,
);
return ListTile(
final switchBtn = Transform.scale(
scale: 0.8,
alignment: .centerRight,
child: Switch(
value: val,
onChanged: switchChange,
),
);
Widget child(Widget? trailing) => ListTile(
contentPadding: widget.contentPadding,
enabled: widget.onTap == null ? true : val,
onTap: widget.onTap == null ? switchChange : () => widget.onTap!(context),
@@ -112,14 +124,28 @@ class _SetSwitchItemState extends State<SetSwitchItem> {
? Text(widget.subtitle!, style: subTitleStyle)
: null,
leading: widget.leading,
trailing: Transform.scale(
scale: 0.8,
alignment: .centerRight,
child: Switch(
value: val,
onChanged: switchChange,
),
),
trailing: trailing,
);
if (widget.isSplit) {
return Row(
children: [
Expanded(child: child(null)),
SizedBox(
height: 25,
child: VerticalDivider(
width: 1,
color: theme.colorScheme.outline.withValues(alpha: .3),
),
),
Padding(
padding: const .only(left: 4, right: 24),
child: switchBtn,
),
],
);
}
return child(switchBtn);
}
}