gm-tui 0.0.1

TUI-based Ethereum wallet
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use super::Event;
use serde::Deserialize;
use std::{
    sync::{
        atomic::{AtomicBool, Ordering},
        mpsc::Sender,
        Arc,
    },
    thread,
    time::Duration,
};

pub async fn watch_eth_price_change(transmitter: Sender<Event>, shutdown_signal: Arc<AtomicBool>) {
    // Query interval is the API query delay, however to prevent blocking at
    // the thread::sleep, which will cause delayed processing of shutdown_signal.
    // To prevent this, we check shutdown_signal at shorter intervals while
    // making API calls at a longer duration.
    let query_interval_milli = 2000;
    let thread_sleep_duration_milli = 100;

    let mut counter = query_interval_milli;
    while !shutdown_signal.load(Ordering::Relaxed) {
        if counter >= query_interval_milli {
            // Send result back to main thread. If main thread has already
            // shutdown, then we will get error. Since our event is not
            // critical, we do not store it to disk.
            let _ = match query_eth_price().await {
                Ok(price) => {
                    let price = format_decimal_string(price);
                    transmitter.send(Event::EthPriceUpdate(price))
                }
                Err(error) => transmitter.send(Event::EthPriceError(error)),
            };
            counter = 0;
        }

        counter += thread_sleep_duration_milli;
        thread::sleep(Duration::from_millis(thread_sleep_duration_milli));
    }
}

fn format_decimal_string(input: String) -> String {
    match input.parse::<f64>() {
        Ok(f) => format!("{f:.2}"),  // 2 decimal places
        Err(_) => input.to_string(), // fallback: return as-is
    }
}

#[derive(Deserialize)]
struct BinanceResponse {
    #[allow(dead_code)]
    symbol: String,
    price: String,
}

async fn query_eth_price() -> Result<String, reqwest::Error> {
    let url = "https://api.binance.com/api/v3/ticker/price?symbol=ETHUSDT";
    let response = reqwest::get(url).await?;
    let json = response.json::<BinanceResponse>().await?;
    Ok(json.price)
}