summaryrefslogtreecommitdiff
path: root/qmail-lspawn.c
diff options
context:
space:
mode:
Diffstat (limited to 'qmail-lspawn.c')
-rw-r--r--qmail-lspawn.c234
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;
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-06-29 03:14:57 +0000