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

mod convert;

use crate::rpc::format::ResTrait;
use crate::rpc::RpcError;
pub use convert::Pack;

use crate::rpc::request::Request;
use crate::sql::Value;

pub fn req(val: Vec<u8>) -> Result<Request, RpcError> {
	rmpv::decode::read_value(&mut val.as_slice())
		.map_err(|_| RpcError::ParseError)
		.map(Pack)?
		.try_into()
}

pub fn res(res: impl ResTrait) -> Result<Vec<u8>, RpcError> {
	// Convert the response into a value
	let val: Value = res.into();
	let val: Pack = val.try_into()?;
	// Create a new vector for encoding output
	let mut res = Vec::new();
	// Serialize the value into MsgPack binary data
	rmpv::encode::write_value(&mut res, &val.0).unwrap();
	Ok(res)
}