Remove redundant check from test state cleaner

Author: mendess

crates/daphne-worker/src/aggregator/router/extractor.rs

@@ -1,8 +1,6 @@
 // Copyright (c) 2025 Cloudflare, Inc. All rights reserved.
 // SPDX-License-Identifier: BSD-3-Clause
 
-use std::io::Cursor;
-
 use axum::{
     async_trait,
     body::Bytes,
@@ -41,11 +39,10 @@ macro_rules! impl_decode_from_dap_http_body {
                     bytes: Bytes,
                     meta: &DapRequestMeta,
                 ) -> Result<Self, DapAbort> {
-                    let mut cursor = Cursor::new(bytes.as_ref());
                     // Check that media type matches.
                     meta.get_checked_media_type(DapMediaType::$type)?;
                     // Decode the body
-                    $type::decode_with_param(&meta.version, &mut cursor)
+                    $type::get_decoded_with_param(&meta.version, bytes.as_ref())
                         .map_err(|e| DapAbort::from_codec_error(e, meta.task_id))
                 }
             }
@@ -62,11 +59,10 @@ impl_decode_from_dap_http_body!(
 
 impl DecodeFromDapHttpBody for HashedAggregationJobReq {
     fn decode_from_http_body(bytes: Bytes, meta: &DapRequestMeta) -> Result<Self, DapAbort> {
-        let mut cursor = Cursor::new(bytes.as_ref());
         // Check that media type matches.
         meta.get_checked_media_type(DapMediaType::AggregationJobInitReq)?;
         // Decode the body
-        HashedAggregationJobReq::decode_with_param(&meta.version, &mut cursor)
+        HashedAggregationJobReq::get_decoded_with_param(&meta.version, bytes.as_ref())
             .map_err(|e| DapAbort::from_codec_error(e, meta.task_id))
     }
 }

crates/daphne-worker/src/durable/test_state_cleaner.rs

@@ -43,14 +43,6 @@ impl TestStateCleaner {
             Some(bindings::TestStateCleaner::Put) => {
                 let durable_ref: DurableReference =
                     serde_json::from_slice(&req.bytes().await?).unwrap();
-                match durable_ref.binding.as_ref() {
-                    bindings::AggregateStore::BINDING => (),
-                    s => {
-                        let message = format!("GarbageCollector: unrecognized binding: {s}");
-                        console_error!("{}", message);
-                        return Err(int_err(message));
-                    }
-                };
 
                 let queued = DurableOrdered::new_roughly_ordered(durable_ref, "object");
                 queued.put(&self.state).await?;