harn-serve 0.8.132

Shared outbound workflow server core for Harn adapters
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

//! Session-store primitive for `harn-serve` (issue #2502).
//!
//! The agent-session/transcript primitive owned by `harn-serve`. One
//! source of truth for events (`Message`, `ToolCall`, `ToolResult`,
//! `Plan`, `Compaction`, `SystemReminder`, `Hypothesis`, `Receipt`,
//! `Reminder`, `PermissionDecision`, plus arbitrary `Custom` shapes),
//! snapshots, replay, fork/truncate, signed receipts (Ed25519 over
//! canonical JSON), retention, and HTTP exposure. This is the durable
//! session boundary for hosts that would otherwise need separate replay
//! tape, receipt, and transcript stores.
//!
//! ## Layout
//!
//! - [`event`] — event taxonomy + canonical JSON encoder
//! - [`signing`] — Ed25519 chain hashes + receipt signatures
//! - [`store`] — public `SessionStore` trait + shared types
//! - [`memory`] — in-memory backend (tests + headless dev)
//! - [`sqlite`] — persistent SQLite backend (local self-host, TUI)
//! - [`retention`] — declarative per-tenant retention policy
//! - [`api`] — axum router exposing `/v1/sessions/*`
//!
//! The trait is storage-agnostic so additional backends can be added
//! without changing callers.

pub mod api;
pub mod event;
pub mod memory;
pub(crate) mod memory_helpers;
pub mod retention;
pub mod signing;
pub mod sqlite;
pub mod store;

#[cfg(test)]
mod tests;

pub use api::sessions_router;
pub use event::{
    canonical_event_bytes, canonical_json_bytes, AppendEvent, EventId, EventSignature,
    SessionEventKind, StoredEvent,
};
pub use memory::MemorySessionStore;
pub use retention::{ArchiveSink, RetentionPolicy, SharedArchiveSink, Tombstone};
pub use signing::{
    chain_root_fold, chain_root_hash, chain_root_init, compute_record_hash, re_anchor_events,
    verify_event, verify_receipt_root, SessionSigner, VerifyError,
    ALGORITHM as SIGNATURE_ALGORITHM,
};
pub use sqlite::SqliteSessionStore;
pub use store::{
    CreateSession, EventPage, ForkResult, ListFilter, ReadRange, SessionId, SessionMeta,
    SessionStatus, SessionStore, SharedSessionStore, Snapshot, SnapshotId, StoreError, StoreHooks,
    StoreResult, SweepReport, TruncateResult, VerifyFailure, VerifyReport, MAX_READ_BATCH,
};