Optimize latest guardian health view

flake.nix

@@ -33,7 +33,7 @@
               wasm-pack
               trunk
               nodejs
-              nodePackages.tailwindcss
+              tailwindcss
             ];
           };
           targets = (pkgs.lib.getAttrs
@@ -130,7 +130,7 @@
                 wasm-pack
                 nodejs
                 binaryen
-                nodePackages.tailwindcss
+                tailwindcss
               ];
 
               FMO_API_SERVER = api;

fmo_server/schema/v9.sql

@@ -0,0 +1,34 @@
+-- Optimize latest_guardian_health to avoid aggregating all historical health rows.
+BEGIN;
+
+INSERT INTO schema_version (version)
+VALUES (9);
+
+CREATE OR REPLACE VIEW latest_guardian_health AS
+SELECT
+    gh.federation_id,
+    gh.time,
+    gh.guardian_id,
+    gh.status,
+    gh.block_height,
+    gh.latency_ms
+FROM
+    federations f
+        CROSS JOIN LATERAL (
+            SELECT
+                time
+            FROM
+                guardian_health
+            WHERE
+                federation_id = f.federation_id
+            ORDER BY
+                time DESC
+            LIMIT 1
+        ) latest
+        INNER JOIN
+    guardian_health gh
+    ON
+        gh.federation_id = f.federation_id
+            AND gh.time = latest.time;
+
+COMMIT;

fmo_server/src/federation/observer.rs

@@ -191,6 +191,7 @@ impl FederationObserver {
                 "/schema/v8.sql",
                 FederationObserver::backfill_reprocess_all_sessions
             ),
+            migration!("/schema/v9.sql"),
         ];
 
         for (index, migration) in migrations.iter().enumerate() {