hypershell-json-components 0.1.0

use alloc::vec::Vec;
use core::marker::PhantomData;

use cgp::extra::handler::{Handler, HandlerComponent};
use cgp::prelude::*;
use hypershell_components::dsl::DecodeJson;
use serde::Serialize;
use serde::de::DeserializeOwned;

#[cgp_new_provider]
impl<Context, Input, Output> Handler<Context, DecodeJson<Output>, Input> for HandleDecodeJson
where
    Context: CanRaiseAsyncError<serde_json::Error>,
    Input: Send + AsRef<[u8]>,
    Output: Send + DeserializeOwned,
{
    type Output = Output;

    async fn handle(
        _context: &Context,
        _tag: PhantomData<DecodeJson<Output>>,
        input: Input,
    ) -> Result<Self::Output, Context::Error> {
        let output = serde_json::from_slice(input.as_ref()).map_err(Context::raise_error)?;
        Ok(output)
    }
}

#[cgp_new_provider]
impl<Context, Code, Input> Handler<Context, Code, Input> for HandleEncodeJson
where
    Context: CanRaiseAsyncError<serde_json::Error>,
    Input: Send + Serialize,
    Code: Send,
{
    type Output = Vec<u8>;

    async fn handle(
        _context: &Context,
        _tag: PhantomData<Code>,
        input: Input,
    ) -> Result<Vec<u8>, Context::Error> {
        let output = serde_json::to_vec(&input).map_err(Context::raise_error)?;
        Ok(output)
    }
}