-
Notifications
You must be signed in to change notification settings - Fork 0
/
http.class.php
97 lines (83 loc) · 3.01 KB
/
http.class.php
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
<?php
class httpWorker {
public static function get($url, $additional_headers=null) {
return self::request($url, 'GET', '', $additional_headers);
}
public static function post($url, $request, $additional_headers=null) {
return self::request($url, 'POST', $request, $additional_headers);
}
public static function request($url, $method = null, $request = null, $additional_headers = null) {
if (empty($method)) $method = 'GET';
if (!is_string($method)) throw new Exception('HTTP Method Required');
$method = strtoupper($method);
# if ($method == 'GET' and empty($additional_headers)) return file_get_contents(urlencode($url));
# if ($method == 'HEAD' and empty($additional_headers)) return get_headers($url, 1);
if (empty($request)) {
if (!in_array($method, array('GET', 'DELETE', 'HEAD', 'TRACE', 'OPTIONS', 'CONNECT', 'PURGE')))
throw new Exception("HTTP Method $method requires \$request data");
else $request = '';
}
if (is_array($request)) {
$version = explode('.', phpversion());
$version = (float) "{$version[0]}.{$version[1]}";
if ($version >= 5.4)
$request = http_build_query($request, 'var', '&', PHP_QUERY_RFC3986);
else
$request = http_build_query($request, 'var', '&');
}
if (empty($url) or !filter_var($url, FILTER_VALIDATE_URL))
throw new Exception("Valid URL required");
$url = parse_url($url);
if (empty($url['host'])) throw new Exception("Host name required in URL");
if (empty($url['path'])) $url['path'] = '/';
// Set Scheme and Port
switch ($url['scheme']) {
case 'https':
$hostname = "ssl://{$url['host']}";
$url['port'] = 443;
break;
default: // Simple HTTP
$hostname = $url['host'];
$url['scheme'] = 'http';
$url['port'] = 80;
}
$length = strlen($request);
if (empty($url['query'])) $url['query'] = '';
if (!empty($url['query']) and strpos($url['query'], '?') !== 0) $url['query'] = "?{$url['query']}";
// Add Headers
$headers = "$method {$url['path']}{$url['query']} HTTP/1.1\r\n";
$headers .= "Host: {$url['host']}\r\n";
$headers .= "Connection: close\r\n";
$headers .= "Content-Length: $length\r\n";
if (!empty($additional_headers) and is_array($additional_headers)) {
foreach ($additional_headers as $header) $headers .= trim($header) . "\r\n";
}
if (!empty($request))
$headers .= "Content-Type: application/x-www-form-urlencoded\r\n";
$request = "$headers\r\n$request";
$fp = fsockopen($hostname, $url['port'], $errno, $errstr);
fwrite($fp, $request);
$response = '';
while (!feof($fp)) {
$response .= fgets($fp, 1024);
}
fclose($fp);
list($response_header, $response) = explode("\r\n\r\n", $response, 2);
$headers = array();
$response_header = explode("\r\n", $response_header);
foreach ($response_header as $line) {
if (strpos($line, ':')) {
list($key, $val) = explode(':', $line, 2);
$headers[$key] = trim($val);
} else {
$headers[0] = $line;
}
}
return array(
0 => $headers,
1 => $response,
'headers' => $headers,
'response' => $response,
);
}
}?>