X-Git-Url: https://diplodocus.org/git/nmh/blobdiff_plain/8e7da2908d70b96ee25587a6b6eb28cb84fb8459..ef0725fd97369e801a56febfdb7a6ec2eaff73c8:/uip/replsbr.c?ds=sidebyside diff --git a/uip/replsbr.c b/uip/replsbr.c index 6a906b44..ed5e94ed 100644 --- a/uip/replsbr.c +++ b/uip/replsbr.c @@ -1,22 +1,33 @@ - -/* - * replsbr.c -- routines to help repl along... +/* replsbr.c -- routines to help repl along... * * 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 /* L_SET */ - -extern short ccto; /* from repl.c */ -extern short cccc; -extern short ccme; -extern short querysw; +#include "h/mh.h" +#include "sbr/fmt_new.h" +#include "sbr/m_name.h" +#include "sbr/m_gmprot.h" +#include "sbr/m_getfld.h" +#include "sbr/read_switch.h" +#include "sbr/concat.h" +#include "sbr/uprf.h" +#include "sbr/escape_addresses.h" +#include "sbr/pidstatus.h" +#include "sbr/arglist.h" +#include "sbr/error.h" +#include "h/addrsbr.h" +#include "h/fmt_scan.h" +#include "h/done.h" +#include "h/utils.h" +#include +#include "replsbr.h" + +short ccto = -1; +short cccc = -1; +short ccme = -1; +short querysw = 0; static int dftype=0; @@ -24,16 +35,7 @@ static char *badaddrs = NULL; static char *dfhost = NULL; static struct mailname mq; -static int nodupcheck = 0; /* If set, no check for duplicates */ - -/* - * Buffer size for content part of header fields. - * We want this to be large enough so that we don't - * do a lot of extra FLDPLUS calls on m_getfld but - * small enough so that we don't snarf the entire - * message body when we're not going to use any of it. - */ -#define SBUFSIZ 256 +static bool nodupcheck; /* If set, no check for duplicates */ static char *addrcomps[] = { "from", @@ -65,15 +67,16 @@ void replout (FILE *inb, char *msg, char *drft, struct msgs *mp, int outputlinelen, int mime, char *form, char *filter, char *fcc, int fmtproc) { - register int state, i; - register struct comp *cptr; - char tmpbuf[SBUFSIZ]; + int state, i; + struct comp *cptr; + char tmpbuf[NMH_BUFSIZ]; struct format *fmt; - register char **ap; + char **ap; int char_read = 0, format_len, mask; - char name[NAMESZ], *scanl, *cp; + char name[NAMESZ], *cp; + charstring_t scanl; static int dat[5]; /* aux. data for format routine */ - m_getfld_state_t gstate = 0; + m_getfld_state_t gstate; struct fmt_callbacks cb; FILE *out; @@ -103,30 +106,16 @@ replout (FILE *inb, char *msg, char *drft, struct msgs *mp, int outputlinelen, * * This prevents the component from being found via fmt_findcomp(), * which makes sure no text gets added to it when the message is processed. - * - * getcpy(NULL) returns a malloc'd zero-length string, so it can safely - * be free()'d later. */ if (!ccto) { cptr = fmt_findcomp ("to"); if (cptr) - cptr->c_name = getcpy(NULL); + cptr->c_name = mh_xstrdup(""); } if (!cccc) { cptr = fmt_findcomp("cc"); if (cptr) - cptr->c_name = getcpy(NULL); - } - /* set up the "fcc" pseudo-component */ - if (fcc) { - cptr = fmt_findcomp ("fcc"); - if (cptr) - cptr->c_text = getcpy (fcc); - } - if ((cp = getenv("USER"))) { - cptr = fmt_findcomp ("user"); - if (cptr) - cptr->c_text = getcpy(cp); + cptr->c_name = mh_xstrdup(""); } if (!ccme) ismymbox (NULL); @@ -134,12 +123,13 @@ replout (FILE *inb, char *msg, char *drft, struct msgs *mp, int outputlinelen, /* * pick any interesting stuff out of msg "inb" */ + gstate = m_getfld_state_init(inb); for (;;) { int msg_count = sizeof tmpbuf; - state = m_getfld (&gstate, name, tmpbuf, &msg_count, inb); + state = m_getfld2(&gstate, name, tmpbuf, &msg_count); switch (state) { - case FLD: - case FLDPLUS: + case FLD: + case FLDPLUS: /* * if we're interested in this component, save a pointer * to the component text, then start using our next free @@ -152,7 +142,7 @@ replout (FILE *inb, char *msg, char *drft, struct msgs *mp, int outputlinelen, char_read += msg_count; while (state == FLDPLUS) { msg_count= sizeof tmpbuf; - state = m_getfld (&gstate, name, tmpbuf, &msg_count, inb); + state = m_getfld2(&gstate, name, tmpbuf, &msg_count); fmt_appendcomp(i, name, tmpbuf); char_read += msg_count; } @@ -160,18 +150,18 @@ replout (FILE *inb, char *msg, char *drft, struct msgs *mp, int outputlinelen, while (state == FLDPLUS) { msg_count= sizeof tmpbuf; - state = m_getfld (&gstate, name, tmpbuf, &msg_count, inb); + state = m_getfld2(&gstate, name, tmpbuf, &msg_count); } break; - case LENERR: - case FMTERR: - case BODY: + case LENERR: + case FMTERR: + case BODY: case FILEEOF: goto finished; - default: - adios (NULL, "m_getfld() returned %d", state); + default: + die("m_getfld2() returned %d", state); } } @@ -181,12 +171,30 @@ replout (FILE *inb, char *msg, char *drft, struct msgs *mp, int outputlinelen, finished: m_getfld_state_destroy (&gstate); + /* set up the "fcc" pseudo-component */ + cptr = fmt_findcomp ("fcc"); + if (cptr) { + free(cptr->c_text); + if (fcc) + cptr->c_text = mh_xstrdup(fcc); + else + cptr->c_text = NULL; + } + cptr = fmt_findcomp ("user"); + if (cptr) { + free(cptr->c_text); + if ((cp = getenv("USER"))) + cptr->c_text = mh_xstrdup(cp); + else + cptr = NULL; + } + /* * if there's a "Subject" component, strip any "Re:"s off it */ cptr = fmt_findcomp ("subject"); if (cptr && (cp = cptr->c_text)) { - register char *sp = cp; + char *sp = cp; for (;;) { while (isspace((unsigned char) *cp)) @@ -199,22 +207,22 @@ finished: } if (sp != cptr->c_text) { cp = cptr->c_text; - cptr->c_text = getcpy (sp); + cptr->c_text = mh_xstrdup(sp); free (cp); } } i = format_len + char_read + 256; - scanl = mh_xmalloc ((size_t) i + 2); + scanl = charstring_create (i + 2); dat[0] = 0; dat[1] = 0; dat[2] = 0; dat[3] = outputlinelen; dat[4] = 0; - memset(&cb, 0, sizeof(cb)); + ZERO(&cb); cb.formataddr = replformataddr; cb.concataddr = replconcataddr; - fmt_scan (fmt, scanl, i + 1, i, dat, &cb); - fputs (scanl, out); + fmt_scan (fmt, scanl, i, dat, &cb); + fputs (charstring_buffer (scanl), out); if (badaddrs) { fputs ("\nrepl: bad addresses:\n", out); fputs ( badaddrs, out); @@ -241,7 +249,7 @@ finished: fclose (out); /* return dynamically allocated buffers */ - free (scanl); + charstring_free (scanl); fmt_free(fmt, 1); } @@ -284,13 +292,13 @@ static unsigned int bufsiz=0; /* current size of buf */ static char * replformataddr (char *orig, char *str) { - register int len; - char baddr[BUFSIZ], error[BUFSIZ]; - register int isgroup; - register char *dst; - register char *cp; - register char *sp; - register struct mailname *mp = NULL; + int len; + char baddr[BUFSIZ+6], error[BUFSIZ]; + bool isgroup; + char *dst; + char *cp; + char *sp; + struct mailname *mp = NULL; char *fixed_str = fix_addresses (str); /* if we don't have a buffer yet, get one */ @@ -316,7 +324,7 @@ replformataddr (char *orig, char *str) } /* concatenate all the new addresses onto 'buf' */ - for (isgroup = 0; (cp = getname (fixed_str)); ) { + for (isgroup = false; (cp = getname (fixed_str)); ) { if ((mp = getm (cp, dfhost, dftype, error, sizeof(error))) == NULL) { snprintf (baddr, sizeof(baddr), "\t%s -- %s\n", cp, error); badaddrs = add (baddr, badaddrs); @@ -324,7 +332,7 @@ replformataddr (char *orig, char *str) } if (isgroup && (mp->m_gname || !mp->m_ingrp)) { *dst++ = ';'; - isgroup = 0; + isgroup = false; } if (insert (mp)) { /* if we get here we're going to add an address */ @@ -335,7 +343,7 @@ replformataddr (char *orig, char *str) if (mp->m_gname) { CHECKMEM (mp->m_gname); CPY (mp->m_gname); - isgroup++; + isgroup = true; } sp = adrformat (mp); CHECKMEM (sp); @@ -350,7 +358,7 @@ replformataddr (char *orig, char *str) *dst = '\0'; last_dst = dst; - return (buf); + return buf; } @@ -371,9 +379,9 @@ replconcataddr(char *orig, char *str) { char *cp; - nodupcheck = 1; + nodupcheck = true; cp = replformataddr(orig, str); - nodupcheck = 0; + nodupcheck = false; return cp; } @@ -381,7 +389,7 @@ static int insert (struct mailname *np) { char buffer[BUFSIZ]; - register struct mailname *mp; + struct mailname *mp; if (nodupcheck) return 1; @@ -390,10 +398,10 @@ insert (struct mailname *np) return 0; for (mp = &mq; mp->m_next; mp = mp->m_next) { - if (!strcasecmp (np->m_host ? np->m_host : "", - mp->m_next->m_host ? mp->m_next->m_host : "") && - !strcasecmp (np->m_mbox ? np->m_mbox : "", - mp->m_next->m_mbox ? mp->m_next->m_mbox : "")) + if (!strcasecmp (FENDNULL(np->m_host), + FENDNULL(mp->m_next->m_host)) && + !strcasecmp (FENDNULL(np->m_mbox), + FENDNULL(mp->m_next->m_mbox))) return 0; } if (!ccme && ismymbox (np)) @@ -401,7 +409,7 @@ insert (struct mailname *np) if (querysw) { snprintf (buffer, sizeof(buffer), "Reply to %s? ", adrformat (np)); - if (!gans (buffer, anoyes)) + if (!read_switch (buffer, anoyes)) return 0; } mp->m_next = np; @@ -432,18 +440,17 @@ replfilter (FILE *in, FILE *out, char *filter, int fmtproc) adios (filter, "unable to read"); rewind (in); - lseek (fileno(in), (off_t) 0, SEEK_SET); + lseek(fileno(in), 0, SEEK_SET); arglist = argsplit(mhlproc, &mhl, &argnum); switch (pid = fork()) { - case NOTOK: + case NOTOK: adios ("fork", "unable to"); - case OK: + case OK: dup2 (fileno (in), fileno (stdin)); dup2 (fileno (out), fileno (stdout)); - closefds (3); /* * We're not allocating the memory for the extra arguments, @@ -468,27 +475,30 @@ replfilter (FILE *in, FILE *out, char *filter, int fmtproc) execvp (mhl, arglist); errstr = strerror(errno); - write(2, "unable to exec ", 15); - write(2, mhlproc, strlen(mhlproc)); - write(2, ": ", 2); - write(2, errstr, strlen(errstr)); - write(2, "\n", 1); - _exit (-1); - - default: + if (write(2, "unable to exec ", 15) < 0 || + write(2, mhlproc, strlen(mhlproc)) < 0 || + write(2, ": ", 2) < 0 || + write(2, errstr, strlen(errstr)) < 0 || + write(2, "\n", 1) < 0) { + advise ("stderr", "write"); + } + _exit(1); + + default: if (pidXwait (pid, mhl)) done (1); fseek (out, 0L, SEEK_END); + arglist_free(mhl, arglist); break; } } -static -char * -fix_addresses (char *str) { +static char * +fix_addresses (char *str) +{ char *fixed_str = NULL; - int fixed_address = 0; + bool fixed_address = false; if (str) { /* @@ -513,11 +523,12 @@ fix_addresses (char *str) { * local part. */ while ((cp = getname (str))) { - struct adr_node *adr_nodep = mh_xmalloc (sizeof *adr_nodep); + struct adr_node *adr_nodep; char error[BUFSIZ]; struct mailname *mp; - adr_nodep->adr = strdup (cp); + NEW(adr_nodep); + adr_nodep->adr = mh_xstrdup (cp); adr_nodep->escape_local_part = 0; adr_nodep->fixed = 0; adr_nodep->next = NULL; @@ -528,7 +539,7 @@ fix_addresses (char *str) { const char *no_at_sign = "no at-sign after local-part"; adr_nodep->escape_local_part = - ! strncmp (error, no_at_sign, strlen (no_at_sign)); + has_prefix(error, no_at_sign); } else { mnfree (mp); } @@ -544,12 +555,12 @@ fix_addresses (char *str) { * Walk the list and try to fix broken addresses. */ for (np = adrs; np; np = np->next) { - char *display_name = strdup (np->adr); + char *display_name = mh_xstrdup (np->adr); size_t len = strlen (display_name); if (np->escape_local_part) { char *local_part_end = strrchr (display_name, '<'); - char *angle_addr = strdup (local_part_end); + char *angle_addr = mh_xstrdup (local_part_end); struct mailname *mp; char *new_adr, *adr; @@ -564,13 +575,13 @@ fix_addresses (char *str) { adr = getname (new_adr); if (adr != NULL && (mp = getm (adr, dfhost, dftype, NULL, 0)) != NULL) { - fixed_address = 1; + fixed_address = true; mnfree (mp); } free (angle_addr); free (new_adr); free (np->adr); - np->adr = strdup (adr); + np->adr = mh_xstrdup (adr); /* Need to flush getname() */ while ((cp = getname (""))) continue; @@ -593,7 +604,7 @@ fix_addresses (char *str) { free (fixed_str); fixed_str = new_str; } else { - fixed_str = strdup (np->adr); + fixed_str = mh_xstrdup (np->adr); } } @@ -605,8 +616,7 @@ fix_addresses (char *str) { if (fixed_address) { return fixed_str; - } else { - free (fixed_str); - return str ? strdup (str) : NULL; } + free (fixed_str); + return str ? mh_xstrdup (str) : NULL; }