miniflare - npm Package Compare versions

Comparing version 0.0.0-17684ebc6 to 0.0.0-17eb8a9f9

dist/src/workers/assets/assets-kv.worker.js

@@ -13,3 +13,7 @@ // src/workers/assets/assets-kv.worker.ts
     let { filePath, contentType } = entry, response = await env[SharedBindings.MAYBE_SERVICE_BLOBS].fetch(
-      new URL(filePath, "http://placeholder")
+      new URL(
+        // somewhere in blobservice I think this is being decoded again
+        filePath.split("/").map((x) => encodeURIComponent(x)).join("/"),
+        "http://placeholder"
+      )
     ), newResponse = new Response(response.body, response);
@@ -16,0 +20,0 @@ return newResponse.headers.append(

dist/src/workers/queues/broker.worker.js

@@ -179,3 +179,5 @@ var __defProp = Object.defineProperty;
   get #maybeProducer() {
-    return this.#producers[this.name];
+    return Object.values(this.#producers).find(
+      (p) => p?.queueName === this.name
+    );
   }
@@ -266,13 +268,17 @@ get #maybeConsumer() {
   message = async (req) => {
+    if (this.#maybeConsumer === void 0)
+      return new Response();
     validateMessageSize(req.headers);
-    let contentType = validateContentType(req.headers), delay = validateMessageDelay(req.headers), body = Buffer2.from(await req.arrayBuffer());
-    return this.#maybeConsumer === void 0 ? new Response() : (this.#enqueue(
+    let contentType = validateContentType(req.headers), delay = validateMessageDelay(req.headers) ?? this.#maybeProducer?.deliveryDelay, body = Buffer2.from(await req.arrayBuffer());
+    return this.#enqueue(
       [{ contentType, delaySecs: delay, body }],
       this.#maybeProducer?.deliveryDelay
-    ), new Response());
+    ), new Response();
   };
   batch = async (req) => {
+    if (this.#maybeConsumer === void 0)
+      return new Response();
     validateBatchSize(req.headers);
     let delay = validateMessageDelay(req.headers) ?? this.#maybeProducer?.deliveryDelay, body = QueuesBatchRequestSchema.parse(await req.json());
-    return this.#maybeConsumer === void 0 ? new Response() : (this.#enqueue(body.messages, delay), new Response());
+    return this.#enqueue(body.messages, delay), new Response();
   };
@@ -279,0 +285,0 @@ };

package.json

 {
   "name": "miniflare",
-  "version": "0.0.0-17684ebc6",
+  "version": "0.0.0-17eb8a9f9",
   "description": "Fun, full-featured, fully-local simulator for Cloudflare Workers",
@@ -82,3 +82,3 @@ "keywords": [
     "@cloudflare/kv-asset-handler": "0.3.4",
-    "@cloudflare/workers-shared": "0.0.0-17684ebc6"
+    "@cloudflare/workers-shared": "0.0.0-17eb8a9f9"
   },
@@ -85,0 +85,0 @@ "engines": {

No alert changes

Improved metrics

Total package byte prevSize

2533770

increased by0.1%

Lines of code

39659

increased by0.22%

No dependency changes