rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-20 15:00:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: pass unknown encoding in decompression layer (#5300)

Browse Source 
fix: allow pass unknown in decompression layer
This commit is contained in:
shuiyisong
2025-01-06 17:10:56 +08:00
committed by GitHub
parent 6a1ec8db25
commit a56c430db0
2 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/servers/src/http.rs
View File

@@ -747,7 +747,7 @@ impl HttpServer {
.layer(
ServiceBuilder::new()
.layer(HandleErrorLayer::new(handle_error))
.layer(RequestDecompressionLayer::new()),
.layer(RequestDecompressionLayer::new().pass_through_unaccepted(true)),
)
.with_state(log_state)
}
@@ -767,7 +767,7 @@ impl HttpServer {
.layer(
ServiceBuilder::new()
.layer(HandleErrorLayer::new(handle_error))
.layer(RequestDecompressionLayer::new()),
.layer(RequestDecompressionLayer::new().pass_through_unaccepted(true)),
)
.with_state(log_state)
}
@@ -860,7 +860,7 @@ impl HttpServer {
.layer(
ServiceBuilder::new()
.layer(HandleErrorLayer::new(handle_error))
.layer(RequestDecompressionLayer::new()),
.layer(RequestDecompressionLayer::new().pass_through_unaccepted(true)),
)
.route("/ping", routing::get(influxdb_ping))
.route("/health", routing::get(influxdb_health))
@@ -881,7 +881,7 @@ impl HttpServer {
.layer(
ServiceBuilder::new()
.layer(HandleErrorLayer::new(handle_error))
.layer(RequestDecompressionLayer::new()),
.layer(RequestDecompressionLayer::new().pass_through_unaccepted(true)),
)
.with_state(otlp_handler)
}

8
tests-integration/tests/http.rs
View File

@@ -1898,6 +1898,14 @@ pub async fn test_loki_pb_logs(store_type: StorageType) {
HeaderName::from_static("content-type"),
HeaderValue::from_static("application/x-protobuf"),
),
(
HeaderName::from_static("content-encoding"),
HeaderValue::from_static("snappy"),
),
(
HeaderName::from_static("accept-encoding"),
HeaderValue::from_static("identity"),
),
(
HeaderName::from_static(GREPTIME_LOG_TABLE_NAME_HEADER_NAME),
HeaderValue::from_static("loki_table_name"),