Struct TangleTestHarness

pub struct TangleTestHarness<Ctx = ()> {
    pub sr25519_signer: TanglePairSigner<Pair>,
    pub ecdsa_signer: TanglePairSigner<Pair>,
    pub alloy_key: PrivateKeySigner,
    /* private fields */
}

Test harness for Tangle network tests

Fields

sr25519_signer: TanglePairSigner<Pair>

ecdsa_signer: TanglePairSigner<Pair>

alloy_key: PrivateKeySigner

Implementations

impl<Ctx> TangleTestHarness<Ctx>

where Ctx: Clone + Send + Sync + 'static,

pub async fn setup(test_dir: TempDir) -> Result<Self, Error>

Create a new TangleTestHarness

Errors

TODO

Examples

use blueprint_tangle_testing_utils::TangleTestHarness;
use tempfile::TempDir;

let tmp_dir = TempDir::new()?;
let harness = TangleTestHarness::setup(tmp_dir).await?;

pub fn env(&self) -> &BlueprintEnvironment

pub fn config(&self) -> &TangleTestConfig

impl<Ctx> TangleTestHarness<Ctx>

where Ctx: Clone + Send + Sync + 'static,

pub fn client(&self) -> &TangleClient

Gets a reference to the Tangle client

pub fn create_deploy_opts(&self, manifest_path: PathBuf) -> Result<Opts>

Creates deploy options for a blueprint

Errors

See read_cargo_toml_file()

pub async fn deploy_blueprint(&self) -> Result<u64, Error>

Deploys a blueprint from the current directory and returns its ID

Errors

See deploy_to_tangle()

pub async fn setup_services_with_options<const N: usize>( &self, __arg1: SetupServicesOpts<N>, ) -> Result<(MultiNodeTestEnv<Ctx, MockHeartbeatConsumer>, u64, u64), Error>

Sets up a complete service environment with initialized event handlers

Returns

A tuple of the test environment, the service ID, and the blueprint ID i.e., (test_env, service_id, blueprint_id)

Note

The Service ID will always be 0 if automatic registration is disabled, as there is not yet a service to have an ID

Errors

• See Self::setup_services, Self::deploy_blueprint() and MultiNodeTestEnv::new()

pub async fn setup_services<const N: usize>( &self, exit_after_registration: bool, ) -> Result<(MultiNodeTestEnv<Ctx, MockHeartbeatConsumer>, u64, u64), Error>

Sets up a complete service environment with initialized event handlers

Returns

A tuple of the test environment, the service ID, and the blueprint ID i.e., (test_env, service_id, blueprint_id)

Note

The Service ID will always be 0 if automatic registration is disabled, as there is not yet a service to have an ID

Errors

• See Self::deploy_blueprint() and MultiNodeTestEnv::new()

pub async fn request_service_with_quotes( &self, blueprint_id: u64, request_args: RequestArgs, operators: Vec<AccountId32>, quotes: Vec<PricingQuote>, quote_signatures: Vec<Signature>, security_commitments: Vec<AssetSecurityCommitment<AssetId>>, optional_assets: Option<Vec<AssetSecurityRequirement<AssetId>>>, ) -> Result<u64, Error>

Requests a service with a given blueprint using pricing quotes.

Arguments

• blueprint_id - The ID of the blueprint to request
• request_args - The arguments for the request
• quotes - The pricing quotes for the service
• quote_signatures - The signatures for the pricing quotes
• security_commitments - The security commitments for the service
• optional_assets - Optional asset security requirements (defaults to Custom(0) at 50%-80% if not provided)

Errors

Returns an error if the transaction fails

pub async fn submit_job( &self, service_id: u64, job_id: u8, inputs: Vec<InputValue>, ) -> Result<JobCalled, Error>

Submits a job to be executed

Arguments

• service_id - The ID of the service to submit the job to
• job_id - The ID of the job to submit
• inputs - The input values for the job

Returns

The submitted job if successful

Errors

Returns an error if the transaction fails

pub async fn wait_for_job_execution( &self, service_id: u64, job: JobCalled, ) -> Result<JobResultSubmitted, Error>

Executes a previously submitted job and waits for completion

Arguments

• service_id - The ID of the service the job was submitted to
• job - The submitted job to execute

Returns

The job results if execution was successful

Errors

Returns an error if no job result is found.

pub fn verify_job( &self, results: &JobResultSubmitted, expected: impl AsRef<[OutputValue]>, )

Verifies that job results match expected outputs

Arguments

• results - The actual job results
• expected - The expected output values

Returns

The verified results if they match expectations

Panics

If the results don’t match the expected outputs