Struct QuoteProviderCache 

pub struct QuoteProviderCache {
    providers: Arc<RwLock<HashMap<WalletAddress, QuoteProviderConfig>>>,
    db: Arc<dyn RfqWriter>,
}

Fields

providers: Arc<RwLock<HashMap<WalletAddress, QuoteProviderConfig>>>

db: Arc<dyn RfqWriter>

Implementations

impl QuoteProviderCache

pub fn new(db: Arc<dyn RfqWriter>) -> Self

pub async fn load_from_db(&self) -> Result<()>

Load all quote providers from database at startup.

pub async fn is_active(&self, wallet: &WalletAddress) -> bool

Check if a wallet is a registered and active QP.

Takes the read lock asynchronously (rather than try_read()) so concurrent admin writes (register/suspend) cannot transiently map a valid active QP to “inactive” and reject legitimate QP websocket connections or firm-quote responses. This is called on the QP websocket auth path and on every inbound RFQ response, so silent false negatives here look like flaky QP behavior to operators.

pub async fn get_active_for_underlying( &self, underlying: &str, ) -> Vec<QuoteProviderConfig>

Get all active QPs that can quote a given underlying.

Takes the read lock asynchronously rather than using try_read, which would silently return an empty vec under concurrent admin writes (register/suspend). A false-empty result here causes submit_rfq to fan out to zero QPs and eventually age into no_quotes even though eligible providers exist.

pub async fn register(&self, config: QuoteProviderConfig) -> Result<()>

Register or update a quote provider (admin operation).

pub async fn update_status( &self, wallet: &WalletAddress, status: QpStatus, ) -> Result<()>

Update QP status (active/suspended).

pub async fn get_all(&self) -> Vec<QuoteProviderConfig>

Get all registered QPs (for admin listing).