pyth-network_pyth-crosschain/lazer/sdk/rust/client/examples/symbols.rs

use {pyth_lazer_client::arc_swap::StreamIntoAutoUpdatedHandle, std::time::Duration};

use pyth_lazer_client::history_client::{PythLazerHistoryClient, PythLazerHistoryClientConfig};
use pyth_lazer_protocol::PriceFeedId;
use tokio::time::sleep;
use url::Url;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    tracing_subscriber::fmt::init();
    let urls = std::env::args()
        .skip(1)
        .map(|s| Url::parse(&s))
        .collect::<Result<Vec<_>, _>>()?;

    let client = PythLazerHistoryClient::new(PythLazerHistoryClientConfig {
        urls,
        update_interval: Duration::from_secs(5),
        ..Default::default()
    });
    let symbols = client
        .all_symbols_metadata_stream()
        .await?
        .into_auto_updated_handle()
        .await?;

    loop {
        println!("symbols len: {}", symbols.load().len());
        println!(
            "symbol 1: {:?}",
            symbols
                .load()
                .iter()
                .find(|feed| feed.pyth_lazer_id == PriceFeedId(1))
        );
        sleep(Duration::from_secs(15)).await;
    }
}