wrangler >=4.125.0 added `connect`. Configure connect with protocol tcp and a port to receive raw socket connections during wrangler dev in the Worker connect(socket, env, ctx) handler. Older versions don't have it.

const { spawnSync } = require("child_process");
const fs = require("fs");
const path = require("path");
const dir = "/w/proj";
fs.rmSync(dir, { recursive: true, force: true });
fs.mkdirSync(dir, { recursive: true });
const home = fs.mkdtempSync("/tmp/home-");
function wrangler(args, extraEnv, dropEnv) {
  const env = Object.assign({}, process.env, { CI: "1", WRANGLER_SEND_METRICS: "false", NO_COLOR: "1", FORCE_COLOR: "0", HOME: home }, extraEnv || {});
  for (const k of dropEnv || []) delete env[k];
  const r = spawnSync(process.execPath, ["--no-warnings", "/w/node_modules/wrangler/wrangler-dist/cli.js", ...args], { cwd: dir, encoding: "utf8", timeout: 40000, env });
  const out = (String(r.stdout || "") + String(r.stderr || "")).replace(/\x1b\[[0-9;]*m/g, "");
  return { status: r.status, out };
}
function symptom(msg) { console.error("FAIL: " + msg); process.exit(1); }
function broken(msg, out) {
  console.error("ERROR: " + msg);
  if (out) console.error(out.slice(-2000));
  process.exit(2);
}
function write(name, content) {
  fs.writeFileSync(path.join(dir, name), typeof content === "string" ? content : JSON.stringify(content, null, 2));
}
write("index.js", 'export default { fetch() { return new Response("ok"); } };\n');
const cfg = (port) => ({ name: "connect-trigger", main: "index.js", compatibility_date: "2026-01-01", connect: [{ protocol: "tcp", port }] });
write("wrangler.json", cfg(5432));
let r = wrangler(["deploy", "--dry-run", "--outdir", "out"]);
if (/Unexpected fields found in top-level field: "connect"/.test(r.out)) symptom("connect is an unexpected top-level field");
if (r.status !== 0 || !r.out.includes("--dry-run: exiting now.")) broken("dry run with a connect entry failed", r.out);
write("wrangler.json", cfg(70000));
r = wrangler(["deploy", "--dry-run", "--outdir", "out2"]);
if (r.status === 0 || !r.out.includes('should have an integer "port" field between 1 and 65535')) broken("connect port 70000 was not rejected", r.out);
console.log("OK: connect entries are validated");

const { spawnSync } = require("child_process");
const fs = require("fs");
const path = require("path");
const dir = "/w/proj";
fs.rmSync(dir, { recursive: true, force: true });
fs.mkdirSync(dir, { recursive: true });
const home = fs.mkdtempSync("/tmp/home-");
function wrangler(args, extraEnv, dropEnv) {
  const env = Object.assign({}, process.env, { CI: "1", WRANGLER_SEND_METRICS: "false", NO_COLOR: "1", FORCE_COLOR: "0", HOME: home }, extraEnv || {});
  for (const k of dropEnv || []) delete env[k];
  const r = spawnSync(process.execPath, ["--no-warnings", "/w/node_modules/wrangler/wrangler-dist/cli.js", ...args], { cwd: dir, encoding: "utf8", timeout: 40000, env });
  const out = (String(r.stdout || "") + String(r.stderr || "")).replace(/\x1b\[[0-9;]*m/g, "");
  return { status: r.status, out };
}
function symptom(msg) { console.error("FAIL: " + msg); process.exit(1); }
function broken(msg, out) {
  console.error("ERROR: " + msg);
  if (out) console.error(out.slice(-2000));
  process.exit(2);
}
function write(name, content) {
  fs.writeFileSync(path.join(dir, name), typeof content === "string" ? content : JSON.stringify(content, null, 2));
}
write("index.js", 'export default { fetch() { return new Response("ok"); } };\n');
const cfg = (port) => ({ name: "connect-trigger", main: "index.js", compatibility_date: "2026-01-01", connect: [{ protocol: "tcp", port }] });
write("wrangler.json", cfg(5432));
let r = wrangler(["deploy", "--dry-run", "--outdir", "out"]);
if (/Unexpected fields found in top-level field: "connect"/.test(r.out)) symptom("connect is an unexpected top-level field");
if (r.status !== 0 || !r.out.includes("--dry-run: exiting now.")) broken("dry run with a connect entry failed", r.out);
write("wrangler.json", cfg(70000));
r = wrangler(["deploy", "--dry-run", "--outdir", "out2"]);
if (r.status === 0 || !r.out.includes('should have an integer "port" field between 1 and 65535')) broken("connect port 70000 was not rejected", r.out);
console.log("OK: connect entries are validated");