miniflare
Advanced tools
Comparing version
@@ -19,3 +19,3 @@ // src/workers/assets/assets-kv.worker.ts | ||
), newResponse = new Response(response.body, response); | ||
return newResponse.headers.append( | ||
return contentType !== null && newResponse.headers.append( | ||
"cf-kv-metadata", | ||
@@ -22,0 +22,0 @@ `{"contentType": "${contentType}"}` |
@@ -869,3 +869,3 @@ // ../../node_modules/.pnpm/kleur@4.1.5/node_modules/kleur/colors.mjs | ||
var encoder = new TextEncoder(); | ||
function getUserRequest(request, env) { | ||
function getUserRequest(request, env, clientIp) { | ||
let originalUrl = request.headers.get(CoreHeaders.ORIGINAL_URL), url = new URL(originalUrl ?? request.url), rewriteHeadersFromOriginalUrl = !1, proxySharedSecret = request.headers.get( | ||
@@ -889,12 +889,7 @@ CoreHeaders.PROXY_SHARED_SECRET | ||
} | ||
if (request = new Request(url, request), request.cf === void 0) { | ||
let cf = { | ||
...env[CoreBindings.JSON_CF_BLOB], | ||
// Defaulting to empty string to preserve undefined `Accept-Encoding` | ||
// through Wrangler's proxy worker. | ||
clientAcceptEncoding: request.headers.get("Accept-Encoding") ?? "" | ||
}; | ||
request = new Request(request, { cf }); | ||
if (request = new Request(url, request), request.headers.set("Accept-Encoding", "br, gzip"), rewriteHeadersFromOriginalUrl && request.headers.set("Host", url.host), clientIp && !request.headers.get("CF-Connecting-IP")) { | ||
let ipv4Regex = /(?<ip>.*?):\d+/, ipv6Regex = /\[(?<ip>.*?)\]:\d+/, ip = clientIp.match(ipv6Regex)?.groups?.ip ?? clientIp.match(ipv4Regex)?.groups?.ip; | ||
ip && request.headers.set("CF-Connecting-IP", ip); | ||
} | ||
return request.headers.set("Accept-Encoding", "br, gzip"), rewriteHeadersFromOriginalUrl && request.headers.set("Host", url.host), request.headers.delete(CoreHeaders.PROXY_SHARED_SECRET), request.headers.delete(CoreHeaders.ORIGINAL_URL), request.headers.delete(CoreHeaders.DISABLE_PRETTY_ERROR), request; | ||
return request.headers.delete(CoreHeaders.PROXY_SHARED_SECRET), request.headers.delete(CoreHeaders.ORIGINAL_URL), request.headers.delete(CoreHeaders.DISABLE_PRETTY_ERROR), request; | ||
} | ||
@@ -1014,8 +1009,13 @@ function getTargetService(request, url, env) { | ||
async fetch(request, env, ctx) { | ||
let startTime = Date.now(); | ||
if (request.headers.get(CoreHeaders.OP) !== null) | ||
let startTime = Date.now(), clientIp = request.cf?.clientIp, clientCfBlobHeader = request.headers.get(CoreHeaders.CF_BLOB), cf = clientCfBlobHeader ? JSON.parse(clientCfBlobHeader) : { | ||
...env[CoreBindings.JSON_CF_BLOB], | ||
// Defaulting to empty string to preserve undefined `Accept-Encoding` | ||
// through Wrangler's proxy worker. | ||
clientAcceptEncoding: request.headers.get("Accept-Encoding") ?? "" | ||
}; | ||
if (request = new Request(request, { cf }), request.headers.get(CoreHeaders.OP) !== null) | ||
return handleProxy(request, env); | ||
let disablePrettyErrorPage = request.headers.get(CoreHeaders.DISABLE_PRETTY_ERROR) !== null, clientAcceptEncoding = request.headers.get("Accept-Encoding"); | ||
try { | ||
request = getUserRequest(request, env); | ||
request = getUserRequest(request, env, clientIp); | ||
} catch (e) { | ||
@@ -1022,0 +1022,0 @@ if (e instanceof HttpError) |
@@ -53,3 +53,3 @@ var __defProp = Object.defineProperty; | ||
let colType = columns[i].type, cellType = typeof cell; | ||
return cell === null ? "NULL" : colType === "INTEGER" || cellType === "number" ? cell : colType === "TEXT" || cellType === "string" ? outputQuotedEscapedString(cell) : cell instanceof ArrayBuffer ? `X'${Array.prototype.map.call(new Uint8Array(cell), (b) => b.toString(16)).join("")}'` : (console.log({ colType, cellType, cell, column: columns[i] }), "ERROR"); | ||
return cell === null ? "NULL" : colType === "INTEGER" || cellType === "number" ? cell : colType === "TEXT" || cellType === "string" ? outputQuotedEscapedString(cell) : cell instanceof ArrayBuffer ? `X'${Array.prototype.map.call(new Uint8Array(cell), (b) => b.toString(16).padStart(2, "0")).join("")}'` : (console.log({ colType, cellType, cell, column: columns[i] }), "ERROR"); | ||
}); | ||
@@ -56,0 +56,0 @@ yield `INSERT INTO ${sqliteQuote(table)} VALUES(${formattedCells.join(",")});`; |
@@ -8,3 +8,6 @@ // src/workers/shared/blob.worker.ts | ||
function viewToBuffer(view) { | ||
return view.buffer.slice(view.byteOffset, view.byteOffset + view.byteLength); | ||
return view.buffer.slice( | ||
view.byteOffset, | ||
view.byteOffset + view.byteLength | ||
); | ||
} | ||
@@ -11,0 +14,0 @@ function base64Encode(value) { |
{ | ||
"name": "miniflare", | ||
"version": "0.0.0-086a6b8c6", | ||
"version": "0.0.0-08b8c4687", | ||
"description": "Fun, full-featured, fully-local simulator for Cloudflare Workers", | ||
@@ -34,18 +34,17 @@ "keywords": [ | ||
"@cspotcode/source-map-support": "0.8.1", | ||
"acorn": "^8.8.0", | ||
"acorn-walk": "^8.2.0", | ||
"capnp-ts": "^0.7.0", | ||
"exit-hook": "^2.2.1", | ||
"glob-to-regexp": "^0.4.1", | ||
"stoppable": "^1.1.0", | ||
"undici": "^5.28.4", | ||
"workerd": "1.20241205.0", | ||
"ws": "^8.18.0", | ||
"youch": "^3.2.2", | ||
"zod": "^3.22.3" | ||
"acorn": "8.14.0", | ||
"acorn-walk": "8.3.2", | ||
"exit-hook": "2.2.1", | ||
"glob-to-regexp": "0.4.1", | ||
"stoppable": "1.1.0", | ||
"undici": "^5.28.5", | ||
"workerd": "1.20250224.0", | ||
"ws": "8.18.0", | ||
"youch": "3.2.3", | ||
"zod": "3.22.3" | ||
}, | ||
"devDependencies": { | ||
"@ava/typescript": "^4.1.0", | ||
"@cloudflare/workers-types": "^4.20241205.0", | ||
"@microsoft/api-extractor": "^7.47.0", | ||
"@cloudflare/workers-types": "^4.20250224.0", | ||
"@microsoft/api-extractor": "7.49.1", | ||
"@types/debug": "^4.1.7", | ||
@@ -56,4 +55,3 @@ "@types/estree": "^1.0.0", | ||
"@types/mime": "^3.0.4", | ||
"@types/node": "^18.19.59", | ||
"@types/rimraf": "^4.0.5", | ||
"@types/node": "^18.19.75", | ||
"@types/stoppable": "^1.1.1", | ||
@@ -65,3 +63,3 @@ "@types/which": "^2.0.1", | ||
"ava": "^6.0.1", | ||
"capnpc-ts": "^0.7.0", | ||
"capnp-es": "^0.0.7", | ||
"concurrently": "^8.2.2", | ||
@@ -71,6 +69,5 @@ "devalue": "^4.3.0", | ||
"esbuild": "0.17.19", | ||
"eslint": "^8.49.0", | ||
"eslint": "^8.57.1", | ||
"eslint-config-prettier": "^9.0.0", | ||
"eslint-plugin-es": "^4.1.0", | ||
"eslint-plugin-import": "2.26.x", | ||
"eslint-plugin-prettier": "^5.0.1", | ||
@@ -83,8 +80,9 @@ "expect-type": "^0.15.0", | ||
"pretty-bytes": "^6.0.0", | ||
"rimraf": "^5.0.1", | ||
"rimraf": "^5.0.10", | ||
"source-map": "^0.6.1", | ||
"typescript": "^5.7.2", | ||
"which": "^2.0.2", | ||
"@cloudflare/workers-shared": "0.0.0-086a6b8c6", | ||
"@cloudflare/workflows-shared": "0.2.1", | ||
"@cloudflare/kv-asset-handler": "0.3.4" | ||
"@cloudflare/kv-asset-handler": "0.3.4", | ||
"@cloudflare/workflows-shared": "0.2.3", | ||
"@cloudflare/workers-shared": "0.0.0-08b8c4687" | ||
}, | ||
@@ -105,3 +103,3 @@ "engines": { | ||
"build": "node scripts/build.mjs && pnpm run types:build", | ||
"capnp:workerd": "capnpc -o ts src/runtime/config/workerd.capnp", | ||
"capnp:workerd": "node scripts/build-capnp.mjs", | ||
"check:lint": "eslint --max-warnings=0 \"{src,test}/**/*.ts\" \"scripts/**/*.{js,mjs}\" \"types/**/*.ts\"", | ||
@@ -108,0 +106,0 @@ "check:type": "tsc", |
@@ -602,2 +602,9 @@ # 🔥 Miniflare | ||
#### Pipelines | ||
- `pipelines?: Record<string, PipelineOptions> | string[]` | ||
Record mapping binding name to a Pipeline. Different workers may bind to the same Pipeline with different bindings | ||
names. If a `string[]` of pipeline names, the binding and Pipeline name are assumed to be the same. | ||
#### Workflows | ||
@@ -604,0 +611,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
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
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
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
2918722
7.69%11
-8.33%37
-2.63%44
10%46670
10.49%889
0.79%48
-4%8
-33.33%+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
+ Added
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
- Removed
Updated
Updated
Updated
Updated
Updated
Updated
Updated
Updated
Updated
Updated