remowt-agent 0.1.0

remowt on-host agent serving fs/pty/systemd endpoints over bifrostlink
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

use std::borrow::Cow;
use std::io::Write as _;

use anyhow::Context as _;
use remowt_ui_prompt::bifrost::PromptEndpointsClient;
use remowt_ui_prompt::dbus::{DbusPrompterInterface, DbusPrompterProxy};
use remowt_ui_prompt::Source;
use zbus::Connection;

use remowt_link_shared::BifConfig;

const BUS_NAME: &str = "lach.RemowtAskpass";
const PROMPTER_PATH: &str = "/lach/Askpass";

pub async fn serve(
	conn: &Connection,
	prompter: PromptEndpointsClient<BifConfig>,
) -> anyhow::Result<()> {
	conn.object_server()
		.at(PROMPTER_PATH, DbusPrompterInterface(prompter))
		.await?;
	conn.request_name(BUS_NAME).await?;
	Ok(())
}

pub async fn ask(prompt: &str, description: String) -> anyhow::Result<()> {
	let conn = Connection::session()
		.await
		.context("connecting to the session bus (DBUS_SESSION_BUS_ADDRESS)")?;
	let proxy = DbusPrompterProxy::builder(&conn)
		.destination(BUS_NAME)?
		.path(PROMPTER_PATH)?
		.build()
		.await?;

	let password = proxy
		.prompt_text(
			false,
			prompt,
			&description,
			&[Source(Cow::Borrowed("remowt-askpass"))],
		)
		.await?;

	let mut out = std::io::stdout().lock();
	out.write_all(password.as_bytes())?;
	out.write_all(b"\n")?;
	out.flush()?;
	Ok(())
}