create first-created-at on the fly for stats api (#675)

Author: nikhilsinhaparseable

server/src/handlers/http/logstream.rs

@@ -266,18 +266,6 @@ pub async fn get_stats(req: HttpRequest) -> Result<impl Responder, StreamError>
     if first_event_at_empty(&stream_name) {
         let store = CONFIG.storage().get_object_store();
         if let Ok(Some(first_event_at)) = catalog::get_first_event(store, &stream_name).await {
-            if let Err(err) = CONFIG
-                .storage()
-                .get_object_store()
-                .put_first_event_at(&stream_name, &first_event_at)
-                .await
-            {
-                log::error!(
-                    "Failed to update first_event_at in metadata for stream {:?} {err:?}",
-                    stream_name
-                );
-            }
-
             if let Err(err) =
                 metadata::STREAM_INFO.set_first_event_at(&stream_name, Some(first_event_at))
             {

server/src/storage.rs

@@ -71,6 +71,7 @@ pub struct ObjectStoreFormat {
     #[serde(rename = "created-at")]
     pub created_at: String,
     #[serde(rename = "first-event-at")]
+    #[serde(skip_serializing_if = "Option::is_none")]
     pub first_event_at: Option<String>,
     pub owner: Owner,
     pub permissions: Vec<Permisssion>,

server/src/storage/object_storage.rs

@@ -161,23 +161,6 @@ pub trait ObjectStorage: Sync + 'static {
         self.put_object(&path, to_bytes(&stream_metadata)).await
     }
 
-    async fn put_first_event_at(
-        &self,
-        stream_name: &str,
-        first_event_at: &str,
-    ) -> Result<(), ObjectStorageError> {
-        let path = stream_json_path(stream_name);
-        let stream_metadata = self.get_object(&path).await?;
-        let first_event_ts =
-            serde_json::to_value(first_event_at).expect("first_event_at is perfectly serializable");
-        let mut stream_metadata: serde_json::Value =
-            serde_json::from_slice(&stream_metadata).expect("parseable config is valid json");
-
-        stream_metadata["first-event-at"] = first_event_ts;
-
-        self.put_object(&path, to_bytes(&stream_metadata)).await
-    }
-
     async fn put_metadata(
         &self,
         parseable_metadata: &StorageMetadata,

server/src/storage/retention.rs

@@ -245,18 +245,6 @@ mod action {
         }
 
         if let Ok(Some(first_event_at)) = catalog::get_first_event(store, &stream_name).await {
-            if let Err(err) = CONFIG
-                .storage()
-                .get_object_store()
-                .put_first_event_at(&stream_name, &first_event_at)
-                .await
-            {
-                log::error!(
-                    "Failed to update first_event_at in metadata for stream {:?} {err:?}",
-                    stream_name
-                );
-            }
-
             if let Err(err) =
                 metadata::STREAM_INFO.set_first_event_at(&stream_name, Some(first_event_at))
             {