feat: Implement auto-refresh code

Cargo.toml

@@ -7,6 +7,7 @@ rust-version = "1.92"
 [dependencies]
 axum = { version = "0.8", features = ["macros"] }
 tokio = { version = "1.0", features = ["full"] }
+tokio-cron-scheduler = "0.15.1"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 reqwest = { version = "0.13", default-features = false, features = ["json", "rustls"] }
@@ -17,3 +18,4 @@ tracing-subscriber = { version = "0.3", features = ["env-filter"] }
 itertools = "0.14"
 thiserror = "2.0"
 anyhow = "1.0"
+polars = { version = "0.45", features = ["lazy", "serde", "json"] }

Dockerfile

@@ -16,6 +16,9 @@ FROM debian:bookworm-slim
 # Set Time Zone to IST
 ENV TZ="Asia/Kolkata"
 
+# Set logging level
+ENV RUST_LOG="info"
+
 # Add required runtime packages
 RUN apt-get update && \
     apt-get install --yes --no-install-recommends \

assets/style.css

@@ -0,0 +1,123 @@
+/* Custom Styling for NetViz on top of Pico CSS v2 */
+
+:root {
+  --pico-font-family: "Inter", system-ui, -apple-system, sans-serif;
+  --pico-primary: #3b82f6;
+  --pico-primary-background: #3b82f6;
+  --pico-primary-hover: #2563eb;
+  --pico-primary-underline: rgba(59, 130, 246, 0.5);
+
+  --pico-border-radius: 0.5rem;
+  --pico-form-element-spacing-vertical: 0.75rem;
+  --pico-form-element-spacing-horizontal: 1rem;
+}
+
+/* Typography */
+@import url("https://fonts.googleapis.com/css2?family=Inter:wght@300;400;500;600;700&display=swap");
+
+body {
+  font-weight: 400;
+}
+
+h1,
+h2,
+h3,
+h4,
+h5,
+h6 {
+  font-weight: 600;
+  margin-bottom: 1rem;
+}
+
+/* Component Overrides & Custom Utilities */
+
+.card {
+  padding: var(--pico-block-spacing-vertical)
+    var(--pico-block-spacing-horizontal);
+  border-radius: var(--pico-border-radius);
+  background: var(--pico-card-background-color);
+  box-shadow: 0 4px 6px -1px rgba(0, 0, 0, 0.1),
+    0 2px 4px -1px rgba(0, 0, 0, 0.06);
+  margin-bottom: var(--pico-block-spacing-vertical);
+  border: 1px solid var(--pico-muted-border-color);
+}
+
+.stat-card {
+  text-align: center;
+}
+
+.stat-value {
+  font-size: 2.5rem;
+  font-weight: 700;
+  color: var(--pico-primary);
+  margin-bottom: 0.5rem;
+}
+
+.stat-label {
+  font-size: 0.875rem;
+  color: var(--pico-muted-color);
+  text-transform: uppercase;
+  letter-spacing: 0.05em;
+}
+
+/* Charts */
+.chart-container {
+  position: relative;
+  height: 400px;
+  width: 100%;
+}
+
+/* Grid adjustments */
+.grid-stats {
+  display: grid;
+  grid-template-columns: repeat(auto-fit, minmax(200px, 1fr));
+  gap: var(--pico-grid-column-gap);
+  margin-bottom: var(--pico-block-spacing-vertical);
+}
+
+/* Navbar */
+nav strong {
+  font-size: 1.25rem;
+  background: -webkit-linear-gradient(45deg, var(--pico-primary), #8b5cf6);
+  background: linear-gradient(45deg, var(--pico-primary), #8b5cf6);
+  -webkit-background-clip: text;
+  background-clip: text;
+  -webkit-text-fill-color: transparent;
+}
+
+/* Badge styled pills */
+.badge {
+  display: inline-block;
+  padding: 0.25em 0.5em;
+  font-size: 0.75em;
+  font-weight: 600;
+  line-height: 1;
+  text-align: center;
+  white-space: nowrap;
+  vertical-align: baseline;
+  border-radius: var(--pico-border-radius);
+  background-color: var(--pico-primary);
+  color: white;
+  margin-right: 0.25rem;
+}
+
+.badge-secondary {
+  background-color: var(--pico-secondary-background);
+  color: var(--pico-color);
+}
+
+/* Animations */
+@keyframes fadeIn {
+  from {
+    opacity: 0;
+    transform: translateY(10px);
+  }
+  to {
+    opacity: 1;
+    transform: translateY(0);
+  }
+}
+
+main > * {
+  animation: fadeIn 0.4s ease-out;
+}

src/error.rs

@@ -24,4 +24,8 @@ pub enum NetVizError {
     /// Unexpected API response format.
     #[error("Invalid API response: {0}")]
     InvalidApiResponse(String),
+
+    /// Polars error.
+    #[error("Polars error: {0}")]
+    Polars(#[from] polars::prelude::PolarsError),
 }

src/fetcher.rs

@@ -3,9 +3,9 @@
 use crate::error::NetVizError;
 use reqwest::header::{HeaderMap, HeaderValue, AUTHORIZATION};
 use serde_json::Value;
-use std::fs;
 use std::path::PathBuf;
 use std::time::Duration;
+use tokio::fs;
 use tracing::{error, info, warn};
 
 /// Base URL for the PeeringDB API.
@@ -32,7 +32,7 @@ const OUTPUT_DIR: &str = "data/peeringdb";
 /// Returns `NetVizError::InvalidApiResponse` if the API index format is unexpected.
 pub async fn fetch_and_save_peeringdb_data() -> Result<(), NetVizError> {
     let output_path = PathBuf::from(OUTPUT_DIR);
-    fs::create_dir_all(&output_path)?;
+    fs::create_dir_all(&output_path).await?;
 
     let client = reqwest::Client::builder()
         .user_agent("NetViz/1.0.0")
@@ -71,7 +71,7 @@ pub async fn fetch_and_save_peeringdb_data() -> Result<(), NetVizError> {
             Ok(resp) => match resp.json::<Value>().await {
                 Ok(data) => match serde_json::to_string_pretty(&data) {
                     Ok(json_data) => {
-                        if let Err(e) = fs::write(&file_path, json_data) {
+                        if let Err(e) = fs::write(&file_path, json_data).await {
                             error!("Failed to write data to {:?}: {}", file_path, e);
                         } else {
                             info!("Successfully saved data to {:?}", file_path);