miniflare - npm Package Compare versions

Comparing version 0.0.0-fc3dd9c6c to 0.0.0-fcaa02cdf

dist/src/workers/core/entry.worker.js

		@@ -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)

dist/src/workers/d1/database.worker.js

		@@ -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(",")});`;

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

		@@ -57,3 +57,3 @@ var __defProp = Object.defineProperty;
		maxBatchSize: z.number().min(0).max(100).optional(),
		maxBatchTimeout: z.number().min(0).max(30).optional(),
		maxBatchTimeout: z.number().min(0).max(60).optional(),
		// seconds
		@@ -60,0 +60,0 @@ maxRetires: z.number().min(0).max(100).optional(),

package.json

		{
		"name": "miniflare",
		"version": "0.0.0-fc3dd9c6c",
		"version": "0.0.0-fcaa02cdf",
		"description": "Fun, full-featured, fully-local simulator for Cloudflare Workers",
		@@ -41,3 +41,3 @@ "keywords": [
		"undici": "^5.28.4",
		"workerd": "1.20241106.1",
		"workerd": "1.20241230.0",
		"ws": "^8.18.0",
		@@ -49,3 +49,3 @@ "youch": "^3.2.2",
		"@ava/typescript": "^4.1.0",
		"@cloudflare/workers-types": "^4.20241106.0",
		"@cloudflare/workers-types": "^4.20241230.0",
		"@microsoft/api-extractor": "^7.47.0",
		@@ -58,3 +58,2 @@ "@types/debug": "^4.1.7",
		"@types/node": "^18.19.59",
		"@types/rimraf": "^4.0.5",
		"@types/stoppable": "^1.1.1",
		@@ -82,8 +81,8 @@ "@types/which": "^2.0.1",
		"pretty-bytes": "^6.0.0",
		"rimraf": "^5.0.1",
		"rimraf": "^5.0.10",
		"source-map": "^0.6.1",
		"which": "^2.0.2",
		"@cloudflare/kv-asset-handler": "0.3.4",
		"@cloudflare/workers-shared": "0.8.0",
		"@cloudflare/workflows-shared": "0.2.0"
		"@cloudflare/workers-shared": "0.0.0-fcaa02cdf",
		"@cloudflare/workflows-shared": "0.2.2"
		},
		@@ -90,0 +89,0 @@ "engines": {

dist/src/index.d.ts

Sorry, the diff of this file is too big to display

dist/src/index.js

Sorry, the diff of this file is too big to display

dist/src/index.js.map