Sasedev/khadhroony-solana-project
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v0.2.11-pre.008-fix.001

Browse Source
This commit is contained in:
SinuS von SifriduS
2026-08-26 10:30:17 +02:00
parent 87d7314bf4
commit 2fdff17651
6 changed files with 146 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/ksp-offchain-transport-lib/src/market_price_service.rs
View File

@@ -1,5 +1,5 @@
// file: crates/ksp-offchain-transport-lib/src/market_price_service.rs
// version: 1
// version: 2
//! Generic market-price refresh service owning provider dispatch and availability transitions.
@@ -204,10 +204,10 @@ impl crate::MarketPriceService {
availability: crate::MarketPriceProviderAvailability,
) -> crate::MarketPriceProviderState {
let mut guard = lock_registry(&self.registry);
if guard.set_availability(provider_id, availability) {
if let std::option::Option::Some(state) = guard.state(provider_id) {
return state.clone();
}
if guard.set_availability(provider_id, availability)
&& let std::option::Option::Some(state) = guard.state(provider_id)
{
return state.clone();
}
return crate::MarketPriceProviderState::new(provider_id.clone(), availability);
}

5
crates/ksp-offchain-transport-lib/tests/dependency_boundary.rs
View File

@@ -1,5 +1,5 @@
// file: crates/ksp-offchain-transport-lib/tests/dependency_boundary.rs
// version: 9
// version: 10
#![warn(missing_docs)]
#![deny(unreachable_pub)]
@@ -123,5 +123,6 @@ fn pre_008_refresh_service_owns_dispatch_while_registry_and_consumer_surface_sta
assert!(!service.contains("std::thread::sleep"));
assert!(!service.contains("tokio::time::sleep"));
assert!(!service.contains("fallback_provider"));
assert!(!service.contains("consensus"));
assert!(!service.contains("fn aggregate("));
assert!(!service.contains("fn consensus("));
}