Skip to content

Commit d64b8a8

Browse files
author
Devdutt Shenoi
committed
refactor: work without request body
1 parent d9d2235 commit d64b8a8

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

src/handlers/http/prism_logstream.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,11 +35,15 @@ pub async fn get_info(stream_name: Path<String>) -> Result<impl Responder, Prism
3535

3636
/// A combination of /stats, /retention, /hottier, /info, /counts and /query
3737
pub async fn post_datasets(
38-
Json(prism_req): Json<PrismDatasetRequest>,
38+
dataset_req: Option<Json<PrismDatasetRequest>>,
3939
req: HttpRequest,
4040
) -> Result<impl Responder, PrismLogstreamError> {
4141
let session_key = extract_session_key_from_req(&req)?;
42-
let dataset = prism_req.get_datasets(session_key).await?;
42+
let dataset = dataset_req
43+
.map(|Json(r)| r)
44+
.unwrap_or_default()
45+
.get_datasets(session_key)
46+
.await?;
4347

4448
Ok(web::Json(dataset))
4549
}

src/prism/logstream/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ pub struct PrismDatasetResponse {
215215

216216
/// Request parameters for retrieving Prism dataset information.
217217
/// Defines which streams to query
218-
#[derive(Deserialize)]
218+
#[derive(Deserialize, Default)]
219219
#[serde(rename_all = "camelCase")]
220220
pub struct PrismDatasetRequest {
221221
/// List of stream names to query

0 commit comments

Comments
 (0)