<?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:----ul1b33ro2vjcBf4bOBknAy2driTHNHQtSjqAiu1Qp5nDBf9ImtpRFQg7MsPbZzzblw1d21lLVeWDliglkdLoPpmZ+JbSIOpQCiy/W42O67l7MkYiv5zxOmQFpclBF0RSpatU8y4KBaebEHPDz3088OX/U9PjEyR2FyleXw55JnN9c7j6z7pXdTJbX2S0jv99plg/9u4lmZMtqKhGYH78/7B/Sre+edwP0YSoM/Q+jqCBCngVOtoVj896zUA9fzR5Gxqlsh9Pshg98b0xSWCEZRcOA/LkXbOGq9M1MUdMGscEXKNPLHFQ/cKzM3fZKAx1/uF3Uq/ecQB7K51S48wlsB0m1wLqdD3Z0LwBuRf6l7ES+Q0lHmNRGVSJ3YDooFCHRPSuGA2TLHYyDIgaKKI3ATrREwPpdweXs+bA2lRjiWI2eo0BV47xoIO1VJBlLJUdIBSY6dWVcBHDSZdPc+ASX3l/Le32pkYH+pE5+SDUQgNOYuzL3dD8l19HvbqdFx/wns9mMklNMxFUmkhpVzKivWsWLx1KCWpKjG+yUcofw6r7URXTgLGOE+Js0R7MyuOcI2b7bjFAJikIg5U8Fy7lOEPQerOvOeX6+36XwOQz4GKXj9XEdshSHfViyw3GlV0/WNtYDcfwqhMRqI4+9gxtQQINwT8OIUluWYYTXBjvGJM=----ATTACHMENT:----MTgxNDg0OTkzMzc3ODQ4MCA4MzMxMDMwODk4Njk1NDM3IDc0MTI3MDkxMzE1MjE1NDI=