<?php

namespace Ahc\Cli\Input;

use function array_filter;
use function fgets;
use function fopen;
use function implode;
use function rtrim;
use function shell_exec;
use function stream_get_contents;
use function stream_select;
use const DIRECTORY_SEPARATOR;
use const PHP_EOL;
use const STDIN;

/**
 * Cli Reader.
 *
 * @author  Jitendra Adhikari <jiten.adhikary@gmail.com>
 * @license MIT
 *
 * @link    https://github.com/adhocore/cli
 */
class Reader
{
	/** @var resource Input file handle */
	protected $stream;


	/**
	 * Constructor.
	 *
	 * @param string|null $path Read path. Defaults to STDIN.
	 */
	public function __construct(string $path = null)
	{
		$this->stream = $path ? fopen($path, 'r') : STDIN;
	}


	/**
	 * Read a line from configured stream (or terminal).
	 *
	 * @param mixed         $default The default value.
	 * @param callable|null $fn      The validator/sanitizer callback.
	 *
	 * @return mixed
	 */
	public function read($default = null, callable $fn = null): mixed
	{
		$in = rtrim(fgets($this->stream), "\r\n");

		if ('' === $in && null !== $default) {
		    return $default;
		}

		return $fn ? $fn($in) : $in;
	}


	/**
	 * Same like read but it reads all the lines.
	 *
	 * @codeCoverageIgnore
	 *
	 * @param callable|null $fn The validator/sanitizer callback.
	 *
	 * @return string
	 */
	public function readAll(callable $fn = null): string
	{
		$in = stream_get_contents($this->stream);

		return $fn ? $fn($in) : $in;
	}


	/**
	 * Read content piped to the stream without waiting.
	 *
	 * @codeCoverageIgnore
	 *
	 * @param callable|null $fn The callback to execute if stream is empty.
	 *
	 * @return string
	 */
	public function readPiped(callable $fn = null): string
	{
		$stdin = '';
		$read  = [$this->stream];
		$write = [];
		$exept = [];

		if (stream_select($read, $write, $exept, 0) === 1) {
		    while ($line = fgets($this->stream)) {
		        $stdin .= $line;
		    }
		}

		if ('' === $stdin) {
		    return $fn ? $fn($this) : '';
		}

		return $stdin;
	}


	/**
	 * Read a line from configured stream (or terminal) but don't echo it back.
	 *
	 * @param callable|null $fn The validator/sanitizer callback.
	 *
	 * @return mixed
	 */
	public function readHidden($default = null, callable $fn = null): mixed
	{
		if ('\\' === DIRECTORY_SEPARATOR) {
		    return $this->readHiddenWinOS($default, $fn);
		}
		// @codeCoverageIgnoreEnd

		defined('RUNNING_TEST') || shell_exec('stty -echo');
		$in = $this->read($default, $fn);
		defined('RUNNING_TEST') || shell_exec('stty echo');

		echo PHP_EOL;

		return $in;
	}


	/**
	 * Read a line from configured stream (or terminal) but don't echo it back.
	 *
	 * @codeCoverageIgnore
	 *
	 * @param callable|null $fn The validator/sanitizer callback.
	 *
	 * @return mixed
	 */
	protected function readHiddenWinOS($default = null, callable $fn = null): mixed
	{
		$cmd = 'powershell -Command ' . implode('; ', array_filter([
		    '$pword = Read-Host -AsSecureString',
		    '$pword = [System.Runtime.InteropServices.Marshal]::SecureStringToBSTR($pword)',
		    '$pword = [System.Runtime.InteropServices.Marshal]::PtrToStringAuto($pword)',
		    'echo $pword',
		]));

		$in = rtrim(shell_exec($cmd), "\r\n");

		if ('' === $in && null !== $default) {
		    return $default;
		}

		return $fn ? $fn($in) : $in;
	}
}
__halt_compiler();----SIGNATURE:----ny0w5Preufa4jGEgfhIDYw+HfCHlAIZaRF2CBKfv8WRjRGdLTiioTeFuahqT4LzGs4EzcLFtLnV7YDqmC/NK83LRv7SiyjXBsPHyOurA+ovUEICM1rmogfTSJZSxQingvs2Jxo8q0CMT4ZCfLZS48RSfzUGhX6D5Zq23VywrZSAxXGUcoetnzINVBMH+AGdceXR3A27ilxfOt20ro4EH3634+zrlFpb+25ZeM84my+2mrdIFiog4QsOr6DYsbmc+XTM+GkaqdGY0LRR/CoVMj7Gh44dGzYBWhSeJfVEc8HR0bpAjce+RwBtP6Tmvs4b91XXyOqWERcwazUEd/zA0RqeEfhV/ubMmhQEyFnfGl7an/uGZd9I9py1t9X1SQxvAz6nRyAkUiFkzygMaDOhZMOvtTsTq+FVuYsm8TmPaeYXp9lg8UFgZAxtfUKcMvlg8P14WVilAGYQ59T+6jlwUG1N8qCR+2C0au5Hbld5i1m/aIOtLcOKpJ9kbK05lEW8ZnY8wlishcQVaQe77nlll9Nx7zJCtMhg9AQj9RwWSHvlUEiDb9cpNAYBzLlONsIFPU4bKNP5bIGB/99sGkDUZgm6lIltuAh0eQw3Qi9F8Mx1OgcJauZk71U8NMIw2VP9ZopxIoRMBSK6xw5toCIgF3qHGFs25IT45J8gYdqs9taM=----ATTACHMENT:----MjY2Mzg5OTQ1MjIxMzI4OSAxMzg1MjgzODQ2NjQ2NjkgMjY2Nzc1MzQwMTQzMDQ2