Compare commits

...

5 Commits

Author SHA1 Message Date
Joel Wurtz 756f60274a
Merge bb2c6cebfd into 219b988300 2025-11-11 20:21:31 +09:00
dependabot[bot] 219b988300
build(deps): bump taiki-e/install-action from 2.62.46 to 2.62.49 (#3823)
Bumps [taiki-e/install-action](https://github.com/taiki-e/install-action) from 2.62.46 to 2.62.49.
- [Release notes](https://github.com/taiki-e/install-action/releases)
- [Changelog](https://github.com/taiki-e/install-action/blob/main/CHANGELOG.md)
- [Commits](f535147c22...44c6d64aa6)

---
updated-dependencies:
- dependency-name: taiki-e/install-action
  dependency-version: 2.62.49
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2025-11-10 01:54:15 +00:00
dependabot[bot] 9cf3521390
build(deps): bump quote from 1.0.41 to 1.0.42 (#3825)
Bumps [quote](https://github.com/dtolnay/quote) from 1.0.41 to 1.0.42.
- [Release notes](https://github.com/dtolnay/quote/releases)
- [Commits](https://github.com/dtolnay/quote/compare/1.0.41...1.0.42)

---
updated-dependencies:
- dependency-name: quote
  dependency-version: 1.0.42
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2025-11-10 01:53:48 +00:00
Rob Ede bb2c6cebfd
Merge branch 'master' into feat/encoding-as-extension 2025-05-10 00:52:46 +01:00
Joel Wurtz 0cb453e499
feat(encoding): use an extension for encoding, which allow a specific handler to disable compression if needed 2024-12-16 14:00:29 +01:00
6 changed files with 38 additions and 17 deletions

View File

@ -49,7 +49,7 @@ jobs:
toolchain: ${{ matrix.version.version }} toolchain: ${{ matrix.version.version }}
- name: Install just, cargo-hack, cargo-nextest, cargo-ci-cache-clean - name: Install just, cargo-hack, cargo-nextest, cargo-ci-cache-clean
uses: taiki-e/install-action@f535147c22906d77695e11cb199e764aa610a4fc # v2.62.46 uses: taiki-e/install-action@44c6d64aa62cd779e873306675c7a58e86d6d532 # v2.62.49
with: with:
tool: just,cargo-hack,cargo-nextest,cargo-ci-cache-clean tool: just,cargo-hack,cargo-nextest,cargo-ci-cache-clean
@ -83,7 +83,7 @@ jobs:
uses: actions-rust-lang/setup-rust-toolchain@1780873c7b576612439a134613cc4cc74ce5538c # v1.15.2 uses: actions-rust-lang/setup-rust-toolchain@1780873c7b576612439a134613cc4cc74ce5538c # v1.15.2
- name: Install just, cargo-hack - name: Install just, cargo-hack
uses: taiki-e/install-action@f535147c22906d77695e11cb199e764aa610a4fc # v2.62.46 uses: taiki-e/install-action@44c6d64aa62cd779e873306675c7a58e86d6d532 # v2.62.49
with: with:
tool: just,cargo-hack tool: just,cargo-hack

View File

@ -64,7 +64,7 @@ jobs:
toolchain: ${{ matrix.version.version }} toolchain: ${{ matrix.version.version }}
- name: Install just, cargo-hack, cargo-nextest, cargo-ci-cache-clean - name: Install just, cargo-hack, cargo-nextest, cargo-ci-cache-clean
uses: taiki-e/install-action@f535147c22906d77695e11cb199e764aa610a4fc # v2.62.46 uses: taiki-e/install-action@44c6d64aa62cd779e873306675c7a58e86d6d532 # v2.62.49
with: with:
tool: just,cargo-hack,cargo-nextest,cargo-ci-cache-clean tool: just,cargo-hack,cargo-nextest,cargo-ci-cache-clean
@ -117,7 +117,7 @@ jobs:
toolchain: nightly toolchain: nightly
- name: Install just - name: Install just
uses: taiki-e/install-action@f535147c22906d77695e11cb199e764aa610a4fc # v2.62.46 uses: taiki-e/install-action@44c6d64aa62cd779e873306675c7a58e86d6d532 # v2.62.49
with: with:
tool: just tool: just

View File

@ -24,7 +24,7 @@ jobs:
components: llvm-tools components: llvm-tools
- name: Install just, cargo-llvm-cov, cargo-nextest - name: Install just, cargo-llvm-cov, cargo-nextest
uses: taiki-e/install-action@f535147c22906d77695e11cb199e764aa610a4fc # v2.62.46 uses: taiki-e/install-action@44c6d64aa62cd779e873306675c7a58e86d6d532 # v2.62.49
with: with:
tool: just,cargo-llvm-cov,cargo-nextest tool: just,cargo-llvm-cov,cargo-nextest

View File

@ -77,7 +77,7 @@ jobs:
toolchain: ${{ vars.RUST_VERSION_EXTERNAL_TYPES }} toolchain: ${{ vars.RUST_VERSION_EXTERNAL_TYPES }}
- name: Install just - name: Install just
uses: taiki-e/install-action@f535147c22906d77695e11cb199e764aa610a4fc # v2.62.46 uses: taiki-e/install-action@44c6d64aa62cd779e873306675c7a58e86d6d532 # v2.62.49
with: with:
tool: just tool: just

4
Cargo.lock generated
View File

@ -2377,9 +2377,9 @@ dependencies = [
[[package]] [[package]]
name = "quote" name = "quote"
version = "1.0.41" version = "1.0.42"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ce25767e7b499d1b604768e7cde645d14cc8584231ea6b295e9c9eb22c02e1d1" checksum = "a338cc41d27e6cc6dce6cefc13a0729dfbb81c262b1f519331575dd80ef3067f"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
] ]

View File

@ -110,14 +110,22 @@ where
#[allow(clippy::borrow_interior_mutable_const)] #[allow(clippy::borrow_interior_mutable_const)]
fn call(&self, req: ServiceRequest) -> Self::Future { fn call(&self, req: ServiceRequest) -> Self::Future {
if req.extensions().get::<Encoding>().is_some() {
return Either::left(CompressResponse {
fut: self.service.call(req),
_phantom: PhantomData,
});
}
// negotiate content-encoding // negotiate content-encoding
let accept_encoding = req.get_header::<AcceptEncoding>(); let accept_encoding = req.get_header::<AcceptEncoding>();
let accept_encoding = match accept_encoding { let accept_encoding = match accept_encoding {
// missing header; fallback to identity // missing header; fallback to identity
None => { None => {
req.extensions_mut().insert::<Encoding>(Encoding::identity());
return Either::left(CompressResponse { return Either::left(CompressResponse {
encoding: Encoding::identity(),
fut: self.service.call(req), fut: self.service.call(req),
_phantom: PhantomData, _phantom: PhantomData,
}) })
@ -143,11 +151,14 @@ where
.map_into_right_body())) .map_into_right_body()))
} }
Some(encoding) => Either::left(CompressResponse { Some(encoding) => {
req.extensions_mut().insert::<Encoding>(encoding);
Either::left(CompressResponse {
fut: self.service.call(req), fut: self.service.call(req),
encoding,
_phantom: PhantomData, _phantom: PhantomData,
}), })
},
} }
} }
} }
@ -159,7 +170,6 @@ pin_project! {
{ {
#[pin] #[pin]
fut: S::Future, fut: S::Future,
encoding: Encoding,
_phantom: PhantomData<B>, _phantom: PhantomData<B>,
} }
} }
@ -176,8 +186,19 @@ where
match ready!(this.fut.poll(cx)) { match ready!(this.fut.poll(cx)) {
Ok(resp) => { Ok(resp) => {
let enc = match this.encoding { let request_encoding = resp.request().extensions().get::<Encoding>().cloned();
Encoding::Known(enc) => *enc,
let encoding = match request_encoding {
Some(enc) => enc.clone(),
None => {
return Poll::Ready(Ok(resp.map_body(move |head, body| {
EitherBody::left(Encoder::response(ContentEncoding::Identity, head, body))
})));
}
};
let enc = match encoding {
Encoding::Known(enc) => enc,
Encoding::Unknown(enc) => { Encoding::Unknown(enc) => {
unimplemented!("encoding '{enc}' should not be here"); unimplemented!("encoding '{enc}' should not be here");
} }