miniflare
Advanced tools
Comparing version 0.0.0-81c40f0a2 to 0.0.0-82180a7a7
@@ -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( |
@@ -689,3 +689,3 @@ // ../../node_modules/.pnpm/kleur@4.1.5/node_modules/kleur/colors.mjs | ||
function isObject(value) { | ||
return value && typeof value == "object"; | ||
return !!value && typeof value == "object"; | ||
} | ||
@@ -695,2 +695,5 @@ function getType(value) { | ||
} | ||
function isInternal(value) { | ||
return isObject(value) && value[Symbol.for("cloudflare:internal-class")]; | ||
} | ||
var ProxyServer = class { | ||
@@ -710,3 +713,3 @@ constructor(_state, env) { | ||
let type = getType(value); | ||
if (type === "Object" && !isPlainObject(value) || type === "Promise") { | ||
if ((type === "Object" || isInternal(value)) && !isPlainObject(value) || type === "Promise") { | ||
let address = this.nextHeapAddress++; | ||
@@ -713,0 +716,0 @@ this.heap.set(address, value), assert2(value !== null); |
@@ -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 @@ }; |
{ | ||
"name": "miniflare", | ||
"version": "0.0.0-81c40f0a2", | ||
"version": "0.0.0-82180a7a7", | ||
"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.20240925.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.20240925.0", | ||
"@microsoft/api-extractor": "^7.47.0", | ||
@@ -84,3 +84,3 @@ "@types/debug": "^4.1.7", | ||
"@cloudflare/kv-asset-handler": "0.3.4", | ||
"@cloudflare/workers-shared": "0.0.0-81c40f0a2" | ||
"@cloudflare/workers-shared": "0.0.0-82180a7a7" | ||
}, | ||
@@ -87,0 +87,0 @@ "engines": { |
@@ -577,2 +577,13 @@ # 🔥 Miniflare | ||
#### Assets | ||
- `directory?: string` | ||
Path to serve Workers static asset files from. | ||
- `binding?: string` | ||
Binding name to inject as a `Fetcher` binding to allow access to static assets from within the Worker. | ||
- `assetOptions?: { html_handling?: HTMLHandlingOptions, not_found_handling?: NotFoundHandlingOptions}` | ||
Configuration for file-based asset routing - see [docs](https://developers.cloudflare.com/workers/static-assets/routing/#routing-configuration) for options | ||
#### Analytics Engine, Sending Email, Vectorize and Workers for Platforms | ||
@@ -579,0 +590,0 @@ |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis 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 riskDynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
2541897
39782
859
387
48
12
+ Added@cloudflare/workerd-darwin-64@1.20240925.0(transitive)
+ Added@cloudflare/workerd-darwin-arm64@1.20240925.0(transitive)
+ Added@cloudflare/workerd-linux-64@1.20240925.0(transitive)
+ Added@cloudflare/workerd-linux-arm64@1.20240925.0(transitive)
+ Added@cloudflare/workerd-windows-64@1.20240925.0(transitive)
+ Addedworkerd@1.20240925.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.20240925.0