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

//! Implementation of the Notify service through the gRPC tunnel.

use tonic::Request;
use tonic::Response;
use tonic::Result;
use tonic::Streaming;
use tonic::async_trait;

use crate::backend::client_service::ClientServiceImpl;
use crate::backend::client_service::notify_service::dispatch::notify_dispatch;
use crate::backend::client_service::notify_service::response::remote::RemoteResponseStream;
use crate::backend::protos::terrazzo::notify::NotifyRequest;
use crate::backend::protos::terrazzo::notify::notify_service_server::NotifyService;

#[async_trait]
impl NotifyService for ClientServiceImpl {
    type NotifyStream = RemoteResponseStream;

    async fn notify(
        &self,
        request: Request<Streaming<NotifyRequest>>,
    ) -> Result<Response<Self::NotifyStream>, tonic::Status> {
        notify_dispatch(request.into_inner().into())
            .map(|response| RemoteResponseStream(response).into())
            .map_err(tonic::Status::from)
    }
}