46cc67e2db
updates fixes updates add another test updates updates updates updates updates updates add test for error; updates updates fixups updates updates fixes updates fixes updates fixes updates updates updates bump Signed-off-by: Jess Frazelle <github@jessfraz.com>
66 lines
1.7 KiB
Rust
66 lines
1.7 KiB
Rust
//! Functions for managing engine communications.
|
|
|
|
use wasm_bindgen::prelude::*;
|
|
|
|
#[cfg(not(target_arch = "wasm32"))]
|
|
#[cfg(not(test))]
|
|
#[cfg(feature = "engine")]
|
|
pub mod conn;
|
|
#[cfg(not(target_arch = "wasm32"))]
|
|
#[cfg(not(test))]
|
|
#[cfg(feature = "engine")]
|
|
pub use conn::EngineConnection;
|
|
|
|
#[cfg(target_arch = "wasm32")]
|
|
#[cfg(not(test))]
|
|
#[cfg(feature = "engine")]
|
|
pub mod conn_wasm;
|
|
#[cfg(target_arch = "wasm32")]
|
|
#[cfg(not(test))]
|
|
#[cfg(feature = "engine")]
|
|
pub use conn_wasm::EngineConnection;
|
|
|
|
#[cfg(test)]
|
|
pub mod conn_mock;
|
|
#[cfg(test)]
|
|
pub use conn_mock::EngineConnection;
|
|
|
|
#[cfg(not(feature = "engine"))]
|
|
#[cfg(not(test))]
|
|
pub mod conn_mock;
|
|
#[cfg(not(feature = "engine"))]
|
|
#[cfg(not(test))]
|
|
pub use conn_mock::EngineConnection;
|
|
|
|
use crate::executor::SourceRange;
|
|
|
|
#[derive(Debug)]
|
|
#[wasm_bindgen]
|
|
pub struct EngineManager {
|
|
connection: EngineConnection,
|
|
}
|
|
|
|
#[wasm_bindgen]
|
|
impl EngineManager {
|
|
#[cfg(target_arch = "wasm32")]
|
|
#[cfg(not(test))]
|
|
#[cfg(feature = "engine")]
|
|
#[wasm_bindgen(constructor)]
|
|
pub async fn new(manager: conn_wasm::EngineCommandManager) -> EngineManager {
|
|
EngineManager {
|
|
// This unwrap is safe because the connection is always created.
|
|
connection: EngineConnection::new(manager).await.unwrap(),
|
|
}
|
|
}
|
|
|
|
pub fn send_modeling_cmd(&mut self, id_str: &str, cmd_str: &str) -> Result<(), String> {
|
|
let id = uuid::Uuid::parse_str(id_str).map_err(|e| e.to_string())?;
|
|
let cmd = serde_json::from_str(cmd_str).map_err(|e| e.to_string())?;
|
|
self.connection
|
|
.send_modeling_cmd(id, SourceRange::default(), cmd)
|
|
.map_err(String::from)?;
|
|
|
|
Ok(())
|
|
}
|
|
}
|