Struct NodeService 

pub struct NodeService { /* private fields */ }

A running node service that can be queried over GraphQL.

Implementations

impl NodeService

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

Terminates the node service 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 process is still running.

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

Runs the processInbox GraphQL mutation for the given chain.

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

Runs the sync GraphQL mutation for the given chain.

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

Transfers the given amount from an owner to a recipient via the transfer mutation.

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

Queries the balance of the given account.

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 over GraphQL.

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

Publishes a data blob to the given chain via the publishDataBlob mutation.

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

Publishes a module to the given chain via the publishModule mutation.

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

Queries the committee hash of the given chain.

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

Queries the current epoch of the given chain.

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

Queries the events of the given stream starting from the given index.

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

Posts the given GraphQL query to the node service, retrying on transient 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>>

Creates an application from a published module via the createApplication mutation.

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.

Trait Implementations

impl Drop for NodeService

fn drop(&mut self)

Executes the destructor for this type.