fix: #1189

Author: Devdutt Shenoi

src/handlers/http/logstream.rs

@@ -47,7 +47,16 @@ use tracing::warn;
 
 pub async fn delete(stream_name: Path<String>) -> Result<impl Responder, StreamError> {
     let stream_name = stream_name.into_inner();
-    if !PARSEABLE.streams.contains(&stream_name) {
+    // Error out if stream doesn't exist in memory, or in the case of query node, in storage as well
+    if !PARSEABLE.streams.contains(&stream_name)
+        && PARSEABLE.options.mode == Mode::Query
+        && matches!(
+            PARSEABLE
+                .create_stream_and_schema_from_storage(&stream_name)
+                .await,
+            Ok(true) | Err(_)
+        )
+    {
         return Err(StreamNotFound(stream_name).into());
     }
 

src/parseable/streams.rs

@@ -569,7 +569,7 @@ impl Stream {
     }
 
     pub fn get_retention(&self) -> Option<Retention> {
-        self.metadata.read().expect(LOCK_EXPECT).retention.clone()
+        dbg!(self.metadata.read().expect(LOCK_EXPECT).retention.clone())
     }
 
     pub fn get_schema_version(&self) -> SchemaVersion {
@@ -596,7 +596,7 @@ impl Stream {
     }
 
     pub fn set_retention(&self, retention: Retention) {
-        self.metadata.write().expect(LOCK_EXPECT).retention = Some(retention);
+        self.metadata.write().expect(LOCK_EXPECT).retention = Some(dbg!(retention));
     }
 
     pub fn set_first_event_at(&self, first_event_at: &str) {