Skip to content

Commit abf5d82

Browse files
server bug fix
1. delete hottier should be restricted for internal streams 2. POST /logstream/{logstream} should be restricted for query mode
1 parent 5487f54 commit abf5d82

File tree

2 files changed

+13
-0
lines changed

2 files changed

+13
-0
lines changed

server/src/handlers/http/ingest.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -186,6 +186,12 @@ pub async fn post_event(req: HttpRequest, body: Bytes) -> Result<HttpResponse, P
186186
if !STREAM_INFO.stream_exists(&stream_name) {
187187
return Err(PostError::StreamNotFound(stream_name));
188188
}
189+
190+
if CONFIG.parseable.mode == Mode::Query {
191+
return Err(PostError::Invalid(anyhow::anyhow!(
192+
"Ingestion is not allowed in Query mode"
193+
)));
194+
}
189195
flatten_and_push_logs(req, body, stream_name).await?;
190196
Ok(HttpResponse::Ok().finish())
191197
}

server/src/handlers/http/logstream.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1057,6 +1057,13 @@ pub async fn delete_stream_hot_tier(req: HttpRequest) -> Result<impl Responder,
10571057
return Err(StreamError::HotTierNotEnabled(stream_name));
10581058
}
10591059

1060+
if STREAM_INFO.stream_type(&stream_name).unwrap() == Some(StreamType::Internal.to_string()) {
1061+
return Err(StreamError::Custom {
1062+
msg: "Hot tier can not be deleted for internal stream".to_string(),
1063+
status: StatusCode::BAD_REQUEST,
1064+
});
1065+
}
1066+
10601067
if let Some(hot_tier_manager) = HotTierManager::global() {
10611068
hot_tier_manager.delete_hot_tier(&stream_name).await?;
10621069
}

0 commit comments

Comments
 (0)