HasMap optimizationa

This commit is contained in:
Marco De Araujo 2025-12-25 19:19:32 -04:00
parent 6af471ecca
commit ef374723b2
2 changed files with 22 additions and 16 deletions

View file

@ -1,21 +1,33 @@
use std::collections::HashMap;
use crate::core::models::{UnifiedData, UnifiedGroupData, UnifiedMonitorData}; use crate::core::models::{UnifiedData, UnifiedGroupData, UnifiedMonitorData};
use crate::data::heartbeat::model::HeartbeatResponse; use crate::data::{
use crate::data::status_page::model::StatusPageResponse; heartbeat::model::{HeartbeatEntry, HeartbeatResponse, UptimeData},
status_page::model::StatusPageResponse,
};
pub fn unify_data(status_page: &StatusPageResponse, heartbeat: &HeartbeatResponse) -> UnifiedData { pub fn unify_data(status_page: &StatusPageResponse, heartbeat: &HeartbeatResponse) -> UnifiedData {
let mut groups = Vec::new(); let mut groups = Vec::new();
let heartbeat_map: HashMap<u64, Vec<HeartbeatEntry>> = heartbeat
.monitors
.iter()
.map(|m| (m.monitor_id, m.heartbeats.clone()))
.collect();
let uptime_map: HashMap<(u64, u32), UptimeData> = heartbeat
.uptime_data
.iter()
.map(|u| ((u.monitor_id, u.period_hours), u.clone()))
.collect();
for group in &status_page.public_group_list { for group in &status_page.public_group_list {
let mut monitors = Vec::new(); let mut monitors = Vec::new();
for monitor_info in &group.monitor_list { for monitor_info in &group.monitor_list {
let uptime_data = heartbeat.get_uptime(monitor_info.id, 24).cloned(); let uptime_data = uptime_map.get(&(monitor_info.id, 24)).cloned();
let heartbeats = heartbeat_map
let heartbeats = heartbeat .get(&monitor_info.id)
.monitors .cloned()
.iter() .unwrap_or_default();
.find(|m| m.monitor_id == monitor_info.id)
.map(|m| m.heartbeats.clone())
.unwrap_or_else(Vec::new);
monitors.push(UnifiedMonitorData { monitors.push(UnifiedMonitorData {
monitor_info: monitor_info.clone(), monitor_info: monitor_info.clone(),

View file

@ -93,10 +93,4 @@ impl HeartbeatResponse {
.sort_by_key(|u| (u.monitor_id, u.period_hours)); .sort_by_key(|u| (u.monitor_id, u.period_hours));
Ok(()) Ok(())
} }
pub fn get_uptime(&self, monitor_id: u64, period_hours: u32) -> Option<&UptimeData> {
self.uptime_data
.iter()
.find(|u| u.monitor_id == monitor_id && u.period_hours == period_hours)
}
} }