terrazzo-terminal 0.2.8

A simple web-based terminal emulator built on Terrazzo.
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

use std::sync::Arc;

use terrazzo::axum::Json;
use terrazzo::axum::response::IntoResponse;
use tracing::Instrument as _;
use tracing::info_span;
use trz_gateway_common::http_error::HttpError;
use trz_gateway_common::id::ClientName;

use self::register::RegisterStreamError;
use crate::api::server::correlation_id::CorrelationId;
use crate::api::shared::terminal_schema::RegisterTerminalRequest;
use crate::backend::Server;

mod ack;
mod close;
mod pipe;
mod register;
mod registration;

pub use self::ack::ack;
pub use self::close::close;
pub use self::pipe::close_pipe;
pub use self::pipe::keepalive;

pub async fn pipe(server: Arc<Server>, correlation_id: CorrelationId) -> impl IntoResponse {
    pipe::pipe(server, correlation_id)
}

pub async fn register(
    my_client_name: Option<ClientName>,
    server: Arc<Server>,
    Json(request): Json<RegisterTerminalRequest>,
) -> Result<(), HttpError<RegisterStreamError>> {
    let span = info_span!("Register", terminal_id = %request.def.address.id);
    let response = register::register(my_client_name, &server, request)
        .instrument(span)
        .await;
    Ok(response?)
}