platform.rs

  1use crate::{
  2    AnyWindowHandle, BackgroundExecutor, ClipboardItem, CursorStyle, DisplayId, ForegroundExecutor,
  3    Keymap, Platform, PlatformDisplay, PlatformTextSystem, Scene, TestDisplay, TestWindow,
  4    WindowOptions,
  5};
  6use anyhow::{anyhow, Result};
  7use collections::VecDeque;
  8use futures::channel::oneshot;
  9use parking_lot::Mutex;
 10use std::{
 11    cell::RefCell,
 12    path::PathBuf,
 13    rc::{Rc, Weak},
 14    sync::Arc,
 15    time::Duration,
 16};
 17
 18/// TestPlatform implements the Platform trait for use in tests.
 19pub struct TestPlatform {
 20    background_executor: BackgroundExecutor,
 21    foreground_executor: ForegroundExecutor,
 22
 23    pub(crate) active_window: RefCell<Option<TestWindow>>,
 24    active_display: Rc<dyn PlatformDisplay>,
 25    active_cursor: Mutex<CursorStyle>,
 26    current_clipboard_item: Mutex<Option<ClipboardItem>>,
 27    pub(crate) prompts: RefCell<TestPrompts>,
 28    weak: Weak<Self>,
 29}
 30
 31#[derive(Default)]
 32pub(crate) struct TestPrompts {
 33    multiple_choice: VecDeque<oneshot::Sender<usize>>,
 34    new_path: VecDeque<(PathBuf, oneshot::Sender<Option<PathBuf>>)>,
 35}
 36
 37impl TestPlatform {
 38    pub fn new(executor: BackgroundExecutor, foreground_executor: ForegroundExecutor) -> Rc<Self> {
 39        Rc::new_cyclic(|weak| TestPlatform {
 40            background_executor: executor,
 41            foreground_executor,
 42            prompts: Default::default(),
 43            active_cursor: Default::default(),
 44            active_display: Rc::new(TestDisplay::new()),
 45            active_window: Default::default(),
 46            current_clipboard_item: Mutex::new(None),
 47            weak: weak.clone(),
 48        })
 49    }
 50
 51    pub(crate) fn simulate_new_path_selection(
 52        &self,
 53        select_path: impl FnOnce(&std::path::Path) -> Option<std::path::PathBuf>,
 54    ) {
 55        let (path, tx) = self
 56            .prompts
 57            .borrow_mut()
 58            .new_path
 59            .pop_front()
 60            .expect("no pending new path prompt");
 61        tx.send(select_path(&path)).ok();
 62    }
 63
 64    pub(crate) fn simulate_prompt_answer(&self, response_ix: usize) {
 65        let tx = self
 66            .prompts
 67            .borrow_mut()
 68            .multiple_choice
 69            .pop_front()
 70            .expect("no pending multiple choice prompt");
 71        tx.send(response_ix).ok();
 72    }
 73
 74    pub(crate) fn has_pending_prompt(&self) -> bool {
 75        !self.prompts.borrow().multiple_choice.is_empty()
 76    }
 77
 78    pub(crate) fn prompt(&self) -> oneshot::Receiver<usize> {
 79        let (tx, rx) = oneshot::channel();
 80        self.prompts.borrow_mut().multiple_choice.push_back(tx);
 81        rx
 82    }
 83
 84    pub(crate) fn set_active_window(&self, window: Option<TestWindow>) {
 85        let executor = self.foreground_executor().clone();
 86        let previous_window = self.active_window.borrow_mut().take();
 87        *self.active_window.borrow_mut() = window.clone();
 88
 89        executor
 90            .spawn(async move {
 91                if let Some(previous_window) = previous_window {
 92                    if let Some(window) = window.as_ref() {
 93                        if Arc::ptr_eq(&previous_window.0, &window.0) {
 94                            return;
 95                        }
 96                    }
 97                    previous_window.simulate_active_status_change(false);
 98                }
 99                if let Some(window) = window {
100                    window.simulate_active_status_change(true);
101                }
102            })
103            .detach();
104    }
105}
106
107impl Platform for TestPlatform {
108    fn background_executor(&self) -> BackgroundExecutor {
109        self.background_executor.clone()
110    }
111
112    fn foreground_executor(&self) -> ForegroundExecutor {
113        self.foreground_executor.clone()
114    }
115
116    fn text_system(&self) -> Arc<dyn PlatformTextSystem> {
117        Arc::new(crate::platform::mac::MacTextSystem::new())
118    }
119
120    fn run(&self, _on_finish_launching: Box<dyn FnOnce()>) {
121        unimplemented!()
122    }
123
124    fn quit(&self) {}
125
126    fn restart(&self) {
127        unimplemented!()
128    }
129
130    fn activate(&self, _ignoring_other_apps: bool) {
131        //
132    }
133
134    fn hide(&self) {
135        unimplemented!()
136    }
137
138    fn hide_other_apps(&self) {
139        unimplemented!()
140    }
141
142    fn unhide_other_apps(&self) {
143        unimplemented!()
144    }
145
146    fn displays(&self) -> Vec<std::rc::Rc<dyn crate::PlatformDisplay>> {
147        vec![self.active_display.clone()]
148    }
149
150    fn display(&self, id: DisplayId) -> Option<std::rc::Rc<dyn crate::PlatformDisplay>> {
151        self.displays().iter().find(|d| d.id() == id).cloned()
152    }
153
154    fn active_window(&self) -> Option<crate::AnyWindowHandle> {
155        self.active_window
156            .borrow()
157            .as_ref()
158            .map(|window| window.0.lock().handle)
159    }
160
161    fn open_window(
162        &self,
163        handle: AnyWindowHandle,
164        options: WindowOptions,
165        _draw: Box<dyn FnMut() -> Result<Scene>>,
166    ) -> Box<dyn crate::PlatformWindow> {
167        let window = TestWindow::new(
168            options,
169            handle,
170            self.weak.clone(),
171            self.active_display.clone(),
172        );
173        Box::new(window)
174    }
175
176    fn set_display_link_output_callback(
177        &self,
178        _display_id: DisplayId,
179        mut callback: Box<dyn FnMut(&crate::VideoTimestamp, &crate::VideoTimestamp) + Send>,
180    ) {
181        let timestamp = crate::VideoTimestamp {
182            version: 0,
183            video_time_scale: 0,
184            video_time: 0,
185            host_time: 0,
186            rate_scalar: 0.0,
187            video_refresh_period: 0,
188            smpte_time: crate::SmtpeTime::default(),
189            flags: 0,
190            reserved: 0,
191        };
192        callback(&timestamp, &timestamp)
193    }
194
195    fn start_display_link(&self, _display_id: DisplayId) {}
196
197    fn stop_display_link(&self, _display_id: DisplayId) {}
198
199    fn open_url(&self, _url: &str) {
200        unimplemented!()
201    }
202
203    fn on_open_urls(&self, _callback: Box<dyn FnMut(Vec<String>)>) {
204        unimplemented!()
205    }
206
207    fn prompt_for_paths(
208        &self,
209        _options: crate::PathPromptOptions,
210    ) -> oneshot::Receiver<Option<Vec<std::path::PathBuf>>> {
211        unimplemented!()
212    }
213
214    fn prompt_for_new_path(
215        &self,
216        directory: &std::path::Path,
217    ) -> oneshot::Receiver<Option<std::path::PathBuf>> {
218        let (tx, rx) = oneshot::channel();
219        self.prompts
220            .borrow_mut()
221            .new_path
222            .push_back((directory.to_path_buf(), tx));
223        rx
224    }
225
226    fn reveal_path(&self, _path: &std::path::Path) {
227        unimplemented!()
228    }
229
230    fn on_become_active(&self, _callback: Box<dyn FnMut()>) {}
231
232    fn on_resign_active(&self, _callback: Box<dyn FnMut()>) {}
233
234    fn on_quit(&self, _callback: Box<dyn FnMut()>) {}
235
236    fn on_reopen(&self, _callback: Box<dyn FnMut()>) {
237        unimplemented!()
238    }
239
240    fn on_event(&self, _callback: Box<dyn FnMut(crate::InputEvent) -> bool>) {
241        unimplemented!()
242    }
243
244    fn set_menus(&self, _menus: Vec<crate::Menu>, _keymap: &Keymap) {}
245
246    fn on_app_menu_action(&self, _callback: Box<dyn FnMut(&dyn crate::Action)>) {}
247
248    fn on_will_open_app_menu(&self, _callback: Box<dyn FnMut()>) {}
249
250    fn on_validate_app_menu_command(&self, _callback: Box<dyn FnMut(&dyn crate::Action) -> bool>) {}
251
252    fn os_name(&self) -> &'static str {
253        "test"
254    }
255
256    fn os_version(&self) -> Result<crate::SemanticVersion> {
257        Err(anyhow!("os_version called on TestPlatform"))
258    }
259
260    fn app_version(&self) -> Result<crate::SemanticVersion> {
261        Err(anyhow!("app_version called on TestPlatform"))
262    }
263
264    fn app_path(&self) -> Result<std::path::PathBuf> {
265        unimplemented!()
266    }
267
268    fn local_timezone(&self) -> time::UtcOffset {
269        time::UtcOffset::UTC
270    }
271
272    fn path_for_auxiliary_executable(&self, _name: &str) -> Result<std::path::PathBuf> {
273        unimplemented!()
274    }
275
276    fn set_cursor_style(&self, style: crate::CursorStyle) {
277        *self.active_cursor.lock() = style;
278    }
279
280    fn should_auto_hide_scrollbars(&self) -> bool {
281        // todo()
282        true
283    }
284
285    fn write_to_clipboard(&self, item: ClipboardItem) {
286        *self.current_clipboard_item.lock() = Some(item);
287    }
288
289    fn read_from_clipboard(&self) -> Option<ClipboardItem> {
290        self.current_clipboard_item.lock().clone()
291    }
292
293    fn write_credentials(&self, _url: &str, _username: &str, _password: &[u8]) -> Result<()> {
294        Ok(())
295    }
296
297    fn read_credentials(&self, _url: &str) -> Result<Option<(String, Vec<u8>)>> {
298        Ok(None)
299    }
300
301    fn delete_credentials(&self, _url: &str) -> Result<()> {
302        Ok(())
303    }
304
305    fn double_click_interval(&self) -> std::time::Duration {
306        Duration::from_millis(500)
307    }
308}