use crossbeam_channel::unbounded;
use sequencer_client::feed_clients::RelayClients;
use std::sync::Arc;

#[tokio::main]
async fn main() {
    // Create a channel to receive messages from the feed client
    let (sender, receiver) = unbounded();

    // Create a new relay client and start reader + connection maintainer
    let relay_client = RelayClients::new("wss://arb1.arbitrum.io/feed", 42161, 2, 1, sender)
        .expect("Failed to create relay client");
    tokio::spawn(RelayClients::start_reader(relay_client));

    // To prevent duplicate messages
    let mut highest_seq_number: i64 = 0;

    loop {
        let data = receiver
            .recv()
            .expect("Failed to receive data from feed client");

        let msg_seq_num = data.messages[0].sequence_number;


        if highest_seq_number >= msg_seq_num {
            continue;
        }

        highest_seq_number = msg_seq_num;

        info!("Received message, sequencer_number: {:?} ", msg_seq_num);
    }
}