diplodocus.org Git - nmh/blob - uip/distsbr.c

   1 /* distsbr.c -- routines to do additional "dist-style" processing
   2  *
   3  * This code is Copyright (c) 2002, by the authors of nmh.  See the
   4  * COPYRIGHT file in the root directory of the nmh distribution for
   5  * complete copyright information.
   6  */
   7
   8 #include "h/mh.h"
   9 #include "sbr/m_gmprot.h"
  10 #include "sbr/m_getfld.h"
  11 #include "sbr/cpydata.h"
  12 #include "sbr/uprf.h"
  13 #include "sbr/m_backup.h"
  14 #include "sbr/error.h"
  15 #include <fcntl.h>
  16 #include "h/utils.h"
  17 #include "sbr/m_mktemp.h"
  18
  19 static int  hdrfd = NOTOK;
  20 static int  txtfd = NOTOK;
  21
  22 #define BADHDR  "please re-edit %s to remove the ``%s'' header!"
  23 #define BADTXT  "please re-edit %s to consist of headers only!"
  24 #define BADMSG  "please re-edit %s to include a ``Resent-To:''!"
  25 #define BADRFT  "please re-edit %s and fix that header!"
  26
  27 /*
  28  * static prototypes
  29  */
  30 static void ready_msg(char *);
  31
  32 int
  33 distout (char *drft, char *msgnam, char *backup)
  34 {
  35     int state;
  36     char *dp, *resent;
  37     char name[NAMESZ], buffer[NMH_BUFSIZ];
  38     FILE *ifp, *ofp;
  39     m_getfld_state_t gstate;
  40
  41     if (rename (drft, strcpy (backup, m_backup (drft))) == NOTOK)
  42         adios (backup, "unable to rename %s to",drft);
  43     if ((ifp = fopen (backup, "r")) == NULL)
  44         adios (backup, "unable to read");
  45
  46     if ((ofp = fopen (drft, "w")) == NULL)
  47         adios (drft, "unable to create temporary file");
  48     chmod (drft, m_gmprot ());
  49
  50     ready_msg (msgnam);
  51     lseek(hdrfd, 0, SEEK_SET); /* msgnam not accurate */
  52     cpydata (hdrfd, fileno (ofp), msgnam, drft);
  53
  54     gstate = m_getfld_state_init(ifp);
  55     for (resent = NULL;;) {
  56         int buffersz = sizeof buffer;
  57         switch (state = m_getfld2(&gstate, name, buffer, &buffersz)) {
  58             case FLD:
  59             case FLDPLUS:
  60                 if (uprf (name, "distribute-"))
  61                     snprintf (name, sizeof(name), "%s%s", "Resent", &name[10]);
  62                 if (uprf (name, "distribution-"))
  63                     snprintf (name, sizeof(name), "%s%s", "Resent", &name[12]);
  64                 if (!uprf (name, "resent")) {
  65                     inform(BADHDR, "draft", name);
  66                     goto leave_bad;
  67                 }
  68                 if (state == FLD)
  69                     resent = add (":", add (name, resent));
  70                 resent = add (buffer, resent);
  71                 fprintf (ofp, "%s: %s", name, buffer);
  72                 while (state == FLDPLUS) {
  73                     buffersz = sizeof buffer;
  74                     state = m_getfld2(&gstate, name, buffer, &buffersz);
  75                     resent = add (buffer, resent);
  76                     fputs (buffer, ofp);
  77                 }
  78                 break;
  79
  80             case BODY:
  81                 for (dp = buffer; *dp; dp++)
  82                     if (!isspace ((unsigned char) *dp)) {
  83                         inform(BADTXT, "draft");
  84                         goto leave_bad;
  85                     }
  86
  87             case FILEEOF:
  88                 goto process;
  89
  90             case LENERR:
  91             case FMTERR:
  92                 inform(BADRFT, "draft");
  93         leave_bad: ;
  94                 fclose (ifp);
  95                 fclose (ofp);
  96                 (void) m_unlink (drft);
  97                 if (rename (backup, drft) == NOTOK)
  98                     adios (drft, "unable to rename %s to", backup);
  99                 return NOTOK;
 100
 101             default:
 102                 die("getfld() returned %d", state);
 103         }
 104     }
 105 process: ;
 106     m_getfld_state_destroy (&gstate);
 107     fclose (ifp);
 108     fflush (ofp);
 109
 110     if (!resent) {
 111         inform(BADMSG, "draft");
 112         fclose (ofp);
 113         (void) m_unlink (drft);
 114         if (rename (backup, drft) == NOTOK)
 115             adios (drft, "unable to rename %s to", backup);
 116         return NOTOK;
 117     }
 118     free (resent);
 119
 120     if (txtfd != NOTOK) {
 121         lseek(txtfd, 0, SEEK_SET); /* msgnam not accurate */
 122         cpydata (txtfd, fileno (ofp), msgnam, drft);
 123     }
 124
 125     fclose (ofp);
 126
 127     return OK;
 128 }
 129
 130
 131 static void
 132 ready_msg (char *msgnam)
 133 {
 134     int state, out;
 135     char name[NAMESZ], buffer[NMH_BUFSIZ], tmpfil[BUFSIZ];
 136     FILE *ifp, *ofp;
 137     char *cp = NULL;
 138     m_getfld_state_t gstate;
 139
 140     if (hdrfd != NOTOK) {
 141         close (hdrfd);
 142         hdrfd = NOTOK;
 143     }
 144     if (txtfd != NOTOK) {
 145         close (txtfd);
 146         txtfd = NOTOK;
 147     }
 148
 149     if ((ifp = fopen (msgnam, "r")) == NULL)
 150         adios (msgnam, "unable to open message");
 151
 152     cp = m_mktemp2(NULL, "dist", &hdrfd, NULL);
 153     if (cp == NULL) {
 154         die("unable to create temporary file in %s", get_temp_dir());
 155     }
 156     strncpy(tmpfil, cp, sizeof(tmpfil));
 157     if ((out = dup (hdrfd)) == NOTOK
 158             || (ofp = fdopen (out, "w")) == NULL)
 159         die("no file descriptors -- you lose big");
 160     (void) m_unlink (tmpfil);
 161
 162     gstate = m_getfld_state_init(ifp);
 163     for (;;) {
 164         int buffersz = sizeof buffer;
 165         switch (state = m_getfld2(&gstate, name, buffer, &buffersz)) {
 166             case FLD:
 167             case FLDPLUS:
 168                 if (uprf (name, "resent"))
 169                     fprintf (ofp, "Prev-");
 170                 fprintf (ofp, "%s: %s", name, buffer);
 171                 while (state == FLDPLUS) {
 172                     buffersz = sizeof buffer;
 173                     state = m_getfld2(&gstate, name, buffer, &buffersz);
 174                     fputs (buffer, ofp);
 175                 }
 176                 break;
 177
 178             case BODY:
 179                 fclose (ofp);
 180
 181                 cp = m_mktemp2(NULL, "dist", &txtfd, NULL);
 182                 if (cp == NULL) {
 183                     die("unable to create temporary file in %s",
 184                           get_temp_dir());
 185                 }
 186                 fchmod(txtfd, 0600);
 187                 strncpy (tmpfil, cp, sizeof(tmpfil));
 188                 if ((out = dup (txtfd)) == NOTOK
 189                         || (ofp = fdopen (out, "w")) == NULL)
 190                     die("no file descriptors -- you lose big");
 191                 (void) m_unlink (tmpfil);
 192                 fprintf (ofp, "\n%s", buffer);
 193                 while (state == BODY) {
 194                     buffersz = sizeof buffer;
 195                     state = m_getfld2(&gstate, name, buffer, &buffersz);
 196                     fputs (buffer, ofp);
 197                 }
 198             case FILEEOF:
 199                 goto process;
 200
 201             case LENERR:
 202             case FMTERR:
 203                 die("format error in message %s", msgnam);
 204
 205             default:
 206                 die("getfld() returned %d", state);
 207         }
 208     }
 209 process: ;
 210     m_getfld_state_destroy (&gstate);
 211     fclose (ifp);
 212     fclose (ofp);
 213 }