Struct grin_wallet_impls::test_framework::WalletProxy

pub struct WalletProxy<C, K> where
    C: NodeClient,
    K: Keychain,  {
    pub chain_dir: String,
    pub chain: Arc<Chain>,
    pub wallets: HashMap<String, (Sender<WalletProxyMessage>, Arc<Mutex<dyn WalletInst<LocalWalletClient, K>>>)>,
    pub tx: Sender<WalletProxyMessage>,
    pub rx: Receiver<WalletProxyMessage>,
    pub running: Arc<AtomicBool>,
    // some fields omitted
}

communicates with a chain instance or other wallet listener APIs via message queues

Fields

chain_dir: String

directory to create the chain in

chain: Arc<Chain>

handle to chain itself

wallets: HashMap<String, (Sender<WalletProxyMessage>, Arc<Mutex<dyn WalletInst<LocalWalletClient, K>>>)>

list of interested wallets

tx: Sender<WalletProxyMessage>

simulate json send to another client address, method, payload (simulate HTTP request)

rx: Receiver<WalletProxyMessage>

simulate json receiving

running: Arc<AtomicBool>

queue control

Methods

impl<C, K> WalletProxy<C, K> where
    C: NodeClient,
    K: Keychain, 

pub fn new(chain_dir: &str) -> Self

Create a new client that will communicate with the given grin node

pub fn add_wallet(
    &mut self,
    addr: &str,
    tx: Sender<WalletProxyMessage>,
    wallet: Arc<Mutex<dyn WalletInst<LocalWalletClient, K>>>
)

Add wallet with a given "address"

pub fn stop(&mut self)

pub fn run(&mut self) -> Result<(), Error>

Run the incoming message queue and respond more or less synchronously