| 1 | #include <sys/types.h> |
| 2 | #include <sys/stat.h> |
| 3 | #include "direntry.h" |
| 4 | #include "readwrite.h" |
| 5 | #include "getln.h" |
| 6 | #include "substdio.h" |
| 7 | #include "stralloc.h" |
| 8 | #include "slurp.h" |
| 9 | #include "getconf.h" |
| 10 | #include "byte.h" |
| 11 | #include "error.h" |
| 12 | #include "str.h" |
| 13 | #include "strerr.h" |
| 14 | #include "sig.h" |
| 15 | #include "now.h" |
| 16 | #include "datetime.h" |
| 17 | #include "date822fmt.h" |
| 18 | #include "fmt.h" |
| 19 | #include "cookie.h" |
| 20 | #include "qmail.h" |
| 21 | |
| 22 | #define FATAL "ezmlm-warn: fatal: " |
| 23 | void die_usage() { strerr_die1x(100,"ezmlm-warn: usage: ezmlm-warn dir"); } |
| 24 | void die_nomem() { strerr_die2x(111,FATAL,"out of memory"); } |
| 25 | |
| 26 | stralloc key = {0}; |
| 27 | stralloc outhost = {0}; |
| 28 | stralloc outlocal = {0}; |
| 29 | stralloc mailinglist = {0}; |
| 30 | |
| 31 | unsigned long when; |
| 32 | char *dir; |
| 33 | stralloc fn = {0}; |
| 34 | struct stat st; |
| 35 | |
| 36 | void die_read() { strerr_die6sys(111,FATAL,"unable to read ",dir,"/",fn.s,": "); } |
| 37 | |
| 38 | char inbuf[1024]; |
| 39 | substdio ssin; |
| 40 | char textbuf[1024]; |
| 41 | substdio sstext; |
| 42 | |
| 43 | stralloc addr = {0}; |
| 44 | char strnum[FMT_ULONG]; |
| 45 | char hash[COOKIE]; |
| 46 | stralloc fnhash = {0}; |
| 47 | stralloc quoted = {0}; |
| 48 | stralloc line = {0}; |
| 49 | |
| 50 | struct qmail qq; |
| 51 | int qqwrite(fd,buf,len) int fd; char *buf; unsigned int len; |
| 52 | { |
| 53 | qmail_put(&qq,buf,len); |
| 54 | return len; |
| 55 | } |
| 56 | char qqbuf[1]; |
| 57 | substdio ssqq = SUBSTDIO_FDBUF(qqwrite,-1,qqbuf,sizeof(qqbuf)); |
| 58 | struct datetime dt; |
| 59 | char date[DATE822FMT]; |
| 60 | |
| 61 | void copy(fn) |
| 62 | char *fn; |
| 63 | { |
| 64 | int fd; |
| 65 | int match; |
| 66 | |
| 67 | fd = open_read(fn); |
| 68 | if (fd == -1) |
| 69 | strerr_die4sys(111,FATAL,"unable to open ",fn,": "); |
| 70 | |
| 71 | substdio_fdbuf(&sstext,read,fd,textbuf,sizeof(textbuf)); |
| 72 | for (;;) { |
| 73 | if (getln(&sstext,&line,&match,'\n') == -1) |
| 74 | strerr_die4sys(111,FATAL,"unable to read ",fn,": "); |
| 75 | if (!match) |
| 76 | break; |
| 77 | qmail_put(&qq,line.s,line.len); |
| 78 | } |
| 79 | |
| 80 | close(fd); |
| 81 | } |
| 82 | |
| 83 | void doit(flagw) |
| 84 | int flagw; |
| 85 | { |
| 86 | int i; |
| 87 | int fd; |
| 88 | int match; |
| 89 | int fdhash; |
| 90 | datetime_sec msgwhen; |
| 91 | |
| 92 | fd = open_read(fn.s); |
| 93 | if (fd == -1) die_read(); |
| 94 | substdio_fdbuf(&ssin,read,fd,inbuf,sizeof(inbuf)); |
| 95 | |
| 96 | if (getln(&ssin,&addr,&match,'\0') == -1) die_read(); |
| 97 | if (!match) { close(fd); return; } |
| 98 | |
| 99 | if (!issub(addr.s)) { close(fd); /*XXX*/unlink(fn.s); return; } |
| 100 | |
| 101 | cookie(hash,"",0,"",addr.s,""); |
| 102 | if (!stralloc_copys(&fnhash,"bounce/h")) die_nomem(); |
| 103 | if (!stralloc_catb(&fnhash,hash,COOKIE)) die_nomem(); |
| 104 | if (!stralloc_0(&fnhash)) die_nomem(); |
| 105 | |
| 106 | if (qmail_open(&qq) == -1) |
| 107 | strerr_die2sys(111,FATAL,"unable to run qmail-queue: "); |
| 108 | |
| 109 | msgwhen = now(); |
| 110 | qmail_puts(&qq,"Mailing-List: "); |
| 111 | qmail_put(&qq,mailinglist.s,mailinglist.len); |
| 112 | qmail_puts(&qq,"\nDate: "); |
| 113 | datetime_tai(&dt,msgwhen); |
| 114 | qmail_put(&qq,date,date822fmt(date,&dt)); |
| 115 | qmail_puts(&qq,"Message-ID: <"); |
| 116 | qmail_put(&qq,strnum,fmt_ulong(strnum,(unsigned long) msgwhen)); |
| 117 | qmail_puts(&qq,"."); |
| 118 | qmail_put(&qq,strnum,fmt_ulong(strnum,(unsigned long) getpid())); |
| 119 | qmail_puts(&qq,".ezmlm-warn@"); |
| 120 | qmail_put(&qq,outhost.s,outhost.len); |
| 121 | qmail_puts(&qq,">\nFrom: "); |
| 122 | if (!quote("ed,&outlocal)) die_nomem(); |
| 123 | qmail_put(&qq,quoted.s,quoted.len); |
| 124 | qmail_puts(&qq,"-help@"); |
| 125 | qmail_put(&qq,outhost.s,outhost.len); |
| 126 | qmail_puts(&qq,"\nTo: "); |
| 127 | if (!quote2("ed,addr.s)) die_nomem(); |
| 128 | qmail_put(&qq,quoted.s,quoted.len); |
| 129 | qmail_puts(&qq,flagw ? "\nSubject: ezmlm probe\n\n" : "\nSubject: ezmlm warning\n\n"); |
| 130 | |
| 131 | copy("text/top"); |
| 132 | copy(flagw ? "text/bounce-probe" : "text/bounce-warn"); |
| 133 | |
| 134 | if (!flagw) { |
| 135 | fdhash = open_read(fnhash.s); |
| 136 | if (fdhash == -1) { |
| 137 | if (errno != error_noent) |
| 138 | strerr_die6sys(111,FATAL,"unable to open ",dir,"/",fnhash.s,": "); |
| 139 | } |
| 140 | else { |
| 141 | copy("text/bounce-num"); |
| 142 | substdio_fdbuf(&sstext,read,fdhash,textbuf,sizeof(textbuf)); |
| 143 | if (substdio_copy(&ssqq,&sstext) < 0) |
| 144 | strerr_die6sys(111,FATAL,"unable to read ",dir,"/",fnhash.s,": "); |
| 145 | close(fdhash); |
| 146 | } |
| 147 | } |
| 148 | |
| 149 | copy("text/bounce-bottom"); |
| 150 | if (substdio_copy(&ssqq,&ssin) < 0) die_read(); |
| 151 | close(fd); |
| 152 | |
| 153 | strnum[fmt_ulong(strnum,when)] = 0; |
| 154 | cookie(hash,key.s,key.len,strnum,addr.s,flagw ? "P" : "W"); |
| 155 | if (!stralloc_copy(&line,&outlocal)) die_nomem(); |
| 156 | if (!stralloc_cats(&line,flagw ? "-return-probe-" : "-return-warn-")) die_nomem(); |
| 157 | if (!stralloc_cats(&line,strnum)) die_nomem(); |
| 158 | if (!stralloc_cats(&line,".")) die_nomem(); |
| 159 | if (!stralloc_catb(&line,hash,COOKIE)) die_nomem(); |
| 160 | if (!stralloc_cats(&line,"-")) die_nomem(); |
| 161 | i = str_chr(addr.s,'@'); |
| 162 | if (!stralloc_catb(&line,addr.s,i)) die_nomem(); |
| 163 | if (addr.s[i]) { |
| 164 | if (!stralloc_cats(&line,"=")) die_nomem(); |
| 165 | if (!stralloc_cats(&line,addr.s + i + 1)) die_nomem(); |
| 166 | } |
| 167 | if (!stralloc_cats(&line,"@")) die_nomem(); |
| 168 | if (!stralloc_cat(&line,&outhost)) die_nomem(); |
| 169 | if (!stralloc_0(&line)) die_nomem(); |
| 170 | qmail_from(&qq,line.s); |
| 171 | |
| 172 | qmail_to(&qq,addr.s); |
| 173 | if (qmail_close(&qq) != 0) |
| 174 | strerr_die2x(111,FATAL,"temporary qmail-queue error"); |
| 175 | |
| 176 | strnum[fmt_ulong(strnum,qmail_qp(&qq))] = 0; |
| 177 | strerr_warn2("ezmlm-warn: info: qp ",strnum,0); |
| 178 | |
| 179 | if (!flagw) { |
| 180 | if (unlink(fnhash.s) == -1) |
| 181 | if (errno != error_noent) |
| 182 | strerr_die6sys(111,FATAL,"unable to remove ",dir,"/",fnhash.s,": "); |
| 183 | } |
| 184 | if (unlink(fn.s) == -1) |
| 185 | strerr_die6sys(111,FATAL,"unable to remove ",dir,"/",fn.s,": "); |
| 186 | } |
| 187 | |
| 188 | void main(argc,argv) |
| 189 | int argc; |
| 190 | char **argv; |
| 191 | { |
| 192 | DIR *bouncedir; |
| 193 | direntry *d; |
| 194 | unsigned long bouncedate; |
| 195 | int fdlock; |
| 196 | |
| 197 | umask(022); |
| 198 | sig_pipeignore(); |
| 199 | when = (unsigned long) now(); |
| 200 | |
| 201 | dir = argv[1]; |
| 202 | if (!dir) die_usage(); |
| 203 | |
| 204 | if (chdir(dir) == -1) |
| 205 | strerr_die4sys(111,FATAL,"unable to switch to ",dir,": "); |
| 206 | |
| 207 | switch(slurp("key",&key,32)) { |
| 208 | case -1: |
| 209 | strerr_die4sys(111,FATAL,"unable to read ",dir,"/key: "); |
| 210 | case 0: |
| 211 | strerr_die3x(100,FATAL,dir,"/key does not exist"); |
| 212 | } |
| 213 | getconf_line(&outhost,"outhost",1,FATAL,dir); |
| 214 | getconf_line(&outlocal,"outlocal",1,FATAL,dir); |
| 215 | getconf_line(&mailinglist,"mailinglist",1,FATAL,dir); |
| 216 | |
| 217 | fdlock = open_append("lockbounce"); |
| 218 | if (fdlock == -1) |
| 219 | strerr_die4sys(111,FATAL,"unable to open ",dir,"/lockbounce: "); |
| 220 | if (lock_ex(fdlock) == -1) |
| 221 | strerr_die4sys(111,FATAL,"unable to lock ",dir,"/lockbounce: "); |
| 222 | |
| 223 | bouncedir = opendir("bounce"); |
| 224 | if (!bouncedir) |
| 225 | strerr_die4sys(111,FATAL,"unable to open ",dir,"/bounce: "); |
| 226 | |
| 227 | while (d = readdir(bouncedir)) { |
| 228 | if (str_equal(d->d_name,".")) continue; |
| 229 | if (str_equal(d->d_name,"..")) continue; |
| 230 | |
| 231 | if (!stralloc_copys(&fn,"bounce/")) die_nomem(); |
| 232 | if (!stralloc_cats(&fn,d->d_name)) die_nomem(); |
| 233 | if (!stralloc_0(&fn)) die_nomem(); |
| 234 | |
| 235 | if (stat(fn.s,&st) == -1) { |
| 236 | if (errno == error_noent) continue; |
| 237 | strerr_die6sys(111,FATAL,"unable to stat ",dir,"/",fn.s,": "); |
| 238 | } |
| 239 | |
| 240 | if (when > st.st_mtime + 3000000) |
| 241 | if (unlink(fn.s) == -1) |
| 242 | strerr_die6sys(111,FATAL,"unable to remove ",dir,"/",fn.s,": "); |
| 243 | |
| 244 | if ((d->d_name[0] == 'd') || (d->d_name[0] == 'w')) { |
| 245 | scan_ulong(d->d_name + 1,&bouncedate); |
| 246 | if (when > bouncedate + 1000000) |
| 247 | doit(d->d_name[0] == 'w'); |
| 248 | } |
| 249 | } |
| 250 | |
| 251 | closedir(bouncedir); |
| 252 | |
| 253 | _exit(0); |
| 254 | } |