From e880a6495238ac15d0194d303af1d9a38ee36fdb Mon Sep 17 00:00:00 2001 From: Satyam Singh Date: Fri, 5 Aug 2022 20:12:18 +0530 Subject: [PATCH 1/2] Fix syntax error in logstream put handler --- server/src/handlers/logstream.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/handlers/logstream.rs b/server/src/handlers/logstream.rs index 84c007f37..a8a8d52ec 100644 --- a/server/src/handlers/logstream.rs +++ b/server/src/handlers/logstream.rs @@ -178,7 +178,7 @@ pub async fn put(req: HttpRequest) -> HttpResponse { // Fail if unable to create log stream on object store backend if let Err(e) = s3.create_stream(&stream_name).await { // delete the stream from metadata because we couldn't create it on object store backend - _ = metadata::STREAM_INFO.delete_stream(stream_name.to_string()); + metadata::STREAM_INFO.delete_stream(stream_name.to_string()).unwrap(); return response::ServerResponse { msg: format!( "failed to create log stream {} due to err: {}", From 83d619a9831ebead88f7cd4e573178fc5690e5e3 Mon Sep 17 00:00:00 2001 From: Satyam Singh Date: Fri, 5 Aug 2022 20:55:29 +0530 Subject: [PATCH 2/2] format code according to rustfmt --- server/src/handlers/logstream.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/server/src/handlers/logstream.rs b/server/src/handlers/logstream.rs index a8a8d52ec..9f2ff9883 100644 --- a/server/src/handlers/logstream.rs +++ b/server/src/handlers/logstream.rs @@ -178,7 +178,9 @@ pub async fn put(req: HttpRequest) -> HttpResponse { // Fail if unable to create log stream on object store backend if let Err(e) = s3.create_stream(&stream_name).await { // delete the stream from metadata because we couldn't create it on object store backend - metadata::STREAM_INFO.delete_stream(stream_name.to_string()).unwrap(); + metadata::STREAM_INFO + .delete_stream(stream_name.to_string()) + .unwrap(); return response::ServerResponse { msg: format!( "failed to create log stream {} due to err: {}",