Remove unused handleQueue() function from entry worker (#678)

With #656, the Queues dispatcher is now implemented as part of the
broker Durable Object. We no longer send message batches directly
from Node.js, so can remove queue handling from the entry worker.

Note the magic proxy enqueues messages through queue producer
bindings like regular workers, so never used this endpoint directly.

Author: mrbbot

packages/miniflare/src/plugins/core/index.ts

@@ -523,9 +523,7 @@ export function getGlobalServices({
 			durableObjectNamespace: { className: "ProxyServer" },
 		},
 		// Add `proxyBindings` here, they'll be added to the `ProxyServer` `env`.
-		// It would be nice if we didn't add all these bindings to the entry worker,
-		// but the entry worker shares lots of `devalue` code with the proxy, and
-		// we'd rather not duplicate that.
+		// TODO(someday): consider making the proxy server a separate worker
 		...proxyBindings,
 	];
 	if (sharedOptions.upstream !== undefined) {

packages/miniflare/src/workers/core/constants.ts

@@ -3,7 +3,6 @@ export const CoreHeaders = {
 	ORIGINAL_URL: "MF-Original-URL",
 	ERROR_STACK: "MF-Experimental-Error-Stack",
 	ROUTE_OVERRIDE: "MF-Route-Override",
-	CUSTOM_EVENT: "MF-Custom-Event",
 
 	// API Proxy
 	OP: "MF-Op",

packages/miniflare/src/workers/core/entry.worker.ts

@@ -1,4 +1,3 @@
-import { unflatten } from "devalue";
 import {
 	Colorize,
 	blue,
@@ -11,7 +10,6 @@ import {
 } from "kleur/colors";
 import { LogLevel, SharedHeaders } from "miniflare:shared";
 import { CoreBindings, CoreHeaders } from "./constants";
-import { structuredSerializableRevivers } from "./devalue";
 import { STATUS_CODES } from "./http";
 import { WorkerRoute, matchRoutes } from "./routing";
 
@@ -188,21 +186,6 @@ function handleProxy(request: Request, env: Env) {
 	return stub.fetch(request);
 }
 
-async function handleQueue(
-	request: Request,
-	url: URL,
-	service: Fetcher,
-	startTime: number
-) {
-	const queueName = decodeURIComponent(url.pathname.substring(1));
-	const flattened = await request.json<number | unknown[]>();
-	const messages = unflatten(flattened, structuredSerializableRevivers);
-	const queueResponse = await service.queue(queueName, messages);
-	(queueResponse as FetcherQueueResult & { time: number }).time =
-		Date.now() - startTime;
-	return Response.json(queueResponse);
-}
-
 async function handleScheduled(
 	params: URLSearchParams,
 	service: Fetcher
@@ -243,11 +226,6 @@ export default <ExportedHandler<Env>>{
 		}
 
 		try {
-			const customEvent = request.headers.get(CoreHeaders.CUSTOM_EVENT);
-			if (customEvent === "queue") {
-				return await handleQueue(request, url, service, startTime);
-			}
-
 			if (url.pathname === "/cdn-cgi/mf/scheduled") {
 				return await handleScheduled(url.searchParams, service);
 			}