add /api/stats/versions

Author: 0x7d8

.sqlx/query-46c6123ada38b3b7b0f8dc9cf6dbe3a8111f5af189a55179d15163c871e4a67a.json

@@ -1,6 +1,6 @@
 [package]
 name = "api"
-version = "2.1.6"
+version = "2.2.0"
 edition = "2024"
 
 [dependencies]

Cargo.lock

@@ -0,0 +1,2 @@
+DROP INDEX IF EXISTS "telemetry_data_data_idx";
+CREATE INDEX IF NOT EXISTS "telemetry_data_data_idx" ON "telemetry_data" USING gin ("data");

Cargo.toml

@@ -1,7 +1,7 @@
 use super::State;
 use utoipa_axum::{router::OpenApiRouter, routes};
 
-mod index {
+mod get {
     use crate::routes::GetState;
     use serde::Serialize;
     use utoipa::ToSchema;
@@ -28,6 +28,6 @@ mod index {
 
 pub fn router(state: &State) -> OpenApiRouter<State> {
     OpenApiRouter::new()
-        .routes(routes!(index::route))
+        .routes(routes!(get::route))
         .with_state(state.clone())
 }

migrations/0006_sail_the_ship.sql

@@ -1,7 +1,7 @@
 use super::State;
 use utoipa_axum::{router::OpenApiRouter, routes};
 
-mod index {
+mod get {
     use crate::routes::GetState;
     use serde::{Deserialize, Serialize};
     use std::collections::BTreeMap;
@@ -72,6 +72,6 @@ mod index {
 
 pub fn router(state: &State) -> OpenApiRouter<State> {
     OpenApiRouter::new()
-        .routes(routes!(index::route))
+        .routes(routes!(get::route))
         .with_state(state.clone())
 }

src/routes/latest.rs

@@ -1,5 +1,6 @@
 mod flags;
 mod panels;
+mod versions;
 
 use super::State;
 use utoipa_axum::router::OpenApiRouter;
@@ -8,5 +9,6 @@ pub fn router(state: &State) -> OpenApiRouter<State> {
     OpenApiRouter::new()
         .nest("/flags", flags::router(state))
         .nest("/panels", panels::router(state))
+        .nest("/versions", versions::router(state))
         .with_state(state.clone())
 }

src/routes/stats/flags.rs

@@ -1,7 +1,7 @@
 use super::State;
 use utoipa_axum::{router::OpenApiRouter, routes};
 
-mod index {
+mod get {
     use crate::routes::GetState;
     use serde::{Deserialize, Serialize};
     use utoipa::ToSchema;
@@ -72,6 +72,6 @@ mod index {
 
 pub fn router(state: &State) -> OpenApiRouter<State> {
     OpenApiRouter::new()
-        .routes(routes!(index::route))
+        .routes(routes!(get::route))
         .with_state(state.clone())
 }

src/routes/stats/mod.rs

@@ -0,0 +1,69 @@
+use super::State;
+use utoipa_axum::{router::OpenApiRouter, routes};
+
+mod get {
+    use crate::routes::GetState;
+    use indexmap::IndexMap;
+
+    #[utoipa::path(get, path = "/", responses(
+        (status = OK, body = inline(HashMap<String, f64>)),
+    ))]
+    pub async fn route(state: GetState) -> axum::Json<serde_json::Value> {
+        let versions = state
+            .cache
+            .cached("stats::versions", 3600, || async {
+                let mut versions: IndexMap<String, f64> = IndexMap::new();
+
+                let data = sqlx::query!(
+                    r#"
+                    SELECT version, percentage
+                    FROM (
+                        SELECT
+                            data->'blueprint'->>'version' AS version,
+                            (COUNT(*) * 100.0 / (
+                                SELECT COUNT(*)
+                                FROM telemetry_data
+                                WHERE id IN (
+                                    SELECT latest_telemetry_data_id
+                                    FROM telemetry_panels_with_latest
+                                )
+                                AND created > NOW() - INTERVAL '2 days'
+                            ))::float8 AS percentage
+                        FROM telemetry_data
+                        WHERE
+                            id IN (
+                                SELECT latest_telemetry_data_id
+                                FROM telemetry_panels_with_latest
+                            )
+                            AND created > NOW() - INTERVAL '2 days'
+                        GROUP BY version
+                    ) x
+                    WHERE x.version LIKE 'beta-202_-__'
+                    ORDER BY x.percentage DESC
+                    "#,
+                )
+                .fetch_all(state.database.read())
+                .await
+                .unwrap();
+
+                for row in data {
+                    versions.insert(
+                        row.version.unwrap(),
+                        (row.percentage.unwrap() * 100.0).round() / 100.0,
+                    );
+                }
+
+                Ok(versions)
+            })
+            .await
+            .unwrap();
+
+        axum::Json(serde_json::to_value(versions).unwrap())
+    }
+}
+
+pub fn router(state: &State) -> OpenApiRouter<State> {
+    OpenApiRouter::new()
+        .routes(routes!(get::route))
+        .with_state(state.clone())
+}