workflow_rpc/
encoding.rs

1//!
2//! Module containing a helper [`Encoding`] enum use in RPC server constructors.
3//!
4
5use crate::error::Error;
6use serde::{Deserialize, Serialize};
7use std::{
8    fmt::{Debug, Display, Formatter},
9    str::FromStr,
10};
11use wasm_bindgen::convert::TryFromJsValue;
12use wasm_bindgen::prelude::*;
13
14/// wRPC protocol encoding: `Borsh` or `JSON`
15/// @category Transport
16#[derive(Debug, Clone, Copy, Serialize, Deserialize, Hash, Eq, PartialEq)]
17#[wasm_bindgen]
18#[serde(rename_all = "kebab-case")]
19pub enum Encoding {
20    Borsh = 0,
21    #[serde(rename = "json")]
22    SerdeJson = 1,
23}
24
25impl Display for Encoding {
26    #[inline]
27    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
28        let s = match self {
29            Encoding::Borsh => "borsh",
30            Encoding::SerdeJson => "json",
31        };
32        f.write_str(s)
33    }
34}
35
36impl FromStr for Encoding {
37    type Err = Error;
38    fn from_str(s: &str) -> Result<Self, Self::Err> {
39        match s.to_lowercase().as_str() {
40            "borsh" => Ok(Encoding::Borsh),
41            "json" => Ok(Encoding::SerdeJson),
42            "serde-json" => Ok(Encoding::SerdeJson),
43            _ => Err(Error::Encoding(
44                "invalid encoding: {s} (must be: 'borsh' or 'json')".to_string(),
45            )),
46        }
47    }
48}
49
50impl TryFrom<u8> for Encoding {
51    type Error = Error;
52    fn try_from(value: u8) -> Result<Self, Self::Error> {
53        match value {
54            0 => Ok(Encoding::Borsh),
55            1 => Ok(Encoding::SerdeJson),
56            _ => Err(Error::Encoding(
57                "invalid encoding: {value} (must be: Encoding.Borsh (0) or Encoding.JSON (1))"
58                    .to_string(),
59            )),
60        }
61    }
62}
63
64impl TryFrom<JsValue> for Encoding {
65    type Error = Error;
66    fn try_from(value: JsValue) -> Result<Self, Self::Error> {
67        if let Ok(encoding) = Encoding::try_from_js_value(value.clone()) {
68            Ok(encoding)
69        } else if let Some(v) = value.as_f64() {
70            Ok(Encoding::try_from(v as u8)?)
71        } else if let Some(string) = value.as_string() {
72            Encoding::from_str(&string)
73        } else {
74            Err(Error::Encoding(
75                "invalid encoding value: {value:?}".to_string(),
76            ))
77        }
78    }
79}
80
81const ENCODING: [Encoding; 2] = [Encoding::Borsh, Encoding::SerdeJson];
82
83impl Encoding {
84    pub fn iter() -> impl Iterator<Item = &'static Encoding> {
85        ENCODING.iter()
86    }
87}
workflow_rpc/encoding.rs

workflow_rpc/
encoding.rs
