remowt-link-shared 0.1.7

Shared bifrostlink endpoint wiring for remowt
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use std::future::Future;

use bifrostlink::declarative::endpoints;
use bifrostlink::{Config, Rpc};
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug, thiserror::Error)]
pub enum Error {
	#[error("editor failed: {0}")]
	Failed(String),
}

pub trait EditorBackend: Send + Sync {
	fn open_editor(&self, socket_path: String) -> impl Future<Output = Result<(), Error>> + Send;
}

pub struct EditorEndpoints<E>(pub E);

#[endpoints(ns = 8)]
impl<E: EditorBackend + 'static> EditorEndpoints<E> {
	#[endpoints(id = 1)]
	async fn open_editor(&self, socket_path: String) -> Result<(), Error> {
		self.0.open_editor(socket_path).await
	}
}

pub fn serve_editor<E, C>(rpc: &mut Rpc<C>, editor: E)
where
	E: EditorBackend + Send + Sync + 'static,
	C: Config,
{
	EditorEndpoints(editor).register_endpoints(rpc);
}