<?php

[0] Fix | Delete

/**

[1] Fix | Delete

* HTTP Proxy connection interface

[2] Fix | Delete

*

[3] Fix | Delete

* @package Requests\Proxy

[4] Fix | Delete

* @since 1.6

[5] Fix | Delete

*/

[6] Fix | Delete

[7] Fix | Delete

namespace WpOrg\Requests\Proxy;

[8] Fix | Delete

[9] Fix | Delete

use WpOrg\Requests\Exception\ArgumentCount;

[10] Fix | Delete

use WpOrg\Requests\Exception\InvalidArgument;

[11] Fix | Delete

use WpOrg\Requests\Hooks;

[12] Fix | Delete

use WpOrg\Requests\Proxy;

[13] Fix | Delete

[14] Fix | Delete

/**

[15] Fix | Delete

* HTTP Proxy connection interface

[16] Fix | Delete

*

[17] Fix | Delete

* Provides a handler for connection via an HTTP proxy

[18] Fix | Delete

*

[19] Fix | Delete

* @package Requests\Proxy

[20] Fix | Delete

* @since 1.6

[21] Fix | Delete

*/

[22] Fix | Delete

final class Http implements Proxy {

[23] Fix | Delete

/**

[24] Fix | Delete

* Proxy host and port

[25] Fix | Delete

*

[26] Fix | Delete

* Notation: "host:port" (eg 127.0.0.1:8080 or someproxy.com:3128)

[27] Fix | Delete

*

[28] Fix | Delete

* @var string

[29] Fix | Delete

*/

[30] Fix | Delete

public $proxy;

[31] Fix | Delete

[32] Fix | Delete

/**

[33] Fix | Delete

* Username

[34] Fix | Delete

*

[35] Fix | Delete

* @var string

[36] Fix | Delete

*/

[37] Fix | Delete

public $user;

[38] Fix | Delete

[39] Fix | Delete

/**

[40] Fix | Delete

* Password

[41] Fix | Delete

*

[42] Fix | Delete

* @var string

[43] Fix | Delete

*/

[44] Fix | Delete

public $pass;

[45] Fix | Delete

[46] Fix | Delete

/**

[47] Fix | Delete

* Do we need to authenticate? (ie username & password have been provided)

[48] Fix | Delete

*

[49] Fix | Delete

* @var boolean

[50] Fix | Delete

*/

[51] Fix | Delete

public $use_authentication;

[52] Fix | Delete

[53] Fix | Delete

/**

[54] Fix | Delete

* Constructor

[55] Fix | Delete

*

[56] Fix | Delete

* @since 1.6

[57] Fix | Delete

*

[58] Fix | Delete

* @param array|string|null $args Proxy as a string or an array of proxy, user and password.

[59] Fix | Delete

* When passed as an array, must have exactly one (proxy)

[60] Fix | Delete

* or three elements (proxy, user, password).

[61] Fix | Delete

*

[62] Fix | Delete

* @throws \WpOrg\Requests\Exception\InvalidArgument When the passed argument is not an array, a string or null.

[63] Fix | Delete

* @throws \WpOrg\Requests\Exception\ArgumentCount On incorrect number of arguments (`proxyhttpbadargs`)

[64] Fix | Delete

*/

[65] Fix | Delete

public function __construct($args = null) {

[66] Fix | Delete

if (is_string($args)) {

[67] Fix | Delete

$this->proxy = $args;

[68] Fix | Delete

} elseif (is_array($args)) {

[69] Fix | Delete

if (count($args) === 1) {

[70] Fix | Delete

list($this->proxy) = $args;

[71] Fix | Delete

} elseif (count($args) === 3) {

[72] Fix | Delete

list($this->proxy, $this->user, $this->pass) = $args;

[73] Fix | Delete

$this->use_authentication = true;

[74] Fix | Delete

} else {

[75] Fix | Delete

throw ArgumentCount::create(

[76] Fix | Delete

'an array with exactly one element or exactly three elements',

[77] Fix | Delete

count($args),

[78] Fix | Delete

'proxyhttpbadargs'

[79] Fix | Delete

);

[80] Fix | Delete

}

[81] Fix | Delete

} elseif ($args !== null) {

[82] Fix | Delete

throw InvalidArgument::create(1, '$args', 'array|string|null', gettype($args));

[83] Fix | Delete

}

[84] Fix | Delete

}

[85] Fix | Delete

[86] Fix | Delete

/**

[87] Fix | Delete

* Register the necessary callbacks

[88] Fix | Delete

*

[89] Fix | Delete

* @since 1.6

[90] Fix | Delete

* @see \WpOrg\Requests\Proxy\Http::curl_before_send()

[91] Fix | Delete

* @see \WpOrg\Requests\Proxy\Http::fsockopen_remote_socket()

[92] Fix | Delete

* @see \WpOrg\Requests\Proxy\Http::fsockopen_remote_host_path()

[93] Fix | Delete

* @see \WpOrg\Requests\Proxy\Http::fsockopen_header()

[94] Fix | Delete

* @param \WpOrg\Requests\Hooks $hooks Hook system

[95] Fix | Delete

*/

[96] Fix | Delete

public function register(Hooks $hooks) {

[97] Fix | Delete

$hooks->register('curl.before_send', [$this, 'curl_before_send']);

[98] Fix | Delete

[99] Fix | Delete

$hooks->register('fsockopen.remote_socket', [$this, 'fsockopen_remote_socket']);

[100] Fix | Delete

$hooks->register('fsockopen.remote_host_path', [$this, 'fsockopen_remote_host_path']);

[101] Fix | Delete

if ($this->use_authentication) {

[102] Fix | Delete

$hooks->register('fsockopen.after_headers', [$this, 'fsockopen_header']);

[103] Fix | Delete

}

[104] Fix | Delete

}

[105] Fix | Delete

[106] Fix | Delete

/**

[107] Fix | Delete

* Set cURL parameters before the data is sent

[108] Fix | Delete

*

[109] Fix | Delete

* @since 1.6

[110] Fix | Delete

* @param resource|\CurlHandle $handle cURL handle

[111] Fix | Delete

*/

[112] Fix | Delete

public function curl_before_send(&$handle) {

[113] Fix | Delete

curl_setopt($handle, CURLOPT_PROXYTYPE, CURLPROXY_HTTP);

[114] Fix | Delete

curl_setopt($handle, CURLOPT_PROXY, $this->proxy);

[115] Fix | Delete

[116] Fix | Delete

if ($this->use_authentication) {

[117] Fix | Delete

curl_setopt($handle, CURLOPT_PROXYAUTH, CURLAUTH_ANY);

[118] Fix | Delete

curl_setopt($handle, CURLOPT_PROXYUSERPWD, $this->get_auth_string());

[119] Fix | Delete

}

[120] Fix | Delete

}

[121] Fix | Delete

[122] Fix | Delete

/**

[123] Fix | Delete

* Alter remote socket information before opening socket connection

[124] Fix | Delete

*

[125] Fix | Delete

* @since 1.6

[126] Fix | Delete

* @param string $remote_socket Socket connection string

[127] Fix | Delete

*/

[128] Fix | Delete

public function fsockopen_remote_socket(&$remote_socket) {

[129] Fix | Delete

$remote_socket = $this->proxy;

[130] Fix | Delete

}

[131] Fix | Delete

[132] Fix | Delete

/**

[133] Fix | Delete

* Alter remote path before getting stream data

[134] Fix | Delete

*

[135] Fix | Delete

* @since 1.6

[136] Fix | Delete

* @param string $path Path to send in HTTP request string ("GET ...")

[137] Fix | Delete

* @param string $url Full URL we're requesting

[138] Fix | Delete

*/

[139] Fix | Delete

public function fsockopen_remote_host_path(&$path, $url) {

[140] Fix | Delete

$path = $url;

[141] Fix | Delete

}

[142] Fix | Delete

[143] Fix | Delete

/**

[144] Fix | Delete

* Add extra headers to the request before sending

[145] Fix | Delete

*

[146] Fix | Delete

* @since 1.6

[147] Fix | Delete

* @param string $out HTTP header string

[148] Fix | Delete

*/

[149] Fix | Delete

public function fsockopen_header(&$out) {

[150] Fix | Delete

$out .= sprintf("Proxy-Authorization: Basic %s\r\n", base64_encode($this->get_auth_string()));

[151] Fix | Delete

}

[152] Fix | Delete

[153] Fix | Delete

/**

[154] Fix | Delete

* Get the authentication string (user:pass)

[155] Fix | Delete

*

[156] Fix | Delete

* @since 1.6

[157] Fix | Delete

* @return string

[158] Fix | Delete

*/

[159] Fix | Delete

public function get_auth_string() {

[160] Fix | Delete

return $this->user . ':' . $this->pass;

[161] Fix | Delete

}

[162] Fix | Delete

}

[163] Fix | Delete

[164] Fix | Delete