tact 0.1.1

Terminal interface for Nanocodex
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

//! Lossless forwarding for active and retiring Nanocodex event streams.

use crate::tui::pane::PaneId;
use nanocodex::{AgentEvent, AgentEvents};
use tokio::sync::mpsc;

pub(crate) enum ForwardedAgentEvent {
    Event {
        pane: PaneId,
        session_id: String,
        generation: u64,
        event: AgentEvent,
    },
    Closed {
        pane: PaneId,
        session_id: String,
        generation: u64,
    },
}

pub(crate) fn forward(
    pane: PaneId,
    generation: u64,
    mut events: AgentEvents,
    sender: mpsc::UnboundedSender<ForwardedAgentEvent>,
) {
    let session_id = events.request_id().to_owned();
    tokio::spawn(async move {
        while let Some(event) = events.recv().await {
            if sender
                .send(ForwardedAgentEvent::Event {
                    pane,
                    session_id: session_id.clone(),
                    generation,
                    event,
                })
                .is_err()
            {
                return;
            }
        }
        drop(sender.send(ForwardedAgentEvent::Closed {
            pane,
            session_id,
            generation,
        }));
    });
}