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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

pub mod traits;

#[macro_export]
macro_rules! events_runtime {
    (
        impl EventsRuntime for $T:ty {
            $(local_events = [$($LE:ty),* $(,)?];)?
            $(parent_events = [$($GE:ty),* $(,)?];)?
            $(children = [$($child:ident),* $(,)?];)?
        }
    ) => {
        events_runtime!(@expand
            impl EventsRuntime for $T {
                local_events = [$($($LE),*)?];
                parent_events = [$($($GE),*)?];
                children = [$($($child),*)?];
            }
        );
    };

    (@expand
        impl EventsRuntime for $T:ty {
            local_events = [$($LE:ty),*];
            parent_events = [$($GE:ty),*];
            children = [$($child:ident),*];
        }
    ) => {
        impl EventsRuntime for $T {
            async fn register_all(
                &mut self,
                emitter: Arc<AsyncEventEmitter>,
            ) -> anyhow::Result<()> {

                // bind event system (parent emitter)
                self.bind_event_system(emitter.clone());

                // register LOCAL events
                $(
                    <Self as EventHandler<$LE>>::register_event(
                        self,
                        $crate::plugins::tui::events::traits::EmitType::Local
                    ).await?;
                )*

                // register GLOBAL events
                $(
                    <Self as EventHandler<$GE>>::register_event(
                        self,
                        $crate::plugins::tui::events::traits::EmitType::Parent
                    ).await?;
                )*

                // register children (each child gets THIS component's local emitter as parent)
                $(
                    let child_emitter = self.event_system().local_emitter.clone();
                    self.$child.register_as_child(child_emitter.clone()).await?;
                )*

                Ok(())
            }

            async fn try_update_all(&mut self) -> anyhow::Result<Vec<Echo>> {
                let mut output = Vec::new();

                // children first
                $(
                    output.extend(
                        self.$child.try_update_all().await?
                    );
                )*

                // then this component
                $(
                    output.extend(
                        <Self as EventHandler<$LE>>::try_update(
                            self,
                            $crate::plugins::tui::events::traits::EmitType::Local
                        ).await?
                    );
                )*

                $(
                    output.extend(
                        <Self as EventHandler<$GE>>::try_update(
                            self,
                            $crate::plugins::tui::events::traits::EmitType::Parent
                        ).await?
                    );
                )*

                Ok(output)
            }
        }
    };
}