Skip to content
Snippets Groups Projects
Unverified Commit ef5b09d2 authored by bgallois's avatar bgallois
Browse files

fix #255

parent c521f5e1
No related branches found
No related tags found
No related merge requests found
......@@ -40,19 +40,24 @@ where
Backend: sc_client_api::Backend<B>,
IdtyIndex: Decode + Encode + PartialEq + TypeInfo,
{
let pool_index = client
let pool_index = if let Some(index) = client
.storage(
parent,
&StorageKey(
frame_support::storage::storage_prefix(b"Distance", b"CurrentPoolIndex").to_vec(),
),
)
.expect("CurrentIndex is Err")
.map_or(0, |raw| {
u32::decode(&mut &raw.0[..]).expect("cannot decode CurrentIndex")
});
.ok()
.flatten()
.map_or(None, |raw| u32::decode(&mut &raw.0[..]).ok())
{
index
} else {
log::error!("🧙 [distance oracle] CurrentPoolIndex cannot be decoded");
return Ok(sp_distance::InherentDataProvider::<IdtyIndex>::new(None));
};
let published_results = client
let published_results = if let Some(results) = client
.storage(
parent,
&StorageKey(
......@@ -67,11 +72,17 @@ where
)
.to_vec(),
),
)?
.map_or_else(Default::default, |raw| {
pallet_distance::EvaluationPool::<AccountId32, IdtyIndex>::decode(&mut &raw.0[..])
.expect("cannot decode EvaluationPool")
});
)
.ok()
.flatten()
.map_or(None, |raw| {
pallet_distance::EvaluationPool::<AccountId32, IdtyIndex>::decode(&mut &raw.0[..]).ok()
}) {
results
} else {
log::error!("🧙 [distance oracle] EvaluationPool cannot be decoded");
return Ok(sp_distance::InherentDataProvider::<IdtyIndex>::new(None));
};
// Have we already published a result for this period?
// The block author is guaranteed to be in the owner_keys.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment