replace network rpc client calls with direct calls to peach_network
This commit is contained in:
parent
3ab3e65eb7
commit
567b0bbc2a
|
@ -2,25 +2,77 @@ use rocket::{get, request::FlashMessage};
|
||||||
use rocket_dyn_templates::Template;
|
use rocket_dyn_templates::Template;
|
||||||
use serde::Serialize;
|
use serde::Serialize;
|
||||||
|
|
||||||
use peach_lib::network_client;
|
use peach_network::{
|
||||||
use peach_lib::stats_client::Traffic;
|
network,
|
||||||
|
network::{Status, Traffic},
|
||||||
|
};
|
||||||
|
|
||||||
use crate::routes::authentication::Authenticated;
|
use crate::routes::authentication::Authenticated;
|
||||||
|
|
||||||
// HELPERS AND ROUTES FOR /status/network
|
// HELPERS AND ROUTES FOR /status/network
|
||||||
|
|
||||||
|
#[derive(Debug, Serialize)]
|
||||||
|
pub struct IfaceTraffic {
|
||||||
|
pub rx: u64,
|
||||||
|
pub rx_unit: Option<String>,
|
||||||
|
pub tx: u64,
|
||||||
|
pub tx_unit: Option<String>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl IfaceTraffic {
|
||||||
|
fn default() -> Self {
|
||||||
|
IfaceTraffic {
|
||||||
|
rx: 0,
|
||||||
|
rx_unit: None,
|
||||||
|
tx: 0,
|
||||||
|
tx_unit: None,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn convert_traffic(traffic: Traffic) -> Option<IfaceTraffic> {
|
||||||
|
let mut t = IfaceTraffic::default();
|
||||||
|
// modify traffic values & assign measurement unit
|
||||||
|
// based on received and transmitted values
|
||||||
|
// if received > 999 MB, convert it to GB
|
||||||
|
if traffic.received > 1_047_527_424 {
|
||||||
|
t.rx = traffic.received / 1_073_741_824;
|
||||||
|
t.rx_unit = Some("GB".to_string());
|
||||||
|
} else if traffic.received > 0 {
|
||||||
|
// otherwise, convert it to MB
|
||||||
|
t.rx = (traffic.received / 1024) / 1024;
|
||||||
|
t.rx_unit = Some("MB".to_string());
|
||||||
|
} else {
|
||||||
|
t.rx = 0;
|
||||||
|
t.rx_unit = Some("MB".to_string());
|
||||||
|
}
|
||||||
|
|
||||||
|
if traffic.transmitted > 1_047_527_424 {
|
||||||
|
t.tx = traffic.transmitted / 1_073_741_824;
|
||||||
|
t.tx_unit = Some("GB".to_string());
|
||||||
|
} else if traffic.transmitted > 0 {
|
||||||
|
t.tx = (traffic.transmitted / 1024) / 1024;
|
||||||
|
t.tx_unit = Some("MB".to_string());
|
||||||
|
} else {
|
||||||
|
t.tx = 0;
|
||||||
|
t.tx_unit = Some("MB".to_string());
|
||||||
|
}
|
||||||
|
|
||||||
|
Some(t)
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Debug, Serialize)]
|
#[derive(Debug, Serialize)]
|
||||||
pub struct NetworkContext {
|
pub struct NetworkContext {
|
||||||
pub ap_ip: String,
|
pub ap_ip: String,
|
||||||
pub ap_ssid: String,
|
pub ap_ssid: String,
|
||||||
pub ap_state: String,
|
pub ap_state: String,
|
||||||
pub ap_traffic: Option<Traffic>,
|
pub ap_traffic: Option<IfaceTraffic>,
|
||||||
pub wlan_ip: String,
|
pub wlan_ip: String,
|
||||||
pub wlan_rssi: Option<String>,
|
pub wlan_rssi: Option<String>,
|
||||||
pub wlan_ssid: String,
|
pub wlan_ssid: String,
|
||||||
pub wlan_state: String,
|
pub wlan_state: String,
|
||||||
pub wlan_status: String,
|
pub wlan_status: Option<Status>,
|
||||||
pub wlan_traffic: Option<Traffic>,
|
pub wlan_traffic: Option<IfaceTraffic>,
|
||||||
pub flash_name: Option<String>,
|
pub flash_name: Option<String>,
|
||||||
pub flash_msg: Option<String>,
|
pub flash_msg: Option<String>,
|
||||||
// page title for header in navbar
|
// page title for header in navbar
|
||||||
|
@ -31,101 +83,47 @@ pub struct NetworkContext {
|
||||||
|
|
||||||
impl NetworkContext {
|
impl NetworkContext {
|
||||||
pub fn build() -> NetworkContext {
|
pub fn build() -> NetworkContext {
|
||||||
let ap_ip = match network_client::ip("ap0") {
|
let ap_ip = match network::ip("ap0") {
|
||||||
Ok(ip) => ip,
|
Ok(Some(ip)) => ip,
|
||||||
Err(_) => "x.x.x.x".to_string(),
|
_ => "x.x.x.x".to_string(),
|
||||||
};
|
};
|
||||||
let ap_ssid = match network_client::ssid("ap0") {
|
let ap_ssid = match network::ssid("ap0") {
|
||||||
Ok(ssid) => ssid,
|
Ok(Some(ssid)) => ssid,
|
||||||
Err(_) => "Not currently activated".to_string(),
|
_ => "Not currently activated".to_string(),
|
||||||
};
|
};
|
||||||
let ap_state = match network_client::state("ap0") {
|
let ap_state = match network::state("ap0") {
|
||||||
Ok(state) => state,
|
Ok(Some(state)) => state,
|
||||||
Err(_) => "Interface unavailable".to_string(),
|
_ => "Interface unavailable".to_string(),
|
||||||
};
|
};
|
||||||
let ap_traffic = match network_client::traffic("ap0") {
|
let ap_traffic = match network::traffic("ap0") {
|
||||||
Ok(traffic) => {
|
// convert bytes to mb or gb and add appropriate units
|
||||||
let mut t = traffic;
|
Ok(Some(traffic)) => convert_traffic(traffic),
|
||||||
// modify traffic values & assign measurement unit
|
_ => None,
|
||||||
// based on received and transmitted values
|
|
||||||
// if received > 999 MB, convert it to GB
|
|
||||||
if t.received > 1_047_527_424 {
|
|
||||||
t.received /= 1_073_741_824;
|
|
||||||
t.rx_unit = Some("GB".to_string());
|
|
||||||
} else if t.received > 0 {
|
|
||||||
// otherwise, convert it to MB
|
|
||||||
t.received = (t.received / 1024) / 1024;
|
|
||||||
t.rx_unit = Some("MB".to_string());
|
|
||||||
} else {
|
|
||||||
t.received = 0;
|
|
||||||
t.rx_unit = Some("MB".to_string());
|
|
||||||
}
|
|
||||||
|
|
||||||
if t.transmitted > 1_047_527_424 {
|
|
||||||
t.transmitted /= 1_073_741_824;
|
|
||||||
t.tx_unit = Some("GB".to_string());
|
|
||||||
} else if t.transmitted > 0 {
|
|
||||||
t.transmitted = (t.transmitted / 1024) / 1024;
|
|
||||||
t.tx_unit = Some("MB".to_string());
|
|
||||||
} else {
|
|
||||||
t.transmitted = 0;
|
|
||||||
t.tx_unit = Some("MB".to_string());
|
|
||||||
}
|
|
||||||
Some(t)
|
|
||||||
}
|
|
||||||
Err(_) => None,
|
|
||||||
};
|
};
|
||||||
let wlan_ip = match network_client::ip("wlan0") {
|
let wlan_ip = match network::ip("wlan0") {
|
||||||
Ok(ip) => ip,
|
Ok(Some(ip)) => ip,
|
||||||
Err(_) => "x.x.x.x".to_string(),
|
_ => "x.x.x.x".to_string(),
|
||||||
};
|
};
|
||||||
let wlan_rssi = match network_client::rssi_percent("wlan0") {
|
let wlan_rssi = match network::rssi_percent("wlan0") {
|
||||||
Ok(rssi) => Some(rssi),
|
Ok(rssi) => rssi,
|
||||||
Err(_) => None,
|
_ => None,
|
||||||
};
|
};
|
||||||
let wlan_ssid = match network_client::ssid("wlan0") {
|
let wlan_ssid = match network::ssid("wlan0") {
|
||||||
Ok(ssid) => ssid,
|
Ok(Some(ssid)) => ssid,
|
||||||
Err(_) => "Not connected".to_string(),
|
_ => "Not connected".to_string(),
|
||||||
};
|
};
|
||||||
let wlan_state = match network_client::state("wlan0") {
|
let wlan_state = match network::state("wlan0") {
|
||||||
Ok(state) => state,
|
Ok(Some(state)) => state,
|
||||||
Err(_) => "Interface unavailable".to_string(),
|
_ => "Interface unavailable".to_string(),
|
||||||
};
|
};
|
||||||
let wlan_status = match network_client::status("wlan0") {
|
let wlan_status = match network::status("wlan0") {
|
||||||
Ok(status) => status,
|
Ok(status) => status,
|
||||||
Err(_) => "Interface unavailable".to_string(),
|
_ => None,
|
||||||
};
|
};
|
||||||
let wlan_traffic = match network_client::traffic("wlan0") {
|
let wlan_traffic = match network::traffic("wlan0") {
|
||||||
Ok(traffic) => {
|
// convert bytes to mb or gb and add appropriate units
|
||||||
let mut t = traffic;
|
Ok(Some(traffic)) => convert_traffic(traffic),
|
||||||
// modify traffic values & assign measurement unit
|
_ => None,
|
||||||
// based on received and transmitted values
|
|
||||||
// if received > 999 MB, convert it to GB
|
|
||||||
if t.received > 1_047_527_424 {
|
|
||||||
t.received /= 1_073_741_824;
|
|
||||||
t.rx_unit = Some("GB".to_string());
|
|
||||||
} else if t.received > 0 {
|
|
||||||
// otherwise, convert it to MB
|
|
||||||
t.received = (t.received / 1024) / 1024;
|
|
||||||
t.rx_unit = Some("MB".to_string());
|
|
||||||
} else {
|
|
||||||
t.received = 0;
|
|
||||||
t.rx_unit = Some("MB".to_string());
|
|
||||||
}
|
|
||||||
|
|
||||||
if t.transmitted > 1_047_527_424 {
|
|
||||||
t.transmitted /= 1_073_741_824;
|
|
||||||
t.tx_unit = Some("GB".to_string());
|
|
||||||
} else if t.transmitted > 0 {
|
|
||||||
t.transmitted = (t.transmitted / 1024) / 1024;
|
|
||||||
t.tx_unit = Some("MB".to_string());
|
|
||||||
} else {
|
|
||||||
t.transmitted = 0;
|
|
||||||
t.tx_unit = Some("MB".to_string());
|
|
||||||
}
|
|
||||||
Some(t)
|
|
||||||
}
|
|
||||||
Err(_) => None,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
NetworkContext {
|
NetworkContext {
|
||||||
|
|
Loading…
Reference in New Issue