update workerd version

Author: teresalves

packages/miniflare/src/workers/kv/namespace.worker.ts

@@ -3,14 +3,14 @@ import {
 	DeferredPromise,
 	DELETE,
 	GET,
-	POST,
 	HttpError,
+	KeyValueEntry,
 	KeyValueStorage,
 	maybeApply,
 	MiniflareDurableObject,
+	POST,
 	PUT,
 	RouteHandler,
-	KeyValueEntry,
 } from "miniflare:shared";
 import { KVHeaders, KVLimits, KVParams } from "./constants";
 import {
@@ -75,10 +75,14 @@ function secondsToMillis(seconds: number): number {
 	return seconds * 1000;
 }
 
-async function processKeyValue(obj: KeyValueEntry<unknown> | null, type: string = "text", withMetadata: boolean = false) {
+async function processKeyValue(
+	obj: KeyValueEntry<unknown> | null,
+	type: string = "text",
+	withMetadata: boolean = false
+) {
 	const decoder = new TextDecoder();
 	let r = "";
-	if(obj?.value) {
+	if (obj?.value) {
 		for await (const chunk of obj?.value) {
 			r += decoder.decode(chunk, { stream: true });
 		}
@@ -89,16 +93,22 @@ async function processKeyValue(obj: KeyValueEntry<unknown> | null, type: string
 	try {
 		val = obj?.value == null ? null : type === "json" ? JSON.parse(r) : r;
 	} catch (err: any) {
-		throw new HttpError(400, "At least of of the requested keys corresponds to a non-JSON value");
+		throw new HttpError(
+			400,
+			"At least of of the requested keys corresponds to a non-JSON value"
+		);
 	}
 	if (val == null) {
 		return null;
 	}
 	if (withMetadata) {
-		return { value: val, metadata: obj?.metadata ? JSON.stringify(obj?.metadata) : null };
+		return {
+			value: val,
+			metadata: obj?.metadata ? JSON.stringify(obj?.metadata) : null,
+		};
 	}
 	return val;
-  }
+}
 
 export class KVNamespaceObject extends MiniflareDurableObject {
 	#storage?: KeyValueStorage;
@@ -115,7 +125,8 @@ export class KVNamespaceObject extends MiniflareDurableObject {
 		const cacheTtlParam = url.searchParams.get(KVParams.CACHE_TTL);
 		const cacheTtl =
 			cacheTtlParam === null ? undefined : parseInt(cacheTtlParam);
-		if(req.body != null) { // get bulk
+		if (req.method === "POST" && req.body != null) {
+			// get bulk
 			// get bulk
 			let r = "";
 			const decoder = new TextDecoder();
@@ -125,11 +136,15 @@ export class KVNamespaceObject extends MiniflareDurableObject {
 			r += decoder.decode();
 			const parsedBody = JSON.parse(r);
 			const keys: string[] = parsedBody.keys;
-			const obj: {[key: string]: any} = {};
-			for(const key of keys) {
+			const obj: { [key: string]: any } = {};
+			for (const key of keys) {
 				validateGetOptions(key, { cacheTtl: parsedBody?.cacheTtl });
 				const entry = await this.storage.get(key);
-				obj[key] = await processKeyValue(entry, parsedBody?.type, parsedBody?.withMetadata);
+				obj[key] = await processKeyValue(
+					entry,
+					parsedBody?.type,
+					parsedBody?.withMetadata
+				);
 			}
 			return new Response(JSON.stringify(obj));
 		}

packages/miniflare/test/plugins/kv/index.spec.ts

@@ -122,6 +122,17 @@ test("get: returns value", async (t) => {
 	const result = await kv.get("key");
 	t.is(result, "value");
 });
+
+// test("bulk get: returns value", async (t) => {
+// 	const { kv } = t.context;
+// 	await kv.put("key", "value");
+// 	const result = await kv.get(["key"]);
+// 	const expectedResult = new Map([
+// 		['key', 'value1'],
+// 	]);
+// 	t.is(result, expectedResult);
+// });
+
 test("get: returns null for non-existent keys", async (t) => {
 	const { kv } = t.context;
 	t.is(await kv.get("key"), null);