test_that("pty works on windows", {
  skip_other_platforms("windows")
  skip_on_cran()

  px <- get_tool("px")
  p <- process$new(px, c("outln", "hello", "sleep", "10"), pty = TRUE)
  on.exit(p$kill(), add = TRUE)
  expect_true(p$is_alive())

  con <- p$get_output_connection()
  out <- ""
  repeat {
    pr <- poll(list(con), 2000L)[[1]]
    if (!identical(pr, "ready")) {
      break
    }
    out <- paste0(out, p$read_output())
    if (grepl("hello", out, fixed = TRUE)) break
  }
  expect_match(out, "hello")
})

test_that("pty write_input works on windows", {
  skip_other_platforms("windows")
  skip_on_cran()

  # Use px cat <stdin> instead of cmd.exe: px reads stdin and echoes to stdout,
  # no banner to flush, no cmd.exe overhead or security-software interference.
  px <- get_tool("px")
  p <- process$new(px, c("cat", "<stdin>"), pty = TRUE)
  on.exit(p$kill(), add = TRUE)
  expect_true(p$is_alive())

  con <- p$get_output_connection()

  p$write_input("hello\r\n")
  # Poll the stdout connection directly (not the full process) to avoid the
  # poll_pipe-forces-timeout-0 effect when the process has already exited.
  # Loop to skip VT init sequences that ConPTY writes before any child output.
  out <- ""
  repeat {
    pr <- poll(list(con), 2000L)[[1]]
    if (!identical(pr, "ready")) {
      break
    }
    out <- paste0(out, p$read_output())
    if (grepl("hello", out, fixed = TRUE)) break
  }
  expect_match(out, "hello")
})

test_that("pty works", {
  skip_other_platforms("unix")
  skip_on_os("solaris")
  skip_on_cran()

  p <- process$new("cat", pty = TRUE)
  on.exit(p$kill(), add = TRUE)
  expect_true(p$is_alive())
  if (!p$is_alive()) {
    stop("process not running")
  }

  pr <- p$poll_io(0)
  expect_equal(pr[["output"]], "timeout")

  p$write_input("foobar\n")
  pr <- p$poll_io(300)
  expect_equal(pr[["output"]], "ready")
  if (pr[["output"]] != "ready") {
    stop("no output")
  }
  expect_equal(p$read_output(), "foobar\r\n")
})

test_that("pty echo", {
  skip_other_platforms("unix")
  skip_on_os("solaris")
  skip_on_cran()

  p <- process$new("cat", pty = TRUE, pty_options = list(echo = TRUE))
  on.exit(p$kill(), add = TRUE)
  expect_true(p$is_alive())
  if (!p$is_alive()) {
    stop("process not running")
  }

  pr <- p$poll_io(0)
  expect_equal(pr[["output"]], "timeout")

  p$write_input("foo")
  pr <- p$poll_io(300)
  expect_equal(pr[["output"]], "ready")
  if (pr[["output"]] != "ready") {
    stop("no output")
  }
  expect_equal(p$read_output(), "foo")

  p$write_input("bar\n")
  pr <- p$poll_io(300)
  expect_equal(pr[["output"]], "ready")
  if (pr[["output"]] != "ready") {
    stop("no output")
  }
  expect_equal(p$read_output(), "bar\r\nfoobar\r\n")
})

test_that("pty captures output from a short-lived process", {
  skip_other_platforms("unix")
  skip_on_os("solaris")
  skip_on_cran()

  px <- get_tool("px")
  p <- process$new(px, "--help", pty = TRUE)
  on.exit(p$kill(), add = TRUE)
  p$wait(5000)

  pr <- p$poll_io(1000)
  expect_equal(pr[["output"]], "ready")

  out <- p$read_output()
  expect_true(nchar(out) > 0)
})

test_that("read_output_lines() fails for pty", {
  skip_if_no_srcrefs()
  skip_other_platforms("unix")
  skip_on_os("solaris")
  skip_on_cran()

  p <- process$new("cat", pty = TRUE)
  p$write_input("foobar\n")
  expect_snapshot(error = TRUE, p$read_output_lines())

  pr <- p$poll_io(300)
  expect_equal(pr[["output"]], "ready")
  if (pr[["output"]] != "ready") {
    stop("no output")
  }
  expect_equal(p$read_output(), "foobar\r\n")
})