Struct OracleTracker 

pub struct OracleTracker { /* private fields */ }

Mutable typed oracle state.

Implementations

impl OracleTracker

pub fn new(registry: OracleRegistry) -> Self

Create a tracker from an existing registry.

pub fn from_registrations_at_timestamp( feeds: Vec<(FeedRegistration, RoundData)>, now_timestamp: u64, ) -> Result<Self, OracleError>

Seed a tracker from registrations and round data.

pub fn registrations(&self) -> impl Iterator<Item = FeedRegistration> + '_

Return cloned registrations for rebuilding reactive routing.

Prefer Self::registrations_iter when read-only access is enough — this iterator clones every registration it yields.

pub fn registrations_iter(&self) -> impl Iterator<Item = &FeedRegistration>

Iterate over registrations without cloning, in feed-id order.

pub fn feed_readiness(&self) -> Vec<OracleFeedReadinessReport>

Return feed/runtime readiness for all registered feeds.

pub fn insert_seeded_registration( &mut self, registration: FeedRegistration, round: RoundData, ) -> Result<(), OracleError>

Insert a pre-discovered feed and seed its latest proxy-read snapshot.

pub fn remove_by_id(&mut self, id: FeedId) -> Option<FeedRegistration>

Remove a feed by id, including its latest snapshot and pending reconciliation.

pub fn remove_by_proxy(&mut self, proxy: Address) -> Option<FeedRegistration>

Remove a feed by proxy, including its latest snapshot and pending reconciliation.

pub fn now_timestamp(&self) -> u64

Return the timestamp used for snapshot freshness classification.

pub fn latest(&self, proxy: Address) -> Option<&OracleSnapshot>

Return the latest snapshot by proxy.

pub fn registration_for_proxy( &self, proxy: Address, ) -> Option<&FeedRegistration>

Return the feed registration for a proxy.

pub fn price(&self, id: impl AsRef<str>) -> Result<OraclePrice, OracleError>

Return the latest actionable-facing price by feed id string.

Errors

Returns OracleError::FeedNotFound when no feed is registered under id or the feed has no current snapshot.

pub fn price_by_id(&self, id: FeedId) -> Result<OraclePrice, OracleError>

Return the latest actionable-facing price by feed id.

Errors

Returns OracleError::FeedNotFound when no feed is registered under id or the feed has no current snapshot.

pub fn price_by_proxy(&self, proxy: Address) -> Result<OraclePrice, OracleError>

Return the latest actionable-facing price by proxy address.

Errors

Returns OracleError::FeedNotFound when no feed is registered under proxy or the feed has no current snapshot.

pub fn latest_round( &self, id: impl AsRef<str>, ) -> Result<RoundData, OracleError>

Return the latest round by feed id string.

Errors

Returns OracleError::FeedNotFound when no feed is registered under id or the feed has no current snapshot.

pub fn latest_round_by_proxy( &self, proxy: Address, ) -> Result<RoundData, OracleError>

Return the latest round by proxy address.

pub fn pending_reconciliations(&self) -> &[OracleReconciliationRequest]

Return event-specific proxy reconciliations waiting to be processed.

pub fn apply_batch_report<N: Network>( &mut self, report: &ReactiveBatchReport<N>, ) -> Result<(), OracleError>

Apply committed reactive reports to typed oracle state.

Built-in handlers emit each update twice for compatibility: as a rich oracle.price_update signal and as a legacy oracle.answer_updated signal. A legacy signal is skipped only when the same batch carries a rich update for the same proxy and event round — legacy-only signals from custom handlers still apply even when unrelated rich updates share the batch. Legacy signals update typed state but are not decoded into OracleHookEvents, so runtime on_event/on_price_update callbacks do not fire for them.

pub async fn reconcile<P: ChainlinkFeedProvider>( &mut self, provider: &P, ) -> Result<ReconcileReport, OracleError>

Reconcile all registered feeds with authoritative proxy reads.

pub fn reconcile_derived_pending_with<R: OracleDerivedReader>( &mut self, reader: &mut R, ) -> DerivedReconcileReport

Reconcile every pending derived-source request through reader.

Derived sources (Morpho, Euler) are confirmed by their protocol’s own view call rather than a Chainlink proxy read: a read equal to the event-recomputed value promotes the snapshot to OracleValueStatus::Confirmed; a differing read installs the authoritative value as OracleValueStatus::Corrected with read-time timestamps. Either way the resulting snapshot carries OracleValueSource::Proxy, because the value now comes from the feed’s authoritative source path. Failed reads leave their request queued and are reported in DerivedReconcileReport::failed instead of failing the pass.

Proxy-kind requests are untouched; drive those through the provider-backed OracleTracker::reconcile / OracleReconciler paths.

Note: correction does not refresh the dependency baselines stored in the feed’s FeedSource legs; subsequent dependency events recompute from the original discovery baselines until the feed is re-discovered.

Trait Implementations

impl Clone for OracleTracker

fn clone(&self) -> OracleTracker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OracleTracker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.