qmail 1.03 import

1 files changed, 234 insertions, 0 deletions

diff --git a/qmail-lspawn.c b/qmail-lspawn.c
new file mode 100644
index 0000000..5109cc3
--- /dev/null
+++ b/qmail-lspawn.c
@@ -0,0 +1,234 @@
+#include "fd.h"
+#include "wait.h"
+#include "prot.h"
+#include "substdio.h"
+#include "stralloc.h"
+#include "scan.h"
+#include "exit.h"
+#include "fork.h"
+#include "error.h"
+#include "cdb.h"
+#include "case.h"
+#include "slurpclose.h"
+#include "auto_qmail.h"
+#include "auto_uids.h"
+#include "qlx.h"
+
+char *aliasempty;
+
+void initialize(argc,argv)
+int argc;
+char **argv;
+{
+  aliasempty = argv[1];
+  if (!aliasempty) _exit(100);
+}
+
+int truncreport = 3000;
+
+void report(ss,wstat,s,len)
+substdio *ss;
+int wstat;
+char *s;
+int len;
+{
+ int i;
+ if (wait_crashed(wstat))
+  { substdio_puts(ss,"Zqmail-local crashed.\n"); return; }
+ switch(wait_exitcode(wstat))
+  {
+   case QLX_CDB:
+     substdio_puts(ss,"ZTrouble reading users/cdb in qmail-lspawn.\n"); return;
+   case QLX_NOMEM:
+     substdio_puts(ss,"ZOut of memory in qmail-lspawn.\n"); return;
+   case QLX_SYS:
+     substdio_puts(ss,"ZTemporary failure in qmail-lspawn.\n"); return;
+   case QLX_NOALIAS:
+     substdio_puts(ss,"ZUnable to find alias user!\n"); return;
+   case QLX_ROOT:
+     substdio_puts(ss,"ZNot allowed to perform deliveries as root.\n"); return;
+   case QLX_USAGE:
+     substdio_puts(ss,"ZInternal qmail-lspawn bug.\n"); return;
+   case QLX_NFS:
+     substdio_puts(ss,"ZNFS failure in qmail-local.\n"); return;
+   case QLX_EXECHARD:
+     substdio_puts(ss,"DUnable to run qmail-local.\n"); return;
+   case QLX_EXECSOFT:
+     substdio_puts(ss,"ZUnable to run qmail-local.\n"); return;
+   case QLX_EXECPW:
+     substdio_puts(ss,"ZUnable to run qmail-getpw.\n"); return;
+   case 111: case 71: case 74: case 75:
+     substdio_put(ss,"Z",1); break;
+   case 0:
+     substdio_put(ss,"K",1); break;
+   case 100:
+   default:
+     substdio_put(ss,"D",1); break;
+  }
+
+ for (i = 0;i < len;++i) if (!s[i]) break;
+ substdio_put(ss,s,i);
+}
+
+stralloc lower = {0};
+stralloc nughde = {0};
+stralloc wildchars = {0};
+
+void nughde_get(local)
+char *local;
+{
+ char *(args[3]);
+ int pi[2];
+ int gpwpid;
+ int gpwstat;
+ int r;
+ int fd;
+ int flagwild;
+
+ if (!stralloc_copys(&lower,"!")) _exit(QLX_NOMEM);
+ if (!stralloc_cats(&lower,local)) _exit(QLX_NOMEM);
+ if (!stralloc_0(&lower)) _exit(QLX_NOMEM);
+ case_lowerb(lower.s,lower.len);
+
+ if (!stralloc_copys(&nughde,"")) _exit(QLX_NOMEM);
+
+ fd = open_read("users/cdb");
+ if (fd == -1)
+   if (errno != error_noent)
+     _exit(QLX_CDB);
+
+ if (fd != -1)
+  {
+   uint32 dlen;
+   unsigned int i;
+
+   r = cdb_seek(fd,"",0,&dlen);
+   if (r != 1) _exit(QLX_CDB);
+   if (!stralloc_ready(&wildchars,(unsigned int) dlen)) _exit(QLX_NOMEM);
+   wildchars.len = dlen;
+   if (cdb_bread(fd,wildchars.s,wildchars.len) == -1) _exit(QLX_CDB);
+
+   i = lower.len;
+   flagwild = 0;
+
+   do
+    {
+     /* i > 0 */
+     if (!flagwild || (i == 1) || (byte_chr(wildchars.s,wildchars.len,lower.s[i - 1]) < wildchars.len))
+      {
+       r = cdb_seek(fd,lower.s,i,&dlen);
+       if (r == -1) _exit(QLX_CDB);
+       if (r == 1)
+        {
+         if (!stralloc_ready(&nughde,(unsigned int) dlen)) _exit(QLX_NOMEM);
+         nughde.len = dlen;
+         if (cdb_bread(fd,nughde.s,nughde.len) == -1) _exit(QLX_CDB);
+         if (flagwild)
+           if (!stralloc_cats(&nughde,local + i - 1)) _exit(QLX_NOMEM);
+         if (!stralloc_0(&nughde)) _exit(QLX_NOMEM);
+         close(fd);
+         return;
+        }
+      }
+     --i;
+     flagwild = 1;
+    }
+   while (i);
+
+   close(fd);
+  }
+
+ if (pipe(pi) == -1) _exit(QLX_SYS);
+ args[0] = "bin/qmail-getpw";
+ args[1] = local;
+ args[2] = 0;
+ switch(gpwpid = vfork())
+  {
+   case -1:
+     _exit(QLX_SYS);
+   case 0:
+     if (prot_gid(auto_gidn) == -1) _exit(QLX_USAGE);
+     if (prot_uid(auto_uidp) == -1) _exit(QLX_USAGE);
+     close(pi[0]);
+     if (fd_move(1,pi[1]) == -1) _exit(QLX_SYS);
+     execv(*args,args);
+     _exit(QLX_EXECPW);
+  }
+ close(pi[1]);
+
+ if (slurpclose(pi[0],&nughde,128) == -1) _exit(QLX_SYS);
+
+ if (wait_pid(&gpwstat,gpwpid) != -1)
+  {
+   if (wait_crashed(gpwstat)) _exit(QLX_SYS);
+   if (wait_exitcode(gpwstat) != 0) _exit(wait_exitcode(gpwstat));
+  }
+}
+
+int spawn(fdmess,fdout,s,r,at)
+int fdmess; int fdout;
+char *s; char *r; int at;
+{
+ int f;
+
+ if (!(f = fork()))
+  {
+   char *(args[11]);
+   unsigned long u;
+   int n;
+   int uid;
+   int gid;
+   char *x;
+   unsigned int xlen;
+   
+   r[at] = 0;
+   if (!r[0]) _exit(0); /* <> */
+
+   if (chdir(auto_qmail) == -1) _exit(QLX_USAGE);
+
+   nughde_get(r);
+
+   x = nughde.s;
+   xlen = nughde.len;
+
+   args[0] = "bin/qmail-local";
+   args[1] = "--";
+   args[2] = x;
+   n = byte_chr(x,xlen,0); if (n++ == xlen) _exit(QLX_USAGE); x += n; xlen -= n;
+
+   scan_ulong(x,&u);
+   uid = u;
+   n = byte_chr(x,xlen,0); if (n++ == xlen) _exit(QLX_USAGE); x += n; xlen -= n;
+
+   scan_ulong(x,&u);
+   gid = u;
+   n = byte_chr(x,xlen,0); if (n++ == xlen) _exit(QLX_USAGE); x += n; xlen -= n;
+
+   args[3] = x;
+   n = byte_chr(x,xlen,0); if (n++ == xlen) _exit(QLX_USAGE); x += n; xlen -= n;
+
+   args[4] = r;
+   args[5] = x;
+   n = byte_chr(x,xlen,0); if (n++ == xlen) _exit(QLX_USAGE); x += n; xlen -= n;
+
+   args[6] = x;
+   n = byte_chr(x,xlen,0); if (n++ == xlen) _exit(QLX_USAGE); x += n; xlen -= n;
+
+   args[7] = r + at + 1;
+   args[8] = s;
+   args[9] = aliasempty;
+   args[10] = 0;
+
+   if (fd_move(0,fdmess) == -1) _exit(QLX_SYS);
+   if (fd_move(1,fdout) == -1) _exit(QLX_SYS);
+   if (fd_copy(2,1) == -1) _exit(QLX_SYS);
+   if (prot_gid(gid) == -1) _exit(QLX_USAGE);
+   if (prot_uid(uid) == -1) _exit(QLX_USAGE);
+   if (!getuid()) _exit(QLX_ROOT);
+
+   execv(*args,args);
+   if (error_temp(errno)) _exit(QLX_EXECSOFT);
+   _exit(QLX_EXECHARD);
+  }
+ return f;
+}