BlueprintFramework · Apr 11, 2025
diff --git a/‎Cargo.lock
+18-7 b/‎Cargo.lock
+18-7
diff --git a/‎Cargo.toml
+5-2 b/‎Cargo.toml
+5-2
diff --git a/‎migrations/0008_great_freedom.sql
+53 b/‎migrations/0008_great_freedom.sql
+53
diff --git a/‎src/database.rs
+25 b/‎src/database.rs
+25
diff --git a/‎src/env.rs
+6 b/‎src/env.rs
+6
diff --git a/‎src/main.rs
+5-4 b/‎src/main.rs
+5-4
@@ -1,8 +1,11 @@
 [package]
 name = "api"
-version = "2.2.2"
+version = "2.3.0"
 edition = "2024"
 
+[profile.dev]
+debug = false
+
 [profile.release]
 debug = "limited"
 
@@ -14,7 +17,7 @@ dotenvy = "0.15.7"
 rustis = "0.13.3"
 serde = { version = "1.0.218", features = ["derive"] }
 serde_json = { version = "1.0.140", features = ["preserve_order"] }
-tokio = { version = "1.43.0", features = ["rt-multi-thread"] }
+tokio = { version = "1.43.0", features = ["full"] }
 utoipa = { version = "5.3.1", features = ["axum_extras", "preserve_order", "chrono"] }
 utoipa-axum = "0.2.0"
 chrono = { version = "0.4.40", features = ["serde"] }
 
@@ -0,0 +1,53 @@
+CREATE MATERIALIZED VIEW mv_extension_stats AS
+SELECT 
+	extensions.id,
+	jsonb_build_object(
+		'panels', (
+			SELECT COUNT(*)
+			FROM (
+				SELECT jsonb_array_elements(data->'blueprint'->'extensions') as ext 
+				FROM telemetry_data 
+				WHERE id IN (
+					SELECT latest_telemetry_data_id 
+					FROM telemetry_panels_with_latest
+				)
+				AND created > NOW() - INTERVAL '2 days'
+			) subq
+			WHERE subq.ext->>'identifier' = extensions.identifier
+		)
+	) stats,
+	(
+		SELECT jsonb_agg(
+			jsonb_build_object(
+				'version', version,
+				'percentage', percentage
+			)
+			ORDER BY percentage DESC
+		)
+		FROM (
+			SELECT
+				ext->>'version' AS version,
+				(COUNT(*) * 100.0 / SUM(COUNT(*)) OVER ())::float8 AS percentage
+			FROM
+				(
+					SELECT jsonb_array_elements(data->'blueprint'->'extensions') AS ext
+					FROM telemetry_data
+					WHERE
+						id IN (
+							SELECT telemetry_data.id
+							FROM telemetry_panels_with_latest
+							WHERE latest_telemetry_data_id = (
+								SELECT latest_telemetry_data_id
+								FROM telemetry_panels_with_latest
+								ORDER BY created DESC
+								LIMIT 1
+							)
+						)
+						AND created > NOW() - INTERVAL '2 days'
+				) AS subq
+			WHERE subq.ext->>'identifier' = extensions.identifier
+			GROUP BY subq.ext->>'version'
+		) version_data
+	) versions
+FROM extensions;
+CREATE UNIQUE INDEX mv_extension_stats_id_idx ON mv_extension_stats (id);
@@ -78,6 +78,31 @@ impl Database {
             });
         }
 
+        if env.database_refresh {
+            let writer = instance.write.clone();
+            tokio::spawn(async move {
+                loop {
+                    tokio::time::sleep(std::time::Duration::from_secs(60 * 30)).await;
+
+                    let start = std::time::Instant::now();
+
+                    sqlx::query("REFRESH MATERIALIZED VIEW mv_extension_stats")
+                        .execute(&writer)
+                        .await
+                        .unwrap();
+
+                    crate::logger::log(
+                        crate::logger::LoggerLevel::Info,
+                        format!(
+                            "{} views refreshed {}",
+                            "database".bright_cyan(),
+                            format!("({}ms)", start.elapsed().as_millis()).bright_black()
+                        ),
+                    );
+                }
+            });
+        }
+
         instance
     }
 
 
@@ -14,6 +14,7 @@ pub struct Env {
 
     pub sentry_url: Option<String>,
     pub database_migrate: bool,
+    pub database_refresh: bool,
     pub database_url: String,
     pub database_url_primary: Option<String>,
 
@@ -75,6 +76,11 @@ impl Env {
                 .trim_matches('"')
                 .parse()
                 .unwrap(),
+            database_refresh: std::env::var("DATABASE_REFRESH")
+                .unwrap_or("false".to_string())
+                .trim_matches('"')
+                .parse()
+                .unwrap(),
             database_url: std::env::var("DATABASE_URL")
                 .expect("DATABASE_URL is required")
                 .trim_matches('"')
 
@@ -39,13 +39,14 @@ fn handle_panic(_err: Box<dyn std::any::Any + Send + 'static>) -> Response<Body>
         "a request panic has occurred".bright_red().to_string(),
     );
 
-    let body = routes::ApiError::new(&["internal server error"]);
-    let body = serde_json::to_string(&body).unwrap();
-
     Response::builder()
         .status(StatusCode::INTERNAL_SERVER_ERROR)
         .header("Content-Type", "application/json")
-        .body(Body::from(body))
+        .body(Body::from(
+            routes::ApiError::new(&["internal server error"])
+                .to_value()
+                .to_string(),
+        ))
         .unwrap()
 }