Struct WasmAgentStateGraph 

pub struct WasmAgentStateGraph { /* private fields */ }

AgentStateGraph for WASM — uses IndexedDB for persistent browser storage.

Architecture: in-memory cache with write-through to IndexedDB.

• All reads are instant (from memory)
• All writes queue changes for IndexedDB flush
• Call drain_pending() from JS to get queued writes, then persist to IndexedDB
• Call load_data() on startup to hydrate from IndexedDB

Implementations

impl WasmAgentStateGraph

pub fn new(db_name: Option<String>) -> Result<WasmAgentStateGraph, JsValue>

Create a new AgentStateGraph with IndexedDB-backed storage. After construction, call load_data() with data from IndexedDB to restore state.

pub fn load_objects(&self, json_pairs: &str) -> Result<(), JsValue>

Load objects from IndexedDB dump. Call on startup. Pass a JSON string: [[“hex_id”, “json”], …]

pub fn load_commits(&self, json_pairs: &str) -> Result<(), JsValue>

Load commits from IndexedDB dump.

pub fn load_refs(&self, json_pairs: &str) -> Result<(), JsValue>

Load refs from IndexedDB dump.

pub fn drain_pending_objects(&self) -> String

Get pending object writes for flushing to IndexedDB. Returns JSON.

pub fn drain_pending_commits(&self) -> String

Get pending commit writes.

pub fn drain_pending_refs(&self) -> String

Get pending ref writes.

pub fn drain_deleted_refs(&self) -> String

Get pending ref deletions (keys to delete from the refs store), so a deleted branch does not come back on the next load.

pub fn db_name(&self) -> String

Get the IndexedDB database name.

pub fn get( &self, path: &str, reference: Option<String>, namespace: Option<String>, ) -> Result<String, JsValue>

Get a JSON value at a path.

pub fn set( &self, path: &str, json_value: &str, category: &str, description: &str, reference: Option<String>, reasoning: Option<String>, confidence: Option<f64>, namespace: Option<String>, ) -> Result<String, JsValue>

Set a JSON value at a path.

pub fn delete( &self, path: &str, category: &str, description: &str, reference: Option<String>, namespace: Option<String>, ) -> Result<String, JsValue>

Delete a value at a path.

pub fn branch( &self, name: &str, from: Option<String>, namespace: Option<String>, ) -> Result<String, JsValue>

Create a branch.

pub fn merge( &self, source: &str, target: Option<String>, description: Option<String>, namespace: Option<String>, ) -> Result<String, JsValue>

Merge source into target.

pub fn diff( &self, ref_a: &str, ref_b: &str, namespace: Option<String>, ) -> Result<String, JsValue>

Structured diff between two refs. Returns JSON.

pub fn log( &self, reference: Option<String>, limit: Option<u32>, namespace: Option<String>, ) -> Result<String, JsValue>

Commit log. Returns JSON.

pub fn blame( &self, path: &str, reference: Option<String>, namespace: Option<String>, ) -> Result<String, JsValue>

Blame — who modified a path and why.

pub fn speculate( &self, from: Option<String>, label: Option<String>, namespace: Option<String>, ) -> Result<u32, JsValue>

Create a speculation. Returns handle ID.

pub fn spec_get(&self, handle_id: u32, path: &str) -> Result<String, JsValue>

Get from a speculation.

pub fn spec_set( &self, handle_id: u32, path: &str, json_value: &str, ) -> Result<(), JsValue>

Set in a speculation.

pub fn commit_speculation( &self, handle_id: u32, category: &str, description: &str, reasoning: Option<String>, confidence: Option<f64>, ) -> Result<String, JsValue>

Commit a speculation.

pub fn discard_speculation(&self, handle_id: u32) -> Result<(), JsValue>

Discard a speculation.

pub fn create_epoch( &self, id: &str, description: &str, ) -> Result<String, JsValue>

Create an epoch.

pub fn seal_epoch(&self, id: &str, summary: &str) -> Result<(), JsValue>

Seal an epoch.

pub fn tasks_create_plan( &self, prefix: &str, agent_id: &str, ref_name: &str, name: &str, description: Option<String>, ) -> Result<String, JsValue>

Create a plan. Returns the Plan as JSON.

pub fn tasks_list_plans( &self, prefix: &str, agent_id: &str, ref_name: &str, ) -> Result<String, JsValue>

pub fn tasks_list_plans_by_status( &self, prefix: &str, agent_id: &str, ref_name: &str, status: Option<String>, ) -> Result<String, JsValue>

pub fn tasks_get_plan( &self, prefix: &str, agent_id: &str, ref_name: &str, name: &str, ) -> Result<String, JsValue>

pub fn tasks_archive_plan( &self, prefix: &str, agent_id: &str, ref_name: &str, name: &str, ) -> Result<String, JsValue>

pub fn tasks_delete_plan( &self, prefix: &str, agent_id: &str, ref_name: &str, name: &str, ) -> Result<(), JsValue>

pub fn tasks_add_task( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, title: &str, priority: &str, parent_id: Option<String>, blockers_json: Option<String>, assigned_to: Option<String>, ) -> Result<String, JsValue>

Add a task. priority is “low”|“medium”|“high”|“critical”. blockers_json is a JSON array of task id strings (or null).

pub fn tasks_add_task_with_extensions( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, title: &str, priority: &str, parent_id: Option<String>, blockers_json: Option<String>, assigned_to: Option<String>, payload_json: Option<String>, parent_change: Option<String>, on_complete_json: Option<String>, ) -> Result<String, JsValue>

Add a task with the 0.6.0 extension fields (payload, parent_change, on_complete). All three are JSON strings; pass None / null for unset. payload is an arbitrary JSON value, parent_change a "spec-id@version" handle, on_complete a JSON-serialized OnCompleteHook.

pub fn tasks_list_tasks( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, ) -> Result<String, JsValue>

pub fn tasks_task_ids( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, ) -> Result<String, JsValue>

pub fn tasks_get_task( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, ) -> Result<String, JsValue>

pub fn tasks_start_task( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, ) -> Result<String, JsValue>

pub fn tasks_complete_task( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, proof_kind: &str, proof_value: &str, proof_note: Option<String>, ) -> Result<String, JsValue>

Complete a task. proof_kind is “commit”|“file”|“test”|“text”.

pub fn tasks_abandon_task( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, reason: &str, ) -> Result<String, JsValue>

pub fn tasks_set_priority( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, priority: &str, ) -> Result<String, JsValue>

pub fn tasks_set_title( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, title: &str, ) -> Result<String, JsValue>

pub fn tasks_set_blockers( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, blockers_json: &str, ) -> Result<String, JsValue>

pub fn tasks_assign_task( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, agent: &str, ) -> Result<String, JsValue>

pub fn tasks_unassign_task( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, task_id: &str, ) -> Result<String, JsValue>

pub fn tasks_next_task( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, ) -> Result<String, JsValue>

pub fn tasks_next_task_for( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, agent: Option<String>, include_unassigned: bool, ) -> Result<String, JsValue>

pub fn tasks_derived_status( &self, prefix: &str, agent_id: &str, ref_name: &str, plan: &str, parent_id: &str, ) -> Result<String, JsValue>

pub fn migrate_check( &self, ref_name: &str, target: Option<String>, ) -> Result<String, JsValue>

Check migration status. Returns a JSON report (see CheckResult).

pub fn migrate_run( &self, ref_name: &str, target: Option<String>, mode: &str, ) -> Result<String, JsValue>

Run migrations. mode is "apply" or "dry-run".

pub fn create_session( &self, agent_id: &str, working_branch: Option<String>, parent_session: Option<String>, delegated_intent: Option<String>, report_to: Option<String>, path_scope: Option<String>, ) -> Result<String, JsValue>

Create a durable session record. Returns the Session as JSON.

pub fn get_session(&self, id: &str) -> Result<String, JsValue>

Fetch a session by id. Returns JSON, or “null” if not found.

pub fn list_sessions( &self, agent_filter: Option<String>, ) -> Result<String, JsValue>

List sessions, optionally filtered by agent_id.

pub fn end_session(&self, id: &str, status: &str) -> Result<(), JsValue>

End a session. status is “active” | “completed” | “abandoned”.

pub fn taint( &self, ref_name: &str, path: &str, params_json: &str, ) -> Result<String, JsValue>

Apply a taint. params_json shape: {"name","effect","reason","severity","expires","propagate","agent_id","metadata"}. Returns the new taint id.

pub fn untaint( &self, ref_name: &str, path: &str, name: &str, params_json: &str, ) -> Result<(), JsValue>

Resolve a taint by name on path. params_json shape: {"reason","proof","agent_id"}.

pub fn quarantine( &self, ref_name: &str, path: &str, params_json: &str, ) -> Result<String, JsValue>

Apply a quarantine. params_json shape: {"name","reason","severity","authorized_agents","expires","propagate","agent_id"}.

pub fn unquarantine( &self, ref_name: &str, path: &str, name: &str, params_json: &str, ) -> Result<(), JsValue>

Release a quarantine. params_json shape matches untaint.

pub fn watch( &self, ref_name: &str, path: &str, params_json: &str, ) -> Result<String, JsValue>

Apply a watch. params_json shape: {"name","reason","metric","threshold","direction","check_interval_secs","expires", "severity","propagate","agent_id"}.

pub fn unwatch( &self, ref_name: &str, path: &str, name: &str, params_json: &str, ) -> Result<(), JsValue>

Remove a watch. params_json shape: {"reason","agent_id"}.

pub fn list_taints( &self, path_prefix: Option<String>, kind: Option<String>, include_resolved: bool, ) -> Result<String, JsValue>

List taints / quarantines / watches. Returns a JSON array of [Taint] records.

pub fn check_taint( &self, path: &str, agent_id: Option<String>, confidence: Option<f64>, ) -> Result<String, JsValue>

Check taint status for path given agent_id + confidence. Returns a [TaintCheck] JSON object.

pub fn list_epochs(&self) -> Result<String, JsValue>

List epochs. Returns JSON.

pub fn list_all_epochs(&self) -> Result<String, JsValue>

List epochs across every workspace. Returns JSON.

list_epochs returns only the active workspace’s epochs. This binding cannot select a workspace, so without this it could not reach epochs outside the default one at all.

Trait Implementations

impl From<WasmAgentStateGraph> for JsValue

fn from(value: WasmAgentStateGraph) -> Self

Converts to this type from the input type.

impl FromWasmAbi for WasmAgentStateGraph

type Abi = WasmPtr<WasmRefCell<WasmAgentStateGraph>>

The Wasm ABI type that this converts from when coming back out from the ABI boundary.

unsafe fn from_abi(js: Self::Abi) -> Self

Recover a Self from Self::Abi.

impl IntoWasmAbi for WasmAgentStateGraph

type Abi = WasmPtr<WasmRefCell<WasmAgentStateGraph>>

The Wasm ABI type that this converts into when crossing the ABI boundary.

fn into_abi(self) -> Self::Abi

Convert self into Self::Abi so that it can be sent across the wasm ABI boundary.

impl LongRefFromWasmAbi for WasmAgentStateGraph

type Abi = WasmPtr<WasmRefCell<WasmAgentStateGraph>>

Same as RefFromWasmAbi::Abi

type Anchor = RcRef<WasmAgentStateGraph>

Same as RefFromWasmAbi::Anchor

unsafe fn long_ref_from_abi(js: Self::Abi) -> Self::Anchor

Same as RefFromWasmAbi::ref_from_abi

impl OptionFromWasmAbi for WasmAgentStateGraph

fn is_none(abi: &Self::Abi) -> bool

Tests whether the argument is a “none” instance. If so it will be deserialized as None, and otherwise it will be passed to FromWasmAbi.

impl OptionIntoWasmAbi for WasmAgentStateGraph

fn none() -> Self::Abi

Returns an ABI instance indicating “none”, which JS will interpret as the None branch of this option.

impl RefFromWasmAbi for WasmAgentStateGraph

type Abi = WasmPtr<WasmRefCell<WasmAgentStateGraph>>

The Wasm ABI type references to Self are recovered from.

type Anchor = RcRef<WasmAgentStateGraph>

The type that holds the reference to Self for the duration of the invocation of the function that has an &Self parameter. This is required to ensure that the lifetimes don’t persist beyond one function call, and so that they remain anonymous.

unsafe fn ref_from_abi(js: Self::Abi) -> Self::Anchor

Recover a Self::Anchor from Self::Abi.

impl RefMutFromWasmAbi for WasmAgentStateGraph

type Abi = WasmPtr<WasmRefCell<WasmAgentStateGraph>>

Same as RefFromWasmAbi::Abi

type Anchor = RcRefMut<WasmAgentStateGraph>

Same as RefFromWasmAbi::Anchor

unsafe fn ref_mut_from_abi(js: Self::Abi) -> Self::Anchor

Same as RefFromWasmAbi::ref_from_abi

impl SupportsConstructor for WasmAgentStateGraph

impl SupportsInstanceProperty for WasmAgentStateGraph

impl SupportsStaticProperty for WasmAgentStateGraph

impl TryFromJsValue for WasmAgentStateGraph

fn try_from_js_value(value: JsValue) -> Result<Self, JsValue>

Performs the conversion.

fn try_from_js_value_ref(value: &JsValue) -> Option<Self>

Performs the conversion.

impl VectorFromWasmAbi for WasmAgentStateGraph

type Abi = <Box<[JsValue]> as FromWasmAbi>::Abi

unsafe fn vector_from_abi(js: Self::Abi) -> Box<[WasmAgentStateGraph]>

impl VectorIntoWasmAbi for WasmAgentStateGraph

type Abi = <Box<[JsValue]> as IntoWasmAbi>::Abi

fn vector_into_abi(vector: Box<[WasmAgentStateGraph]>) -> Self::Abi

impl WasmDescribe for WasmAgentStateGraph

fn describe()

impl WasmDescribeVector for WasmAgentStateGraph

fn describe_vector()