@@ -15,164 +15,164 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_ByteStream_ArrayByteStream implements Swift_InputByteStream, Swift_OutputByteStream |
17 | 17 | { |
18 | - /** |
|
19 | - * The internal stack of bytes. |
|
20 | - * |
|
21 | - * @var string[] |
|
22 | - */ |
|
23 | - private $array = []; |
|
24 | - |
|
25 | - /** |
|
26 | - * The size of the stack. |
|
27 | - * |
|
28 | - * @var int |
|
29 | - */ |
|
30 | - private $arraySize = 0; |
|
31 | - |
|
32 | - /** |
|
33 | - * The internal pointer offset. |
|
34 | - * |
|
35 | - * @var int |
|
36 | - */ |
|
37 | - private $offset = 0; |
|
38 | - |
|
39 | - /** |
|
40 | - * Bound streams. |
|
41 | - * |
|
42 | - * @var Swift_InputByteStream[] |
|
43 | - */ |
|
44 | - private $mirrors = []; |
|
45 | - |
|
46 | - /** |
|
47 | - * Create a new ArrayByteStream. |
|
48 | - * |
|
49 | - * If $stack is given the stream will be populated with the bytes it contains. |
|
50 | - * |
|
51 | - * @param mixed $stack of bytes in string or array form, optional |
|
52 | - */ |
|
53 | - public function __construct($stack = null) |
|
54 | - { |
|
55 | - if (\is_array($stack)) { |
|
56 | - $this->array = $stack; |
|
57 | - $this->arraySize = \count($stack); |
|
58 | - } elseif (\is_string($stack)) { |
|
59 | - $this->write($stack); |
|
60 | - } else { |
|
61 | - $this->array = []; |
|
62 | - } |
|
63 | - } |
|
64 | - |
|
65 | - /** |
|
66 | - * Reads $length bytes from the stream into a string and moves the pointer |
|
67 | - * through the stream by $length. |
|
68 | - * |
|
69 | - * If less bytes exist than are requested the |
|
70 | - * remaining bytes are given instead. If no bytes are remaining at all, boolean |
|
71 | - * false is returned. |
|
72 | - * |
|
73 | - * @param int $length |
|
74 | - * |
|
75 | - * @return string |
|
76 | - */ |
|
77 | - public function read($length) |
|
78 | - { |
|
79 | - if ($this->offset == $this->arraySize) { |
|
80 | - return false; |
|
81 | - } |
|
82 | - |
|
83 | - // Don't use array slice |
|
84 | - $end = $length + $this->offset; |
|
85 | - $end = $this->arraySize < $end ? $this->arraySize : $end; |
|
86 | - $ret = ''; |
|
87 | - for (; $this->offset < $end; ++$this->offset) { |
|
88 | - $ret .= $this->array[$this->offset]; |
|
89 | - } |
|
90 | - |
|
91 | - return $ret; |
|
92 | - } |
|
93 | - |
|
94 | - /** |
|
95 | - * Writes $bytes to the end of the stream. |
|
96 | - * |
|
97 | - * @param string $bytes |
|
98 | - */ |
|
99 | - public function write($bytes) |
|
100 | - { |
|
101 | - $to_add = str_split($bytes); |
|
102 | - foreach ($to_add as $value) { |
|
103 | - $this->array[] = $value; |
|
104 | - } |
|
105 | - $this->arraySize = \count($this->array); |
|
106 | - |
|
107 | - foreach ($this->mirrors as $stream) { |
|
108 | - $stream->write($bytes); |
|
109 | - } |
|
110 | - } |
|
111 | - |
|
112 | - /** |
|
113 | - * Not used. |
|
114 | - */ |
|
115 | - public function commit() |
|
116 | - { |
|
117 | - } |
|
118 | - |
|
119 | - /** |
|
120 | - * Attach $is to this stream. |
|
121 | - * |
|
122 | - * The stream acts as an observer, receiving all data that is written. |
|
123 | - * All {@link write()} and {@link flushBuffers()} operations will be mirrored. |
|
124 | - */ |
|
125 | - public function bind(Swift_InputByteStream $is) |
|
126 | - { |
|
127 | - $this->mirrors[] = $is; |
|
128 | - } |
|
129 | - |
|
130 | - /** |
|
131 | - * Remove an already bound stream. |
|
132 | - * |
|
133 | - * If $is is not bound, no errors will be raised. |
|
134 | - * If the stream currently has any buffered data it will be written to $is |
|
135 | - * before unbinding occurs. |
|
136 | - */ |
|
137 | - public function unbind(Swift_InputByteStream $is) |
|
138 | - { |
|
139 | - foreach ($this->mirrors as $k => $stream) { |
|
140 | - if ($is === $stream) { |
|
141 | - unset($this->mirrors[$k]); |
|
142 | - } |
|
143 | - } |
|
144 | - } |
|
145 | - |
|
146 | - /** |
|
147 | - * Move the internal read pointer to $byteOffset in the stream. |
|
148 | - * |
|
149 | - * @param int $byteOffset |
|
150 | - * |
|
151 | - * @return bool |
|
152 | - */ |
|
153 | - public function setReadPointer($byteOffset) |
|
154 | - { |
|
155 | - if ($byteOffset > $this->arraySize) { |
|
156 | - $byteOffset = $this->arraySize; |
|
157 | - } elseif ($byteOffset < 0) { |
|
158 | - $byteOffset = 0; |
|
159 | - } |
|
160 | - |
|
161 | - $this->offset = $byteOffset; |
|
162 | - } |
|
163 | - |
|
164 | - /** |
|
165 | - * Flush the contents of the stream (empty it) and set the internal pointer |
|
166 | - * to the beginning. |
|
167 | - */ |
|
168 | - public function flushBuffers() |
|
169 | - { |
|
170 | - $this->offset = 0; |
|
171 | - $this->array = []; |
|
172 | - $this->arraySize = 0; |
|
173 | - |
|
174 | - foreach ($this->mirrors as $stream) { |
|
175 | - $stream->flushBuffers(); |
|
176 | - } |
|
177 | - } |
|
18 | + /** |
|
19 | + * The internal stack of bytes. |
|
20 | + * |
|
21 | + * @var string[] |
|
22 | + */ |
|
23 | + private $array = []; |
|
24 | + |
|
25 | + /** |
|
26 | + * The size of the stack. |
|
27 | + * |
|
28 | + * @var int |
|
29 | + */ |
|
30 | + private $arraySize = 0; |
|
31 | + |
|
32 | + /** |
|
33 | + * The internal pointer offset. |
|
34 | + * |
|
35 | + * @var int |
|
36 | + */ |
|
37 | + private $offset = 0; |
|
38 | + |
|
39 | + /** |
|
40 | + * Bound streams. |
|
41 | + * |
|
42 | + * @var Swift_InputByteStream[] |
|
43 | + */ |
|
44 | + private $mirrors = []; |
|
45 | + |
|
46 | + /** |
|
47 | + * Create a new ArrayByteStream. |
|
48 | + * |
|
49 | + * If $stack is given the stream will be populated with the bytes it contains. |
|
50 | + * |
|
51 | + * @param mixed $stack of bytes in string or array form, optional |
|
52 | + */ |
|
53 | + public function __construct($stack = null) |
|
54 | + { |
|
55 | + if (\is_array($stack)) { |
|
56 | + $this->array = $stack; |
|
57 | + $this->arraySize = \count($stack); |
|
58 | + } elseif (\is_string($stack)) { |
|
59 | + $this->write($stack); |
|
60 | + } else { |
|
61 | + $this->array = []; |
|
62 | + } |
|
63 | + } |
|
64 | + |
|
65 | + /** |
|
66 | + * Reads $length bytes from the stream into a string and moves the pointer |
|
67 | + * through the stream by $length. |
|
68 | + * |
|
69 | + * If less bytes exist than are requested the |
|
70 | + * remaining bytes are given instead. If no bytes are remaining at all, boolean |
|
71 | + * false is returned. |
|
72 | + * |
|
73 | + * @param int $length |
|
74 | + * |
|
75 | + * @return string |
|
76 | + */ |
|
77 | + public function read($length) |
|
78 | + { |
|
79 | + if ($this->offset == $this->arraySize) { |
|
80 | + return false; |
|
81 | + } |
|
82 | + |
|
83 | + // Don't use array slice |
|
84 | + $end = $length + $this->offset; |
|
85 | + $end = $this->arraySize < $end ? $this->arraySize : $end; |
|
86 | + $ret = ''; |
|
87 | + for (; $this->offset < $end; ++$this->offset) { |
|
88 | + $ret .= $this->array[$this->offset]; |
|
89 | + } |
|
90 | + |
|
91 | + return $ret; |
|
92 | + } |
|
93 | + |
|
94 | + /** |
|
95 | + * Writes $bytes to the end of the stream. |
|
96 | + * |
|
97 | + * @param string $bytes |
|
98 | + */ |
|
99 | + public function write($bytes) |
|
100 | + { |
|
101 | + $to_add = str_split($bytes); |
|
102 | + foreach ($to_add as $value) { |
|
103 | + $this->array[] = $value; |
|
104 | + } |
|
105 | + $this->arraySize = \count($this->array); |
|
106 | + |
|
107 | + foreach ($this->mirrors as $stream) { |
|
108 | + $stream->write($bytes); |
|
109 | + } |
|
110 | + } |
|
111 | + |
|
112 | + /** |
|
113 | + * Not used. |
|
114 | + */ |
|
115 | + public function commit() |
|
116 | + { |
|
117 | + } |
|
118 | + |
|
119 | + /** |
|
120 | + * Attach $is to this stream. |
|
121 | + * |
|
122 | + * The stream acts as an observer, receiving all data that is written. |
|
123 | + * All {@link write()} and {@link flushBuffers()} operations will be mirrored. |
|
124 | + */ |
|
125 | + public function bind(Swift_InputByteStream $is) |
|
126 | + { |
|
127 | + $this->mirrors[] = $is; |
|
128 | + } |
|
129 | + |
|
130 | + /** |
|
131 | + * Remove an already bound stream. |
|
132 | + * |
|
133 | + * If $is is not bound, no errors will be raised. |
|
134 | + * If the stream currently has any buffered data it will be written to $is |
|
135 | + * before unbinding occurs. |
|
136 | + */ |
|
137 | + public function unbind(Swift_InputByteStream $is) |
|
138 | + { |
|
139 | + foreach ($this->mirrors as $k => $stream) { |
|
140 | + if ($is === $stream) { |
|
141 | + unset($this->mirrors[$k]); |
|
142 | + } |
|
143 | + } |
|
144 | + } |
|
145 | + |
|
146 | + /** |
|
147 | + * Move the internal read pointer to $byteOffset in the stream. |
|
148 | + * |
|
149 | + * @param int $byteOffset |
|
150 | + * |
|
151 | + * @return bool |
|
152 | + */ |
|
153 | + public function setReadPointer($byteOffset) |
|
154 | + { |
|
155 | + if ($byteOffset > $this->arraySize) { |
|
156 | + $byteOffset = $this->arraySize; |
|
157 | + } elseif ($byteOffset < 0) { |
|
158 | + $byteOffset = 0; |
|
159 | + } |
|
160 | + |
|
161 | + $this->offset = $byteOffset; |
|
162 | + } |
|
163 | + |
|
164 | + /** |
|
165 | + * Flush the contents of the stream (empty it) and set the internal pointer |
|
166 | + * to the beginning. |
|
167 | + */ |
|
168 | + public function flushBuffers() |
|
169 | + { |
|
170 | + $this->offset = 0; |
|
171 | + $this->array = []; |
|
172 | + $this->arraySize = 0; |
|
173 | + |
|
174 | + foreach ($this->mirrors as $stream) { |
|
175 | + $stream->flushBuffers(); |
|
176 | + } |
|
177 | + } |
|
178 | 178 | } |
@@ -13,40 +13,40 @@ |
||
13 | 13 | */ |
14 | 14 | class Swift_ByteStream_TemporaryFileByteStream extends Swift_ByteStream_FileByteStream |
15 | 15 | { |
16 | - public function __construct() |
|
17 | - { |
|
18 | - $filePath = tempnam(sys_get_temp_dir(), 'FileByteStream'); |
|
19 | - |
|
20 | - if (false === $filePath) { |
|
21 | - throw new Swift_IoException('Failed to retrieve temporary file name.'); |
|
22 | - } |
|
23 | - |
|
24 | - parent::__construct($filePath, true); |
|
25 | - } |
|
26 | - |
|
27 | - public function getContent() |
|
28 | - { |
|
29 | - if (false === ($content = file_get_contents($this->getPath()))) { |
|
30 | - throw new Swift_IoException('Failed to get temporary file content.'); |
|
31 | - } |
|
32 | - |
|
33 | - return $content; |
|
34 | - } |
|
35 | - |
|
36 | - public function __destruct() |
|
37 | - { |
|
38 | - if (file_exists($this->getPath())) { |
|
39 | - @unlink($this->getPath()); |
|
40 | - } |
|
41 | - } |
|
42 | - |
|
43 | - public function __sleep() |
|
44 | - { |
|
45 | - throw new \BadMethodCallException('Cannot serialize '.__CLASS__); |
|
46 | - } |
|
47 | - |
|
48 | - public function __wakeup() |
|
49 | - { |
|
50 | - throw new \BadMethodCallException('Cannot unserialize '.__CLASS__); |
|
51 | - } |
|
16 | + public function __construct() |
|
17 | + { |
|
18 | + $filePath = tempnam(sys_get_temp_dir(), 'FileByteStream'); |
|
19 | + |
|
20 | + if (false === $filePath) { |
|
21 | + throw new Swift_IoException('Failed to retrieve temporary file name.'); |
|
22 | + } |
|
23 | + |
|
24 | + parent::__construct($filePath, true); |
|
25 | + } |
|
26 | + |
|
27 | + public function getContent() |
|
28 | + { |
|
29 | + if (false === ($content = file_get_contents($this->getPath()))) { |
|
30 | + throw new Swift_IoException('Failed to get temporary file content.'); |
|
31 | + } |
|
32 | + |
|
33 | + return $content; |
|
34 | + } |
|
35 | + |
|
36 | + public function __destruct() |
|
37 | + { |
|
38 | + if (file_exists($this->getPath())) { |
|
39 | + @unlink($this->getPath()); |
|
40 | + } |
|
41 | + } |
|
42 | + |
|
43 | + public function __sleep() |
|
44 | + { |
|
45 | + throw new \BadMethodCallException('Cannot serialize '.__CLASS__); |
|
46 | + } |
|
47 | + |
|
48 | + public function __wakeup() |
|
49 | + { |
|
50 | + throw new \BadMethodCallException('Cannot unserialize '.__CLASS__); |
|
51 | + } |
|
52 | 52 | } |
@@ -15,200 +15,200 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_ByteStream_FileByteStream extends Swift_ByteStream_AbstractFilterableInputStream implements Swift_FileStream |
17 | 17 | { |
18 | - /** The internal pointer offset */ |
|
19 | - private $offset = 0; |
|
20 | - |
|
21 | - /** The path to the file */ |
|
22 | - private $path; |
|
23 | - |
|
24 | - /** The mode this file is opened in for writing */ |
|
25 | - private $mode; |
|
26 | - |
|
27 | - /** A lazy-loaded resource handle for reading the file */ |
|
28 | - private $reader; |
|
29 | - |
|
30 | - /** A lazy-loaded resource handle for writing the file */ |
|
31 | - private $writer; |
|
32 | - |
|
33 | - /** If stream is seekable true/false, or null if not known */ |
|
34 | - private $seekable = null; |
|
35 | - |
|
36 | - /** |
|
37 | - * Create a new FileByteStream for $path. |
|
38 | - * |
|
39 | - * @param string $path |
|
40 | - * @param bool $writable if true |
|
41 | - */ |
|
42 | - public function __construct($path, $writable = false) |
|
43 | - { |
|
44 | - if (empty($path)) { |
|
45 | - throw new Swift_IoException('The path cannot be empty'); |
|
46 | - } |
|
47 | - $this->path = $path; |
|
48 | - $this->mode = $writable ? 'w+b' : 'rb'; |
|
49 | - } |
|
50 | - |
|
51 | - /** |
|
52 | - * Get the complete path to the file. |
|
53 | - * |
|
54 | - * @return string |
|
55 | - */ |
|
56 | - public function getPath() |
|
57 | - { |
|
58 | - return $this->path; |
|
59 | - } |
|
60 | - |
|
61 | - /** |
|
62 | - * Reads $length bytes from the stream into a string and moves the pointer |
|
63 | - * through the stream by $length. |
|
64 | - * |
|
65 | - * If less bytes exist than are requested the |
|
66 | - * remaining bytes are given instead. If no bytes are remaining at all, boolean |
|
67 | - * false is returned. |
|
68 | - * |
|
69 | - * @param int $length |
|
70 | - * |
|
71 | - * @return string|bool |
|
72 | - * |
|
73 | - * @throws Swift_IoException |
|
74 | - */ |
|
75 | - public function read($length) |
|
76 | - { |
|
77 | - $fp = $this->getReadHandle(); |
|
78 | - if (!feof($fp)) { |
|
79 | - $bytes = fread($fp, $length); |
|
80 | - $this->offset = ftell($fp); |
|
81 | - |
|
82 | - // If we read one byte after reaching the end of the file |
|
83 | - // feof() will return false and an empty string is returned |
|
84 | - if ((false === $bytes || '' === $bytes) && feof($fp)) { |
|
85 | - $this->resetReadHandle(); |
|
86 | - |
|
87 | - return false; |
|
88 | - } |
|
89 | - |
|
90 | - return $bytes; |
|
91 | - } |
|
92 | - |
|
93 | - $this->resetReadHandle(); |
|
94 | - |
|
95 | - return false; |
|
96 | - } |
|
97 | - |
|
98 | - /** |
|
99 | - * Move the internal read pointer to $byteOffset in the stream. |
|
100 | - * |
|
101 | - * @param int $byteOffset |
|
102 | - * |
|
103 | - * @return bool |
|
104 | - */ |
|
105 | - public function setReadPointer($byteOffset) |
|
106 | - { |
|
107 | - if (isset($this->reader)) { |
|
108 | - $this->seekReadStreamToPosition($byteOffset); |
|
109 | - } |
|
110 | - $this->offset = $byteOffset; |
|
111 | - } |
|
112 | - |
|
113 | - /** Just write the bytes to the file */ |
|
114 | - protected function doCommit($bytes) |
|
115 | - { |
|
116 | - fwrite($this->getWriteHandle(), $bytes); |
|
117 | - $this->resetReadHandle(); |
|
118 | - } |
|
119 | - |
|
120 | - /** Not used */ |
|
121 | - protected function flush() |
|
122 | - { |
|
123 | - } |
|
124 | - |
|
125 | - /** Get the resource for reading */ |
|
126 | - private function getReadHandle() |
|
127 | - { |
|
128 | - if (!isset($this->reader)) { |
|
129 | - $pointer = @fopen($this->path, 'rb'); |
|
130 | - if (!$pointer) { |
|
131 | - throw new Swift_IoException('Unable to open file for reading ['.$this->path.']'); |
|
132 | - } |
|
133 | - $this->reader = $pointer; |
|
134 | - if (0 != $this->offset) { |
|
135 | - $this->getReadStreamSeekableStatus(); |
|
136 | - $this->seekReadStreamToPosition($this->offset); |
|
137 | - } |
|
138 | - } |
|
139 | - |
|
140 | - return $this->reader; |
|
141 | - } |
|
142 | - |
|
143 | - /** Get the resource for writing */ |
|
144 | - private function getWriteHandle() |
|
145 | - { |
|
146 | - if (!isset($this->writer)) { |
|
147 | - if (!$this->writer = fopen($this->path, $this->mode)) { |
|
148 | - throw new Swift_IoException('Unable to open file for writing ['.$this->path.']'); |
|
149 | - } |
|
150 | - } |
|
151 | - |
|
152 | - return $this->writer; |
|
153 | - } |
|
154 | - |
|
155 | - /** Force a reload of the resource for reading */ |
|
156 | - private function resetReadHandle() |
|
157 | - { |
|
158 | - if (isset($this->reader)) { |
|
159 | - fclose($this->reader); |
|
160 | - $this->reader = null; |
|
161 | - } |
|
162 | - } |
|
163 | - |
|
164 | - /** Check if ReadOnly Stream is seekable */ |
|
165 | - private function getReadStreamSeekableStatus() |
|
166 | - { |
|
167 | - $metas = stream_get_meta_data($this->reader); |
|
168 | - $this->seekable = $metas['seekable']; |
|
169 | - } |
|
170 | - |
|
171 | - /** Streams in a readOnly stream ensuring copy if needed */ |
|
172 | - private function seekReadStreamToPosition($offset) |
|
173 | - { |
|
174 | - if (null === $this->seekable) { |
|
175 | - $this->getReadStreamSeekableStatus(); |
|
176 | - } |
|
177 | - if (false === $this->seekable) { |
|
178 | - $currentPos = ftell($this->reader); |
|
179 | - if ($currentPos < $offset) { |
|
180 | - $toDiscard = $offset - $currentPos; |
|
181 | - fread($this->reader, $toDiscard); |
|
182 | - |
|
183 | - return; |
|
184 | - } |
|
185 | - $this->copyReadStream(); |
|
186 | - } |
|
187 | - fseek($this->reader, $offset, SEEK_SET); |
|
188 | - } |
|
189 | - |
|
190 | - /** Copy a readOnly Stream to ensure seekability */ |
|
191 | - private function copyReadStream() |
|
192 | - { |
|
193 | - if ($tmpFile = fopen('php://temp/maxmemory:4096', 'w+b')) { |
|
194 | - /* We have opened a php:// Stream Should work without problem */ |
|
195 | - } elseif (\function_exists('sys_get_temp_dir') && is_writable(sys_get_temp_dir()) && ($tmpFile = tmpfile())) { |
|
196 | - /* We have opened a tmpfile */ |
|
197 | - } else { |
|
198 | - throw new Swift_IoException('Unable to copy the file to make it seekable, sys_temp_dir is not writable, php://memory not available'); |
|
199 | - } |
|
200 | - $currentPos = ftell($this->reader); |
|
201 | - fclose($this->reader); |
|
202 | - $source = fopen($this->path, 'rb'); |
|
203 | - if (!$source) { |
|
204 | - throw new Swift_IoException('Unable to open file for copying ['.$this->path.']'); |
|
205 | - } |
|
206 | - fseek($tmpFile, 0, SEEK_SET); |
|
207 | - while (!feof($source)) { |
|
208 | - fwrite($tmpFile, fread($source, 4096)); |
|
209 | - } |
|
210 | - fseek($tmpFile, $currentPos, SEEK_SET); |
|
211 | - fclose($source); |
|
212 | - $this->reader = $tmpFile; |
|
213 | - } |
|
18 | + /** The internal pointer offset */ |
|
19 | + private $offset = 0; |
|
20 | + |
|
21 | + /** The path to the file */ |
|
22 | + private $path; |
|
23 | + |
|
24 | + /** The mode this file is opened in for writing */ |
|
25 | + private $mode; |
|
26 | + |
|
27 | + /** A lazy-loaded resource handle for reading the file */ |
|
28 | + private $reader; |
|
29 | + |
|
30 | + /** A lazy-loaded resource handle for writing the file */ |
|
31 | + private $writer; |
|
32 | + |
|
33 | + /** If stream is seekable true/false, or null if not known */ |
|
34 | + private $seekable = null; |
|
35 | + |
|
36 | + /** |
|
37 | + * Create a new FileByteStream for $path. |
|
38 | + * |
|
39 | + * @param string $path |
|
40 | + * @param bool $writable if true |
|
41 | + */ |
|
42 | + public function __construct($path, $writable = false) |
|
43 | + { |
|
44 | + if (empty($path)) { |
|
45 | + throw new Swift_IoException('The path cannot be empty'); |
|
46 | + } |
|
47 | + $this->path = $path; |
|
48 | + $this->mode = $writable ? 'w+b' : 'rb'; |
|
49 | + } |
|
50 | + |
|
51 | + /** |
|
52 | + * Get the complete path to the file. |
|
53 | + * |
|
54 | + * @return string |
|
55 | + */ |
|
56 | + public function getPath() |
|
57 | + { |
|
58 | + return $this->path; |
|
59 | + } |
|
60 | + |
|
61 | + /** |
|
62 | + * Reads $length bytes from the stream into a string and moves the pointer |
|
63 | + * through the stream by $length. |
|
64 | + * |
|
65 | + * If less bytes exist than are requested the |
|
66 | + * remaining bytes are given instead. If no bytes are remaining at all, boolean |
|
67 | + * false is returned. |
|
68 | + * |
|
69 | + * @param int $length |
|
70 | + * |
|
71 | + * @return string|bool |
|
72 | + * |
|
73 | + * @throws Swift_IoException |
|
74 | + */ |
|
75 | + public function read($length) |
|
76 | + { |
|
77 | + $fp = $this->getReadHandle(); |
|
78 | + if (!feof($fp)) { |
|
79 | + $bytes = fread($fp, $length); |
|
80 | + $this->offset = ftell($fp); |
|
81 | + |
|
82 | + // If we read one byte after reaching the end of the file |
|
83 | + // feof() will return false and an empty string is returned |
|
84 | + if ((false === $bytes || '' === $bytes) && feof($fp)) { |
|
85 | + $this->resetReadHandle(); |
|
86 | + |
|
87 | + return false; |
|
88 | + } |
|
89 | + |
|
90 | + return $bytes; |
|
91 | + } |
|
92 | + |
|
93 | + $this->resetReadHandle(); |
|
94 | + |
|
95 | + return false; |
|
96 | + } |
|
97 | + |
|
98 | + /** |
|
99 | + * Move the internal read pointer to $byteOffset in the stream. |
|
100 | + * |
|
101 | + * @param int $byteOffset |
|
102 | + * |
|
103 | + * @return bool |
|
104 | + */ |
|
105 | + public function setReadPointer($byteOffset) |
|
106 | + { |
|
107 | + if (isset($this->reader)) { |
|
108 | + $this->seekReadStreamToPosition($byteOffset); |
|
109 | + } |
|
110 | + $this->offset = $byteOffset; |
|
111 | + } |
|
112 | + |
|
113 | + /** Just write the bytes to the file */ |
|
114 | + protected function doCommit($bytes) |
|
115 | + { |
|
116 | + fwrite($this->getWriteHandle(), $bytes); |
|
117 | + $this->resetReadHandle(); |
|
118 | + } |
|
119 | + |
|
120 | + /** Not used */ |
|
121 | + protected function flush() |
|
122 | + { |
|
123 | + } |
|
124 | + |
|
125 | + /** Get the resource for reading */ |
|
126 | + private function getReadHandle() |
|
127 | + { |
|
128 | + if (!isset($this->reader)) { |
|
129 | + $pointer = @fopen($this->path, 'rb'); |
|
130 | + if (!$pointer) { |
|
131 | + throw new Swift_IoException('Unable to open file for reading ['.$this->path.']'); |
|
132 | + } |
|
133 | + $this->reader = $pointer; |
|
134 | + if (0 != $this->offset) { |
|
135 | + $this->getReadStreamSeekableStatus(); |
|
136 | + $this->seekReadStreamToPosition($this->offset); |
|
137 | + } |
|
138 | + } |
|
139 | + |
|
140 | + return $this->reader; |
|
141 | + } |
|
142 | + |
|
143 | + /** Get the resource for writing */ |
|
144 | + private function getWriteHandle() |
|
145 | + { |
|
146 | + if (!isset($this->writer)) { |
|
147 | + if (!$this->writer = fopen($this->path, $this->mode)) { |
|
148 | + throw new Swift_IoException('Unable to open file for writing ['.$this->path.']'); |
|
149 | + } |
|
150 | + } |
|
151 | + |
|
152 | + return $this->writer; |
|
153 | + } |
|
154 | + |
|
155 | + /** Force a reload of the resource for reading */ |
|
156 | + private function resetReadHandle() |
|
157 | + { |
|
158 | + if (isset($this->reader)) { |
|
159 | + fclose($this->reader); |
|
160 | + $this->reader = null; |
|
161 | + } |
|
162 | + } |
|
163 | + |
|
164 | + /** Check if ReadOnly Stream is seekable */ |
|
165 | + private function getReadStreamSeekableStatus() |
|
166 | + { |
|
167 | + $metas = stream_get_meta_data($this->reader); |
|
168 | + $this->seekable = $metas['seekable']; |
|
169 | + } |
|
170 | + |
|
171 | + /** Streams in a readOnly stream ensuring copy if needed */ |
|
172 | + private function seekReadStreamToPosition($offset) |
|
173 | + { |
|
174 | + if (null === $this->seekable) { |
|
175 | + $this->getReadStreamSeekableStatus(); |
|
176 | + } |
|
177 | + if (false === $this->seekable) { |
|
178 | + $currentPos = ftell($this->reader); |
|
179 | + if ($currentPos < $offset) { |
|
180 | + $toDiscard = $offset - $currentPos; |
|
181 | + fread($this->reader, $toDiscard); |
|
182 | + |
|
183 | + return; |
|
184 | + } |
|
185 | + $this->copyReadStream(); |
|
186 | + } |
|
187 | + fseek($this->reader, $offset, SEEK_SET); |
|
188 | + } |
|
189 | + |
|
190 | + /** Copy a readOnly Stream to ensure seekability */ |
|
191 | + private function copyReadStream() |
|
192 | + { |
|
193 | + if ($tmpFile = fopen('php://temp/maxmemory:4096', 'w+b')) { |
|
194 | + /* We have opened a php:// Stream Should work without problem */ |
|
195 | + } elseif (\function_exists('sys_get_temp_dir') && is_writable(sys_get_temp_dir()) && ($tmpFile = tmpfile())) { |
|
196 | + /* We have opened a tmpfile */ |
|
197 | + } else { |
|
198 | + throw new Swift_IoException('Unable to copy the file to make it seekable, sys_temp_dir is not writable, php://memory not available'); |
|
199 | + } |
|
200 | + $currentPos = ftell($this->reader); |
|
201 | + fclose($this->reader); |
|
202 | + $source = fopen($this->path, 'rb'); |
|
203 | + if (!$source) { |
|
204 | + throw new Swift_IoException('Unable to open file for copying ['.$this->path.']'); |
|
205 | + } |
|
206 | + fseek($tmpFile, 0, SEEK_SET); |
|
207 | + while (!feof($source)) { |
|
208 | + fwrite($tmpFile, fread($source, 4096)); |
|
209 | + } |
|
210 | + fseek($tmpFile, $currentPos, SEEK_SET); |
|
211 | + fclose($source); |
|
212 | + $this->reader = $tmpFile; |
|
213 | + } |
|
214 | 214 | } |
@@ -15,56 +15,56 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_StreamFilters_StringReplacementFilter implements Swift_StreamFilter |
17 | 17 | { |
18 | - /** The needle(s) to search for */ |
|
19 | - private $search; |
|
18 | + /** The needle(s) to search for */ |
|
19 | + private $search; |
|
20 | 20 | |
21 | - /** The replacement(s) to make */ |
|
22 | - private $replace; |
|
21 | + /** The replacement(s) to make */ |
|
22 | + private $replace; |
|
23 | 23 | |
24 | - /** |
|
25 | - * Create a new StringReplacementFilter with $search and $replace. |
|
26 | - * |
|
27 | - * @param string|array $search |
|
28 | - * @param string|array $replace |
|
29 | - */ |
|
30 | - public function __construct($search, $replace) |
|
31 | - { |
|
32 | - $this->search = $search; |
|
33 | - $this->replace = $replace; |
|
34 | - } |
|
24 | + /** |
|
25 | + * Create a new StringReplacementFilter with $search and $replace. |
|
26 | + * |
|
27 | + * @param string|array $search |
|
28 | + * @param string|array $replace |
|
29 | + */ |
|
30 | + public function __construct($search, $replace) |
|
31 | + { |
|
32 | + $this->search = $search; |
|
33 | + $this->replace = $replace; |
|
34 | + } |
|
35 | 35 | |
36 | - /** |
|
37 | - * Returns true if based on the buffer passed more bytes should be buffered. |
|
38 | - * |
|
39 | - * @param string $buffer |
|
40 | - * |
|
41 | - * @return bool |
|
42 | - */ |
|
43 | - public function shouldBuffer($buffer) |
|
44 | - { |
|
45 | - if ('' === $buffer) { |
|
46 | - return false; |
|
47 | - } |
|
36 | + /** |
|
37 | + * Returns true if based on the buffer passed more bytes should be buffered. |
|
38 | + * |
|
39 | + * @param string $buffer |
|
40 | + * |
|
41 | + * @return bool |
|
42 | + */ |
|
43 | + public function shouldBuffer($buffer) |
|
44 | + { |
|
45 | + if ('' === $buffer) { |
|
46 | + return false; |
|
47 | + } |
|
48 | 48 | |
49 | - $endOfBuffer = substr($buffer, -1); |
|
50 | - foreach ((array) $this->search as $needle) { |
|
51 | - if (false !== strpos($needle, $endOfBuffer)) { |
|
52 | - return true; |
|
53 | - } |
|
54 | - } |
|
49 | + $endOfBuffer = substr($buffer, -1); |
|
50 | + foreach ((array) $this->search as $needle) { |
|
51 | + if (false !== strpos($needle, $endOfBuffer)) { |
|
52 | + return true; |
|
53 | + } |
|
54 | + } |
|
55 | 55 | |
56 | - return false; |
|
57 | - } |
|
56 | + return false; |
|
57 | + } |
|
58 | 58 | |
59 | - /** |
|
60 | - * Perform the actual replacements on $buffer and return the result. |
|
61 | - * |
|
62 | - * @param string $buffer |
|
63 | - * |
|
64 | - * @return string |
|
65 | - */ |
|
66 | - public function filter($buffer) |
|
67 | - { |
|
68 | - return str_replace($this->search, $this->replace, $buffer); |
|
69 | - } |
|
59 | + /** |
|
60 | + * Perform the actual replacements on $buffer and return the result. |
|
61 | + * |
|
62 | + * @param string $buffer |
|
63 | + * |
|
64 | + * @return string |
|
65 | + */ |
|
66 | + public function filter($buffer) |
|
67 | + { |
|
68 | + return str_replace($this->search, $this->replace, $buffer); |
|
69 | + } |
|
70 | 70 | } |
@@ -17,150 +17,150 @@ |
||
17 | 17 | */ |
18 | 18 | class Swift_StreamFilters_ByteArrayReplacementFilter implements Swift_StreamFilter |
19 | 19 | { |
20 | - /** The replacement(s) to make */ |
|
21 | - private $replace; |
|
20 | + /** The replacement(s) to make */ |
|
21 | + private $replace; |
|
22 | 22 | |
23 | - /** The Index for searching */ |
|
24 | - private $index; |
|
23 | + /** The Index for searching */ |
|
24 | + private $index; |
|
25 | 25 | |
26 | - /** The Search Tree */ |
|
27 | - private $tree = []; |
|
26 | + /** The Search Tree */ |
|
27 | + private $tree = []; |
|
28 | 28 | |
29 | - /** Gives the size of the largest search */ |
|
30 | - private $treeMaxLen = 0; |
|
29 | + /** Gives the size of the largest search */ |
|
30 | + private $treeMaxLen = 0; |
|
31 | 31 | |
32 | - private $repSize; |
|
32 | + private $repSize; |
|
33 | 33 | |
34 | - /** |
|
35 | - * Create a new ByteArrayReplacementFilter with $search and $replace. |
|
36 | - * |
|
37 | - * @param array $search |
|
38 | - * @param array $replace |
|
39 | - */ |
|
40 | - public function __construct($search, $replace) |
|
41 | - { |
|
42 | - $this->index = []; |
|
43 | - $this->tree = []; |
|
44 | - $this->replace = []; |
|
45 | - $this->repSize = []; |
|
34 | + /** |
|
35 | + * Create a new ByteArrayReplacementFilter with $search and $replace. |
|
36 | + * |
|
37 | + * @param array $search |
|
38 | + * @param array $replace |
|
39 | + */ |
|
40 | + public function __construct($search, $replace) |
|
41 | + { |
|
42 | + $this->index = []; |
|
43 | + $this->tree = []; |
|
44 | + $this->replace = []; |
|
45 | + $this->repSize = []; |
|
46 | 46 | |
47 | - $tree = null; |
|
48 | - $i = null; |
|
49 | - $last_size = $size = 0; |
|
50 | - foreach ($search as $i => $search_element) { |
|
51 | - if (null !== $tree) { |
|
52 | - $tree[-1] = min(\count($replace) - 1, $i - 1); |
|
53 | - $tree[-2] = $last_size; |
|
54 | - } |
|
55 | - $tree = &$this->tree; |
|
56 | - if (\is_array($search_element)) { |
|
57 | - foreach ($search_element as $k => $char) { |
|
58 | - $this->index[$char] = true; |
|
59 | - if (!isset($tree[$char])) { |
|
60 | - $tree[$char] = []; |
|
61 | - } |
|
62 | - $tree = &$tree[$char]; |
|
63 | - } |
|
64 | - $last_size = $k + 1; |
|
65 | - $size = max($size, $last_size); |
|
66 | - } else { |
|
67 | - $last_size = 1; |
|
68 | - if (!isset($tree[$search_element])) { |
|
69 | - $tree[$search_element] = []; |
|
70 | - } |
|
71 | - $tree = &$tree[$search_element]; |
|
72 | - $size = max($last_size, $size); |
|
73 | - $this->index[$search_element] = true; |
|
74 | - } |
|
75 | - } |
|
76 | - if (null !== $i) { |
|
77 | - $tree[-1] = min(\count($replace) - 1, $i); |
|
78 | - $tree[-2] = $last_size; |
|
79 | - $this->treeMaxLen = $size; |
|
80 | - } |
|
81 | - foreach ($replace as $rep) { |
|
82 | - if (!\is_array($rep)) { |
|
83 | - $rep = [$rep]; |
|
84 | - } |
|
85 | - $this->replace[] = $rep; |
|
86 | - } |
|
87 | - for ($i = \count($this->replace) - 1; $i >= 0; --$i) { |
|
88 | - $this->replace[$i] = $rep = $this->filter($this->replace[$i], $i); |
|
89 | - $this->repSize[$i] = \count($rep); |
|
90 | - } |
|
91 | - } |
|
47 | + $tree = null; |
|
48 | + $i = null; |
|
49 | + $last_size = $size = 0; |
|
50 | + foreach ($search as $i => $search_element) { |
|
51 | + if (null !== $tree) { |
|
52 | + $tree[-1] = min(\count($replace) - 1, $i - 1); |
|
53 | + $tree[-2] = $last_size; |
|
54 | + } |
|
55 | + $tree = &$this->tree; |
|
56 | + if (\is_array($search_element)) { |
|
57 | + foreach ($search_element as $k => $char) { |
|
58 | + $this->index[$char] = true; |
|
59 | + if (!isset($tree[$char])) { |
|
60 | + $tree[$char] = []; |
|
61 | + } |
|
62 | + $tree = &$tree[$char]; |
|
63 | + } |
|
64 | + $last_size = $k + 1; |
|
65 | + $size = max($size, $last_size); |
|
66 | + } else { |
|
67 | + $last_size = 1; |
|
68 | + if (!isset($tree[$search_element])) { |
|
69 | + $tree[$search_element] = []; |
|
70 | + } |
|
71 | + $tree = &$tree[$search_element]; |
|
72 | + $size = max($last_size, $size); |
|
73 | + $this->index[$search_element] = true; |
|
74 | + } |
|
75 | + } |
|
76 | + if (null !== $i) { |
|
77 | + $tree[-1] = min(\count($replace) - 1, $i); |
|
78 | + $tree[-2] = $last_size; |
|
79 | + $this->treeMaxLen = $size; |
|
80 | + } |
|
81 | + foreach ($replace as $rep) { |
|
82 | + if (!\is_array($rep)) { |
|
83 | + $rep = [$rep]; |
|
84 | + } |
|
85 | + $this->replace[] = $rep; |
|
86 | + } |
|
87 | + for ($i = \count($this->replace) - 1; $i >= 0; --$i) { |
|
88 | + $this->replace[$i] = $rep = $this->filter($this->replace[$i], $i); |
|
89 | + $this->repSize[$i] = \count($rep); |
|
90 | + } |
|
91 | + } |
|
92 | 92 | |
93 | - /** |
|
94 | - * Returns true if based on the buffer passed more bytes should be buffered. |
|
95 | - * |
|
96 | - * @param array $buffer |
|
97 | - * |
|
98 | - * @return bool |
|
99 | - */ |
|
100 | - public function shouldBuffer($buffer) |
|
101 | - { |
|
102 | - $endOfBuffer = end($buffer); |
|
93 | + /** |
|
94 | + * Returns true if based on the buffer passed more bytes should be buffered. |
|
95 | + * |
|
96 | + * @param array $buffer |
|
97 | + * |
|
98 | + * @return bool |
|
99 | + */ |
|
100 | + public function shouldBuffer($buffer) |
|
101 | + { |
|
102 | + $endOfBuffer = end($buffer); |
|
103 | 103 | |
104 | - return isset($this->index[$endOfBuffer]); |
|
105 | - } |
|
104 | + return isset($this->index[$endOfBuffer]); |
|
105 | + } |
|
106 | 106 | |
107 | - /** |
|
108 | - * Perform the actual replacements on $buffer and return the result. |
|
109 | - * |
|
110 | - * @param array $buffer |
|
111 | - * @param int $minReplaces |
|
112 | - * |
|
113 | - * @return array |
|
114 | - */ |
|
115 | - public function filter($buffer, $minReplaces = -1) |
|
116 | - { |
|
117 | - if (0 == $this->treeMaxLen) { |
|
118 | - return $buffer; |
|
119 | - } |
|
107 | + /** |
|
108 | + * Perform the actual replacements on $buffer and return the result. |
|
109 | + * |
|
110 | + * @param array $buffer |
|
111 | + * @param int $minReplaces |
|
112 | + * |
|
113 | + * @return array |
|
114 | + */ |
|
115 | + public function filter($buffer, $minReplaces = -1) |
|
116 | + { |
|
117 | + if (0 == $this->treeMaxLen) { |
|
118 | + return $buffer; |
|
119 | + } |
|
120 | 120 | |
121 | - $newBuffer = []; |
|
122 | - $buf_size = \count($buffer); |
|
123 | - $last_size = 0; |
|
124 | - for ($i = 0; $i < $buf_size; ++$i) { |
|
125 | - $search_pos = $this->tree; |
|
126 | - $last_found = PHP_INT_MAX; |
|
127 | - // We try to find if the next byte is part of a search pattern |
|
128 | - for ($j = 0; $j <= $this->treeMaxLen; ++$j) { |
|
129 | - // We have a new byte for a search pattern |
|
130 | - if (isset($buffer[$p = $i + $j]) && isset($search_pos[$buffer[$p]])) { |
|
131 | - $search_pos = $search_pos[$buffer[$p]]; |
|
132 | - // We have a complete pattern, save, in case we don't find a better match later |
|
133 | - if (isset($search_pos[-1]) && $search_pos[-1] < $last_found |
|
134 | - && $search_pos[-1] > $minReplaces) { |
|
135 | - $last_found = $search_pos[-1]; |
|
136 | - $last_size = $search_pos[-2]; |
|
137 | - } |
|
138 | - } |
|
139 | - // We got a complete pattern |
|
140 | - elseif (PHP_INT_MAX !== $last_found) { |
|
141 | - // Adding replacement datas to output buffer |
|
142 | - $rep_size = $this->repSize[$last_found]; |
|
143 | - for ($j = 0; $j < $rep_size; ++$j) { |
|
144 | - $newBuffer[] = $this->replace[$last_found][$j]; |
|
145 | - } |
|
146 | - // We Move cursor forward |
|
147 | - $i += $last_size - 1; |
|
148 | - // Edge Case, last position in buffer |
|
149 | - if ($i >= $buf_size) { |
|
150 | - $newBuffer[] = $buffer[$i]; |
|
151 | - } |
|
121 | + $newBuffer = []; |
|
122 | + $buf_size = \count($buffer); |
|
123 | + $last_size = 0; |
|
124 | + for ($i = 0; $i < $buf_size; ++$i) { |
|
125 | + $search_pos = $this->tree; |
|
126 | + $last_found = PHP_INT_MAX; |
|
127 | + // We try to find if the next byte is part of a search pattern |
|
128 | + for ($j = 0; $j <= $this->treeMaxLen; ++$j) { |
|
129 | + // We have a new byte for a search pattern |
|
130 | + if (isset($buffer[$p = $i + $j]) && isset($search_pos[$buffer[$p]])) { |
|
131 | + $search_pos = $search_pos[$buffer[$p]]; |
|
132 | + // We have a complete pattern, save, in case we don't find a better match later |
|
133 | + if (isset($search_pos[-1]) && $search_pos[-1] < $last_found |
|
134 | + && $search_pos[-1] > $minReplaces) { |
|
135 | + $last_found = $search_pos[-1]; |
|
136 | + $last_size = $search_pos[-2]; |
|
137 | + } |
|
138 | + } |
|
139 | + // We got a complete pattern |
|
140 | + elseif (PHP_INT_MAX !== $last_found) { |
|
141 | + // Adding replacement datas to output buffer |
|
142 | + $rep_size = $this->repSize[$last_found]; |
|
143 | + for ($j = 0; $j < $rep_size; ++$j) { |
|
144 | + $newBuffer[] = $this->replace[$last_found][$j]; |
|
145 | + } |
|
146 | + // We Move cursor forward |
|
147 | + $i += $last_size - 1; |
|
148 | + // Edge Case, last position in buffer |
|
149 | + if ($i >= $buf_size) { |
|
150 | + $newBuffer[] = $buffer[$i]; |
|
151 | + } |
|
152 | 152 | |
153 | - // We start the next loop |
|
154 | - continue 2; |
|
155 | - } else { |
|
156 | - // this byte is not in a pattern and we haven't found another pattern |
|
157 | - break; |
|
158 | - } |
|
159 | - } |
|
160 | - // Normal byte, move it to output buffer |
|
161 | - $newBuffer[] = $buffer[$i]; |
|
162 | - } |
|
153 | + // We start the next loop |
|
154 | + continue 2; |
|
155 | + } else { |
|
156 | + // this byte is not in a pattern and we haven't found another pattern |
|
157 | + break; |
|
158 | + } |
|
159 | + } |
|
160 | + // Normal byte, move it to output buffer |
|
161 | + $newBuffer[] = $buffer[$i]; |
|
162 | + } |
|
163 | 163 | |
164 | - return $newBuffer; |
|
165 | - } |
|
164 | + return $newBuffer; |
|
165 | + } |
|
166 | 166 | } |
@@ -15,31 +15,31 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_StreamFilters_StringReplacementFilterFactory implements Swift_ReplacementFilterFactory |
17 | 17 | { |
18 | - /** Lazy-loaded filters */ |
|
19 | - private $filters = []; |
|
18 | + /** Lazy-loaded filters */ |
|
19 | + private $filters = []; |
|
20 | 20 | |
21 | - /** |
|
22 | - * Create a new StreamFilter to replace $search with $replace in a string. |
|
23 | - * |
|
24 | - * @param string $search |
|
25 | - * @param string $replace |
|
26 | - * |
|
27 | - * @return Swift_StreamFilter |
|
28 | - */ |
|
29 | - public function createFilter($search, $replace) |
|
30 | - { |
|
31 | - if (!isset($this->filters[$search][$replace])) { |
|
32 | - if (!isset($this->filters[$search])) { |
|
33 | - $this->filters[$search] = []; |
|
34 | - } |
|
21 | + /** |
|
22 | + * Create a new StreamFilter to replace $search with $replace in a string. |
|
23 | + * |
|
24 | + * @param string $search |
|
25 | + * @param string $replace |
|
26 | + * |
|
27 | + * @return Swift_StreamFilter |
|
28 | + */ |
|
29 | + public function createFilter($search, $replace) |
|
30 | + { |
|
31 | + if (!isset($this->filters[$search][$replace])) { |
|
32 | + if (!isset($this->filters[$search])) { |
|
33 | + $this->filters[$search] = []; |
|
34 | + } |
|
35 | 35 | |
36 | - if (!isset($this->filters[$search][$replace])) { |
|
37 | - $this->filters[$search][$replace] = []; |
|
38 | - } |
|
36 | + if (!isset($this->filters[$search][$replace])) { |
|
37 | + $this->filters[$search][$replace] = []; |
|
38 | + } |
|
39 | 39 | |
40 | - $this->filters[$search][$replace] = new Swift_StreamFilters_StringReplacementFilter($search, $replace); |
|
41 | - } |
|
40 | + $this->filters[$search][$replace] = new Swift_StreamFilters_StringReplacementFilter($search, $replace); |
|
41 | + } |
|
42 | 42 | |
43 | - return $this->filters[$search][$replace]; |
|
44 | - } |
|
43 | + return $this->filters[$search][$replace]; |
|
44 | + } |
|
45 | 45 | } |
@@ -15,17 +15,17 @@ |
||
15 | 15 | */ |
16 | 16 | interface Swift_Filterable |
17 | 17 | { |
18 | - /** |
|
19 | - * Add a new StreamFilter, referenced by $key. |
|
20 | - * |
|
21 | - * @param string $key |
|
22 | - */ |
|
23 | - public function addFilter(Swift_StreamFilter $filter, $key); |
|
18 | + /** |
|
19 | + * Add a new StreamFilter, referenced by $key. |
|
20 | + * |
|
21 | + * @param string $key |
|
22 | + */ |
|
23 | + public function addFilter(Swift_StreamFilter $filter, $key); |
|
24 | 24 | |
25 | - /** |
|
26 | - * Remove an existing filter using $key. |
|
27 | - * |
|
28 | - * @param string $key |
|
29 | - */ |
|
30 | - public function removeFilter($key); |
|
25 | + /** |
|
26 | + * Remove an existing filter using $key. |
|
27 | + * |
|
28 | + * @param string $key |
|
29 | + */ |
|
30 | + public function removeFilter($key); |
|
31 | 31 | } |
@@ -15,265 +15,265 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_Message extends Swift_Mime_SimpleMessage |
17 | 17 | { |
18 | - /** |
|
19 | - * @var Swift_Signers_HeaderSigner[] |
|
20 | - */ |
|
21 | - private $headerSigners = []; |
|
22 | - |
|
23 | - /** |
|
24 | - * @var Swift_Signers_BodySigner[] |
|
25 | - */ |
|
26 | - private $bodySigners = []; |
|
27 | - |
|
28 | - /** |
|
29 | - * @var array |
|
30 | - */ |
|
31 | - private $savedMessage = []; |
|
32 | - |
|
33 | - /** |
|
34 | - * Create a new Message. |
|
35 | - * |
|
36 | - * Details may be optionally passed into the constructor. |
|
37 | - * |
|
38 | - * @param string $subject |
|
39 | - * @param string $body |
|
40 | - * @param string $contentType |
|
41 | - * @param string $charset |
|
42 | - */ |
|
43 | - public function __construct($subject = null, $body = null, $contentType = null, $charset = null) |
|
44 | - { |
|
45 | - \call_user_func_array( |
|
46 | - [$this, 'Swift_Mime_SimpleMessage::__construct'], |
|
47 | - Swift_DependencyContainer::getInstance() |
|
48 | - ->createDependenciesFor('mime.message') |
|
49 | - ); |
|
50 | - |
|
51 | - if (!isset($charset)) { |
|
52 | - $charset = Swift_DependencyContainer::getInstance() |
|
53 | - ->lookup('properties.charset'); |
|
54 | - } |
|
55 | - $this->setSubject($subject); |
|
56 | - $this->setBody($body); |
|
57 | - $this->setCharset($charset); |
|
58 | - if ($contentType) { |
|
59 | - $this->setContentType($contentType); |
|
60 | - } |
|
61 | - } |
|
62 | - |
|
63 | - /** |
|
64 | - * Add a MimePart to this Message. |
|
65 | - * |
|
66 | - * @param string|Swift_OutputByteStream $body |
|
67 | - * @param string $contentType |
|
68 | - * @param string $charset |
|
69 | - * |
|
70 | - * @return $this |
|
71 | - */ |
|
72 | - public function addPart($body, $contentType = null, $charset = null) |
|
73 | - { |
|
74 | - return $this->attach((new Swift_MimePart($body, $contentType, $charset))->setEncoder($this->getEncoder())); |
|
75 | - } |
|
76 | - |
|
77 | - /** |
|
78 | - * Attach a new signature handler to the message. |
|
79 | - * |
|
80 | - * @return $this |
|
81 | - */ |
|
82 | - public function attachSigner(Swift_Signer $signer) |
|
83 | - { |
|
84 | - if ($signer instanceof Swift_Signers_HeaderSigner) { |
|
85 | - $this->headerSigners[] = $signer; |
|
86 | - } elseif ($signer instanceof Swift_Signers_BodySigner) { |
|
87 | - $this->bodySigners[] = $signer; |
|
88 | - } |
|
89 | - |
|
90 | - return $this; |
|
91 | - } |
|
92 | - |
|
93 | - /** |
|
94 | - * Detach a signature handler from a message. |
|
95 | - * |
|
96 | - * @return $this |
|
97 | - */ |
|
98 | - public function detachSigner(Swift_Signer $signer) |
|
99 | - { |
|
100 | - if ($signer instanceof Swift_Signers_HeaderSigner) { |
|
101 | - foreach ($this->headerSigners as $k => $headerSigner) { |
|
102 | - if ($headerSigner === $signer) { |
|
103 | - unset($this->headerSigners[$k]); |
|
104 | - |
|
105 | - return $this; |
|
106 | - } |
|
107 | - } |
|
108 | - } elseif ($signer instanceof Swift_Signers_BodySigner) { |
|
109 | - foreach ($this->bodySigners as $k => $bodySigner) { |
|
110 | - if ($bodySigner === $signer) { |
|
111 | - unset($this->bodySigners[$k]); |
|
112 | - |
|
113 | - return $this; |
|
114 | - } |
|
115 | - } |
|
116 | - } |
|
117 | - |
|
118 | - return $this; |
|
119 | - } |
|
120 | - |
|
121 | - /** |
|
122 | - * Clear all signature handlers attached to the message. |
|
123 | - * |
|
124 | - * @return $this |
|
125 | - */ |
|
126 | - public function clearSigners() |
|
127 | - { |
|
128 | - $this->headerSigners = []; |
|
129 | - $this->bodySigners = []; |
|
130 | - |
|
131 | - return $this; |
|
132 | - } |
|
133 | - |
|
134 | - /** |
|
135 | - * Get this message as a complete string. |
|
136 | - * |
|
137 | - * @return string |
|
138 | - */ |
|
139 | - public function toString() |
|
140 | - { |
|
141 | - if (empty($this->headerSigners) && empty($this->bodySigners)) { |
|
142 | - return parent::toString(); |
|
143 | - } |
|
144 | - |
|
145 | - $this->saveMessage(); |
|
146 | - |
|
147 | - $this->doSign(); |
|
148 | - |
|
149 | - $string = parent::toString(); |
|
150 | - |
|
151 | - $this->restoreMessage(); |
|
152 | - |
|
153 | - return $string; |
|
154 | - } |
|
155 | - |
|
156 | - /** |
|
157 | - * Write this message to a {@link Swift_InputByteStream}. |
|
158 | - */ |
|
159 | - public function toByteStream(Swift_InputByteStream $is) |
|
160 | - { |
|
161 | - if (empty($this->headerSigners) && empty($this->bodySigners)) { |
|
162 | - parent::toByteStream($is); |
|
163 | - |
|
164 | - return; |
|
165 | - } |
|
166 | - |
|
167 | - $this->saveMessage(); |
|
168 | - |
|
169 | - $this->doSign(); |
|
170 | - |
|
171 | - parent::toByteStream($is); |
|
172 | - |
|
173 | - $this->restoreMessage(); |
|
174 | - } |
|
175 | - |
|
176 | - public function __wakeup() |
|
177 | - { |
|
178 | - Swift_DependencyContainer::getInstance()->createDependenciesFor('mime.message'); |
|
179 | - } |
|
180 | - |
|
181 | - /** |
|
182 | - * loops through signers and apply the signatures. |
|
183 | - */ |
|
184 | - protected function doSign() |
|
185 | - { |
|
186 | - foreach ($this->bodySigners as $signer) { |
|
187 | - $altered = $signer->getAlteredHeaders(); |
|
188 | - $this->saveHeaders($altered); |
|
189 | - $signer->signMessage($this); |
|
190 | - } |
|
191 | - |
|
192 | - foreach ($this->headerSigners as $signer) { |
|
193 | - $altered = $signer->getAlteredHeaders(); |
|
194 | - $this->saveHeaders($altered); |
|
195 | - $signer->reset(); |
|
196 | - |
|
197 | - $signer->setHeaders($this->getHeaders()); |
|
198 | - |
|
199 | - $signer->startBody(); |
|
200 | - $this->bodyToByteStream($signer); |
|
201 | - $signer->endBody(); |
|
202 | - |
|
203 | - $signer->addSignature($this->getHeaders()); |
|
204 | - } |
|
205 | - } |
|
206 | - |
|
207 | - /** |
|
208 | - * save the message before any signature is applied. |
|
209 | - */ |
|
210 | - protected function saveMessage() |
|
211 | - { |
|
212 | - $this->savedMessage = ['headers' => []]; |
|
213 | - $this->savedMessage['body'] = $this->getBody(); |
|
214 | - $this->savedMessage['children'] = $this->getChildren(); |
|
215 | - if (\count($this->savedMessage['children']) > 0 && '' != $this->getBody()) { |
|
216 | - $this->setChildren(array_merge([$this->becomeMimePart()], $this->savedMessage['children'])); |
|
217 | - $this->setBody(''); |
|
218 | - } |
|
219 | - } |
|
220 | - |
|
221 | - /** |
|
222 | - * save the original headers. |
|
223 | - */ |
|
224 | - protected function saveHeaders(array $altered) |
|
225 | - { |
|
226 | - foreach ($altered as $head) { |
|
227 | - $lc = strtolower($head ?? ''); |
|
228 | - |
|
229 | - if (!isset($this->savedMessage['headers'][$lc])) { |
|
230 | - $this->savedMessage['headers'][$lc] = $this->getHeaders()->getAll($head); |
|
231 | - } |
|
232 | - } |
|
233 | - } |
|
234 | - |
|
235 | - /** |
|
236 | - * Remove or restore altered headers. |
|
237 | - */ |
|
238 | - protected function restoreHeaders() |
|
239 | - { |
|
240 | - foreach ($this->savedMessage['headers'] as $name => $savedValue) { |
|
241 | - $headers = $this->getHeaders()->getAll($name); |
|
242 | - |
|
243 | - foreach ($headers as $key => $value) { |
|
244 | - if (!isset($savedValue[$key])) { |
|
245 | - $this->getHeaders()->remove($name, $key); |
|
246 | - } |
|
247 | - } |
|
248 | - } |
|
249 | - } |
|
250 | - |
|
251 | - /** |
|
252 | - * Restore message body. |
|
253 | - */ |
|
254 | - protected function restoreMessage() |
|
255 | - { |
|
256 | - $this->setBody($this->savedMessage['body']); |
|
257 | - $this->setChildren($this->savedMessage['children']); |
|
258 | - |
|
259 | - $this->restoreHeaders(); |
|
260 | - $this->savedMessage = []; |
|
261 | - } |
|
262 | - |
|
263 | - /** |
|
264 | - * Clone Message Signers. |
|
265 | - * |
|
266 | - * @see Swift_Mime_SimpleMimeEntity::__clone() |
|
267 | - */ |
|
268 | - public function __clone() |
|
269 | - { |
|
270 | - parent::__clone(); |
|
271 | - foreach ($this->bodySigners as $key => $bodySigner) { |
|
272 | - $this->bodySigners[$key] = clone $bodySigner; |
|
273 | - } |
|
274 | - |
|
275 | - foreach ($this->headerSigners as $key => $headerSigner) { |
|
276 | - $this->headerSigners[$key] = clone $headerSigner; |
|
277 | - } |
|
278 | - } |
|
18 | + /** |
|
19 | + * @var Swift_Signers_HeaderSigner[] |
|
20 | + */ |
|
21 | + private $headerSigners = []; |
|
22 | + |
|
23 | + /** |
|
24 | + * @var Swift_Signers_BodySigner[] |
|
25 | + */ |
|
26 | + private $bodySigners = []; |
|
27 | + |
|
28 | + /** |
|
29 | + * @var array |
|
30 | + */ |
|
31 | + private $savedMessage = []; |
|
32 | + |
|
33 | + /** |
|
34 | + * Create a new Message. |
|
35 | + * |
|
36 | + * Details may be optionally passed into the constructor. |
|
37 | + * |
|
38 | + * @param string $subject |
|
39 | + * @param string $body |
|
40 | + * @param string $contentType |
|
41 | + * @param string $charset |
|
42 | + */ |
|
43 | + public function __construct($subject = null, $body = null, $contentType = null, $charset = null) |
|
44 | + { |
|
45 | + \call_user_func_array( |
|
46 | + [$this, 'Swift_Mime_SimpleMessage::__construct'], |
|
47 | + Swift_DependencyContainer::getInstance() |
|
48 | + ->createDependenciesFor('mime.message') |
|
49 | + ); |
|
50 | + |
|
51 | + if (!isset($charset)) { |
|
52 | + $charset = Swift_DependencyContainer::getInstance() |
|
53 | + ->lookup('properties.charset'); |
|
54 | + } |
|
55 | + $this->setSubject($subject); |
|
56 | + $this->setBody($body); |
|
57 | + $this->setCharset($charset); |
|
58 | + if ($contentType) { |
|
59 | + $this->setContentType($contentType); |
|
60 | + } |
|
61 | + } |
|
62 | + |
|
63 | + /** |
|
64 | + * Add a MimePart to this Message. |
|
65 | + * |
|
66 | + * @param string|Swift_OutputByteStream $body |
|
67 | + * @param string $contentType |
|
68 | + * @param string $charset |
|
69 | + * |
|
70 | + * @return $this |
|
71 | + */ |
|
72 | + public function addPart($body, $contentType = null, $charset = null) |
|
73 | + { |
|
74 | + return $this->attach((new Swift_MimePart($body, $contentType, $charset))->setEncoder($this->getEncoder())); |
|
75 | + } |
|
76 | + |
|
77 | + /** |
|
78 | + * Attach a new signature handler to the message. |
|
79 | + * |
|
80 | + * @return $this |
|
81 | + */ |
|
82 | + public function attachSigner(Swift_Signer $signer) |
|
83 | + { |
|
84 | + if ($signer instanceof Swift_Signers_HeaderSigner) { |
|
85 | + $this->headerSigners[] = $signer; |
|
86 | + } elseif ($signer instanceof Swift_Signers_BodySigner) { |
|
87 | + $this->bodySigners[] = $signer; |
|
88 | + } |
|
89 | + |
|
90 | + return $this; |
|
91 | + } |
|
92 | + |
|
93 | + /** |
|
94 | + * Detach a signature handler from a message. |
|
95 | + * |
|
96 | + * @return $this |
|
97 | + */ |
|
98 | + public function detachSigner(Swift_Signer $signer) |
|
99 | + { |
|
100 | + if ($signer instanceof Swift_Signers_HeaderSigner) { |
|
101 | + foreach ($this->headerSigners as $k => $headerSigner) { |
|
102 | + if ($headerSigner === $signer) { |
|
103 | + unset($this->headerSigners[$k]); |
|
104 | + |
|
105 | + return $this; |
|
106 | + } |
|
107 | + } |
|
108 | + } elseif ($signer instanceof Swift_Signers_BodySigner) { |
|
109 | + foreach ($this->bodySigners as $k => $bodySigner) { |
|
110 | + if ($bodySigner === $signer) { |
|
111 | + unset($this->bodySigners[$k]); |
|
112 | + |
|
113 | + return $this; |
|
114 | + } |
|
115 | + } |
|
116 | + } |
|
117 | + |
|
118 | + return $this; |
|
119 | + } |
|
120 | + |
|
121 | + /** |
|
122 | + * Clear all signature handlers attached to the message. |
|
123 | + * |
|
124 | + * @return $this |
|
125 | + */ |
|
126 | + public function clearSigners() |
|
127 | + { |
|
128 | + $this->headerSigners = []; |
|
129 | + $this->bodySigners = []; |
|
130 | + |
|
131 | + return $this; |
|
132 | + } |
|
133 | + |
|
134 | + /** |
|
135 | + * Get this message as a complete string. |
|
136 | + * |
|
137 | + * @return string |
|
138 | + */ |
|
139 | + public function toString() |
|
140 | + { |
|
141 | + if (empty($this->headerSigners) && empty($this->bodySigners)) { |
|
142 | + return parent::toString(); |
|
143 | + } |
|
144 | + |
|
145 | + $this->saveMessage(); |
|
146 | + |
|
147 | + $this->doSign(); |
|
148 | + |
|
149 | + $string = parent::toString(); |
|
150 | + |
|
151 | + $this->restoreMessage(); |
|
152 | + |
|
153 | + return $string; |
|
154 | + } |
|
155 | + |
|
156 | + /** |
|
157 | + * Write this message to a {@link Swift_InputByteStream}. |
|
158 | + */ |
|
159 | + public function toByteStream(Swift_InputByteStream $is) |
|
160 | + { |
|
161 | + if (empty($this->headerSigners) && empty($this->bodySigners)) { |
|
162 | + parent::toByteStream($is); |
|
163 | + |
|
164 | + return; |
|
165 | + } |
|
166 | + |
|
167 | + $this->saveMessage(); |
|
168 | + |
|
169 | + $this->doSign(); |
|
170 | + |
|
171 | + parent::toByteStream($is); |
|
172 | + |
|
173 | + $this->restoreMessage(); |
|
174 | + } |
|
175 | + |
|
176 | + public function __wakeup() |
|
177 | + { |
|
178 | + Swift_DependencyContainer::getInstance()->createDependenciesFor('mime.message'); |
|
179 | + } |
|
180 | + |
|
181 | + /** |
|
182 | + * loops through signers and apply the signatures. |
|
183 | + */ |
|
184 | + protected function doSign() |
|
185 | + { |
|
186 | + foreach ($this->bodySigners as $signer) { |
|
187 | + $altered = $signer->getAlteredHeaders(); |
|
188 | + $this->saveHeaders($altered); |
|
189 | + $signer->signMessage($this); |
|
190 | + } |
|
191 | + |
|
192 | + foreach ($this->headerSigners as $signer) { |
|
193 | + $altered = $signer->getAlteredHeaders(); |
|
194 | + $this->saveHeaders($altered); |
|
195 | + $signer->reset(); |
|
196 | + |
|
197 | + $signer->setHeaders($this->getHeaders()); |
|
198 | + |
|
199 | + $signer->startBody(); |
|
200 | + $this->bodyToByteStream($signer); |
|
201 | + $signer->endBody(); |
|
202 | + |
|
203 | + $signer->addSignature($this->getHeaders()); |
|
204 | + } |
|
205 | + } |
|
206 | + |
|
207 | + /** |
|
208 | + * save the message before any signature is applied. |
|
209 | + */ |
|
210 | + protected function saveMessage() |
|
211 | + { |
|
212 | + $this->savedMessage = ['headers' => []]; |
|
213 | + $this->savedMessage['body'] = $this->getBody(); |
|
214 | + $this->savedMessage['children'] = $this->getChildren(); |
|
215 | + if (\count($this->savedMessage['children']) > 0 && '' != $this->getBody()) { |
|
216 | + $this->setChildren(array_merge([$this->becomeMimePart()], $this->savedMessage['children'])); |
|
217 | + $this->setBody(''); |
|
218 | + } |
|
219 | + } |
|
220 | + |
|
221 | + /** |
|
222 | + * save the original headers. |
|
223 | + */ |
|
224 | + protected function saveHeaders(array $altered) |
|
225 | + { |
|
226 | + foreach ($altered as $head) { |
|
227 | + $lc = strtolower($head ?? ''); |
|
228 | + |
|
229 | + if (!isset($this->savedMessage['headers'][$lc])) { |
|
230 | + $this->savedMessage['headers'][$lc] = $this->getHeaders()->getAll($head); |
|
231 | + } |
|
232 | + } |
|
233 | + } |
|
234 | + |
|
235 | + /** |
|
236 | + * Remove or restore altered headers. |
|
237 | + */ |
|
238 | + protected function restoreHeaders() |
|
239 | + { |
|
240 | + foreach ($this->savedMessage['headers'] as $name => $savedValue) { |
|
241 | + $headers = $this->getHeaders()->getAll($name); |
|
242 | + |
|
243 | + foreach ($headers as $key => $value) { |
|
244 | + if (!isset($savedValue[$key])) { |
|
245 | + $this->getHeaders()->remove($name, $key); |
|
246 | + } |
|
247 | + } |
|
248 | + } |
|
249 | + } |
|
250 | + |
|
251 | + /** |
|
252 | + * Restore message body. |
|
253 | + */ |
|
254 | + protected function restoreMessage() |
|
255 | + { |
|
256 | + $this->setBody($this->savedMessage['body']); |
|
257 | + $this->setChildren($this->savedMessage['children']); |
|
258 | + |
|
259 | + $this->restoreHeaders(); |
|
260 | + $this->savedMessage = []; |
|
261 | + } |
|
262 | + |
|
263 | + /** |
|
264 | + * Clone Message Signers. |
|
265 | + * |
|
266 | + * @see Swift_Mime_SimpleMimeEntity::__clone() |
|
267 | + */ |
|
268 | + public function __clone() |
|
269 | + { |
|
270 | + parent::__clone(); |
|
271 | + foreach ($this->bodySigners as $key => $bodySigner) { |
|
272 | + $this->bodySigners[$key] = clone $bodySigner; |
|
273 | + } |
|
274 | + |
|
275 | + foreach ($this->headerSigners as $key => $headerSigner) { |
|
276 | + $this->headerSigners[$key] = clone $headerSigner; |
|
277 | + } |
|
278 | + } |
|
279 | 279 | } |
@@ -17,284 +17,284 @@ |
||
17 | 17 | */ |
18 | 18 | class Swift_Encoder_QpEncoder implements Swift_Encoder |
19 | 19 | { |
20 | - /** |
|
21 | - * The CharacterStream used for reading characters (as opposed to bytes). |
|
22 | - * |
|
23 | - * @var Swift_CharacterStream |
|
24 | - */ |
|
25 | - protected $charStream; |
|
20 | + /** |
|
21 | + * The CharacterStream used for reading characters (as opposed to bytes). |
|
22 | + * |
|
23 | + * @var Swift_CharacterStream |
|
24 | + */ |
|
25 | + protected $charStream; |
|
26 | 26 | |
27 | - /** |
|
28 | - * A filter used if input should be canonicalized. |
|
29 | - * |
|
30 | - * @var Swift_StreamFilter |
|
31 | - */ |
|
32 | - protected $filter; |
|
27 | + /** |
|
28 | + * A filter used if input should be canonicalized. |
|
29 | + * |
|
30 | + * @var Swift_StreamFilter |
|
31 | + */ |
|
32 | + protected $filter; |
|
33 | 33 | |
34 | - /** |
|
35 | - * Pre-computed QP for HUGE optimization. |
|
36 | - * |
|
37 | - * @var string[] |
|
38 | - */ |
|
39 | - protected static $qpMap = [ |
|
40 | - 0 => '=00', 1 => '=01', 2 => '=02', 3 => '=03', 4 => '=04', |
|
41 | - 5 => '=05', 6 => '=06', 7 => '=07', 8 => '=08', 9 => '=09', |
|
42 | - 10 => '=0A', 11 => '=0B', 12 => '=0C', 13 => '=0D', 14 => '=0E', |
|
43 | - 15 => '=0F', 16 => '=10', 17 => '=11', 18 => '=12', 19 => '=13', |
|
44 | - 20 => '=14', 21 => '=15', 22 => '=16', 23 => '=17', 24 => '=18', |
|
45 | - 25 => '=19', 26 => '=1A', 27 => '=1B', 28 => '=1C', 29 => '=1D', |
|
46 | - 30 => '=1E', 31 => '=1F', 32 => '=20', 33 => '=21', 34 => '=22', |
|
47 | - 35 => '=23', 36 => '=24', 37 => '=25', 38 => '=26', 39 => '=27', |
|
48 | - 40 => '=28', 41 => '=29', 42 => '=2A', 43 => '=2B', 44 => '=2C', |
|
49 | - 45 => '=2D', 46 => '=2E', 47 => '=2F', 48 => '=30', 49 => '=31', |
|
50 | - 50 => '=32', 51 => '=33', 52 => '=34', 53 => '=35', 54 => '=36', |
|
51 | - 55 => '=37', 56 => '=38', 57 => '=39', 58 => '=3A', 59 => '=3B', |
|
52 | - 60 => '=3C', 61 => '=3D', 62 => '=3E', 63 => '=3F', 64 => '=40', |
|
53 | - 65 => '=41', 66 => '=42', 67 => '=43', 68 => '=44', 69 => '=45', |
|
54 | - 70 => '=46', 71 => '=47', 72 => '=48', 73 => '=49', 74 => '=4A', |
|
55 | - 75 => '=4B', 76 => '=4C', 77 => '=4D', 78 => '=4E', 79 => '=4F', |
|
56 | - 80 => '=50', 81 => '=51', 82 => '=52', 83 => '=53', 84 => '=54', |
|
57 | - 85 => '=55', 86 => '=56', 87 => '=57', 88 => '=58', 89 => '=59', |
|
58 | - 90 => '=5A', 91 => '=5B', 92 => '=5C', 93 => '=5D', 94 => '=5E', |
|
59 | - 95 => '=5F', 96 => '=60', 97 => '=61', 98 => '=62', 99 => '=63', |
|
60 | - 100 => '=64', 101 => '=65', 102 => '=66', 103 => '=67', 104 => '=68', |
|
61 | - 105 => '=69', 106 => '=6A', 107 => '=6B', 108 => '=6C', 109 => '=6D', |
|
62 | - 110 => '=6E', 111 => '=6F', 112 => '=70', 113 => '=71', 114 => '=72', |
|
63 | - 115 => '=73', 116 => '=74', 117 => '=75', 118 => '=76', 119 => '=77', |
|
64 | - 120 => '=78', 121 => '=79', 122 => '=7A', 123 => '=7B', 124 => '=7C', |
|
65 | - 125 => '=7D', 126 => '=7E', 127 => '=7F', 128 => '=80', 129 => '=81', |
|
66 | - 130 => '=82', 131 => '=83', 132 => '=84', 133 => '=85', 134 => '=86', |
|
67 | - 135 => '=87', 136 => '=88', 137 => '=89', 138 => '=8A', 139 => '=8B', |
|
68 | - 140 => '=8C', 141 => '=8D', 142 => '=8E', 143 => '=8F', 144 => '=90', |
|
69 | - 145 => '=91', 146 => '=92', 147 => '=93', 148 => '=94', 149 => '=95', |
|
70 | - 150 => '=96', 151 => '=97', 152 => '=98', 153 => '=99', 154 => '=9A', |
|
71 | - 155 => '=9B', 156 => '=9C', 157 => '=9D', 158 => '=9E', 159 => '=9F', |
|
72 | - 160 => '=A0', 161 => '=A1', 162 => '=A2', 163 => '=A3', 164 => '=A4', |
|
73 | - 165 => '=A5', 166 => '=A6', 167 => '=A7', 168 => '=A8', 169 => '=A9', |
|
74 | - 170 => '=AA', 171 => '=AB', 172 => '=AC', 173 => '=AD', 174 => '=AE', |
|
75 | - 175 => '=AF', 176 => '=B0', 177 => '=B1', 178 => '=B2', 179 => '=B3', |
|
76 | - 180 => '=B4', 181 => '=B5', 182 => '=B6', 183 => '=B7', 184 => '=B8', |
|
77 | - 185 => '=B9', 186 => '=BA', 187 => '=BB', 188 => '=BC', 189 => '=BD', |
|
78 | - 190 => '=BE', 191 => '=BF', 192 => '=C0', 193 => '=C1', 194 => '=C2', |
|
79 | - 195 => '=C3', 196 => '=C4', 197 => '=C5', 198 => '=C6', 199 => '=C7', |
|
80 | - 200 => '=C8', 201 => '=C9', 202 => '=CA', 203 => '=CB', 204 => '=CC', |
|
81 | - 205 => '=CD', 206 => '=CE', 207 => '=CF', 208 => '=D0', 209 => '=D1', |
|
82 | - 210 => '=D2', 211 => '=D3', 212 => '=D4', 213 => '=D5', 214 => '=D6', |
|
83 | - 215 => '=D7', 216 => '=D8', 217 => '=D9', 218 => '=DA', 219 => '=DB', |
|
84 | - 220 => '=DC', 221 => '=DD', 222 => '=DE', 223 => '=DF', 224 => '=E0', |
|
85 | - 225 => '=E1', 226 => '=E2', 227 => '=E3', 228 => '=E4', 229 => '=E5', |
|
86 | - 230 => '=E6', 231 => '=E7', 232 => '=E8', 233 => '=E9', 234 => '=EA', |
|
87 | - 235 => '=EB', 236 => '=EC', 237 => '=ED', 238 => '=EE', 239 => '=EF', |
|
88 | - 240 => '=F0', 241 => '=F1', 242 => '=F2', 243 => '=F3', 244 => '=F4', |
|
89 | - 245 => '=F5', 246 => '=F6', 247 => '=F7', 248 => '=F8', 249 => '=F9', |
|
90 | - 250 => '=FA', 251 => '=FB', 252 => '=FC', 253 => '=FD', 254 => '=FE', |
|
91 | - 255 => '=FF', |
|
92 | - ]; |
|
34 | + /** |
|
35 | + * Pre-computed QP for HUGE optimization. |
|
36 | + * |
|
37 | + * @var string[] |
|
38 | + */ |
|
39 | + protected static $qpMap = [ |
|
40 | + 0 => '=00', 1 => '=01', 2 => '=02', 3 => '=03', 4 => '=04', |
|
41 | + 5 => '=05', 6 => '=06', 7 => '=07', 8 => '=08', 9 => '=09', |
|
42 | + 10 => '=0A', 11 => '=0B', 12 => '=0C', 13 => '=0D', 14 => '=0E', |
|
43 | + 15 => '=0F', 16 => '=10', 17 => '=11', 18 => '=12', 19 => '=13', |
|
44 | + 20 => '=14', 21 => '=15', 22 => '=16', 23 => '=17', 24 => '=18', |
|
45 | + 25 => '=19', 26 => '=1A', 27 => '=1B', 28 => '=1C', 29 => '=1D', |
|
46 | + 30 => '=1E', 31 => '=1F', 32 => '=20', 33 => '=21', 34 => '=22', |
|
47 | + 35 => '=23', 36 => '=24', 37 => '=25', 38 => '=26', 39 => '=27', |
|
48 | + 40 => '=28', 41 => '=29', 42 => '=2A', 43 => '=2B', 44 => '=2C', |
|
49 | + 45 => '=2D', 46 => '=2E', 47 => '=2F', 48 => '=30', 49 => '=31', |
|
50 | + 50 => '=32', 51 => '=33', 52 => '=34', 53 => '=35', 54 => '=36', |
|
51 | + 55 => '=37', 56 => '=38', 57 => '=39', 58 => '=3A', 59 => '=3B', |
|
52 | + 60 => '=3C', 61 => '=3D', 62 => '=3E', 63 => '=3F', 64 => '=40', |
|
53 | + 65 => '=41', 66 => '=42', 67 => '=43', 68 => '=44', 69 => '=45', |
|
54 | + 70 => '=46', 71 => '=47', 72 => '=48', 73 => '=49', 74 => '=4A', |
|
55 | + 75 => '=4B', 76 => '=4C', 77 => '=4D', 78 => '=4E', 79 => '=4F', |
|
56 | + 80 => '=50', 81 => '=51', 82 => '=52', 83 => '=53', 84 => '=54', |
|
57 | + 85 => '=55', 86 => '=56', 87 => '=57', 88 => '=58', 89 => '=59', |
|
58 | + 90 => '=5A', 91 => '=5B', 92 => '=5C', 93 => '=5D', 94 => '=5E', |
|
59 | + 95 => '=5F', 96 => '=60', 97 => '=61', 98 => '=62', 99 => '=63', |
|
60 | + 100 => '=64', 101 => '=65', 102 => '=66', 103 => '=67', 104 => '=68', |
|
61 | + 105 => '=69', 106 => '=6A', 107 => '=6B', 108 => '=6C', 109 => '=6D', |
|
62 | + 110 => '=6E', 111 => '=6F', 112 => '=70', 113 => '=71', 114 => '=72', |
|
63 | + 115 => '=73', 116 => '=74', 117 => '=75', 118 => '=76', 119 => '=77', |
|
64 | + 120 => '=78', 121 => '=79', 122 => '=7A', 123 => '=7B', 124 => '=7C', |
|
65 | + 125 => '=7D', 126 => '=7E', 127 => '=7F', 128 => '=80', 129 => '=81', |
|
66 | + 130 => '=82', 131 => '=83', 132 => '=84', 133 => '=85', 134 => '=86', |
|
67 | + 135 => '=87', 136 => '=88', 137 => '=89', 138 => '=8A', 139 => '=8B', |
|
68 | + 140 => '=8C', 141 => '=8D', 142 => '=8E', 143 => '=8F', 144 => '=90', |
|
69 | + 145 => '=91', 146 => '=92', 147 => '=93', 148 => '=94', 149 => '=95', |
|
70 | + 150 => '=96', 151 => '=97', 152 => '=98', 153 => '=99', 154 => '=9A', |
|
71 | + 155 => '=9B', 156 => '=9C', 157 => '=9D', 158 => '=9E', 159 => '=9F', |
|
72 | + 160 => '=A0', 161 => '=A1', 162 => '=A2', 163 => '=A3', 164 => '=A4', |
|
73 | + 165 => '=A5', 166 => '=A6', 167 => '=A7', 168 => '=A8', 169 => '=A9', |
|
74 | + 170 => '=AA', 171 => '=AB', 172 => '=AC', 173 => '=AD', 174 => '=AE', |
|
75 | + 175 => '=AF', 176 => '=B0', 177 => '=B1', 178 => '=B2', 179 => '=B3', |
|
76 | + 180 => '=B4', 181 => '=B5', 182 => '=B6', 183 => '=B7', 184 => '=B8', |
|
77 | + 185 => '=B9', 186 => '=BA', 187 => '=BB', 188 => '=BC', 189 => '=BD', |
|
78 | + 190 => '=BE', 191 => '=BF', 192 => '=C0', 193 => '=C1', 194 => '=C2', |
|
79 | + 195 => '=C3', 196 => '=C4', 197 => '=C5', 198 => '=C6', 199 => '=C7', |
|
80 | + 200 => '=C8', 201 => '=C9', 202 => '=CA', 203 => '=CB', 204 => '=CC', |
|
81 | + 205 => '=CD', 206 => '=CE', 207 => '=CF', 208 => '=D0', 209 => '=D1', |
|
82 | + 210 => '=D2', 211 => '=D3', 212 => '=D4', 213 => '=D5', 214 => '=D6', |
|
83 | + 215 => '=D7', 216 => '=D8', 217 => '=D9', 218 => '=DA', 219 => '=DB', |
|
84 | + 220 => '=DC', 221 => '=DD', 222 => '=DE', 223 => '=DF', 224 => '=E0', |
|
85 | + 225 => '=E1', 226 => '=E2', 227 => '=E3', 228 => '=E4', 229 => '=E5', |
|
86 | + 230 => '=E6', 231 => '=E7', 232 => '=E8', 233 => '=E9', 234 => '=EA', |
|
87 | + 235 => '=EB', 236 => '=EC', 237 => '=ED', 238 => '=EE', 239 => '=EF', |
|
88 | + 240 => '=F0', 241 => '=F1', 242 => '=F2', 243 => '=F3', 244 => '=F4', |
|
89 | + 245 => '=F5', 246 => '=F6', 247 => '=F7', 248 => '=F8', 249 => '=F9', |
|
90 | + 250 => '=FA', 251 => '=FB', 252 => '=FC', 253 => '=FD', 254 => '=FE', |
|
91 | + 255 => '=FF', |
|
92 | + ]; |
|
93 | 93 | |
94 | - protected static $safeMapShare = []; |
|
94 | + protected static $safeMapShare = []; |
|
95 | 95 | |
96 | - /** |
|
97 | - * A map of non-encoded ascii characters. |
|
98 | - * |
|
99 | - * @var string[] |
|
100 | - */ |
|
101 | - protected $safeMap = []; |
|
96 | + /** |
|
97 | + * A map of non-encoded ascii characters. |
|
98 | + * |
|
99 | + * @var string[] |
|
100 | + */ |
|
101 | + protected $safeMap = []; |
|
102 | 102 | |
103 | - /** |
|
104 | - * Creates a new QpEncoder for the given CharacterStream. |
|
105 | - * |
|
106 | - * @param Swift_CharacterStream $charStream to use for reading characters |
|
107 | - * @param Swift_StreamFilter $filter if input should be canonicalized |
|
108 | - */ |
|
109 | - public function __construct(Swift_CharacterStream $charStream, Swift_StreamFilter $filter = null) |
|
110 | - { |
|
111 | - $this->charStream = $charStream; |
|
112 | - if (!isset(self::$safeMapShare[$this->getSafeMapShareId()])) { |
|
113 | - $this->initSafeMap(); |
|
114 | - self::$safeMapShare[$this->getSafeMapShareId()] = $this->safeMap; |
|
115 | - } else { |
|
116 | - $this->safeMap = self::$safeMapShare[$this->getSafeMapShareId()]; |
|
117 | - } |
|
118 | - $this->filter = $filter; |
|
119 | - } |
|
103 | + /** |
|
104 | + * Creates a new QpEncoder for the given CharacterStream. |
|
105 | + * |
|
106 | + * @param Swift_CharacterStream $charStream to use for reading characters |
|
107 | + * @param Swift_StreamFilter $filter if input should be canonicalized |
|
108 | + */ |
|
109 | + public function __construct(Swift_CharacterStream $charStream, Swift_StreamFilter $filter = null) |
|
110 | + { |
|
111 | + $this->charStream = $charStream; |
|
112 | + if (!isset(self::$safeMapShare[$this->getSafeMapShareId()])) { |
|
113 | + $this->initSafeMap(); |
|
114 | + self::$safeMapShare[$this->getSafeMapShareId()] = $this->safeMap; |
|
115 | + } else { |
|
116 | + $this->safeMap = self::$safeMapShare[$this->getSafeMapShareId()]; |
|
117 | + } |
|
118 | + $this->filter = $filter; |
|
119 | + } |
|
120 | 120 | |
121 | - public function __sleep() |
|
122 | - { |
|
123 | - return ['charStream', 'filter']; |
|
124 | - } |
|
121 | + public function __sleep() |
|
122 | + { |
|
123 | + return ['charStream', 'filter']; |
|
124 | + } |
|
125 | 125 | |
126 | - public function __wakeup() |
|
127 | - { |
|
128 | - if (!isset(self::$safeMapShare[$this->getSafeMapShareId()])) { |
|
129 | - $this->initSafeMap(); |
|
130 | - self::$safeMapShare[$this->getSafeMapShareId()] = $this->safeMap; |
|
131 | - } else { |
|
132 | - $this->safeMap = self::$safeMapShare[$this->getSafeMapShareId()]; |
|
133 | - } |
|
134 | - } |
|
126 | + public function __wakeup() |
|
127 | + { |
|
128 | + if (!isset(self::$safeMapShare[$this->getSafeMapShareId()])) { |
|
129 | + $this->initSafeMap(); |
|
130 | + self::$safeMapShare[$this->getSafeMapShareId()] = $this->safeMap; |
|
131 | + } else { |
|
132 | + $this->safeMap = self::$safeMapShare[$this->getSafeMapShareId()]; |
|
133 | + } |
|
134 | + } |
|
135 | 135 | |
136 | - protected function getSafeMapShareId() |
|
137 | - { |
|
138 | - return static::class; |
|
139 | - } |
|
136 | + protected function getSafeMapShareId() |
|
137 | + { |
|
138 | + return static::class; |
|
139 | + } |
|
140 | 140 | |
141 | - protected function initSafeMap() |
|
142 | - { |
|
143 | - foreach (array_merge( |
|
144 | - [0x09, 0x20], range(0x21, 0x3C), range(0x3E, 0x7E)) as $byte) { |
|
145 | - $this->safeMap[$byte] = \chr($byte); |
|
146 | - } |
|
147 | - } |
|
141 | + protected function initSafeMap() |
|
142 | + { |
|
143 | + foreach (array_merge( |
|
144 | + [0x09, 0x20], range(0x21, 0x3C), range(0x3E, 0x7E)) as $byte) { |
|
145 | + $this->safeMap[$byte] = \chr($byte); |
|
146 | + } |
|
147 | + } |
|
148 | 148 | |
149 | - /** |
|
150 | - * Takes an unencoded string and produces a QP encoded string from it. |
|
151 | - * |
|
152 | - * QP encoded strings have a maximum line length of 76 characters. |
|
153 | - * If the first line needs to be shorter, indicate the difference with |
|
154 | - * $firstLineOffset. |
|
155 | - * |
|
156 | - * @param string $string to encode |
|
157 | - * @param int $firstLineOffset optional |
|
158 | - * @param int $maxLineLength optional 0 indicates the default of 76 chars |
|
159 | - * |
|
160 | - * @return string |
|
161 | - */ |
|
162 | - public function encodeString($string, $firstLineOffset = 0, $maxLineLength = 0) |
|
163 | - { |
|
164 | - if ($maxLineLength > 76 || $maxLineLength <= 0) { |
|
165 | - $maxLineLength = 76; |
|
166 | - } |
|
149 | + /** |
|
150 | + * Takes an unencoded string and produces a QP encoded string from it. |
|
151 | + * |
|
152 | + * QP encoded strings have a maximum line length of 76 characters. |
|
153 | + * If the first line needs to be shorter, indicate the difference with |
|
154 | + * $firstLineOffset. |
|
155 | + * |
|
156 | + * @param string $string to encode |
|
157 | + * @param int $firstLineOffset optional |
|
158 | + * @param int $maxLineLength optional 0 indicates the default of 76 chars |
|
159 | + * |
|
160 | + * @return string |
|
161 | + */ |
|
162 | + public function encodeString($string, $firstLineOffset = 0, $maxLineLength = 0) |
|
163 | + { |
|
164 | + if ($maxLineLength > 76 || $maxLineLength <= 0) { |
|
165 | + $maxLineLength = 76; |
|
166 | + } |
|
167 | 167 | |
168 | - $thisLineLength = $maxLineLength - $firstLineOffset; |
|
168 | + $thisLineLength = $maxLineLength - $firstLineOffset; |
|
169 | 169 | |
170 | - $lines = []; |
|
171 | - $lNo = 0; |
|
172 | - $lines[$lNo] = ''; |
|
173 | - $currentLine = &$lines[$lNo++]; |
|
174 | - $size = $lineLen = 0; |
|
170 | + $lines = []; |
|
171 | + $lNo = 0; |
|
172 | + $lines[$lNo] = ''; |
|
173 | + $currentLine = &$lines[$lNo++]; |
|
174 | + $size = $lineLen = 0; |
|
175 | 175 | |
176 | - $this->charStream->flushContents(); |
|
177 | - $this->charStream->importString($string); |
|
176 | + $this->charStream->flushContents(); |
|
177 | + $this->charStream->importString($string); |
|
178 | 178 | |
179 | - // Fetching more than 4 chars at one is slower, as is fetching fewer bytes |
|
180 | - // Conveniently 4 chars is the UTF-8 safe number since UTF-8 has up to 6 |
|
181 | - // bytes per char and (6 * 4 * 3 = 72 chars per line) * =NN is 3 bytes |
|
182 | - while (false !== $bytes = $this->nextSequence()) { |
|
183 | - // If we're filtering the input |
|
184 | - if (isset($this->filter)) { |
|
185 | - // If we can't filter because we need more bytes |
|
186 | - while ($this->filter->shouldBuffer($bytes)) { |
|
187 | - // Then collect bytes into the buffer |
|
188 | - if (false === $moreBytes = $this->nextSequence(1)) { |
|
189 | - break; |
|
190 | - } |
|
179 | + // Fetching more than 4 chars at one is slower, as is fetching fewer bytes |
|
180 | + // Conveniently 4 chars is the UTF-8 safe number since UTF-8 has up to 6 |
|
181 | + // bytes per char and (6 * 4 * 3 = 72 chars per line) * =NN is 3 bytes |
|
182 | + while (false !== $bytes = $this->nextSequence()) { |
|
183 | + // If we're filtering the input |
|
184 | + if (isset($this->filter)) { |
|
185 | + // If we can't filter because we need more bytes |
|
186 | + while ($this->filter->shouldBuffer($bytes)) { |
|
187 | + // Then collect bytes into the buffer |
|
188 | + if (false === $moreBytes = $this->nextSequence(1)) { |
|
189 | + break; |
|
190 | + } |
|
191 | 191 | |
192 | - foreach ($moreBytes as $b) { |
|
193 | - $bytes[] = $b; |
|
194 | - } |
|
195 | - } |
|
196 | - // And filter them |
|
197 | - $bytes = $this->filter->filter($bytes); |
|
198 | - } |
|
192 | + foreach ($moreBytes as $b) { |
|
193 | + $bytes[] = $b; |
|
194 | + } |
|
195 | + } |
|
196 | + // And filter them |
|
197 | + $bytes = $this->filter->filter($bytes); |
|
198 | + } |
|
199 | 199 | |
200 | - $enc = $this->encodeByteSequence($bytes, $size); |
|
200 | + $enc = $this->encodeByteSequence($bytes, $size); |
|
201 | 201 | |
202 | - $i = strpos($enc, '=0D=0A'); |
|
203 | - $newLineLength = $lineLen + (false === $i ? $size : $i); |
|
202 | + $i = strpos($enc, '=0D=0A'); |
|
203 | + $newLineLength = $lineLen + (false === $i ? $size : $i); |
|
204 | 204 | |
205 | - if ($currentLine && $newLineLength >= $thisLineLength) { |
|
206 | - $lines[$lNo] = ''; |
|
207 | - $currentLine = &$lines[$lNo++]; |
|
208 | - $thisLineLength = $maxLineLength; |
|
209 | - $lineLen = 0; |
|
210 | - } |
|
205 | + if ($currentLine && $newLineLength >= $thisLineLength) { |
|
206 | + $lines[$lNo] = ''; |
|
207 | + $currentLine = &$lines[$lNo++]; |
|
208 | + $thisLineLength = $maxLineLength; |
|
209 | + $lineLen = 0; |
|
210 | + } |
|
211 | 211 | |
212 | - $currentLine .= $enc; |
|
212 | + $currentLine .= $enc; |
|
213 | 213 | |
214 | - if (false === $i) { |
|
215 | - $lineLen += $size; |
|
216 | - } else { |
|
217 | - // 6 is the length of '=0D=0A'. |
|
218 | - $lineLen = $size - strrpos($enc, '=0D=0A') - 6; |
|
219 | - } |
|
220 | - } |
|
214 | + if (false === $i) { |
|
215 | + $lineLen += $size; |
|
216 | + } else { |
|
217 | + // 6 is the length of '=0D=0A'. |
|
218 | + $lineLen = $size - strrpos($enc, '=0D=0A') - 6; |
|
219 | + } |
|
220 | + } |
|
221 | 221 | |
222 | - return $this->standardize(implode("=\r\n", $lines)); |
|
223 | - } |
|
222 | + return $this->standardize(implode("=\r\n", $lines)); |
|
223 | + } |
|
224 | 224 | |
225 | - /** |
|
226 | - * Updates the charset used. |
|
227 | - * |
|
228 | - * @param string $charset |
|
229 | - */ |
|
230 | - public function charsetChanged($charset) |
|
231 | - { |
|
232 | - $this->charStream->setCharacterSet($charset); |
|
233 | - } |
|
225 | + /** |
|
226 | + * Updates the charset used. |
|
227 | + * |
|
228 | + * @param string $charset |
|
229 | + */ |
|
230 | + public function charsetChanged($charset) |
|
231 | + { |
|
232 | + $this->charStream->setCharacterSet($charset); |
|
233 | + } |
|
234 | 234 | |
235 | - /** |
|
236 | - * Encode the given byte array into a verbatim QP form. |
|
237 | - * |
|
238 | - * @param int[] $bytes |
|
239 | - * @param int $size |
|
240 | - * |
|
241 | - * @return string |
|
242 | - */ |
|
243 | - protected function encodeByteSequence(array $bytes, &$size) |
|
244 | - { |
|
245 | - $ret = ''; |
|
246 | - $size = 0; |
|
247 | - foreach ($bytes as $b) { |
|
248 | - if (isset($this->safeMap[$b])) { |
|
249 | - $ret .= $this->safeMap[$b]; |
|
250 | - ++$size; |
|
251 | - } else { |
|
252 | - $ret .= self::$qpMap[$b]; |
|
253 | - $size += 3; |
|
254 | - } |
|
255 | - } |
|
235 | + /** |
|
236 | + * Encode the given byte array into a verbatim QP form. |
|
237 | + * |
|
238 | + * @param int[] $bytes |
|
239 | + * @param int $size |
|
240 | + * |
|
241 | + * @return string |
|
242 | + */ |
|
243 | + protected function encodeByteSequence(array $bytes, &$size) |
|
244 | + { |
|
245 | + $ret = ''; |
|
246 | + $size = 0; |
|
247 | + foreach ($bytes as $b) { |
|
248 | + if (isset($this->safeMap[$b])) { |
|
249 | + $ret .= $this->safeMap[$b]; |
|
250 | + ++$size; |
|
251 | + } else { |
|
252 | + $ret .= self::$qpMap[$b]; |
|
253 | + $size += 3; |
|
254 | + } |
|
255 | + } |
|
256 | 256 | |
257 | - return $ret; |
|
258 | - } |
|
257 | + return $ret; |
|
258 | + } |
|
259 | 259 | |
260 | - /** |
|
261 | - * Get the next sequence of bytes to read from the char stream. |
|
262 | - * |
|
263 | - * @param int $size number of bytes to read |
|
264 | - * |
|
265 | - * @return int[] |
|
266 | - */ |
|
267 | - protected function nextSequence($size = 4) |
|
268 | - { |
|
269 | - return $this->charStream->readBytes($size); |
|
270 | - } |
|
260 | + /** |
|
261 | + * Get the next sequence of bytes to read from the char stream. |
|
262 | + * |
|
263 | + * @param int $size number of bytes to read |
|
264 | + * |
|
265 | + * @return int[] |
|
266 | + */ |
|
267 | + protected function nextSequence($size = 4) |
|
268 | + { |
|
269 | + return $this->charStream->readBytes($size); |
|
270 | + } |
|
271 | 271 | |
272 | - /** |
|
273 | - * Make sure CRLF is correct and HT/SPACE are in valid places. |
|
274 | - * |
|
275 | - * @param string $string |
|
276 | - * |
|
277 | - * @return string |
|
278 | - */ |
|
279 | - protected function standardize($string) |
|
280 | - { |
|
281 | - $string = str_replace(["\t=0D=0A", ' =0D=0A', '=0D=0A'], |
|
282 | - ["=09\r\n", "=20\r\n", "\r\n"], $string |
|
283 | - ); |
|
284 | - switch ($end = \ord(substr($string, -1))) { |
|
285 | - case 0x09: |
|
286 | - case 0x20: |
|
287 | - $string = substr_replace($string, self::$qpMap[$end], -1); |
|
288 | - } |
|
272 | + /** |
|
273 | + * Make sure CRLF is correct and HT/SPACE are in valid places. |
|
274 | + * |
|
275 | + * @param string $string |
|
276 | + * |
|
277 | + * @return string |
|
278 | + */ |
|
279 | + protected function standardize($string) |
|
280 | + { |
|
281 | + $string = str_replace(["\t=0D=0A", ' =0D=0A', '=0D=0A'], |
|
282 | + ["=09\r\n", "=20\r\n", "\r\n"], $string |
|
283 | + ); |
|
284 | + switch ($end = \ord(substr($string, -1))) { |
|
285 | + case 0x09: |
|
286 | + case 0x20: |
|
287 | + $string = substr_replace($string, self::$qpMap[$end], -1); |
|
288 | + } |
|
289 | 289 | |
290 | - return $string; |
|
291 | - } |
|
290 | + return $string; |
|
291 | + } |
|
292 | 292 | |
293 | - /** |
|
294 | - * Make a deep copy of object. |
|
295 | - */ |
|
296 | - public function __clone() |
|
297 | - { |
|
298 | - $this->charStream = clone $this->charStream; |
|
299 | - } |
|
293 | + /** |
|
294 | + * Make a deep copy of object. |
|
295 | + */ |
|
296 | + public function __clone() |
|
297 | + { |
|
298 | + $this->charStream = clone $this->charStream; |
|
299 | + } |
|
300 | 300 | } |