lee/rustdesk
1
0
Fork 0
mirror of https://github.com/rustdesk/rustdesk.git synced 2025-12-12 02:57:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix group visit

Browse Source 
Signed-off-by: 21pages <pages21@163.com>
This commit is contained in:
21pages
2023-06-17 20:48:58 +08:00
parent 5a14945666
commit 8b7a145c61
6 changed files with 99 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

111
flutter/lib/models/group_model.dart
View File

@@ -1,6 +1,5 @@
import 'package:flutter/widgets.dart';
import 'package:flutter_hbb/common.dart';
import 'package:flutter_hbb/common/widgets/peer_tab_page.dart';
import 'package:flutter_hbb/common/hbbs/hbbs.dart';
import 'package:flutter_hbb/models/model.dart';
import 'package:flutter_hbb/models/peer_model.dart';
@@ -10,10 +9,12 @@ import 'dart:convert';
import 'package:http/http.dart' as http;
class GroupModel {
final RxBool userLoading = false.obs;
final RxString userLoadError = "".obs;
final RxBool groupLoading = false.obs;
final RxString groupLoadError = "".obs;
final RxBool peerLoading = false.obs; //to-do: not used
final RxString peerLoadError = "".obs;
final RxString groupName = ''.obs;
final RxString groupId = ''.obs;
final RxList<UserPayload> users = RxList.empty(growable: true);
final RxList<PeerPayload> peerPayloads = RxList.empty(growable: true);
final RxList<Peer> peersShow = RxList.empty(growable: true);
@@ -22,10 +23,12 @@ class GroupModel {
GroupModel(this.parent);
Future<void> reset() async {
userLoading.value = false;
userLoadError.value = "";
groupLoading.value = false;
groupLoadError.value = "";
peerLoading.value = false;
peerLoadError.value = "";
groupName.value = '';
groupId.value = '';
users.clear();
peerPayloads.clear();
peersShow.clear();
@@ -33,13 +36,26 @@ class GroupModel {
Future<void> pull() async {
await reset();
if (bind.mainGetLocalOption(key: 'access_token') == '') {
return;
}
try {
if (!await _getGroup()) {
reset();
return;
}
} catch (e) {
debugPrintStack(label: '$e');
reset();
return;
}
if (gFFI.userModel.userName.isEmpty ||
(gFFI.userModel.isAdmin.isFalse && gFFI.userModel.groupName.isEmpty)) {
(gFFI.userModel.isAdmin.isFalse && groupName.isEmpty)) {
gFFI.peerTabModel.check_dynamic_tabs();
return;
}
userLoading.value = true;
userLoadError.value = "";
groupLoading.value = true;
groupLoadError.value = "";
final api = "${await bind.mainGetApiServer()}/api/users";
try {
var uri0 = Uri.parse(api);
@@ -56,8 +72,7 @@ class GroupModel {
queryParameters: {
'current': current.toString(),
'pageSize': pageSize.toString(),
if (gFFI.userModel.isAdmin.isFalse)
'grp': gFFI.userModel.groupName.value,
if (gFFI.userModel.isAdmin.isFalse) 'grp': groupId.value,
});
final resp = await http.get(uri, headers: getHttpHeaders());
if (resp.body.isNotEmpty && resp.body.toLowerCase() != "null") {
@@ -65,12 +80,17 @@ class GroupModel {
if (json.containsKey('error')) {
throw json['error'];
} else {
if (total == 0) total = json['total'];
if (json.containsKey('data')) {
final data = json['data'];
if (data is List) {
for (final user in data) {
users.add(UserPayload.fromJson(user));
if (json.containsKey('total')) {
if (total == 0) total = json['total'];
if (json.containsKey('data')) {
final data = json['data'];
if (data is List) {
for (final user in data) {
final u = UserPayload.fromJson(user);
if (!users.any((e) => e.name == u.name)) {
users.add(u);
}
}
}
}
}
@@ -78,15 +98,43 @@ class GroupModel {
}
} while (current * pageSize < total);
} catch (err) {
debugPrint('$err');
userLoadError.value = err.toString();
debugPrintStack(label: '$err');
groupLoadError.value = err.toString();
} finally {
userLoading.value = false;
groupLoading.value = false;
gFFI.peerTabModel.check_dynamic_tabs();
}
}
Future<void> pullUserPeers(String username) async {
Future<bool> _getGroup() async {
final url = await bind.mainGetApiServer();
final body = {
'id': await bind.mainGetMyId(),
'uuid': await bind.mainGetUuid()
};
try {
final response = await http.post(Uri.parse('$url/api/currentGroup'),
headers: getHttpHeaders(), body: json.encode(body));
final status = response.statusCode;
if (status == 401 || status == 400) {
return false;
}
final data = json.decode(response.body);
final error = data['error'];
if (error != null) {
throw error;
}
groupName.value = data['name'] ?? '';
groupId.value = data['id'] ?? '';
return groupId.value.isNotEmpty && groupName.isNotEmpty;
} catch (e) {
debugPrintStack(label: '$e');
} finally {}
return false;
}
Future<void> pullUserPeers(UserPayload user) async {
peerPayloads.clear();
peersShow.clear();
peerLoading.value = true;
@@ -107,8 +155,7 @@ class GroupModel {
queryParameters: {
'current': current.toString(),
'pageSize': pageSize.toString(),
'grp': gFFI.userModel.groupName.value,
'target_user': username
'target_user': user.id,
});
final resp = await http.get(uri, headers: getHttpHeaders());
if (resp.body.isNotEmpty && resp.body.toLowerCase() != "null") {
@@ -116,14 +163,16 @@ class GroupModel {
if (json.containsKey('error')) {
throw json['error'];
} else {
if (total == 0) total = json['total'];
if (json.containsKey('data')) {
final data = json['data'];
if (data is List) {
for (final p in data) {
final peer = PeerPayload.fromJson(p);
peerPayloads.add(peer);
peersShow.add(PeerPayload.toPeer(peer));
if (json.containsKey('total')) {
if (total == 0) total = json['total'];
if (json.containsKey('data')) {
final data = json['data'];
if (data is List) {
for (final p in data) {
final peer = PeerPayload.fromJson(p);
peerPayloads.add(peer);
peersShow.add(PeerPayload.toPeer(peer));
}
}
}
}
@@ -131,7 +180,7 @@ class GroupModel {
}
} while (current * pageSize < total);
} catch (err) {
debugPrint('$err');
debugPrintStack(label: '$err');
peerLoadError.value = err.toString();
} finally {
peerLoading.value = false;