Struct AgentRuntime 

pub struct AgentRuntime<S = Lmdb>
where
    S: Db,
{ /* private fields */ }

Implementations

impl<S: Db> Runtime<S>

pub fn new( storage: &S, agent_store: CodeStore<S>, lock: MutLock, ) -> Result<Self>

pub fn into_shared(self) -> Arc<Mutex<Self>>

pub fn get_db(&self) -> S

Returns a copy of the underlying db handle

pub fn agent_exists(&self, aid: &AgentId) -> Result<bool>

Check whether a sw-agent exists

pub fn agent_revoked(&self, aid: &AgentId) -> Result<bool>

Check whether a sw-agent is revoked

pub fn instantiate_sw_agent( &mut self, agent_id: AgentId, module_bytes: &[u8], ) -> Result<()>

pub async fn check_module_and_state( &mut self, module_bytes: Vec<u8>, state: Value, ) -> Result<(bool, Vec<String>)>

Sanity check for introductions

pub fn set_executor(&mut self, executor_id: BorderlessId) -> Result<()>

Sets the currently active executor

This buffers the BorderlessId of the executor, to later write it into the dedicated register, so that the wasm side can query it.

pub fn register_ws(&mut self, aid: AgentId) -> Result<Receiver<Vec<u8>>>

Registers a new websocket client

pub async fn initialize(&mut self, aid: &AgentId) -> Result<Init>

pub async fn process_ws_msg( &mut self, aid: &AgentId, msg: Vec<u8>, ) -> Result<Option<Events>>

pub async fn on_ws_open(&mut self, aid: &AgentId) -> Result<Option<Events>>

pub async fn on_ws_error(&mut self, aid: &AgentId) -> Result<Option<Events>>

pub async fn on_ws_close(&mut self, aid: &AgentId) -> Result<Option<Events>>

pub async fn process_introduction( &mut self, introduction: Introduction, ) -> Result<()>

pub async fn process_revocation(&mut self, revocation: Revocation) -> Result<()>

pub async fn process_action( &mut self, aid: &AgentId, action: CallAction, ) -> Result<Option<Events>>

pub async fn http_get_state( &mut self, aid: &AgentId, path: String, ) -> Result<(u16, Vec<u8>)>

pub async fn http_post_action( &mut self, aid: &AgentId, path: String, payload: Vec<u8>, writer: &BorderlessId, ) -> Result<Result<(Events, CallAction), (u16, String)>>

Uses a POST request to parse and generate a CallAction object.

The return type is a nested result. The outer result type should convert to a server error, as it represents errors in the runtime itself. The inner error type comes from the wasm code and contains the error status and message.

pub async fn get_symbols(&mut self, aid: &AgentId) -> Result<Option<Symbols>>

Returns the symbols of the contract

pub fn available_agents(&self) -> Result<Vec<AgentId>>