← Back to branch summary

~ballot/wordpress/openstack-objectstorage

« back to all changes in this revision

Viewing changes to vendor/guzzlehttp/guzzle/src/Message/MessageParser.php

  • Committer: Benjamin Allot
  • Date: 2020-07-02 16:31:38 UTC
  • Revision ID: benjamin.allot@canonical.com-20200702163138-qyk6njanak5uw2pg
Revert to revno 3

Show diffs side-by-side

added added

removed removed

Lines of Context:
vendor/guzzlehttp/guzzle/src/Message/MessageParser.php
1
 
<?php
2
 
namespace GuzzleHttp\Message;
3
 
 
4
 
/**
5
 
 * Request and response parser used by Guzzle
6
 
 */
7
 
class MessageParser
8
 
{
9
 
    /**
10
 
     * Parse an HTTP request message into an associative array of parts.
11
 
     *
12
 
     * @param string $message HTTP request to parse
13
 
     *
14
 
     * @return array|bool Returns false if the message is invalid
15
 
     */
16
 
    public function parseRequest($message)
17
 
    {
18
 
        if (!($parts = $this->parseMessage($message))) {
19
 
            return false;
20
 
        }
21
 
 
22
 
        // Parse the protocol and protocol version
23
 
        if (isset($parts['start_line'][2])) {
24
 
            $startParts = explode('/', $parts['start_line'][2]);
25
 
            $protocol = strtoupper($startParts[0]);
26
 
            $version = isset($startParts[1]) ? $startParts[1] : '1.1';
27
 
        } else {
28
 
            $protocol = 'HTTP';
29
 
            $version = '1.1';
30
 
        }
31
 
 
32
 
        $parsed = [
33
 
            'method'   => strtoupper($parts['start_line'][0]),
34
 
            'protocol' => $protocol,
35
 
            'protocol_version' => $version,
36
 
            'headers'  => $parts['headers'],
37
 
            'body'     => $parts['body']
38
 
        ];
39
 
 
40
 
        $parsed['request_url'] = $this->getUrlPartsFromMessage(
41
 
            (isset($parts['start_line'][1]) ? $parts['start_line'][1] : ''), $parsed);
42
 
 
43
 
        return $parsed;
44
 
    }
45
 
 
46
 
    /**
47
 
     * Parse an HTTP response message into an associative array of parts.
48
 
     *
49
 
     * @param string $message HTTP response to parse
50
 
     *
51
 
     * @return array|bool Returns false if the message is invalid
52
 
     */
53
 
    public function parseResponse($message)
54
 
    {
55
 
        if (!($parts = $this->parseMessage($message))) {
56
 
            return false;
57
 
        }
58
 
 
59
 
        list($protocol, $version) = explode('/', trim($parts['start_line'][0]));
60
 
 
61
 
        return [
62
 
            'protocol'         => $protocol,
63
 
            'protocol_version' => $version,
64
 
            'code'             => $parts['start_line'][1],
65
 
            'reason_phrase'    => isset($parts['start_line'][2]) ? $parts['start_line'][2] : '',
66
 
            'headers'          => $parts['headers'],
67
 
            'body'             => $parts['body']
68
 
        ];
69
 
    }
70
 
 
71
 
    /**
72
 
     * Parse a message into parts
73
 
     *
74
 
     * @param string $message Message to parse
75
 
     *
76
 
     * @return array|bool
77
 
     */
78
 
    private function parseMessage($message)
79
 
    {
80
 
        if (!$message) {
81
 
            return false;
82
 
        }
83
 
 
84
 
        $startLine = null;
85
 
        $headers = [];
86
 
        $body = '';
87
 
 
88
 
        // Iterate over each line in the message, accounting for line endings
89
 
        $lines = preg_split('/(\\r?\\n)/', $message, -1, PREG_SPLIT_DELIM_CAPTURE);
90
 
        for ($i = 0, $totalLines = count($lines); $i < $totalLines; $i += 2) {
91
 
 
92
 
            $line = $lines[$i];
93
 
 
94
 
            // If two line breaks were encountered, then this is the end of body
95
 
            if (empty($line)) {
96
 
                if ($i < $totalLines - 1) {
97
 
                    $body = implode('', array_slice($lines, $i + 2));
98
 
                }
99
 
                break;
100
 
            }
101
 
 
102
 
            // Parse message headers
103
 
            if (!$startLine) {
104
 
                $startLine = explode(' ', $line, 3);
105
 
            } elseif (strpos($line, ':')) {
106
 
                $parts = explode(':', $line, 2);
107
 
                $key = trim($parts[0]);
108
 
                $value = isset($parts[1]) ? trim($parts[1]) : '';
109
 
                if (!isset($headers[$key])) {
110
 
                    $headers[$key] = $value;
111
 
                } elseif (!is_array($headers[$key])) {
112
 
                    $headers[$key] = [$headers[$key], $value];
113
 
                } else {
114
 
                    $headers[$key][] = $value;
115
 
                }
116
 
            }
117
 
        }
118
 
 
119
 
        return [
120
 
            'start_line' => $startLine,
121
 
            'headers'    => $headers,
122
 
            'body'       => $body
123
 
        ];
124
 
    }
125
 
 
126
 
    /**
127
 
     * Create URL parts from HTTP message parts
128
 
     *
129
 
     * @param string $requestUrl Associated URL
130
 
     * @param array  $parts      HTTP message parts
131
 
     *
132
 
     * @return array
133
 
     */
134
 
    private function getUrlPartsFromMessage($requestUrl, array $parts)
135
 
    {
136
 
        // Parse the URL information from the message
137
 
        $urlParts = ['path' => $requestUrl, 'scheme' => 'http'];
138
 
 
139
 
        // Check for the Host header
140
 
        if (isset($parts['headers']['Host'])) {
141
 
            $urlParts['host'] = $parts['headers']['Host'];
142
 
        } elseif (isset($parts['headers']['host'])) {
143
 
            $urlParts['host'] = $parts['headers']['host'];
144
 
        } else {
145
 
            $urlParts['host'] = null;
146
 
        }
147
 
 
148
 
        if (false === strpos($urlParts['host'], ':')) {
149
 
            $urlParts['port'] = '';
150
 
        } else {
151
 
            $hostParts = explode(':', $urlParts['host']);
152
 
            $urlParts['host'] = trim($hostParts[0]);
153
 
            $urlParts['port'] = (int) trim($hostParts[1]);
154
 
            if ($urlParts['port'] == 443) {
155
 
                $urlParts['scheme'] = 'https';
156
 
            }
157
 
        }
158
 
 
159
 
        // Check if a query is present
160
 
        $path = $urlParts['path'];
161
 
        $qpos = strpos($path, '?');
162
 
        if ($qpos) {
163
 
            $urlParts['query'] = substr($path, $qpos + 1);
164
 
            $urlParts['path'] = substr($path, 0, $qpos);
165
 
        } else {
166
 
            $urlParts['query'] = '';
167
 
        }
168
 
 
169
 
        return $urlParts;
170
 
    }
171
 
}