git.marmaro.de Git - mmh/blob - uip/forw.c

   1 /*
   2 ** forw.c -- forward a message, or group of messages.
   3 **
   4 ** This code is Copyright (c) 2002, by the authors of nmh.  See the
   5 ** COPYRIGHT file in the root directory of the nmh distribution for
   6 ** complete copyright information.
   7 */
   8
   9 #include <h/mh.h>
  10 #include <fcntl.h>
  11 #include <h/fmt_scan.h>
  12 #include <h/tws.h>
  13 #include <h/utils.h>
  14 #include <unistd.h>
  15 #include <locale.h>
  16 #include <sysexits.h>
  17
  18 #define IFORMAT  "digest-issue-%s"
  19 #define VFORMAT  "digest-volume-%s"
  20
  21 static struct swit switches[] = {
  22 #define ANNOSW  0
  23         { "annotate", 0 },
  24 #define NANNOSW  1
  25         { "noannotate", 2 },
  26 #define EDITRSW  2
  27         { "editor editor", 0 },
  28 #define FORMSW  3
  29         { "form formfile", 0 },
  30 #define DGSTSW  4
  31         { "digest list", 0 },
  32 #define ISSUESW  5
  33         { "issue number", 0 },
  34 #define VOLUMSW  6
  35         { "volume number", 0 },
  36 #define WHATSW  7
  37         { "whatnowproc program", 0 },
  38 #define VERSIONSW  8
  39         { "Version", 0 },
  40 #define HELPSW  9
  41         { "help", 0 },
  42 #define BILDSW  10
  43         { "build", 5 },  /* interface from mhe */
  44         { NULL, 0 }
  45 };
  46
  47 static char drft[BUFSIZ];
  48 static struct msgs *mp = NULL;
  49
  50
  51 /*
  52 ** static prototypes
  53 */
  54 static void add_forw_hdr(char *);
  55 static int build_form(char *, char *, int, int);
  56
  57
  58 int
  59 main(int argc, char **argv)
  60 {
  61         int msgp = 0, anot = 0;
  62         int issue = 0, volume = 0;
  63         int in;
  64         int out, msgnum;
  65         char *cp, *cwd, *maildir;
  66         char *digest = NULL, *ed = NULL;
  67         char *folder = NULL;
  68         char *form = NULL, buf[BUFSIZ], value[10];
  69         char **argp, **arguments, *msgs[MAXARGS];
  70         char *fmtstr;
  71         int buildsw = 0;
  72
  73         setlocale(LC_ALL, "");
  74         invo_name = mhbasename(argv[0]);
  75
  76         /* read user profile/context */
  77         context_read();
  78
  79         arguments = getarguments(invo_name, argc, argv, 1);
  80         argp = arguments;
  81
  82         while ((cp = *argp++)) {
  83                 if (*cp == '-') {
  84                         switch (smatch(++cp, switches)) {
  85                         case AMBIGSW:
  86                                 ambigsw(cp, switches);
  87                                 exit(EX_USAGE);
  88                         case UNKWNSW:
  89                                 adios(EX_USAGE, NULL, "-%s unknown", cp);
  90
  91                         case HELPSW:
  92                                 snprintf(buf, sizeof(buf), "%s [+folder] [msgs] [switches]", invo_name);
  93                                 print_help(buf, switches, 1);
  94                                 exit(argc == 2 ? EX_OK : EX_USAGE);
  95                         case VERSIONSW:
  96                                 print_version(invo_name);
  97                                 exit(argc == 2 ? EX_OK : EX_USAGE);
  98
  99                         case ANNOSW:
 100                                 anot++;
 101                                 continue;
 102                         case NANNOSW:
 103                                 anot = 0;
 104                                 continue;
 105
 106                         case EDITRSW:
 107                                 if (!(ed = *argp++) || *ed == '-')
 108                                         adios(EX_USAGE, NULL, "missing argument to %s",
 109                                                         argp[-2]);
 110                                 continue;
 111
 112                         case WHATSW:
 113                                 if (!(whatnowproc = *argp++) ||
 114                                                 *whatnowproc == '-')
 115                                         adios(EX_USAGE, NULL, "missing argument to %s",
 116                                                         argp[-2]);
 117                                 continue;
 118
 119                         case BILDSW:
 120                                 buildsw++;
 121                                 continue;
 122
 123                         case FORMSW:
 124                                 if (!(form = *argp++) || *form == '-')
 125                                         adios(EX_USAGE, NULL, "missing argument to %s",
 126                                                         argp[-2]);
 127                                 continue;
 128
 129                         case DGSTSW:
 130                                 if (!(digest = *argp++) || *digest == '-')
 131                                         adios(EX_USAGE, NULL, "missing argument to %s",
 132                                                         argp[-2]);
 133                                 //mime = 0;
 134                                 continue;
 135                         case ISSUESW:
 136                                 if (!(cp = *argp++) || *cp == '-')
 137                                         adios(EX_USAGE, NULL, "missing argument to %s",
 138                                                         argp[-2]);
 139                                 if ((issue = atoi(cp)) < 1)
 140                                         adios(EX_USAGE, NULL, "bad argument %s %s",
 141                                                         argp[-2], cp);
 142                                 continue;
 143                         case VOLUMSW:
 144                                 if (!(cp = *argp++) || *cp == '-')
 145                                         adios(EX_USAGE, NULL, "missing argument to %s",
 146                                                         argp[-2]);
 147                                 if ((volume = atoi(cp)) < 1)
 148                                         adios(EX_USAGE, NULL, "bad argument %s %s",
 149                                                         argp[-2], cp);
 150                                 continue;
 151                         }
 152                 }
 153                 if (*cp == '+' || *cp == '@') {
 154                         if (folder)
 155                                 adios(EX_USAGE, NULL, "only one folder at a time!");
 156                         else
 157                                 folder = getcpy(expandfol(cp));
 158                 } else {
 159                         msgs[msgp++] = cp;
 160                 }
 161         }
 162
 163         cwd = getcpy(pwd());
 164         strncpy(drft, buildsw ? toabsdir("draft") : m_draft(seq_beyond),
 165                         sizeof(drft));
 166         /*
 167         ** FIXME: (concerning MHE support (buildsw) only)
 168         ** There's no check if the draft already exists. mmh has removed
 169         ** this case by having the draft folder. I won't add code only to
 170         ** handle this legacy issue for MHE. -- meillo@marmaro.de 2012-05
 171         */
 172
 173         /*
 174         ** Forwarding a message.
 175         */
 176         if (!msgp)
 177                 msgs[msgp++] = seq_cur;
 178         if (!folder)
 179                 folder = getcurfol();
 180         maildir = toabsdir(folder);
 181
 182         if (chdir(maildir) == NOTOK)
 183                 adios(EX_OSERR, maildir, "unable to change directory to");
 184
 185         /* read folder and create message structure */
 186         if (!(mp = folder_read(folder)))
 187                 adios(EX_IOERR, NULL, "unable to read folder %s", folder);
 188
 189         /* check for empty folder */
 190         if (mp->nummsg == 0)
 191                 adios(EX_DATAERR, NULL, "no messages in %s", folder);
 192
 193         /* parse all the message ranges/sequences and set SELECTED */
 194         for (msgnum = 0; msgnum < msgp; msgnum++) {
 195                 if (!m_convert(mp, msgs[msgnum])) {
 196                         exit(EX_SOFTWARE);
 197                 }
 198         }
 199         seq_setprev(mp);  /* set the previous sequence */
 200
 201         if ((out = creat(drft, m_gmprot())) == NOTOK)
 202                 adios(EX_CANTCREAT, drft, "unable to create");
 203
 204         /* Open form (component) file. */
 205         if (digest) {
 206                 if (issue == 0) {
 207                         snprintf(buf, sizeof(buf), IFORMAT, digest);
 208                         if (volume == 0 && (cp = context_find(buf))
 209                                         && ((issue = atoi(cp)) < 0))
 210                                 issue = 0;
 211                         issue++;
 212                 }
 213                 if (volume == 0) {
 214                         snprintf(buf, sizeof(buf), VFORMAT, digest);
 215                         if ((cp = context_find(buf)) == NULL ||
 216                                         (volume = atoi(cp)) <= 0)
 217                                 volume = 1;
 218                 }
 219                 if (!form)
 220                         form = digestcomps;
 221                 in = build_form(form, digest, volume, issue);
 222                 cpydata(in, out, form, drft);
 223                 close(in);
 224         } else {
 225                 fmtstr = new_fs(form, forwcomps);
 226                 if (write(out, fmtstr, strlen(fmtstr)) != (int)strlen(fmtstr)) {
 227                         adios(EX_IOERR, drft, "error writing");
 228                 }
 229         }
 230         close(out);
 231
 232         add_forw_hdr(drft);
 233
 234         if (digest) {
 235                 snprintf(buf, sizeof(buf), IFORMAT, digest);
 236                 snprintf(value, sizeof(value), "%d", issue);
 237                 context_replace(buf, getcpy(value));
 238                 snprintf(buf, sizeof(buf), VFORMAT, digest);
 239                 snprintf(value, sizeof(value), "%d", volume);
 240                 context_replace(buf, getcpy(value));
 241         }
 242
 243         context_replace(curfolder, folder); /* update current folder */
 244         seq_setcur(mp, mp->lowsel);  /* update current message */
 245         seq_save(mp);  /* synchronize sequences */
 246         context_save();  /* save the context file */
 247
 248         if (buildsw)
 249                 exit(EX_OK);
 250         what_now(ed, NOUSE, drft, NULL, 0, mp,
 251                 anot ? "Forwarded" : NULL, cwd);
 252         return EX_OSERR;
 253 }
 254
 255
 256 /*
 257 ** Create an attachment header for the to be forward messages.
 258 */
 259 static void
 260 add_forw_hdr(char *draft)
 261 {
 262         int msgnum;
 263         char buf[BUFSIZ];
 264         char *vec[MAXARGS];
 265         int vecp = 0;
 266
 267         vec[vecp++] = "anno";
 268         vec[vecp++] = "-append";
 269         vec[vecp++] = "-nodate";
 270         vec[vecp++] = draft;
 271         vec[vecp++] = "-comp";
 272         vec[vecp++] = attach_hdr;
 273         vec[vecp++] = "-text";
 274         snprintf(buf, sizeof buf, "+%s", mp->foldpath);
 275         for (msgnum = mp->lowsel; msgnum <= mp->hghsel; msgnum++) {
 276                 if (!is_selected(mp, msgnum)) {
 277                         continue;
 278                 }
 279                 if (strlen(buf) + 1 + strlen(m_name(msgnum)) + 1
 280                                 > sizeof buf) {
 281                         adios(EX_DATAERR, NULL, "Attachment header line too long. "
 282                                         "Forward less messages.");
 283                 }
 284                 strcat(buf, " ");
 285                 strcat(buf, m_name(msgnum));
 286         }
 287         vec[vecp++] = buf;
 288         vec[vecp] = NULL;
 289         if (execprog(*vec, vec) != 0) {
 290                 advise(NULL, "unable to add attachment header");
 291         }
 292 }
 293
 294
 295 static int
 296 build_form(char *form, char *digest, int volume, int issue)
 297 {
 298         int in;
 299         int fmtsize;
 300         char *fmtstr;
 301         char *line, tmpfil[BUFSIZ];
 302         FILE *tmp;
 303         struct comp *cptr;
 304         struct format *fmt;
 305         int dat[5];
 306         char *cp = NULL;
 307
 308         /* Get new format string */
 309         fmtstr = new_fs(form, NULL);
 310         fmtsize = strlen(fmtstr) + 256;
 311
 312         /* Compile format string */
 313         fmt_compile(fmtstr, &fmt);
 314
 315         FINDCOMP(cptr, "digest");
 316         if (cptr)
 317                 cptr->c_text = digest;
 318         FINDCOMP(cptr, "date");
 319         if (cptr)
 320                 cptr->c_text = getcpy(dtimenow());
 321
 322         dat[0] = issue;
 323         dat[1] = volume;
 324         dat[2] = 0;
 325         dat[3] = fmtsize;
 326         dat[4] = 0;
 327
 328         cp = m_mktemp2(NULL, invo_name, NULL, &tmp);
 329         if (cp == NULL) {
 330                 adios(EX_CANTCREAT, "forw", "unable to create temporary file");
 331         }
 332         strncpy(tmpfil, cp, sizeof(tmpfil));
 333         unlink(tmpfil);
 334         if ((in = dup(fileno(tmp))) == NOTOK)
 335                 adios(EX_OSERR, "dup", "unable to");
 336
 337         line = mh_xmalloc((unsigned) fmtsize);
 338         fmt_scan(fmt, line, fmtsize, dat);
 339         fputs(line, tmp);
 340         free(line);
 341         if (fclose(tmp))
 342                 adios(EX_IOERR, tmpfil, "error writing");
 343
 344         lseek(in, (off_t) 0, SEEK_SET);
 345         return in;
 346 }