Function createNativeTunnel

packages/cli/src/commands/dev.ts:526–558

(
  hostname: string,
  port: number,
  https: boolean,
  triggerApi: TriggerApi,
  spinner: Ora
)

let yaltTunnel: YaltTunnel | null = null;

async function createNativeTunnel(
  hostname: string,
  port: number,
  https: boolean,
  triggerApi: TriggerApi,
  spinner: Ora
) {
  try {
    const response = await triggerApi.createTunnel();

    // import WS dynamically
    const WebSocket = await import("ws");

    yaltTunnel = new YaltTunnel(
      response.url,
      `${hostname}:${port}`,
      https,
      {
        WebSocket: WebSocket.default,
        connectionTimeout: getConnectionTimeoutValue(),
        maxRetries: 10,
      },
      { verbose: process.env.TUNNEL_VERBOSE === "1" }
    );

    await yaltTunnel.connect();

    return `https://${response.url}`;
  } catch (e) {
    spinner.fail(`Failed to create tunnel.\n${e}`);
    return;
  }
}

function getConnectionTimeoutValue() {
  if (typeof process.env.TUNNEL_CONNECTION_TIMEOUT === "string") {