validateRequestFrame,

validateResponseFrame,

} from "./protocol/index.js";

import { resolveGatewayStartupRetryAfterMs } from "./protocol/startup-unavailable.js";

type Pending = {

resolve: (value: unknown) => void;

1006: "abnormal closure (no close frame)",

1008: "policy violation",

1012: "service restart",

1013: "try again later",

};

export function describeGatewayCloseCode(code: number): string | undefined {

private reconnectTimer: NodeJS.Timeout | null = null;

private pendingDeviceTokenRetry = false;

private deviceTokenRetryBudgetUsed = false;

private pendingStartupReconnectDelayMs: number | null = null;

private pendingConnectErrorDetailCode: string | null = null;

// Track last tick to detect silent stalls.

private lastTick: number | null = null;

}

this.socketOpened = false;

this.resolvePendingStop(ws);

if (this.pendingStartupReconnectDelayMs !== null) {

this.scheduleReconnect();

return;

}

// Clear persisted device auth state only when device-token auth was active.

// Shared token/password failures can return the same close reason but should

// not erase a valid cached device token.

this.closed = true;

this.pendingDeviceTokenRetry = false;

this.deviceTokenRetryBudgetUsed = false;

this.pendingStartupReconnectDelayMs = null;

this.pendingConnectErrorDetailCode = null;

this.clearReconnectTimer();

if (this.tickTimer) {

.then((helloOk) => {

this.pendingDeviceTokenRetry = false;

this.deviceTokenRetryBudgetUsed = false;

this.pendingStartupReconnectDelayMs = null;

this.pendingConnectErrorDetailCode = null;

const authInfo = helloOk?.auth;

if (authInfo?.deviceToken && this.opts.deviceIdentity) {

this.deviceTokenRetryBudgetUsed = true;

this.backoffMs = Math.min(this.backoffMs, 250);

}

const startupRetryAfterMs = resolveGatewayStartupRetryAfterMs(err);

if (startupRetryAfterMs !== null) {

this.pendingStartupReconnectDelayMs = startupRetryAfterMs;

logDebug(`gateway connect failed: ${String(err)}`);

this.ws?.close(1013, "gateway starting");

return;

}

this.opts.onConnectError?.(err instanceof Error ? err : new Error(String(err)));

const msg = `gateway connect failed: ${String(err)}`;

if (this.opts.mode === GATEWAY_CLIENT_MODES.PROBE || isGatewayClientStoppedError(err)) {

this.tickTimer = null;

}

this.clearReconnectTimer();

const delay = this.backoffMs;

this.backoffMs = Math.min(this.backoffMs * 2, 30_000);

const startupDelay = this.pendingStartupReconnectDelayMs;

this.pendingStartupReconnectDelayMs = null;

const delay = startupDelay ?? this.backoffMs;

if (startupDelay === null) {

this.backoffMs = Math.min(this.backoffMs * 2, 30_000);

}

this.reconnectTimer = setTimeout(() => {

this.reconnectTimer = null;

this.start();