//! Пример для проверки компонента
//!
//! Запуск:
//!
//! ```bash
//! cargo run -p rsiot-redis-subscriber --example ex1
//! ```
//!
//! Проверки:
//!
//! - через веб-интрефейс, в Pub/Sub, в канал `rsiot-redis-subscriber` записать сообщение
//! {"Message0": 123}. В консоли должно прочитаться это сообщение
//!
//! - через веб-интерфейс, перед запуском примера создать хеш с названием `rsiot-redis-subscriber`,
//! задать ключ `Message0`. После запуска примера в консоли должно прочитаться это сообщение
//!
//! - корректный перезапуск. При отключении Redis, передачи неправильного сообщения в Pub/Sub

use tokio::main;
use tracing::Level;
use tracing_subscriber::fmt;
use url::Url;

use rsiot_component_core::ComponentCollection;
use rsiot_extra_components::cmp_logger;
use rsiot_messages_core::{ExampleMessage, ExampleMessageChannel};
use rsiot_redis_subscriber::cmp_redis_subscriber;

#[main]
async fn main() {
    fmt().init();

    let mut chain = ComponentCollection::<ExampleMessage>::new(
        100,
        vec![
            cmp_redis_subscriber::new(cmp_redis_subscriber::Config {
                url: Url::parse("redis://127.0.0.1:6379").unwrap(),
                redis_channel: ExampleMessageChannel::Output,
            }),
            cmp_logger::new(cmp_logger::Config {
                level: Level::INFO,
                header: "".into(),
            }),
        ],
    );
    chain.spawn().await;
}