chore: update miniflare to get new assets functionality

Author: zebp

package-lock.json

@@ -16,7 +16,7 @@
   "devDependencies": {
     "@types/node": "^20.4.8",
     "@types/uuid": "^9.0.2",
-    "miniflare": "^3.20240909.4",
+    "miniflare": "^3.20241205.0",
     "typescript": "^5.1.6",
     "undici": "^5.28.4",
     "uuid": "^9.0.0",

package.json

@@ -27,7 +27,7 @@
     /* Modules */
     "module": "ES2022",                                /* Specify what module code is generated. */
     // "rootDir": "./",                                  /* Specify the root folder within your source files. */
-    "moduleResolution": "nodenext",                     /* Specify how TypeScript looks up a file from a given module specifier. */
+    "moduleResolution": "bundler",                     /* Specify how TypeScript looks up a file from a given module specifier. */
     // "baseUrl": "./",                                  /* Specify the base directory to resolve non-relative module names. */
     // "paths": {},                                      /* Specify a set of entries that re-map imports to additional lookup locations. */
     // "rootDirs": [],                                   /* Allow multiple folders to be treated as one when resolving modules. */

tsconfig.json

@@ -1,17 +1,37 @@
+use worker::Url;
+
 #[cfg(not(feature = "http"))]
 pub async fn handle_asset(
     req: worker::Request,
     env: worker::Env,
     _data: crate::SomeSharedData,
 ) -> worker::Result<worker::Response> {
-    use worker::Url;
+    let url: Url = req.url()?;
+    let name: String = url.path_segments().unwrap().nth(1).unwrap().to_string();
+    let url: String = ["https://dummyurl.com/", &name].concat();
+
+    env.assets("ASSETS")
+        .expect("ASSETS BINDING")
+        .fetch(url, None)
+        .await
+}
+
+#[cfg(feature = "http")]
+#[worker::send]
+pub async fn handle_asset(
+    req: worker::Request,
+    env: worker::Env,
+    _data: crate::SomeSharedData,
+) -> worker::Result<worker::Response> {
+    use std::convert::TryInto;
 
     let url: Url = req.url()?;
     let name: String = url.path_segments().unwrap().nth(1).unwrap().to_string();
     let url: String = ["https://dummyurl.com/", &name].concat();
-    Ok(env
-        .assets("ASSETS")
+
+    env.assets("ASSETS")
         .expect("ASSETS BINDING")
         .fetch(url, None)
-        .await?)
+        .await?
+        .try_into()
 }

worker-sandbox/src/assets.rs

@@ -64,6 +64,7 @@ pub fn make_router(data: SomeSharedData, env: Env) -> axum::Router {
             "/async-request",
             get(handler!(request::handle_async_request)),
         )
+        .route("/asset/:name", get(handler!(assets::handle_asset)))
         .route("/websocket", get(handler!(ws::handle_websocket)))
         .route("/got-close-event", get(handler!(handle_close_event)))
         .route("/ws-client", get(handler!(ws::handle_websocket_client)))

worker-sandbox/src/router.rs

@@ -73,8 +73,8 @@ export const mf = new Miniflare({
   queueProducers: ["my_queue", "my_queue"],
   fetchMock: mockAgent,
   assets: {
-    path: "./public",
-    bindingName: "ASSETS",
+    directory: "./public",
+    binding: "ASSETS",
     routingConfig: {
       has_user_worker: true,
     },