1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
<?php
/**
* Copyright 2007-2014 Horde LLC (http://www.horde.org/)
*
* @author Chuck Hagenbuch <chuck@horde.org>
* @license http://www.horde.org/licenses/bsd BSD
* @category Horde
* @package Http
*/
/**
* @author Chuck Hagenbuch <chuck@horde.org>
* @license http://www.horde.org/licenses/bsd BSD
* @category Horde
* @package Http
*/
class Horde_Http_Request_Curl extends Horde_Http_Request_Base
{
/**
* Map of HTTP authentication schemes from Horde_Http constants to
* HTTP_AUTH constants.
*
* @var array
*/
protected $_httpAuthSchemes = array(
Horde_Http::AUTH_ANY => CURLAUTH_ANY,
Horde_Http::AUTH_BASIC => CURLAUTH_BASIC,
Horde_Http::AUTH_DIGEST => CURLAUTH_DIGEST,
Horde_Http::AUTH_GSSNEGOTIATE => CURLAUTH_GSSNEGOTIATE,
Horde_Http::AUTH_NTLM => CURLAUTH_NTLM,
);
/**
* Constructor
*
* @throws Horde_Http_Exception
*/
public function __construct($args = array())
{
if (!extension_loaded('curl')) {
throw new Horde_Http_Exception('The curl extension is not installed. See http://php.net/curl.installation');
}
parent::__construct($args);
}
/**
* Send this HTTP request
*
* @throws Horde_Http_Exception
* @return Horde_Http_Response_Base
*/
public function send()
{
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $this->uri);
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
curl_setopt($curl, CURLOPT_HEADER, true);
curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $this->method);
curl_setopt($curl, CURLOPT_TIMEOUT, $this->timeout);
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, $this->verifyPeer);
// User-Agent
curl_setopt($curl, CURLOPT_USERAGENT, $this->userAgent);
// Redirects
if ($this->redirects) {
curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
curl_setopt($curl, CURLOPT_MAXREDIRS, $this->redirects);
} else {
curl_setopt($curl, CURLOPT_FOLLOWLOCATION, false);
curl_setopt($curl, CURLOPT_MAXREDIRS, 0);
}
$data = $this->data;
if (is_array($data)) {
// If we don't set POSTFIELDS to a string, and the first value
// begins with @, it will be treated as a filename, and the proper
// POST data isn't passed.
$data = http_build_query($data);
}
if ($data) {
curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
}
// Proxy settings
if ($this->proxyServer) {
curl_setopt($curl, CURLOPT_PROXY, $this->proxyServer);
if ($this->proxyPort) {
curl_setopt($curl, CURLOPT_PROXYPORT, $this->proxyPort);
}
if ($this->proxyUsername && $this->proxyPassword) {
curl_setopt($curl, CURLOPT_PROXYUSERPWD, $this->proxyUsername . ':' . $this->proxyPassword);
curl_setopt($curl, CURLOPT_PROXYAUTH, $this->_httpAuthScheme($this->proxyAuthenticationScheme));
}
if ($this->proxyType == Horde_Http::PROXY_SOCKS5) {
curl_setopt($curl, CURLOPT_PROXYTYPE, CURLPROXY_SOCKS5);
} else if ($this->proxyType != Horde_Http::PROXY_HTTP) {
throw new Horde_Http_Exception(sprintf('Proxy type %s not supported by this request type!', $this->proxyType));
}
}
// Authentication settings
if ($this->username) {
curl_setopt($curl, CURLOPT_USERPWD, $this->username . ':' . $this->password);
curl_setopt($curl, CURLOPT_HTTPAUTH, $this->_httpAuthScheme($this->authenticationScheme));
}
// Concatenate the headers
$hdr = array();
$headers = $this->headers;
if (empty($headers['Expect'])) {
$headers['Expect'] = '';
}
foreach ($headers as $header => $value) {
$hdr[] = $header . ': ' . $value;
}
curl_setopt($curl, CURLOPT_HTTPHEADER, $hdr);
$result = curl_exec($curl);
if ($result === false) {
throw new Horde_Http_Exception(curl_error($curl), curl_errno($curl));
}
$info = curl_getinfo($curl);
return new Horde_Http_Response_Curl($this->uri, $result, $info);
}
/**
* Translate a Horde_Http::AUTH_* constant to CURLAUTH_*
*
* @param const
* @throws Horde_Http_Exception
* @return const
*/
protected function _httpAuthScheme($httpAuthScheme)
{
if (!isset($this->_httpAuthSchemes[$httpAuthScheme])) {
throw new Horde_Http_Exception('Unsupported authentication scheme (' . $httpAuthScheme . ')');
}
return $this->_httpAuthSchemes[$httpAuthScheme];
}
}
|
