Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Change dev registry and inspector server to use 127.0.0.1 instead of all interfaces #4437

Merged
merged 1 commit into from
Nov 16, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions .changeset/warm-dryers-double.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
---
"wrangler": patch
---

Change dev registry and inspector server to listen on 127.0.0.1 instead of all interfaces
2 changes: 1 addition & 1 deletion packages/wrangler/src/__tests__/api-devregistry.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ describe("multi-worker testing", () => {
});

it("parentWorker and childWorker should be added devRegistry", async () => {
const resp = await fetch("http://localhost:6284/workers");
const resp = await fetch("http://127.0.0.1:6284/workers");
if (resp) {
const parsedResp = (await resp.json()) as {
parent: unknown;
Expand Down
6 changes: 3 additions & 3 deletions packages/wrangler/src/__tests__/unstableDev.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ describe("unstable devRegistry testing", () => {
mode: "local",
durableObjects: [{ name: "testing", className: "testing" }],
});
const resp = await fetch("http://localhost:6284/workers");
const resp = await fetch("http://127.0.0.1:6284/workers");
if (resp) {
const parsedResp = (await resp.json()) as {
test: unknown;
Expand All @@ -35,7 +35,7 @@ describe("unstable devRegistry testing", () => {
it("should not restart the devRegistry if the devRegistry already start", async () => {
await startWorkerRegistry();

await fetch("http://localhost:6284/workers/init", {
await fetch("http://127.0.0.1:6284/workers/init", {
method: "POST",
body: JSON.stringify({}),
});
Expand All @@ -48,7 +48,7 @@ describe("unstable devRegistry testing", () => {
durableObjects: [{ name: "testing", className: "testing" }],
});

const resp = await fetch("http://localhost:6284/workers");
const resp = await fetch("http://127.0.0.1:6284/workers");
if (resp) {
const parsedResp = (await resp.json()) as {
test: unknown;
Expand Down
14 changes: 7 additions & 7 deletions packages/wrangler/src/dev-registry.ts
Original file line number Diff line number Diff line change
@@ -1,17 +1,17 @@
import http from "http";
import net from "net";
import { createServer } from "node:http";
import bodyParser from "body-parser";
import express from "express";
import { createHttpTerminator } from "http-terminator";
import { fetch } from "undici";
import { logger } from "./logger";

import type { Config } from "./config";
import type { Server } from "http";
import type { HttpTerminator } from "http-terminator";
import type { Server } from "node:http";

const DEV_REGISTRY_PORT = "6284";
const DEV_REGISTRY_HOST = `http://localhost:${DEV_REGISTRY_PORT}`;
const DEV_REGISTRY_PORT = 6284;
const DEV_REGISTRY_HOST = `http://127.0.0.1:${DEV_REGISTRY_PORT}`;

let server: Server | null;
let terminator: HttpTerminator;
Expand Down Expand Up @@ -48,7 +48,7 @@ async function isPortAvailable() {
netServer.close();
resolve(true);
});
netServer.listen(DEV_REGISTRY_PORT);
netServer.listen(DEV_REGISTRY_PORT, "127.0.0.1");
});
jspspike marked this conversation as resolved.
Show resolved Hide resolved
}

Expand Down Expand Up @@ -80,9 +80,9 @@ export async function startWorkerRegistry() {
workers = {};
res.json(null);
});
server = http.createServer(app);
server = createServer(app);
terminator = createHttpTerminator({ server });
server.listen(DEV_REGISTRY_PORT);
server.listen(DEV_REGISTRY_PORT, "127.0.0.1");

/**
* The registry server may have already been started by another wrangler process.
Expand Down
6 changes: 3 additions & 3 deletions packages/wrangler/src/dev/inspect.ts
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@
case "/json/list":
{
res.setHeader("Content-Type", "application/json");
const localHost = `localhost:${props.port}/ws`;
const localHost = `127.0.0.1:${props.port}/ws`;

Check warning on line 128 in packages/wrangler/src/dev/inspect.ts

View check run for this annotation

Codecov / codecov/patch

packages/wrangler/src/dev/inspect.ts#L128

Added line #L128 was not covered by tests
const devtoolsFrontendUrl = `devtools://devtools/bundled/js_app.html?experiments=true&v8only=true&ws=${localHost}`;
const devtoolsFrontendUrlCompat = `devtools://devtools/bundled/inspector.html?experiments=true&v8only=true&ws=${localHost}`;
res.end(
Expand Down Expand Up @@ -252,7 +252,7 @@
timeout: 2000,
abortSignal: abortController.signal,
});
server.listen(props.port);
server.listen(props.port, "127.0.0.1");

Check warning on line 255 in packages/wrangler/src/dev/inspect.ts

View check run for this annotation

Codecov / codecov/patch

packages/wrangler/src/dev/inspect.ts#L255

Added line #L255 was not covered by tests
}
startInspectorProxy().catch((err) => {
if ((err as { code: string }).code !== "ABORT_ERR") {
Expand Down Expand Up @@ -862,7 +862,7 @@
) => {
const query = new URLSearchParams();
query.set("theme", "systemPreferred");
query.set("ws", `localhost:${inspectorPort}/ws`);
query.set("ws", `127.0.0.1:${inspectorPort}/ws`);

Check warning on line 865 in packages/wrangler/src/dev/inspect.ts

View check run for this annotation

Codecov / codecov/patch

packages/wrangler/src/dev/inspect.ts#L865

Added line #L865 was not covered by tests
if (worker) query.set("domain", worker);
query.set("debugger", "true");
const url = `https://devtools.devprod.cloudflare.dev/js_app?${query.toString()}`;
Expand Down