Struct OpenClawAdapter 

pub struct OpenClawAdapter { /* private fields */ }

Configured OpenClaw reader, rooted at the state dir (which holds agents/*).

Implementations

impl OpenClawAdapter

pub fn new(root: impl Into<PathBuf>) -> Self

pub fn from_config(config: Value) -> Result<Self, AdapterError>

Build an adapter from an [adapters.openclaw] config blob (home-expanded root + policy knobs). Shared by the factory’s open and the sync pipeline’s deletion-reconciliation pass, so both honor the same knobs.

impl OpenClawAdapter

pub async fn reconcile_deletions( &self, store: &Store, ) -> Result<ReconciliationReport>

Reconcile .deleted. archives (decision 7). A deleted-reason archive whose session_key has NO live session_entries row is an explicit user deletion -> EraseTarget; the same archive with a live entry (its session_key still routed) is a budget eviction of an old generation -> PRESERVE. Ambiguity (unreadable DB, key unknown, session absent from pond) always resolves to preserve. This is a pure detection pass: it names every action for the sync summary and returns the erase set; the actual byte-purge + denylist is the caller’s pond erase step (spec.md#session-append-only-exception), never performed here and never over MCP.

Trait Implementations

impl Adapter for OpenClawAdapter

fn discover(&self) -> DiscoverFuture<'_>

Count how many sessions Self::events will produce, used by the CLI bar to set its length up front. A filesystem adapter walks its root and counts .jsonl files; an API adapter calls its list endpoint. Cheap and best-effort: errors here only mean we run with an unknown total (the bar still ticks per session), so callers fall back to a rolling counter rather than failing the sync.

fn events_with<'a>( &'a self, oracle: &'a dyn SkipOracle, ) -> AdapterYieldStream<'a>

Stream events with a SkipOracle the adapter MAY consult to short-circuit per-session re-decoding (spec.md#adapter-integrity-event-ordering). Default impl ignores the oracle.

fn events(&self) -> EventStream<'_>

Stream every canonical event for every session this adapter knows about, in append-only order per session. The stream borrows self so callers can pass &adapter or hold a Box<dyn Adapter> and invoke this through as_ref().

fn plan<'a>(&'a self, _oracle: &'a dyn SkipOracle) -> PlanFuture<'a>

Cheap sync preview: classify every discovered source as fresh vs pending against the oracle’s watermarks WITHOUT decoding bodies (the same gate Self::events_with applies before its expensive read). Powers pond sync --dry-run and the pond status pending count, so it must stay bounded-read cheap. Ok(None) (the default) means this adapter has no gate cheaper than a full read and callers report the pending count as unknown rather than paying for it.

impl Clone for OpenClawAdapter

fn clone(&self) -> OpenClawAdapter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OpenClawAdapter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.