Struct WshRpcProxy 

pub struct WshRpcProxy {
    rpc_context: Arc<Mutex<Option<RpcContext>>>,
    auth_token: Arc<Mutex<String>>,
    pub to_remote: Sender<Vec<u8>>,
    pub from_remote: Receiver<Vec<u8>>,
    to_remote_rx: Option<Receiver<Vec<u8>>>,
    from_remote_tx: Sender<Vec<u8>>,
}

Single-connection RPC proxy. Forwards messages between a local connection and a remote endpoint.

Fields

rpc_context: Arc<Mutex<Option<RpcContext>>>

auth_token: Arc<Mutex<String>>

to_remote: Sender<Vec<u8>>

from_remote: Receiver<Vec<u8>>

to_remote_rx: Option<Receiver<Vec<u8>>>

from_remote_tx: Sender<Vec<u8>>

Implementations

impl WshRpcProxy

pub fn new() -> Self

pub fn set_rpc_context(&self, ctx: RpcContext)

pub fn get_rpc_context(&self) -> Option<RpcContext>

pub fn set_auth_token(&self, token: &str)

pub fn get_auth_token(&self) -> String

pub fn take_to_remote_rx(&mut self) -> Option<Receiver<Vec<u8>>>

Take the receiver end of to_remote channel (for proxy loop).

pub fn from_remote_sender(&self) -> Sender<Vec<u8>>

Get a clone of the from_remote sender (for injecting messages).

pub async fn send_to_remote(&self, msg: Vec<u8>) -> Result<(), String>

Send a message to the remote endpoint.

pub async fn send_rpc_message(&self, msg: &RpcMessage) -> Result<(), String>

Inject an RPC message (encode as JSON and send to remote).

pub async fn send_response_error( &self, req_id: &str, err_msg: &str, ) -> Result<(), String>

Send an error response for a given request.