fix: avoid removal of retention configuration while updating snapshot (#661)

fixes #654

Author: gurjotkaur20

server/src/storage.rs

@@ -37,6 +37,7 @@ pub use store_metadata::{
     put_remote_metadata, put_staging_metadata, resolve_parseable_metadata, StorageMetadata,
 };
 
+use self::retention::Retention;
 pub use self::staging::StorageDir;
 
 /// local sync interval to move data.records to /tmp dir of that stream.
@@ -76,6 +77,7 @@ pub struct ObjectStoreFormat {
     pub snapshot: Snapshot,
     #[serde(default)]
     pub cache_enabled: bool,
+    pub retention: Retention,
 }
 
 #[derive(Debug, Clone, PartialEq, Eq, serde::Serialize, serde::Deserialize)]
@@ -118,6 +120,7 @@ impl Default for ObjectStoreFormat {
             stats: Stats::default(),
             snapshot: Snapshot::default(),
             cache_enabled: false,
+            retention: Retention::new(),
         }
     }
 }

server/src/storage/retention.rs

@@ -128,6 +128,12 @@ struct TaskView {
     duration: String,
 }
 
+impl Retention {
+    pub fn new() -> Self {
+        Self { tasks: Vec::new() }
+    }
+}
+
 impl TryFrom<Vec<TaskView>> for Retention {
     type Error = String;