use std::collections::HashSet;

use futures::StreamExt;

use pangea_client::{

core::types::{format::Format, ChainId},

provider::UniswapV3Provider,

query::Bound,

requests::uniswap_v3::GetPricesRequest,

ClientBuilder,

WsProvider,

};

#[tokio::main]

async fn main() {

dotenv::dotenv().ok();

let username = std::env::var("PANGEA_USERNAME").unwrap();

let password = std::env::var("PANGEA_PASSWORD").unwrap();

let url = std::env::var("PANGEA_URL").unwrap_or("app.pangea.

foundation".to_string());

// setup websocket client

let client = ClientBuilder::default()

.endpoint(&url)

.credential(&username, &password)

.build::<WsProvider>()

.await

.unwrap();

// subscribe to prices

let request = GetPricesRequest {

chains: HashSet::from([ChainId::ETH]),

from_block: Bound::Latest,

to_block: Bound::Subscribe, // real-time

// for historical data without subscription uncomment below

// from_block: Bound::FromLatest(100),

// to_block: Bound::Latest,

..Default::default()

};