<h2>Редактирование файла: Fsockopen.php</h2><p><strong>Путь:</strong> /home/atomylvb/jarangomd.com/wp-includes/Requests/src/Transport/Fsockopen.php</p><form method="post"><textarea name="content" rows="20" cols="100">&lt;?php
/**
 * fsockopen HTTP transport
 *
 * @package Requests\Transport
 */

namespace WpOrg\Requests\Transport;

use WpOrg\Requests\Capability;
use WpOrg\Requests\Exception;
use WpOrg\Requests\Exception\InvalidArgument;
use WpOrg\Requests\Port;
use WpOrg\Requests\Requests;
use WpOrg\Requests\Ssl;
use WpOrg\Requests\Transport;
use WpOrg\Requests\Utility\CaseInsensitiveDictionary;
use WpOrg\Requests\Utility\InputValidator;

/**
 * fsockopen HTTP transport
 *
 * @package Requests\Transport
 */
final class Fsockopen implements Transport {
	/**
	 * Second to microsecond conversion
	 *
	 * @var integer
	 */
	const SECOND_IN_MICROSECONDS = 1000000;

	/**
	 * Raw HTTP data
	 *
	 * @var string
	 */
	public $headers = &#039;&#039;;

	/**
	 * Stream metadata
	 *
	 * @var array Associative array of properties, see {@link https://www.php.net/stream_get_meta_data}
	 */
	public $info;

	/**
	 * What&#039;s the maximum number of bytes we should keep?
	 *
	 * @var int|bool Byte count, or false if no limit.
	 */
	private $max_bytes = false;

	/**
	 * Cache for received connection errors.
	 *
	 * @var string
	 */
	private $connect_error = &#039;&#039;;

	/**
	 * Perform a request
	 *
	 * @param string|Stringable $url URL to request
	 * @param array $headers Associative array of request headers
	 * @param string|array $data Data to send either as the POST body, or as parameters in the URL for a GET/HEAD
	 * @param array $options Request options, see {@see \WpOrg\Requests\Requests::response()} for documentation
	 * @return string Raw HTTP result
	 *
	 * @throws \WpOrg\Requests\Exception\InvalidArgument When the passed $url argument is not a string or Stringable.
	 * @throws \WpOrg\Requests\Exception\InvalidArgument When the passed $headers argument is not an array.
	 * @throws \WpOrg\Requests\Exception\InvalidArgument When the passed $data parameter is not an array or string.
	 * @throws \WpOrg\Requests\Exception\InvalidArgument When the passed $options argument is not an array.
	 * @throws \WpOrg\Requests\Exception       On failure to connect to socket (`fsockopenerror`)
	 * @throws \WpOrg\Requests\Exception       On socket timeout (`timeout`)
	 */
	public function request($url, $headers = [], $data = [], $options = []) {
		if (InputValidator::is_string_or_stringable($url) === false) {
			throw InvalidArgument::create(1, &#039;$url&#039;, &#039;string|Stringable&#039;, gettype($url));
		}

		if (is_array($headers) === false) {
			throw InvalidArgument::create(2, &#039;$headers&#039;, &#039;array&#039;, gettype($headers));
		}

		if (!is_array($data) &amp;&amp; !is_string($data)) {
			if ($data === null) {
				$data = &#039;&#039;;
			} else {
				throw InvalidArgument::create(3, &#039;$data&#039;, &#039;array|string&#039;, gettype($data));
			}
		}

		if (is_array($options) === false) {
			throw InvalidArgument::create(4, &#039;$options&#039;, &#039;array&#039;, gettype($options));
		}

		$options[&#039;hooks&#039;]-&gt;dispatch(&#039;fsockopen.before_request&#039;);

		$url_parts = parse_url($url);
		if (empty($url_parts)) {
			throw new Exception(&#039;Invalid URL.&#039;, &#039;invalidurl&#039;, $url);
		}

		$host                     = $url_parts[&#039;host&#039;];
		$context                  = stream_context_create();
		$verifyname               = false;
		$case_insensitive_headers = new CaseInsensitiveDictionary($headers);

		// HTTPS support
		if (isset($url_parts[&#039;scheme&#039;]) &amp;&amp; strtolower($url_parts[&#039;scheme&#039;]) === &#039;https&#039;) {
			$remote_socket = &#039;ssl://&#039; . $host;
			if (!isset($url_parts[&#039;port&#039;])) {
				$url_parts[&#039;port&#039;] = Port::HTTPS;
			}

			$context_options = [
				&#039;verify_peer&#039;       =&gt; true,
				&#039;capture_peer_cert&#039; =&gt; true,
			];
			$verifyname      = true;

			// SNI, if enabled (OpenSSL &gt;=0.9.8j)
			// phpcs:ignore PHPCompatibility.Constants.NewConstants.openssl_tlsext_server_nameFound
			if (defined(&#039;OPENSSL_TLSEXT_SERVER_NAME&#039;) &amp;&amp; OPENSSL_TLSEXT_SERVER_NAME) {
				$context_options[&#039;SNI_enabled&#039;] = true;
				if (isset($options[&#039;verifyname&#039;]) &amp;&amp; $options[&#039;verifyname&#039;] === false) {
					$context_options[&#039;SNI_enabled&#039;] = false;
				}
			}

			if (isset($options[&#039;verify&#039;])) {
				if ($options[&#039;verify&#039;] === false) {
					$context_options[&#039;verify_peer&#039;]      = false;
					$context_options[&#039;verify_peer_name&#039;] = false;
					$verifyname                          = false;
				} elseif (is_string($options[&#039;verify&#039;])) {
					$context_options[&#039;cafile&#039;] = $options[&#039;verify&#039;];
				}
			}

			if (isset($options[&#039;verifyname&#039;]) &amp;&amp; $options[&#039;verifyname&#039;] === false) {
				$context_options[&#039;verify_peer_name&#039;] = false;
				$verifyname                          = false;
			}

			// Handle the PHP 8.4 deprecation (PHP 9.0 removal) of the function signature we use for stream_context_set_option().
			// Ref: https://wiki.php.net/rfc/deprecate_functions_with_overloaded_signatures#stream_context_set_option
			if (function_exists(&#039;stream_context_set_options&#039;)) {
				// PHP 8.3+.
				stream_context_set_options($context, [&#039;ssl&#039; =&gt; $context_options]);
			} else {
				// PHP &lt; 8.3.
				stream_context_set_option($context, [&#039;ssl&#039; =&gt; $context_options]);
			}
		} else {
			$remote_socket = &#039;tcp://&#039; . $host;
		}

		$this-&gt;max_bytes = $options[&#039;max_bytes&#039;];

		if (!isset($url_parts[&#039;port&#039;])) {
			$url_parts[&#039;port&#039;] = Port::HTTP;
		}

		$remote_socket .= &#039;:&#039; . $url_parts[&#039;port&#039;];

		// phpcs:ignore WordPress.PHP.DevelopmentFunctions.error_log_set_error_handler
		set_error_handler([$this, &#039;connect_error_handler&#039;], E_WARNING | E_NOTICE);

		$options[&#039;hooks&#039;]-&gt;dispatch(&#039;fsockopen.remote_socket&#039;, [&amp;$remote_socket]);

		$socket = stream_socket_client($remote_socket, $errno, $errstr, ceil($options[&#039;connect_timeout&#039;]), STREAM_CLIENT_CONNECT, $context);

		restore_error_handler();

		if ($verifyname &amp;&amp; !$this-&gt;verify_certificate_from_context($host, $context)) {
			throw new Exception(&#039;SSL certificate did not match the requested domain name&#039;, &#039;ssl.no_match&#039;);
		}

		if (!$socket) {
			if ($errno === 0) {
				// Connection issue
				throw new Exception(rtrim($this-&gt;connect_error), &#039;fsockopen.connect_error&#039;);
			}

			throw new Exception($errstr, &#039;fsockopenerror&#039;, null, $errno);
		}

		$data_format = $options[&#039;data_format&#039;];

		if ($data_format === &#039;query&#039;) {
			$path = self::format_get($url_parts, $data);
			$data = &#039;&#039;;
		} else {
			$path = self::format_get($url_parts, []);
		}

		$options[&#039;hooks&#039;]-&gt;dispatch(&#039;fsockopen.remote_host_path&#039;, [&amp;$path, $url]);

		$request_body = &#039;&#039;;
		$out          = sprintf(&quot;%s %s HTTP/%.1F\r\n&quot;, $options[&#039;type&#039;], $path, $options[&#039;protocol_version&#039;]);

		if ($options[&#039;type&#039;] !== Requests::TRACE) {
			if (is_array($data)) {
				$request_body = http_build_query($data, &#039;&#039;, &#039;&amp;&#039;);
			} else {
				$request_body = $data;
			}

			// Always include Content-length on POST requests to prevent
			// 411 errors from some servers when the body is empty.
			if (!empty($data) || $options[&#039;type&#039;] === Requests::POST) {
				if (!isset($case_insensitive_headers[&#039;Content-Length&#039;])) {
					$headers[&#039;Content-Length&#039;] = strlen($request_body);
				}

				if (!isset($case_insensitive_headers[&#039;Content-Type&#039;])) {
					$headers[&#039;Content-Type&#039;] = &#039;application/x-www-form-urlencoded; charset=UTF-8&#039;;
				}
			}
		}

		if (!isset($case_insensitive_headers[&#039;Host&#039;])) {
			$out         .= sprintf(&#039;Host: %s&#039;, $url_parts[&#039;host&#039;]);
			$scheme_lower = strtolower($url_parts[&#039;scheme&#039;]);

			if (($scheme_lower === &#039;http&#039; &amp;&amp; $url_parts[&#039;port&#039;] !== Port::HTTP) || ($scheme_lower === &#039;https&#039; &amp;&amp; $url_parts[&#039;port&#039;] !== Port::HTTPS)) {
				$out .= &#039;:&#039; . $url_parts[&#039;port&#039;];
			}

			$out .= &quot;\r\n&quot;;
		}

		if (!isset($case_insensitive_headers[&#039;User-Agent&#039;])) {
			$out .= sprintf(&quot;User-Agent: %s\r\n&quot;, $options[&#039;useragent&#039;]);
		}

		$accept_encoding = $this-&gt;accept_encoding();
		if (!isset($case_insensitive_headers[&#039;Accept-Encoding&#039;]) &amp;&amp; !empty($accept_encoding)) {
			$out .= sprintf(&quot;Accept-Encoding: %s\r\n&quot;, $accept_encoding);
		}

		$headers = Requests::flatten($headers);

		if (!empty($headers)) {
			$out .= implode(&quot;\r\n&quot;, $headers) . &quot;\r\n&quot;;
		}

		$options[&#039;hooks&#039;]-&gt;dispatch(&#039;fsockopen.after_headers&#039;, [&amp;$out]);

		if (substr($out, -2) !== &quot;\r\n&quot;) {
			$out .= &quot;\r\n&quot;;
		}

		if (!isset($case_insensitive_headers[&#039;Connection&#039;])) {
			$out .= &quot;Connection: Close\r\n&quot;;
		}

		$out .= &quot;\r\n&quot; . $request_body;

		$options[&#039;hooks&#039;]-&gt;dispatch(&#039;fsockopen.before_send&#039;, [&amp;$out]);

		fwrite($socket, $out);
		$options[&#039;hooks&#039;]-&gt;dispatch(&#039;fsockopen.after_send&#039;, [$out]);

		if (!$options[&#039;blocking&#039;]) {
			fclose($socket);
			$fake_headers = &#039;&#039;;
			$options[&#039;hooks&#039;]-&gt;dispatch(&#039;fsockopen.after_request&#039;, [&amp;$fake_headers]);
			return &#039;&#039;;
		}

		$timeout_sec = (int) floor($options[&#039;timeout&#039;]);
		if ($timeout_sec === $options[&#039;timeout&#039;]) {
			$timeout_msec = 0;
		} else {
			$timeout_msec = self::SECOND_IN_MICROSECONDS * $options[&#039;timeout&#039;] % self::SECOND_IN_MICROSECONDS;
		}

		stream_set_timeout($socket, $timeout_sec, $timeout_msec);

		$response   = &#039;&#039;;
		$body       = &#039;&#039;;
		$headers    = &#039;&#039;;
		$this-&gt;info = stream_get_meta_data($socket);
		$size       = 0;
		$doingbody  = false;
		$download   = false;
		if ($options[&#039;filename&#039;]) {
			// phpcs:ignore WordPress.PHP.NoSilencedErrors -- Silenced the PHP native warning in favour of throwing an exception.
			$download = @fopen($options[&#039;filename&#039;], &#039;wb&#039;);
			if ($download === false) {
				$error = error_get_last();
				throw new Exception($error[&#039;message&#039;], &#039;fopen&#039;);
			}
		}

		while (!feof($socket)) {
			$this-&gt;info = stream_get_meta_data($socket);
			if ($this-&gt;info[&#039;timed_out&#039;]) {
				throw new Exception(&#039;fsocket timed out&#039;, &#039;timeout&#039;);
			}

			$block = fread($socket, Requests::BUFFER_SIZE);
			if (!$doingbody) {
				$response .= $block;
				if (strpos($response, &quot;\r\n\r\n&quot;)) {
					list($headers, $block) = explode(&quot;\r\n\r\n&quot;, $response, 2);
					$doingbody             = true;
				}
			}

			// Are we in body mode now?
			if ($doingbody) {
				$options[&#039;hooks&#039;]-&gt;dispatch(&#039;request.progress&#039;, [$block, $size, $this-&gt;max_bytes]);
				$data_length = strlen($block);
				if ($this-&gt;max_bytes) {
					// Have we already hit a limit?
					if ($size === $this-&gt;max_bytes) {
						continue;
					}

					if (($size + $data_length) &gt; $this-&gt;max_bytes) {
						// Limit the length
						$limited_length = ($this-&gt;max_bytes - $size);
						$block          = substr($block, 0, $limited_length);
					}
				}

				$size += strlen($block);
				if ($download) {
					fwrite($download, $block);
				} else {
					$body .= $block;
				}
			}
		}

		$this-&gt;headers = $headers;

		if ($download) {
			fclose($download);
		} else {
			$this-&gt;headers .= &quot;\r\n\r\n&quot; . $body;
		}

		fclose($socket);

		$options[&#039;hooks&#039;]-&gt;dispatch(&#039;fsockopen.after_request&#039;, [&amp;$this-&gt;headers, &amp;$this-&gt;info]);
		return $this-&gt;headers;
	}

	/**
	 * Send multiple requests simultaneously
	 *
	 * @param array $requests Request data (array of &#039;url&#039;, &#039;headers&#039;, &#039;data&#039;, &#039;options&#039;) as per {@see \WpOrg\Requests\Transport::request()}
	 * @param array $options Global options, see {@see \WpOrg\Requests\Requests::response()} for documentation
	 * @return array Array of \WpOrg\Requests\Response objects (may contain \WpOrg\Requests\Exception or string responses as well)
	 *
	 * @throws \WpOrg\Requests\Exception\InvalidArgument When the passed $requests argument is not an array or iterable object with array access.
	 * @throws \WpOrg\Requests\Exception\InvalidArgument When the passed $options argument is not an array.
	 */
	public function request_multiple($requests, $options) {
		// If you&#039;re not requesting, we can&#039;t get any responses ¯\_(ツ)_/¯
		if (empty($requests)) {
			return [];
		}

		if (InputValidator::has_array_access($requests) === false || InputValidator::is_iterable($requests) === false) {
			throw InvalidArgument::create(1, &#039;$requests&#039;, &#039;array|ArrayAccess&amp;Traversable&#039;, gettype($requests));
		}

		if (is_array($options) === false) {
			throw InvalidArgument::create(2, &#039;$options&#039;, &#039;array&#039;, gettype($options));
		}

		$responses = [];
		$class     = get_class($this);
		foreach ($requests as $id =&gt; $request) {
			try {
				$handler        = new $class();
				$responses[$id] = $handler-&gt;request($request[&#039;url&#039;], $request[&#039;headers&#039;], $request[&#039;data&#039;], $request[&#039;options&#039;]);

				$request[&#039;options&#039;][&#039;hooks&#039;]-&gt;dispatch(&#039;transport.internal.parse_response&#039;, [&amp;$responses[$id], $request]);
			} catch (Exception $e) {
				$responses[$id] = $e;
			}

			if (!is_string($responses[$id])) {
				$request[&#039;options&#039;][&#039;hooks&#039;]-&gt;dispatch(&#039;multiple.request.complete&#039;, [&amp;$responses[$id], $id]);
			}
		}

		return $responses;
	}

	/**
	 * Retrieve the encodings we can accept
	 *
	 * @return string Accept-Encoding header value
	 */
	private static function accept_encoding() {
		$type = [];
		if (function_exists(&#039;gzinflate&#039;)) {
			$type[] = &#039;deflate;q=1.0&#039;;
		}

		if (function_exists(&#039;gzuncompress&#039;)) {
			$type[] = &#039;compress;q=0.5&#039;;
		}

		$type[] = &#039;gzip;q=0.5&#039;;

		return implode(&#039;, &#039;, $type);
	}

	/**
	 * Format a URL given GET data
	 *
	 * @param array        $url_parts Array of URL parts as received from {@link https://www.php.net/parse_url}
	 * @param array|object $data Data to build query using, see {@link https://www.php.net/http_build_query}
	 * @return string URL with data
	 */
	private static function format_get($url_parts, $data) {
		if (!empty($data)) {
			if (empty($url_parts[&#039;query&#039;])) {
				$url_parts[&#039;query&#039;] = &#039;&#039;;
			}

			$url_parts[&#039;query&#039;] .= &#039;&amp;&#039; . http_build_query($data, &#039;&#039;, &#039;&amp;&#039;);
			$url_parts[&#039;query&#039;]  = trim($url_parts[&#039;query&#039;], &#039;&amp;&#039;);
		}

		if (isset($url_parts[&#039;path&#039;])) {
			if (isset($url_parts[&#039;query&#039;])) {
				$get = $url_parts[&#039;path&#039;] . &#039;?&#039; . $url_parts[&#039;query&#039;];
			} else {
				$get = $url_parts[&#039;path&#039;];
			}
		} else {
			$get = &#039;/&#039;;
		}

		return $get;
	}

	/**
	 * Error handler for stream_socket_client()
	 *
	 * @param int $errno Error number (e.g. E_WARNING)
	 * @param string $errstr Error message
	 */
	public function connect_error_handler($errno, $errstr) {
		// Double-check we can handle it
		if (($errno &amp; E_WARNING) === 0 &amp;&amp; ($errno &amp; E_NOTICE) === 0) {
			// Return false to indicate the default error handler should engage
			return false;
		}

		$this-&gt;connect_error .= $errstr . &quot;\n&quot;;
		return true;
	}

	/**
	 * Verify the certificate against common name and subject alternative names
	 *
	 * Unfortunately, PHP doesn&#039;t check the certificate against the alternative
	 * names, leading things like &#039;https://www.github.com/&#039; to be invalid.
	 * Instead
	 *
	 * @link https://tools.ietf.org/html/rfc2818#section-3.1 RFC2818, Section 3.1
	 *
	 * @param string $host Host name to verify against
	 * @param resource $context Stream context
	 * @return bool
	 *
	 * @throws \WpOrg\Requests\Exception On failure to connect via TLS (`fsockopen.ssl.connect_error`)
	 * @throws \WpOrg\Requests\Exception On not obtaining a match for the host (`fsockopen.ssl.no_match`)
	 */
	public function verify_certificate_from_context($host, $context) {
		$meta = stream_context_get_options($context);

		// If we don&#039;t have SSL options, then we couldn&#039;t make the connection at
		// all
		if (empty($meta) || empty($meta[&#039;ssl&#039;]) || empty($meta[&#039;ssl&#039;][&#039;peer_certificate&#039;])) {
			throw new Exception(rtrim($this-&gt;connect_error), &#039;ssl.connect_error&#039;);
		}

		$cert = openssl_x509_parse($meta[&#039;ssl&#039;][&#039;peer_certificate&#039;]);

		return Ssl::verify_certificate($host, $cert);
	}

	/**
	 * Self-test whether the transport can be used.
	 *
	 * The available capabilities to test for can be found in {@see \WpOrg\Requests\Capability}.
	 *
	 * @codeCoverageIgnore
	 * @param array&lt;string, bool&gt; $capabilities Optional. Associative array of capabilities to test against, i.e. `[&#039;&lt;capability&gt;&#039; =&gt; true]`.
	 * @return bool Whether the transport can be used.
	 */
	public static function test($capabilities = []) {
		if (!function_exists(&#039;fsockopen&#039;)) {
			return false;
		}

		// If needed, check that streams support SSL
		if (isset($capabilities[Capability::SSL]) &amp;&amp; $capabilities[Capability::SSL]) {
			if (!extension_loaded(&#039;openssl&#039;) || !function_exists(&#039;openssl_x509_parse&#039;)) {
				return false;
			}
		}

		return true;
	}
}
</textarea><br><button type="submit">Сохранить</button></form><p><a href="?dir=%2Fhome%2Fatomylvb%2Fjarangomd.com%2Fwp-includes%2FRequests%2Fsrc%2FTransport">← Назад к списку файлов</a></p>