Struct NodeService 

pub struct NodeService { /* private fields */ }

A running node service.

Implementations

impl NodeService

pub async fn terminate(self) -> Result<()>

Terminates the node service by killing its child process.

pub fn port(&self) -> u16

Returns the port the node service is listening on.

pub fn ensure_is_running(&mut self) -> Result<()>

Checks that the node service child process is still running.

pub async fn process_inbox(&self, chain_id: &ChainId) -> Result<Vec<CryptoHash>>

Issues a processInbox GraphQL mutation and returns the hashes of the created blocks.

pub async fn sync(&self, chain_id: &ChainId) -> Result<u64>

Issues a sync GraphQL mutation for the given chain and returns the new block height.

pub async fn transfer( &self, chain_id: ChainId, owner: AccountOwner, recipient: Account, amount: Amount, ) -> Result<CryptoHash>

Issues a transfer GraphQL mutation and returns the resulting block hash.

pub async fn balance(&self, account: &Account) -> Result<Amount>

Queries the balance of the given account via GraphQL.

pub fn make_application<A: ContractAbi>( &self, chain_id: &ChainId, application_id: &ApplicationId<A>, ) -> Result<ApplicationWrapper<A>>

Returns an ApplicationWrapper for querying the given application on this node service.

pub async fn publish_data_blob( &self, chain_id: &ChainId, bytes: Vec<u8>, ) -> Result<CryptoHash>

Issues a publishDataBlob GraphQL mutation and returns the blob’s hash.

pub async fn publish_module<Abi, Parameters, InstantiationArgument>( &self, chain_id: &ChainId, contract: PathBuf, service: PathBuf, vm_runtime: VmRuntime, ) -> Result<ModuleId<Abi, Parameters, InstantiationArgument>>

Issues a publishModule GraphQL mutation and returns the new module ID.

pub async fn query_committees( &self, chain_id: &ChainId, ) -> Result<BTreeMap<Epoch, Committee>>

Queries the committees of the given chain via GraphQL.

pub async fn events_from_index( &self, chain_id: &ChainId, stream_id: &StreamId, start_index: u32, ) -> Result<Vec<IndexAndEvent>>

Issues an eventsFromIndex GraphQL query for events on the given chain and stream.

pub async fn query_node(&self, query: impl AsRef<str>) -> Result<Value>

Posts the given GraphQL query to the node service, retrying on timeouts and errors.

pub async fn create_application<Abi: ContractAbi, Parameters: Serialize, InstantiationArgument: Serialize>( &self, chain_id: &ChainId, module_id: &ModuleId<Abi, Parameters, InstantiationArgument>, parameters: &Parameters, argument: &InstantiationArgument, required_application_ids: &[ApplicationId], ) -> Result<ApplicationId<Abi>>

Issues a createApplication GraphQL mutation and returns the new application ID.

pub async fn chain_tip( &self, chain: ChainId, ) -> Result<Option<(CryptoHash, BlockHeight)>>

Obtains the hash and height of the chain’s tip block, as known by this node service.

pub async fn notifications( &self, chain_id: ChainId, ) -> Result<Pin<Box<impl Stream<Item = Result<Notification>>>>>

Subscribes to the node service and returns a stream of notifications about a chain.

pub async fn query_result( &self, name: &str, chain_id: ChainId, application_id: &ApplicationId, ) -> Result<Pin<Box<impl Stream<Item = Result<Value>>>>>

Subscribes to query results via the queryResult GraphQL subscription.