1 #include <sys/types.h>
2 #include <sys/stat.h>
3 #include "readwrite.h"
4 #include "sig.h"
5 #include "exit.h"
6 #include "open.h"
7 #include "seek.h"
8 #include "fmt.h"
9 #include "alloc.h"
10 #include "substdio.h"
11 #include "datetime.h"
12 #include "now.h"
13 #include "triggerpull.h"
14 #include "extra.h"
15 #include "auto_qmail.h"
16 #include "auto_uids.h"
17 #include "date822fmt.h"
18 #include "fmtqfn.h"
19
20 #define DEATH 86400 /* 24 hours; _must_ be below q-s's OSSIFIED (36 hours) */
21 #define ADDR 1003
22
23 char inbuf[2048];
24 struct substdio ssin;
25 char outbuf[256];
26 struct substdio ssout;
27
28 datetime_sec starttime;
29 struct datetime dt;
30 unsigned long mypid;
31 unsigned long uid;
32 char *pidfn;
33 struct stat pidst;
34 unsigned long messnum;
35 char *messfn;
36 char *todofn;
37 char *intdfn;
38 int messfd;
39 int intdfd;
40 int flagmademess = 0;
41 int flagmadeintd = 0;
42
cleanup()43 void cleanup()
44 {
45 if (flagmadeintd)
46 {
47 seek_trunc(intdfd,0);
48 if (unlink(intdfn) == -1) return;
49 }
50 if (flagmademess)
51 {
52 seek_trunc(messfd,0);
53 if (unlink(messfn) == -1) return;
54 }
55 }
56
die(e)57 void die(e) int e; { _exit(e); }
die_write()58 void die_write() { cleanup(); die(53); }
die_read()59 void die_read() { cleanup(); die(54); }
sigalrm()60 void sigalrm() { /* thou shalt not clean up here */ die(52); }
sigbug()61 void sigbug() { die(81); }
62
63 unsigned int receivedlen;
64 char *received;
65 /* "Received: (qmail-queue invoked by alias); 26 Sep 1995 04:46:54 -0000\n" */
66
receivedfmt(s)67 static unsigned int receivedfmt(s)
68 char *s;
69 {
70 unsigned int i;
71 unsigned int len;
72 len = 0;
73 i = fmt_str(s,"Received: (qmail "); len += i; if (s) s += i;
74 i = fmt_ulong(s,mypid); len += i; if (s) s += i;
75 i = fmt_str(s," invoked "); len += i; if (s) s += i;
76 if (uid == auto_uida)
77 { i = fmt_str(s,"by alias"); len += i; if (s) s += i; }
78 else if (uid == auto_uidd)
79 { i = fmt_str(s,"from network"); len += i; if (s) s += i; }
80 else if (uid == auto_uids)
81 { i = fmt_str(s,"for bounce"); len += i; if (s) s += i; }
82 else
83 {
84 i = fmt_str(s,"by uid "); len += i; if (s) s += i;
85 i = fmt_ulong(s,uid); len += i; if (s) s += i;
86 }
87 i = fmt_str(s,"); "); len += i; if (s) s += i;
88 i = date822fmt(s,&dt); len += i; if (s) s += i;
89 return len;
90 }
91
received_setup()92 void received_setup()
93 {
94 receivedlen = receivedfmt((char *) 0);
95 received = alloc(receivedlen + 1);
96 if (!received) die(51);
97 receivedfmt(received);
98 }
99
pidfmt(s,seq)100 unsigned int pidfmt(s,seq)
101 char *s;
102 unsigned long seq;
103 {
104 unsigned int i;
105 unsigned int len;
106
107 len = 0;
108 i = fmt_str(s,"pid/"); len += i; if (s) s += i;
109 i = fmt_ulong(s,mypid); len += i; if (s) s += i;
110 i = fmt_str(s,"."); len += i; if (s) s += i;
111 i = fmt_ulong(s,starttime); len += i; if (s) s += i;
112 i = fmt_str(s,"."); len += i; if (s) s += i;
113 i = fmt_ulong(s,seq); len += i; if (s) s += i;
114 ++len; if (s) *s++ = 0;
115
116 return len;
117 }
118
fnnum(dirslash,flagsplit)119 char *fnnum(dirslash,flagsplit)
120 char *dirslash;
121 int flagsplit;
122 {
123 char *s;
124
125 s = alloc(fmtqfn((char *) 0,dirslash,messnum,flagsplit));
126 if (!s) die(51);
127 fmtqfn(s,dirslash,messnum,flagsplit);
128 return s;
129 }
130
pidopen()131 void pidopen()
132 {
133 unsigned int len;
134 unsigned long seq;
135
136 seq = 1;
137 len = pidfmt((char *) 0,seq);
138 pidfn = alloc(len);
139 if (!pidfn) die(51);
140
141 for (seq = 1;seq < 10;++seq)
142 {
143 if (pidfmt((char *) 0,seq) > len) die(81); /* paranoia */
144 pidfmt(pidfn,seq);
145 messfd = open_excl(pidfn);
146 if (messfd != -1) return;
147 }
148
149 die(63);
150 }
151
152 char tmp[FMT_ULONG];
153
main()154 int main()
155 {
156 unsigned int len;
157 char ch;
158
159 sig_blocknone();
160 umask(033);
161 if (chdir(auto_qmail) == -1) die(61);
162 if (chdir("queue") == -1) die(62);
163
164 mypid = getpid();
165 uid = getuid();
166 starttime = now();
167 datetime_tai(&dt,starttime);
168
169 received_setup();
170
171 sig_pipeignore();
172 sig_miscignore();
173 sig_alarmcatch(sigalrm);
174 sig_bugcatch(sigbug);
175
176 alarm(DEATH);
177
178 pidopen();
179 if (fstat(messfd,&pidst) == -1) die(63);
180
181 messnum = pidst.st_ino;
182 messfn = fnnum("mess/",1);
183 todofn = fnnum("todo/",0);
184 intdfn = fnnum("intd/",0);
185
186 if (link(pidfn,messfn) == -1) die(64);
187 if (unlink(pidfn) == -1) die(63);
188 flagmademess = 1;
189
190 substdio_fdbuf(&ssout,write,messfd,outbuf,sizeof(outbuf));
191 substdio_fdbuf(&ssin,read,0,inbuf,sizeof(inbuf));
192
193 if (substdio_bput(&ssout,received,receivedlen) == -1) die_write();
194
195 switch(substdio_copy(&ssout,&ssin))
196 {
197 case -2: die_read();
198 case -3: die_write();
199 }
200
201 if (substdio_flush(&ssout) == -1) die_write();
202 if (fsync(messfd) == -1) die_write();
203
204 intdfd = open_excl(intdfn);
205 if (intdfd == -1) die(65);
206 flagmadeintd = 1;
207
208 substdio_fdbuf(&ssout,write,intdfd,outbuf,sizeof(outbuf));
209 substdio_fdbuf(&ssin,read,1,inbuf,sizeof(inbuf));
210
211 if (substdio_bput(&ssout,"u",1) == -1) die_write();
212 if (substdio_bput(&ssout,tmp,fmt_ulong(tmp,uid)) == -1) die_write();
213 if (substdio_bput(&ssout,"",1) == -1) die_write();
214
215 if (substdio_bput(&ssout,"p",1) == -1) die_write();
216 if (substdio_bput(&ssout,tmp,fmt_ulong(tmp,mypid)) == -1) die_write();
217 if (substdio_bput(&ssout,"",1) == -1) die_write();
218
219 if (substdio_get(&ssin,&ch,1) < 1) die_read();
220 if (ch != 'F') die(91);
221 if (substdio_bput(&ssout,&ch,1) == -1) die_write();
222 for (len = 0;len < ADDR;++len)
223 {
224 if (substdio_get(&ssin,&ch,1) < 1) die_read();
225 if (substdio_put(&ssout,&ch,1) == -1) die_write();
226 if (!ch) break;
227 }
228 if (len >= ADDR) die(11);
229
230 if (substdio_bput(&ssout,QUEUE_EXTRA,QUEUE_EXTRALEN) == -1) die_write();
231
232 for (;;)
233 {
234 if (substdio_get(&ssin,&ch,1) < 1) die_read();
235 if (!ch) break;
236 if (ch != 'T') die(91);
237 if (substdio_bput(&ssout,&ch,1) == -1) die_write();
238 for (len = 0;len < ADDR;++len)
239 {
240 if (substdio_get(&ssin,&ch,1) < 1) die_read();
241 if (substdio_bput(&ssout,&ch,1) == -1) die_write();
242 if (!ch) break;
243 }
244 if (len >= ADDR) die(11);
245 }
246
247 if (substdio_flush(&ssout) == -1) die_write();
248 if (fsync(intdfd) == -1) die_write();
249
250 if (link(intdfn,todofn) == -1) die(66);
251
252 triggerpull();
253 die(0);
254 }
255