hongshaorou/rustdesk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #5408 from 21pages/ab

Browse Source 
ab: add full check in pullAb && sync recent check login
This commit is contained in:
RustDesk 2023-08-16 16:21:36 +08:00 committed by GitHub
commit 9ac4346850
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
flutter/lib/models/ab_model.dart
View File

@ -46,14 +46,17 @@ class AbModel {
AbModel(this.parent) { AbModel(this.parent) {
if (desktopType == DesktopType.main) { if (desktopType == DesktopType.main) {
Timer.periodic(Duration(milliseconds: 500), (timer) async { Timer.periodic(Duration(milliseconds: 500), (timer) async {
if (_timerCounter++ % 6 == 0) syncFromRecent(); if (_timerCounter++ % 6 == 0) {
if (!gFFI.userModel.isLogin) return;
syncFromRecent();
}
}); });
} }
} }
Future<void> pullAb({force = true, quiet = false}) async { Future<void> pullAb({force = true, quiet = false}) async {
debugPrint("pullAb, force:$force, quiet:$quiet"); debugPrint("pullAb, force:$force, quiet:$quiet");
if (gFFI.userModel.userName.isEmpty) return; if (!gFFI.userModel.isLogin) return;
if (abLoading.value) return; if (abLoading.value) return;
if (!force && initialized) return; if (!force && initialized) return;
DateTime startTime = DateTime.now(); DateTime startTime = DateTime.now();
@ -101,6 +104,9 @@ class AbModel {
peers.add(Peer.fromJson(peer)); peers.add(Peer.fromJson(peer));
} }
} }
if (isFull(false)) {
peers.removeRange(licensedDevices, peers.length);
}
_saveCache(); // save on success _saveCache(); // save on success
} }
} }
@ -442,7 +448,7 @@ class AbModel {
} }
// Be careful with loop calls // Be careful with loop calls
if (syncChanged && push) { if (syncChanged && push) {
pushAb(toastIfSucc: false); pushAb(toastIfSucc: false, toastIfFail: false);
} else if (uiChanged) { } else if (uiChanged) {
peers.refresh(); peers.refresh();
} }