use crate::buffer::Controller as BufferController; use crate::cursor::Controller as CursorController; use crate::workspace::Workspace; use pyo3::prelude::*; use super::Promise; use crate::a_sync_allow_threads; #[pymethods] impl Workspace { // join a workspace #[pyo3(name = "create")] fn pycreate(&self, py: Python, path: String) -> PyResult { let this = self.clone(); a_sync_allow_threads!(py, this.create(path.as_str()).await) } #[pyo3(name = "attach")] fn pyattach(&self, py: Python, path: String) -> PyResult { let this = self.clone(); a_sync_allow_threads!(py, this.attach(path.as_str()).await) } #[pyo3(name = "detach")] fn pydetach(&self, path: String) -> bool { match self.detach(path.as_str()) { crate::workspace::worker::DetachResult::NotAttached => false, crate::workspace::worker::DetachResult::Detaching => true, crate::workspace::worker::DetachResult::AlreadyDetached => true, } } #[pyo3(name = "event")] fn pyevent(&self, py: Python) -> PyResult { let this = self.clone(); a_sync_allow_threads!(py, this.event().await) } #[pyo3(name = "fetch_buffers")] fn pyfetch_buffers(&self, py: Python) -> PyResult { let this = self.clone(); a_sync_allow_threads!(py, this.fetch_buffers().await) } #[pyo3(name = "fetch_users")] fn pyfetch_users(&self, py: Python) -> PyResult { let this = self.clone(); a_sync_allow_threads!(py, this.fetch_users().await) } #[pyo3(name = "list_buffer_users")] fn pylist_buffer_users(&self, py: Python, path: String) -> PyResult { // crate::Result> let this = self.clone(); a_sync_allow_threads!(py, this.list_buffer_users(path.as_str()).await) } #[pyo3(name = "delete")] fn pydelete(&self, py: Python, path: String) -> PyResult { let this = self.clone(); a_sync_allow_threads!(py, this.delete(path.as_str()).await) } #[pyo3(name = "id")] fn pyid(&self) -> String { self.id() } #[pyo3(name = "cursor")] fn pycursor(&self) -> CursorController { self.cursor() } #[pyo3(name = "buffer_by_name")] fn pybuffer_by_name(&self, path: String) -> Option { self.buffer_by_name(path.as_str()) } #[pyo3(name = "buffer_list")] fn pybuffer_list(&self) -> Vec { self.buffer_list() } #[pyo3(name = "filetree")] #[pyo3(signature = (filter=None))] fn pyfiletree(&self, filter: Option<&str>) -> Vec { self.filetree(filter) } }