]> diplodocus.org Git - nmh/blobdiff - uip/mhstoresbr.c
projects / nmh / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
Make many m_getfld() buffer parameters NMH_BUFSIZ big.
[nmh] / uip / mhstoresbr.c
diff --git a/uip/mhstoresbr.c b/uip/mhstoresbr.c
index b978dbfb3c304f7c262dc4f50aa9f6c9b9c7a4f4..a651d01a7b56087ed1d837f199a124046f0d679d 100644 (file)
--- a/uip/mhstoresbr.c
+++ b/uip/mhstoresbr.c
@@ -1,6 +1,4 @@
-
-/*
- * mhstoresbr.c -- routines to save/store the contents of MIME messages
+/* mhstoresbr.c -- routines to save/store the contents of MIME messages
  *
  * This code is Copyright (c) 2002, by the authors of nmh.  See the
  * COPYRIGHT file in the root directory of the nmh distribution for
  *
  * This code is Copyright (c) 2002, by the authors of nmh.  See the
  * COPYRIGHT file in the root directory of the nmh distribution for
@@ -9,34 +7,67 @@
 
 #include <h/mh.h>
 #include <fcntl.h>
 
 #include <h/mh.h>
 #include <fcntl.h>
-#include <h/signals.h>
 #include <h/md5.h>
 #include <h/md5.h>
-#include <errno.h>
-#include <signal.h>
 #include <h/mts.h>
 #include <h/tws.h>
 #include <h/mime.h>
 #include <h/mhparse.h>
 #include <h/utils.h>
 
 #include <h/mts.h>
 #include <h/tws.h>
 #include <h/mime.h>
 #include <h/mhparse.h>
 #include <h/utils.h>
 
+enum clobber_policy_t {
+  NMH_CLOBBER_ALWAYS = 0,
+  NMH_CLOBBER_AUTO,
+  NMH_CLOBBER_SUFFIX,
+  NMH_CLOBBER_ASK,
+  NMH_CLOBBER_NEVER
+};
+
+static enum clobber_policy_t clobber_policy (const char *);
 
 
-/*
- * The list of top-level contents to display
- */
-extern CT *cts;
+struct mhstoreinfo {
+    CT *cts;                 /* Top-level list of contents to store. */
+    char *cwd;               /* cached current directory */
+    int autosw;              /* -auto enabled */
+    int verbosw;             /* -verbose enabled */
+    int files_not_clobbered; /* output flag indicating that store failed
+                                in order to not clobber an existing file */
 
 
-int autosw = 0;
+    /* The following must never be touched by a caller:  they are for
+       internal use by the mhstoresbr functions. */
+    char *dir;               /* directory in which to store contents */
+    enum clobber_policy_t clobber_policy;  /* -clobber selection */
+};
 
 
-/*
- * Cache of current directory.  This must be
- * set before these routines are called.
- */
-char *cwd;
+static bool use_param_as_filename(const char *p);
+
+mhstoreinfo_t
+mhstoreinfo_create (CT *ct, char *pwd, const char *csw, int asw, int vsw) {
+    mhstoreinfo_t info;
+
+    NEW(info);
+    info->cts = ct;
+    info->cwd = pwd;
+    info->autosw = asw;
+    info->verbosw = vsw;
+    info->files_not_clobbered = 0;
+    info->dir = NULL;
+    info->clobber_policy = clobber_policy (csw);
+
+    return info;
+}
+
+void
+mhstoreinfo_free (mhstoreinfo_t info) {
+    free (info->cwd);
+    free (info->dir);
+    free (info);
+}
+
+int
+mhstoreinfo_files_not_clobbered (const mhstoreinfo_t info) {
+    return info->files_not_clobbered;
+}
 
 
-/*
- * The directory in which to store the contents.
- */
-static char *dir;
 
 /*
  * Type for a compare function for qsort.  This keeps
 
 /*
  * Type for a compare function for qsort.  This keeps
@@ -46,36 +77,28 @@ typedef int (*qsort_comp) (const void *, const void *);
 
 
 /* mhmisc.c */
 
 
 /* mhmisc.c */
-int part_ok (CT, int);
+int part_ok (CT);
 int type_ok (CT, int);
 void flush_errors (void);
 
 int type_ok (CT, int);
 void flush_errors (void);
 
-/* mhshowsbr.c */
-int show_content_aux (CT, int, int, char *, char *);
-
-/*
- * prototypes
- */
-void store_all_messages (CT *);
-
 /*
  * static prototypes
  */
 /*
  * static prototypes
  */
-static void store_single_message (CT);
-static int store_switch (CT);
-static int store_generic (CT);
-static int store_application (CT);
-static int store_multi (CT);
-static int store_partial (CT);
-static int store_external (CT);
+static void store_single_message (CT, mhstoreinfo_t);
+static int store_switch (CT, mhstoreinfo_t);
+static int store_generic (CT, mhstoreinfo_t);
+static int store_application (CT, mhstoreinfo_t);
+static int store_multi (CT, mhstoreinfo_t);
+static int store_partial (CT, mhstoreinfo_t);
+static int store_external (CT, mhstoreinfo_t);
 static int ct_compar (CT *, CT *);
 static int ct_compar (CT *, CT *);
-static int store_content (CT, CT);
+static int store_content (CT, CT, mhstoreinfo_t);
 static int output_content_file (CT, int);
 static int output_content_folder (char *, char *);
 static int parse_format_string (CT, char *, char *, int, char *);
 static void get_storeproc (CT);
 static int copy_some_headers (FILE *, CT);
 static int output_content_file (CT, int);
 static int output_content_folder (char *, char *);
 static int parse_format_string (CT, char *, char *, int, char *);
 static void get_storeproc (CT);
 static int copy_some_headers (FILE *, CT);
-static char *clobber_check (char *);
+static char *clobber_check (char *, mhstoreinfo_t);
 
 /*
  * Main entry point to store content
 
 /*
  * Main entry point to store content
@@ -83,7 +106,7 @@ static char *clobber_check (char *);
  */
 
 void
  */
 
 void
-store_all_messages (CT *cts)
+store_all_messages (mhstoreinfo_t info)
 {
     CT ct, *ctp;
     char *cp;
 {
     CT ct, *ctp;
     char *cp;
@@ -93,13 +116,13 @@ store_all_messages (CT *cts)
      * store any contents.
      */
     if ((cp = context_find (nmhstorage)) && *cp)
      * store any contents.
      */
     if ((cp = context_find (nmhstorage)) && *cp)
-       dir = getcpy (cp);
+       info->dir = mh_xstrdup(cp);
     else
     else
-       dir = getcpy (cwd);
+       info->dir = getcpy (info->cwd);
 
 
-    for (ctp = cts; *ctp; ctp++) {
+    for (ctp = info->cts; *ctp; ctp++) {
        ct = *ctp;
        ct = *ctp;
-       store_single_message (ct);
+       store_single_message (ct, info);
     }
 
     flush_errors ();
     }
 
     flush_errors ();
@@ -112,11 +135,11 @@ store_all_messages (CT *cts)
  */
 
 static void
  */
 
 static void
-store_single_message (CT ct)
+store_single_message (CT ct, mhstoreinfo_t info)
 {
     if (type_ok (ct, 1)) {
        umask (ct->c_umask);
 {
     if (type_ok (ct, 1)) {
        umask (ct->c_umask);
-       store_switch (ct);
+       store_switch (ct, info);
        if (ct->c_fp) {
            fclose (ct->c_fp);
            ct->c_fp = NULL;
        if (ct->c_fp) {
            fclose (ct->c_fp);
            ct->c_fp = NULL;
@@ -132,43 +155,34 @@ store_single_message (CT ct)
  */
 
 static int
  */
 
 static int
-store_switch (CT ct)
+store_switch (CT ct, mhstoreinfo_t info)
 {
     switch (ct->c_type) {
        case CT_MULTIPART:
 {
     switch (ct->c_type) {
        case CT_MULTIPART:
-           return store_multi (ct);
-           break;
+           return store_multi (ct, info);
 
        case CT_MESSAGE:
            switch (ct->c_subtype) {
                case MESSAGE_PARTIAL:
 
        case CT_MESSAGE:
            switch (ct->c_subtype) {
                case MESSAGE_PARTIAL:
-                   return store_partial (ct);
-                   break;
+                   return store_partial (ct, info);
 
                case MESSAGE_EXTERNAL:
 
                case MESSAGE_EXTERNAL:
-                   return store_external (ct);
+                   return store_external (ct, info);
 
                case MESSAGE_RFC822:
                default:
 
                case MESSAGE_RFC822:
                default:
-                   return store_generic (ct);
-                   break;
+                   return store_generic (ct, info);
            }
            }
-           break;
 
        case CT_APPLICATION:
 
        case CT_APPLICATION:
-           return store_application (ct);
-           break;
+       default:
+           return store_application (ct, info);
 
        case CT_TEXT:
        case CT_AUDIO:
        case CT_IMAGE:
        case CT_VIDEO:
 
        case CT_TEXT:
        case CT_AUDIO:
        case CT_IMAGE:
        case CT_VIDEO:
-           return store_generic (ct);
-           break;
-
-       default:
-           adios (NULL, "unknown content type %d", ct->c_type);
-           break;
+           return store_generic (ct, info);
     }
 
     return OK; /* NOT REACHED */
     }
 
     return OK; /* NOT REACHED */
@@ -181,17 +195,17 @@ store_switch (CT ct)
  */
 
 static int
  */
 
 static int
-store_generic (CT ct)
+store_generic (CT ct, mhstoreinfo_t info)
 {
     /*
      * Check if the content specifies a filename.
      * Don't bother with this for type "message"
      * (only "message/rfc822" will use store_generic).
      */
 {
     /*
      * Check if the content specifies a filename.
      * Don't bother with this for type "message"
      * (only "message/rfc822" will use store_generic).
      */
-    if (autosw && ct->c_type != CT_MESSAGE)
+    if (info->autosw && ct->c_type != CT_MESSAGE)
        get_storeproc (ct);
 
        get_storeproc (ct);
 
-    return store_content (ct, NULL);
+    return store_content (ct, NULL, info);
 }
 
 
 }
 
 
@@ -200,13 +214,12 @@ store_generic (CT ct)
  */
 
 static int
  */
 
 static int
-store_application (CT ct)
+store_application (CT ct, mhstoreinfo_t info)
 {
 {
-    char **ap, **ep;
     CI ci = &ct->c_ctinfo;
 
     /* Check if the content specifies a filename */
     CI ci = &ct->c_ctinfo;
 
     /* Check if the content specifies a filename */
-    if (autosw)
+    if (info->autosw)
        get_storeproc (ct);
 
     /*
        get_storeproc (ct);
 
     /*
@@ -216,28 +229,23 @@ store_application (CT ct)
      */
     if (!ct->c_storeproc && ct->c_subtype == APPLICATION_OCTETS) {
        int tarP = 0, zP = 0, gzP = 0;
      */
     if (!ct->c_storeproc && ct->c_subtype == APPLICATION_OCTETS) {
        int tarP = 0, zP = 0, gzP = 0;
+       char *cp;
 
 
-       for (ap = ci->ci_attrs, ep = ci->ci_values; *ap; ap++, ep++) {
-           /* check for "type=tar" attribute */
-           if (!mh_strcasecmp (*ap, "type")) {
-               if (mh_strcasecmp (*ep, "tar"))
-                   break;
-
+       if ((cp = get_param(ci->ci_first_pm, "type", ' ', 1))) {
+           if (strcasecmp (cp, "tar") == 0)
                tarP = 1;
                tarP = 1;
-               continue;
-           }
+       }
 
 
-           /* check for "conversions=compress" attribute */
-           if ((!mh_strcasecmp (*ap, "conversions") || !mh_strcasecmp (*ap, "x-conversions"))
-               && (!mh_strcasecmp (*ep, "compress") || !mh_strcasecmp (*ep, "x-compress"))) {
+       /* check for "conversions=compress" attribute */
+       if ((cp = get_param(ci->ci_first_pm, "conversions", ' ', 1)) ||
+           (cp = get_param(ci->ci_first_pm, "x-conversions", ' ', 1))) {
+           if (strcasecmp (cp, "compress") == 0 ||
+                   strcasecmp (cp, "x-compress") == 0) {
                zP = 1;
                zP = 1;
-               continue;
            }
            }
-           /* check for "conversions=gzip" attribute */
-           if ((!mh_strcasecmp (*ap, "conversions") || !mh_strcasecmp (*ap, "x-conversions"))
-               && (!mh_strcasecmp (*ep, "gzip") || !mh_strcasecmp (*ep, "x-gzip"))) {
+           if (strcasecmp (cp, "gzip") == 0 ||
+                   strcasecmp (cp, "x-gzip") == 0) {
                gzP = 1;
                gzP = 1;
-               continue;
            }
        }
 
            }
        }
 
@@ -246,7 +254,7 @@ store_application (CT ct)
                                  : (gzP ? "%egzip -dc | tar tvf -"
                                     : "%etar tvf -"), NULL);
            if (!ct->c_storeproc) {
                                  : (gzP ? "%egzip -dc | tar tvf -"
                                     : "%etar tvf -"), NULL);
            if (!ct->c_storeproc) {
-               if (autosw) {
+               if (info->autosw) {
                    ct->c_storeproc = add (zP ? "| uncompress | tar xvpf -"
                                           : (gzP ? "| gzip -dc | tar xvpf -"
                                              : "| tar xvpf -"), NULL);
                    ct->c_storeproc = add (zP ? "| uncompress | tar xvpf -"
                                           : (gzP ? "| gzip -dc | tar xvpf -"
                                              : "| tar xvpf -"), NULL);
@@ -260,7 +268,7 @@ store_application (CT ct)
        }
     }
 
        }
     }
 
-    return store_content (ct, NULL);
+    return store_content (ct, NULL, info);
 }
 
 
 }
 
 
@@ -269,7 +277,7 @@ store_application (CT ct)
  */
 
 static int
  */
 
 static int
-store_multi (CT ct)
+store_multi (CT ct, mhstoreinfo_t info)
 {
     int        result;
     struct multipart *m = (struct multipart *) ct->c_ctparams;
 {
     int        result;
     struct multipart *m = (struct multipart *) ct->c_ctparams;
@@ -279,8 +287,15 @@ store_multi (CT ct)
     for (part = m->mp_parts; part; part = part->mp_next) {
        CT  p = part->mp_part;
 
     for (part = m->mp_parts; part; part = part->mp_next) {
        CT  p = part->mp_part;
 
-       if (part_ok (p, 1) && type_ok (p, 1)) {
-           result = store_switch (p);
+       if (part_ok (p) && type_ok (p, 1)) {
+           if (ct->c_storage) {
+               /* Support mhstore -outfile.  The MIME parser doesn't
+                  load c_storage, so we know that p->c_storage is
+                  NULL here. */
+               p->c_storage = mh_xstrdup(ct->c_storage);
+           }
+           result = store_switch (p, info);
+
            if (result == OK && ct->c_subtype == MULTI_ALTERNATE)
                break;
        }
            if (result == OK && ct->c_subtype == MULTI_ALTERNATE)
                break;
        }
@@ -296,7 +311,7 @@ store_multi (CT ct)
  */
 
 static int
  */
 
 static int
-store_partial (CT ct)
+store_partial (CT ct, mhstoreinfo_t info)
 {
     int        cur, hi, i;
     CT p, *ctp, *ctq;
 {
     int        cur, hi, i;
     CT p, *ctp, *ctq;
@@ -308,7 +323,7 @@ store_partial (CT ct)
        return OK;
 
     hi = i = 0;
        return OK;
 
     hi = i = 0;
-    for (ctp = cts; *ctp; ctp++) {
+    for (ctp = info->cts; *ctp; ctp++) {
        p = *ctp;
        if (p->c_type == CT_MESSAGE && p->c_subtype == ct->c_subtype) {
            pm = (struct partial *) p->c_ctparams;
        p = *ctp;
        if (p->c_type == CT_MESSAGE && p->c_subtype == ct->c_subtype) {
            pm = (struct partial *) p->c_ctparams;
@@ -326,15 +341,13 @@ store_partial (CT ct)
     }
 
     if (hi == 0) {
     }
 
     if (hi == 0) {
-       advise (NULL, "missing (at least) last part of multipart message");
+       inform("missing (at least) last part of multipart message");
        return NOTOK;
     }
 
        return NOTOK;
     }
 
-    if ((base = (CT *) calloc ((size_t) (i + 1), sizeof(*base))) == NULL)
-       adios (NULL, "out of memory");
-
+    base = mh_xcalloc(i + 1, sizeof *base);
     ctq = base;
     ctq = base;
-    for (ctp = cts; *ctp; ctp++) {
+    for (ctp = info->cts; *ctp; ctp++) {
        p = *ctp;
        if (p->c_type == CT_MESSAGE && p->c_subtype == ct->c_subtype) {
            pm = (struct partial *) p->c_ctparams;
        p = *ctp;
        if (p->c_type == CT_MESSAGE && p->c_subtype == ct->c_subtype) {
            pm = (struct partial *) p->c_ctparams;
@@ -351,22 +364,21 @@ store_partial (CT ct)
     for (ctq = base; *ctq; ctq++) {
        p = *ctq;
        pm = (struct partial *) p->c_ctparams;
     for (ctq = base; *ctq; ctq++) {
        p = *ctq;
        pm = (struct partial *) p->c_ctparams;
-       if (pm->pm_marked != cur) {
-           if (pm->pm_marked == cur - 1) {
-               admonish (NULL,
-                         "duplicate part %d of %d part multipart message",
-                         pm->pm_marked, hi);
-               continue;
-           }
+       if (pm->pm_marked == cur) {
+           cur++;
+            continue;
+        }
+
+        if (pm->pm_marked == cur - 1) {
+            inform("duplicate part %d of %d part multipart message, continuing...",
+                      pm->pm_marked, hi);
+            continue;
+        }
 
 missing_part:
 
 missing_part:
-           advise (NULL,
-                   "missing %spart %d of %d part multipart message",
-                   cur != hi ? "(at least) " : "", cur, hi);
-           goto losing;
-       }
-        else
-           cur++;
+        inform("missing %spart %d of %d part multipart message",
+            cur != hi ? "(at least) " : "", cur, hi);
+        goto losing;
     }
     if (hi != --cur) {
        cur = hi;
     }
     if (hi != --cur) {
        cur = hi;
@@ -380,19 +392,19 @@ missing_part:
 
     ctq = base;
     ct = *ctq++;
 
     ctq = base;
     ct = *ctq++;
-    if (store_content (ct, NULL) == NOTOK) {
+    if (store_content (ct, NULL, info) == NOTOK) {
 losing:
 losing:
-       free ((char *) base);
+       free(base);
        return NOTOK;
     }
 
     for (; *ctq; ctq++) {
        p = *ctq;
        return NOTOK;
     }
 
     for (; *ctq; ctq++) {
        p = *ctq;
-       if (store_content (p, ct) == NOTOK)
+       if (store_content (p, ct, info) == NOTOK)
            goto losing;
     }
 
            goto losing;
     }
 
-    free ((char *) base);
+    free(base);
     return OK;
 }
 
     return OK;
 }
 
@@ -402,7 +414,7 @@ losing:
  */
 
 static int
  */
 
 static int
-store_external (CT ct)
+store_external (CT ct, mhstoreinfo_t info)
 {
     int        result = NOTOK;
     struct exbody *e = (struct exbody *) ct->c_ctparams;
 {
     int        result = NOTOK;
     struct exbody *e = (struct exbody *) ct->c_ctparams;
@@ -415,19 +427,14 @@ store_external (CT ct)
      * Check if the parameters for the external body
      * specified a filename.
      */
      * Check if the parameters for the external body
      * specified a filename.
      */
-    if (autosw) {
+    if (info->autosw) {
        char *cp;
 
        char *cp;
 
-       if ((cp = e->eb_name)
-           && *cp != '/'
-           && *cp != '.'
-           && *cp != '|'
-           && *cp != '!'
-           && !strchr (cp, '%')) {
+       if ((cp = e->eb_name) && use_param_as_filename(cp)) {
            if (!ct->c_storeproc)
            if (!ct->c_storeproc)
-               ct->c_storeproc = add (cp, NULL);
+               ct->c_storeproc = mh_xstrdup(cp);
            if (!p->c_storeproc)
            if (!p->c_storeproc)
-               p->c_storeproc = add (cp, NULL);
+               p->c_storeproc = mh_xstrdup(cp);
        }
     }
 
        }
     }
 
@@ -440,7 +447,12 @@ store_external (CT ct)
     p->c_partno = ct->c_partno;
 
     /* we probably need to check if content is really there */
     p->c_partno = ct->c_partno;
 
     /* we probably need to check if content is really there */
-    result = store_switch (p);
+    if (ct->c_storage) {
+       /* Support mhstore -outfile.  The MIME parser doesn't load
+          c_storage, so we know that p->c_storage is NULL here. */
+       p->c_storage = mh_xstrdup(ct->c_storage);
+    }
+    result = store_switch (p, info);
 
     p->c_partno = NULL;
     return result;
 
     p->c_partno = NULL;
     return result;
@@ -474,7 +486,7 @@ ct_compar (CT *a, CT *b)
  */
 
 static int
  */
 
 static int
-store_content (CT ct, CT p)
+store_content (CT ct, CT p, mhstoreinfo_t info)
 {
     int appending = 0, msgnum = 0;
     int is_partial = 0, first_partial = 0;
 {
     int appending = 0, msgnum = 0;
     int is_partial = 0, first_partial = 0;
@@ -514,11 +526,13 @@ store_content (CT ct, CT p)
         */
        if (p) {
            appending = 1;
         */
        if (p) {
            appending = 1;
-           ct->c_storage = add (p->c_storage, NULL);
+            if (! ct->c_storage) {
+               ct->c_storage = add (p->c_storage, NULL);
 
 
-           /* record the folder name */
-           if (p->c_folder) {
-               ct->c_folder = add (p->c_folder, NULL);
+               /* record the folder name */
+               if (p->c_folder) {
+                   ct->c_folder = mh_xstrdup(p->c_folder);
+               }
            }
            goto got_filename;
        }
            }
            goto got_filename;
        }
@@ -536,61 +550,69 @@ store_content (CT ct, CT p)
     if ((cp = ct->c_storeproc) == NULL || *cp == '\0') {
        CI ci = &ct->c_ctinfo;
 
     if ((cp = ct->c_storeproc) == NULL || *cp == '\0') {
        CI ci = &ct->c_ctinfo;
 
-       snprintf (buffer, sizeof(buffer), "%s-store-%s/%s",
-               invo_name, ci->ci_type, ci->ci_subtype);
-       if ((cp = context_find (buffer)) == NULL || *cp == '\0') {
-           snprintf (buffer, sizeof(buffer), "%s-store-%s", invo_name, ci->ci_type);
-           if ((cp = context_find (buffer)) == NULL || *cp == '\0') {
-               cp = ct->c_type == CT_MESSAGE ? "+" : "%m%P.%s";
-           }
+       cp = context_find_by_type ("store", ci->ci_type, ci->ci_subtype);
+       if (cp == NULL) {
+           cp = ct->c_type == CT_MESSAGE ? "+" : "%m%P.%s";
        }
     }
 
        }
     }
 
-    /*
-     * Check the beginning of storage formatting string
-     * to see if we are saving content to a folder.
-     */
-    if (*cp == '+' || *cp == '@') {
-       char *tmpfilenam, *folder;
+    if (! ct->c_storage) {
+       /*
+        * Check the beginning of storage formatting string
+        * to see if we are saving content to a folder.
+        */
+       if (*cp == '+' || *cp == '@') {
+           char *tmpfilenam, *folder;
 
 
-       /* Store content in temporary file for now */
-       tmpfilenam = m_mktemp(invo_name, NULL, NULL);
-       ct->c_storage = add (tmpfilenam, NULL);
+           /* Store content in temporary file for now */
+           if ((tmpfilenam = m_mktemp(invo_name, NULL, NULL)) == NULL) {
+               adios(NULL, "unable to create temporary file in %s",
+                     get_temp_dir());
+           }
+           ct->c_storage = mh_xstrdup(tmpfilenam);
 
 
-       /* Get the folder name */
-       if (cp[1])
-           folder = pluspath (cp);
-       else
-           folder = getfolder (1);
+           /* Get the folder name */
+           if (cp[1])
+               folder = pluspath (cp);
+           else
+               folder = getfolder (1);
 
 
-       /* Check if folder exists */
-       create_folder(m_mailpath(folder), 0, exit);
+           /* Check if folder exists */
+           create_folder(m_mailpath(folder), 0, exit);
 
 
-       /* Record the folder name */
-       ct->c_folder = add (folder, NULL);
+           /* Record the folder name */
+           ct->c_folder = mh_xstrdup(folder);
 
 
-       if (cp[1])
-           free (folder);
+           if (cp[1])
+               free (folder);
 
 
-       goto got_filename;
-    }
+           goto got_filename;
+       }
 
 
-    /*
-     * Parse and expand the storage formatting string
-     * in `cp' into `buffer'.
-     */
-    parse_format_string (ct, cp, buffer, sizeof(buffer), dir);
+       /*
+        * Parse and expand the storage formatting string
+        * in `cp' into `buffer'.
+        */
+       parse_format_string (ct, cp, buffer, sizeof(buffer), info->dir);
 
 
-    /*
-     * If formatting begins with '|' or '!', then pass
-     * content to standard input of a command and return.
-     */
-    if (buffer[0] == '|' || buffer[0] == '!')
-       return show_content_aux (ct, 1, 0, buffer + 1, dir);
+       /*
+        * If formatting begins with '|' or '!', then pass
+        * content to standard input of a command and return.
+        */
+       if (buffer[0] == '|' || buffer[0] == '!')
+           return show_content_aux (ct, 0, buffer + 1, info->dir, NULL);
 
 
-    /* record the filename */
-    if ((ct->c_storage = clobber_check (add (buffer, NULL))) == NULL) {
-      return NOTOK;
+        /* record the filename */
+       if ((ct->c_storage = clobber_check (mh_xstrdup(buffer), info)) ==
+           NULL) {
+           return NOTOK;
+       }
+    } else {
+       /* The output filename was explicitly specified, so use it. */
+       if ((ct->c_storage = clobber_check (ct->c_storage, info)) ==
+           NULL) {
+           return NOTOK;
+       }
     }
 
 got_filename:
     }
 
 got_filename:
@@ -608,47 +630,49 @@ got_filename:
      */
     if (ct->c_folder && (!is_partial || last_partial)) {
        msgnum = output_content_folder (ct->c_folder, ct->c_storage);
      */
     if (ct->c_folder && (!is_partial || last_partial)) {
        msgnum = output_content_folder (ct->c_folder, ct->c_storage);
-       unlink (ct->c_storage);
+       (void) m_unlink (ct->c_storage);
        if (msgnum == NOTOK)
            return NOTOK;
     }
 
        if (msgnum == NOTOK)
            return NOTOK;
     }
 
-    /*
-     * Now print out the name/number of the message
-     * that we are storing.
-     */
-    if (is_partial) {
-       if (first_partial)
-           fprintf (stderr, "reassembling partials ");
-       if (last_partial)
-           fprintf (stderr, "%s", ct->c_file);
-       else
-           fprintf (stderr, "%s,", ct->c_file);
-    } else {
-       fprintf (stderr, "storing message %s", ct->c_file);
-       if (ct->c_partno)
-           fprintf (stderr, " part %s", ct->c_partno);
-    }
-
-    /*
-     * Unless we are in the "middle" of group of message/partials,
-     * we now print the name of the file, folder, and/or message
-     * to which we are storing the content.
-     */
-    if (!is_partial || last_partial) {
-       if (ct->c_folder) {
-           fprintf (stderr, " to folder %s as message %d\n", ct->c_folder, msgnum);
-       } else if (!strcmp(ct->c_storage, "-")) {
-           fprintf (stderr, " to stdout\n");
-       } else {
-           int cwdlen;
+    if (info->verbosw) {
+        /*
+         * Now print out the name/number of the message
+         * that we are storing.
+         */
+        if (is_partial) {
+            if (first_partial)
+                fprintf (stderr, "reassembling partials ");
+            if (last_partial)
+                fputs(ct->c_file, stderr);
+            else
+                fprintf (stderr, "%s,", ct->c_file);
+        } else {
+            fprintf (stderr, "storing message %s", ct->c_file);
+            if (ct->c_partno)
+                fprintf (stderr, " part %s", ct->c_partno);
+        }
 
 
-           cwdlen = strlen (cwd);
-           fprintf (stderr, " as file %s\n",
-               strncmp (ct->c_storage, cwd, cwdlen)
-               || ct->c_storage[cwdlen] != '/'
-               ? ct->c_storage : ct->c_storage + cwdlen + 1);
-       }
+        /*
+         * Unless we are in the "middle" of group of message/partials,
+         * we now print the name of the file, folder, and/or message
+         * to which we are storing the content.
+         */
+        if (!is_partial || last_partial) {
+            if (ct->c_folder) {
+                fprintf (stderr, " to folder %s as message %d\n", ct->c_folder,
+                         msgnum);
+            } else if (!strcmp(ct->c_storage, "-")) {
+                fprintf (stderr, " to stdout\n");
+            } else {
+                int cwdlen = strlen (info->cwd);
+
+                fprintf (stderr, " as file %s\n",
+                         !has_prefix(ct->c_storage, info->cwd)
+                         || ct->c_storage[cwdlen] != '/'
+                         ? ct->c_storage : ct->c_storage + cwdlen + 1);
+            }
+        }
     }
 
     return OK;
     }
 
     return OK;
@@ -679,7 +703,7 @@ output_content_file (CT ct, int appending)
        int cc, fd;
 
        if (!ct->c_ceopenfnx) {
        int cc, fd;
 
        if (!ct->c_ceopenfnx) {
-           advise (NULL, "don't know how to decode part %s of message %s",
+           inform("don't know how to decode part %s of message %s",
                    ct->c_partno, ct->c_file);
            return NOTOK;
        }
                    ct->c_partno, ct->c_file);
            return NOTOK;
        }
@@ -743,7 +767,9 @@ losing:
                    break;
 
                default:
                    break;
 
                default:
-                   fwrite (buffer, sizeof(*buffer), cc, fp);
+                   if ((int) fwrite (buffer, sizeof(*buffer), cc, fp) < cc) {
+                       advise ("output_content_file", "fwrite");
+                   }
                    continue;
            }
            break;
                    continue;
            }
            break;
@@ -803,7 +829,7 @@ losing:
        }
     }
 
        }
     }
 
-    while (fgets (buffer, sizeof(buffer) - 1, ct->c_fp)) {
+    while (fgets (buffer, sizeof buffer, ct->c_fp)) {
        if ((pos += strlen (buffer)) > last) {
            int diff;
 
        if ((pos += strlen (buffer)) > last) {
            int diff;
 
@@ -872,11 +898,11 @@ output_content_folder (char *folder, char *filename)
     struct msgs *mp;
 
     /* Read the folder. */
     struct msgs *mp;
 
     /* Read the folder. */
-    if ((mp = folder_read (folder))) {
+    if ((mp = folder_read (folder, 0))) {
        /* Link file into folder */
        /* Link file into folder */
-       msgnum = folder_addmsg (&mp, filename, 0, 0, 0, 0, (char *)0);
+       msgnum = folder_addmsg (&mp, filename, 0, 0, 0, 0, NULL);
     } else {
     } else {
-       advise (NULL, "unable to read folder %s", folder);
+       inform("unable to read folder %s", folder);
        return NOTOK;
     }
 
        return NOTOK;
     }
 
@@ -942,13 +968,14 @@ parse_format_string (CT ct, char *cp, char *buffer, int buflen, char *dir)
                        *bp = '\0';
                        buflen--;
                        continue;
                        *bp = '\0';
                        buflen--;
                        continue;
-                   } else {
-                       char **ap, **ep;
+                   }
+                    {
+                       PM pm;
                        char *s = "";
 
                        char *s = "";
 
-                       for (ap = ci->ci_attrs, ep = ci->ci_values;
-                                *ap; ap++, ep++) {
-                           snprintf (bp, buflen, "%s%s=\"%s\"", s, *ap, *ep);
+                       for (pm = ci->ci_first_pm; pm; pm = pm->pm_next) {
+                           snprintf (bp, buflen, "%s%s=\"%s\"", s,
+                                     pm->pm_name, get_param_value(pm, '?'));
                            len = strlen (bp);
                            bp += len;
                            buflen -= len;
                            len = strlen (bp);
                            bp += len;
                            buflen -= len;
@@ -969,7 +996,7 @@ parse_format_string (CT ct, char *cp, char *buffer, int buflen, char *dir)
                    break;
 
                case 'p':
                    break;
 
                case 'p':
-                   /* insert part number withouth leading dot */
+                   /* insert part number without leading dot */
                    if (ct->c_partno)
                        strncpy (bp, ct->c_partno, buflen);
                    break;
                    if (ct->c_partno)
                        strncpy (bp, ct->c_partno, buflen);
                    break;
@@ -1020,8 +1047,8 @@ raw:
 static void
 get_storeproc (CT ct)
 {
 static void
 get_storeproc (CT ct)
 {
-    char **ap, **ep, *cp;
-    CI ci = &ct->c_ctinfo;
+    char *cp;
+    CI ci;
 
     /*
      * If the storeproc has already been defined,
 
     /*
      * If the storeproc has already been defined,
@@ -1031,22 +1058,32 @@ get_storeproc (CT ct)
     if (ct->c_storeproc)
        return;
 
     if (ct->c_storeproc)
        return;
 
+    /*
+     * If there's a Content-Disposition header and it has a filename,
+     * use that (RFC-2183).
+     */
+    if (ct->c_dispo) {
+       if ((cp = get_param(ct->c_dispo_first, "filename", '_', 0)) &&
+            use_param_as_filename(cp)) {
+               ct->c_storeproc = mh_xstrdup(cp);
+               free(cp);
+               return;
+       }
+        mh_xfree(cp);
+    }
+
     /*
      * Check the attribute/value pairs, for the attribute "name".
      * If found, do a few sanity checks and copy the value into
      * the storeproc.
      */
     /*
      * Check the attribute/value pairs, for the attribute "name".
      * If found, do a few sanity checks and copy the value into
      * the storeproc.
      */
-    for (ap = ci->ci_attrs, ep = ci->ci_values; *ap; ap++, ep++) {
-       if (!mh_strcasecmp (*ap, "name")
-           && *(cp = *ep) != '/'
-           && *cp != '.'
-           && *cp != '|'
-           && *cp != '!'
-           && !strchr (cp, '%')) {
-           ct->c_storeproc = add (cp, NULL);
-           return;
-       }
+    ci = &ct->c_ctinfo;
+    if ((cp = get_param(ci->ci_first_pm, "name", '_', 0)) &&
+        use_param_as_filename(cp)) {
+           ct->c_storeproc = mh_xstrdup(cp);
+
     }
     }
+    mh_xfree(cp);
 }
 
 
 }
 
 
@@ -1068,10 +1105,10 @@ copy_some_headers (FILE *out, CT ct)
         * messages are not copied.
         */
        if (!uprf (hp->name, XXX_FIELD_PRF)
         * messages are not copied.
         */
        if (!uprf (hp->name, XXX_FIELD_PRF)
-               && mh_strcasecmp (hp->name, VRSN_FIELD)
-               && mh_strcasecmp (hp->name, "Subject")
-               && mh_strcasecmp (hp->name, "Encrypted")
-               && mh_strcasecmp (hp->name, "Message-ID"))
+               && strcasecmp (hp->name, VRSN_FIELD)
+               && strcasecmp (hp->name, "Subject")
+               && strcasecmp (hp->name, "Encrypted")
+               && strcasecmp (hp->name, "Message-ID"))
            fprintf (out, "%s:%s", hp->name, hp->value);
        hp = hp->next;  /* next header field */
     }
            fprintf (out, "%s:%s", hp->name, hp->value);
        hp = hp->next;  /* next header field */
     }
@@ -1082,35 +1119,26 @@ copy_some_headers (FILE *out, CT ct)
 /******************************************************************************/
 /* -clobber support */
 
 /******************************************************************************/
 /* -clobber support */
 
-enum clobber_policy_t {
-  NMH_CLOBBER_ALWAYS,
-  NMH_CLOBBER_AUTO,
-  NMH_CLOBBER_SUFFIX,
-  NMH_CLOBBER_ASK,
-  NMH_CLOBBER_NEVER
-};
-
-static enum clobber_policy_t clobber_policy = NMH_CLOBBER_ALWAYS;
-
-int files_not_clobbered = 0;
-
-int
-save_clobber_policy (const char *value) {
-  if (! mh_strcasecmp (value, "always")) {
-    clobber_policy = NMH_CLOBBER_ALWAYS;
-  } else if (! mh_strcasecmp (value, "auto")) {
-    clobber_policy = NMH_CLOBBER_AUTO;
-  } else if (! mh_strcasecmp (value, "suffix")) {
-    clobber_policy = NMH_CLOBBER_SUFFIX;
-  } else if (! mh_strcasecmp (value, "ask")) {
-    clobber_policy = NMH_CLOBBER_ASK;
-  } else if (! mh_strcasecmp (value, "never")) {
-    clobber_policy = NMH_CLOBBER_NEVER;
-  } else {
-    return 1;
+static
+enum clobber_policy_t
+clobber_policy (const char *value) {
+  if (value == NULL  ||  ! strcasecmp (value, "always")) {
+    return NMH_CLOBBER_ALWAYS;
+  }
+  if (! strcasecmp (value, "auto")) {
+    return NMH_CLOBBER_AUTO;
+  }
+  if (! strcasecmp (value, "suffix")) {
+    return NMH_CLOBBER_SUFFIX;
+  }
+  if (! strcasecmp (value, "ask")) {
+    return NMH_CLOBBER_ASK;
+  }
+  if (! strcasecmp (value, "never")) {
+    return NMH_CLOBBER_NEVER;
   }
 
   }
 
-  return 0;
+  adios (NULL, "invalid argument, %s, to clobber", value);
 }
 
 
 }
 
 
@@ -1145,9 +1173,8 @@ next_version (char *file, enum clobber_policy_t clobber_policy) {
 
       default:
         /* Should never get here. */
 
       default:
         /* Should never get here. */
-        advise (NULL, "will not overwrite %s, invalid clobber policy", buffer);
+        inform("will not overwrite %s, invalid clobber policy", buffer);
         free (buffer);
         free (buffer);
-        ++files_not_clobbered;
         return NULL;
     }
 
         return NULL;
     }
 
@@ -1167,10 +1194,9 @@ next_version (char *file, enum clobber_policy_t clobber_policy) {
   free (file);
 
   if (version >= max_versions) {
   free (file);
 
   if (version >= max_versions) {
-    advise (NULL, "will not overwrite %s, too many versions", buffer);
+    inform("will not overwrite %s, too many versions", buffer);
     free (buffer);
     buffer = NULL;
     free (buffer);
     buffer = NULL;
-    ++files_not_clobbered;
   }
 
   return buffer;
   }
 
   return buffer;
@@ -1178,31 +1204,37 @@ next_version (char *file, enum clobber_policy_t clobber_policy) {
 
 
 static char *
 
 
 static char *
-clobber_check (char *original_file) {
+clobber_check (char *original_file, mhstoreinfo_t info) {
   /* clobber policy        return value
    * --------------        ------------
   /* clobber policy        return value
    * --------------        ------------
-   *   -always                 file
-   *   -auto           file-<digits>.extension
-   *   -suffix             file.<digits>
-   *   -ask          file, 0, or another filename/path
-   *   -never                   0
+   *   -always             original_file
+   *   -auto               original_file-<digits>.extension
+   *   -suffix             original_file.<digits>
+   *   -ask                original_file, 0, or another filename/path
+   *   -never              0
    */
 
   char *file;
   char *cwd = NULL;
   int check_again;
 
    */
 
   char *file;
   char *cwd = NULL;
   int check_again;
 
-  if (clobber_policy == NMH_CLOBBER_ASK) {
+  if (! strcmp (original_file, "-")) {
+      return original_file;
+  }
+
+  if (info->clobber_policy == NMH_CLOBBER_ASK) {
     /* Save cwd for possible use in loop below. */
     char *slash;
 
     /* Save cwd for possible use in loop below. */
     char *slash;
 
-    cwd = add (original_file, NULL);
+    cwd = mh_xstrdup(original_file);
     slash = strrchr (cwd, '/');
 
     if (slash) {
       *slash = '\0';
     } else {
     slash = strrchr (cwd, '/');
 
     if (slash) {
       *slash = '\0';
     } else {
-      /* original_file wasn't a full path, which shouldn't happen. */
+      /* original_file isn't a full path, which should only happen if
+         it is -. */
+      free (cwd);
       cwd = NULL;
     }
   }
       cwd = NULL;
     }
   }
@@ -1213,14 +1245,17 @@ clobber_check (char *original_file) {
     file = original_file;
     check_again = 0;
 
     file = original_file;
     check_again = 0;
 
-    switch (clobber_policy) {
+    switch (info->clobber_policy) {
       case NMH_CLOBBER_ALWAYS:
         break;
 
       case NMH_CLOBBER_SUFFIX:
       case NMH_CLOBBER_AUTO:
         if (stat (file, &st) == OK) {
       case NMH_CLOBBER_ALWAYS:
         break;
 
       case NMH_CLOBBER_SUFFIX:
       case NMH_CLOBBER_AUTO:
         if (stat (file, &st) == OK) {
-          file = next_version (original_file, clobber_policy);
+          if ((file = next_version (original_file, info->clobber_policy)) ==
+              NULL) {
+              ++info->files_not_clobbered;
+          }
         }
         break;
 
         }
         break;
 
@@ -1228,17 +1263,20 @@ clobber_check (char *original_file) {
         if (stat (file, &st) == OK) {
           enum answers { NMH_YES, NMH_NO, NMH_RENAME };
           static struct swit answer[4] = {
         if (stat (file, &st) == OK) {
           enum answers { NMH_YES, NMH_NO, NMH_RENAME };
           static struct swit answer[4] = {
-            { "yes", 0, NMH_YES }, { "no", 0, NMH_NO }, { "rename", 0, NMH_RENAME }, { NULL, 0, 0 } };
+            { "yes", 0, NMH_YES },
+            { "no", 0, NMH_NO },
+            { "rename", 0, NMH_RENAME },
+            { NULL, 0, 0 } };
           char **ans;
 
           if (isatty (fileno (stdin))) {
             char *prompt =
               concat ("Overwrite \"", file, "\" [y/n/rename]? ", NULL);
           char **ans;
 
           if (isatty (fileno (stdin))) {
             char *prompt =
               concat ("Overwrite \"", file, "\" [y/n/rename]? ", NULL);
-            ans = getans (prompt, answer);
+            ans = read_switch_multiword (prompt, answer);
             free (prompt);
           } else {
             /* Overwrite, that's what nmh used to do.  And warn. */
             free (prompt);
           } else {
             /* Overwrite, that's what nmh used to do.  And warn. */
-            advise (NULL, "-clobber ask but no tty, so overwrite %s", file);
+            inform("-clobber ask but no tty, so overwrite %s", file);
             break;
           }
 
             break;
           }
 
@@ -1248,7 +1286,7 @@ clobber_check (char *original_file) {
             case NMH_NO:
               free (file);
               file = NULL;
             case NMH_NO:
               free (file);
               file = NULL;
-              ++files_not_clobbered;
+              ++info->files_not_clobbered;
               break;
             case NMH_RENAME: {
               char buf[PATH_MAX];
               break;
             case NMH_RENAME: {
               char buf[PATH_MAX];
@@ -1256,22 +1294,19 @@ clobber_check (char *original_file) {
               if (fgets (buf, sizeof buf, stdin) == NULL  ||
                   buf[0] == '\0') {
                 file = NULL;
               if (fgets (buf, sizeof buf, stdin) == NULL  ||
                   buf[0] == '\0') {
                 file = NULL;
-                ++files_not_clobbered;
+                ++info->files_not_clobbered;
               } else {
               } else {
-                char *newline = strchr (buf, '\n');
-                if (newline) {
-                  *newline = '\0';
-                }
+                trim_suffix_c(buf, '\n');
               }
 
               free (file);
 
               if (buf[0] == '/') {
                 /* Full path, use it. */
               }
 
               free (file);
 
               if (buf[0] == '/') {
                 /* Full path, use it. */
-                file = add (buf, NULL);
+                file = mh_xstrdup(buf);
               } else {
                 /* Relative path. */
               } else {
                 /* Relative path. */
-                file = cwd  ?  concat (cwd, "/", buf, NULL)  :  add (buf, NULL);
+                file = cwd  ?  concat (cwd, "/", buf, NULL)  :  mh_xstrdup(buf);
               }
 
               check_again = 1;
               }
 
               check_again = 1;
@@ -1285,10 +1320,10 @@ clobber_check (char *original_file) {
         if (stat (file, &st) == OK) {
           /* Keep count of files that would have been clobbered,
              and return that as process exit status. */
         if (stat (file, &st) == OK) {
           /* Keep count of files that would have been clobbered,
              and return that as process exit status. */
-          advise (NULL, "will not overwrite %s with -clobber never", file);
+          inform("will not overwrite %s with -clobber never", file);
           free (file);
           file = NULL;
           free (file);
           file = NULL;
-          ++files_not_clobbered;
+          ++info->files_not_clobbered;
         }
         break;
     }
         }
         break;
     }
@@ -1296,12 +1331,17 @@ clobber_check (char *original_file) {
     original_file = file;
   } while (check_again);
 
     original_file = file;
   } while (check_again);
 
-  if (cwd) {
-    free (cwd);
-  }
+  free (cwd);
 
   return file;
 }
 
 
   return file;
 }
 
+static bool use_param_as_filename(const char *p)
+{
+    /* Preserve result of original test that considered an empty string
+     * OK. */
+    return !*p || (!strchr("/.|!", *p) && !strchr(p, '%'));
+}
+
 /* -clobber support */
 /******************************************************************************/
 /* -clobber support */
 /******************************************************************************/
Fork of https://git.savannah.nongnu.org/cgit/nmh.git