logos-blockchain/logos-blockchain-testing
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-testing.git synced 2026-03-31 08:13:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Hide raw scenario sources behind semantic accessors

Browse Source
This commit is contained in:
andrussal 2026-03-08 14:00:34 +01:00
parent 05b907d8ef
commit f79eb34a50
4 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
testing-framework/core/src/scenario/definition.rs
View File

@ -113,6 +113,7 @@ impl<E: Application, Caps> Scenario<E, Caps> {
}
#[must_use]
#[doc(hidden)]
pub fn sources(&self) -> &ScenarioSources {
&self.sources
}
@ -122,6 +123,11 @@ impl<E: Application, Caps> Scenario<E, Caps> {
self.sources.existing_cluster()
}
#[must_use]
pub const fn uses_existing_cluster(&self) -> bool {
self.sources.uses_existing_cluster()
}
#[must_use]
#[doc(hidden)]
pub fn attached_source(&self) -> Option<&AttachSource> {

2
testing-framework/core/src/scenario/runtime/orchestration/source_resolver.rs
View File

@ -41,7 +41,7 @@ pub enum SourceResolveError {
pub fn build_source_orchestration_plan<E: Application, Caps>(
scenario: &Scenario<E, Caps>,
) -> Result<SourceOrchestrationPlan, SourceOrchestrationPlanError> {
SourceOrchestrationPlan::try_from_sources(scenario.sources())
Ok(scenario.source_orchestration_plan().clone())
}
/// Resolves runtime source nodes via unified providers from orchestration plan.

2
testing-framework/deployers/compose/src/deployer/orchestrator.rs
View File

@ -71,7 +71,7 @@ impl<E: ComposeDeployEnv> DeploymentOrchestrator<E> {
}
})?;
if scenario.sources().uses_existing_cluster() {
if scenario.uses_existing_cluster() {
return self
.deploy_attached_only::<Caps>(scenario, source_plan)
.await

2
testing-framework/deployers/k8s/src/deployer/orchestrator.rs
View File

@ -179,7 +179,7 @@ where
let observability = resolve_observability_inputs(scenario.capabilities())?;
if scenario.sources().uses_existing_cluster() {
if scenario.uses_existing_cluster() {
let runner = deploy_attached_only::<E, Caps>(scenario, source_plan, observability).await?;
return Ok((runner, attached_metadata(scenario)));
}