lifegpc/eh_downloader_flutter
1
0
Fork 0
mirror of https://github.com/lifegpc/eh_downloader_flutter.git synced 2026-06-28 14:46:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix multiple websocket connection was established after change api entrypoint

Browse Source
This commit is contained in:
lifegpc
2024-05-29 08:17:21 +00:00
committed by GitHub
parent 4e013e317d
commit 69929d6990
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
lib/task.dart
View File

@@ -97,7 +97,8 @@ class TaskManager {
Future<void> connect() async {
if (auth.canManageTasks != true) return;
try {
_channel = await connectWebSocket(api.getTaskUrl());
final url = api.getTaskUrl();
_channel = await connectWebSocket(url);
_channel!.stream.listen((event) {
try {
final data = jsonDecode(event) as Map<String, dynamic>;
@@ -196,7 +197,8 @@ class TaskManager {
}
}, onError: (e) {
_log.warning("Task websocket error: $e");
if (_allowReconnect && !_needClosed) {
final url2 = api.getTaskUrl();
if (_allowReconnect && !_needClosed && url == url2) {
_log.info("Reconnecting to task server in 5 seconds");
_reconnectTimer = Timer(const Duration(seconds: 5), () {
_reconnectTimer = null;
@@ -209,7 +211,8 @@ class TaskManager {
}, onDone: () {
_log.warning(
"WenSocket closed: ${_channel?.closeCode} ${_channel?.closeReason}");
if (_allowReconnect && !_needClosed) {
final url2 = api.getTaskUrl();
if (_allowReconnect && !_needClosed && url == url2) {
_log.info("Reconnecting to task server in 5 seconds");
_reconnectTimer = Timer(const Duration(seconds: 5), () {
_reconnectTimer = null;