mesh_rpc/
rpc.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

use crate::service::Code;
use crate::service::Status;
use thiserror::Error;

pub fn status_from_err(code: Code, err: impl Into<anyhow::Error>) -> Status {
    Status {
        code: code as i32,
        message: format!("{:#}", err.into()),
        details: Vec::new(),
    }
}

#[derive(Debug, Error)]
pub enum ProtocolError {
    #[error("invalid message type {0}")]
    InvalidMessageType(u8),
    #[error("stream id must be odd for client requests")]
    EvenStreamId,
}