Use stream metadata to check if stream exists (#420)

nitisht · web-flow · commit cb8f25774b03 · 2023-05-22T23:43:37.000+05:30
diff --git a/server/src/handlers/http/logstream.rs b/server/src/handlers/http/logstream.rs
@@ -39,8 +39,8 @@ pub async fn delete(req: HttpRequest) -> Result<impl Responder, StreamError> {
 
     let objectstore = CONFIG.storage().get_object_store();
 
-    if !objectstore.stream_exists(&stream_name).await? {
-        return Err(StreamError::StreamNotFound(stream_name.to_string()));
+    if !metadata::STREAM_INFO.stream_exists(&stream_name) {
+        return Err(StreamError::StreamNotFound(stream_name));
     }
 
     objectstore.delete_stream(&stream_name).await?;

Original file line number	Diff line number	Diff line change
`@@ -39,8 +39,8 @@ pub async fn delete(req: HttpRequest) -> Result<impl Responder, StreamError> {`
`39`	`39`
`40`	`40`	`let objectstore = CONFIG.storage().get_object_store();`
`41`	`41`
`42`		`- if !objectstore.stream_exists(&stream_name).await? {`
`43`		`- return Err(StreamError::StreamNotFound(stream_name.to_string()));`
	`42`	`+ if !metadata::STREAM_INFO.stream_exists(&stream_name) {`
	`43`	`+ return Err(StreamError::StreamNotFound(stream_name));`
`44`	`44`	`}`
`45`	`45`
`46`	`46`	`objectstore.delete_stream(&stream_name).await?;`