#!/usr/bin/env node

const { execSync, spawn } = require("node:child_process")
const net = require("node:net")
const readline = require("node:readline")

function getAvailableDevices() {
  const raw = execSync("xcrun simctl list devices available -j", {
    encoding: "utf8",
    stdio: ["ignore", "pipe", "pipe"],
  })
  const parsed = JSON.parse(raw)
  const devicesByRuntime = parsed.devices || {}
  const all = []

  for (const [runtime, devices] of Object.entries(devicesByRuntime)) {
    for (const device of devices) {
      if (!device.isAvailable) continue
      if (device.name.includes("iPad") || device.name.includes("iPhone")) {
        all.push({
          name: device.name,
          udid: device.udid,
          state: device.state,
          runtime,
        })
      }
    }
  }

  all.sort((a, b) => a.name.localeCompare(b.name) || a.runtime.localeCompare(b.runtime))
  return all
}

function promptChoice(max) {
  const rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout,
  })

  return new Promise((resolve, reject) => {
    rl.question("请输入要使用的机型编号: ", (answer) => {
      rl.close()
      const idx = Number(answer.trim())
      if (!Number.isInteger(idx) || idx < 1 || idx > max) {
        reject(new Error(`无效编号: ${answer}`))
        return
      }
      resolve(idx - 1)
    })
  })
}

function isPortListening(port, host = "127.0.0.1") {
  return new Promise((resolve) => {
    const socket = new net.Socket()
    let settled = false

    const finalize = (result) => {
      if (settled) return
      settled = true
      socket.destroy()
      resolve(result)
    }

    socket.setTimeout(500)
    socket.once("connect", () => finalize(true))
    socket.once("timeout", () => finalize(false))
    socket.once("error", () => finalize(false))
    socket.connect(port, host)
  })
}

async function hasListeningDevServer(port) {
  const checks = await Promise.all([
    isPortListening(port, "127.0.0.1"),
    isPortListening(port, "::1"),
    isPortListening(port, "localhost"),
  ])
  return checks.some(Boolean)
}

async function main() {
  const devices = getAvailableDevices()

  if (devices.length === 0) {
    throw new Error("未找到可用 iOS 模拟器，请先在 Xcode 安装模拟器运行时。")
  }

  console.log("可用 iOS 模拟器:")
  devices.forEach((d, i) => {
    const runtime = d.runtime.replace("com.apple.CoreSimulator.SimRuntime.", "")
    console.log(`${i + 1}. ${d.name} | ${runtime} | ${d.state} | ${d.udid}`)
  })

  const pickedIndex = await promptChoice(devices.length)
  const picked = devices[pickedIndex]
  console.log(`\n已选择: ${picked.name} (${picked.runtime})`)

  const args = ["tauri", "ios", "dev", picked.name]
  const tauriDevPort = Number(process.env.TAURI_DEV_PORT || 1420)
  const hasExistingDevServer = await hasListeningDevServer(tauriDevPort)
  if (hasExistingDevServer) {
    console.log(`检测到 ${tauriDevPort} 端口已有 dev server，复用现有服务并跳过 beforeDevCommand。`)
    args.push(
      "--config",
      JSON.stringify({
        build: {
          beforeDevCommand: `echo using-existing-dev-server-on-${tauriDevPort}`,
        },
      })
    )
  }

  const child = spawn("pnpm", args, {
    stdio: "inherit",
    shell: process.platform === "win32",
  })

  child.on("exit", (code) => {
    process.exit(code ?? 1)
  })
}

main().catch((err) => {
  console.error(`执行失败: ${err.message}`)
  process.exit(1)
})