@@ -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 | } |
@@ -15,76 +15,76 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_Encoder_Rfc2231Encoder implements Swift_Encoder |
17 | 17 | { |
18 | - /** |
|
19 | - * A character stream to use when reading a string as characters instead of bytes. |
|
20 | - * |
|
21 | - * @var Swift_CharacterStream |
|
22 | - */ |
|
23 | - private $charStream; |
|
18 | + /** |
|
19 | + * A character stream to use when reading a string as characters instead of bytes. |
|
20 | + * |
|
21 | + * @var Swift_CharacterStream |
|
22 | + */ |
|
23 | + private $charStream; |
|
24 | 24 | |
25 | - /** |
|
26 | - * Creates a new Rfc2231Encoder using the given character stream instance. |
|
27 | - */ |
|
28 | - public function __construct(Swift_CharacterStream $charStream) |
|
29 | - { |
|
30 | - $this->charStream = $charStream; |
|
31 | - } |
|
25 | + /** |
|
26 | + * Creates a new Rfc2231Encoder using the given character stream instance. |
|
27 | + */ |
|
28 | + public function __construct(Swift_CharacterStream $charStream) |
|
29 | + { |
|
30 | + $this->charStream = $charStream; |
|
31 | + } |
|
32 | 32 | |
33 | - /** |
|
34 | - * Takes an unencoded string and produces a string encoded according to |
|
35 | - * RFC 2231 from it. |
|
36 | - * |
|
37 | - * @param string $string |
|
38 | - * @param int $firstLineOffset |
|
39 | - * @param int $maxLineLength optional, 0 indicates the default of 75 bytes |
|
40 | - * |
|
41 | - * @return string |
|
42 | - */ |
|
43 | - public function encodeString($string, $firstLineOffset = 0, $maxLineLength = 0) |
|
44 | - { |
|
45 | - $lines = []; |
|
46 | - $lineCount = 0; |
|
47 | - $lines[] = ''; |
|
48 | - $currentLine = &$lines[$lineCount++]; |
|
33 | + /** |
|
34 | + * Takes an unencoded string and produces a string encoded according to |
|
35 | + * RFC 2231 from it. |
|
36 | + * |
|
37 | + * @param string $string |
|
38 | + * @param int $firstLineOffset |
|
39 | + * @param int $maxLineLength optional, 0 indicates the default of 75 bytes |
|
40 | + * |
|
41 | + * @return string |
|
42 | + */ |
|
43 | + public function encodeString($string, $firstLineOffset = 0, $maxLineLength = 0) |
|
44 | + { |
|
45 | + $lines = []; |
|
46 | + $lineCount = 0; |
|
47 | + $lines[] = ''; |
|
48 | + $currentLine = &$lines[$lineCount++]; |
|
49 | 49 | |
50 | - if (0 >= $maxLineLength) { |
|
51 | - $maxLineLength = 75; |
|
52 | - } |
|
50 | + if (0 >= $maxLineLength) { |
|
51 | + $maxLineLength = 75; |
|
52 | + } |
|
53 | 53 | |
54 | - $this->charStream->flushContents(); |
|
55 | - $this->charStream->importString($string); |
|
54 | + $this->charStream->flushContents(); |
|
55 | + $this->charStream->importString($string); |
|
56 | 56 | |
57 | - $thisLineLength = $maxLineLength - $firstLineOffset; |
|
57 | + $thisLineLength = $maxLineLength - $firstLineOffset; |
|
58 | 58 | |
59 | - while (false !== $char = $this->charStream->read(4)) { |
|
60 | - $encodedChar = rawurlencode($char); |
|
61 | - if (0 != \strlen($currentLine) |
|
62 | - && \strlen($currentLine.$encodedChar) > $thisLineLength) { |
|
63 | - $lines[] = ''; |
|
64 | - $currentLine = &$lines[$lineCount++]; |
|
65 | - $thisLineLength = $maxLineLength; |
|
66 | - } |
|
67 | - $currentLine .= $encodedChar; |
|
68 | - } |
|
59 | + while (false !== $char = $this->charStream->read(4)) { |
|
60 | + $encodedChar = rawurlencode($char); |
|
61 | + if (0 != \strlen($currentLine) |
|
62 | + && \strlen($currentLine.$encodedChar) > $thisLineLength) { |
|
63 | + $lines[] = ''; |
|
64 | + $currentLine = &$lines[$lineCount++]; |
|
65 | + $thisLineLength = $maxLineLength; |
|
66 | + } |
|
67 | + $currentLine .= $encodedChar; |
|
68 | + } |
|
69 | 69 | |
70 | - return implode("\r\n", $lines); |
|
71 | - } |
|
70 | + return implode("\r\n", $lines); |
|
71 | + } |
|
72 | 72 | |
73 | - /** |
|
74 | - * Updates the charset used. |
|
75 | - * |
|
76 | - * @param string $charset |
|
77 | - */ |
|
78 | - public function charsetChanged($charset) |
|
79 | - { |
|
80 | - $this->charStream->setCharacterSet($charset); |
|
81 | - } |
|
73 | + /** |
|
74 | + * Updates the charset used. |
|
75 | + * |
|
76 | + * @param string $charset |
|
77 | + */ |
|
78 | + public function charsetChanged($charset) |
|
79 | + { |
|
80 | + $this->charStream->setCharacterSet($charset); |
|
81 | + } |
|
82 | 82 | |
83 | - /** |
|
84 | - * Make a deep copy of object. |
|
85 | - */ |
|
86 | - public function __clone() |
|
87 | - { |
|
88 | - $this->charStream = clone $this->charStream; |
|
89 | - } |
|
83 | + /** |
|
84 | + * Make a deep copy of object. |
|
85 | + */ |
|
86 | + public function __clone() |
|
87 | + { |
|
88 | + $this->charStream = clone $this->charStream; |
|
89 | + } |
|
90 | 90 | } |
@@ -15,44 +15,44 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_Encoder_Base64Encoder implements Swift_Encoder |
17 | 17 | { |
18 | - /** |
|
19 | - * Takes an unencoded string and produces a Base64 encoded string from it. |
|
20 | - * |
|
21 | - * Base64 encoded strings have a maximum line length of 76 characters. |
|
22 | - * If the first line needs to be shorter, indicate the difference with |
|
23 | - * $firstLineOffset. |
|
24 | - * |
|
25 | - * @param string $string to encode |
|
26 | - * @param int $firstLineOffset |
|
27 | - * @param int $maxLineLength optional, 0 indicates the default of 76 bytes |
|
28 | - * |
|
29 | - * @return string |
|
30 | - */ |
|
31 | - public function encodeString($string, $firstLineOffset = 0, $maxLineLength = 0) |
|
32 | - { |
|
33 | - if (0 >= $maxLineLength || 76 < $maxLineLength) { |
|
34 | - $maxLineLength = 76; |
|
35 | - } |
|
18 | + /** |
|
19 | + * Takes an unencoded string and produces a Base64 encoded string from it. |
|
20 | + * |
|
21 | + * Base64 encoded strings have a maximum line length of 76 characters. |
|
22 | + * If the first line needs to be shorter, indicate the difference with |
|
23 | + * $firstLineOffset. |
|
24 | + * |
|
25 | + * @param string $string to encode |
|
26 | + * @param int $firstLineOffset |
|
27 | + * @param int $maxLineLength optional, 0 indicates the default of 76 bytes |
|
28 | + * |
|
29 | + * @return string |
|
30 | + */ |
|
31 | + public function encodeString($string, $firstLineOffset = 0, $maxLineLength = 0) |
|
32 | + { |
|
33 | + if (0 >= $maxLineLength || 76 < $maxLineLength) { |
|
34 | + $maxLineLength = 76; |
|
35 | + } |
|
36 | 36 | |
37 | - $encodedString = base64_encode($string ?? ''); |
|
38 | - $firstLine = ''; |
|
37 | + $encodedString = base64_encode($string ?? ''); |
|
38 | + $firstLine = ''; |
|
39 | 39 | |
40 | - if (0 != $firstLineOffset) { |
|
41 | - $firstLine = substr( |
|
42 | - $encodedString, 0, $maxLineLength - $firstLineOffset |
|
43 | - )."\r\n"; |
|
44 | - $encodedString = substr( |
|
45 | - $encodedString, $maxLineLength - $firstLineOffset |
|
46 | - ); |
|
47 | - } |
|
40 | + if (0 != $firstLineOffset) { |
|
41 | + $firstLine = substr( |
|
42 | + $encodedString, 0, $maxLineLength - $firstLineOffset |
|
43 | + )."\r\n"; |
|
44 | + $encodedString = substr( |
|
45 | + $encodedString, $maxLineLength - $firstLineOffset |
|
46 | + ); |
|
47 | + } |
|
48 | 48 | |
49 | - return $firstLine.trim(chunk_split($encodedString, $maxLineLength, "\r\n")); |
|
50 | - } |
|
49 | + return $firstLine.trim(chunk_split($encodedString, $maxLineLength, "\r\n")); |
|
50 | + } |
|
51 | 51 | |
52 | - /** |
|
53 | - * Does nothing. |
|
54 | - */ |
|
55 | - public function charsetChanged($charset) |
|
56 | - { |
|
57 | - } |
|
52 | + /** |
|
53 | + * Does nothing. |
|
54 | + */ |
|
55 | + public function charsetChanged($charset) |
|
56 | + { |
|
57 | + } |
|
58 | 58 | } |
@@ -19,69 +19,69 @@ |
||
19 | 19 | */ |
20 | 20 | interface Swift_CharacterStream |
21 | 21 | { |
22 | - /** |
|
23 | - * Set the character set used in this CharacterStream. |
|
24 | - * |
|
25 | - * @param string $charset |
|
26 | - */ |
|
27 | - public function setCharacterSet($charset); |
|
22 | + /** |
|
23 | + * Set the character set used in this CharacterStream. |
|
24 | + * |
|
25 | + * @param string $charset |
|
26 | + */ |
|
27 | + public function setCharacterSet($charset); |
|
28 | 28 | |
29 | - /** |
|
30 | - * Set the CharacterReaderFactory for multi charset support. |
|
31 | - */ |
|
32 | - public function setCharacterReaderFactory(Swift_CharacterReaderFactory $factory); |
|
29 | + /** |
|
30 | + * Set the CharacterReaderFactory for multi charset support. |
|
31 | + */ |
|
32 | + public function setCharacterReaderFactory(Swift_CharacterReaderFactory $factory); |
|
33 | 33 | |
34 | - /** |
|
35 | - * Overwrite this character stream using the byte sequence in the byte stream. |
|
36 | - * |
|
37 | - * @param Swift_OutputByteStream $os output stream to read from |
|
38 | - */ |
|
39 | - public function importByteStream(Swift_OutputByteStream $os); |
|
34 | + /** |
|
35 | + * Overwrite this character stream using the byte sequence in the byte stream. |
|
36 | + * |
|
37 | + * @param Swift_OutputByteStream $os output stream to read from |
|
38 | + */ |
|
39 | + public function importByteStream(Swift_OutputByteStream $os); |
|
40 | 40 | |
41 | - /** |
|
42 | - * Import a string a bytes into this CharacterStream, overwriting any existing |
|
43 | - * data in the stream. |
|
44 | - * |
|
45 | - * @param string $string |
|
46 | - */ |
|
47 | - public function importString($string); |
|
41 | + /** |
|
42 | + * Import a string a bytes into this CharacterStream, overwriting any existing |
|
43 | + * data in the stream. |
|
44 | + * |
|
45 | + * @param string $string |
|
46 | + */ |
|
47 | + public function importString($string); |
|
48 | 48 | |
49 | - /** |
|
50 | - * Read $length characters from the stream and move the internal pointer |
|
51 | - * $length further into the stream. |
|
52 | - * |
|
53 | - * @param int $length |
|
54 | - * |
|
55 | - * @return string |
|
56 | - */ |
|
57 | - public function read($length); |
|
49 | + /** |
|
50 | + * Read $length characters from the stream and move the internal pointer |
|
51 | + * $length further into the stream. |
|
52 | + * |
|
53 | + * @param int $length |
|
54 | + * |
|
55 | + * @return string |
|
56 | + */ |
|
57 | + public function read($length); |
|
58 | 58 | |
59 | - /** |
|
60 | - * Read $length characters from the stream and return a 1-dimensional array |
|
61 | - * containing there octet values. |
|
62 | - * |
|
63 | - * @param int $length |
|
64 | - * |
|
65 | - * @return int[] |
|
66 | - */ |
|
67 | - public function readBytes($length); |
|
59 | + /** |
|
60 | + * Read $length characters from the stream and return a 1-dimensional array |
|
61 | + * containing there octet values. |
|
62 | + * |
|
63 | + * @param int $length |
|
64 | + * |
|
65 | + * @return int[] |
|
66 | + */ |
|
67 | + public function readBytes($length); |
|
68 | 68 | |
69 | - /** |
|
70 | - * Write $chars to the end of the stream. |
|
71 | - * |
|
72 | - * @param string $chars |
|
73 | - */ |
|
74 | - public function write($chars); |
|
69 | + /** |
|
70 | + * Write $chars to the end of the stream. |
|
71 | + * |
|
72 | + * @param string $chars |
|
73 | + */ |
|
74 | + public function write($chars); |
|
75 | 75 | |
76 | - /** |
|
77 | - * Move the internal pointer to $charOffset in the stream. |
|
78 | - * |
|
79 | - * @param int $charOffset |
|
80 | - */ |
|
81 | - public function setPointer($charOffset); |
|
76 | + /** |
|
77 | + * Move the internal pointer to $charOffset in the stream. |
|
78 | + * |
|
79 | + * @param int $charOffset |
|
80 | + */ |
|
81 | + public function setPointer($charOffset); |
|
82 | 82 | |
83 | - /** |
|
84 | - * Empty the stream and reset the internal pointer. |
|
85 | - */ |
|
86 | - public function flushContents(); |
|
83 | + /** |
|
84 | + * Empty the stream and reset the internal pointer. |
|
85 | + */ |
|
86 | + public function flushContents(); |
|
87 | 87 | } |
@@ -15,14 +15,14 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_TransportException extends Swift_IoException |
17 | 17 | { |
18 | - /** |
|
19 | - * Create a new TransportException with $message. |
|
20 | - * |
|
21 | - * @param string $message |
|
22 | - * @param int $code |
|
23 | - */ |
|
24 | - public function __construct($message, $code = 0, Exception $previous = null) |
|
25 | - { |
|
26 | - parent::__construct($message, $code, $previous); |
|
27 | - } |
|
18 | + /** |
|
19 | + * Create a new TransportException with $message. |
|
20 | + * |
|
21 | + * @param string $message |
|
22 | + * @param int $code |
|
23 | + */ |
|
24 | + public function __construct($message, $code = 0, Exception $previous = null) |
|
25 | + { |
|
26 | + parent::__construct($message, $code, $previous); |
|
27 | + } |
|
28 | 28 | } |
@@ -15,29 +15,29 @@ |
||
15 | 15 | */ |
16 | 16 | class Swift_Image extends Swift_EmbeddedFile |
17 | 17 | { |
18 | - /** |
|
19 | - * Create a new EmbeddedFile. |
|
20 | - * |
|
21 | - * Details may be optionally provided to the constructor. |
|
22 | - * |
|
23 | - * @param string|Swift_OutputByteStream $data |
|
24 | - * @param string $filename |
|
25 | - * @param string $contentType |
|
26 | - */ |
|
27 | - public function __construct($data = null, $filename = null, $contentType = null) |
|
28 | - { |
|
29 | - parent::__construct($data, $filename, $contentType); |
|
30 | - } |
|
18 | + /** |
|
19 | + * Create a new EmbeddedFile. |
|
20 | + * |
|
21 | + * Details may be optionally provided to the constructor. |
|
22 | + * |
|
23 | + * @param string|Swift_OutputByteStream $data |
|
24 | + * @param string $filename |
|
25 | + * @param string $contentType |
|
26 | + */ |
|
27 | + public function __construct($data = null, $filename = null, $contentType = null) |
|
28 | + { |
|
29 | + parent::__construct($data, $filename, $contentType); |
|
30 | + } |
|
31 | 31 | |
32 | - /** |
|
33 | - * Create a new Image from a filesystem path. |
|
34 | - * |
|
35 | - * @param string $path |
|
36 | - * |
|
37 | - * @return self |
|
38 | - */ |
|
39 | - public static function fromPath($path) |
|
40 | - { |
|
41 | - return (new self())->setFile(new Swift_ByteStream_FileByteStream($path)); |
|
42 | - } |
|
32 | + /** |
|
33 | + * Create a new Image from a filesystem path. |
|
34 | + * |
|
35 | + * @param string $path |
|
36 | + * |
|
37 | + * @return self |
|
38 | + */ |
|
39 | + public static function fromPath($path) |
|
40 | + { |
|
41 | + return (new self())->setFile(new Swift_ByteStream_FileByteStream($path)); |
|
42 | + } |
|
43 | 43 | } |
@@ -17,526 +17,526 @@ |
||
17 | 17 | */ |
18 | 18 | class Swift_Signers_SMimeSigner implements Swift_Signers_BodySigner |
19 | 19 | { |
20 | - protected $signCertificate; |
|
21 | - protected $signPrivateKey; |
|
22 | - protected $encryptCert; |
|
23 | - protected $signThenEncrypt = true; |
|
24 | - protected $signLevel; |
|
25 | - protected $encryptLevel; |
|
26 | - protected $signOptions; |
|
27 | - protected $encryptOptions; |
|
28 | - protected $encryptCipher; |
|
29 | - protected $extraCerts = null; |
|
30 | - protected $wrapFullMessage = false; |
|
31 | - |
|
32 | - /** |
|
33 | - * @var Swift_StreamFilters_StringReplacementFilterFactory |
|
34 | - */ |
|
35 | - protected $replacementFactory; |
|
36 | - |
|
37 | - /** |
|
38 | - * @var Swift_Mime_SimpleHeaderFactory |
|
39 | - */ |
|
40 | - protected $headerFactory; |
|
41 | - |
|
42 | - /** |
|
43 | - * Constructor. |
|
44 | - * |
|
45 | - * @param string|null $signCertificate |
|
46 | - * @param string|null $signPrivateKey |
|
47 | - * @param string|null $encryptCertificate |
|
48 | - */ |
|
49 | - public function __construct($signCertificate = null, $signPrivateKey = null, $encryptCertificate = null) |
|
50 | - { |
|
51 | - if (null !== $signPrivateKey) { |
|
52 | - $this->setSignCertificate($signCertificate, $signPrivateKey); |
|
53 | - } |
|
54 | - |
|
55 | - if (null !== $encryptCertificate) { |
|
56 | - $this->setEncryptCertificate($encryptCertificate); |
|
57 | - } |
|
58 | - |
|
59 | - $this->replacementFactory = Swift_DependencyContainer::getInstance() |
|
60 | - ->lookup('transport.replacementfactory'); |
|
61 | - |
|
62 | - $this->signOptions = PKCS7_DETACHED; |
|
63 | - $this->encryptCipher = OPENSSL_CIPHER_AES_128_CBC; |
|
64 | - } |
|
65 | - |
|
66 | - /** |
|
67 | - * Set the certificate location to use for signing. |
|
68 | - * |
|
69 | - * @see https://secure.php.net/manual/en/openssl.pkcs7.flags.php |
|
70 | - * |
|
71 | - * @param string $certificate |
|
72 | - * @param string|array $privateKey If the key needs an passphrase use array('file-location', 'passphrase') instead |
|
73 | - * @param int $signOptions Bitwise operator options for openssl_pkcs7_sign() |
|
74 | - * @param string $extraCerts A file containing intermediate certificates needed by the signing certificate |
|
75 | - * |
|
76 | - * @return $this |
|
77 | - */ |
|
78 | - public function setSignCertificate($certificate, $privateKey = null, $signOptions = PKCS7_DETACHED, $extraCerts = null) |
|
79 | - { |
|
80 | - $this->signCertificate = 'file://'.str_replace('\\', '/', realpath($certificate)); |
|
81 | - |
|
82 | - if (null !== $privateKey) { |
|
83 | - if (\is_array($privateKey)) { |
|
84 | - $this->signPrivateKey = $privateKey; |
|
85 | - $this->signPrivateKey[0] = 'file://'.str_replace('\\', '/', realpath($privateKey[0])); |
|
86 | - } else { |
|
87 | - $this->signPrivateKey = 'file://'.str_replace('\\', '/', realpath($privateKey)); |
|
88 | - } |
|
89 | - } |
|
90 | - |
|
91 | - $this->signOptions = $signOptions; |
|
92 | - $this->extraCerts = $extraCerts ? realpath($extraCerts) : null; |
|
93 | - |
|
94 | - return $this; |
|
95 | - } |
|
96 | - |
|
97 | - /** |
|
98 | - * Set the certificate location to use for encryption. |
|
99 | - * |
|
100 | - * @see https://secure.php.net/manual/en/openssl.pkcs7.flags.php |
|
101 | - * @see https://secure.php.net/manual/en/openssl.ciphers.php |
|
102 | - * |
|
103 | - * @param string|array $recipientCerts Either an single X.509 certificate, or an assoc array of X.509 certificates. |
|
104 | - * @param int $cipher |
|
105 | - * |
|
106 | - * @return $this |
|
107 | - */ |
|
108 | - public function setEncryptCertificate($recipientCerts, $cipher = null) |
|
109 | - { |
|
110 | - if (\is_array($recipientCerts)) { |
|
111 | - $this->encryptCert = []; |
|
112 | - |
|
113 | - foreach ($recipientCerts as $cert) { |
|
114 | - $this->encryptCert[] = 'file://'.str_replace('\\', '/', realpath($cert)); |
|
115 | - } |
|
116 | - } else { |
|
117 | - $this->encryptCert = 'file://'.str_replace('\\', '/', realpath($recipientCerts)); |
|
118 | - } |
|
119 | - |
|
120 | - if (null !== $cipher) { |
|
121 | - $this->encryptCipher = $cipher; |
|
122 | - } |
|
123 | - |
|
124 | - return $this; |
|
125 | - } |
|
126 | - |
|
127 | - /** |
|
128 | - * @return string |
|
129 | - */ |
|
130 | - public function getSignCertificate() |
|
131 | - { |
|
132 | - return $this->signCertificate; |
|
133 | - } |
|
134 | - |
|
135 | - /** |
|
136 | - * @return string |
|
137 | - */ |
|
138 | - public function getSignPrivateKey() |
|
139 | - { |
|
140 | - return $this->signPrivateKey; |
|
141 | - } |
|
142 | - |
|
143 | - /** |
|
144 | - * Set perform signing before encryption. |
|
145 | - * |
|
146 | - * The default is to first sign the message and then encrypt. |
|
147 | - * But some older mail clients, namely Microsoft Outlook 2000 will work when the message first encrypted. |
|
148 | - * As this goes against the official specs, its recommended to only use 'encryption -> signing' when specifically targeting these 'broken' clients. |
|
149 | - * |
|
150 | - * @param bool $signThenEncrypt |
|
151 | - * |
|
152 | - * @return $this |
|
153 | - */ |
|
154 | - public function setSignThenEncrypt($signThenEncrypt = true) |
|
155 | - { |
|
156 | - $this->signThenEncrypt = $signThenEncrypt; |
|
157 | - |
|
158 | - return $this; |
|
159 | - } |
|
160 | - |
|
161 | - /** |
|
162 | - * @return bool |
|
163 | - */ |
|
164 | - public function isSignThenEncrypt() |
|
165 | - { |
|
166 | - return $this->signThenEncrypt; |
|
167 | - } |
|
168 | - |
|
169 | - /** |
|
170 | - * Resets internal states. |
|
171 | - * |
|
172 | - * @return $this |
|
173 | - */ |
|
174 | - public function reset() |
|
175 | - { |
|
176 | - return $this; |
|
177 | - } |
|
178 | - |
|
179 | - /** |
|
180 | - * Specify whether to wrap the entire MIME message in the S/MIME message. |
|
181 | - * |
|
182 | - * According to RFC5751 section 3.1: |
|
183 | - * In order to protect outer, non-content-related message header fields |
|
184 | - * (for instance, the "Subject", "To", "From", and "Cc" fields), the |
|
185 | - * sending client MAY wrap a full MIME message in a message/rfc822 |
|
186 | - * wrapper in order to apply S/MIME security services to these header |
|
187 | - * fields. It is up to the receiving client to decide how to present |
|
188 | - * this "inner" header along with the unprotected "outer" header. |
|
189 | - * |
|
190 | - * @param bool $wrap |
|
191 | - * |
|
192 | - * @return $this |
|
193 | - */ |
|
194 | - public function setWrapFullMessage($wrap) |
|
195 | - { |
|
196 | - $this->wrapFullMessage = $wrap; |
|
197 | - } |
|
198 | - |
|
199 | - /** |
|
200 | - * Change the Swift_Message to apply the signing. |
|
201 | - * |
|
202 | - * @return $this |
|
203 | - */ |
|
204 | - public function signMessage(Swift_Message $message) |
|
205 | - { |
|
206 | - if (null === $this->signCertificate && null === $this->encryptCert) { |
|
207 | - return $this; |
|
208 | - } |
|
209 | - |
|
210 | - if ($this->signThenEncrypt) { |
|
211 | - $this->smimeSignMessage($message); |
|
212 | - $this->smimeEncryptMessage($message); |
|
213 | - } else { |
|
214 | - $this->smimeEncryptMessage($message); |
|
215 | - $this->smimeSignMessage($message); |
|
216 | - } |
|
217 | - } |
|
218 | - |
|
219 | - /** |
|
220 | - * Return the list of header a signer might tamper. |
|
221 | - * |
|
222 | - * @return array |
|
223 | - */ |
|
224 | - public function getAlteredHeaders() |
|
225 | - { |
|
226 | - return ['Content-Type', 'Content-Transfer-Encoding', 'Content-Disposition']; |
|
227 | - } |
|
228 | - |
|
229 | - /** |
|
230 | - * Sign a Swift message. |
|
231 | - */ |
|
232 | - protected function smimeSignMessage(Swift_Message $message) |
|
233 | - { |
|
234 | - // If we don't have a certificate we can't sign the message |
|
235 | - if (null === $this->signCertificate) { |
|
236 | - return; |
|
237 | - } |
|
238 | - |
|
239 | - // Work on a clone of the original message |
|
240 | - $signMessage = clone $message; |
|
241 | - $signMessage->clearSigners(); |
|
242 | - |
|
243 | - if ($this->wrapFullMessage) { |
|
244 | - // The original message essentially becomes the body of the new |
|
245 | - // wrapped message |
|
246 | - $signMessage = $this->wrapMimeMessage($signMessage); |
|
247 | - } else { |
|
248 | - // Only keep header needed to parse the body correctly |
|
249 | - $this->clearAllHeaders($signMessage); |
|
250 | - $this->copyHeaders( |
|
251 | - $message, |
|
252 | - $signMessage, |
|
253 | - [ |
|
254 | - 'Content-Type', |
|
255 | - 'Content-Transfer-Encoding', |
|
256 | - 'Content-Disposition', |
|
257 | - ] |
|
258 | - ); |
|
259 | - } |
|
260 | - |
|
261 | - // Copy the cloned message into a temporary file stream |
|
262 | - $messageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
263 | - $signMessage->toByteStream($messageStream); |
|
264 | - $messageStream->commit(); |
|
265 | - $signedMessageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
266 | - |
|
267 | - // Sign the message using openssl |
|
268 | - if (!openssl_pkcs7_sign( |
|
269 | - $messageStream->getPath(), |
|
270 | - $signedMessageStream->getPath(), |
|
271 | - $this->signCertificate, |
|
272 | - $this->signPrivateKey, |
|
273 | - [], |
|
274 | - $this->signOptions, |
|
275 | - $this->extraCerts |
|
276 | - ) |
|
277 | - ) { |
|
278 | - throw new Swift_IoException(sprintf('Failed to sign S/Mime message. Error: "%s".', openssl_error_string())); |
|
279 | - } |
|
280 | - |
|
281 | - // Parse the resulting signed message content back into the Swift message |
|
282 | - // preserving the original headers |
|
283 | - $this->parseSSLOutput($signedMessageStream, $message); |
|
284 | - } |
|
285 | - |
|
286 | - /** |
|
287 | - * Encrypt a Swift message. |
|
288 | - */ |
|
289 | - protected function smimeEncryptMessage(Swift_Message $message) |
|
290 | - { |
|
291 | - // If we don't have a certificate we can't encrypt the message |
|
292 | - if (null === $this->encryptCert) { |
|
293 | - return; |
|
294 | - } |
|
295 | - |
|
296 | - // Work on a clone of the original message |
|
297 | - $encryptMessage = clone $message; |
|
298 | - $encryptMessage->clearSigners(); |
|
299 | - |
|
300 | - if ($this->wrapFullMessage) { |
|
301 | - // The original message essentially becomes the body of the new |
|
302 | - // wrapped message |
|
303 | - $encryptMessage = $this->wrapMimeMessage($encryptMessage); |
|
304 | - } else { |
|
305 | - // Only keep header needed to parse the body correctly |
|
306 | - $this->clearAllHeaders($encryptMessage); |
|
307 | - $this->copyHeaders( |
|
308 | - $message, |
|
309 | - $encryptMessage, |
|
310 | - [ |
|
311 | - 'Content-Type', |
|
312 | - 'Content-Transfer-Encoding', |
|
313 | - 'Content-Disposition', |
|
314 | - ] |
|
315 | - ); |
|
316 | - } |
|
317 | - |
|
318 | - // Convert the message content (including headers) to a string |
|
319 | - // and place it in a temporary file |
|
320 | - $messageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
321 | - $encryptMessage->toByteStream($messageStream); |
|
322 | - $messageStream->commit(); |
|
323 | - $encryptedMessageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
324 | - |
|
325 | - // Encrypt the message |
|
326 | - if (!openssl_pkcs7_encrypt( |
|
327 | - $messageStream->getPath(), |
|
328 | - $encryptedMessageStream->getPath(), |
|
329 | - $this->encryptCert, |
|
330 | - [], |
|
331 | - 0, |
|
332 | - $this->encryptCipher |
|
333 | - ) |
|
334 | - ) { |
|
335 | - throw new Swift_IoException(sprintf('Failed to encrypt S/Mime message. Error: "%s".', openssl_error_string())); |
|
336 | - } |
|
337 | - |
|
338 | - // Parse the resulting signed message content back into the Swift message |
|
339 | - // preserving the original headers |
|
340 | - $this->parseSSLOutput($encryptedMessageStream, $message); |
|
341 | - } |
|
342 | - |
|
343 | - /** |
|
344 | - * Copy named headers from one Swift message to another. |
|
345 | - */ |
|
346 | - protected function copyHeaders( |
|
347 | - Swift_Message $fromMessage, |
|
348 | - Swift_Message $toMessage, |
|
349 | - array $headers = [] |
|
350 | - ) { |
|
351 | - foreach ($headers as $header) { |
|
352 | - $this->copyHeader($fromMessage, $toMessage, $header); |
|
353 | - } |
|
354 | - } |
|
355 | - |
|
356 | - /** |
|
357 | - * Copy a single header from one Swift message to another. |
|
358 | - * |
|
359 | - * @param string $headerName |
|
360 | - */ |
|
361 | - protected function copyHeader(Swift_Message $fromMessage, Swift_Message $toMessage, $headerName) |
|
362 | - { |
|
363 | - $header = $fromMessage->getHeaders()->get($headerName); |
|
364 | - if (!$header) { |
|
365 | - return; |
|
366 | - } |
|
367 | - $headers = $toMessage->getHeaders(); |
|
368 | - switch ($header->getFieldType()) { |
|
369 | - case Swift_Mime_Header::TYPE_TEXT: |
|
370 | - $headers->addTextHeader($header->getFieldName(), $header->getValue()); |
|
371 | - break; |
|
372 | - case Swift_Mime_Header::TYPE_PARAMETERIZED: |
|
373 | - $headers->addParameterizedHeader( |
|
374 | - $header->getFieldName(), |
|
375 | - $header->getValue(), |
|
376 | - $header->getParameters() |
|
377 | - ); |
|
378 | - break; |
|
379 | - } |
|
380 | - } |
|
381 | - |
|
382 | - /** |
|
383 | - * Remove all headers from a Swift message. |
|
384 | - */ |
|
385 | - protected function clearAllHeaders(Swift_Message $message) |
|
386 | - { |
|
387 | - $headers = $message->getHeaders(); |
|
388 | - foreach ($headers->listAll() as $header) { |
|
389 | - $headers->removeAll($header); |
|
390 | - } |
|
391 | - } |
|
392 | - |
|
393 | - /** |
|
394 | - * Wraps a Swift_Message in a message/rfc822 MIME part. |
|
395 | - * |
|
396 | - * @return Swift_MimePart |
|
397 | - */ |
|
398 | - protected function wrapMimeMessage(Swift_Message $message) |
|
399 | - { |
|
400 | - // Start by copying the original message into a message stream |
|
401 | - $messageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
402 | - $message->toByteStream($messageStream); |
|
403 | - $messageStream->commit(); |
|
404 | - |
|
405 | - // Create a new MIME part that wraps the original stream |
|
406 | - $wrappedMessage = new Swift_MimePart($messageStream, 'message/rfc822'); |
|
407 | - $wrappedMessage->setEncoder(new Swift_Mime_ContentEncoder_PlainContentEncoder('7bit')); |
|
408 | - |
|
409 | - return $wrappedMessage; |
|
410 | - } |
|
411 | - |
|
412 | - protected function parseSSLOutput(Swift_InputByteStream $inputStream, Swift_Message $message) |
|
413 | - { |
|
414 | - $messageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
415 | - $this->copyFromOpenSSLOutput($inputStream, $messageStream); |
|
416 | - |
|
417 | - $this->streamToMime($messageStream, $message); |
|
418 | - } |
|
419 | - |
|
420 | - /** |
|
421 | - * Merges an OutputByteStream from OpenSSL to a Swift_Message. |
|
422 | - */ |
|
423 | - protected function streamToMime(Swift_OutputByteStream $fromStream, Swift_Message $message) |
|
424 | - { |
|
425 | - // Parse the stream into headers and body |
|
426 | - list($headers, $messageStream) = $this->parseStream($fromStream); |
|
427 | - |
|
428 | - // Get the original message headers |
|
429 | - $messageHeaders = $message->getHeaders(); |
|
430 | - |
|
431 | - // Let the stream determine the headers describing the body content, |
|
432 | - // since the body of the original message is overwritten by the body |
|
433 | - // coming from the stream. |
|
434 | - // These are all content-* headers. |
|
435 | - |
|
436 | - // Default transfer encoding is 7bit if not set |
|
437 | - $encoding = ''; |
|
438 | - // Remove all existing transfer encoding headers |
|
439 | - $messageHeaders->removeAll('Content-Transfer-Encoding'); |
|
440 | - // See whether the stream sets the transfer encoding |
|
441 | - if (isset($headers['content-transfer-encoding'])) { |
|
442 | - $encoding = $headers['content-transfer-encoding']; |
|
443 | - } |
|
444 | - |
|
445 | - // We use the null content encoder, since the body is already encoded |
|
446 | - // according to the transfer encoding specified in the stream |
|
447 | - $message->setEncoder(new Swift_Mime_ContentEncoder_NullContentEncoder($encoding)); |
|
448 | - |
|
449 | - // Set the disposition, if present |
|
450 | - if (isset($headers['content-disposition'])) { |
|
451 | - $messageHeaders->addTextHeader('Content-Disposition', $headers['content-disposition']); |
|
452 | - } |
|
453 | - |
|
454 | - // Copy over the body from the stream using the content type dictated |
|
455 | - // by the stream content |
|
456 | - $message->setChildren([]); |
|
457 | - $message->setBody($messageStream, $headers['content-type']); |
|
458 | - } |
|
459 | - |
|
460 | - /** |
|
461 | - * This message will parse the headers of a MIME email byte stream |
|
462 | - * and return an array that contains the headers as an associative |
|
463 | - * array and the email body as a string. |
|
464 | - * |
|
465 | - * @return array |
|
466 | - */ |
|
467 | - protected function parseStream(Swift_OutputByteStream $emailStream) |
|
468 | - { |
|
469 | - $bufferLength = 78; |
|
470 | - $headerData = ''; |
|
471 | - $headerBodySeparator = "\r\n\r\n"; |
|
472 | - |
|
473 | - $emailStream->setReadPointer(0); |
|
474 | - |
|
475 | - // Read out the headers section from the stream to a string |
|
476 | - while (false !== ($buffer = $emailStream->read($bufferLength))) { |
|
477 | - $headerData .= $buffer; |
|
478 | - |
|
479 | - $headersPosEnd = strpos($headerData, $headerBodySeparator); |
|
480 | - |
|
481 | - // Stop reading if we found the end of the headers |
|
482 | - if (false !== $headersPosEnd) { |
|
483 | - break; |
|
484 | - } |
|
485 | - } |
|
486 | - |
|
487 | - // Split the header data into lines |
|
488 | - $headerData = trim(substr($headerData, 0, $headersPosEnd)); |
|
489 | - $headerLines = explode("\r\n", $headerData); |
|
490 | - unset($headerData); |
|
491 | - |
|
492 | - $headers = []; |
|
493 | - $currentHeaderName = ''; |
|
494 | - |
|
495 | - // Transform header lines into an associative array |
|
496 | - foreach ($headerLines as $headerLine) { |
|
497 | - // Handle headers that span multiple lines |
|
498 | - if (false === strpos($headerLine, ':')) { |
|
499 | - $headers[$currentHeaderName] .= ' '.trim($headerLine ?? ''); |
|
500 | - continue; |
|
501 | - } |
|
502 | - |
|
503 | - $header = explode(':', $headerLine, 2); |
|
504 | - $currentHeaderName = strtolower($header[0] ?? ''); |
|
505 | - $headers[$currentHeaderName] = trim($header[1] ?? ''); |
|
506 | - } |
|
507 | - |
|
508 | - // Read the entire email body into a byte stream |
|
509 | - $bodyStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
510 | - |
|
511 | - // Skip the header and separator and point to the body |
|
512 | - $emailStream->setReadPointer($headersPosEnd + \strlen($headerBodySeparator)); |
|
513 | - |
|
514 | - while (false !== ($buffer = $emailStream->read($bufferLength))) { |
|
515 | - $bodyStream->write($buffer); |
|
516 | - } |
|
517 | - |
|
518 | - $bodyStream->commit(); |
|
519 | - |
|
520 | - return [$headers, $bodyStream]; |
|
521 | - } |
|
522 | - |
|
523 | - protected function copyFromOpenSSLOutput(Swift_OutputByteStream $fromStream, Swift_InputByteStream $toStream) |
|
524 | - { |
|
525 | - $bufferLength = 4096; |
|
526 | - $filteredStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
527 | - $filteredStream->addFilter($this->replacementFactory->createFilter("\r\n", "\n"), 'CRLF to LF'); |
|
528 | - $filteredStream->addFilter($this->replacementFactory->createFilter("\n", "\r\n"), 'LF to CRLF'); |
|
529 | - |
|
530 | - while (false !== ($buffer = $fromStream->read($bufferLength))) { |
|
531 | - $filteredStream->write($buffer); |
|
532 | - } |
|
533 | - |
|
534 | - $filteredStream->flushBuffers(); |
|
535 | - |
|
536 | - while (false !== ($buffer = $filteredStream->read($bufferLength))) { |
|
537 | - $toStream->write($buffer); |
|
538 | - } |
|
539 | - |
|
540 | - $toStream->commit(); |
|
541 | - } |
|
20 | + protected $signCertificate; |
|
21 | + protected $signPrivateKey; |
|
22 | + protected $encryptCert; |
|
23 | + protected $signThenEncrypt = true; |
|
24 | + protected $signLevel; |
|
25 | + protected $encryptLevel; |
|
26 | + protected $signOptions; |
|
27 | + protected $encryptOptions; |
|
28 | + protected $encryptCipher; |
|
29 | + protected $extraCerts = null; |
|
30 | + protected $wrapFullMessage = false; |
|
31 | + |
|
32 | + /** |
|
33 | + * @var Swift_StreamFilters_StringReplacementFilterFactory |
|
34 | + */ |
|
35 | + protected $replacementFactory; |
|
36 | + |
|
37 | + /** |
|
38 | + * @var Swift_Mime_SimpleHeaderFactory |
|
39 | + */ |
|
40 | + protected $headerFactory; |
|
41 | + |
|
42 | + /** |
|
43 | + * Constructor. |
|
44 | + * |
|
45 | + * @param string|null $signCertificate |
|
46 | + * @param string|null $signPrivateKey |
|
47 | + * @param string|null $encryptCertificate |
|
48 | + */ |
|
49 | + public function __construct($signCertificate = null, $signPrivateKey = null, $encryptCertificate = null) |
|
50 | + { |
|
51 | + if (null !== $signPrivateKey) { |
|
52 | + $this->setSignCertificate($signCertificate, $signPrivateKey); |
|
53 | + } |
|
54 | + |
|
55 | + if (null !== $encryptCertificate) { |
|
56 | + $this->setEncryptCertificate($encryptCertificate); |
|
57 | + } |
|
58 | + |
|
59 | + $this->replacementFactory = Swift_DependencyContainer::getInstance() |
|
60 | + ->lookup('transport.replacementfactory'); |
|
61 | + |
|
62 | + $this->signOptions = PKCS7_DETACHED; |
|
63 | + $this->encryptCipher = OPENSSL_CIPHER_AES_128_CBC; |
|
64 | + } |
|
65 | + |
|
66 | + /** |
|
67 | + * Set the certificate location to use for signing. |
|
68 | + * |
|
69 | + * @see https://secure.php.net/manual/en/openssl.pkcs7.flags.php |
|
70 | + * |
|
71 | + * @param string $certificate |
|
72 | + * @param string|array $privateKey If the key needs an passphrase use array('file-location', 'passphrase') instead |
|
73 | + * @param int $signOptions Bitwise operator options for openssl_pkcs7_sign() |
|
74 | + * @param string $extraCerts A file containing intermediate certificates needed by the signing certificate |
|
75 | + * |
|
76 | + * @return $this |
|
77 | + */ |
|
78 | + public function setSignCertificate($certificate, $privateKey = null, $signOptions = PKCS7_DETACHED, $extraCerts = null) |
|
79 | + { |
|
80 | + $this->signCertificate = 'file://'.str_replace('\\', '/', realpath($certificate)); |
|
81 | + |
|
82 | + if (null !== $privateKey) { |
|
83 | + if (\is_array($privateKey)) { |
|
84 | + $this->signPrivateKey = $privateKey; |
|
85 | + $this->signPrivateKey[0] = 'file://'.str_replace('\\', '/', realpath($privateKey[0])); |
|
86 | + } else { |
|
87 | + $this->signPrivateKey = 'file://'.str_replace('\\', '/', realpath($privateKey)); |
|
88 | + } |
|
89 | + } |
|
90 | + |
|
91 | + $this->signOptions = $signOptions; |
|
92 | + $this->extraCerts = $extraCerts ? realpath($extraCerts) : null; |
|
93 | + |
|
94 | + return $this; |
|
95 | + } |
|
96 | + |
|
97 | + /** |
|
98 | + * Set the certificate location to use for encryption. |
|
99 | + * |
|
100 | + * @see https://secure.php.net/manual/en/openssl.pkcs7.flags.php |
|
101 | + * @see https://secure.php.net/manual/en/openssl.ciphers.php |
|
102 | + * |
|
103 | + * @param string|array $recipientCerts Either an single X.509 certificate, or an assoc array of X.509 certificates. |
|
104 | + * @param int $cipher |
|
105 | + * |
|
106 | + * @return $this |
|
107 | + */ |
|
108 | + public function setEncryptCertificate($recipientCerts, $cipher = null) |
|
109 | + { |
|
110 | + if (\is_array($recipientCerts)) { |
|
111 | + $this->encryptCert = []; |
|
112 | + |
|
113 | + foreach ($recipientCerts as $cert) { |
|
114 | + $this->encryptCert[] = 'file://'.str_replace('\\', '/', realpath($cert)); |
|
115 | + } |
|
116 | + } else { |
|
117 | + $this->encryptCert = 'file://'.str_replace('\\', '/', realpath($recipientCerts)); |
|
118 | + } |
|
119 | + |
|
120 | + if (null !== $cipher) { |
|
121 | + $this->encryptCipher = $cipher; |
|
122 | + } |
|
123 | + |
|
124 | + return $this; |
|
125 | + } |
|
126 | + |
|
127 | + /** |
|
128 | + * @return string |
|
129 | + */ |
|
130 | + public function getSignCertificate() |
|
131 | + { |
|
132 | + return $this->signCertificate; |
|
133 | + } |
|
134 | + |
|
135 | + /** |
|
136 | + * @return string |
|
137 | + */ |
|
138 | + public function getSignPrivateKey() |
|
139 | + { |
|
140 | + return $this->signPrivateKey; |
|
141 | + } |
|
142 | + |
|
143 | + /** |
|
144 | + * Set perform signing before encryption. |
|
145 | + * |
|
146 | + * The default is to first sign the message and then encrypt. |
|
147 | + * But some older mail clients, namely Microsoft Outlook 2000 will work when the message first encrypted. |
|
148 | + * As this goes against the official specs, its recommended to only use 'encryption -> signing' when specifically targeting these 'broken' clients. |
|
149 | + * |
|
150 | + * @param bool $signThenEncrypt |
|
151 | + * |
|
152 | + * @return $this |
|
153 | + */ |
|
154 | + public function setSignThenEncrypt($signThenEncrypt = true) |
|
155 | + { |
|
156 | + $this->signThenEncrypt = $signThenEncrypt; |
|
157 | + |
|
158 | + return $this; |
|
159 | + } |
|
160 | + |
|
161 | + /** |
|
162 | + * @return bool |
|
163 | + */ |
|
164 | + public function isSignThenEncrypt() |
|
165 | + { |
|
166 | + return $this->signThenEncrypt; |
|
167 | + } |
|
168 | + |
|
169 | + /** |
|
170 | + * Resets internal states. |
|
171 | + * |
|
172 | + * @return $this |
|
173 | + */ |
|
174 | + public function reset() |
|
175 | + { |
|
176 | + return $this; |
|
177 | + } |
|
178 | + |
|
179 | + /** |
|
180 | + * Specify whether to wrap the entire MIME message in the S/MIME message. |
|
181 | + * |
|
182 | + * According to RFC5751 section 3.1: |
|
183 | + * In order to protect outer, non-content-related message header fields |
|
184 | + * (for instance, the "Subject", "To", "From", and "Cc" fields), the |
|
185 | + * sending client MAY wrap a full MIME message in a message/rfc822 |
|
186 | + * wrapper in order to apply S/MIME security services to these header |
|
187 | + * fields. It is up to the receiving client to decide how to present |
|
188 | + * this "inner" header along with the unprotected "outer" header. |
|
189 | + * |
|
190 | + * @param bool $wrap |
|
191 | + * |
|
192 | + * @return $this |
|
193 | + */ |
|
194 | + public function setWrapFullMessage($wrap) |
|
195 | + { |
|
196 | + $this->wrapFullMessage = $wrap; |
|
197 | + } |
|
198 | + |
|
199 | + /** |
|
200 | + * Change the Swift_Message to apply the signing. |
|
201 | + * |
|
202 | + * @return $this |
|
203 | + */ |
|
204 | + public function signMessage(Swift_Message $message) |
|
205 | + { |
|
206 | + if (null === $this->signCertificate && null === $this->encryptCert) { |
|
207 | + return $this; |
|
208 | + } |
|
209 | + |
|
210 | + if ($this->signThenEncrypt) { |
|
211 | + $this->smimeSignMessage($message); |
|
212 | + $this->smimeEncryptMessage($message); |
|
213 | + } else { |
|
214 | + $this->smimeEncryptMessage($message); |
|
215 | + $this->smimeSignMessage($message); |
|
216 | + } |
|
217 | + } |
|
218 | + |
|
219 | + /** |
|
220 | + * Return the list of header a signer might tamper. |
|
221 | + * |
|
222 | + * @return array |
|
223 | + */ |
|
224 | + public function getAlteredHeaders() |
|
225 | + { |
|
226 | + return ['Content-Type', 'Content-Transfer-Encoding', 'Content-Disposition']; |
|
227 | + } |
|
228 | + |
|
229 | + /** |
|
230 | + * Sign a Swift message. |
|
231 | + */ |
|
232 | + protected function smimeSignMessage(Swift_Message $message) |
|
233 | + { |
|
234 | + // If we don't have a certificate we can't sign the message |
|
235 | + if (null === $this->signCertificate) { |
|
236 | + return; |
|
237 | + } |
|
238 | + |
|
239 | + // Work on a clone of the original message |
|
240 | + $signMessage = clone $message; |
|
241 | + $signMessage->clearSigners(); |
|
242 | + |
|
243 | + if ($this->wrapFullMessage) { |
|
244 | + // The original message essentially becomes the body of the new |
|
245 | + // wrapped message |
|
246 | + $signMessage = $this->wrapMimeMessage($signMessage); |
|
247 | + } else { |
|
248 | + // Only keep header needed to parse the body correctly |
|
249 | + $this->clearAllHeaders($signMessage); |
|
250 | + $this->copyHeaders( |
|
251 | + $message, |
|
252 | + $signMessage, |
|
253 | + [ |
|
254 | + 'Content-Type', |
|
255 | + 'Content-Transfer-Encoding', |
|
256 | + 'Content-Disposition', |
|
257 | + ] |
|
258 | + ); |
|
259 | + } |
|
260 | + |
|
261 | + // Copy the cloned message into a temporary file stream |
|
262 | + $messageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
263 | + $signMessage->toByteStream($messageStream); |
|
264 | + $messageStream->commit(); |
|
265 | + $signedMessageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
266 | + |
|
267 | + // Sign the message using openssl |
|
268 | + if (!openssl_pkcs7_sign( |
|
269 | + $messageStream->getPath(), |
|
270 | + $signedMessageStream->getPath(), |
|
271 | + $this->signCertificate, |
|
272 | + $this->signPrivateKey, |
|
273 | + [], |
|
274 | + $this->signOptions, |
|
275 | + $this->extraCerts |
|
276 | + ) |
|
277 | + ) { |
|
278 | + throw new Swift_IoException(sprintf('Failed to sign S/Mime message. Error: "%s".', openssl_error_string())); |
|
279 | + } |
|
280 | + |
|
281 | + // Parse the resulting signed message content back into the Swift message |
|
282 | + // preserving the original headers |
|
283 | + $this->parseSSLOutput($signedMessageStream, $message); |
|
284 | + } |
|
285 | + |
|
286 | + /** |
|
287 | + * Encrypt a Swift message. |
|
288 | + */ |
|
289 | + protected function smimeEncryptMessage(Swift_Message $message) |
|
290 | + { |
|
291 | + // If we don't have a certificate we can't encrypt the message |
|
292 | + if (null === $this->encryptCert) { |
|
293 | + return; |
|
294 | + } |
|
295 | + |
|
296 | + // Work on a clone of the original message |
|
297 | + $encryptMessage = clone $message; |
|
298 | + $encryptMessage->clearSigners(); |
|
299 | + |
|
300 | + if ($this->wrapFullMessage) { |
|
301 | + // The original message essentially becomes the body of the new |
|
302 | + // wrapped message |
|
303 | + $encryptMessage = $this->wrapMimeMessage($encryptMessage); |
|
304 | + } else { |
|
305 | + // Only keep header needed to parse the body correctly |
|
306 | + $this->clearAllHeaders($encryptMessage); |
|
307 | + $this->copyHeaders( |
|
308 | + $message, |
|
309 | + $encryptMessage, |
|
310 | + [ |
|
311 | + 'Content-Type', |
|
312 | + 'Content-Transfer-Encoding', |
|
313 | + 'Content-Disposition', |
|
314 | + ] |
|
315 | + ); |
|
316 | + } |
|
317 | + |
|
318 | + // Convert the message content (including headers) to a string |
|
319 | + // and place it in a temporary file |
|
320 | + $messageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
321 | + $encryptMessage->toByteStream($messageStream); |
|
322 | + $messageStream->commit(); |
|
323 | + $encryptedMessageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
324 | + |
|
325 | + // Encrypt the message |
|
326 | + if (!openssl_pkcs7_encrypt( |
|
327 | + $messageStream->getPath(), |
|
328 | + $encryptedMessageStream->getPath(), |
|
329 | + $this->encryptCert, |
|
330 | + [], |
|
331 | + 0, |
|
332 | + $this->encryptCipher |
|
333 | + ) |
|
334 | + ) { |
|
335 | + throw new Swift_IoException(sprintf('Failed to encrypt S/Mime message. Error: "%s".', openssl_error_string())); |
|
336 | + } |
|
337 | + |
|
338 | + // Parse the resulting signed message content back into the Swift message |
|
339 | + // preserving the original headers |
|
340 | + $this->parseSSLOutput($encryptedMessageStream, $message); |
|
341 | + } |
|
342 | + |
|
343 | + /** |
|
344 | + * Copy named headers from one Swift message to another. |
|
345 | + */ |
|
346 | + protected function copyHeaders( |
|
347 | + Swift_Message $fromMessage, |
|
348 | + Swift_Message $toMessage, |
|
349 | + array $headers = [] |
|
350 | + ) { |
|
351 | + foreach ($headers as $header) { |
|
352 | + $this->copyHeader($fromMessage, $toMessage, $header); |
|
353 | + } |
|
354 | + } |
|
355 | + |
|
356 | + /** |
|
357 | + * Copy a single header from one Swift message to another. |
|
358 | + * |
|
359 | + * @param string $headerName |
|
360 | + */ |
|
361 | + protected function copyHeader(Swift_Message $fromMessage, Swift_Message $toMessage, $headerName) |
|
362 | + { |
|
363 | + $header = $fromMessage->getHeaders()->get($headerName); |
|
364 | + if (!$header) { |
|
365 | + return; |
|
366 | + } |
|
367 | + $headers = $toMessage->getHeaders(); |
|
368 | + switch ($header->getFieldType()) { |
|
369 | + case Swift_Mime_Header::TYPE_TEXT: |
|
370 | + $headers->addTextHeader($header->getFieldName(), $header->getValue()); |
|
371 | + break; |
|
372 | + case Swift_Mime_Header::TYPE_PARAMETERIZED: |
|
373 | + $headers->addParameterizedHeader( |
|
374 | + $header->getFieldName(), |
|
375 | + $header->getValue(), |
|
376 | + $header->getParameters() |
|
377 | + ); |
|
378 | + break; |
|
379 | + } |
|
380 | + } |
|
381 | + |
|
382 | + /** |
|
383 | + * Remove all headers from a Swift message. |
|
384 | + */ |
|
385 | + protected function clearAllHeaders(Swift_Message $message) |
|
386 | + { |
|
387 | + $headers = $message->getHeaders(); |
|
388 | + foreach ($headers->listAll() as $header) { |
|
389 | + $headers->removeAll($header); |
|
390 | + } |
|
391 | + } |
|
392 | + |
|
393 | + /** |
|
394 | + * Wraps a Swift_Message in a message/rfc822 MIME part. |
|
395 | + * |
|
396 | + * @return Swift_MimePart |
|
397 | + */ |
|
398 | + protected function wrapMimeMessage(Swift_Message $message) |
|
399 | + { |
|
400 | + // Start by copying the original message into a message stream |
|
401 | + $messageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
402 | + $message->toByteStream($messageStream); |
|
403 | + $messageStream->commit(); |
|
404 | + |
|
405 | + // Create a new MIME part that wraps the original stream |
|
406 | + $wrappedMessage = new Swift_MimePart($messageStream, 'message/rfc822'); |
|
407 | + $wrappedMessage->setEncoder(new Swift_Mime_ContentEncoder_PlainContentEncoder('7bit')); |
|
408 | + |
|
409 | + return $wrappedMessage; |
|
410 | + } |
|
411 | + |
|
412 | + protected function parseSSLOutput(Swift_InputByteStream $inputStream, Swift_Message $message) |
|
413 | + { |
|
414 | + $messageStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
415 | + $this->copyFromOpenSSLOutput($inputStream, $messageStream); |
|
416 | + |
|
417 | + $this->streamToMime($messageStream, $message); |
|
418 | + } |
|
419 | + |
|
420 | + /** |
|
421 | + * Merges an OutputByteStream from OpenSSL to a Swift_Message. |
|
422 | + */ |
|
423 | + protected function streamToMime(Swift_OutputByteStream $fromStream, Swift_Message $message) |
|
424 | + { |
|
425 | + // Parse the stream into headers and body |
|
426 | + list($headers, $messageStream) = $this->parseStream($fromStream); |
|
427 | + |
|
428 | + // Get the original message headers |
|
429 | + $messageHeaders = $message->getHeaders(); |
|
430 | + |
|
431 | + // Let the stream determine the headers describing the body content, |
|
432 | + // since the body of the original message is overwritten by the body |
|
433 | + // coming from the stream. |
|
434 | + // These are all content-* headers. |
|
435 | + |
|
436 | + // Default transfer encoding is 7bit if not set |
|
437 | + $encoding = ''; |
|
438 | + // Remove all existing transfer encoding headers |
|
439 | + $messageHeaders->removeAll('Content-Transfer-Encoding'); |
|
440 | + // See whether the stream sets the transfer encoding |
|
441 | + if (isset($headers['content-transfer-encoding'])) { |
|
442 | + $encoding = $headers['content-transfer-encoding']; |
|
443 | + } |
|
444 | + |
|
445 | + // We use the null content encoder, since the body is already encoded |
|
446 | + // according to the transfer encoding specified in the stream |
|
447 | + $message->setEncoder(new Swift_Mime_ContentEncoder_NullContentEncoder($encoding)); |
|
448 | + |
|
449 | + // Set the disposition, if present |
|
450 | + if (isset($headers['content-disposition'])) { |
|
451 | + $messageHeaders->addTextHeader('Content-Disposition', $headers['content-disposition']); |
|
452 | + } |
|
453 | + |
|
454 | + // Copy over the body from the stream using the content type dictated |
|
455 | + // by the stream content |
|
456 | + $message->setChildren([]); |
|
457 | + $message->setBody($messageStream, $headers['content-type']); |
|
458 | + } |
|
459 | + |
|
460 | + /** |
|
461 | + * This message will parse the headers of a MIME email byte stream |
|
462 | + * and return an array that contains the headers as an associative |
|
463 | + * array and the email body as a string. |
|
464 | + * |
|
465 | + * @return array |
|
466 | + */ |
|
467 | + protected function parseStream(Swift_OutputByteStream $emailStream) |
|
468 | + { |
|
469 | + $bufferLength = 78; |
|
470 | + $headerData = ''; |
|
471 | + $headerBodySeparator = "\r\n\r\n"; |
|
472 | + |
|
473 | + $emailStream->setReadPointer(0); |
|
474 | + |
|
475 | + // Read out the headers section from the stream to a string |
|
476 | + while (false !== ($buffer = $emailStream->read($bufferLength))) { |
|
477 | + $headerData .= $buffer; |
|
478 | + |
|
479 | + $headersPosEnd = strpos($headerData, $headerBodySeparator); |
|
480 | + |
|
481 | + // Stop reading if we found the end of the headers |
|
482 | + if (false !== $headersPosEnd) { |
|
483 | + break; |
|
484 | + } |
|
485 | + } |
|
486 | + |
|
487 | + // Split the header data into lines |
|
488 | + $headerData = trim(substr($headerData, 0, $headersPosEnd)); |
|
489 | + $headerLines = explode("\r\n", $headerData); |
|
490 | + unset($headerData); |
|
491 | + |
|
492 | + $headers = []; |
|
493 | + $currentHeaderName = ''; |
|
494 | + |
|
495 | + // Transform header lines into an associative array |
|
496 | + foreach ($headerLines as $headerLine) { |
|
497 | + // Handle headers that span multiple lines |
|
498 | + if (false === strpos($headerLine, ':')) { |
|
499 | + $headers[$currentHeaderName] .= ' '.trim($headerLine ?? ''); |
|
500 | + continue; |
|
501 | + } |
|
502 | + |
|
503 | + $header = explode(':', $headerLine, 2); |
|
504 | + $currentHeaderName = strtolower($header[0] ?? ''); |
|
505 | + $headers[$currentHeaderName] = trim($header[1] ?? ''); |
|
506 | + } |
|
507 | + |
|
508 | + // Read the entire email body into a byte stream |
|
509 | + $bodyStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
510 | + |
|
511 | + // Skip the header and separator and point to the body |
|
512 | + $emailStream->setReadPointer($headersPosEnd + \strlen($headerBodySeparator)); |
|
513 | + |
|
514 | + while (false !== ($buffer = $emailStream->read($bufferLength))) { |
|
515 | + $bodyStream->write($buffer); |
|
516 | + } |
|
517 | + |
|
518 | + $bodyStream->commit(); |
|
519 | + |
|
520 | + return [$headers, $bodyStream]; |
|
521 | + } |
|
522 | + |
|
523 | + protected function copyFromOpenSSLOutput(Swift_OutputByteStream $fromStream, Swift_InputByteStream $toStream) |
|
524 | + { |
|
525 | + $bufferLength = 4096; |
|
526 | + $filteredStream = new Swift_ByteStream_TemporaryFileByteStream(); |
|
527 | + $filteredStream->addFilter($this->replacementFactory->createFilter("\r\n", "\n"), 'CRLF to LF'); |
|
528 | + $filteredStream->addFilter($this->replacementFactory->createFilter("\n", "\r\n"), 'LF to CRLF'); |
|
529 | + |
|
530 | + while (false !== ($buffer = $fromStream->read($bufferLength))) { |
|
531 | + $filteredStream->write($buffer); |
|
532 | + } |
|
533 | + |
|
534 | + $filteredStream->flushBuffers(); |
|
535 | + |
|
536 | + while (false !== ($buffer = $filteredStream->read($bufferLength))) { |
|
537 | + $toStream->write($buffer); |
|
538 | + } |
|
539 | + |
|
540 | + $toStream->commit(); |
|
541 | + } |
|
542 | 542 | } |