ibc-relayer-cli 1.13.2

Hermes is an IBC Relayer written in Rust 
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

use abscissa_core::clap::Parser;
use abscissa_core::Command;
use abscissa_core::Runnable;
use tracing::info;
use tracing::Level;

use crate::prelude::app_config;
use crate::tracing_handle::send_command;

#[derive(Clone, Command, Debug, Parser, PartialEq, Eq)]
pub struct SetLogLevelCmd {
    #[clap(
        long = "log-level",
        required = true,
        value_name = "LOG_LEVEL",
        help = "The new lowest log level which will be displayed. Possible values are `trace`, `debug`, `info`, `warn` or `error`"
    )]
    log_level: Level,

    #[clap(
        long = "log-filter",
        help_heading = "FLAGS",
        value_name = "LOG_FILTER",
        help = "The target of the log level to update, if left empty all the targets will be updated. Example `ibc` or `tendermint_rpc`"
    )]
    log_filter: Option<String>,
}

impl Runnable for SetLogLevelCmd {
    fn run(&self) {
        let rt = tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()
            .unwrap();

        rt.block_on(run(&self.log_level, self.log_filter.as_ref()));
    }
}

async fn run(log_level: &Level, log_filter: Option<&String>) {
    let config = app_config();

    let port = config.tracing_server.port;

    let str_log = log_level.to_string();

    let result = if let Some(log_filter) = log_filter {
        let log_cmd = format!("{log_filter}={str_log}");
        info!("Setting log level to: {log_cmd}");
        send_command(&log_cmd, port).await
    } else {
        info!("Setting log level to: {str_log}");
        send_command(&str_log, port).await
    };

    match result {
        Ok(msg) => info!("{msg}"),
        Err(e) => info!("Failed to set log level: {e}"),
    }
}