vinzenz/hyperhive
vinzenz/hyperhive
Watch
0
0
Fork
You've already forked hyperhive
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

matrix: activationScript pre-creates token + share reqwest client across sweep (argus #565 nits)

Browse source
This commit is contained in:
damocles 2026-05-29 13:10:44 +02:00 • committed by Mara
commit dfec976461
2 changed files with 44 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

34
hive-c0re/src/matrix.rs
View file

@ -225,7 +225,15 @@ fn extract_access_token(body: &serde_json::Value) -> Result<String> {
/// homeserver. Skips registration entirely if the token file already
/// exists (treating a present token as proof the account is good).
/// To force re-registration, delete the token file.
pub async fn ensure_user_for(name: &str, register_token: &str) -> Result<()> {
///
/// `client` is shared across the sweep so we build one reqwest
/// connection pool for all agents rather than one per call (argus
/// nit on #565 — bounded but wasteful).
pub async fn ensure_user_for(
client: &reqwest::Client,
name: &str,
register_token: &str,
) -> Result<()> {
use std::os::unix::fs::PermissionsExt;
let path = token_path(name);
if path.exists()
@ -235,11 +243,7 @@ pub async fn ensure_user_for(name: &str, register_token: &str) -> Result<()> {
tracing::debug!(%name, "matrix: token already present");
return Ok(());
}
let client = reqwest::Client::builder()
.timeout(std::time::Duration::from_secs(HTTP_TIMEOUT_SECS))
.build()
.context("matrix: build HTTP client")?;
let access_token = register_user(&client, name, register_token).await?;
let access_token = register_user(client, name, register_token).await?;
if let Some(parent) = path.parent() {
std::fs::create_dir_all(parent).ok();
}
@ -253,8 +257,8 @@ pub async fn ensure_user_for(name: &str, register_token: &str) -> Result<()> {
/// Per-agent matrix sync: ensure the agent has a matrix account + token.
/// All operations are idempotent; failures are logged as warnings but
/// don't abort the caller.
pub async fn sync_agent(name: &str, register_token: &str) {
if let Err(e) = ensure_user_for(name, register_token).await {
pub async fn sync_agent(client: &reqwest::Client, name: &str, register_token: &str) {
if let Err(e) = ensure_user_for(client, name, register_token).await {
tracing::warn!(%name, error = ?e, "matrix: ensure_user failed");
}
}
@ -276,6 +280,18 @@ pub async fn ensure_all() {
return;
}
};
// One HTTP client for the whole sweep — connection pool is
// reused across agents.
let client = match reqwest::Client::builder()
.timeout(std::time::Duration::from_secs(HTTP_TIMEOUT_SECS))
.build()
{
Ok(c) => c,
Err(e) => {
tracing::warn!(error = ?e, "matrix: build HTTP client failed; skipping sweep");
return;
}
};
let Ok(containers) = crate::lifecycle::list().await else {
tracing::warn!("matrix: nixos-container list failed; skipping user sweep");
return;
@ -288,7 +304,7 @@ pub async fn ensure_all() {
} else {
continue;
};
sync_agent(&name, &register_token).await;
sync_agent(&client, &name, &register_token).await;
}
}