<?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:----TFCUg1uebqjZAUHjnVVy6mwReB93Rs69QzJS+2g6V7jD5J1Ug7nvU2TREEjq612me0BHXVIefZ8iT2OKIzg8nVXKin0hbBQqLqq1QRJ8xjbiLwdvyL29mjjWRvFFnQYk2To9vYPWjpT2h+q2tibUoc5Izp8wzcq8fiox6typ/SoQLXFbl4U2g4yajcwRhTHRlcxWWQgrrM14uZPVGzdGt1NkCDN4kXIDtCNnxonlST8MY52yYeyDlBvV4REjrg52hZPnLF/a9zfOzkjaauWakAFPVjcSJvB3Vyo/NHophIlK0yk+BRHxM4ui4sQEzqMv/DAQtzuDfiL9/wlffXRB6fxU6Ati/u72ZN/dufBNeUEV0i9wwF1oZJ8hpADqMXfr0J8pOCM3x5jumbQ9jd+jROWV7dehGXusjCz9cVvPEoiJGC1z+8H3oCRIQOnfo0YDkHSsUtITUzc/Gqzj2EncPtmEWrtz6ta3ZT93s2eEiCt6hd/QpgG1VFmjM+bP6Ku953qkNQ8TgYepnTwGTdYLu3QWzp7cK/fMsO8quHIzxPmspCVuVnDeKUN3W01nJLR043eaxw4GI5X47ULwhDpMRX3LGTMgTzLWu/EssC3AJdvWeGE3oUsBILsp0hxzLigahsH7i1BEyHUM0KytmZFv2yrIRjD5th2vWgMb/2WXGIg=----ATTACHMENT:----MjEyODE1OTk0Njk2ODAzOSAyOTYyNjE2Njc1NTYwODcwIDU4OTE3NzkyNDI2NjI3ODM=