rsiot-http-server 0.0.71

HTTP-сервер
Documentation 
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
28

use std::sync::Arc;

use axum::extract;

use rsiot_messages_core::MsgDataBound;

use crate::{error::Error, shared_state::SharedState};

/// Маршрут для ввода сообщений
pub async fn replace<TMsg>(
    extract::State(shared_state): extract::State<Arc<SharedState<TMsg>>>,
    body: String,
) -> Result<(), Error>
where
    TMsg: MsgDataBound,
{
    let msg = (shared_state.config.fn_output)(&body).map_err(Error::FnInput)?;
    let msg = match msg {
        Some(val) => val,
        None => return Ok(()),
    };
    shared_state
        .cmp_interface
        .send_output(msg)
        .await
        .map_err(Error::CmpOutput)?;
    Ok(())
}