Get info from status page json
This commit is contained in:
parent
d024280878
commit
dbe196f388
8 changed files with 113 additions and 30 deletions
|
|
@ -1,4 +1,4 @@
|
|||
pub mod parser;
|
||||
pub mod model;
|
||||
pub use parser::{format_duration, parse_response,status_to_string};
|
||||
pub mod parser;
|
||||
pub use model::HeartbeatResponse;
|
||||
pub use parser::parse_response;
|
||||
|
|
|
|||
|
|
@ -1,28 +1,11 @@
|
|||
use anyhow::{Context, Ok, Result};
|
||||
use std::collections::HashMap;
|
||||
use crate::i18n::t;
|
||||
use super::HeartbeatResponse;
|
||||
use crate::i18n::t;
|
||||
use anyhow::{Context, Ok, Result};
|
||||
|
||||
pub fn parse_response(json_text: &str) -> Result<HeartbeatResponse> {
|
||||
let mut response: HeartbeatResponse = serde_json::from_str(json_text)
|
||||
.with_context(|| t("invalid-json-heartbeat"))?;
|
||||
let mut response: HeartbeatResponse =
|
||||
serde_json::from_str(json_text).with_context(|| t("invalid-json-heartbeat"))?;
|
||||
|
||||
response.process()?;
|
||||
Ok(response)
|
||||
}
|
||||
|
||||
pub fn status_to_string(status: u8) -> String {
|
||||
match status {
|
||||
1 => t("up"),
|
||||
2 => t("down"),
|
||||
_ => t("unknown"),
|
||||
}
|
||||
}
|
||||
|
||||
pub fn format_duration(duration_ms:Option<u64>) -> String {
|
||||
match duration_ms {
|
||||
Some(ms) if ms < 1000 => format!("{}ms", ms),
|
||||
Some(ms) => format!("{:.1}s", ms),
|
||||
None => "N/A".to_string(),
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -3,3 +3,5 @@ missing_api_key = ❌ API key not provided. Use --api-key or environment variabl
|
|||
success = ✅ Metrics received successfully!
|
||||
metrics_preview = 📋 First 200 characters of metrics:
|
||||
Response = Response
|
||||
invalid-json-status-page = ❌ Error parssing status page JSON
|
||||
invalid-json-heartbeat = ❌ Error parssing heartbeat JSON
|
||||
|
|
|
|||
|
|
@ -3,3 +3,5 @@ metrics_preview = 📋 Primeiras 200 caracteres das métricas:
|
|||
missing_api_key = ❌ API key não fornecida. Use --api-key ou a variável de ambiente UPTIME_API_KEY
|
||||
missing_url = ❌ URL não fornecida. Use --url ou a variável de ambiente UPTIME_URL
|
||||
Response = Resposta
|
||||
invalid-json-status-page = ❌ Falha ao parsear JSON do status page
|
||||
invalid-json-heartbeat = ❌ Falha ao parsear JSON do heartbeat
|
||||
|
|
|
|||
37
src/main.rs
37
src/main.rs
|
|
@ -5,6 +5,7 @@ use std::result::Result::Ok;
|
|||
mod i18n;
|
||||
use i18n::{init_locales, t};
|
||||
mod heartbeat;
|
||||
mod status_page;
|
||||
|
||||
#[derive(Debug, Parser)]
|
||||
#[command(author, version, about)]
|
||||
|
|
@ -19,27 +20,49 @@ struct Args {
|
|||
fn main() -> Result<()> {
|
||||
init_locales()?;
|
||||
let args = Args::parse();
|
||||
let base_url = args.base_url.trim_end_matches("/");
|
||||
|
||||
let heartbeat_url = format!(
|
||||
"{}/api/status-page/heartbeat/{}",
|
||||
args.base_url.trim_end_matches("/"),
|
||||
base_url,
|
||||
args.slug
|
||||
);
|
||||
let status_page_url = format!(
|
||||
"{}/api/status-page/{}",
|
||||
base_url,
|
||||
args.slug
|
||||
);
|
||||
|
||||
let client = Client::new();
|
||||
|
||||
println!("{}", heartbeat_url);
|
||||
println!("Heartbeat URL: {}", heartbeat_url);
|
||||
|
||||
let response = client.get(heartbeat_url).send()?;
|
||||
let heartbeat_response = client.get(heartbeat_url).send()?;
|
||||
|
||||
if response.status().is_success() {
|
||||
let json_text = response.text()?;
|
||||
if heartbeat_response.status().is_success() {
|
||||
let json_text = heartbeat_response.text()?;
|
||||
match heartbeat::parse_response(&json_text) {
|
||||
Ok(data) => println!("moises: {}", data.uptime_data[0].get_perc_formated()),
|
||||
Err(e) => println!("{}", e),
|
||||
}
|
||||
} else {
|
||||
println!("{}", response.status());
|
||||
println!("{}: {}", t("Response"), response.text()?);
|
||||
println!("{}", heartbeat_response.status());
|
||||
println!("{}: {}", t("Response"), heartbeat_response.text()?);
|
||||
}
|
||||
|
||||
println!("Status Page URL: {}", status_page_url);
|
||||
|
||||
let status_page_response = client.get(status_page_url).send()?;
|
||||
|
||||
if status_page_response.status().is_success() {
|
||||
let json_text = status_page_response.text()?;
|
||||
match status_page::parse_response(&json_text) {
|
||||
Ok(data) => println!("moises: {}", data.config.title),
|
||||
Err(e) => println!("{}", e),
|
||||
}
|
||||
} else {
|
||||
println!("{}", status_page_response.status());
|
||||
println!("{}: {}", t("Response"), status_page_response.text()?);
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
|
|
|
|||
4
src/status_page/mod.rs
Normal file
4
src/status_page/mod.rs
Normal file
|
|
@ -0,0 +1,4 @@
|
|||
pub mod model;
|
||||
pub mod parser;
|
||||
pub use model::StatusPageResponse;
|
||||
pub use parser::parse_response;
|
||||
61
src/status_page/model.rs
Normal file
61
src/status_page/model.rs
Normal file
|
|
@ -0,0 +1,61 @@
|
|||
use std::collections::HashMap;
|
||||
|
||||
use anyhow::{Context, Result};
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
use crate::i18n::t;
|
||||
|
||||
#[derive(Debug, Clone, Deserialize, Serialize)]
|
||||
pub struct StatusPageConfig {
|
||||
pub slug: String,
|
||||
pub title: String,
|
||||
#[serde(default)]
|
||||
pub description: Option<String>,
|
||||
pub icon: String,
|
||||
#[serde(rename = "autoRefreshInterval")]
|
||||
pub auto_refresh_interval: u32,
|
||||
pub theme: String,
|
||||
pub published: bool,
|
||||
#[serde(rename = "showTags")]
|
||||
pub show_tags: bool,
|
||||
#[serde(rename = "customCSS")]
|
||||
pub custon_css: String,
|
||||
#[serde(rename = "footerText", default)]
|
||||
pub footer_text: Option<String>,
|
||||
#[serde(rename = "showPoweredBy")]
|
||||
pub show_powered_by: bool,
|
||||
#[serde(rename = "googleAnalyticsId", default)]
|
||||
pub google_analytics_id: Option<String>,
|
||||
#[serde(rename = "showCertificateExpiry")]
|
||||
pub show_certificate_expiry: bool,
|
||||
}
|
||||
|
||||
#[derive(Debug, Clone, Deserialize, Serialize)]
|
||||
pub struct MonitorInfo {
|
||||
pub id: u64,
|
||||
pub name: String,
|
||||
#[serde(rename = "sendUrl")]
|
||||
pub send_url: u8,
|
||||
#[serde(rename = "type")]
|
||||
pub monitor_type: String,
|
||||
}
|
||||
|
||||
#[derive(Debug, Clone, Deserialize, Serialize)]
|
||||
pub struct StatusPageGroup {
|
||||
pub id: u64,
|
||||
pub name: String,
|
||||
pub weight: u32,
|
||||
#[serde(rename = "monitorList")]
|
||||
pub monitor_list: Vec<MonitorInfo>,
|
||||
}
|
||||
|
||||
#[derive(Debug, Clone, Deserialize, Serialize)]
|
||||
pub struct StatusPageResponse {
|
||||
pub config: StatusPageConfig,
|
||||
#[serde(skip, default)]
|
||||
pub incident: Option<String>,
|
||||
#[serde(rename = "publicGroupList")]
|
||||
pub public_group_list: Vec<StatusPageGroup>,
|
||||
#[serde(rename = "maintenanceList", skip)]
|
||||
pub maintenance_list: Vec<String>,
|
||||
}
|
||||
8
src/status_page/parser.rs
Normal file
8
src/status_page/parser.rs
Normal file
|
|
@ -0,0 +1,8 @@
|
|||
use super::model::StatusPageResponse;
|
||||
use crate::i18n::t;
|
||||
use anyhow::{Context, Ok, Result};
|
||||
|
||||
pub fn parse_response(json_text: &str) -> Result<StatusPageResponse> {
|
||||
let mut response: StatusPageResponse = serde_json::from_str(json_text)?; //.with_context(|| t("invalid-json-status-page"))?;
|
||||
Ok(response)
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue