1  use apibara_core::starknet::v1alpha2::{Block, Filter, HeaderFilter};
 2  use apibara_sdk::{configuration, ClientBuilder, Configuration, Uri};
 3  use futures_util::{StreamExt, TryStreamExt};
 4  
 5  // #[tokio::test]
 6  // #[ignore]
 7  #[allow(dead_code)]
 8  async fn test_apibara_high_level_api() -> Result<(), Box<dyn std::error::Error>> {
 9      let (config_client, config_stream) = configuration::channel(128);
10  
11      config_client
12          .send(
13              Configuration::<Filter>::default()
14                  .with_starting_block(800_000)
15                  .with_filter(|mut filter| filter.with_header(HeaderFilter::new()).build()),
16          )
17          .await?;
18  
19      let uri = Uri::from_static("https://goerli.starknet.a5a.ch");
20      let stream = ClientBuilder::default()
21          .with_bearer_token(Some("my_auth_token".into()))
22          .connect(uri)
23          .await?
24          .start_stream::<Filter, Block, _>(config_stream)
25          .await?;
26  
27      let mut stream = stream.take(2);
28      while let Some(response) = stream.try_next().await.unwrap() {
29          println!("Response: {:?}", response);
30      }
31  
32      Ok(())
33  }