X-Git-Url: https://git.distorted.org.uk/~mdw/ezmlm/blobdiff_plain/5b62e993b0af39700031c2875d7f6654e6a02850..f8beb284087c279acfb30506f5bb32baa4949b44:/ezmlm-split.c

diff --git a/ezmlm-split.c b/ezmlm-split.c
new file mode 100644
index 0000000..f115358
--- /dev/null
+++ b/ezmlm-split.c
@@ -0,0 +1,316 @@
+/*$Id: ezmlm-split.c,v 1.6 1999/05/12 22:17:54 lindberg Exp $*/
+/*$Name: ezmlm-idx-040 $*/
+
+#include <sys/types.h>
+#include <sys/stat.h>
+#include "error.h"
+#include "stralloc.h"
+#include "str.h"
+#include "env.h"
+#include "sig.h"
+#include "slurp.h"
+#include "getconf.h"
+#include "strerr.h"
+#include "byte.h"
+#include "getln.h"
+#include "case.h"
+#include "qmail.h"
+#include "substdio.h"
+#include "readwrite.h"
+#include "quote.h"
+#include "now.h"
+#include "uint32.h"
+#include "fmt.h"
+#include "errtxt.h"
+#include "idx.h"
+
+#define FATAL "ezmlm-split: fatal: "
+#define INFO "ezmlm-split: info: "
+
+int flagdo = 1;		/* default is manager function */
+
+char *sender;
+char *split;
+stralloc outhost = {0};
+stralloc inlocal = {0};
+stralloc outlocal = {0};
+stralloc target = {0};
+stralloc lctarget = {0};
+stralloc line = {0};
+stralloc domain = {0};
+stralloc name = {0};
+stralloc from = {0};
+stralloc to = {0};
+char strnum[FMT_ULONG];
+unsigned long lineno;
+int flagfound;
+
+void die_usage() {
+  strerr_die1x(100,"ezmlm-split: usage: ezmlm-split [-dD] dir [splitfile]"); }
+
+void die_nomem() { strerr_die2x(111,FATAL,ERR_NOMEM); }
+
+void die_badaddr()
+{
+  strerr_die2x(100,FATAL,ERR_BAD_ADDRESS);
+}
+
+void die_syntax()
+{
+  strnum[fmt_ulong(strnum,lineno)] = '\0';
+  strerr_die6x(111,FATAL,split," syntax error line ",strnum,": ",line.s);
+}
+
+char spbuf[1024];	/* should normally hold entire file */
+substdio sssp;
+
+struct qmail qq;
+int qqwrite(fd,buf,len) int fd; char *buf; unsigned int len;
+{
+  qmail_put(&qq,buf,len);
+  return (int) len;
+}
+char qqbuf[1];
+substdio ssqq = SUBSTDIO_FDBUF(qqwrite,-1,qqbuf,(int) sizeof(qqbuf));
+
+char outbuf[1];
+substdio ssout = SUBSTDIO_FDBUF(write,1,outbuf,(int) sizeof(outbuf));
+
+char inbuf[1024];
+substdio ssin = SUBSTDIO_FDBUF(read,0,inbuf,(int) sizeof(inbuf));
+
+int findname()
+/* returns 1 if a matching line was found, 0 otherwise. name will contain */
+/* the correct list address in either case */
+{
+  char *cpat,*cp,*cpname,*cp1,*cp2,*cplast;
+  unsigned long u;
+  uint32 h;
+  unsigned char hash,hash_hi,hash_lo;
+  unsigned int pos,pos_name,pos_hi;
+  char ch;
+  int fd,match;
+
+  /* make case insensitive hash */
+  flagfound = 0;			/* default */
+  cpname = "";				/* default */
+  if (!stralloc_copy(&lctarget,&target)) die_nomem();
+  case_lowerb(lctarget.s,lctarget.len -1);
+  h = 5381;
+  cp = lctarget.s;
+  while ((ch = *cp++)) {
+    h = (h + (h << 5)) ^ (uint32) ch;
+  }
+  hash = (h % 53);
+
+  /* make domain pointer */
+  cpat = lctarget.s + str_chr(lctarget.s,'@');
+  if (!*cpat)
+    strerr_die4x(100,FATAL,ERR_ADDR_AT,": ",target.s);
+  cplast = cpat + str_len(cpat) - 1;
+  if (*cplast == '.') --cplast;		/* annonying special case */
+  cp1 = cpat + byte_rchr(cpat,cplast - cpat, '.');
+  if (cp1 != cplast) {			/* got one '.' */
+    if (!stralloc_copyb(&domain,cp1 + 1, cplast - cp1)) die_nomem();
+    cp2 = cpat + byte_rchr(cpat, cp1 - cpat,'.');
+    if (cp2 == cp1) cp2 = cpat;
+    ++cp2;
+    if (!stralloc_append(&domain,".")) die_nomem();
+    if (!stralloc_catb(&domain,cp2, cp1 - cp2)) die_nomem();
+  } else				/* no '.' */
+    if (!stralloc_copyb(&domain,cpat + 1,cplast - cpat)) die_nomem();
+  if (!stralloc_0(&domain)) die_nomem();
+
+  if ((fd = open_read(split)) == -1)
+    strerr_die4sys(111,FATAL,ERR_OPEN,split,": ");
+  substdio_fdbuf(&sssp,read,fd,spbuf,(int) sizeof(spbuf));
+  lineno = 0;
+  for (;;) {	/* dom:hash_lo:hash_hi:listaddress */
+    if (getln(&sssp,&line,&match,'\n') == -1)
+      strerr_die4sys(111,FATAL,ERR_READ,split,": ");
+     lineno++;
+    if (!match)
+      break;
+    if (line.s[0] == '#') continue;	/* comment */
+    line.s[line.len - 1] = '\0';	/* no need to allow \0 in lines */
+    if (!line.s[pos = str_chr(line.s,':')])
+      continue;				/* usually blank line */
+    line.s[pos] = '\0';
+    if (pos == 0 ||			/* no domain */
+	  (case_starts(domain.s,line.s))) {	/* or matching domain */
+	if (!line.s[++pos]) die_syntax();
+	pos_hi = pos + str_chr(line.s + pos,':');
+	if (!line.s[pos_hi]) die_syntax();
+	pos_hi++;
+	(void) scan_ulong(line.s + pos, &u);	/* scan_uint() not in ezmlm */
+	hash_lo = (unsigned char) u;
+	(void) scan_ulong(line.s + pos_hi, &u);
+	hash_hi = (unsigned char) u;
+	pos_name = pos_hi + str_chr(line.s + pos_hi,':');
+	if (pos_hi == pos_name) hash_hi = 52L;	/* default hi = 52 */
+	if (line.s[pos_name]) pos_name++;
+	if (hash > hash_hi || hash < hash_lo) continue;	/* not us */
+	cpname = line.s + pos_name;
+	while (*cpname &&				/* isolate name */
+	    (*cpname == ' ' || *cpname == '\t')) cpname++;
+	pos = line.len - 2;
+	while (pos && (line.s[pos] == '\n' || line.s[pos] == ' ' ||
+		line.s[pos] == '\t')) line.s[pos--] = '\0';
+	break;
+    }
+  }
+  close(fd);
+
+  if (*cpname) {
+    if (!stralloc_copys(&name,cpname)) die_nomem();
+    if (byte_chr(name.s,name.len,'@') == name.len) {	/* local sublist */
+      if (!stralloc_append(&name,"@")) die_nomem();
+      if (!stralloc_cat(&name,&outhost)) die_nomem();
+    }
+    if (!stralloc_0(&name)) die_nomem();
+    return 1;
+  } else {			/* match without name or no match =>this list */
+    if (!stralloc_copy(&name,&outlocal)) die_nomem();
+    if (!stralloc_append(&name,"@")) die_nomem();
+    if (!stralloc_cat(&name,&outhost)) die_nomem();
+    if (!stralloc_0(&name)) die_nomem();
+    return 0;
+  }
+}
+
+void main(argc,argv)
+int argc;
+char **argv;
+{
+  char *dir;
+  char *local;
+  char *action;
+  char *def;
+  char *dtline;
+  char *nhost;
+  char *err;
+  unsigned int i;
+  int match;
+  int optind = 1;
+
+  sig_pipeignore();
+
+  dir = argv[optind++];
+  if (!dir) die_usage();
+  if (dir[0] == '-') {
+    if (dir[1] == 'd') flagdo = 1;
+    else if (dir[1] == 'D') flagdo = 0;
+    else die_usage();
+    if (!(dir = argv[optind++])) die_usage();
+  }
+  if (!(split = argv[optind]))
+    split = "split";
+
+  if (chdir(dir) == -1)
+    strerr_die4sys(111,FATAL,ERR_SWITCH,dir,": ");
+
+  getconf_line(&outhost,"outhost",1,FATAL,dir);
+  getconf_line(&outlocal,"outlocal",1,FATAL,dir);
+
+  if (flagdo) {
+    sender = env_get("SENDER");
+    if (!sender) strerr_die2x(100,FATAL,ERR_NOSENDER);
+    if (!*sender)
+      strerr_die2x(100,FATAL,ERR_BOUNCE);
+    if (!sender[str_chr(sender,'@')])
+      strerr_die2x(100,FATAL,ERR_ANONYMOUS);
+    if (str_equal(sender,"#@[]"))
+      strerr_die2x(100,FATAL,ERR_BOUNCE);
+
+    def = env_get("DEFAULT");
+    if (def) {
+      action = def;
+    } else {
+      local = env_get("LOCAL");
+      if (!local) strerr_die2x(100,FATAL,ERR_NOLOCAL);
+      getconf_line(&inlocal,"inlocal",1,FATAL,dir);
+      if (inlocal.len > str_len(local)) die_badaddr();
+      if (case_diffb(inlocal.s,inlocal.len,local)) die_badaddr();
+      action = local + inlocal.len + 1;
+    }
+    if (!stralloc_copys(&target,sender)) die_nomem();
+    if (action[0]) {
+      i = str_chr(action,'-');
+      if (action[i]) {
+        action[i] = '\0';
+        if (!stralloc_copys(&target,action + i + 1)) die_nomem();
+        i = byte_rchr(target.s,target.len,'=');
+        if (i < target.len)
+	  target.s[i] = '@';
+      }
+    }
+    if (!stralloc_0(&target)) die_nomem();
+
+    if (case_diffs(action,ACTION_SUBSCRIBE) &&
+      case_diffs(action,ALT_SUBSCRIBE) &&
+      case_diffs(action,ACTION_UNSUBSCRIBE) &&
+      case_diffs(action,ALT_UNSUBSCRIBE))
+    _exit(0);			/* not for us */
+
+    if (findname()) {
+				/* new sender */
+      if (!stralloc_copy(&from,&outlocal)) die_nomem();
+      if (!stralloc_cats(&from,"-return-@")) die_nomem();
+      if (!stralloc_cat(&from,&outhost)) die_nomem();
+      if (!stralloc_0(&from)) die_nomem();
+      if (name.s[i = str_rchr(name.s,'@')]) {		/* name must have '@'*/
+	nhost = name.s + i;
+	*(nhost++) = '\0';
+      }
+      if (!stralloc_copys(&to,name.s)) die_nomem();	/* local */
+      if (!stralloc_append(&to,"-")) die_nomem();	/* - */
+      if (!stralloc_cats(&to,action)) die_nomem();	/* subscribe */
+      if (!stralloc_append(&to,"-")) die_nomem();	/* - */
+      if (target.s[i = str_rchr(target.s,'@')])
+	target.s[i] = '=';
+      if (!stralloc_cats(&to,target.s)) die_nomem();	/* target */
+      if (!stralloc_append(&to,"@")) die_nomem();	/* - */
+      if (!stralloc_cats(&to,nhost)) die_nomem();	/* host */
+      if (!stralloc_0(&to)) die_nomem();
+      dtline = env_get("DTLINE");
+      if (!dtline) strerr_die2x(100,FATAL,ERR_NODTLINE);
+
+      if (qmail_open(&qq,(stralloc *) 0) == -1)
+        strerr_die2sys(111,FATAL,ERR_QMAIL_QUEUE);
+      qmail_puts(&qq,dtline);				/* delivered-to */
+      if (substdio_copy(&ssqq,&ssin) != 0)
+        strerr_die2sys(111,FATAL,ERR_READ_INPUT);
+      qmail_from(&qq,from.s);
+      qmail_to(&qq,to.s);
+
+      if (*(err = qmail_close(&qq)) != '\0')
+        strerr_die3x(111,FATAL,ERR_TMP_QMAIL_QUEUE,err + 1);
+
+      strnum[fmt_ulong(strnum,qmail_qp(&qq))] = 0;
+      strerr_die3x(99,INFO,"qp ",strnum);
+    }
+    _exit(0);
+  } else {
+
+    for (;;) {
+      if (getln(&ssin,&line,&match,'\n') == -1)
+	  strerr_die2sys(111,FATAL,ERR_READ_INPUT);
+      if (!match) break;
+      if (line.len == 1) continue;	/* ignore blank lines */
+      if (line.s[0] == '#') continue;	/* ignore comments */
+      if (!stralloc_copy(&target,&line)) die_nomem();
+      target.s[target.len - 1] = '\0';
+      (void) findname();
+      if (!stralloc_cats(&name,": ")) die_nomem();
+      if (!stralloc_cats(&name,target.s)) die_nomem();
+      if (!stralloc_append(&name,"\n")) die_nomem();
+      if (substdio_put(&ssout,name.s,name.len) == -1)
+	strerr_die2sys(111,ERR_WRITE,"output: ");
+    }
+    if (substdio_flush(&ssout) == -1)
+      strerr_die2sys(111,ERR_FLUSH,"output: ");
+    _exit(0);
+  }
+}
+
+