Experiment with ipc framework

crates/bitwarden-ipc/Cargo.toml

@@ -0,0 +1,15 @@
+[package]
+name = "bitwarden-ipc"
+version.workspace = true
+authors.workspace = true
+edition.workspace = true
+rust-version.workspace = true
+homepage.workspace = true
+repository.workspace = true
+license-file.workspace = true
+keywords.workspace = true
+
+[dependencies]
+
+[lints]
+workspace = true

crates/bitwarden-ipc/src/channel.rs

@@ -0,0 +1,26 @@
+use std::rc::Rc;
+
+use crate::{link::Link, providers::CryptoProvider};
+
+/// An end-to-end channel between two IPC endpoints, possibly traversing multiple links across processes.
+/// A channel is a stateful object that can provide a secure and trusted communication path between two endpoints.
+pub struct Channel<C>
+where
+    C: CryptoProvider,
+{
+    link: Box<dyn Link>,
+    crypto: Rc<C>,
+    session: C::Session,
+}
+
+impl<C> Channel<C>
+where
+    C: CryptoProvider,
+{
+    fn send(&self, data: &[u8]) {
+        todo!()
+    }
+    fn receive(&self) -> Vec<u8> {
+        todo!()
+    }
+}

crates/bitwarden-ipc/src/destination.rs

@@ -0,0 +1,6 @@
+#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
+pub enum Destination {
+    Web,
+    Browser,
+    Desktop,
+}

crates/bitwarden-ipc/src/lib.rs

@@ -0,0 +1,8 @@
+mod channel;
+mod destination;
+mod link;
+mod manager;
+mod providers;
+mod proxy;
+
+pub use manager::Manager;

crates/bitwarden-ipc/src/link.rs

@@ -0,0 +1,11 @@
+use crate::destination::Destination;
+
+/// A wrapper around a "physical" connection (e.g. a TCP connection) between two IPC endpoints.
+/// This is a low-level struct that is used to send and receive data between two endpoints
+/// it is not meant to be used directly by consumers of this library.
+pub trait Link {
+    fn send(&self, data: &[u8]);
+    fn receive(&self) -> Vec<u8>;
+
+    fn available_destinations(&self) -> Vec<Destination>;
+}

crates/bitwarden-ipc/src/manager.rs

@@ -0,0 +1,28 @@
+use std::rc::Rc;
+
+use crate::{destination::Destination, link::Link, providers::CryptoProvider};
+
+pub struct Manager<C>
+where
+    C: CryptoProvider,
+{
+    crypto: Rc<C>,
+    links: Vec<Box<dyn Link>>,
+}
+
+impl<C> Manager<C>
+where
+    C: CryptoProvider,
+{
+    pub fn new() -> Self {
+        todo!()
+    }
+
+    pub fn register_link(&mut self) {
+        todo!()
+    }
+
+    pub fn get_channel(&mut self, destination: Destination) {
+        todo!()
+    }
+}

crates/bitwarden-ipc/src/providers/crypto.rs

@@ -0,0 +1,8 @@
+pub trait CryptoProvider {
+    type Session;
+
+    fn establish_session(&self) -> Self::Session;
+
+    fn encrypt(&self, data: &[u8]) -> Vec<u8>;
+    fn decrypt(&self, data: &[u8]) -> Vec<u8>;
+}

crates/bitwarden-ipc/src/providers/mod.rs

@@ -0,0 +1,3 @@
+mod crypto;
+
+pub use crypto::CryptoProvider;

crates/bitwarden-ipc/src/proxy.rs

@@ -0,0 +1,16 @@
+use crate::link::Link;
+
+pub struct Proxy {
+    links: (Box<dyn Link>, Box<dyn Link>),
+}
+
+impl Proxy {
+    pub fn new(links: (Box<dyn Link>, Box<dyn Link>)) -> Self {
+        Self { links }
+    }
+
+    pub fn start(&self) {
+        let data = self.links.0.receive();
+        self.links.1.send(&data);
+    }
+}