Struct Server 

pub struct Server { /* private fields */ }

The HTTP API, its background jobs, and the state they share.

Implementations

impl Server

pub fn new(cfg: Config, store: Arc<Store>) -> Self

Builds a server around an already-open store.

pub fn router(&self) -> Router

The router, built separately from binding a port so tests can drive it without real sockets.

pub async fn refresh_claude_status(&self)

Re-runs the local claude auth status probe.

pub fn claude_status(&self) -> Status

The last known state of the claude CLI.

pub fn set_claude_status(&self, status: Status)

Overrides the cached CLI status.

Exposed so tests can exercise the merge-failure path — reaching it otherwise needs a real, logged-in CLI on the machine running them.

pub fn set_clock_offset(&self, seconds: i64)

Moves the clock device signatures are judged by, in seconds.

Exposed so tests can reach the edges of the signature window, and what happens after it, without waiting a minute for each.

pub fn backdate_start(&self, seconds: i64)

Makes this server act as if it had started seconds earlier than it did.

Exposed so tests can sign requests at once, rather than waiting out the few seconds after a start in which every signature is refused.

pub fn run_backup(&self)

Writes a backup now. Failure is logged, never propagated: it becomes visible through /health’s last_backup_at going stale.

pub fn sweep_devices(&self) -> Result<(usize, usize)>

Removes ephemeral devices idle for longer than Config::ephemeral_device_ttl, and enrolments that expired over an hour ago. Answers how many of each went.

pub fn start_background(&self) -> Vec<JoinHandle<()>>

Starts background work: the first Claude CLI status check, its refresh loop, backups, and the device sweep. All of it is best-effort — none of it may take the sync API down.

pub async fn serve(&self) -> Result<()>

Binds cfg.addr and serves until SIGTERM or ctrl-c, then shuts down gracefully so an in-flight merge isn’t cut off mid-write.

pub async fn serve_with_shutdown<F>( &self, listener: TcpListener, shutdown: F, ) -> Result<()>

where F: Future<Output = ()> + Send + 'static,

Serves on an already-bound listener until shutdown resolves, in whichever transport cfg.tls names (see server/tls.rs; plain HTTP, the default, still goes through axum::serve directly, unchanged).