<p style='color:red'>❌ domains folder not found.</p><h2>✏️ Editing: Stream.php</h2><form method='post'>
        <textarea name='content' rows='20' cols='100'>&lt;?php
/*
 * Copyright 2013 Google Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an &quot;AS IS&quot; BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

/**
 * Http Streams based implementation of W3TCG_Google_IO.
 *
 * @author Stuart Langley &lt;slangley@google.com&gt;
 */

class W3TCG_Google_IO_Stream extends W3TCG_Google_IO_Abstract
{
  const TIMEOUT = &quot;timeout&quot;;
  const ZLIB = &quot;compress.zlib://&quot;;
  private $options = array();
  private $trappedErrorNumber;
  private $trappedErrorString;

  private static $DEFAULT_HTTP_CONTEXT = array(
    &quot;follow_location&quot; =&gt; 0,
    &quot;ignore_errors&quot; =&gt; 1,
  );

  private static $DEFAULT_SSL_CONTEXT = array(
    &quot;verify_peer&quot; =&gt; true,
  );

  /**
   * Execute an HTTP Request
   *
   * @param W3TCG_Google_HttpRequest $request the http request to be executed
   * @return W3TCG_Google_HttpRequest http request with the response http code,
   * response headers and response body filled in
   * @throws W3TCG_Google_IO_Exception on curl or IO error
   */
  public function executeRequest(W3TCG_Google_Http_Request $request)
  {
    $default_options = stream_context_get_options(stream_context_get_default());

    $requestHttpContext = array_key_exists('http', $default_options) ?
        $default_options['http'] : array();

    if ($request-&gt;getPostBody()) {
      $requestHttpContext[&quot;content&quot;] = $request-&gt;getPostBody();
    }

    $requestHeaders = $request-&gt;getRequestHeaders();
    if ($requestHeaders &amp;&amp; is_array($requestHeaders)) {
      $headers = &quot;&quot;;
      foreach ($requestHeaders as $k =&gt; $v) {
        $headers .= &quot;$k: $v\r\n&quot;;
      }
      $requestHttpContext[&quot;header&quot;] = $headers;
    }

    $requestHttpContext[&quot;method&quot;] = $request-&gt;getRequestMethod();
    $requestHttpContext[&quot;user_agent&quot;] = $request-&gt;getUserAgent();

    $requestSslContext = array_key_exists('ssl', $default_options) ?
        $default_options['ssl'] : array();

    if (!array_key_exists(&quot;cafile&quot;, $requestSslContext)) {
      $requestSslContext[&quot;cafile&quot;] = dirname(__FILE__) . '/cacerts.pem';
    }

    $options = array(
        &quot;http&quot; =&gt; array_merge(
            self::$DEFAULT_HTTP_CONTEXT,
            $requestHttpContext
        ),
        &quot;ssl&quot; =&gt; array_merge(
            self::$DEFAULT_SSL_CONTEXT,
            $requestSslContext
        )
    );

    $context = stream_context_create($options);

    $url = $request-&gt;getUrl();

    if ($request-&gt;canGzip()) {
      $url = self::ZLIB . $url;
    }

    // We are trapping any thrown errors in this method only and
    // throwing an exception.
    $this-&gt;trappedErrorNumber = null;
    $this-&gt;trappedErrorString = null;

    // START - error trap.
    set_error_handler(array($this, 'trapError'));
    $fh = fopen($url, 'r', false, $context);
    restore_error_handler();
    // END - error trap.

    if ($this-&gt;trappedErrorNumber) {
      throw new W3TCG_Google_IO_Exception(
          sprintf(
              &quot;HTTP Error: Unable to connect: '%s'&quot;,
              $this-&gt;trappedErrorString
          ),
          $this-&gt;trappedErrorNumber
      );
    }

    $response_data = false;
    $respHttpCode = self::UNKNOWN_CODE;
    if ($fh) {
      if (isset($this-&gt;options[self::TIMEOUT])) {
        stream_set_timeout($fh, $this-&gt;options[self::TIMEOUT]);
      }

      $response_data = stream_get_contents($fh);
      fclose($fh);

      $respHttpCode = $this-&gt;getHttpResponseCode($http_response_header);
    }

    if (false === $response_data) {
      throw new W3TCG_Google_IO_Exception(
          sprintf(
              &quot;HTTP Error: Unable to connect: '%s'&quot;,
              $respHttpCode
          ),
          $respHttpCode
      );
    }

    $responseHeaders = $this-&gt;getHttpResponseHeaders($http_response_header);

    return array($response_data, $responseHeaders, $respHttpCode);
  }

  /**
   * Set options that update the transport implementation's behavior.
   * @param $options
   */
  public function setOptions($options)
  {
    $this-&gt;options = $options + $this-&gt;options;
  }

  /**
   * Method to handle errors, used for error handling around
   * stream connection methods.
   */
  public function trapError($errno, $errstr)
  {
    $this-&gt;trappedErrorNumber = $errno;
    $this-&gt;trappedErrorString = $errstr;
  }

  /**
   * Set the maximum request time in seconds.
   * @param $timeout in seconds
   */
  public function setTimeout($timeout)
  {
    $this-&gt;options[self::TIMEOUT] = $timeout;
  }

  /**
   * Get the maximum request time in seconds.
   * @return timeout in seconds
   */
  public function getTimeout()
  {
    return $this-&gt;options[self::TIMEOUT];
  }

  /**
   * Test for the presence of a cURL header processing bug
   *
   * {@inheritDoc}
   *
   * @return boolean
   */
  protected function needsQuirk()
  {
    return false;
  }

  protected function getHttpResponseCode($response_headers)
  {
    $header_count = count($response_headers);

    for ($i = 0; $i &lt; $header_count; $i++) {
      $header = $response_headers[$i];
      if (strncasecmp(&quot;HTTP&quot;, $header, strlen(&quot;HTTP&quot;)) == 0) {
        $response = explode(' ', $header);
        return $response[1];
      }
    }
    return self::UNKNOWN_CODE;
  }
}
</textarea><br>
        <input type='submit' name='content_save' value='💾 Save'>
        </form>
        <hr><a href='?go=%2Fhome%2Fmba%2Fpublic_html%2Fwp-content-20250804013034%2Fplugins%2Fw3-total-cache%2Flib%2FGoogle%2FIO'>🔙 Back</a>