flutter_desktop_cm fix Windows build & TODO clipboard_file

src/ui/cm.rs

@@ -1,7 +1,11 @@
-use crate::ipc::{self, new_listener, Connection, Data, start_pa};
-#[cfg(windows)]
-use crate::ipc::start_clipboard_file;
+#[cfg(target_os = "linux")]
+use crate::ipc::start_pa;
+use crate::ipc::{self, new_listener, Connection, Data};
 use crate::VERSION;
+#[cfg(windows)]
+use clipboard::{
+    create_cliprdr_context, empty_clipboard, get_rx_clip_client, server_clip_file, set_conn_enabled,
+};
 use hbb_common::fs::{
     can_enable_overwrite_detection, get_string, is_write_need_confirmation, new_send_confirm,
     DigestCheckResult,
@@ -158,7 +162,7 @@ impl ConnectionManager {
                     id,
                     file_num,
                     mut files,
-                    overwrite_detection
+                    overwrite_detection,
                 } => {
                     // cm has no show_hidden context
                     // dummy remote, show_hidden, is_remote
@@ -435,7 +439,7 @@ impl sciter::EventHandler for ConnectionManager {
     }
 }
 
-enum ClipboardFileData {
+pub enum ClipboardFileData {
     #[cfg(windows)]
     Clip((i32, ipc::ClipbaordFile)),
     Enable((i32, bool)),
@@ -537,3 +541,76 @@ async fn start_ipc(cm: ConnectionManager) {
     crate::platform::quit_gui();
 }
 
+#[cfg(windows)]
+#[tokio::main(flavor = "current_thread")]
+pub async fn start_clipboard_file(
+    cm: ConnectionManager,
+    mut rx: mpsc::UnboundedReceiver<ClipboardFileData>,
+) {
+    let mut cliprdr_context = None;
+    let mut rx_clip_client = get_rx_clip_client().lock().await;
+
+    loop {
+        tokio::select! {
+            clip_file = rx_clip_client.recv() => match clip_file {
+                Some((conn_id, clip)) => {
+                    cmd_inner_send(
+                        &cm,
+                        conn_id,
+                        Data::ClipbaordFile(clip)
+                    );
+                }
+                None => {
+                    //
+                }
+            },
+            server_msg = rx.recv() => match server_msg {
+                Some(ClipboardFileData::Clip((conn_id, clip))) => {
+                    if let Some(ctx) = cliprdr_context.as_mut() {
+                        server_clip_file(ctx, conn_id, clip);
+                    }
+                }
+                Some(ClipboardFileData::Enable((id, enabled))) => {
+                    if enabled && cliprdr_context.is_none() {
+                        cliprdr_context = Some(match create_cliprdr_context(true, false) {
+                            Ok(context) => {
+                                log::info!("clipboard context for file transfer created.");
+                                context
+                            }
+                            Err(err) => {
+                                log::error!(
+                                    "Create clipboard context for file transfer: {}",
+                                    err.to_string()
+                                );
+                                return;
+                            }
+                        });
+                    }
+                    set_conn_enabled(id, enabled);
+                    if !enabled {
+                        if let Some(ctx) = cliprdr_context.as_mut() {
+                            empty_clipboard(ctx, id);
+                        }
+                    }
+                }
+                None => {
+                    break
+                }
+            }
+        }
+    }
+}
+
+#[cfg(windows)]
+fn cmd_inner_send(cm: &ConnectionManager, id: i32, data: Data) {
+    let lock = cm.read().unwrap();
+    if id != 0 {
+        if let Some(s) = lock.senders.get(&id) {
+            allow_err!(s.send(data));
+        }
+    } else {
+        for s in lock.senders.values() {
+            allow_err!(s.send(data.clone()));
+        }
+    }
+}