From c2161da3cab8f4dd8ea244307b7f8a4d3f4044c3 Mon Sep 17 00:00:00 2001
From: OJ Kwon <kwon.ohjoong@gmail.com>
Date: Fri, 6 Apr 2018 12:07:18 -0700
Subject: [PATCH] feat(browser): implement device select dialog

---
 components/compositing/compositor_thread.rs |  3 ++
 ports/servo/browser.rs                      | 39 +++++++++++++++++++++
 2 files changed, 42 insertions(+)

diff --git a/components/compositing/compositor_thread.rs b/components/compositing/compositor_thread.rs
index 3f43c2ba2bb1..3d9a320c897a 100644
--- a/components/compositing/compositor_thread.rs
+++ b/components/compositing/compositor_thread.rs
@@ -141,6 +141,8 @@ pub enum EmbedderMsg {
     LoadComplete(TopLevelBrowsingContextId),
     /// A pipeline panicked. First string is the reason, second one is the backtrace.
     Panic(TopLevelBrowsingContextId, String, Option<String>),
+    /// Open dialog to select bluetooth device.
+    GetSelectedBluetoothDevice(Vec<String>, IpcSender<Option<String>>),
     /// Servo has shut down
     Shutdown,
 }
@@ -241,6 +243,7 @@ impl Debug for EmbedderMsg {
             EmbedderMsg::LoadStart(..) => write!(f, "LoadStart"),
             EmbedderMsg::LoadComplete(..) => write!(f, "LoadComplete"),
             EmbedderMsg::Panic(..) => write!(f, "Panic"),
+            EmbedderMsg::GetSelectedBluetoothDevice(..) => write!(f, "GetSelectedBluetoothDevice"),
             EmbedderMsg::Shutdown => write!(f, "Shutdown"),
         }
     }
diff --git a/ports/servo/browser.rs b/ports/servo/browser.rs
index ff0a8d20ceed..92422388e223 100644
--- a/ports/servo/browser.rs
+++ b/ports/servo/browser.rs
@@ -7,6 +7,7 @@ use glutin_app::keyutils::{CMD_OR_CONTROL, CMD_OR_ALT};
 use glutin_app::window::{Window, LINE_HEIGHT};
 use servo::compositing::compositor_thread::EmbedderMsg;
 use servo::compositing::windowing::{WebRenderDebugOption, WindowEvent};
+use servo::ipc_channel::ipc::IpcSender;
 use servo::msg::constellation_msg::{Key, TopLevelBrowsingContextId as BrowserId};
 use servo::msg::constellation_msg::{KeyModifiers, KeyState, TraversalDirection};
 use servo::net_traits::pub_domains::is_reg_domain;
@@ -16,6 +17,8 @@ use servo::servo_url::ServoUrl;
 use servo::webrender_api::ScrollLocation;
 use std::mem;
 use std::rc::Rc;
+#[cfg(target_os = "linux")]
+use std::thread;
 use tinyfiledialogs;
 
 pub struct Browser {
@@ -288,6 +291,9 @@ impl Browser {
                     self.shutdown_requested = true;
                 },
                 EmbedderMsg::Panic(_browser_id, _reason, _backtrace) => {
+                },
+                EmbedderMsg::GetSelectedBluetoothDevice(devices, sender) => {
+                    platform_get_selected_devices(devices, sender);
                 }
             }
         }
@@ -295,6 +301,39 @@ impl Browser {
 
 }
 
+#[cfg(target_os = "linux")]
+fn platform_get_selected_devices(devices: Vec<String>, sender: IpcSender<Option<String>>) {
+    let picker_name = "Choose a device";
+
+    thread::Builder::new().name(picker_name.to_owned()).spawn(move || {
+        let dialog_rows: Vec<&str> = devices.iter()
+            .map(|s| s.as_ref())
+            .collect();
+        let dialog_rows: Option<&[&str]> = Some(dialog_rows.as_slice());
+
+        match tinyfiledialogs::list_dialog("Choose a device", &["Id", "Name"], dialog_rows) {
+            Some(device) => {
+                // The device string format will be "Address|Name". We need the first part of it.
+                let address = device.split("|").next().map(|s| s.to_string());
+                let _ = sender.send(address);
+            },
+            None => {
+                let _ = sender.send(None);
+            }
+        }
+    }).expect("Thread spawning failed");
+}
+
+#[cfg(not(target_os = "linux"))]
+fn platform_get_selected_devices(devices: Vec<String>, sender: IpcSender<Option<String>>) {
+    for device in devices {
+        if let Some(address) = device.split("|").next().map(|s| s.to_string()) {
+            let _ = sender.send(Some(address));
+        }
+    }
+    let _ = sender.send(None);
+}
+
 fn sanitize_url(request: &str) -> Option<ServoUrl> {
     let request = request.trim();
     ServoUrl::parse(&request).ok()