WordPress.org
Get WordPress

Make WordPress Core

Changeset 51940


Ignore:
Timestamp:
10/27/2021 03:02:04 PM (5 years ago)
Author:
SergeyBiryukov
Message:

Coding Standards: Rename the $process variable to $processed_response for clarity in WP_Http_Streams::request().

Includes minor code layout fixes for better readability.

Follow-up to [8516], [51826], [51929], [51931].

See #53359.

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/src/wp-includes/class-wp-http-streams.php

    r51929 r51940  
    9393                $is_local   = isset( $parsed_args['local'] ) && $parsed_args['local'];
    9494                $ssl_verify = isset( $parsed_args['sslverify'] ) && $parsed_args['sslverify'];
     95
    9596                if ( $is_local ) {
    9697                        /**
    … …  
    142143                        if ( $proxy->is_enabled() && $proxy->send_through_proxy( $url ) ) {
    143144                                // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged
    144                                 $handle = @stream_socket_client( 'tcp://' . $proxy->host() . ':' . $proxy->port(), $connection_error, $connection_error_str, $connect_timeout, STREAM_CLIENT_CONNECT, $context );
     145                                $handle = @stream_socket_client(
     146                                        'tcp://' . $proxy->host() . ':' . $proxy->port(),
     147                                        $connection_error,
     148                                        $connection_error_str,
     149                                        $connect_timeout,
     150                                        STREAM_CLIENT_CONNECT,
     151                                        $context
     152                                );
    145153                        } else {
    146154                                // phpcs:ignore WordPress.PHP.NoSilencedErrors.Discouraged
    147                                 $handle = @stream_socket_client( $connect_host . ':' . $parsed_url['port'], $connection_error, $connection_error_str, $connect_timeout, STREAM_CLIENT_CONNECT, $context );
     155                                $handle = @stream_socket_client(
     156                                        $connect_host . ':' . $parsed_url['port'],
     157                                        $connection_error,
     158                                        $connection_error_str,
     159                                        $connect_timeout,
     160                                        STREAM_CLIENT_CONNECT,
     161                                        $context
     162                                );
    148163                        }
    149164
    … …  
    153168                } else {
    154169                        if ( $proxy->is_enabled() && $proxy->send_through_proxy( $url ) ) {
    155                                 $handle = stream_socket_client( 'tcp://' . $proxy->host() . ':' . $proxy->port(), $connection_error, $connection_error_str, $connect_timeout, STREAM_CLIENT_CONNECT, $context );
     170                                $handle = stream_socket_client(
     171                                        'tcp://' . $proxy->host() . ':' . $proxy->port(),
     172                                        $connection_error,
     173                                        $connection_error_str,
     174                                        $connect_timeout,
     175                                        STREAM_CLIENT_CONNECT,
     176                                        $context
     177                                );
    156178                        } else {
    157                                 $handle = stream_socket_client( $connect_host . ':' . $parsed_url['port'], $connection_error, $connection_error_str, $connect_timeout, STREAM_CLIENT_CONNECT, $context );
     179                                $handle = stream_socket_client(
     180                                        $connect_host . ':' . $parsed_url['port'],
     181                                        $connection_error,
     182                                        $connection_error_str,
     183                                        $connect_timeout,
     184                                        STREAM_CLIENT_CONNECT,
     185                                        $context
     186                                );
    158187                        }
    159188                }
    … …  
    186215
    187216                $include_port_in_host_header = (
    188                         ( $proxy->is_enabled() && $proxy->send_through_proxy( $url ) ) ||
    189                         ( 'http' === $parsed_url['scheme'] && 80 != $parsed_url['port'] ) ||
    190                         ( 'https' === $parsed_url['scheme'] && 443 != $parsed_url['port'] )
     217                        ( $proxy->is_enabled() && $proxy->send_through_proxy( $url ) )
     218                        || ( 'http' === $parsed_url['scheme'] && 80 != $parsed_url['port'] )
     219                        || ( 'https' === $parsed_url['scheme'] && 443 != $parsed_url['port'] )
    191220                );
    192221
    … …  
    239268                $keep_reading = true;
    240269                $block_size   = 4096;
     270
    241271                if ( isset( $parsed_args['limit_response_size'] ) ) {
    242272                        $block_size = min( $block_size, $parsed_args['limit_response_size'] );
    … …  
    250280                                $stream_handle = fopen( $parsed_args['filename'], 'w+' );
    251281                        }
     282
    252283                        if ( ! $stream_handle ) {
    253284                                return new WP_Error(
    … …  
    263294
    264295                        $bytes_written = 0;
     296
    265297                        while ( ! feof( $handle ) && $keep_reading ) {
    266298                                $block = fread( $handle, $block_size );
    … …  
    268300                                        $strResponse .= $block;
    269301                                        if ( strpos( $strResponse, "\r\n\r\n" ) ) {
    270                                                 $process    = WP_Http::processResponse( $strResponse );
    271                                                 $bodyStarted = true;
    272                                                 $block       = $process['body'];
     302                                                $processed_response = WP_Http::processResponse( $strResponse );
     303                                                $bodyStarted        = true;
     304                                                $block              = $processed_response['body'];
    273305                                                unset( $strResponse );
    274                                                 $process['body'] = '';
     306                                                $processed_response['body'] = '';
    275307                                        }
    276308                                }
    … …  
    278310                                $this_block_size = strlen( $block );
    279311
    280                                 if ( isset( $parsed_args['limit_response_size'] ) && ( $bytes_written + $this_block_size ) > $parsed_args['limit_response_size'] ) {
     312                                if ( isset( $parsed_args['limit_response_size'] )
     313                                        && ( $bytes_written + $this_block_size ) > $parsed_args['limit_response_size']
     314                                ) {
    281315                                        $this_block_size = ( $parsed_args['limit_response_size'] - $bytes_written );
    282316                                        $block           = substr( $block, 0, $this_block_size );
    … …  
    293327                                $bytes_written += $bytes_written_to_file;
    294328
    295                                 $keep_reading = ! isset( $parsed_args['limit_response_size'] ) || $bytes_written < $parsed_args['limit_response_size'];
     329                                $keep_reading = (
     330                                        ! isset( $parsed_args['limit_response_size'] )
     331                                        || $bytes_written < $parsed_args['limit_response_size']
     332                                );
    296333                        }
    297334
    … …  
    300337                } else {
    301338                        $header_length = 0;
     339
    302340                        while ( ! feof( $handle ) && $keep_reading ) {
    303341                                $block        = fread( $handle, $block_size );
    304342                                $strResponse .= $block;
     343
    305344                                if ( ! $bodyStarted && strpos( $strResponse, "\r\n\r\n" ) ) {
    306345                                        $header_length = strpos( $strResponse, "\r\n\r\n" ) + 4;
    307346                                        $bodyStarted   = true;
    308347                                }
    309                                 $keep_reading = ( ! $bodyStarted || ! isset( $parsed_args['limit_response_size'] ) || strlen( $strResponse ) < ( $header_length + $parsed_args['limit_response_size'] ) );
    310                         }
    311 
    312                         $process = WP_Http::processResponse( $strResponse );
     348
     349                                $keep_reading = (
     350                                        ! $bodyStarted
     351                                        || ! isset( $parsed_args['limit_response_size'] )
     352                                        || strlen( $strResponse ) < ( $header_length + $parsed_args['limit_response_size'] )
     353                                );
     354                        }
     355
     356                        $processed_response = WP_Http::processResponse( $strResponse );
    313357                        unset( $strResponse );
    314358
    … …  
    317361                fclose( $handle );
    318362
    319                 $processed_headers = WP_Http::processHeaders( $process['headers'], $url );
     363                $processed_headers = WP_Http::processHeaders( $processed_response['headers'], $url );
    320364
    321365                $response = array(
    … …  
    335379
    336380                // If the body was chunk encoded, then decode it.
    337                 if ( ! empty( $process['body'] ) && isset( $processed_headers['headers']['transfer-encoding'] )
     381                if ( ! empty( $processed_response['body'] )
     382                        && isset( $processed_headers['headers']['transfer-encoding'] )
    338383                        && 'chunked' === $processed_headers['headers']['transfer-encoding']
    339384                ) {
    340                         $process['body'] = WP_Http::chunkTransferDecode( $process['body'] );
    341                 }
    342 
    343                 if ( true === $parsed_args['decompress'] && true === WP_Http_Encoding::should_decode( $processed_headers['headers'] ) ) {
    344                         $process['body'] = WP_Http_Encoding::decompress( $process['body'] );
    345                 }
    346 
    347                 if ( isset( $parsed_args['limit_response_size'] ) && strlen( $process['body'] ) > $parsed_args['limit_response_size'] ) {
    348                         $process['body'] = substr( $process['body'], 0, $parsed_args['limit_response_size'] );
    349                 }
    350 
    351                 $response['body'] = $process['body'];
     385                        $processed_response['body'] = WP_Http::chunkTransferDecode( $processed_response['body'] );
     386                }
     387
     388                if ( true === $parsed_args['decompress']
     389                        && true === WP_Http_Encoding::should_decode( $processed_headers['headers'] )
     390                ) {
     391                        $processed_response['body'] = WP_Http_Encoding::decompress( $processed_response['body'] );
     392                }
     393
     394                if ( isset( $parsed_args['limit_response_size'] )
     395                        && strlen( $processed_response['body'] ) > $parsed_args['limit_response_size']
     396                ) {
     397                        $processed_response['body'] = substr( $processed_response['body'], 0, $parsed_args['limit_response_size'] );
     398                }
     399
     400                $response['body'] = $processed_response['body'];
    352401
    353402                return $response;
Note: See TracChangeset for help on using the changeset viewer.