codemp 0.8.5

codemp -- code multiplexer
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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

pub mod buffer;
pub mod client;
pub mod cursor;
pub mod ext;
pub mod workspace;

impl From<crate::errors::ConnectionError> for napi::Error {
	fn from(value: crate::errors::ConnectionError) -> Self {
		napi::Error::new(napi::Status::GenericFailure, format!("{value}"))
	}
}

impl From<crate::errors::RemoteError> for napi::Error {
	fn from(value: crate::errors::RemoteError) -> Self {
		napi::Error::new(napi::Status::GenericFailure, format!("{value}"))
	}
}

impl From<crate::errors::ControllerError> for napi::Error {
	fn from(value: crate::errors::ControllerError) -> Self {
		napi::Error::new(napi::Status::GenericFailure, format!("{value}"))
	}
}

use napi_derive::napi;

#[napi]
pub struct JsLogger(std::sync::Arc<tokio::sync::Mutex<tokio::sync::mpsc::Receiver<String>>>);

#[napi]
impl JsLogger {
	#[napi(constructor)]
	pub fn new(debug: Option<bool>) -> JsLogger {
		let (tx, rx) = tokio::sync::mpsc::channel(256);
		let level = if debug.unwrap_or(false) {
			tracing::Level::DEBUG
		} else {
			tracing::Level::INFO
		}; //TODO: study this tracing subscriber and customize it
		let format = tracing_subscriber::fmt::format()
			.with_level(true)
			.with_target(true)
			.with_thread_ids(false)
			.with_thread_names(false)
			.with_ansi(false)
			.with_file(false)
			.with_line_number(false)
			.with_source_location(false)
			.compact();
		let _initialized = tracing_subscriber::fmt()
			.event_format(format)
			.with_max_level(level)
			.with_writer(std::sync::Mutex::new(JsLoggerProducer(tx)))
			.try_init()
			.is_ok();
		JsLogger(std::sync::Arc::new(tokio::sync::Mutex::new(rx)))
	}

	#[napi]
	pub async fn message(&self) -> Option<String> {
		self.0.lock().await.recv().await
	}
}

#[derive(Debug, Clone)]
struct JsLoggerProducer(tokio::sync::mpsc::Sender<String>);

impl std::io::Write for JsLoggerProducer {
	fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> {
		// TODO this is a LOSSY logger!!
		let _ = self.0.try_send(String::from_utf8_lossy(buf).to_string()); // ignore: logger disconnected or with full buffer
		Ok(buf.len())
	}

	fn flush(&mut self) -> std::io::Result<()> {
		Ok(())
	}
}