X-Git-Url: http://git.marmaro.de/?p=mmh;a=blobdiff_plain;f=uip%2Fsend.c;h=d7691db99a332a57c9ddc6322303cc6371b7bd91;hp=d1a183e5a3c3cc9e39e9bedc609c86495cb8af0f;hb=6e9577f324bef90765a5edc02044eb111ec48072;hpb=51cb63baa791f6ba84c0a7f8538ecfd00b013bcb diff --git a/uip/send.c b/uip/send.c index d1a183e..d7691db 100644 --- a/uip/send.c +++ b/uip/send.c @@ -1,455 +1,726 @@ /* - * send.c -- send a composed message - * - * This code is Copyright (c) 2002, by the authors of nmh. See the - * COPYRIGHT file in the root directory of the nmh distribution for - * complete copyright information. - */ +** send.c -- send a composed message +** +** This code is Copyright (c) 2002, by the authors of nmh. See the +** COPYRIGHT file in the root directory of the nmh distribution for +** complete copyright information. +*/ #include #include #include #include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#ifdef HAVE_SYS_TIME_H +# include +#endif +#include + +#ifdef HAVE_SYS_PARAM_H +# include +#endif + +int debugsw = 0; /* global */ +char *altmsg = NULL; +char *annotext = NULL; +char *distfile = NULL; + +/* name of temp file for body content */ +static char body_file_name[MAXPATHLEN + 1]; +/* name of mhbuild composition temporary file */ +static char composition_file_name[MAXPATHLEN + 1]; +static int field_size; /* size of header field buffer */ +static char *field; /* header field buffer */ +static FILE *draft_file; /* draft file pointer */ +static FILE *body_file; /* body file pointer */ +static FILE *composition_file; /* composition file pointer */ + +/* +** static prototypes +*/ +static int sendsbr(char **, int, char *, struct stat *); +static void anno(struct stat *); +static int sendaux(char **, int, char *, struct stat *); +static int attach(char *); +static int signandenc(char *); +static void clean_up_temporary_files(void); +static int get_line(void); +static void make_mime_composition_file_entry(char *); +static char* strexit(int status); static struct swit switches[] = { -#define ALIASW 0 - { "alias aliasfile", 0 }, -#define DEBUGSW 1 +#define DEBUGSW 0 { "debug", -5 }, -#define DRAFTSW 2 - { "draft", 0 }, -#define DFOLDSW 3 - { "draftfolder +folder", 6 }, -#define DMSGSW 4 - { "draftmessage msg", 6 }, -#define NDFLDSW 5 - { "nodraftfolder", 0 }, -#define FILTSW 6 - { "filter filterfile", 0 }, -#define NFILTSW 7 - { "nofilter", 0 }, -#define FRMTSW 8 - { "format", 0 }, -#define NFRMTSW 9 - { "noformat", 0 }, -#define FORWSW 10 - { "forward", 0 }, -#define NFORWSW 11 - { "noforward", 0 }, -#define MIMESW 12 - { "mime", 0 }, -#define NMIMESW 13 - { "nomime", 0 }, -#define MSGDSW 14 - { "msgid", 0 }, -#define NMSGDSW 15 - { "nomsgid", 0 }, -#define PUSHSW 16 - { "push", 0 }, -#define NPUSHSW 17 - { "nopush", 0 }, -#define UNIQSW 19 - { "unique", -6 }, -#define NUNIQSW 20 - { "nounique", -8 }, -#define VERBSW 21 +#define VERBSW 1 { "verbose", 0 }, -#define NVERBSW 22 - { "noverbose", 0 }, -#define WATCSW 23 - { "watch", 0 }, -#define NWATCSW 24 - { "nowatch", 0 }, -#define WIDTHSW 25 - { "width columns", 0 }, -#define VERSIONSW 26 - { "version", 0 }, -#define HELPSW 27 +#define NVERBSW 2 + { "noverbose", 2 }, +#define VERSIONSW 3 + { "Version", 0 }, +#define HELPSW 4 { "help", 0 }, -#define BITSTUFFSW 28 - { "dashstuffing", -12 }, -#define NBITSTUFFSW 29 - { "nodashstuffing", -14 }, -#define MAILSW 30 - { "mail", -4 }, -#define SAMLSW 31 - { "saml", -4 }, -#define SENDSW 32 - { "send", -4 }, -#define SOMLSW 33 - { "soml", -4 }, -#define CLIESW 34 - { "client host", -6 }, -#define SERVSW 35 - { "server host", 6 }, -#define SNOOPSW 36 - { "snoop", 5 }, -#define ATTACHSW 40 - { "attach", 6 }, -#define ATTACHFORMATSW 41 - { "attachformat", 7 }, -#define PORTSW 42 - { "port server-port-name/number" , 4 }, { NULL, 0 } }; -static struct swit anyl[] = { -#define NOSW 0 - { "no", 0 }, -#define YESW 1 - { "yes", 0 }, -#define LISTDSW 2 - { "list", 0 }, - { NULL, 0 } -}; - -extern int debugsw; /* from sendsbr.c */ -extern int forwsw; -extern int inplace; -extern int pushsw; -extern int unique; -extern int verbsw; - -extern char *altmsg; /* .. */ -extern char *annotext; -extern char *distfile; - +char *version=VERSION; int -main (int argc, char **argv) +main(int argc, char **argv) { - int msgp = 0, distsw = 0, vecp = 1; - int isdf = 0, mime = 0; + int nmsgs = 0, nfiles = 0, distsw = 0, vecp = 1; int msgnum, status; - char *cp, *dfolder = NULL, *maildir = NULL; - char buf[BUFSIZ], **ap, **argp, **arguments; + int in, out; + int n; + char *cp, *maildir = NULL, *folder = NULL; + char buf[BUFSIZ], **argp, **arguments; char *msgs[MAXARGS], *vec[MAXARGS]; + char *files[MAXARGS]; struct msgs *mp; struct stat st; - char *attach = (char *)0; /* header field name for attachments */ - int attachformat = 0; /* mhbuild format specifier for attachments */ -#ifdef UCI - FILE *fp; -#endif /* UCI */ + struct stat st2; -#ifdef LOCALE setlocale(LC_ALL, ""); -#endif - invo_name = r1bindex (argv[0], '/'); + invo_name = mhbasename(argv[0]); /* read user profile/context */ context_read(); - arguments = getarguments (invo_name, argc, argv, 1); + arguments = getarguments(invo_name, argc, argv, 1); argp = arguments; - vec[vecp++] = "-library"; - vec[vecp++] = getcpy (m_maildir ("")); - while ((cp = *argp++)) { if (*cp == '-') { - switch (smatch (++cp, switches)) { - case AMBIGSW: - ambigsw (cp, switches); - done (1); - case UNKWNSW: - adios (NULL, "-%s unknown\n", cp); - - case HELPSW: - snprintf (buf, sizeof(buf), "%s [file] [switches]", invo_name); - print_help (buf, switches, 1); - done (1); - case VERSIONSW: - print_version(invo_name); - done (1); - - case DRAFTSW: - msgs[msgp++] = draft; - continue; - - case DFOLDSW: - if (dfolder) - adios (NULL, "only one draft folder at a time!"); - if (!(cp = *argp++) || *cp == '-') - adios (NULL, "missing argument to %s", argp[-2]); - dfolder = path (*cp == '+' || *cp == '@' ? cp + 1 : cp, - *cp != '@' ? TFOLDER : TSUBCWF); - continue; - case DMSGSW: - if (!(cp = *argp++) || *cp == '-') - adios (NULL, "missing argument to %s", argp[-2]); - msgs[msgp++] = cp; - continue; - case NDFLDSW: - dfolder = NULL; - isdf = NOTOK; - continue; - - case PUSHSW: - pushsw++; - continue; - case NPUSHSW: - pushsw = 0; - continue; - - case UNIQSW: - unique++; - continue; - case NUNIQSW: - unique = 0; - continue; - - case FORWSW: - forwsw++; - continue; - case NFORWSW: - forwsw = 0; - continue; - - case VERBSW: - verbsw++; - vec[vecp++] = --cp; - continue; - case NVERBSW: - verbsw = 0; - vec[vecp++] = --cp; - continue; - - case MIMESW: - mime++; - vec[vecp++] = --cp; - continue; - case NMIMESW: - mime = 0; - vec[vecp++] = --cp; - continue; - - case DEBUGSW: - debugsw++; /* fall */ - case NFILTSW: - case FRMTSW: - case NFRMTSW: - case BITSTUFFSW: - case NBITSTUFFSW: - case MSGDSW: - case NMSGDSW: - case WATCSW: - case NWATCSW: - case MAILSW: - case SAMLSW: - case SENDSW: - case SOMLSW: - case SNOOPSW: - vec[vecp++] = --cp; - continue; - - case ALIASW: - case FILTSW: - case WIDTHSW: - case CLIESW: - case SERVSW: - case PORTSW: - vec[vecp++] = --cp; - if (!(cp = *argp++) || *cp == '-') - adios (NULL, "missing argument to %s", argp[-2]); - vec[vecp++] = cp; - continue; - - case ATTACHSW: - if (!(attach = *argp++) || *attach == '-') - adios (NULL, "missing argument to %s", argp[-2]); - continue; - - case ATTACHFORMATSW: - if (! *argp || **argp == '-') - adios (NULL, "missing argument to %s", argp[-1]); - else { - attachformat = atoi (*argp); - if (attachformat < 0 || - attachformat > ATTACHFORMATS - 1) { - advise (NULL, "unsupported attachformat %d", - attachformat); - continue; - } - } - ++argp; - continue; + switch (smatch(++cp, switches)) { + case AMBIGSW: + ambigsw(cp, switches); + exit(EX_USAGE); + case UNKWNSW: + adios(EX_USAGE, NULL, "-%s unknown\n", cp); + + case HELPSW: + snprintf(buf, sizeof(buf), + "%s [file] [switches]", + invo_name); + print_help(buf, switches, 1); + exit(argc == 2 ? EX_OK : EX_USAGE); + case VERSIONSW: + print_version(invo_name); + exit(argc == 2 ? EX_OK : EX_USAGE); + + case DEBUGSW: + debugsw++; + /* fall */ + case VERBSW: + case NVERBSW: + vec[vecp++] = --cp; + continue; + } + } else if (*cp == '+' || *cp == '@') { + if (folder) { + adios(EX_USAGE, NULL, "only one folder at a time!"); + } else { + folder = mh_xstrdup(expandfol(cp)); } } else { - msgs[msgp++] = cp; + if (*cp == '/') { + files[nfiles++] = cp; + } else { + msgs[nmsgs++] = cp; + } } } - /* - * check for "Aliasfile:" profile entry - */ - if ((cp = context_find ("Aliasfile"))) { - char *dp = NULL; - - for (ap = brkstring(dp = getcpy(cp), " ", "\n"); ap && *ap; ap++) { - vec[vecp++] = "-alias"; - vec[vecp++] = *ap; - } + if (!nmsgs && !nfiles) { + msgs[nmsgs++] = seq_cur; } - if (dfolder == NULL) { - if (msgp == 0) { -#ifdef WHATNOW - if ((cp = getenv ("mhdraft")) && *cp) { - msgs[msgp++] = cp; - goto go_to_it; - } -#endif /* WHATNOW */ - msgs[msgp++] = getcpy (m_draft (NULL, NULL, 1, &isdf)); - if (stat (msgs[0], &st) == NOTOK) - adios (msgs[0], "unable to stat draft file"); - cp = concat ("Use \"", msgs[0], "\"? ", NULL); - for (status = LISTDSW; status != YESW;) { - if (!(argp = getans (cp, anyl))) - done (1); - switch (status = smatch (*argp, anyl)) { - case NOSW: - done (0); - case YESW: - break; - case LISTDSW: - showfile (++argp, msgs[0]); - break; - default: - advise (NULL, "say what?"); - break; - } + if (nmsgs) { + folder = folder ? folder : draftfolder; + maildir = toabsdir(folder); + if (chdir(maildir) == NOTOK) { + adios(EX_OSERR, maildir, "unable to change directory to"); + } + if (!(mp = folder_read(folder))) { + adios(EX_IOERR, NULL, "unable to read folder %s", + folder); + } + if (mp->nummsg == 0) { + adios(EX_DATAERR, NULL, "no messages in folder %s", + folder); + } + /* parse all the msgranges/sequences and set SELECTED */ + for (msgnum = 0; msgnum < nmsgs; msgnum++) { + if (!m_convert(mp, msgs[msgnum])) { + exit(EX_USAGE); } - } else { - for (msgnum = 0; msgnum < msgp; msgnum++) - msgs[msgnum] = getcpy (m_maildir (msgs[msgnum])); } - } else { - if (!context_find ("path")) - free (path ("./", TFOLDER)); - - if (!msgp) - msgs[msgp++] = "cur"; - maildir = m_maildir (dfolder); - - if (chdir (maildir) == NOTOK) - adios (maildir, "unable to change directory to"); - - /* read folder and create message structure */ - if (!(mp = folder_read (dfolder))) - adios (NULL, "unable to read folder %s", dfolder); - - /* check for empty folder */ - if (mp->nummsg == 0) - adios (NULL, "no messages in %s", dfolder); - - /* parse all the message ranges/sequences and set SELECTED */ - for (msgnum = 0; msgnum < msgp; msgnum++) - if (!m_convert (mp, msgs[msgnum])) - done (1); - seq_setprev (mp); /* set the previous-sequence */ - - for (msgp = 0, msgnum = mp->lowsel; msgnum <= mp->hghsel; msgnum++) { - if (is_selected (mp, msgnum)) { - msgs[msgp++] = getcpy (m_name (msgnum)); - unset_exists (mp, msgnum); + seq_setprev(mp); + + for (nmsgs = 0, msgnum = mp->lowsel; + msgnum <= mp->hghsel; msgnum++) { + if (is_selected(mp, msgnum)) { + files[nfiles++] = mh_xstrdup(m_name(msgnum)); + unset_exists(mp, msgnum); } } mp->msgflags |= SEQMOD; - seq_save (mp); - } - -#ifdef WHATNOW -go_to_it: -#endif /* WHATNOW */ - - if ((cp = getenv ("SIGNATURE")) == NULL || *cp == 0) - if ((cp = context_find ("signature")) && *cp) - m_putenv ("SIGNATURE", cp); -#ifdef UCI - else { - snprintf (buf, sizeof(buf), "%s/.signature", mypath); - if ((fp = fopen (buf, "r")) != NULL - && fgets (buf, sizeof buf, fp) != NULL) { - fclose (fp); - if (cp = strchr (buf, '\n')) - *cp = 0; - m_putenv ("SIGNATURE", buf); - } + seq_save(mp); + } + + if (!(cp = getenv("SIGNATURE")) || !*cp) { + if ((cp = context_find("signature")) && *cp) { + m_putenv("SIGNATURE", cp); } -#endif /* UCI */ + } - for (msgnum = 0; msgnum < msgp; msgnum++) - if (stat (msgs[msgnum], &st) == NOTOK) - adios (msgs[msgnum], "unable to stat draft file"); + for (n = 0; n < nfiles; n++) { + if (stat(files[n], &st) == NOTOK) { + adios(EX_IOERR, files[n], "unable to stat draft file"); + } + } - if ((annotext = getenv ("mhannotate")) == NULL || *annotext == 0) + if (!(annotext = getenv("mhannotate")) || !*annotext) { annotext = NULL; - if (annotext && ((cp = getenv ("mhinplace")) != NULL && *cp != 0)) - inplace = atoi (cp); - if ((altmsg = getenv ("mhaltmsg")) == NULL || *altmsg == 0) + } + if (!(altmsg = getenv("mhaltmsg")) || !*altmsg) { altmsg = NULL; /* used by dist interface - see below */ + } - if ((cp = getenv ("mhdist")) - && *cp - && (distsw = atoi (cp)) - && altmsg) { + if ((cp = getenv("mhdist")) && *cp && (distsw = atoi(cp)) && altmsg) { vec[vecp++] = "-dist"; - distfile = getcpy (m_mktemp2 (altmsg, invo_name, NULL, NULL)); - if (link (altmsg, distfile) == NOTOK) { - if (errno != EXDEV -#ifdef EISREMOTE - && errno != EISREMOTE -#endif /* EISREMOTE */ - ) - adios (distfile, "unable to link %s to", altmsg); - free (distfile); - distfile = getcpy (m_mktemp2(NULL, invo_name, NULL, NULL)); - { - int in, out; - struct stat st; - - if ((in = open (altmsg, O_RDONLY)) == NOTOK) - adios (altmsg, "unable to open"); - fstat(in, &st); - if ((out = creat (distfile, (int) st.st_mode & 0777)) == NOTOK) - adios (distfile, "unable to write"); - cpydata (in, out, altmsg, distfile); - close (in); - close (out); - } + if ((in = open(altmsg, O_RDONLY)) == NOTOK) { + adios(EX_IOERR, altmsg, "unable to open for reading"); + } + fstat(in, &st2); + distfile = mh_xstrdup(m_mktemp2(NULL, invo_name, NULL, NULL)); + if ((out = creat(distfile, (int)st2.st_mode & 0777))==NOTOK) { + adios(EX_IOERR, distfile, "unable to open for writing"); } + cpydata(in, out, altmsg, distfile); + close(in); + close(out); } else { distfile = NULL; } - if (altmsg == NULL || stat (altmsg, &st) == NOTOK) { + if (!altmsg || stat(altmsg, &st) == NOTOK) { st.st_mtime = 0; st.st_dev = 0; st.st_ino = 0; } - if (pushsw) - push (); - status = 0; - vec[0] = r1bindex (postproc, '/'); - closefds (3); - - for (msgnum = 0; msgnum < msgp; msgnum++) { - switch (sendsbr (vec, vecp, msgs[msgnum], &st, 1, attach, - attachformat)) { - case DONE: - done (++status); - case NOTOK: - status++; /* fall */ - case OK: - break; + vec[0] = "spost"; + for (n=3; n= field_size - 1) { + field = mh_xrealloc(field, field_size += 256); + p = field + n - 1; + } + } + *p = '\0'; + + return (c); +} + +static void +make_mime_composition_file_entry(char *file_name) +{ + FILE *fp; + struct node *np; + char *cp; + char content_type[BUFSIZ]; + char cmdbuf[BUFSIZ]; + char *cmd = mimetypequeryproc; + int semicolon = 0; + + for (np = m_defs; np; np = np->n_next) { + if (strcasecmp(np->n_name, mimetypequery)==0) { + cmd = np->n_field; + break; + } + } + snprintf(cmdbuf, sizeof cmdbuf, "%s %s", cmd, file_name); + + if (!(fp = popen(cmdbuf, "r"))) { + clean_up_temporary_files(); + adios(EX_IOERR, NULL, "unable to determine content type with `%s'", + cmdbuf); + } + if (fgets(content_type, sizeof content_type, fp) && + (cp = strrchr(content_type, '\n'))) { + *cp = '\0'; + } else { + strcpy(content_type, "application/octet-stream"); + admonish(NULL, "problems with `%s', using fall back type `%s'", + cmdbuf, content_type); + } + pclose(fp); + + /* TODO: don't use access(2) because it checks for ruid, not euid */ + if (access(file_name, R_OK) != 0) { + clean_up_temporary_files(); + adios(EX_IOERR, NULL, "unable to access file `%s'", file_name); + } + + /* Check for broken file(1). See man page mh-profile(5). */ + for (cp=content_type; *cp; cp++) { + if (isspace(*cp)) { + if (!semicolon) { + adios(EX_SOFTWARE, NULL, "Sorry, your Mime-Type-Query command (%s) is broken.\n\tThe output misses a semicolon before the whitespace.\n\tOutput was: %s", cmd, content_type); + } + } else if (*cp == ';') { + semicolon = 1; + } else { + semicolon = 0; + } + } + + cp = (!(cp = strrchr(file_name, '/'))) ? file_name : cp + 1; + fprintf(composition_file, + "#%s; name=\"%s\" <> [%s] {attachment} %s\n", + content_type, cp, cp, file_name); + + return; +} + +/* +** The back-end of the message sending back-end. +** Annotate original message, and call `spost' to send message. +*/ +static int +sendaux(char **vec, int vecp, char *drft, struct stat *st) +{ + pid_t child_id; + int status; + char backup[BUFSIZ]; + + vec[vecp++] = drft; + if (distfile && distout(drft, distfile, backup) == NOTOK) { + return DONE; + } + vec[vecp] = NULL; + + switch (child_id = fork()) { + case -1: + /* oops -- fork error */ + advise("fork", "unable to"); + return DONE; + + case 0: + /* child process -- send it */ + execvp(*vec, vec); + fprintf(stderr, "unable to exec "); + perror(*vec); + _exit(EX_OSERR); + break; /* NOT REACHED */ + + default: + /* parent process -- wait for it */ + status = pidwait(child_id, NOTOK); + if (WIFEXITED(status) && WEXITSTATUS(status) == EX_OK) { + if (annotext) { + anno(st); + } + } else { + /* spost failed */ + advise(NULL, "%s", strexit(status)); + if (distfile) { + unlink(drft); + if (rename(backup, drft) == NOTOK) { + advise(drft, "unable to rename %s to", + backup); + } + } + } + } + + return status ? NOTOK : status; +} + + +static void +anno(struct stat *st) +{ + struct stat st2; + char *msgs, *folder; + char buf[BUFSIZ]; + char *vec[MAXARGS]; + int vecp = 0; + char *cp, *dp; + + if (altmsg && (stat(altmsg, &st2) == NOTOK || + st->st_mtime != st2.st_mtime || + st->st_dev != st2.st_dev || + st->st_ino != st2.st_ino)) { + if (debugsw) { + admonish(NULL, "$mhaltmsg mismatch"); + } + return; + } + + if (!(folder = getenv("mhfolder")) || !*folder) { + if (debugsw) { + admonish(NULL, "$mhfolder not set"); + } + return; + } + if (!(msgs = getenv("mhmessages")) || !*msgs) { + if (debugsw) { + admonish(NULL, "$mhmessages not set"); + } + return; + } + if (debugsw) { + advise(NULL, "annotate as `%s': %s %s", annotext, + folder, msgs); + } + vec[vecp++] = "anno"; + vec[vecp++] = "-comp"; + vec[vecp++] = annotext; + snprintf(buf, sizeof buf, "+%s", folder); + vec[vecp++] = buf; + + while (isspace(*msgs)) { + msgs++; + } + for (cp=dp=msgs; *cp; cp++) { + if (isspace(*cp)) { + while (isspace(*cp)) { + *cp++ = '\0'; + } + vec[vecp++] = dp; + dp = cp; + } + } + vec[vecp++] = dp; + vec[vecp] = NULL; + if (execprog(*vec, vec) != 0) { + advise(NULL, "unable to annotate"); + } +} + + +char* +strexit(int status) +{ + if (WIFSIGNALED(status)) { + return "spost or sendmail killed by signal"; + } + if (!WIFEXITED(status)) { + return "message not delivered to anyone"; + } + switch (WEXITSTATUS(status)) { + case EX_TEMPFAIL: + return "Temporary error, maybe the MTA has queued the message"; + default: + return "message not delivered to anyone"; + } }