terrazzo-terminal 0.2.7

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
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

use std::path::Path;
use std::sync::Arc;

use nameth::nameth;
use server_fn::BoxedStream;
use server_fn::ServerFnError;
use server_fn::Websocket;
use server_fn::codec::JsonEncoding;
use terrazzo::server;

use crate::api::client_address::ClientAddress;
use crate::text_editor::file_path::FilePath;
use crate::text_editor::rust_lang::synthetic::SyntheticDiagnostic;

#[server(protocol = Websocket<JsonEncoding, JsonEncoding>)]
#[nameth]
pub(super) async fn notify(
    request: BoxedStream<NotifyRequest, ServerFnError>,
) -> Result<BoxedStream<NotifyResponse, ServerFnError>, ServerFnError> {
    use crate::backend::client_service::notify_service::dispatch::notify_dispatch;
    Ok(notify_dispatch(request.into())?.into())
}

#[derive(Debug, serde::Serialize, serde::Deserialize)]
pub enum NotifyRequest {
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "S"))]
    Start {
        #[cfg_attr(not(feature = "diagnostics"), serde(rename = "r"))]
        remote: ClientAddress,
    },
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "W"))]
    Watch {
        #[cfg_attr(not(feature = "diagnostics"), serde(rename = "p"))]
        full_path: FilePath<Arc<Path>>,
    },
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "U"))]
    UnWatch {
        #[cfg_attr(not(feature = "diagnostics"), serde(rename = "p"))]
        full_path: FilePath<Arc<Path>>,
    },
}

#[derive(Debug, serde::Serialize, serde::Deserialize)]
pub struct NotifyResponse {
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "p"))]
    pub path: Arc<Path>,
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "k"))]
    pub kind: EventKind,
}

#[derive(Debug, serde::Serialize, serde::Deserialize)]
pub enum EventKind {
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "F"))]
    File(FileEventKind),
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "C"))]
    CargoCheck(Arc<Vec<SyntheticDiagnostic>>),
}

#[derive(Clone, Copy, Debug, serde::Serialize, serde::Deserialize)]
pub enum FileEventKind {
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "C"))]
    Create,
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "M"))]
    Modify,
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "D"))]
    Delete,
    #[cfg_attr(not(feature = "diagnostics"), serde(rename = "E"))]
    Error,
}