// Copyright (c) 2022-2023 Yuki Kishimoto
// Copyright (c) 2023-2024 Rust Nostr Developers
// Distributed under the MIT software license

use std::time::Duration;

use nostr_sdk::prelude::*;

#[tokio::main]
async fn main() -> Result<()> {
    tracing_subscriber::fmt::init();

    let client = Client::default();
    client.add_relay("wss://relay.damus.io").await?;
    client.add_relay("wss://nos.lol").await?;

    client.connect().await;

    // Stream events from all connected relays
    let filter = Filter::new().kind(Kind::TextNote).limit(100);
    let mut rx = client
        .stream_events(vec![filter], Some(Duration::from_secs(15)))
        .await?;

    while let Some(event) = rx.next().await {
        println!("{}", event.as_json());
    }

    Ok(())
}