twonly/twonly-app
1
0
Fork 0
mirror of https://github.com/twonlyapp/twonly-app.git synced 2026-01-15 09:28:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix #98

Browse source
This commit is contained in:
otsmr 2025-04-08 17:30:37 +02:00
parent d25f4cb36d
commit 8b998914e3
1 changed files with 23 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
lib/src/providers/api_provider.dart
View file

@ -6,6 +6,7 @@ import 'dart:math';
import 'package:fixnum/fixnum.dart';
import 'package:flutter/foundation.dart';
import 'package:logging/logging.dart';
import 'package:mutex/mutex.dart';
import 'package:package_info_plus/package_info_plus.dart';
import 'package:twonly/globals.dart';
import 'package:twonly/src/app.dart';
@ -26,6 +27,8 @@ import 'package:web_socket_channel/io.dart';
import 'package:libsignal_protocol_dart/src/ecc/ed25519.dart';
import 'package:web_socket_channel/web_socket_channel.dart';
final lockConnecting = Mutex();
/// The ApiProvider is responsible for communicating with the server.
/// It handles errors and does automatically tries to reconnect on
/// errors or network changes.
@ -95,29 +98,31 @@ class ApiProvider {
}
Future<bool> connect() async {
if (_channel != null) {
return true;
}
// ensure that the connect function is not called again by the timer.
if (reconnectionTimer != null) {
reconnectionTimer!.cancel();
}
return lockConnecting.protect<bool>(() async {
if (_channel != null) {
return true;
}
// ensure that the connect function is not called again by the timer.
if (reconnectionTimer != null) {
reconnectionTimer!.cancel();
}
isAuthenticated = false;
isAuthenticated = false;
log.fine("Trying to connect to the backend $apiUrl!");
if (await _connectTo(apiUrl)) {
await onConnected();
return true;
}
if (backupApiUrl != null) {
log.fine("Trying to connect to the backup backend $backupApiUrl!");
if (await _connectTo(backupApiUrl!)) {
log.fine("Trying to connect to the backend $apiUrl!");
if (await _connectTo(apiUrl)) {
await onConnected();
return true;
}
}
return false;
if (backupApiUrl != null) {
log.fine("Trying to connect to the backup backend $backupApiUrl!");
if (await _connectTo(backupApiUrl!)) {
await onConnected();
return true;
}
}
return false;
});
}
bool get isConnected => _channel != null && _channel!.closeCode != null;