).toBe(19003);

});

it("falls back to config when env ports exceed TCP bounds", () => {

expect(

resolveGatewayPort({ gateway: { port: 19003 } }, envWith({ OPENCLAW_GATEWAY_PORT: "65536" })),

).toBe(19003);

expect(

resolveGatewayPort(

{ gateway: { port: 19004 } },

envWith({ OPENCLAW_GATEWAY_PORT: "127.0.0.1:65536" }),

),

).toBe(19004);

expect(

resolveGatewayPort(

{ gateway: { port: 19005 } },

envWith({ OPENCLAW_GATEWAY_PORT: "[::1]:65536" }),

),

).toBe(19005);

});

it("falls back when malformed IPv6 inputs do not provide an explicit port", () => {

expect(

resolveGatewayPort({ gateway: { port: 19003 } }, envWith({ OPENCLAW_GATEWAY_PORT: "::1" })),

import os from "node:os";

import path from "node:path";

import { resolveHomeRelativePath, resolveRequiredHomeDir } from "../infra/home-dir.js";

import { parseStrictPositiveInteger } from "../infra/parse-finite-number.js";

import { parseTcpPort } from "../infra/tcp-port.js";

import type { OpenClawConfig } from "./types.js";

/**

return null;

}

if (/^\d+$/.test(trimmed)) {

return parseStrictPositiveInteger(trimmed) ?? null;

return parseTcpPort(trimmed);

}

// Docker Compose publish strings can leak into host CLI env loading via repo `.env`,

// for example `127.0.0.1:18789` or `[::1]:18789`. Accept only explicit host:port forms.

const bracketedIpv6Match = trimmed.match(/^\[[^\]]+\]:(\d+)$/);

if (bracketedIpv6Match?.[1]) {

return parseStrictPositiveInteger(bracketedIpv6Match[1]) ?? null;

return parseTcpPort(bracketedIpv6Match[1]);

}

const firstColon = trimmed.indexOf(":");

if (!/^\d+$/.test(suffix)) {

return null;

}

return parseStrictPositiveInteger(suffix) ?? null;

return parseTcpPort(suffix);

}

export function resolveGatewayPort(

);

});

it("omits out-of-range SSH discovery ports", async () => {

process.env.NODE_ENV = "development";

delete process.env.VITEST;

process.env.OPENCLAW_SSH_PORT = "65536";

const service = makeDiscoveryService({ id: "bonjour" });

await startGatewayDiscovery({

machineDisplayName: "Lab Mac",

port: 18789,

wideAreaDiscoveryEnabled: false,

tailscaleMode: "serve",

mdnsMode: "full",

gatewayDiscoveryServices: [service],

logDiscovery: makeLogs(),

});

expect(service.service.advertise).toHaveBeenCalledWith(

expect.objectContaining({ sshPort: undefined }),

);

});

it("continues startup when a local discovery service never settles", async () => {

vi.useFakeTimers();

process.env.NODE_ENV = "development";

import { isTruthyEnvValue } from "../infra/env.js";

import {

parseStrictNonNegativeInteger,

parseStrictPositiveInteger,

} from "../infra/parse-finite-number.js";

import { parseStrictPositiveInteger } from "../infra/parse-finite-number.js";

import { pickPrimaryTailnetIPv4, pickPrimaryTailnetIPv6 } from "../infra/tailnet.js";

import { parseTcpPort } from "../infra/tcp-port.js";

import { resolveWideAreaDiscoveryDomain, writeWideAreaGatewayZone } from "../infra/widearea-dns.js";

import type { PluginGatewayDiscoveryServiceRegistration } from "../plugins/registry-types.js";

import {

const tailnetDns = needsTailnetDns

? await resolveTailnetDnsHint({ enabled: tailscaleEnabled })

: undefined;

const sshPortEnv = mdnsMinimal ? undefined : process.env.OPENCLAW_SSH_PORT?.trim();

const sshPortParsed = parseStrictNonNegativeInteger(sshPortEnv);

const sshPort =

sshPortParsed !== undefined && sshPortParsed > 0 && sshPortParsed <= 65535

? sshPortParsed

: undefined;

const sshPort = mdnsMinimal

? undefined

: (parseTcpPort(process.env.OPENCLAW_SSH_PORT) ?? undefined);

const cliPath = mdnsMinimal ? undefined : resolveBonjourCliPath();

if (localDiscoveryEnabled) {