Home | History | Annotate | Line # | Download | only in mail
mime_decode.c revision 1.3
      1 /*	$NetBSD: mime_decode.c,v 1.3 2006/11/01 16:42:27 christos Exp $	*/
      2 
      3 /*-
      4  * Copyright (c) 2006 The NetBSD Foundation, Inc.
      5  * All rights reserved.
      6  *
      7  * This code is derived from software contributed to The NetBSD Foundation
      8  * by Anon Ymous.
      9  *
     10  * Redistribution and use in source and binary forms, with or without
     11  * modification, are permitted provided that the following conditions
     12  * are met:
     13  * 1. Redistributions of source code must retain the above copyright
     14  *    notice, this list of conditions and the following disclaimer.
     15  * 2. Redistributions in binary form must reproduce the above copyright
     16  *    notice, this list of conditions and the following disclaimer in the
     17  *    documentation and/or other materials provided with the distribution.
     18  * 3. All advertising materials mentioning features or use of this software
     19  *    must display the following acknowledgement:
     20  *        This product includes software developed by the NetBSD
     21  *        Foundation, Inc. and its contributors.
     22  * 4. Neither the name of The NetBSD Foundation nor the names of its
     23  *    contributors may be used to endorse or promote products derived
     24  *    from this software without specific prior written permission.
     25  *
     26  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     27  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     28  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     29  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     30  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     31  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     32  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     33  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     34  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     35  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     36  * POSSIBILITY OF SUCH DAMAGE.
     37  */
     38 
     39 
     40 #ifdef MIME_SUPPORT
     41 
     42 #include <sys/cdefs.h>
     43 #ifndef __lint__
     44 __RCSID("$NetBSD: mime_decode.c,v 1.3 2006/11/01 16:42:27 christos Exp $");
     45 #endif /* not __lint__ */
     46 
     47 #include <assert.h>
     48 #include <err.h>
     49 #include <fcntl.h>
     50 #include <libgen.h>
     51 #include <setjmp.h>
     52 #include <signal.h>
     53 #include <stdio.h>
     54 #include <stdlib.h>
     55 #include <string.h>
     56 #include <unistd.h>
     57 #include <iconv.h>
     58 
     59 #include "def.h"
     60 #include "extern.h"
     61 #ifdef USE_EDITLINE
     62 #include "complete.h"
     63 #endif
     64 #ifdef MIME_SUPPORT
     65 #include "mime.h"
     66 #include "mime_child.h"
     67 #include "mime_codecs.h"
     68 #include "mime_header.h"
     69 #endif
     70 #include "glob.h"
     71 
     72 
     73 /************************************************
     74  * The fundametal data structure for this module!
     75  */
     76 struct mime_info {
     77 	struct mime_info *mi_blink;
     78 	struct mime_info *mi_flink;
     79 
     80 	/* sendmessage -> decoder -> filter -> pager */
     81 
     82 	FILE *mi_fo;		/* output file handle pointing to PAGER */
     83 	FILE *mi_pipe_end;	/* initial end of pipe */
     84 	FILE *mi_head_end;	/* close to here at start of body */
     85 
     86 	int mi_partnum;		/* part number displayed (if nonzero) */
     87 
     88 	const char *mi_version;
     89 	const char *mi_type;
     90 	const char *mi_subtype;
     91 	const char *mi_boundary;
     92 	const char *mi_charset;
     93 	const char *mi_encoding;
     94 
     95 	struct message *mp;		/* MP for this message regarded as a part. */
     96 	struct {
     97 		struct mime_info *mip;	/* parent of part of multipart message */
     98 		struct message *mp;
     99 	} mi_parent;
    100 
    101 	const char *mi_command_hook;	/* alternate command used to process this message */
    102 };
    103 
    104 
    105 #if 0
    106 #ifndef __lint__
    107 /*
    108  * XXX - This block for debugging only and eventually should go away.
    109  */
    110 static void
    111 show_one_mime_info(FILE *fp, struct mime_info *mip)
    112 {
    113 #define XX(a) (a) ? (a) : "<null>"
    114 
    115 	(void)fprintf(fp, ">> --------\n");
    116 	(void)fprintf(fp, "mip %d:\n", mip->mi_partnum);
    117 	(void)fprintf(fp, "** Version: %s\n",  XX(mip->mi_version));
    118 	(void)fprintf(fp, "** type: %s\n",     XX(mip->mi_type));
    119 	(void)fprintf(fp, "** subtype: %s\n",  XX(mip->mi_subtype));
    120 	(void)fprintf(fp, "** charset: %s\n",  XX(mip->mi_charset));
    121 	(void)fprintf(fp, "** encoding: %s\n", XX(mip->mi_encoding));
    122 	(void)fprintf(fp, "** boundary: %s\n", XX(mip->mi_boundary));
    123 	(void)fprintf(fp, "** %p: flag: 0x%x, block: %ld, offset: %d, size: %lld, lines: %ld:%ld\n",
    124 	    mip->mp,
    125 	    mip->mp->m_flag,
    126 	    mip->mp->m_block, mip->mp->m_offset, mip->mp->m_size,
    127 	    mip->mp->m_lines, mip->mp->m_blines);
    128 	(void)fprintf(fp, "** mip: %p\n", mip);
    129 	(void)fprintf(fp, "** mi_flink: %p\n", mip->mi_flink);
    130 	(void)fprintf(fp, "** mi_blink: %p\n", mip->mi_blink);
    131 	(void)fprintf(fp, "** mip %p, mp %p,  parent_mip %p, parent_mp %p\n",
    132 	    mip, mip->mp, mip->mi_parent.mip, mip->mi_parent.mp);
    133 
    134 	(void)fprintf(fp, "** mi_fo %p, mi_head_end %p, mi_pipe_end %p\n",
    135 	    mip->mi_fo, mip->mi_head_end, mip->mi_pipe_end);
    136 
    137 	(void)fprintf(fp, "** mi_partnum: %d\n", mip->mi_partnum);
    138 
    139 	(void)fflush(fp);
    140 
    141 #undef XX
    142 }
    143 
    144 __unused
    145 static void
    146 show_mime_info(FILE *fp, struct mime_info *mip, struct mime_info *end_mip)
    147 {
    148 	for (/* EMTPY */; mip != end_mip; mip = mip->mi_flink)
    149 		show_one_mime_info(fp, mip);
    150 
    151 	(void)fprintf(fp, "++ =========\n");
    152 	(void)fflush(fp);
    153 }
    154 #endif /* __lint__ */
    155 #endif /* #if */
    156 
    157 
    158 /*
    159  * Our interface to the file registry in popen.c
    160  */
    161 static FILE *
    162 pipe_end(struct mime_info *mip)
    163 {
    164 	FILE *fp;
    165 	fp = last_registered_file(1);	/* get last registered pipe */
    166 	if (fp == NULL)
    167 		fp = mip->mi_fo;
    168 	return fp;
    169 }
    170 
    171 /*
    172  * Copy the first ';' delimited substring from 'src' (null terminated)
    173  * into 'dst', expanding quotes and removing comments (as per RFC
    174  * 822).  Returns a pointer in src to the next non-white character
    175  * following ';'.  The caller is responsible for ensuring 'dst' is
    176  * sufficiently large to hold the result.
    177  */
    178 static char *
    179 get_param(char *dst, char *src)
    180 {
    181 	char *lastq;
    182 	char *cp;
    183 	char *cp2;
    184 	int nesting;
    185 
    186 	cp2 = dst;
    187 	lastq = dst;
    188 	for (cp = src; *cp && *cp != ';'; cp++) {
    189 		switch (*cp) {
    190 		case '"':	/* start of quoted string */
    191 			for (cp++; *cp; cp++) {
    192 				if (*cp == '"')
    193 					break;
    194 				if (*cp == '\\' && cp[1] != '\0')
    195 					++cp;
    196 				*cp2++ = *cp;
    197 			}
    198 			lastq = cp2-1;
    199 			break;
    200 		case '(':	/* start of comment */
    201 			nesting = 1;
    202 			while (nesting > 0 && *++cp) {
    203 				if (*cp == '\\' && cp[1] != '\0')
    204 					cp++;
    205 				if (*cp == '(')
    206 					nesting++;
    207 				if (*cp == ')')
    208 					nesting--;
    209 			}
    210 			break;
    211 		default:
    212 			*cp2++ = *cp;
    213 			break;
    214 		}
    215 	}
    216 	/* remove trailing white space */
    217 	while (cp2 > lastq && isblank((unsigned char)cp2[-1]))
    218 		cp2--;
    219 	*cp2 = '\0';
    220 	if (*cp == ';')
    221 		cp++;
    222 	cp = skip_white(cp);
    223 	return cp;
    224 }
    225 
    226 /*
    227  * Content parameter
    228  *    if field is NULL, return the content "specifier".
    229  */
    230 static char*
    231 cparam(const char field[], char *src, int downcase)
    232 {
    233 	char *cp;
    234 	char *dst;
    235 
    236 	if (src == NULL)
    237 		return NULL;
    238 
    239 	dst = salloc(strlen(src) + 1); /* large enough for any param in src */
    240 	cp = skip_white(src);
    241 	cp = get_param(dst, cp);
    242 
    243 	if (field == NULL)
    244 		return dst;
    245 
    246 	while (*cp != '\0') {
    247 		size_t len = strlen(field);
    248 		cp = get_param(dst, cp);
    249 		if (strncasecmp(dst, field, len) == 0 && dst[len] == '=') {
    250 			char *cp2;
    251 			cp2 = dst + len + 1;
    252 			if (downcase)
    253 				istrcpy(cp2, cp2);
    254 			return cp2;
    255 		}
    256 	}
    257 	return NULL;
    258 }
    259 
    260 
    261 static void
    262 get_content(struct mime_info *mip)
    263 {
    264 	char *mime_type_field;
    265 	struct message *mp;
    266 	char *cp;
    267 
    268 	mp = mip->mp;
    269 	mip->mi_version  = cparam(NULL, hfield(MIME_HDR_VERSION, mp), 0);
    270 	mip->mi_encoding = cparam(NULL, hfield(MIME_HDR_ENCODING, mp), 1);
    271 
    272 	mime_type_field = hfield(MIME_HDR_TYPE, mp);
    273 	mip->mi_type = cparam(NULL, mime_type_field, 1);
    274 	if (mip->mi_type) {
    275 		cp = strchr(mip->mi_type, '/');
    276 		if (cp)
    277 			*cp++ = '\0';
    278 		mip->mi_subtype = cp;
    279 	}
    280 	mip->mi_charset = cparam("charset", mime_type_field, 1);
    281 	mip->mi_boundary = cparam("boundary", mime_type_field, 0);
    282 }
    283 
    284 
    285 static struct message *
    286 salloc_message(int flag, long block, short offset)
    287 {
    288 	struct message *mp;
    289 	/* use csalloc in case someone adds a field someday! */
    290 	mp = csalloc(1, sizeof(*mp));
    291 	mp->m_flag   = flag;
    292 	mp->m_block  = block;
    293 	mp->m_offset = offset;
    294 #if 0
    295 	mp->m_lines  = 0;
    296 	mp->m_size   = 0;
    297 	mp->m_blines = 0;
    298 #endif
    299 	return mp;
    300 }
    301 
    302 static struct mime_info *
    303 insert_new_mip(struct mime_info *this_mip)
    304 {
    305 	struct mime_info *new_mip;
    306 	new_mip = csalloc(1, sizeof(*new_mip));
    307 	new_mip->mi_blink = this_mip;
    308 	new_mip->mi_flink = this_mip->mi_flink;
    309 	this_mip->mi_flink = new_mip;
    310 	this_mip = new_mip;
    311 	return new_mip;
    312 }
    313 
    314 static void
    315 split_multipart(struct mime_info *top_mip)
    316 {
    317 	FILE *fp;
    318 	struct message *top_mp;
    319 	struct message *this_mp;
    320 	struct mime_info *this_mip;
    321 	off_t beg_pos;
    322 	const char *boundary;
    323 	size_t boundary_len;
    324 	long lines_left;	/* must be signed and same size as m_lines */
    325 	int partnum;
    326 	int in_header;
    327 
    328 	top_mp = top_mip->mp;
    329 	this_mp = salloc_message(top_mp->m_flag, top_mp->m_block, top_mp->m_offset);
    330 	this_mip = top_mip;
    331 	this_mip->mp = this_mp;
    332 
    333 	partnum = 1;
    334 /*	top_mip->mi_partnum = partnum++;  */ /* Keep the number set by the caller */
    335 	in_header = 1;
    336 	boundary = top_mip->mi_boundary;
    337 	boundary_len = boundary ? strlen(boundary) : 0;
    338 
    339 	fp = setinput(top_mp);
    340 	beg_pos = ftello(fp);
    341 
    342 	for (lines_left = top_mp->m_lines - 1; lines_left >= 0; lines_left--) {
    343 		char *line;
    344 		size_t line_len;
    345 
    346 		line = fgetln(fp, &line_len);
    347 
    348 		this_mp->m_lines++;		/* count the message lines */
    349 
    350 		if (!in_header)
    351 			this_mp->m_blines++;	/* count the body lines */
    352 
    353 		if (lines_left == 0 || (
    354 			    !in_header &&
    355 			    line_len >= boundary_len + 2 &&
    356 			    line[0] == '-' && line[1] == '-' &&
    357 			    strncmp(line + 2, boundary, boundary_len) == 0)) {
    358 			off_t cur_pos;
    359 			off_t end_pos;
    360 
    361 			cur_pos = ftello(fp);
    362 
    363 			/* the boundary belongs to the next part */
    364 			end_pos = cur_pos - line_len;
    365 			this_mp->m_lines  -= 1;
    366 			this_mp->m_blines -= 1;
    367 
    368 			this_mp->m_size = end_pos - beg_pos;
    369 
    370 			if (line[boundary_len + 2] == '-' &&
    371 			    line[boundary_len + 3] == '-') {/* end of multipart */
    372 				/* do a sanity check on the EOM */
    373 				if (lines_left) {
    374 					/*
    375 					 * XXX - this can happen!
    376 					 * Should we display the
    377 					 * trailing garbage or check
    378 					 * that it is blank or just
    379 					 * ignore it?
    380 					 */
    381 /*					(void)printf("EOM: lines left: %ld\n", lines_left); */
    382 				}
    383 				break;	/* XXX - stop at this point or grab the rest? */
    384 			}
    385 
    386 			this_mip = insert_new_mip(this_mip);
    387 			this_mp = salloc_message(top_mp->m_flag,
    388 			    (long)blockof(end_pos), offsetof(end_pos));
    389 			this_mip->mp = this_mp;
    390 			this_mip->mi_parent.mip = top_mip;
    391 			this_mip->mi_parent.mp = top_mp;
    392 			this_mip->mi_partnum = partnum++;
    393 
    394 			beg_pos = end_pos;
    395 			in_header = 1;
    396 		}
    397 
    398 		if (line_len == 1)
    399 			in_header = 0;
    400 	}
    401 }
    402 
    403 static void
    404 split_message(struct mime_info *top_mip)
    405 {
    406 	struct mime_info *this_mip;
    407 	struct message *top_mp;
    408 	struct message *this_mp;
    409 	FILE *fp;
    410 	off_t beg_pos;
    411 	long lines_left;	/* must be same size as m_lines */
    412 	int in_header;
    413 
    414 	top_mp = top_mip->mp;
    415 	this_mp = salloc_message(top_mp->m_flag, top_mp->m_block, top_mp->m_offset);
    416 	this_mip = top_mip;
    417 	this_mip->mp = this_mp;
    418 
    419 	in_header = 1;
    420 
    421 	fp = setinput(top_mp);
    422 	beg_pos = ftello(fp);
    423 
    424 	for (lines_left = top_mp->m_lines; lines_left > 0; lines_left--) {
    425 		size_t line_len;
    426 
    427 		(void)fgetln(fp, &line_len);
    428 
    429 		this_mp->m_lines++;		/* count the message lines */
    430 		if (!in_header)
    431 			this_mp->m_blines++;	/* count the body lines */
    432 
    433 		if (in_header && line_len == 1) { /* end of header */
    434 			off_t end_pos;
    435 			end_pos = ftello(fp);
    436 			this_mp->m_size = end_pos - beg_pos;
    437 
    438 			this_mip = insert_new_mip(this_mip);
    439 			this_mp = salloc_message(top_mp->m_flag,
    440 			    (long)blockof(end_pos), offsetof(end_pos));
    441 			this_mip->mp = this_mp;
    442 			this_mip->mi_parent.mip = top_mip;
    443 			this_mip->mi_parent.mp = top_mp;
    444 			this_mip->mi_partnum = 0;  /* no partnum displayed */
    445 
    446 			beg_pos = end_pos;
    447 			in_header = 0;	/* never in header again */
    448 		}
    449 	}
    450 
    451 	/* close the last message */
    452 	this_mp->m_size = ftello(fp) - beg_pos;
    453 }
    454 
    455 
    456 static const char *
    457 get_command_hook(struct mime_info *mip, const char *domain)
    458 {
    459 	char *key;
    460 	char *cmd;
    461 
    462 	if (mip->mi_type == NULL)
    463 		return NULL;
    464 
    465 	/* XXX - should we use easprintf() here?  We are probably
    466 	 * hosed elsewhere if this fails anyway. */
    467 
    468 	cmd = NULL;
    469 	if (mip->mi_subtype) {
    470 		if (asprintf(&key, "mime%s-%s-%s",
    471 			domain,	mip->mi_type, mip->mi_subtype) == -1) {
    472 			warn("get_command_hook: subtupe: asprintf");
    473 			return NULL;
    474 		}
    475 		cmd = value(key);
    476 		free(key);
    477 	}
    478 	if (cmd == NULL) {
    479 		if (asprintf(&key, "mime%s-%s", domain, mip->mi_type) == -1) {
    480 			warn("get_command_hook: type: asprintf");
    481 			return NULL;
    482 		}
    483 		cmd = value(key);
    484 		free(key);
    485 	}
    486 	return cmd;
    487 }
    488 
    489 
    490 static int
    491 is_basic_alternative(struct mime_info *mip)
    492 {
    493 	return
    494 	    strcasecmp(mip->mi_type, "text") == 0 &&
    495 	    strcasecmp(mip->mi_subtype, "plain") == 0;
    496 }
    497 
    498 static struct mime_info *
    499 select_alternative(struct mime_info *top_mip, struct mime_info *end_mip)
    500 {
    501 	struct mime_info *the_mip;	/* the chosen alternate */
    502 	struct mime_info *this_mip;
    503 	/*
    504 	 * The alternates are supposed to occur in order of
    505 	 * increasing "complexity".  So: if there is at least
    506 	 * one alternate of type "text/plain", use the last
    507 	 * one, otherwise default to the first alternate.
    508 	 */
    509 	the_mip = top_mip->mi_flink;
    510 	for (this_mip = top_mip->mi_flink;
    511 	     this_mip != end_mip;
    512 	     this_mip = this_mip->mi_flink) {
    513 		const char *cmd;
    514 
    515 		if (this_mip->mi_type == NULL ||
    516 		    this_mip->mi_subtype == NULL)
    517 			continue;
    518 
    519 		if (is_basic_alternative(this_mip))
    520 			the_mip = this_mip;
    521 		else if (
    522 			(cmd = get_command_hook(this_mip, "-hook")) ||
    523 			(cmd = get_command_hook(this_mip, "-head")) ||
    524 			(cmd = get_command_hook(this_mip, "-body"))) {
    525 			int flags;
    526 			/* just get the flags. */
    527 			flags = mime_run_command(cmd, NULL);
    528 			if ((flags & CMD_FLAG_ALTERNATIVE) != 0)
    529 				the_mip = this_mip;
    530 		}
    531 	}
    532 	return the_mip;
    533 }
    534 
    535 
    536 static inline int
    537 is_multipart(struct mime_info *mip)
    538 {
    539 	return mip->mi_type &&
    540 	    strcasecmp("multipart", mip->mi_type) == 0;
    541 }
    542 static inline int
    543 is_message(struct mime_info *mip)
    544 {
    545 	return mip->mi_type &&
    546 	    strcasecmp("message", mip->mi_type) == 0;
    547 }
    548 
    549 static inline int
    550 is_alternative(struct mime_info *mip)
    551 {
    552 	return mip->mi_subtype &&
    553 	    strcasecmp("alternative", mip->mi_subtype) == 0;
    554 }
    555 
    556 
    557 /*
    558  * Take a mime_info pointer and expand it recursively into all its
    559  * mime parts.  Only "multipart" and "message" types recursed into;
    560  * they are handled separately.
    561  */
    562 static struct mime_info *
    563 expand_mip(struct mime_info *top_mip)
    564 {
    565 	struct mime_info *this_mip;
    566 	struct mime_info *next_mip;
    567 
    568 	next_mip = top_mip->mi_flink;
    569 
    570 	if (is_multipart(top_mip)) {
    571 		split_multipart(top_mip);
    572 
    573 		for (this_mip = top_mip->mi_flink;
    574 		     this_mip != next_mip;
    575 		     this_mip = this_mip->mi_flink) {
    576 			get_content(this_mip);
    577 		}
    578 		if (is_alternative(top_mip)) {
    579 			this_mip = select_alternative(top_mip, next_mip);
    580 			this_mip->mi_partnum = 0; /* suppress partnum display */
    581 			this_mip->mi_flink = next_mip;
    582 			this_mip->mi_blink = top_mip;
    583 			top_mip->mi_flink  = this_mip;
    584 		}
    585 		/*
    586 		 * Recurse into each part.
    587 		 */
    588 		for (this_mip = top_mip->mi_flink;
    589 		     this_mip != next_mip;
    590 		     this_mip = expand_mip(this_mip))
    591 			continue;
    592 	}
    593 	else if (is_message(top_mip)) {
    594 		split_message(top_mip);
    595 
    596 		this_mip = top_mip->mi_flink;
    597 		if (this_mip) {
    598 			get_content(this_mip);
    599 			/*
    600 			 * If the one part is MIME encoded, recurse into it.
    601 			 * XXX - Should this be conditional on subtype "rcs822"?
    602 			 */
    603 			if (this_mip->mi_type &&
    604 			    this_mip->mi_version &&
    605 			    equal(this_mip->mi_version, MIME_VERSION)) {
    606 				this_mip->mi_partnum = 0;
    607 				(void)expand_mip(this_mip);
    608 			}
    609 		}
    610 	}
    611 
    612 	return next_mip;
    613 }
    614 
    615 
    616 static int
    617 show_partnum(FILE *fp, struct mime_info *mip)
    618 {
    619 	int need_dot;
    620 	need_dot = 0;
    621 	if (mip->mi_parent.mip && mip->mi_parent.mip->mi_parent.mip)
    622 		need_dot = show_partnum(fp, mip->mi_parent.mip);
    623 
    624 	if (mip->mi_partnum) {
    625 		(void)fprintf(fp, "%s%d", need_dot ? "." : "",  mip->mi_partnum);
    626 		need_dot = 1;
    627 	}
    628 	return need_dot;
    629 }
    630 
    631 
    632 PUBLIC struct mime_info *
    633 mime_decode_open(struct message *mp)
    634 {
    635 	struct mime_info *mip;
    636 
    637 	mip = csalloc(1, sizeof(*mip));
    638 	mip->mp = salloc(sizeof(*mip->mp));
    639 	*mip->mp = *mp;		/* copy this so we can change its m_lines */
    640 
    641 	get_content(mip);
    642 
    643 	/* RFC 2049 - sec 2 item 1 */
    644 	if (mip->mi_version == NULL ||
    645 	    !equal(mip->mi_version, MIME_VERSION))
    646 		return NULL;
    647 
    648 	if (mip->mi_type)
    649 		(void)expand_mip(mip);
    650 
    651 /*	show_mime_info(stderr, mip, NULL); */
    652 
    653 	return mip;
    654 }
    655 
    656 
    657 PUBLIC void
    658 mime_decode_close(struct mime_info *mip)
    659 {
    660 	if (mip)
    661 		close_top_files(mip->mi_pipe_end);
    662 }
    663 
    664 
    665 struct prefix_line_args_s {
    666 	const char *prefix;
    667 	size_t prefixlen;
    668 };
    669 
    670 static void
    671 prefix_line(FILE *fi, FILE *fo, void *cookie)
    672 {
    673 	struct prefix_line_args_s *args;
    674 	const char *line;
    675 	const char *prefix;
    676 	size_t prefixlen;
    677 	size_t length;
    678 
    679 	args = cookie;
    680 	prefix    = args->prefix;
    681 	prefixlen = args->prefixlen;
    682 
    683 	while ((line = fgetln(fi, &length)) != NULL) {
    684 		if (length > 1)
    685 			(void)fputs(prefix, fo);
    686 		else
    687 			(void)fwrite(prefix, sizeof *prefix,
    688 			    prefixlen, fo);
    689 		(void)fwrite(line, sizeof(*line), length, fo);
    690 	}
    691 	(void)fflush(fo);
    692 }
    693 
    694 PUBLIC int
    695 mime_sendmessage(struct message *mp, FILE *obuf, struct ignoretab *doign,
    696     const char *prefix, struct mime_info *mip)
    697 {
    698 	int error;
    699 	FILE *end_of_pipe;
    700 	FILE *end_of_prefix;
    701 
    702 	if (mip == NULL)
    703 		return sendmessage(mp, obuf, doign ? ignore : 0, prefix, NULL);
    704 
    705 	/*
    706 	 * Set these early so pipe_end() and mime_decode_close() work!
    707 	 * XXX - Do this before anything that can block, like
    708 	 *       fflush()!  Shouldn't we move these settings to
    709 	 *       mime_decode_open() to avoid a race condition?
    710 	 *       Especially, mip->mi_pipe_end?
    711 	 */
    712 	mip->mi_fo = obuf;
    713 	mip->mi_pipe_end = last_registered_file(0);
    714 
    715 	(void)fflush(obuf);  /* Be safe and flush!  XXX - necessary? */
    716 
    717 	/*
    718 	 * Handle the prefix as a pipe stage so it doesn't get seen by
    719 	 * any decoding or hooks.
    720 	 */
    721 	if (prefix != NULL) {
    722 		static struct prefix_line_args_s prefix_line_args;
    723 		const char *dp, *dp2 = NULL;
    724 		for (dp = prefix; *dp; dp++)
    725 			if (*dp != ' ' && *dp != '\t')
    726 				dp2 = dp;
    727 		prefix_line_args.prefixlen = dp2 == 0 ? 0 : dp2 - prefix + 1;
    728 		prefix_line_args.prefix = prefix;
    729 		mime_run_function(prefix_line, pipe_end(mip), (void*)&prefix_line_args);
    730 	}
    731 
    732 	end_of_pipe   = mip->mi_pipe_end;
    733 	end_of_prefix = last_registered_file(0);
    734 	error = 0;
    735 	for (/* EMPTY */; mip; mip = mip->mi_flink) {
    736 		mip->mi_fo = obuf;
    737 		mip->mi_pipe_end = end_of_pipe;
    738 		error |= sendmessage(mip->mp, pipe_end(mip), doign ? ignore : 0, NULL, mip);
    739 		close_top_files(end_of_prefix);	/* don't close the prefixer! */
    740 	}
    741 	return error;
    742 }
    743 
    744 
    745 #ifdef CHARSET_SUPPORT
    746 /**********************************************
    747  * higher level interface to run mime_ficonv().
    748  *
    749  */
    750 static void
    751 run_mime_ficonv(struct mime_info *mip, const char *charset)
    752 {
    753 	FILE *fo;
    754 	iconv_t cd;
    755 
    756 	fo = pipe_end(mip);
    757 
    758 	if (charset == NULL ||
    759 	    mip->mi_charset == NULL ||
    760 	    strcasecmp(mip->mi_charset, charset) == 0 ||
    761 	    strcasecmp(mip->mi_charset, "unknown") == 0)
    762 		return;
    763 
    764 	cd = iconv_open(charset, mip->mi_charset);
    765 	if (cd == (iconv_t)-1) {
    766 		(void)fprintf(fo, "\t [ iconv_open failed: %s ]\n\n",
    767 		    strerror(errno));
    768 		(void)fflush(fo);	/* flush here or see double! */
    769 		return;
    770 	}
    771 
    772 	if (value(ENAME_MIME_CHARSET_VERBOSE))
    773 		(void)fprintf(fo, "\t[ converting %s -> %s ]\n\n", mip->mi_charset, charset);
    774 
    775 	mime_run_function(mime_ficonv, fo, cd);
    776 
    777 	iconv_close(cd);
    778 }
    779 #endif /* CHARSET_SUPPORT */
    780 
    781 
    782 static void
    783 run_decoder(struct mime_info *mip, void(*fn)(FILE*, FILE*, void *))
    784 {
    785 #ifdef CHARSET_SUPPORT
    786 	char *charset;
    787 
    788 	charset = value(ENAME_MIME_CHARSET);
    789 	if (charset && mip->mi_type && strcasecmp(mip->mi_type, "text") == 0)
    790 		run_mime_ficonv(mip, charset);
    791 #endif /* CHARSET_SUPPORT */
    792 
    793 	if (fn == mime_fio_copy)/* XXX - avoid an extra unnecessary pipe stage */
    794 		return;
    795 
    796 	mime_run_function(fn, pipe_end(mip), (void*)1);
    797 }
    798 
    799 
    800 /*
    801  * Determine how to handle the display based on the type and subtype
    802  * fields.
    803  */
    804 enum dispmode_e {
    805 	DM_IGNORE	= 0x00,	/* silently ignore part - must be zero! */
    806 	DM_DISPLAY,		/* decode and display the part */
    807 	DM_UNKNOWN,		/* unknown display */
    808 	DM_BINARY,		/* indicate binary data */
    809 	DM_PGPSIGN,		/* OpenPGP signed part */
    810 	DM_PGPENCR,		/* OpenPGP encrypted part */
    811 	DM_PGPKEYS		/* OpenPGP keys part */
    812 };
    813 #define APPLICATION_OCTET_STREAM	DM_BINARY
    814 
    815 static enum dispmode_e
    816 get_display_mode(struct mime_info *mip, mime_codec_t dec)
    817 {
    818 	struct mime_subtype_s {
    819 		const char *st_name;
    820 		enum dispmode_e st_dispmode;
    821 	};
    822 	struct mime_type_s {
    823 		const char *mt_type;
    824 		const struct mime_subtype_s *mt_subtype;
    825 		enum dispmode_e mt_dispmode;	/* default if NULL subtype */
    826 	};
    827 	static const struct mime_subtype_s text_subtype_tbl[] = {
    828 		{ "plain",		DM_DISPLAY },
    829 		{ "html", 		DM_DISPLAY },	/* rfc2854 */
    830 		{ "rfc822-headers",	DM_DISPLAY },
    831 		{ "css",		DM_DISPLAY },	/* rfc2318 */
    832 		{ "enriched",		DM_DISPLAY },	/* rfc1523/rfc1563/rfc1896 */
    833 		{ "graphics",		DM_DISPLAY },	/* rfc0553 */
    834 		{ "nroff",		DM_DISPLAY },	/* rfc4263 */
    835 		{ "red",		DM_DISPLAY },	/* rfc4102 */
    836 		{ NULL,			DM_DISPLAY }	/* default */
    837 	};
    838 	static const struct mime_subtype_s image_subtype_tbl[] = {
    839 		{ "tiff",		DM_BINARY },	/* rfc2302/rfc3302 */
    840 		{ "tiff-fx",		DM_BINARY },	/* rfc3250/rfc3950 */
    841 		{ "t38",		DM_BINARY },	/* rfc3362 */
    842 		{ NULL,			DM_BINARY }	/* default */
    843 	};
    844 	static const struct mime_subtype_s audio_subtype_tbl[] = {
    845 		{ "mpeg",		DM_BINARY },	/* rfc3003 */
    846 		{ "t38",		DM_BINARY },	/* rfc4612 */
    847 		{ NULL,			DM_BINARY }	/* default */
    848 	};
    849 	static const struct mime_subtype_s video_subtype_tbl[] = {
    850 		{ NULL,			DM_BINARY }	/* default */
    851 	};
    852 	static const struct mime_subtype_s application_subtype_tbl[] = {
    853 		{ "octet-stream",	APPLICATION_OCTET_STREAM },
    854                 { "pgp-encrypted",      DM_PGPENCR },   /* rfc3156 */
    855 		{ "pgp-keys",           DM_PGPKEYS },   /* rfc3156 */
    856 		{ "pgp-signature",      DM_PGPSIGN },   /* rfc3156 */
    857 		{ "pdf",		DM_BINARY },	/* rfc3778 */
    858 		{ "whoispp-query",	DM_UNKNOWN },	/* rfc2957 */
    859 		{ "whoispp-response",	DM_UNKNOWN },	/* rfc2958 */
    860 		{ "font-tdpfr",		DM_UNKNOWN },	/* rfc3073 */
    861 		{ "xhtml+xml",		DM_UNKNOWN },	/* rfc3236 */
    862 		{ "ogg",		DM_UNKNOWN },	/* rfc3534 */
    863 		{ "rdf+xml",		DM_UNKNOWN },	/* rfc3870 */
    864 		{ "soap+xml",		DM_UNKNOWN },	/* rfc3902 */
    865 		{ "mbox",		DM_UNKNOWN },	/* rfc4155 */
    866 		{ "xv+xml",		DM_UNKNOWN },	/* rfc4374 */
    867 		{ "smil",		DM_UNKNOWN },	/* rfc4536 */
    868 		{ "smil+xml",		DM_UNKNOWN },	/* rfc4536 */
    869 		{ "json",		DM_UNKNOWN },	/* rfc4627 */
    870 		{ "voicexml+xml",	DM_UNKNOWN },	/* rfc4267 */
    871 		{ "ssml+xml",		DM_UNKNOWN },	/* rfc4267 */
    872 		{ "srgs",		DM_UNKNOWN },	/* rfc4267 */
    873 		{ "srgs+xml",		DM_UNKNOWN },	/* rfc4267 */
    874 		{ "ccxml+xml",		DM_UNKNOWN },	/* rfc4267 */
    875 		{ "pls+xml.",		DM_UNKNOWN },	/* rfc4267 */
    876 		{ NULL,			APPLICATION_OCTET_STREAM } /* default */
    877 	};
    878 	static const struct mime_type_s mime_type_tbl[] = {
    879 		{ "text",	 text_subtype_tbl,		DM_DISPLAY },
    880 		{ "image",	 image_subtype_tbl,		DM_IGNORE },
    881 		{ "audio",	 audio_subtype_tbl,		DM_IGNORE },
    882 		{ "video",	 video_subtype_tbl,		DM_IGNORE },
    883 		{ "application", application_subtype_tbl,	APPLICATION_OCTET_STREAM },
    884 		{ "NULL",	 NULL,				DM_UNKNOWN }, /* default */
    885 	};
    886 	const struct mime_type_s *mtp;
    887 	const struct mime_subtype_s *stp;
    888 	const char *mi_type;
    889 	const char *mi_subtype;
    890 
    891 	/*
    892 	 * Silently ignore all multipart bodies.
    893 	 * 1) In the case of "multipart" types, this typically
    894 	 *    contains a message for non-mime enabled mail readers.
    895 	 * 2) In the case of "message" type, there should be no body.
    896 	 */
    897 	if (is_multipart(mip) || is_message(mip))
    898 		return DM_IGNORE;
    899 
    900 	/*
    901 	 * If the encoding type given but not recognized, treat block
    902 	 * as "application/octet-stream".  rfc 2049 sec 2 part 2.
    903 	 */
    904 	if (mip->mi_encoding && dec == NULL)
    905 		return APPLICATION_OCTET_STREAM;
    906 
    907 	mi_type    = mip->mi_type;
    908 	mi_subtype = mip->mi_type ? mip->mi_subtype : NULL;
    909 
    910 	/*
    911 	 * If there was no type specified, display anyway so we don't
    912 	 * miss anything.  (The encoding type is known.)
    913 	 */
    914 	if (mi_type == NULL)
    915 		return DM_DISPLAY;	/* XXX - default to something safe! */
    916 
    917 	for (mtp = mime_type_tbl; mtp->mt_type; mtp++) {
    918 		if (strcasecmp(mtp->mt_type, mi_type) == 0) {
    919 			if (mi_subtype == NULL)
    920 				return mtp->mt_dispmode;
    921 			for (stp = mtp->mt_subtype; stp->st_name; stp++) {
    922 				if (strcasecmp(stp->st_name, mi_subtype) == 0)
    923 					return stp->st_dispmode;
    924 			}
    925 			return stp->st_dispmode;
    926 		}
    927 	}
    928 	return mtp->mt_dispmode;
    929 }
    930 
    931 
    932 PUBLIC FILE *
    933 mime_decode_body(struct mime_info *mip)
    934 {
    935 	static enum dispmode_e dispmode;
    936 	mime_codec_t dec;
    937 	const char *cmd;
    938 
    939 	/* close anything left over from mime_decode_head() */
    940 	close_top_files(mip->mi_head_end);
    941 
    942 	/*
    943 	 * Make sure we flush everything down the pipe so children
    944 	 * don't see it.
    945 	 */
    946 	(void)fflush(pipe_end(mip));
    947 
    948 	cmd = NULL;
    949 	if (mip->mi_command_hook == NULL)
    950 		cmd = get_command_hook(mip, "-body");
    951 
    952 	dec = mime_fio_decoder(mip->mi_encoding);
    953 	/*
    954 	 * If there is a filter running, we need to send the message
    955 	 * to it.  Otherwise, get the default display mode for this body.
    956 	 */
    957 	dispmode = cmd || mip->mi_command_hook ? DM_DISPLAY : get_display_mode(mip, dec);
    958 
    959 	if (dec == NULL)	/* make sure we have a usable decoder */
    960 		dec = mime_fio_decoder(MIME_TRANSFER_7BIT);
    961 
    962 	if (dispmode == DM_DISPLAY) {
    963 		int flags;
    964 		if (cmd == NULL)
    965 			/* just get the flags */
    966 			flags = mime_run_command(mip->mi_command_hook, NULL);
    967 		else
    968 			flags = mime_run_command(cmd, pipe_end(mip));
    969 		if ((flags & CMD_FLAG_NO_DECODE) == 0)
    970 			run_decoder(mip, dec);
    971 		return pipe_end(mip);
    972 	}
    973 	else {
    974 		static const struct msg_tbl_s {
    975 			enum dispmode_e dm;
    976 			const char *msg;
    977 		} msg_tbl[] = {
    978 			{ DM_BINARY,	"binary content"	},
    979 			{ DM_PGPSIGN,	"OpenPGP signature"	},
    980 			{ DM_PGPENCR,	"OpenPGP encrypted"	},
    981 			{ DM_PGPKEYS,	"OpenPGP keys"		},
    982 			{ DM_UNKNOWN,	"unknown data"		},
    983 			{ DM_IGNORE,	NULL			},
    984 			{ -1,		NULL			},
    985 		};
    986 		const struct msg_tbl_s *mp;
    987 
    988 		for (mp = msg_tbl; mp->dm != -1; mp++)
    989 			if (mp->dm == dispmode)
    990 				break;
    991 
    992 		assert(mp->dm != -1);	/* msg_tbl is short if this happens! */
    993 
    994 		if (mp->msg)
    995 			(void)fprintf(pipe_end(mip), "  [%s]\n\n", mp->msg);
    996 
    997 		return NULL;
    998 	}
    999 }
   1000 
   1001 
   1002 
   1003 
   1004 /************************************************************************
   1005  * Higher level header decoding interface.
   1006  *
   1007  * The core routines are in mime_header.c.
   1008  */
   1009 
   1010 PUBLIC char *
   1011 mime_decode_hfield(char *linebuf, size_t bufsize, char *hdrstr)
   1012 {
   1013 	hfield_decoder_t decode;
   1014 	decode = mime_hfield_decoder(hdrstr);
   1015 	if (decode) {
   1016 		decode(linebuf, bufsize, hdrstr);
   1017 		return linebuf;
   1018 	}
   1019 	return hdrstr;
   1020 }
   1021 
   1022 /*
   1023  * Return the next header field found in the given message.
   1024  * Return >= 0 if something found, < 0 elsewise.
   1025  * "colon" is set to point to the colon in the header.
   1026  */
   1027 static int
   1028 get_folded_hfield(FILE *f, char *linebuf, size_t bufsize, int rem, char **colon)
   1029 {
   1030 	char *cp, *cp2;
   1031 	char *line;
   1032 	size_t len;
   1033 
   1034 	for (;;) {
   1035 		if (--rem <= 0)
   1036 			return -1;
   1037 		if ((cp = fgetln(f, &len)) == NULL)
   1038 			return -1;
   1039 		for (cp2 = cp; isprint((unsigned char)*cp2) &&
   1040 			 !isblank((unsigned char)*cp2) && *cp2 != ':'; cp2++)
   1041 			continue;
   1042 		len = MIN(bufsize - 1, len);
   1043 		bufsize -= len;
   1044 		(void)memcpy(linebuf, cp, len);
   1045 		*colon = *cp2 == ':' ? linebuf + (cp2 - cp) : NULL;
   1046 		line = linebuf + len;
   1047 		for (/*EMPTY*/; rem > 0; rem--) {
   1048 			int c;
   1049 			(void)ungetc(c = getc(f), f);
   1050 			if (c == EOF || !isblank((unsigned char)c))
   1051 				break;
   1052 
   1053 			if ((cp = fgetln(f, &len)) == NULL)
   1054 				break;
   1055 			len = MIN(bufsize - 1, len);
   1056 			bufsize -= len;
   1057 			if (len == 0)
   1058 			    break;
   1059 			(void)memcpy(line, cp, len);
   1060 			line += len;
   1061 		}
   1062 		*line = 0;
   1063 		return rem;
   1064 		/* NOTREACHED */
   1065 	}
   1066 }
   1067 
   1068 static void
   1069 decode_header(FILE *fi, FILE *fo, void *cookie __unused)
   1070 {
   1071 	char linebuf[LINESIZE];
   1072 	char *colon;
   1073 #ifdef __lint__
   1074 	cookie = cookie;
   1075 #endif
   1076 	while(get_folded_hfield(fi, linebuf, sizeof(linebuf), INT_MAX, &colon) >= 0) {
   1077 		char decbuf[LINESIZE];
   1078 		char *hdrstr;
   1079 		hdrstr = linebuf;
   1080 		if (colon)
   1081 			hdrstr = mime_decode_hfield(decbuf, sizeof(decbuf), hdrstr);
   1082 		(void)fprintf(fo, hdrstr);
   1083 	}
   1084 }
   1085 
   1086 
   1087 PUBLIC FILE *
   1088 mime_decode_header(struct mime_info *mip)
   1089 {
   1090 	int flags;
   1091 	const char *cmd;
   1092 	FILE *fo;
   1093 
   1094 	fo = pipe_end(mip);
   1095 	/*
   1096 	 * Make sure we flush everything down the pipe so children
   1097 	 * don't see it.
   1098 	 */
   1099 
   1100 	if (mip->mi_partnum) {
   1101 		(void)fprintf(fo, "----- Part ");
   1102 		(void)show_partnum(fo, mip);
   1103 		(void)fprintf(fo, " -----\n");
   1104 	}
   1105 	(void)fflush(fo);
   1106 
   1107 	/*
   1108 	 * install the message hook before the head hook.
   1109 	 */
   1110 	cmd = get_command_hook(mip, "-hook");
   1111 	mip->mi_command_hook = cmd;
   1112 	if (cmd) {
   1113 		flags = mime_run_command(cmd, pipe_end(mip));
   1114 		mip->mi_head_end = last_registered_file(0);
   1115 	}
   1116 	else {
   1117 		cmd = get_command_hook(mip, "-head");
   1118 		mip->mi_head_end = last_registered_file(0);
   1119 		flags = mime_run_command(cmd, pipe_end(mip));
   1120 	}
   1121 
   1122 	if (value(ENAME_MIME_DECODE_HDR) && (flags & CMD_FLAG_NO_DECODE) == 0)
   1123 		mime_run_function(decode_header, pipe_end(mip), NULL);
   1124 
   1125 	return pipe_end(mip);
   1126 }
   1127 
   1128 #endif /* MIME_SUPPORT */
   1129