refactor(ext/fetch): pass opstate in `FetchHandler::fetch_file`

1 files changed, 8 insertions, 5 deletions

diff --git a/ext/fetch/lib.rs b/ext/fetch/lib.rs
index 56e9ef1af..a4cff402f 100644
--- a/ext/fetch/lib.rs
+++ b/ext/fetch/lib.rs
@@ -67,7 +67,7 @@ pub struct Options {
   pub request_builder_hook: Option<fn(RequestBuilder) -> RequestBuilder>,
   pub unsafely_ignore_certificate_errors: Option<Vec<String>>,
   pub client_cert_chain_and_key: Option<(String, String)>,
-  pub file_fetch_handler: Box<dyn FetchHandler>,
+  pub file_fetch_handler: Rc<dyn FetchHandler>,
 }
 
 impl Default for Options {
@@ -79,7 +79,7 @@ impl Default for Options {
       request_builder_hook: None,
       unsafely_ignore_certificate_errors: None,
       client_cert_chain_and_key: None,
-      file_fetch_handler: Box::new(DefaultFileFetchHandler),
+      file_fetch_handler: Rc::new(DefaultFileFetchHandler),
     }
   }
 }
@@ -134,7 +134,8 @@ pub trait FetchHandler: dyn_clone::DynClone {
   // cancelable response result, the optional fetch body resource and the
   // optional cancel handle.
   fn fetch_file(
-    &mut self,
+    &self,
+    state: &mut OpState,
     url: Url,
   ) -> (
     CancelableResponseFuture,
@@ -151,7 +152,8 @@ pub struct DefaultFileFetchHandler;
 
 impl FetchHandler for DefaultFileFetchHandler {
   fn fetch_file(
-    &mut self,
+    &self,
+    _state: &mut OpState,
     _url: Url,
   ) -> (
     CancelableResponseFuture,
@@ -234,8 +236,9 @@ where
       let Options {
         file_fetch_handler, ..
       } = state.borrow_mut::<Options>();
+      let file_fetch_handler = file_fetch_handler.clone();
       let (request, maybe_request_body, maybe_cancel_handle) =
-        file_fetch_handler.fetch_file(url);
+        file_fetch_handler.fetch_file(state, url);
       let request_rid = state.resource_table.add(FetchRequestResource(request));
       let maybe_request_body_rid =
         maybe_request_body.map(|r| state.resource_table.add(r));