Show last collection end time

Author: Mark-Simulacrum

database/src/pool.rs

@@ -1,5 +1,6 @@
 use crate::{ArtifactId, ArtifactIdNumber};
 use crate::{Cache, CollectionId, Index, Profile, QueryDatum, QueuedCommit, Step};
+use chrono::{DateTime, Utc};
 use hashbrown::HashMap;
 use std::sync::{Arc, Mutex};
 use std::time::Duration;
@@ -74,6 +75,8 @@ pub trait Connection: Send + Sync {
     async fn in_progress_artifacts(&self) -> Vec<ArtifactId>;
 
     async fn in_progress_steps(&self, aid: &ArtifactId) -> Vec<Step>;
+
+    async fn last_end_time(&self) -> Option<DateTime<Utc>>;
 }
 
 #[async_trait::async_trait]

database/src/pool/postgres.rs

@@ -932,4 +932,17 @@ where
             })
             .collect()
     }
+    async fn last_end_time(&self) -> Option<DateTime<Utc>> {
+        self.conn()
+            .query_opt(
+                "select date_recorded + (duration || 'seconds')::interval \
+                from artifact_collection_duration \
+                order by date_recorded desc \
+                limit 1;",
+                &[],
+            )
+            .await
+            .unwrap()
+            .map(|r| r.get(0))
+    }
 }

database/src/pool/sqlite.rs

@@ -1,7 +1,7 @@
 use crate::pool::{Connection, ConnectionManager, ManagedConnection, Transaction};
 use crate::{ArtifactId, CollectionId, Commit, Crate, Date, Profile};
 use crate::{ArtifactIdNumber, Index, QueryDatum, QueuedCommit};
-use chrono::{TimeZone, Utc};
+use chrono::{DateTime, TimeZone, Utc};
 use hashbrown::HashMap;
 use rusqlite::params;
 use rusqlite::OptionalExtension;
@@ -754,4 +754,17 @@ impl Connection for SqliteConnection {
             .map(|r| r.unwrap())
             .collect()
     }
+    async fn last_end_time(&self) -> Option<DateTime<Utc>> {
+        self.raw_ref()
+            .query_row(
+                "select date_recorded + duration \
+                from artifact_collection_duration \
+                order by date_recorded desc \
+                limit 1;",
+                params![],
+                |r| Ok(Utc.timestamp(r.get(0)?, 0)),
+            )
+            .optional()
+            .unwrap()
+    }
 }

site/src/api.rs

@@ -194,6 +194,8 @@ pub mod status {
         pub benchmarks: Vec<BenchmarkStatus>,
         pub missing: Vec<(Commit, MissingReason)>,
         pub current: Option<CurrentState>,
+        // None if no recent end, otherwise seconds since epoch
+        pub most_recent_end: Option<i64>,
     }
 }
 

site/src/server.rs

@@ -307,6 +307,7 @@ pub async fn handle_status_page(data: Arc<InputData>) -> status::Response {
         benchmarks: benchmark_state,
         missing,
         current,
+        most_recent_end: conn.last_end_time().await.map(|d| d.timestamp()),
     }
 }
 

site/static/status.html

@@ -32,7 +32,7 @@
 
     function populate_data(data) {
         let state_div = document.querySelector("#benchmark-state");
-        {
+        if (data.last_commit) {
             let element = document.createElement("p");
             element.innerHTML = `SHA: ${data.last_commit.sha}, date: ${data.last_commit.date}`;
             state_div.appendChild(element);
@@ -109,7 +109,14 @@
             missing_div.appendChild(table);
         } else {
             let element = document.createElement("p");
-            element.innerHTML = `(Current work is not currently displayed; this is being worked on)`;
+            if (data.most_recent_end) {
+                let end = new Date(data.most_recent_end * 1000);
+                element.innerHTML = `No current collection in progress. Last one
+                    finished at ${end.toLocaleString()} local time,
+                    ${format_duration(Math.trunc((new Date() - end)/1000))} ago.`;
+            } else {
+                element.innerHTML = "No current collection in progress.";
+            }
             missing_div.appendChild(element);
         }
         {
@@ -161,9 +168,11 @@
         let hours = Math.trunc(mins / 60);
         mins -= hours*60;
 
-        let s = `${mins < 10 ? "&nbsp;" + mins : mins}m${secs < 10 ? "0" + secs : secs}s`;
+        let s = "";
         if (hours > 0) {
-            s = `${hours}h ${s}`;
+            s = `${hours}h${mins < 10 ? "0" + mins : mins}m${secs < 10 ? "0" + secs : secs}s`;
+        } else {
+            s = `${mins < 10 ? " " + mins : mins}m${secs < 10 ? "0" + secs : secs}s`;
         }
         return s;
     }