New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

miniflare

Package Overview
Dependencies
Maintainers
1
Versions
1038
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

miniflare - npm Package Compare versions

Comparing version

0.0.0-2b6f14966
to
0.0.0-2bc289e2e

dist/src/workers/assets/rpc-proxy.worker.js
dist/src/workers/assets/rpc-proxy.worker.js.map
dist/src/workers/pipelines/pipeline.worker.js
dist/src/workers/pipelines/pipeline.worker.js.map

2

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

@@ -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}"}`

36

dist/src/workers/cache/cache.worker.js

@@ -93,4 +93,3 @@ var __create = Object.create;

let cc = {};
if (!header)
return cc;
if (!header) return cc;
let parts = header.trim().split(/,/);

@@ -175,4 +174,3 @@ for (let part of parts) {

for (let name of fields)
if (req.headers[name] !== this._reqHeaders[name])
return !1;
if (req.headers[name] !== this._reqHeaders[name]) return !1;
return !0;

@@ -270,6 +268,4 @@ }

_fromObject(obj) {
if (this._responseTime)
throw Error("Reinitialized");
if (!obj || obj.v !== 1)
throw Error("Invalid serialization");
if (this._responseTime) throw Error("Reinitialized");
if (!obj || obj.v !== 1) throw Error("Invalid serialization");
this._responseTime = obj.t, this._isShared = obj.sh, this._cacheHeuristic = obj.ch, this._immutableMinTtl = obj.imm !== void 0 ? obj.imm : 24 * 3600 * 1e3, this._status = obj.st, this._resHeaders = obj.resh, this._rescc = obj.rescc, this._method = obj.m, this._url = obj.u, this._host = obj.h, this._noAuthorization = obj.a, this._reqHeaders = obj.reqh, this._reqcc = obj.reqcc;

@@ -312,4 +308,3 @@ }

}
} else
this._resHeaders["last-modified"] && !headers["if-modified-since"] && (headers["if-modified-since"] = this._resHeaders["last-modified"]);
} else this._resHeaders["last-modified"] && !headers["if-modified-since"] && (headers["if-modified-since"] = this._resHeaders["last-modified"]);
return headers;

@@ -482,4 +477,3 @@ }

let result = {};
for (let [key, value] of headers)
result[key.toLowerCase()] = value;
for (let [key, value] of headers) result[key.toLowerCase()] = value;
return result;

@@ -525,4 +519,3 @@ }

}
var CR = "\r".charCodeAt(0), LF = `
`.charCodeAt(0), STATUS_REGEXP = /^HTTP\/\d(?:\.\d)? (?<rawStatusCode>\d+) (?<statusText>.*)$/;
var CR = 13, LF = 10, STATUS_REGEXP = /^HTTP\/\d(?:\.\d)? (?<rawStatusCode>\d+) (?<statusText>.*)$/;
async function parseHttpResponse(stream) {

@@ -533,4 +526,3 @@ let buffer = Buffer2.alloc(0), blankLineIndex = -1;

(_value, index) => buffer[index] === CR && buffer[index + 1] === LF && buffer[index + 2] === CR && buffer[index + 3] === LF
), blankLineIndex !== -1)
break;
), blankLineIndex !== -1) break;
assert(blankLineIndex !== -1, "Expected to find blank line in HTTP message");

@@ -583,4 +575,3 @@ let rawStatusHeaders = buffer.subarray(0, blankLineIndex).toString(), [rawStatus, ...rawHeaders] = rawStatusHeaders.split(`\r

let cacheKey = getCacheKey(req);
if (isSitesRequest(req))
throw new CacheMiss();
if (isSitesRequest(req)) throw new CacheMiss();
let resHeaders, resRanges, cached = await this.storage.get(cacheKey, ({ size, headers }) => {

@@ -597,4 +588,3 @@ resHeaders = new Headers(headers);

});
if (cached?.metadata === void 0)
throw new CacheMiss();
if (cached?.metadata === void 0) throw new CacheMiss();
return assert(resHeaders !== void 0), resHeaders.set("CF-Cache-Status", "HIT"), resRanges ??= [], getMatchResponse(req.headers, {

@@ -611,4 +601,3 @@ status: cached.metadata.status,

let cacheKey = getCacheKey(req);
if (isSitesRequest(req))
throw new CacheMiss();
if (isSitesRequest(req)) throw new CacheMiss();
assert(req.body !== null);

@@ -650,4 +639,3 @@ let res = await parseHttpResponse(req.body), body = res.body;

let cacheKey = getCacheKey(req);
if (!await this.storage.delete(cacheKey))
throw new PurgeFailure();
if (!await this.storage.delete(cacheKey)) throw new PurgeFailure();
return new Response(null);

@@ -654,0 +642,0 @@ };

87

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

@@ -70,4 +70,3 @@ // ../../node_modules/.pnpm/kleur@4.1.5/node_modules/kleur/colors.mjs

function isCompressedByCloudflareFL(contentTypeHeader) {
if (!contentTypeHeader)
return !0;
if (!contentTypeHeader) return !0;
let [contentType] = contentTypeHeader.split(";");

@@ -203,15 +202,10 @@ return compressedByCloudflareFL.has(contentType);

for (let route of routes) {
if (route.protocol && route.protocol !== url.protocol)
continue;
if (route.protocol && route.protocol !== url.protocol) continue;
if (route.allowHostnamePrefix) {
if (!url.hostname.endsWith(route.hostname))
continue;
} else if (url.hostname !== route.hostname)
continue;
if (!url.hostname.endsWith(route.hostname)) continue;
} else if (url.hostname !== route.hostname) continue;
let path = url.pathname + url.search;
if (route.allowPathSuffix) {
if (!path.startsWith(route.path))
continue;
} else if (path !== route.path)
continue;
if (!path.startsWith(route.path)) continue;
} else if (path !== route.path) continue;
return route.target;

@@ -290,4 +284,3 @@ }

function unflatten(parsed, revivers) {
if (typeof parsed == "number")
return hydrate(parsed, !0);
if (typeof parsed == "number") return hydrate(parsed, !0);
if (!Array.isArray(parsed) || parsed.length === 0)

@@ -300,16 +293,9 @@ throw new Error("Invalid input");

function hydrate(index, standalone = !1) {
if (index === -1)
return;
if (index === -3)
return NaN;
if (index === -4)
return 1 / 0;
if (index === -5)
return -1 / 0;
if (index === -6)
return -0;
if (standalone)
throw new Error("Invalid input");
if (index in hydrated)
return hydrated[index];
if (index === -1) return;
if (index === -3) return NaN;
if (index === -4) return 1 / 0;
if (index === -5) return -1 / 0;
if (index === -6) return -0;
if (standalone) throw new Error("Invalid input");
if (index in hydrated) return hydrated[index];
let value = values[index];

@@ -387,14 +373,8 @@ if (!value || typeof value != "object")

throw new DevalueError("Cannot stringify a function", keys);
if (indexes.has(thing))
return indexes.get(thing);
if (thing === void 0)
return -1;
if (Number.isNaN(thing))
return -3;
if (thing === 1 / 0)
return -4;
if (thing === -1 / 0)
return -5;
if (thing === 0 && 1 / thing < 0)
return -6;
if (indexes.has(thing)) return indexes.get(thing);
if (thing === void 0) return -1;
if (Number.isNaN(thing)) return -3;
if (thing === 1 / 0) return -4;
if (thing === -1 / 0) return -5;
if (thing === 0 && 1 / thing < 0) return -6;
let index2 = p++;

@@ -563,4 +543,3 @@ indexes.set(thing, index2);

Headers(val) {
if (val instanceof impl.Headers)
return Object.fromEntries(val);
if (val instanceof impl.Headers) return Object.fromEntries(val);
},

@@ -751,4 +730,3 @@ Request(val) {

let hostHeader = request.headers.get("Host");
if (hostHeader == null)
return new Response(null, { status: 400 });
if (hostHeader == null) return new Response(null, { status: 400 });
try {

@@ -762,4 +740,3 @@ let host = new URL(`http://${hostHeader}`);

let secretHex = request.headers.get(CoreHeaders.OP_SECRET);
if (secretHex == null)
return new Response(null, { status: 401 });
if (secretHex == null) return new Response(null, { status: 401 });
let expectedSecret = this.env[CoreBindings.DATA_PROXY_SECRET], secretBuffer = Buffer2.from(secretHex, "hex");

@@ -769,4 +746,3 @@ if (secretBuffer.byteLength !== expectedSecret.byteLength || !crypto.subtle.timingSafeEqual(secretBuffer, expectedSecret))

let opHeader = request.headers.get(CoreHeaders.OP), targetHeader = request.headers.get(CoreHeaders.OP_TARGET), keyHeader = request.headers.get(CoreHeaders.OP_KEY), allowAsync = request.headers.get(CoreHeaders.OP_SYNC) === null, argsSizeHeader = request.headers.get(CoreHeaders.OP_STRINGIFIED_SIZE), contentLengthHeader = request.headers.get("Content-Length");
if (targetHeader === null)
return new Response(null, { status: 400 });
if (targetHeader === null) return new Response(null, { status: 400 });
if (opHeader === ProxyOps.FREE) {

@@ -790,4 +766,3 @@ for (let targetValue of targetHeader.split(",")) {

} else if (opHeader === ProxyOps.GET_OWN_DESCRIPTOR) {
if (keyHeader === null)
return new Response(null, { status: 400 });
if (keyHeader === null) return new Response(null, { status: 400 });
let descriptor = Object.getOwnPropertyDescriptor(target, keyHeader);

@@ -961,7 +936,5 @@ descriptor !== void 0 && (result = {

function ensureAcceptableEncoding(clientAcceptEncoding, response) {
if (clientAcceptEncoding === null)
return response;
if (clientAcceptEncoding === null) return response;
let encodings = parseAcceptEncoding(clientAcceptEncoding);
if (encodings.length === 0)
return response;
if (encodings.length === 0) return response;
let contentEncoding = response.headers.get("Content-Encoding"), contentType = response.headers.get("Content-Type");

@@ -988,4 +961,3 @@ if (!isCompressedByCloudflareFL(contentType) || contentEncoding !== null && contentEncoding !== "gzip" && contentEncoding !== "br")

function maybeLogRequest(req, res, env, ctx, startTime) {
if (env[CoreBindings.JSON_LOG_LEVEL] < LogLevel.INFO)
return;
if (env[CoreBindings.JSON_LOG_LEVEL] < LogLevel.INFO) return;
let url = new URL(req.url), statusText = (res.statusText.trim() || STATUS_CODES[res.status]) ?? "", lines = [

@@ -1025,4 +997,3 @@ `${bold(req.method)} ${url.pathname} `,

};
if (request = new Request(request, { cf }), request.headers.get(CoreHeaders.OP) !== null)
return handleProxy(request, env);
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");

@@ -1029,0 +1000,0 @@ try {

6

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

@@ -31,4 +31,3 @@ var __defProp = Object.defineProperty;

for (let { name: table, sql } of tables) {
if (filterTables.size > 0 && !filterTables.has(table))
continue;
if (filterTables.size > 0 && !filterTables.has(table)) continue;
if (table === "sqlite_sequence")

@@ -47,4 +46,3 @@ noSchema || (yield "DELETE FROM sqlite_sequence;");

}
if (noData)
continue;
if (noData) continue;
let columns_cursor = db.exec(`PRAGMA table_info="${table}"`), columns = Array.from(columns_cursor), select = `SELECT ${columns.map((c) => c.name).join(", ")}

@@ -51,0 +49,0 @@ FROM "${table}";`, rows_cursor = db.exec(select);

6

dist/src/workers/kv/namespace.worker.js

@@ -48,4 +48,3 @@ var __defProp = Object.defineProperty;

function decodeKey({ key }, query) {
if (query.get(KVParams.URL_ENCODED)?.toLowerCase() !== "true")
return key;
if (query.get(KVParams.URL_ENCODED)?.toLowerCase() !== "true") return key;
try {

@@ -184,4 +183,3 @@ return decodeURIComponent(key);

let entry = await this.storage.get(key);
if (entry === null)
throw new HttpError2(404, "Not Found");
if (entry === null) throw new HttpError2(404, "Not Found");
let headers = new Headers();

@@ -188,0 +186,0 @@ return entry.expiration !== void 0 && headers.set(

9

dist/src/workers/kv/sites.worker.js

@@ -105,6 +105,4 @@ // src/workers/kv/sites.worker.ts

let aElement = a[i], bElement = b[i];
if (aElement < bElement)
return -1;
if (aElement > bElement)
return 1;
if (aElement < bElement) return -1;
if (aElement > bElement) return 1;
}

@@ -120,4 +118,3 @@ return a.length - b.length;

keys.sort((a, b) => arrayCompare(a.encodedName, b.encodedName));
for (let key of keys)
delete key.encodedName;
for (let key of keys) delete key.encodedName;
let startAfter = cursor === void 0 ? "" : base64Decode(cursor), startIndex = 0;

@@ -124,0 +121,0 @@ startAfter !== "" && (startIndex = keys.findIndex(({ name }) => name === startAfter), startIndex === -1 && (startIndex = keys.length), startIndex++);

29

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

@@ -80,3 +80,3 @@ var __defProp = Object.defineProperty;

// src/workers/queues/broker.worker.ts
var MAX_MESSAGE_SIZE_BYTES = 128 * 1e3, MAX_MESSAGE_BATCH_COUNT = 100, MAX_MESSAGE_BATCH_SIZE = (256 + 32) * 1e3, DEFAULT_BATCH_SIZE = 5, DEFAULT_BATCH_TIMEOUT = 1, DEFAULT_RETRIES = 2, exceptionQueueResponse = {
var MAX_MESSAGE_SIZE_BYTES = 128 * 1e3, MAX_MESSAGE_BATCH_COUNT = 100, MAX_MESSAGE_BATCH_SIZE = 288 * 1e3, DEFAULT_BATCH_SIZE = 5, DEFAULT_BATCH_TIMEOUT = 1, DEFAULT_RETRIES = 2, exceptionQueueResponse = {
outcome: "exception",

@@ -110,4 +110,3 @@ retryBatch: { retry: !1 },

let format = headers.get("X-Msg-Delay-Secs");
if (!format)
return;
if (!format) return;
let result = QueueMessageDelaySchema.safeParse(Number(format));

@@ -225,10 +224,9 @@ if (!result.success)

this.timers.setTimeout(fn, delay * 1e3);
} else
consumer.deadLetterQueue !== void 0 ? (await this.logWithLevel(
LogLevel.WARN,
`Moving message "${message.id}" on queue "${this.name}" to dead letter queue "${consumer.deadLetterQueue}" after ${maxAttempts} failed attempt${maxAttemptsS}...`
), toDeadLetterQueue.push(message)) : await this.logWithLevel(
LogLevel.WARN,
`Dropped message "${message.id}" on queue "${this.name}" after ${maxAttempts} failed attempt${maxAttemptsS}!`
);
} else consumer.deadLetterQueue !== void 0 ? (await this.logWithLevel(
LogLevel.WARN,
`Moving message "${message.id}" on queue "${this.name}" to dead letter queue "${consumer.deadLetterQueue}" after ${maxAttempts} failed attempt${maxAttemptsS}...`
), toDeadLetterQueue.push(message)) : await this.logWithLevel(
LogLevel.WARN,
`Dropped message "${message.id}" on queue "${this.name}" after ${maxAttempts} failed attempt${maxAttemptsS}!`
);
let acked = batch.length - failedMessages;

@@ -256,4 +254,3 @@ if (await this.logWithLevel(

if (this.#pendingFlush !== void 0) {
if (this.#pendingFlush.immediate || batchHasSpace)
return;
if (this.#pendingFlush.immediate || batchHasSpace) return;
this.timers.clearTimeout(this.#pendingFlush.timeout), this.#pendingFlush = void 0;

@@ -273,4 +270,3 @@ }

message = async (req) => {
if (this.#maybeConsumer === void 0)
return new Response();
if (this.#maybeConsumer === void 0) return new Response();
validateMessageSize(req.headers);

@@ -284,4 +280,3 @@ let contentType = validateContentType(req.headers), delay = validateMessageDelay(req.headers) ?? this.#maybeProducer?.deliveryDelay, body = Buffer2.from(await req.arrayBuffer());

batch = async (req) => {
if (this.#maybeConsumer === void 0)
return new Response();
if (this.#maybeConsumer === void 0) return new Response();
validateBatchSize(req.headers);

@@ -288,0 +283,0 @@ let delay = validateMessageDelay(req.headers) ?? this.#maybeProducer?.deliveryDelay, body = QueuesBatchRequestSchema.parse(await req.json());

69

dist/src/workers/r2/bucket.worker.js

@@ -494,4 +494,3 @@ var __defProp = Object.defineProperty;

for (let i = 0; i < x.length; i++)
if (x.charCodeAt(i) >= 256)
return x.length * 2;
if (x.charCodeAt(i) >= 256) return x.length * 2;
return x.length;

@@ -521,13 +520,10 @@ }

let ranges = parseRanges(options.rangeHeader, size);
if (ranges?.length === 1)
return ranges[0];
if (ranges?.length === 1) return ranges[0];
} else if (options.range !== void 0) {
let { offset, length, suffix } = options.range;
if (suffix !== void 0) {
if (suffix <= 0)
throw new InvalidRange();
if (suffix <= 0) throw new InvalidRange();
suffix > size && (suffix = size), offset = size - suffix, length = suffix;
}
if (offset === void 0 && (offset = 0), length === void 0 && (length = size - offset), offset < 0 || offset > size || length <= 0)
throw new InvalidRange();
if (offset === void 0 && (offset = 0), length === void 0 && (length = size - offset), offset < 0 || offset > size || length <= 0) throw new InvalidRange();
return offset + length > size && (length = size - offset), { start: offset, end: offset + length - 1 };

@@ -542,4 +538,3 @@ }

metadataSize(customMetadata) {
if (customMetadata === void 0)
return this;
if (customMetadata === void 0) return this;
let metadataLength = 0;

@@ -574,4 +569,3 @@ for (let [key, value] of Object.entries(customMetadata))

async transform(chunk, controller) {
for (let hash of hashes)
await hash.writer.write(chunk);
for (let hash of hashes) await hash.writer.write(chunk);
controller.enqueue(chunk);

@@ -600,4 +594,3 @@ },

let hash = createHash("md5");
for (let md5Hex of md5Hexes)
hash.update(md5Hex, "hex");
for (let md5Hex of md5Hexes) hash.update(md5Hex, "hex");
return `${hash.digest("hex")}-${md5Hexes.length}`;

@@ -610,4 +603,3 @@ }

let metadataSize = parseInt(req.headers.get(R2Headers.METADATA_SIZE));
if (Number.isNaN(metadataSize))
throw new InvalidMetadata();
if (Number.isNaN(metadataSize)) throw new InvalidMetadata();
assert2(req.body !== null);

@@ -619,4 +611,3 @@ let body = req.body, [metadataBuffer, value] = await readPrefix(body, metadataSize), metadataJson = decoder.decode(metadataBuffer);

let header = req.headers.get(R2Headers.REQUEST);
if (header === null)
throw new InvalidMetadata();
if (header === null) throw new InvalidMetadata();
return R2BindingRequestSchema.parse(JSON.parse(header));

@@ -730,6 +721,4 @@ }

let partRows = stmtDeletePartsByKey({ object_key: key });
for (let partRow of partRows)
oldBlobIds.push(partRow.blob_id);
} else
maybeOldBlobId !== void 0 && oldBlobIds.push(maybeOldBlobId);
for (let partRow of partRows) oldBlobIds.push(partRow.blob_id);
} else maybeOldBlobId !== void 0 && oldBlobIds.push(maybeOldBlobId);
}

@@ -799,4 +788,3 @@ return oldBlobIds;

for (let { part } of selectedParts) {
if (partNumberSet.has(part))
throw new InternalError();
if (partNumberSet.has(part)) throw new InternalError();
partNumberSet.add(part);

@@ -826,6 +814,4 @@ }

let partRows2 = stmtDeletePartsByKey({ object_key: key });
for (let partRow of partRows2)
oldBlobIds.push(partRow.blob_id);
} else
maybeOldBlobId !== void 0 && oldBlobIds.push(maybeOldBlobId);
for (let partRow of partRows2) oldBlobIds.push(partRow.blob_id);
} else maybeOldBlobId !== void 0 && oldBlobIds.push(maybeOldBlobId);
let totalSize = parts.reduce((acc, { size }) => acc + size, 0), etag = generateMultipartEtag(

@@ -852,4 +838,3 @@ parts.map(({ checksum_md5 }) => checksum_md5)

let partRows = stmtDeleteUnlinkedPartsByUploadId({ upload_id });
for (let partRow of partRows)
oldBlobIds.push(partRow.blob_id);
for (let partRow of partRows) oldBlobIds.push(partRow.blob_id);
return stmtUpdateUploadState({

@@ -946,4 +931,3 @@ upload_id,

let row = get(this.#stmts.getByKey({ key }));
if (row === void 0)
throw new NoSuchKey();
if (row === void 0) throw new NoSuchKey();
let range = { offset: 0, length: row.size };

@@ -955,4 +939,3 @@ return new InternalR2Object(row, range);

let result = this.#stmts.getPartsByKey(key);
if (result === void 0)
throw new NoSuchKey();
if (result === void 0) throw new NoSuchKey();
let { row, parts } = result, defaultR2Range = { offset: 0, length: row.size };

@@ -976,4 +959,3 @@ try {

value = this.#assembleMultipartValue(parts, range ?? defaultRange);
} else if (value = await this.blob.get(row.blob_id, range), value === null)
throw new NoSuchKey();
} else if (value = await this.blob.get(row.blob_id, range), value === null) throw new NoSuchKey();
return new InternalR2ObjectBody(row, value, r2Range);

@@ -1004,4 +986,3 @@ }

if (oldBlobIds !== void 0)
for (let blobId2 of oldBlobIds)
this.#backgroundDelete(blobId2);
for (let blobId2 of oldBlobIds) this.#backgroundDelete(blobId2);
return new InternalR2Object(row);

@@ -1011,7 +992,5 @@ }

Array.isArray(keys) || (keys = [keys]);
for (let key of keys)
validate.key(key);
for (let key of keys) validate.key(key);
let oldBlobIds = this.#stmts.deleteByKeys(keys);
for (let blobId of oldBlobIds)
this.#backgroundDelete(blobId);
for (let blobId of oldBlobIds) this.#backgroundDelete(blobId);
}

@@ -1096,4 +1075,3 @@ #listWithoutDelimiterQuery(excludeHttp, excludeCustom) {

);
for (let blobId of oldBlobIds)
this.#backgroundDelete(blobId);
for (let blobId of oldBlobIds) this.#backgroundDelete(blobId);
return new InternalR2Object(newRow);

@@ -1104,4 +1082,3 @@ }

let oldBlobIds = this.#stmts.abortMultipartUpload(key, uploadId);
for (let blobId of oldBlobIds)
this.#backgroundDelete(blobId);
for (let blobId of oldBlobIds) this.#backgroundDelete(blobId);
}

@@ -1108,0 +1085,0 @@ get = async (req) => {

79

dist/src/workers/shared/index.worker.js

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

@@ -50,4 +53,3 @@ function base64Encode(value) {

let headers = range === void 0 ? {} : rangeHeaders(range), res = await fetcher.fetch(url, { headers });
if (res.status === 404)
return null;
if (res.status === 404) return null;
if (assert(res.ok && res.body !== null), range !== void 0 && res.status !== 206) {

@@ -86,4 +88,3 @@ let contentLength = parseInt(res.headers.get("Content-Length"));

let res = await fetcher.fetch(url, { method: "HEAD" });
if (res.status === 404)
return null;
if (res.status === 404) return null;
assert(res.ok);

@@ -151,7 +152,5 @@ let contentLength = parseInt(res.headers.get("Content-Length"));

async delete(id) {
if (this.#stickyBlobs)
return;
if (this.#stickyBlobs) return;
let idURL = this.idURL(id);
if (idURL === null)
return;
if (idURL === null) return;
let res = await this.#fetcher.fetch(idURL, { method: "DELETE" });

@@ -215,4 +214,3 @@ assert(res.ok || res.status === 404);

let result;
for (let row of cursor)
result ??= row;
for (let row of cursor) result ??= row;
return result;

@@ -294,4 +292,3 @@ }

let row = get(this.#stmts.getByKey(key));
if (row === void 0)
return null;
if (row === void 0) return null;
if (this.#hasExpired(row))

@@ -331,4 +328,3 @@ return drain(this.#stmts.deleteByKey({ key })), this.#backgroundDelete(row.blob_id), null;

}), rows = Array.from(rowsCursor), expiredRows = this.#stmts.deleteExpired({ now });
for (let row of expiredRows)
this.#backgroundDelete(row.blob_id);
for (let row of expiredRows) this.#backgroundDelete(row.blob_id);
let hasMoreRows = rows.length === opts.limit + 1;

@@ -343,8 +339,4 @@ rows.splice(opts.limit, 1);

function testRegExps(matcher, value) {
for (let exclude of matcher.exclude)
if (exclude.test(value))
return !1;
for (let include of matcher.include)
if (include.test(value))
return !0;
for (let exclude of matcher.exclude) if (exclude.test(value)) return !1;
for (let include of matcher.include) if (include.test(value)) return !0;
return !1;

@@ -378,4 +370,3 @@ }

let url = new URL(req.url), methodRoutes = this.#routes?.get(req.method);
if (methodRoutes === void 0)
return new Response(null, { status: 405 });
if (methodRoutes === void 0) return new Response(null, { status: 405 });
let handlers = this;

@@ -385,4 +376,3 @@ try {

let match = path.exec(url.pathname);
if (match !== null)
return await handlers[key](req, match.groups, url);
if (match !== null) return await handlers[key](req, match.groups, url);
}

@@ -431,9 +421,7 @@ return new Response(null, { status: 404 });

clearTimeout(handle) {
if (typeof handle == "number")
return clearTimeout(handle);
if (typeof handle == "number") return clearTimeout(handle);
this.#fakePendingTimeouts.delete(handle[kFakeTimerHandle]);
}
queueMicrotask(closure) {
if (this.#fakeTimestamp === void 0)
return queueMicrotask(closure);
if (this.#fakeTimestamp === void 0) return queueMicrotask(closure);
let result = closure();

@@ -503,4 +491,3 @@ result instanceof Promise && (this.#fakeRunningTasks.add(result), result.finally(() => this.#fakeRunningTasks.delete(result)));

get blob() {
if (this.#blob !== void 0)
return this.#blob;
if (this.#blob !== void 0) return this.#blob;
let maybeBlobsService = this.env[SharedBindings.MAYBE_SERVICE_BLOBS], stickyBlobs = !!this.env[SharedBindings.MAYBE_JSON_ENABLE_STICKY_BLOBS];

@@ -548,4 +535,3 @@ return assert5(

let controlOp = req?.cf?.miniflare?.controlOp;
if (controlOp !== void 0)
return this.#handleControlOp(controlOp);
if (controlOp !== void 0) return this.#handleControlOp(controlOp);
}

@@ -574,28 +560,21 @@ let name = req.cf?.miniflare?.name;

let prefixMatch = rangePrefixRegexp.exec(rangeHeader);
if (prefixMatch === null)
return;
if (rangeHeader = rangeHeader.substring(prefixMatch[0].length), rangeHeader.trimStart() === "")
return [];
if (prefixMatch === null) return;
if (rangeHeader = rangeHeader.substring(prefixMatch[0].length), rangeHeader.trimStart() === "") return [];
let ranges = rangeHeader.split(","), result = [];
for (let range of ranges) {
let match = rangeRegexp.exec(range);
if (match === null)
return;
if (match === null) return;
let { start, end } = match.groups;
if (start !== void 0 && end !== void 0) {
let rangeStart = parseInt(start), rangeEnd = parseInt(end);
if (rangeStart > rangeEnd || rangeStart >= length)
return;
if (rangeStart > rangeEnd || rangeStart >= length) return;
rangeEnd >= length && (rangeEnd = length - 1), result.push({ start: rangeStart, end: rangeEnd });
} else if (start !== void 0 && end === void 0) {
let rangeStart = parseInt(start);
if (rangeStart >= length)
return;
if (rangeStart >= length) return;
result.push({ start: rangeStart, end: length - 1 });
} else if (start === void 0 && end !== void 0) {
let suffix = parseInt(end);
if (suffix >= length)
return [];
if (suffix === 0)
continue;
if (suffix >= length) return [];
if (suffix === 0) continue;
result.push({ start: length - suffix, end: length - 1 });

@@ -635,4 +614,3 @@ } else

let resolve;
for (; (resolve = this.drainQueue.shift()) !== void 0; )
resolve();
for (; (resolve = this.drainQueue.shift()) !== void 0; ) resolve();
}

@@ -666,4 +644,3 @@ }

let resolve;
for (; (resolve = this.resolveQueue.shift()) !== void 0; )
resolve();
for (; (resolve = this.resolveQueue.shift()) !== void 0; ) resolve();
}

@@ -670,0 +647,0 @@ }

45

package.json
{
"name": "miniflare",
"version": "0.0.0-2b6f14966",
"version": "0.0.0-2bc289e2e",
"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.20250124.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.20250121.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,3 +55,3 @@ "@types/estree": "^1.0.0",

"@types/mime": "^3.0.4",
"@types/node": "^18.19.59",
"@types/node": "^18.19.75",
"@types/stoppable": "^1.1.1",

@@ -64,11 +63,10 @@ "@types/which": "^2.0.1",

"ava": "^6.0.1",
"capnpc-ts": "^0.7.0",
"capnp-es": "^0.0.7",
"concurrently": "^8.2.2",
"devalue": "^4.3.0",
"devtools-protocol": "^0.0.1182435",
"esbuild": "0.17.19",
"eslint": "^8.49.0",
"esbuild": "0.24.2",
"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,9 +81,10 @@ "expect-type": "^0.15.0",

"source-map": "^0.6.1",
"typescript": "^5.7.2",
"which": "^2.0.2",
"@cloudflare/workers-shared": "0.0.0-2b6f14966",
"@cloudflare/kv-asset-handler": "0.3.4",
"@cloudflare/workflows-shared": "0.2.2"
"@cloudflare/workers-shared": "0.14.4",
"@cloudflare/workflows-shared": "0.2.3"
},
"engines": {
"node": ">=16.13"
"node": ">=18.0.0"
},

@@ -103,3 +102,3 @@ "volta": {

"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\"",

@@ -106,0 +105,0 @@ "check:type": "tsc",

7

README.md

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

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

Sorry, the diff of this file is not supported yet

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

Sorry, the diff of this file is not supported yet

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

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

dist/src/workers/assets/assets.worker.js.map

Sorry, the diff of this file is not supported yet

dist/src/workers/assets/router.worker.js

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

dist/src/workers/assets/router.worker.js.map

Sorry, the diff of this file is not supported yet

dist/src/workers/cache/cache-entry.worker.js.map

Sorry, the diff of this file is not supported yet

dist/src/workers/cache/cache.worker.js.map

Sorry, the diff of this file is not supported yet

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

Sorry, the diff of this file is not supported yet

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

Sorry, the diff of this file is not supported yet

dist/src/workers/kv/namespace.worker.js.map

Sorry, the diff of this file is not supported yet

dist/src/workers/kv/sites.worker.js.map

Sorry, the diff of this file is not supported yet

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

Sorry, the diff of this file is not supported yet

dist/src/workers/r2/bucket.worker.js.map

Sorry, the diff of this file is not supported yet

dist/src/workers/ratelimit/ratelimit.worker.js.map

Sorry, the diff of this file is not supported yet

dist/src/workers/shared/index.worker.js.map

Sorry, the diff of this file is not supported yet

dist/src/workers/shared/zod.worker.js

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

dist/src/workers/shared/zod.worker.js.map

Sorry, the diff of this file is not supported yet

dist/src/workers/workflows/binding.worker.js

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

dist/src/workers/workflows/binding.worker.js.map

Sorry, the diff of this file is not supported yet