tentacli 15.2.3

Framework for building extensible network protocol clients via modular plugins.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use async_broadcast::Receiver;
use std::collections::HashMap;
use std::sync::Arc;
use tokio::sync::RwLock;
use tokio::sync::mpsc::Sender;
use tokio_util::sync::CancellationToken;

mod components;
mod events;
mod layout;
mod theme;
mod traits;

// use crate::client::{CtxMap, Echo, OrderedOutput, ServerLabel, Task};
// use crate::client::plugin::CorePlugin;
use crate::client::prelude::*;
use crate::plugins::tui::components::app::App;

#[derive(Default)]
pub struct TUIPlugin;

impl CorePlugin for TUIPlugin {
    fn get_tasks(
        &self,
        broadcast_rx: Receiver<OrderedOutput>,
        echo_senders: Arc<HashMap<ServerLabel, Sender<Echo>>>,
        shutdown: CancellationToken,
        _: Arc<RwLock<CtxMap>>,
    ) -> anyhow::Result<Vec<Task>> {
        Ok(vec![App::handle_run(
            broadcast_rx,
            echo_senders.clone(),
            shutdown.clone(),
        )])
    }
}