hebo 0.3.3

Distributed MQTT broker
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
29
30
31
32
33
34
35
36
37
38

// Copyright (c) 2021 Xu Shaohua <shaohua@biofan.org>. All rights reserved.
// Use of this source is governed by Affero General Public License that can be found
// in the LICENSE file.

use tokio::sync::oneshot;
use warp::http::StatusCode;

use super::types::DashboardSender;
use crate::commands::DashboardToServerContexCmd;

/// metrics api
pub async fn get_uptime(sender: DashboardSender) -> Result<impl warp::Reply, warp::Rejection> {
    log::info!("Dashboard::get_uptime()");
    let (resp_tx, resp_rx) = oneshot::channel();
    if let Err(err) = sender
        .send(DashboardToServerContexCmd::MetricsGetUptime(resp_tx))
        .await
    {
        log::error!("Failed to send cmd to server ctx, err: {err:?}");
    } else {
        match resp_rx.await {
            Ok(uptime) => {
                return Ok(warp::reply::with_status(
                    format!("{uptime}"),
                    StatusCode::OK,
                ));
            }
            Err(err) => {
                log::info!("metrics response err: {err:?}");
            }
        }
    }

    Ok(warp::reply::with_status(
        "Internal server error".to_string(),
        StatusCode::INTERNAL_SERVER_ERROR,
    ))
}