/src/openssl/crypto/asn1/asn_mime.c
Line | Count | Source (jump to first uncovered line) |
1 | | /* |
2 | | * Copyright 2008-2018 The OpenSSL Project Authors. All Rights Reserved. |
3 | | * |
4 | | * Licensed under the OpenSSL license (the "License"). You may not use |
5 | | * this file except in compliance with the License. You can obtain a copy |
6 | | * in the file LICENSE in the source distribution or at |
7 | | * https://www.openssl.org/source/license.html |
8 | | */ |
9 | | |
10 | | #include <stdio.h> |
11 | | #include "internal/ctype.h" |
12 | | #include "internal/cryptlib.h" |
13 | | #include <openssl/rand.h> |
14 | | #include <openssl/x509.h> |
15 | | #include <openssl/asn1.h> |
16 | | #include <openssl/asn1t.h> |
17 | | #include "internal/evp_int.h" |
18 | | #include "internal/bio.h" |
19 | | #include "asn1_locl.h" |
20 | | |
21 | | /* |
22 | | * Generalised MIME like utilities for streaming ASN1. Although many have a |
23 | | * PKCS7/CMS like flavour others are more general purpose. |
24 | | */ |
25 | | |
26 | | /* |
27 | | * MIME format structures Note that all are translated to lower case apart |
28 | | * from parameter values. Quotes are stripped off |
29 | | */ |
30 | | |
31 | | struct mime_param_st { |
32 | | char *param_name; /* Param name e.g. "micalg" */ |
33 | | char *param_value; /* Param value e.g. "sha1" */ |
34 | | }; |
35 | | |
36 | | struct mime_header_st { |
37 | | char *name; /* Name of line e.g. "content-type" */ |
38 | | char *value; /* Value of line e.g. "text/plain" */ |
39 | | STACK_OF(MIME_PARAM) *params; /* Zero or more parameters */ |
40 | | }; |
41 | | |
42 | | static int asn1_output_data(BIO *out, BIO *data, ASN1_VALUE *val, int flags, |
43 | | const ASN1_ITEM *it); |
44 | | static char *strip_ends(char *name); |
45 | | static char *strip_start(char *name); |
46 | | static char *strip_end(char *name); |
47 | | static MIME_HEADER *mime_hdr_new(const char *name, const char *value); |
48 | | static int mime_hdr_addparam(MIME_HEADER *mhdr, const char *name, const char *value); |
49 | | static STACK_OF(MIME_HEADER) *mime_parse_hdr(BIO *bio); |
50 | | static int mime_hdr_cmp(const MIME_HEADER *const *a, |
51 | | const MIME_HEADER *const *b); |
52 | | static int mime_param_cmp(const MIME_PARAM *const *a, |
53 | | const MIME_PARAM *const *b); |
54 | | static void mime_param_free(MIME_PARAM *param); |
55 | | static int mime_bound_check(char *line, int linelen, const char *bound, int blen); |
56 | | static int multi_split(BIO *bio, const char *bound, STACK_OF(BIO) **ret); |
57 | | static int strip_eol(char *linebuf, int *plen, int flags); |
58 | | static MIME_HEADER *mime_hdr_find(STACK_OF(MIME_HEADER) *hdrs, const char *name); |
59 | | static MIME_PARAM *mime_param_find(MIME_HEADER *hdr, const char *name); |
60 | | static void mime_hdr_free(MIME_HEADER *hdr); |
61 | | |
62 | 0 | #define MAX_SMLEN 1024 |
63 | | #define mime_debug(x) /* x */ |
64 | | |
65 | | /* Output an ASN1 structure in BER format streaming if necessary */ |
66 | | |
67 | | int i2d_ASN1_bio_stream(BIO *out, ASN1_VALUE *val, BIO *in, int flags, |
68 | | const ASN1_ITEM *it) |
69 | 0 | { |
70 | 0 | /* If streaming create stream BIO and copy all content through it */ |
71 | 0 | if (flags & SMIME_STREAM) { |
72 | 0 | BIO *bio, *tbio; |
73 | 0 | bio = BIO_new_NDEF(out, val, it); |
74 | 0 | if (!bio) { |
75 | 0 | ASN1err(ASN1_F_I2D_ASN1_BIO_STREAM, ERR_R_MALLOC_FAILURE); |
76 | 0 | return 0; |
77 | 0 | } |
78 | 0 | SMIME_crlf_copy(in, bio, flags); |
79 | 0 | (void)BIO_flush(bio); |
80 | 0 | /* Free up successive BIOs until we hit the old output BIO */ |
81 | 0 | do { |
82 | 0 | tbio = BIO_pop(bio); |
83 | 0 | BIO_free(bio); |
84 | 0 | bio = tbio; |
85 | 0 | } while (bio != out); |
86 | 0 | } |
87 | 0 | /* |
88 | 0 | * else just write out ASN1 structure which will have all content stored |
89 | 0 | * internally |
90 | 0 | */ |
91 | 0 | else |
92 | 0 | ASN1_item_i2d_bio(it, out, val); |
93 | 0 | return 1; |
94 | 0 | } |
95 | | |
96 | | /* Base 64 read and write of ASN1 structure */ |
97 | | |
98 | | static int B64_write_ASN1(BIO *out, ASN1_VALUE *val, BIO *in, int flags, |
99 | | const ASN1_ITEM *it) |
100 | 0 | { |
101 | 0 | BIO *b64; |
102 | 0 | int r; |
103 | 0 | b64 = BIO_new(BIO_f_base64()); |
104 | 0 | if (b64 == NULL) { |
105 | 0 | ASN1err(ASN1_F_B64_WRITE_ASN1, ERR_R_MALLOC_FAILURE); |
106 | 0 | return 0; |
107 | 0 | } |
108 | 0 | /* |
109 | 0 | * prepend the b64 BIO so all data is base64 encoded. |
110 | 0 | */ |
111 | 0 | out = BIO_push(b64, out); |
112 | 0 | r = i2d_ASN1_bio_stream(out, val, in, flags, it); |
113 | 0 | (void)BIO_flush(out); |
114 | 0 | BIO_pop(out); |
115 | 0 | BIO_free(b64); |
116 | 0 | return r; |
117 | 0 | } |
118 | | |
119 | | /* Streaming ASN1 PEM write */ |
120 | | |
121 | | int PEM_write_bio_ASN1_stream(BIO *out, ASN1_VALUE *val, BIO *in, int flags, |
122 | | const char *hdr, const ASN1_ITEM *it) |
123 | 0 | { |
124 | 0 | int r; |
125 | 0 | BIO_printf(out, "-----BEGIN %s-----\n", hdr); |
126 | 0 | r = B64_write_ASN1(out, val, in, flags, it); |
127 | 0 | BIO_printf(out, "-----END %s-----\n", hdr); |
128 | 0 | return r; |
129 | 0 | } |
130 | | |
131 | | static ASN1_VALUE *b64_read_asn1(BIO *bio, const ASN1_ITEM *it) |
132 | 0 | { |
133 | 0 | BIO *b64; |
134 | 0 | ASN1_VALUE *val; |
135 | 0 |
|
136 | 0 | if ((b64 = BIO_new(BIO_f_base64())) == NULL) { |
137 | 0 | ASN1err(ASN1_F_B64_READ_ASN1, ERR_R_MALLOC_FAILURE); |
138 | 0 | return 0; |
139 | 0 | } |
140 | 0 | bio = BIO_push(b64, bio); |
141 | 0 | val = ASN1_item_d2i_bio(it, bio, NULL); |
142 | 0 | if (!val) |
143 | 0 | ASN1err(ASN1_F_B64_READ_ASN1, ASN1_R_DECODE_ERROR); |
144 | 0 | (void)BIO_flush(bio); |
145 | 0 | BIO_pop(bio); |
146 | 0 | BIO_free(b64); |
147 | 0 | return val; |
148 | 0 | } |
149 | | |
150 | | /* Generate the MIME "micalg" parameter from RFC3851, RFC4490 */ |
151 | | |
152 | | static int asn1_write_micalg(BIO *out, STACK_OF(X509_ALGOR) *mdalgs) |
153 | 0 | { |
154 | 0 | const EVP_MD *md; |
155 | 0 | int i, have_unknown = 0, write_comma, ret = 0, md_nid; |
156 | 0 | have_unknown = 0; |
157 | 0 | write_comma = 0; |
158 | 0 | for (i = 0; i < sk_X509_ALGOR_num(mdalgs); i++) { |
159 | 0 | if (write_comma) |
160 | 0 | BIO_write(out, ",", 1); |
161 | 0 | write_comma = 1; |
162 | 0 | md_nid = OBJ_obj2nid(sk_X509_ALGOR_value(mdalgs, i)->algorithm); |
163 | 0 | md = EVP_get_digestbynid(md_nid); |
164 | 0 | if (md && md->md_ctrl) { |
165 | 0 | int rv; |
166 | 0 | char *micstr; |
167 | 0 | rv = md->md_ctrl(NULL, EVP_MD_CTRL_MICALG, 0, &micstr); |
168 | 0 | if (rv > 0) { |
169 | 0 | BIO_puts(out, micstr); |
170 | 0 | OPENSSL_free(micstr); |
171 | 0 | continue; |
172 | 0 | } |
173 | 0 | if (rv != -2) |
174 | 0 | goto err; |
175 | 0 | } |
176 | 0 | switch (md_nid) { |
177 | 0 | case NID_sha1: |
178 | 0 | BIO_puts(out, "sha1"); |
179 | 0 | break; |
180 | 0 |
|
181 | 0 | case NID_md5: |
182 | 0 | BIO_puts(out, "md5"); |
183 | 0 | break; |
184 | 0 |
|
185 | 0 | case NID_sha256: |
186 | 0 | BIO_puts(out, "sha-256"); |
187 | 0 | break; |
188 | 0 |
|
189 | 0 | case NID_sha384: |
190 | 0 | BIO_puts(out, "sha-384"); |
191 | 0 | break; |
192 | 0 |
|
193 | 0 | case NID_sha512: |
194 | 0 | BIO_puts(out, "sha-512"); |
195 | 0 | break; |
196 | 0 |
|
197 | 0 | case NID_id_GostR3411_94: |
198 | 0 | BIO_puts(out, "gostr3411-94"); |
199 | 0 | goto err; |
200 | 0 |
|
201 | 0 | default: |
202 | 0 | if (have_unknown) |
203 | 0 | write_comma = 0; |
204 | 0 | else { |
205 | 0 | BIO_puts(out, "unknown"); |
206 | 0 | have_unknown = 1; |
207 | 0 | } |
208 | 0 | break; |
209 | 0 |
|
210 | 0 | } |
211 | 0 | } |
212 | 0 |
|
213 | 0 | ret = 1; |
214 | 0 | err: |
215 | 0 |
|
216 | 0 | return ret; |
217 | 0 |
|
218 | 0 | } |
219 | | |
220 | | /* SMIME sender */ |
221 | | |
222 | | int SMIME_write_ASN1(BIO *bio, ASN1_VALUE *val, BIO *data, int flags, |
223 | | int ctype_nid, int econt_nid, |
224 | | STACK_OF(X509_ALGOR) *mdalgs, const ASN1_ITEM *it) |
225 | 0 | { |
226 | 0 | char bound[33], c; |
227 | 0 | int i; |
228 | 0 | const char *mime_prefix, *mime_eol, *cname = "smime.p7m"; |
229 | 0 | const char *msg_type = NULL; |
230 | 0 | if (flags & SMIME_OLDMIME) |
231 | 0 | mime_prefix = "application/x-pkcs7-"; |
232 | 0 | else |
233 | 0 | mime_prefix = "application/pkcs7-"; |
234 | 0 |
|
235 | 0 | if (flags & SMIME_CRLFEOL) |
236 | 0 | mime_eol = "\r\n"; |
237 | 0 | else |
238 | 0 | mime_eol = "\n"; |
239 | 0 | if ((flags & SMIME_DETACHED) && data) { |
240 | 0 | /* We want multipart/signed */ |
241 | 0 | /* Generate a random boundary */ |
242 | 0 | if (RAND_bytes((unsigned char *)bound, 32) <= 0) |
243 | 0 | return 0; |
244 | 0 | for (i = 0; i < 32; i++) { |
245 | 0 | c = bound[i] & 0xf; |
246 | 0 | if (c < 10) |
247 | 0 | c += '0'; |
248 | 0 | else |
249 | 0 | c += 'A' - 10; |
250 | 0 | bound[i] = c; |
251 | 0 | } |
252 | 0 | bound[32] = 0; |
253 | 0 | BIO_printf(bio, "MIME-Version: 1.0%s", mime_eol); |
254 | 0 | BIO_printf(bio, "Content-Type: multipart/signed;"); |
255 | 0 | BIO_printf(bio, " protocol=\"%ssignature\";", mime_prefix); |
256 | 0 | BIO_puts(bio, " micalg=\""); |
257 | 0 | asn1_write_micalg(bio, mdalgs); |
258 | 0 | BIO_printf(bio, "\"; boundary=\"----%s\"%s%s", |
259 | 0 | bound, mime_eol, mime_eol); |
260 | 0 | BIO_printf(bio, "This is an S/MIME signed message%s%s", |
261 | 0 | mime_eol, mime_eol); |
262 | 0 | /* Now write out the first part */ |
263 | 0 | BIO_printf(bio, "------%s%s", bound, mime_eol); |
264 | 0 | if (!asn1_output_data(bio, data, val, flags, it)) |
265 | 0 | return 0; |
266 | 0 | BIO_printf(bio, "%s------%s%s", mime_eol, bound, mime_eol); |
267 | 0 |
|
268 | 0 | /* Headers for signature */ |
269 | 0 |
|
270 | 0 | BIO_printf(bio, "Content-Type: %ssignature;", mime_prefix); |
271 | 0 | BIO_printf(bio, " name=\"smime.p7s\"%s", mime_eol); |
272 | 0 | BIO_printf(bio, "Content-Transfer-Encoding: base64%s", mime_eol); |
273 | 0 | BIO_printf(bio, "Content-Disposition: attachment;"); |
274 | 0 | BIO_printf(bio, " filename=\"smime.p7s\"%s%s", mime_eol, mime_eol); |
275 | 0 | B64_write_ASN1(bio, val, NULL, 0, it); |
276 | 0 | BIO_printf(bio, "%s------%s--%s%s", mime_eol, bound, |
277 | 0 | mime_eol, mime_eol); |
278 | 0 | return 1; |
279 | 0 | } |
280 | 0 | |
281 | 0 | /* Determine smime-type header */ |
282 | 0 | |
283 | 0 | if (ctype_nid == NID_pkcs7_enveloped) |
284 | 0 | msg_type = "enveloped-data"; |
285 | 0 | else if (ctype_nid == NID_pkcs7_signed) { |
286 | 0 | if (econt_nid == NID_id_smime_ct_receipt) |
287 | 0 | msg_type = "signed-receipt"; |
288 | 0 | else if (sk_X509_ALGOR_num(mdalgs) >= 0) |
289 | 0 | msg_type = "signed-data"; |
290 | 0 | else |
291 | 0 | msg_type = "certs-only"; |
292 | 0 | } else if (ctype_nid == NID_id_smime_ct_compressedData) { |
293 | 0 | msg_type = "compressed-data"; |
294 | 0 | cname = "smime.p7z"; |
295 | 0 | } |
296 | 0 | /* MIME headers */ |
297 | 0 | BIO_printf(bio, "MIME-Version: 1.0%s", mime_eol); |
298 | 0 | BIO_printf(bio, "Content-Disposition: attachment;"); |
299 | 0 | BIO_printf(bio, " filename=\"%s\"%s", cname, mime_eol); |
300 | 0 | BIO_printf(bio, "Content-Type: %smime;", mime_prefix); |
301 | 0 | if (msg_type) |
302 | 0 | BIO_printf(bio, " smime-type=%s;", msg_type); |
303 | 0 | BIO_printf(bio, " name=\"%s\"%s", cname, mime_eol); |
304 | 0 | BIO_printf(bio, "Content-Transfer-Encoding: base64%s%s", |
305 | 0 | mime_eol, mime_eol); |
306 | 0 | if (!B64_write_ASN1(bio, val, data, flags, it)) |
307 | 0 | return 0; |
308 | 0 | BIO_printf(bio, "%s", mime_eol); |
309 | 0 | return 1; |
310 | 0 | } |
311 | | |
312 | | /* Handle output of ASN1 data */ |
313 | | |
314 | | static int asn1_output_data(BIO *out, BIO *data, ASN1_VALUE *val, int flags, |
315 | | const ASN1_ITEM *it) |
316 | 0 | { |
317 | 0 | BIO *tmpbio; |
318 | 0 | const ASN1_AUX *aux = it->funcs; |
319 | 0 | ASN1_STREAM_ARG sarg; |
320 | 0 | int rv = 1; |
321 | 0 |
|
322 | 0 | /* |
323 | 0 | * If data is not detached or resigning then the output BIO is already |
324 | 0 | * set up to finalise when it is written through. |
325 | 0 | */ |
326 | 0 | if (!(flags & SMIME_DETACHED) || (flags & PKCS7_REUSE_DIGEST)) { |
327 | 0 | SMIME_crlf_copy(data, out, flags); |
328 | 0 | return 1; |
329 | 0 | } |
330 | 0 | |
331 | 0 | if (!aux || !aux->asn1_cb) { |
332 | 0 | ASN1err(ASN1_F_ASN1_OUTPUT_DATA, ASN1_R_STREAMING_NOT_SUPPORTED); |
333 | 0 | return 0; |
334 | 0 | } |
335 | 0 |
|
336 | 0 | sarg.out = out; |
337 | 0 | sarg.ndef_bio = NULL; |
338 | 0 | sarg.boundary = NULL; |
339 | 0 |
|
340 | 0 | /* Let ASN1 code prepend any needed BIOs */ |
341 | 0 |
|
342 | 0 | if (aux->asn1_cb(ASN1_OP_DETACHED_PRE, &val, it, &sarg) <= 0) |
343 | 0 | return 0; |
344 | 0 | |
345 | 0 | /* Copy data across, passing through filter BIOs for processing */ |
346 | 0 | SMIME_crlf_copy(data, sarg.ndef_bio, flags); |
347 | 0 |
|
348 | 0 | /* Finalize structure */ |
349 | 0 | if (aux->asn1_cb(ASN1_OP_DETACHED_POST, &val, it, &sarg) <= 0) |
350 | 0 | rv = 0; |
351 | 0 |
|
352 | 0 | /* Now remove any digests prepended to the BIO */ |
353 | 0 |
|
354 | 0 | while (sarg.ndef_bio != out) { |
355 | 0 | tmpbio = BIO_pop(sarg.ndef_bio); |
356 | 0 | BIO_free(sarg.ndef_bio); |
357 | 0 | sarg.ndef_bio = tmpbio; |
358 | 0 | } |
359 | 0 |
|
360 | 0 | return rv; |
361 | 0 |
|
362 | 0 | } |
363 | | |
364 | | /* |
365 | | * SMIME reader: handle multipart/signed and opaque signing. in multipart |
366 | | * case the content is placed in a memory BIO pointed to by "bcont". In |
367 | | * opaque this is set to NULL |
368 | | */ |
369 | | |
370 | | ASN1_VALUE *SMIME_read_ASN1(BIO *bio, BIO **bcont, const ASN1_ITEM *it) |
371 | | { |
372 | | BIO *asnin; |
373 | | STACK_OF(MIME_HEADER) *headers = NULL; |
374 | | STACK_OF(BIO) *parts = NULL; |
375 | | MIME_HEADER *hdr; |
376 | | MIME_PARAM *prm; |
377 | | ASN1_VALUE *val; |
378 | | int ret; |
379 | | |
380 | | if (bcont) |
381 | | *bcont = NULL; |
382 | | |
383 | | if ((headers = mime_parse_hdr(bio)) == NULL) { |
384 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_MIME_PARSE_ERROR); |
385 | | return NULL; |
386 | | } |
387 | | |
388 | | if ((hdr = mime_hdr_find(headers, "content-type")) == NULL |
389 | | || hdr->value == NULL) { |
390 | | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
391 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_NO_CONTENT_TYPE); |
392 | | return NULL; |
393 | | } |
394 | | |
395 | | /* Handle multipart/signed */ |
396 | | |
397 | | if (strcmp(hdr->value, "multipart/signed") == 0) { |
398 | | /* Split into two parts */ |
399 | | prm = mime_param_find(hdr, "boundary"); |
400 | | if (!prm || !prm->param_value) { |
401 | | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
402 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_NO_MULTIPART_BOUNDARY); |
403 | | return NULL; |
404 | | } |
405 | | ret = multi_split(bio, prm->param_value, &parts); |
406 | | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
407 | | if (!ret || (sk_BIO_num(parts) != 2)) { |
408 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_NO_MULTIPART_BODY_FAILURE); |
409 | | sk_BIO_pop_free(parts, BIO_vfree); |
410 | | return NULL; |
411 | | } |
412 | | |
413 | | /* Parse the signature piece */ |
414 | | asnin = sk_BIO_value(parts, 1); |
415 | | |
416 | | if ((headers = mime_parse_hdr(asnin)) == NULL) { |
417 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_MIME_SIG_PARSE_ERROR); |
418 | | sk_BIO_pop_free(parts, BIO_vfree); |
419 | | return NULL; |
420 | | } |
421 | | |
422 | | /* Get content type */ |
423 | | |
424 | | if ((hdr = mime_hdr_find(headers, "content-type")) == NULL |
425 | | || hdr->value == NULL) { |
426 | | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
427 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_NO_SIG_CONTENT_TYPE); |
428 | | sk_BIO_pop_free(parts, BIO_vfree); |
429 | | return NULL; |
430 | | } |
431 | | |
432 | | if (strcmp(hdr->value, "application/x-pkcs7-signature") && |
433 | | strcmp(hdr->value, "application/pkcs7-signature")) { |
434 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_SIG_INVALID_MIME_TYPE); |
435 | | ERR_add_error_data(2, "type: ", hdr->value); |
436 | | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
437 | | sk_BIO_pop_free(parts, BIO_vfree); |
438 | | return NULL; |
439 | | } |
440 | | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
441 | | /* Read in ASN1 */ |
442 | | if ((val = b64_read_asn1(asnin, it)) == NULL) { |
443 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_ASN1_SIG_PARSE_ERROR); |
444 | | sk_BIO_pop_free(parts, BIO_vfree); |
445 | | return NULL; |
446 | | } |
447 | | |
448 | | if (bcont) { |
449 | | *bcont = sk_BIO_value(parts, 0); |
450 | | BIO_free(asnin); |
451 | | sk_BIO_free(parts); |
452 | | } else |
453 | | sk_BIO_pop_free(parts, BIO_vfree); |
454 | | return val; |
455 | | } |
456 | | |
457 | | /* OK, if not multipart/signed try opaque signature */ |
458 | | |
459 | | if (strcmp(hdr->value, "application/x-pkcs7-mime") && |
460 | | strcmp(hdr->value, "application/pkcs7-mime")) { |
461 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_INVALID_MIME_TYPE); |
462 | | ERR_add_error_data(2, "type: ", hdr->value); |
463 | | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
464 | | return NULL; |
465 | | } |
466 | | |
467 | | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
468 | | |
469 | | if ((val = b64_read_asn1(bio, it)) == NULL) { |
470 | | ASN1err(ASN1_F_SMIME_READ_ASN1, ASN1_R_ASN1_PARSE_ERROR); |
471 | | return NULL; |
472 | | } |
473 | | return val; |
474 | | |
475 | | } |
476 | | |
477 | | /* Copy text from one BIO to another making the output CRLF at EOL */ |
478 | | int SMIME_crlf_copy(BIO *in, BIO *out, int flags) |
479 | 0 | { |
480 | 0 | BIO *bf; |
481 | 0 | char eol; |
482 | 0 | int len; |
483 | 0 | char linebuf[MAX_SMLEN]; |
484 | 0 | /* |
485 | 0 | * Buffer output so we don't write one line at a time. This is useful |
486 | 0 | * when streaming as we don't end up with one OCTET STRING per line. |
487 | 0 | */ |
488 | 0 | bf = BIO_new(BIO_f_buffer()); |
489 | 0 | if (bf == NULL) |
490 | 0 | return 0; |
491 | 0 | out = BIO_push(bf, out); |
492 | 0 | if (flags & SMIME_BINARY) { |
493 | 0 | while ((len = BIO_read(in, linebuf, MAX_SMLEN)) > 0) |
494 | 0 | BIO_write(out, linebuf, len); |
495 | 0 | } else { |
496 | 0 | int eolcnt = 0; |
497 | 0 | if (flags & SMIME_TEXT) |
498 | 0 | BIO_printf(out, "Content-Type: text/plain\r\n\r\n"); |
499 | 0 | while ((len = BIO_gets(in, linebuf, MAX_SMLEN)) > 0) { |
500 | 0 | eol = strip_eol(linebuf, &len, flags); |
501 | 0 | if (len) { |
502 | 0 | /* Not EOF: write out all CRLF */ |
503 | 0 | if (flags & SMIME_ASCIICRLF) { |
504 | 0 | int i; |
505 | 0 | for (i = 0; i < eolcnt; i++) |
506 | 0 | BIO_write(out, "\r\n", 2); |
507 | 0 | eolcnt = 0; |
508 | 0 | } |
509 | 0 | BIO_write(out, linebuf, len); |
510 | 0 | if (eol) |
511 | 0 | BIO_write(out, "\r\n", 2); |
512 | 0 | } else if (flags & SMIME_ASCIICRLF) |
513 | 0 | eolcnt++; |
514 | 0 | else if (eol) |
515 | 0 | BIO_write(out, "\r\n", 2); |
516 | 0 | } |
517 | 0 | } |
518 | 0 | (void)BIO_flush(out); |
519 | 0 | BIO_pop(out); |
520 | 0 | BIO_free(bf); |
521 | 0 | return 1; |
522 | 0 | } |
523 | | |
524 | | /* Strip off headers if they are text/plain */ |
525 | | int SMIME_text(BIO *in, BIO *out) |
526 | 0 | { |
527 | 0 | char iobuf[4096]; |
528 | 0 | int len; |
529 | 0 | STACK_OF(MIME_HEADER) *headers; |
530 | 0 | MIME_HEADER *hdr; |
531 | 0 |
|
532 | 0 | if ((headers = mime_parse_hdr(in)) == NULL) { |
533 | 0 | ASN1err(ASN1_F_SMIME_TEXT, ASN1_R_MIME_PARSE_ERROR); |
534 | 0 | return 0; |
535 | 0 | } |
536 | 0 | if ((hdr = mime_hdr_find(headers, "content-type")) == NULL |
537 | 0 | || hdr->value == NULL) { |
538 | 0 | ASN1err(ASN1_F_SMIME_TEXT, ASN1_R_MIME_NO_CONTENT_TYPE); |
539 | 0 | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
540 | 0 | return 0; |
541 | 0 | } |
542 | 0 | if (strcmp(hdr->value, "text/plain")) { |
543 | 0 | ASN1err(ASN1_F_SMIME_TEXT, ASN1_R_INVALID_MIME_TYPE); |
544 | 0 | ERR_add_error_data(2, "type: ", hdr->value); |
545 | 0 | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
546 | 0 | return 0; |
547 | 0 | } |
548 | 0 | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
549 | 0 | while ((len = BIO_read(in, iobuf, sizeof(iobuf))) > 0) |
550 | 0 | BIO_write(out, iobuf, len); |
551 | 0 | if (len < 0) |
552 | 0 | return 0; |
553 | 0 | return 1; |
554 | 0 | } |
555 | | |
556 | | /* |
557 | | * Split a multipart/XXX message body into component parts: result is |
558 | | * canonical parts in a STACK of bios |
559 | | */ |
560 | | |
561 | | static int multi_split(BIO *bio, const char *bound, STACK_OF(BIO) **ret) |
562 | 0 | { |
563 | 0 | char linebuf[MAX_SMLEN]; |
564 | 0 | int len, blen; |
565 | 0 | int eol = 0, next_eol = 0; |
566 | 0 | BIO *bpart = NULL; |
567 | 0 | STACK_OF(BIO) *parts; |
568 | 0 | char state, part, first; |
569 | 0 |
|
570 | 0 | blen = strlen(bound); |
571 | 0 | part = 0; |
572 | 0 | state = 0; |
573 | 0 | first = 1; |
574 | 0 | parts = sk_BIO_new_null(); |
575 | 0 | *ret = parts; |
576 | 0 | if (*ret == NULL) |
577 | 0 | return 0; |
578 | 0 | while ((len = BIO_gets(bio, linebuf, MAX_SMLEN)) > 0) { |
579 | 0 | state = mime_bound_check(linebuf, len, bound, blen); |
580 | 0 | if (state == 1) { |
581 | 0 | first = 1; |
582 | 0 | part++; |
583 | 0 | } else if (state == 2) { |
584 | 0 | if (!sk_BIO_push(parts, bpart)) { |
585 | 0 | BIO_free(bpart); |
586 | 0 | return 0; |
587 | 0 | } |
588 | 0 | return 1; |
589 | 0 | } else if (part) { |
590 | 0 | /* Strip CR+LF from linebuf */ |
591 | 0 | next_eol = strip_eol(linebuf, &len, 0); |
592 | 0 | if (first) { |
593 | 0 | first = 0; |
594 | 0 | if (bpart) |
595 | 0 | if (!sk_BIO_push(parts, bpart)) { |
596 | 0 | BIO_free(bpart); |
597 | 0 | return 0; |
598 | 0 | } |
599 | 0 | bpart = BIO_new(BIO_s_mem()); |
600 | 0 | if (bpart == NULL) |
601 | 0 | return 0; |
602 | 0 | BIO_set_mem_eof_return(bpart, 0); |
603 | 0 | } else if (eol) |
604 | 0 | BIO_write(bpart, "\r\n", 2); |
605 | 0 | eol = next_eol; |
606 | 0 | if (len) |
607 | 0 | BIO_write(bpart, linebuf, len); |
608 | 0 | } |
609 | 0 | } |
610 | 0 | BIO_free(bpart); |
611 | 0 | return 0; |
612 | 0 | } |
613 | | |
614 | | /* This is the big one: parse MIME header lines up to message body */ |
615 | | |
616 | | #define MIME_INVALID 0 |
617 | 0 | #define MIME_START 1 |
618 | 0 | #define MIME_TYPE 2 |
619 | 0 | #define MIME_NAME 3 |
620 | 0 | #define MIME_VALUE 4 |
621 | 0 | #define MIME_QUOTE 5 |
622 | 0 | #define MIME_COMMENT 6 |
623 | | |
624 | | static STACK_OF(MIME_HEADER) *mime_parse_hdr(BIO *bio) |
625 | 0 | { |
626 | 0 | char *p, *q, c; |
627 | 0 | char *ntmp; |
628 | 0 | char linebuf[MAX_SMLEN]; |
629 | 0 | MIME_HEADER *mhdr = NULL, *new_hdr = NULL; |
630 | 0 | STACK_OF(MIME_HEADER) *headers; |
631 | 0 | int len, state, save_state = 0; |
632 | 0 |
|
633 | 0 | headers = sk_MIME_HEADER_new(mime_hdr_cmp); |
634 | 0 | if (headers == NULL) |
635 | 0 | return NULL; |
636 | 0 | while ((len = BIO_gets(bio, linebuf, MAX_SMLEN)) > 0) { |
637 | 0 | /* If whitespace at line start then continuation line */ |
638 | 0 | if (mhdr && ossl_isspace(linebuf[0])) |
639 | 0 | state = MIME_NAME; |
640 | 0 | else |
641 | 0 | state = MIME_START; |
642 | 0 | ntmp = NULL; |
643 | 0 | /* Go through all characters */ |
644 | 0 | for (p = linebuf, q = linebuf; (c = *p) && (c != '\r') && (c != '\n'); |
645 | 0 | p++) { |
646 | 0 |
|
647 | 0 | /* |
648 | 0 | * State machine to handle MIME headers if this looks horrible |
649 | 0 | * that's because it *is* |
650 | 0 | */ |
651 | 0 |
|
652 | 0 | switch (state) { |
653 | 0 | case MIME_START: |
654 | 0 | if (c == ':') { |
655 | 0 | state = MIME_TYPE; |
656 | 0 | *p = 0; |
657 | 0 | ntmp = strip_ends(q); |
658 | 0 | q = p + 1; |
659 | 0 | } |
660 | 0 | break; |
661 | 0 |
|
662 | 0 | case MIME_TYPE: |
663 | 0 | if (c == ';') { |
664 | 0 | mime_debug("Found End Value\n"); |
665 | 0 | *p = 0; |
666 | 0 | new_hdr = mime_hdr_new(ntmp, strip_ends(q)); |
667 | 0 | if (new_hdr == NULL) |
668 | 0 | goto err; |
669 | 0 | if (!sk_MIME_HEADER_push(headers, new_hdr)) |
670 | 0 | goto err; |
671 | 0 | mhdr = new_hdr; |
672 | 0 | new_hdr = NULL; |
673 | 0 | ntmp = NULL; |
674 | 0 | q = p + 1; |
675 | 0 | state = MIME_NAME; |
676 | 0 | } else if (c == '(') { |
677 | 0 | save_state = state; |
678 | 0 | state = MIME_COMMENT; |
679 | 0 | } |
680 | 0 | break; |
681 | 0 |
|
682 | 0 | case MIME_COMMENT: |
683 | 0 | if (c == ')') { |
684 | 0 | state = save_state; |
685 | 0 | } |
686 | 0 | break; |
687 | 0 |
|
688 | 0 | case MIME_NAME: |
689 | 0 | if (c == '=') { |
690 | 0 | state = MIME_VALUE; |
691 | 0 | *p = 0; |
692 | 0 | ntmp = strip_ends(q); |
693 | 0 | q = p + 1; |
694 | 0 | } |
695 | 0 | break; |
696 | 0 |
|
697 | 0 | case MIME_VALUE: |
698 | 0 | if (c == ';') { |
699 | 0 | state = MIME_NAME; |
700 | 0 | *p = 0; |
701 | 0 | mime_hdr_addparam(mhdr, ntmp, strip_ends(q)); |
702 | 0 | ntmp = NULL; |
703 | 0 | q = p + 1; |
704 | 0 | } else if (c == '"') { |
705 | 0 | mime_debug("Found Quote\n"); |
706 | 0 | state = MIME_QUOTE; |
707 | 0 | } else if (c == '(') { |
708 | 0 | save_state = state; |
709 | 0 | state = MIME_COMMENT; |
710 | 0 | } |
711 | 0 | break; |
712 | 0 |
|
713 | 0 | case MIME_QUOTE: |
714 | 0 | if (c == '"') { |
715 | 0 | mime_debug("Found Match Quote\n"); |
716 | 0 | state = MIME_VALUE; |
717 | 0 | } |
718 | 0 | break; |
719 | 0 | } |
720 | 0 | } |
721 | 0 |
|
722 | 0 | if (state == MIME_TYPE) { |
723 | 0 | new_hdr = mime_hdr_new(ntmp, strip_ends(q)); |
724 | 0 | if (new_hdr == NULL) |
725 | 0 | goto err; |
726 | 0 | if (!sk_MIME_HEADER_push(headers, new_hdr)) |
727 | 0 | goto err; |
728 | 0 | mhdr = new_hdr; |
729 | 0 | new_hdr = NULL; |
730 | 0 | } else if (state == MIME_VALUE) |
731 | 0 | mime_hdr_addparam(mhdr, ntmp, strip_ends(q)); |
732 | 0 | if (p == linebuf) |
733 | 0 | break; /* Blank line means end of headers */ |
734 | 0 | } |
735 | 0 |
|
736 | 0 | return headers; |
737 | 0 | |
738 | 0 | err: |
739 | 0 | mime_hdr_free(new_hdr); |
740 | 0 | sk_MIME_HEADER_pop_free(headers, mime_hdr_free); |
741 | 0 | return NULL; |
742 | 0 | } |
743 | | |
744 | | static char *strip_ends(char *name) |
745 | 0 | { |
746 | 0 | return strip_end(strip_start(name)); |
747 | 0 | } |
748 | | |
749 | | /* Strip a parameter of whitespace from start of param */ |
750 | | static char *strip_start(char *name) |
751 | 0 | { |
752 | 0 | char *p, c; |
753 | 0 | /* Look for first non white space or quote */ |
754 | 0 | for (p = name; (c = *p); p++) { |
755 | 0 | if (c == '"') { |
756 | 0 | /* Next char is start of string if non null */ |
757 | 0 | if (p[1]) |
758 | 0 | return p + 1; |
759 | 0 | /* Else null string */ |
760 | 0 | return NULL; |
761 | 0 | } |
762 | 0 | if (!ossl_isspace(c)) |
763 | 0 | return p; |
764 | 0 | } |
765 | 0 | return NULL; |
766 | 0 | } |
767 | | |
768 | | /* As above but strip from end of string : maybe should handle brackets? */ |
769 | | static char *strip_end(char *name) |
770 | 0 | { |
771 | 0 | char *p, c; |
772 | 0 | if (!name) |
773 | 0 | return NULL; |
774 | 0 | /* Look for first non white space or quote */ |
775 | 0 | for (p = name + strlen(name) - 1; p >= name; p--) { |
776 | 0 | c = *p; |
777 | 0 | if (c == '"') { |
778 | 0 | if (p - 1 == name) |
779 | 0 | return NULL; |
780 | 0 | *p = 0; |
781 | 0 | return name; |
782 | 0 | } |
783 | 0 | if (ossl_isspace(c)) |
784 | 0 | *p = 0; |
785 | 0 | else |
786 | 0 | return name; |
787 | 0 | } |
788 | 0 | return NULL; |
789 | 0 | } |
790 | | |
791 | | static MIME_HEADER *mime_hdr_new(const char *name, const char *value) |
792 | 0 | { |
793 | 0 | MIME_HEADER *mhdr = NULL; |
794 | 0 | char *tmpname = NULL, *tmpval = NULL, *p; |
795 | 0 |
|
796 | 0 | if (name) { |
797 | 0 | if ((tmpname = OPENSSL_strdup(name)) == NULL) |
798 | 0 | return NULL; |
799 | 0 | for (p = tmpname; *p; p++) |
800 | 0 | *p = ossl_tolower(*p); |
801 | 0 | } |
802 | 0 | if (value) { |
803 | 0 | if ((tmpval = OPENSSL_strdup(value)) == NULL) |
804 | 0 | goto err; |
805 | 0 | for (p = tmpval; *p; p++) |
806 | 0 | *p = ossl_tolower(*p); |
807 | 0 | } |
808 | 0 | mhdr = OPENSSL_malloc(sizeof(*mhdr)); |
809 | 0 | if (mhdr == NULL) |
810 | 0 | goto err; |
811 | 0 | mhdr->name = tmpname; |
812 | 0 | mhdr->value = tmpval; |
813 | 0 | if ((mhdr->params = sk_MIME_PARAM_new(mime_param_cmp)) == NULL) |
814 | 0 | goto err; |
815 | 0 | return mhdr; |
816 | 0 | |
817 | 0 | err: |
818 | 0 | OPENSSL_free(tmpname); |
819 | 0 | OPENSSL_free(tmpval); |
820 | 0 | OPENSSL_free(mhdr); |
821 | 0 | return NULL; |
822 | 0 | } |
823 | | |
824 | | static int mime_hdr_addparam(MIME_HEADER *mhdr, const char *name, const char *value) |
825 | 0 | { |
826 | 0 | char *tmpname = NULL, *tmpval = NULL, *p; |
827 | 0 | MIME_PARAM *mparam = NULL; |
828 | 0 |
|
829 | 0 | if (name) { |
830 | 0 | tmpname = OPENSSL_strdup(name); |
831 | 0 | if (!tmpname) |
832 | 0 | goto err; |
833 | 0 | for (p = tmpname; *p; p++) |
834 | 0 | *p = ossl_tolower(*p); |
835 | 0 | } |
836 | 0 | if (value) { |
837 | 0 | tmpval = OPENSSL_strdup(value); |
838 | 0 | if (!tmpval) |
839 | 0 | goto err; |
840 | 0 | } |
841 | 0 | /* Parameter values are case sensitive so leave as is */ |
842 | 0 | mparam = OPENSSL_malloc(sizeof(*mparam)); |
843 | 0 | if (mparam == NULL) |
844 | 0 | goto err; |
845 | 0 | mparam->param_name = tmpname; |
846 | 0 | mparam->param_value = tmpval; |
847 | 0 | if (!sk_MIME_PARAM_push(mhdr->params, mparam)) |
848 | 0 | goto err; |
849 | 0 | return 1; |
850 | 0 | err: |
851 | 0 | OPENSSL_free(tmpname); |
852 | 0 | OPENSSL_free(tmpval); |
853 | 0 | OPENSSL_free(mparam); |
854 | 0 | return 0; |
855 | 0 | } |
856 | | |
857 | | static int mime_hdr_cmp(const MIME_HEADER *const *a, |
858 | | const MIME_HEADER *const *b) |
859 | 0 | { |
860 | 0 | if (!(*a)->name || !(*b)->name) |
861 | 0 | return ! !(*a)->name - ! !(*b)->name; |
862 | 0 | |
863 | 0 | return strcmp((*a)->name, (*b)->name); |
864 | 0 | } |
865 | | |
866 | | static int mime_param_cmp(const MIME_PARAM *const *a, |
867 | | const MIME_PARAM *const *b) |
868 | 0 | { |
869 | 0 | if (!(*a)->param_name || !(*b)->param_name) |
870 | 0 | return ! !(*a)->param_name - ! !(*b)->param_name; |
871 | 0 | return strcmp((*a)->param_name, (*b)->param_name); |
872 | 0 | } |
873 | | |
874 | | /* Find a header with a given name (if possible) */ |
875 | | |
876 | | static MIME_HEADER *mime_hdr_find(STACK_OF(MIME_HEADER) *hdrs, const char *name) |
877 | 0 | { |
878 | 0 | MIME_HEADER htmp; |
879 | 0 | int idx; |
880 | 0 |
|
881 | 0 | htmp.name = (char *)name; |
882 | 0 | htmp.value = NULL; |
883 | 0 | htmp.params = NULL; |
884 | 0 |
|
885 | 0 | idx = sk_MIME_HEADER_find(hdrs, &htmp); |
886 | 0 | return sk_MIME_HEADER_value(hdrs, idx); |
887 | 0 | } |
888 | | |
889 | | static MIME_PARAM *mime_param_find(MIME_HEADER *hdr, const char *name) |
890 | 0 | { |
891 | 0 | MIME_PARAM param; |
892 | 0 | int idx; |
893 | 0 |
|
894 | 0 | param.param_name = (char *)name; |
895 | 0 | param.param_value = NULL; |
896 | 0 | idx = sk_MIME_PARAM_find(hdr->params, ¶m); |
897 | 0 | return sk_MIME_PARAM_value(hdr->params, idx); |
898 | 0 | } |
899 | | |
900 | | static void mime_hdr_free(MIME_HEADER *hdr) |
901 | 0 | { |
902 | 0 | if (hdr == NULL) |
903 | 0 | return; |
904 | 0 | OPENSSL_free(hdr->name); |
905 | 0 | OPENSSL_free(hdr->value); |
906 | 0 | if (hdr->params) |
907 | 0 | sk_MIME_PARAM_pop_free(hdr->params, mime_param_free); |
908 | 0 | OPENSSL_free(hdr); |
909 | 0 | } |
910 | | |
911 | | static void mime_param_free(MIME_PARAM *param) |
912 | 0 | { |
913 | 0 | OPENSSL_free(param->param_name); |
914 | 0 | OPENSSL_free(param->param_value); |
915 | 0 | OPENSSL_free(param); |
916 | 0 | } |
917 | | |
918 | | /*- |
919 | | * Check for a multipart boundary. Returns: |
920 | | * 0 : no boundary |
921 | | * 1 : part boundary |
922 | | * 2 : final boundary |
923 | | */ |
924 | | static int mime_bound_check(char *line, int linelen, const char *bound, int blen) |
925 | | { |
926 | | if (linelen == -1) |
927 | | linelen = strlen(line); |
928 | | if (blen == -1) |
929 | | blen = strlen(bound); |
930 | | /* Quickly eliminate if line length too short */ |
931 | | if (blen + 2 > linelen) |
932 | | return 0; |
933 | | /* Check for part boundary */ |
934 | | if ((strncmp(line, "--", 2) == 0) |
935 | | && strncmp(line + 2, bound, blen) == 0) { |
936 | | if (strncmp(line + blen + 2, "--", 2) == 0) |
937 | | return 2; |
938 | | else |
939 | | return 1; |
940 | | } |
941 | | return 0; |
942 | | } |
943 | | |
944 | | static int strip_eol(char *linebuf, int *plen, int flags) |
945 | 0 | { |
946 | 0 | int len = *plen; |
947 | 0 | char *p, c; |
948 | 0 | int is_eol = 0; |
949 | 0 |
|
950 | 0 | for (p = linebuf + len - 1; len > 0; len--, p--) { |
951 | 0 | c = *p; |
952 | 0 | if (c == '\n') { |
953 | 0 | is_eol = 1; |
954 | 0 | } else if (is_eol && flags & SMIME_ASCIICRLF && c == 32) { |
955 | 0 | /* Strip trailing space on a line; 32 == ASCII for ' ' */ |
956 | 0 | continue; |
957 | 0 | } else if (c != '\r') { |
958 | 0 | break; |
959 | 0 | } |
960 | 0 | } |
961 | 0 | *plen = len; |
962 | 0 | return is_eol; |
963 | 0 | } |