TheLanc3/rustdesk
1
0
Fork 0
mirror of https://github.com/rustdesk/rustdesk.git synced 2026-04-14 18:21:28 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix: load peers, always push event data (#10856)

Browse Source 
Signed-off-by: fufesou <linlong1266@gmail.com>
This commit is contained in:
fufesou
2025-02-20 22:44:18 +08:00
committed by GitHub
parent f631c1c28d
commit ce1e4863cb
1 changed files with 24 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
src/flutter_ffi.rs
View File

@@ -1121,24 +1121,24 @@ fn load_recent_peers(
} }
pub fn main_load_recent_peers() { pub fn main_load_recent_peers() {
let push_to_flutter = |peers, ids| {
let mut data = HashMap::from([("name", "load_recent_peers".to_owned()), ("peers", peers)]);
if let Some(ids) = ids {
data.insert("ids", ids);
}
let _res = flutter::push_global_event(
flutter::APP_TYPE_MAIN,
serde_json::ser::to_string(&data).unwrap_or("".to_owned()),
);
};
if !config::APP_DIR.read().unwrap().is_empty() { if !config::APP_DIR.read().unwrap().is_empty() {
let vec_id_modified_time_path = PeerConfig::get_vec_id_modified_time_path(&None); let vec_id_modified_time_path = PeerConfig::get_vec_id_modified_time_path(&None);
if vec_id_modified_time_path.is_empty() { if vec_id_modified_time_path.is_empty() {
push_to_flutter("".to_owned(), None);
return; return;
} }
let push_to_flutter = |peers, ids| {
let mut data =
HashMap::from([("name", "load_recent_peers".to_owned()), ("peers", peers)]);
if let Some(ids) = ids {
data.insert("ids", ids);
}
let _res = flutter::push_global_event(
flutter::APP_TYPE_MAIN,
serde_json::ser::to_string(&data).unwrap_or("".to_owned()),
);
};
let load_two_times = vec_id_modified_time_path.len() > PeerConfig::BATCH_LOADING_COUNT let load_two_times = vec_id_modified_time_path.len() > PeerConfig::BATCH_LOADING_COUNT
&& cfg!(target_os = "windows"); && cfg!(target_os = "windows");
let mut all_peers = vec![]; let mut all_peers = vec![];
@@ -1168,6 +1168,8 @@ pub fn main_load_recent_peers() {
serde_json::ser::to_string(&all_peers).unwrap_or("".to_owned()), serde_json::ser::to_string(&all_peers).unwrap_or("".to_owned()),
None, None,
); );
} else {
push_to_flutter("".to_owned(), None)
} }
} }
@@ -1189,6 +1191,13 @@ pub fn main_load_recent_peers_for_ab(filter: String) -> String {
} }
pub fn main_load_fav_peers() { pub fn main_load_fav_peers() {
let push_to_flutter = |peers| {
let data = HashMap::from([("name", "load_fav_peers".to_owned()), ("peers", peers)]);
let _res = flutter::push_global_event(
flutter::APP_TYPE_MAIN,
serde_json::ser::to_string(&data).unwrap_or("".to_owned()),
);
};
if !config::APP_DIR.read().unwrap().is_empty() { if !config::APP_DIR.read().unwrap().is_empty() {
let favs = get_fav(); let favs = get_fav();
let mut recent = PeerConfig::peers(Some(favs.clone())); let mut recent = PeerConfig::peers(Some(favs.clone()));
@@ -1217,17 +1226,9 @@ pub fn main_load_fav_peers() {
.map(|(id, _, p)| peer_to_map(id, p)) .map(|(id, _, p)| peer_to_map(id, p))
.collect(); .collect();
let data = HashMap::from([ push_to_flutter(serde_json::ser::to_string(&peers).unwrap_or("".to_owned()));
("name", "load_fav_peers".to_owned()), } else {
( push_to_flutter("".to_owned());
"peers",
serde_json::ser::to_string(&peers).unwrap_or("".to_owned()),
),
]);
let _res = flutter::push_global_event(
flutter::APP_TYPE_MAIN,
serde_json::ser::to_string(&data).unwrap_or("".to_owned()),
);
} }
} }