[Management] Surface SRV scores in interface.

Author: davidv1992

nts-pool-management/.sqlx/query-171a166b3904d3adc72871e46be498526c402b598ad4ac3043581eb4e0b0ced6.json

@@ -0,0 +1,16 @@
+-- Add down migration script here
+DROP VIEW time_source_scores;
+CREATE VIEW time_source_scores AS WITH latest_per_monitor AS (
+	SELECT DISTINCT ON (time_source_id, monitor_id, protocol) *
+	FROM monitor_samples
+	ORDER BY time_source_id, monitor_id, protocol, received_at DESC
+),
+best_per_source AS (
+    SELECT DISTINCT ON (time_source_id, protocol) *
+    FROM latest_per_monitor
+    ORDER BY time_source_id, protocol, score DESC
+)
+SELECT ts.*, COALESCE(v4.score, 0) AS "ipv4_score", COALESCE(v6.score, 0) AS "ipv6_score"
+FROM time_sources AS ts
+LEFT JOIN best_per_source AS v4 ON v4.time_source_id = ts.id AND v4.protocol = 'ipv4'
+LEFT JOIN best_per_source AS v6 ON v6.time_source_id = ts.id AND v6.protocol = 'ipv6';

nts-pool-management/.sqlx/query-31d4ce07c537f10111af5dd81bdd7db63d70d3c6f962a3313bf7f9d345d28dde.json

@@ -0,0 +1,18 @@
+-- Add up migration script here
+DROP VIEW time_source_scores;
+CREATE VIEW time_source_scores AS WITH latest_per_monitor AS (
+	SELECT DISTINCT ON (time_source_id, monitor_id, protocol) *
+	FROM monitor_samples
+	ORDER BY time_source_id, monitor_id, protocol, received_at DESC
+),
+best_per_source AS (
+    SELECT DISTINCT ON (time_source_id, protocol) *
+    FROM latest_per_monitor
+    ORDER BY time_source_id, protocol, score DESC
+)
+SELECT ts.*, COALESCE(v4.score, 0) AS "ipv4_score", COALESCE(v6.score, 0) AS "ipv6_score", COALESCE(srv4.score, 0) AS "srv4_score", COALESCE(srv6.score, 0) AS "srv6_score"
+FROM time_sources AS ts
+LEFT JOIN best_per_source AS v4 ON v4.time_source_id = ts.id AND v4.protocol = 'ipv4'
+LEFT JOIN best_per_source AS v6 ON v6.time_source_id = ts.id AND v6.protocol = 'ipv6'
+LEFT JOIN best_per_source AS srv4 ON srv4.time_source_id = ts.id AND srv4.protocol = 'srvv4'
+LEFT JOIN best_per_source AS srv6 ON srv6.time_source_id = ts.id AND srv6.protocol = 'srvv6';

…f3c8ffd46003e473ae2a7f47a9f02c229da.json …ce4475beef54273e55eb6a5d4e4e432108f.jsonnts-pool-management/.sqlx/query-a3296570a3b04d48298edfae5077ef3c8ffd46003e473ae2a7f47a9f02c229da.json renamed to nts-pool-management/.sqlx/query-44206d6268686fd775902f78e6a7bce4475beef54273e55eb6a5d4e4e432108f.json nts-pool-management/.sqlx/query-a3296570a3b04d48298edfae5077ef3c8ffd46003e473ae2a7f47a9f02c229da.json renamed to nts-pool-management/.sqlx/query-44206d6268686fd775902f78e6a7bce4475beef54273e55eb6a5d4e4e432108f.json

@@ -42,6 +42,8 @@ pub struct TimeSource {
     pub weight: i32,
     pub ipv4_score: f64,
     pub ipv6_score: f64,
+    pub srv4_score: f64,
+    pub srv6_score: f64,
 }
 
 #[derive(Debug, Deserialize, Clone, PartialEq, Eq)]
@@ -373,7 +375,9 @@ pub async fn details(
                 base_secret_index AS "base_secret_index!",
                 weight AS "weight!",
                 ipv4_score AS "ipv4_score!: _",
-                ipv6_score AS "ipv6_score!: _"
+                ipv6_score AS "ipv6_score!: _",
+                srv4_score AS "srv4_score!: _",
+                srv6_score AS "srv6_score!: _"
             FROM time_source_scores
             WHERE id = $1 AND deleted = false;
         "#,
@@ -400,7 +404,9 @@ pub async fn by_user(
                 base_secret_index AS "base_secret_index!",
                 weight AS "weight!",
                 ipv4_score AS "ipv4_score!: _",
-                ipv6_score AS "ipv6_score!: _"
+                ipv6_score AS "ipv6_score!: _",
+                srv4_score AS "srv4_score!: _",
+                srv6_score AS "srv6_score!: _"
             FROM time_source_scores
             WHERE owner = $1 AND deleted = false;
         "#,
@@ -424,7 +430,9 @@ pub async fn list(conn: impl DbConnLike<'_>) -> Result<Vec<TimeSource>, sqlx::Er
                 base_secret_index AS "base_secret_index!",
                 weight AS "weight!",
                 ipv4_score AS "ipv4_score!: _",
-                ipv6_score AS "ipv6_score!: _"
+                ipv6_score AS "ipv6_score!: _",
+                srv4_score AS "srv4_score!: _",
+                srv6_score AS "srv6_score!: _"
             FROM time_source_scores
             WHERE deleted = false;
         "#,
@@ -456,7 +464,9 @@ pub async fn list_with_owner_names(
                     ts.base_secret_index,
                     ts.weight,
                     ts.ipv4_score,
-                    ts.ipv6_score
+                    ts.ipv6_score,
+                    ts.srv4_score,
+                    ts.srv6_score
                 ) AS "time_source!: TimeSource",
                 u.email AS "user_email!"
             FROM time_source_scores AS ts