example: fifo communication

Author: edfloreshz

Cargo.toml

@@ -0,0 +1,15 @@
+[package]
+name = "bottles-core"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+serde = { version = "1.0.217", features = ["derive"] }
+serde_json = "1.0.134"
+thiserror = "2.0.9"
+tracing = "0.1.41"
+unix-named-pipe = "0.2.0"
+
+[dev-dependencies]
+bottles-core = { path = "." }
+tracing-subscriber = "0.3.19"

examples/cli.rs

@@ -0,0 +1,18 @@
+use bottles_core::{Error, Payload, WineBridge, WineBridgeAction};
+use tracing::Level;
+
+pub fn main() -> Result<(), Error> {
+    let wine_prefix = std::env::args()
+        .nth(1)
+        .expect("Wine prefix path is required");
+    tracing_subscriber::fmt()
+        .with_max_level(Level::DEBUG)
+        .init();
+    let mut bridge = WineBridge::new(wine_prefix);
+    bridge.connect()?;
+    bridge.send(Payload {
+        action: WineBridgeAction::Run {
+            executable: "explorer.exe".to_string(),
+        },
+    })
+}

src/error.rs

@@ -0,0 +1,15 @@
+extern crate unix_named_pipe;
+
+use thiserror::Error;
+
+#[derive(Error, Debug)]
+pub enum Error {
+    #[error("I/O: {0}")]
+    Io(#[from] std::io::Error),
+    #[error("Serde: {0}")]
+    Serde(#[from] serde_json::Error),
+    #[error("Failed to create named pipe")]
+    NamedPipeError,
+    #[error("Failed to connect to bridge, be sure to call .connect() first")]
+    ConnectToBridgeError,
+}

src/lib.rs

@@ -0,0 +1,4 @@
+mod error;
+mod wine;
+pub use error::Error;
+pub use wine::bridge::{Payload, WineBridge, WineBridgeAction};

src/wine/bridge.rs

@@ -0,0 +1,50 @@
+use std::{fs::File, io::Write};
+
+use serde::{Deserialize, Serialize};
+use serde_json as json;
+
+use tracing::info;
+
+use crate::Error;
+
+#[derive(Debug)]
+pub struct WineBridge {
+    pub wine_prefix: String,
+    pub pipe: Option<File>,
+}
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct Payload {
+    pub action: WineBridgeAction,
+}
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub enum WineBridgeAction {
+    Run { executable: String },
+}
+
+impl WineBridge {
+    pub fn new(wine_prefix: impl ToString) -> Self {
+        Self {
+            wine_prefix: wine_prefix.to_string(),
+            pipe: None,
+        }
+    }
+
+    pub fn connect(&mut self) -> Result<(), Error> {
+        info!("Connecting to wine prefix: {}", self.wine_prefix);
+        let pipe = unix_named_pipe::open_write(&self.wine_prefix)?;
+        self.pipe = Some(pipe);
+        Ok(())
+    }
+
+    pub fn send(&mut self, message: Payload) -> Result<(), Error> {
+        info!("Sending message to wine prefix: {:#?}", message);
+        let Some(pipe) = self.pipe.as_mut() else {
+            return Err(Error::ConnectToBridgeError);
+        };
+        let payload = json::to_string(&message)? + "\n";
+        pipe.write_all(payload.as_bytes())?;
+        Ok(())
+    }
+}

src/wine/mod.rs

@@ -0,0 +1 @@
+pub mod bridge;