miniflare - npm Package Compare versions

Comparing version 0.0.0-3bd833cbe to 0.0.0-3e75612ff

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-3bd833cbe",
+  "version": "0.0.0-3e75612ff",
   "description": "Fun, full-featured, fully-local simulator for Cloudflare Workers",
@@ -41,3 +41,3 @@ "keywords": [
     "undici": "^5.28.4",
-    "workerd": "1.20240821.1",
+    "workerd": "1.20240909.0",
     "ws": "^8.17.1",
@@ -49,3 +49,3 @@ "youch": "^3.2.2",
     "@ava/typescript": "^4.1.0",
-    "@cloudflare/workers-types": "^4.20240821.1",
+    "@cloudflare/workers-types": "^4.20240909.0",
     "@microsoft/api-extractor": "^7.47.0",
@@ -83,3 +83,4 @@ "@types/debug": "^4.1.7",
     "which": "^2.0.2",
-    "@cloudflare/kv-asset-handler": "0.3.4"
+    "@cloudflare/kv-asset-handler": "0.3.4",
+    "@cloudflare/workers-shared": "0.0.0-3e75612ff"
   },
@@ -86,0 +87,0 @@ "engines": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Dynamic require

Supply chain risk

Dynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

2532084

increased by93.66%

Number of package files

38

increased by11.76%

Lines of code

39599

increased by85.03%

Worsened metrics

Dev dependency count

36

increased by2.86%

Number of low supply chain risk alerts

48

increased by17.07%

Number of medium supply chain risk alerts

12

increased by100%

Dependency changes

• + Added@cloudflare/workerd-darwin-64@1.20240909.0(transitive)

• + Added@cloudflare/workerd-darwin-arm64@1.20240909.0(transitive)

• + Added@cloudflare/workerd-linux-64@1.20240909.0(transitive)

• + Added@cloudflare/workerd-linux-arm64@1.20240909.0(transitive)

• + Added@cloudflare/workerd-windows-64@1.20240909.0(transitive)

• + Addedworkerd@1.20240909.0(transitive)

• - Removed@cloudflare/workerd-darwin-64@1.20240821.1(transitive)

• - Removed@cloudflare/workerd-darwin-arm64@1.20240821.1(transitive)

• - Removed@cloudflare/workerd-linux-64@1.20240821.1(transitive)

• - Removed@cloudflare/workerd-linux-arm64@1.20240821.1(transitive)

• - Removed@cloudflare/workerd-windows-64@1.20240821.1(transitive)

• - Removedworkerd@1.20240821.1(transitive)

• Updatedworkerd@1.20240909.0