Struct RpcGlobalState

pub struct RpcGlobalState {
    pub(crate) clients: Mutex<HashMap<String, ClientHandleArc>>,
    pub(crate) rpc_handles: Mutex<HashMap<u64, AbortHandle>>,
    pub(crate) unified_database: Database,
}

Fields

clients: Mutex<HashMap<String, ClientHandleArc>>

rpc_handles: Mutex<HashMap<u64, AbortHandle>>

unified_database: Database

Implementations

impl RpcGlobalState

pub fn new(unified_database: Database) -> Self

pub(crate) async fn add_client( &self, client_name: String, client: ClientHandleArc, )

pub(crate) async fn get_client( &self, client_name: &str, ) -> Option<ClientHandleArc>

pub(crate) fn add_rpc_handle(&self, request_id: u64, handle: AbortHandle)

pub(crate) fn remove_rpc_handle(&self, request_id: u64) -> Option<AbortHandle>

pub(crate) async fn client_builder(db: Database) -> Result<ClientBuilder, Error>

pub(crate) async fn client_db(&self, client_name: String) -> Result<Database>

Get client-specific database with proper prefix

pub(crate) async fn handle_join_federation( &self, invite_code: String, client_name: String, force_recover: bool, ) -> Result<()>

Handle joining federation using unified database

pub(crate) async fn handle_open_client(&self, client_name: String) -> Result<()>

pub(crate) async fn handle_close_client( &self, client_name: String, ) -> Result<()>

pub(crate) fn handle_client_rpc( self: Arc<Self>, client_name: String, module: String, method: String, payload: Value, ) -> BoxStream<'static, Result<Value>>

pub(crate) fn parse_invite_code(&self, invite_code: String) -> Result<Value>

pub(crate) fn parse_bolt11_invoice(&self, invoice_str: String) -> Result<Value>

pub(crate) async fn preview_federation( &self, invite_code: String, ) -> Result<Value>

pub(crate) fn handle_rpc_inner( self: Arc<Self>, request: RpcRequest, ) -> Option<BoxStream<'static, Result<Value>>>

pub fn handle_rpc( self: Arc<Self>, request: RpcRequest, handler: impl RpcResponseHandler + 'static, ) -> HandledRpc<'static>

pub(crate) async fn get_mnemonic_words(&self) -> Result<Option<Vec<String>>>

Retrieve the wallet-level mnemonic words. Returns the mnemonic as a vector of words, or None if no mnemonic is set.

pub(crate) async fn set_mnemonic(&self, words: Vec<String>) -> Result<()>

Set a mnemonic from user-provided words Returns an error if a mnemonic is already set

pub(crate) async fn generate_mnemonic(&self) -> Result<Vec<String>>

Generate a new random mnemonic and set it Returns an error if a mnemonic is already set

pub(crate) fn derive_federation_secret( &self, mnemonic: &Mnemonic, federation_id: &FederationId, ) -> DerivableSecret

Derive federation-specific secret from wallet mnemonic

pub(crate) async fn get_mnemonic_from_db(&self) -> Result<Option<Mnemonic>>

Fetch mnemonic from database