mimir-mem 0.8.0

Mimir: unified local-first memory for AI coding agents
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

//! Blocking HTTP client for server-mode sync (via `ureq`, no async runtime).

use anyhow::{anyhow, bail, Result};
use mimir_core::replicate::{ApplyStats, SyncBatch};
use serde::Deserialize;

#[derive(Debug, Deserialize)]
pub struct PushResult {
    pub applied: ApplyStats,
    pub watermark: i64,
}

fn auth(token: &str) -> String {
    format!("Bearer {token}")
}

/// `GET /sync/pull?since=<since>` → the hub's changes since `since`.
pub fn pull(endpoint: &str, token: &str, since: i64) -> Result<SyncBatch> {
    let url = format!("{}/sync/pull?since={since}", endpoint.trim_end_matches('/'));
    match ureq::get(&url).set("Authorization", &auth(token)).call() {
        Ok(r) => Ok(r.into_json::<SyncBatch>()?),
        Err(ureq::Error::Status(401, _)) => {
            bail!("hub rejected the token (401) — check MIMIR_SYNC_TOKEN")
        }
        Err(ureq::Error::Status(code, _)) => bail!("hub pull failed: HTTP {code}"),
        Err(e) => Err(anyhow!("hub unreachable at {endpoint}: {e}")),
    }
}

/// `POST /sync/push` with a batch body → the hub's apply stats + watermark.
pub fn push(endpoint: &str, token: &str, batch: &SyncBatch) -> Result<PushResult> {
    let url = format!("{}/sync/push", endpoint.trim_end_matches('/'));
    match ureq::post(&url)
        .set("Authorization", &auth(token))
        .send_json(batch)
    {
        Ok(r) => Ok(r.into_json::<PushResult>()?),
        Err(ureq::Error::Status(401, _)) => {
            bail!("hub rejected the token (401) — check MIMIR_SYNC_TOKEN")
        }
        Err(ureq::Error::Status(code, _)) => bail!("hub push failed: HTTP {code}"),
        Err(e) => Err(anyhow!("hub unreachable at {endpoint}: {e}")),
    }
}