2 #include <sys/socket.h>
3 #include <netinet/in.h>
12 #include "auto_qmail.h"
20 #include "gen_alloc.h"
21 #include "gen_allocdefs.h"
27 #include "readwrite.h"
28 #include "timeoutconn.h"
29 #include "timeoutread.h"
30 #include "timeoutwrite.h"
32 #define HUGESMTPTEXT 5000
34 #define PORT_SMTP 25 /* silly rabbit, /etc/services is for users */
35 unsigned long port
= PORT_SMTP
;
37 GEN_ALLOC_typedef(saa
,stralloc
,sa
,len
,a
)
38 GEN_ALLOC_readyplus(saa
,stralloc
,sa
,len
,a
,i
,n
,x
,10,saa_readyplus
)
39 static stralloc sauninit
= {0};
41 stralloc helohost
= {0};
42 stralloc routes
= {0};
43 struct constmap maproutes
;
45 stralloc sender
= {0};
49 struct ip_address partner
;
51 void out(s
) char *s
; { if (substdio_puts(subfdoutsmall
,s
) == -1) _exit(0); }
52 void zero() { if (substdio_put(subfdoutsmall
,"\0",1) == -1) _exit(0); }
53 void zerodie() { zero(); substdio_flush(subfdoutsmall
); _exit(0); }
54 void outsafe(sa
) stralloc
*sa
; { int i
; char ch
;
55 for (i
= 0;i
< sa
->len
;++i
) {
56 ch
= sa
->s
[i
]; if (ch
< 33) ch
= '?'; if (ch
> 126) ch
= '?';
57 if (substdio_put(subfdoutsmall
,&ch
,1) == -1) _exit(0); } }
59 void temp_nomem() { out("ZOut of memory. (#4.3.0)\n"); zerodie(); }
60 void temp_oserr() { out("Z\
61 System resources temporarily unavailable. (#4.3.0)\n"); zerodie(); }
62 void temp_noconn() { out("Z\
63 Sorry, I wasn't able to establish an SMTP connection. (#4.4.1)\n"); zerodie(); }
64 void temp_read() { out("ZUnable to read message. (#4.3.0)\n"); zerodie(); }
65 void temp_dnscanon() { out("Z\
66 CNAME lookup failed temporarily. (#4.4.3)\n"); zerodie(); }
67 void temp_dns() { out("Z\
68 Sorry, I couldn't find any host by that name. (#4.1.2)\n"); zerodie(); }
69 void temp_chdir() { out("Z\
70 Unable to switch to home directory. (#4.3.0)\n"); zerodie(); }
71 void temp_control() { out("Z\
72 Unable to read control files. (#4.3.0)\n"); zerodie(); }
73 void perm_partialline() { out("D\
74 SMTP cannot transfer messages with partial final lines. (#5.6.2)\n"); zerodie(); }
75 void perm_usage() { out("D\
76 I (qmail-remote) was invoked improperly. (#5.3.5)\n"); zerodie(); }
77 void perm_dns() { out("D\
78 Sorry, I couldn't find any host named ");
80 out(". (#5.1.2)\n"); zerodie(); }
81 void perm_nomx() { out("D\
82 Sorry, I couldn't find a mail exchanger or IP address. (#5.4.4)\n");
84 void perm_ambigmx() { out("D\
85 Sorry. Although I'm listed as a best-preference MX or A for that host,\n\
86 it isn't in my control/locals file, so I don't treat it as local. (#5.4.6)\n");
92 if (substdio_put(subfdoutsmall
,x
,ip_fmt(x
,&partner
)) == -1) _exit(0);
98 out("ZConnected to ");
100 out(" but connection died. ");
101 if (flagcritical
) out("Possible duplicate! ");
106 int timeoutconnect
= 60;
110 int saferead(fd
,buf
,len
) int fd
; char *buf
; int len
;
113 r
= timeoutread(timeout
,smtpfd
,buf
,len
);
114 if (r
<= 0) dropped();
117 int safewrite(fd
,buf
,len
) int fd
; char *buf
; int len
;
120 r
= timeoutwrite(timeout
,smtpfd
,buf
,len
);
121 if (r
<= 0) dropped();
126 substdio ssin
= SUBSTDIO_FDBUF(read
,0,inbuf
,sizeof inbuf
);
127 char smtptobuf
[1024];
128 substdio smtpto
= SUBSTDIO_FDBUF(safewrite
,-1,smtptobuf
,sizeof smtptobuf
);
129 char smtpfrombuf
[128];
130 substdio smtpfrom
= SUBSTDIO_FDBUF(saferead
,-1,smtpfrombuf
,sizeof smtpfrombuf
);
132 stralloc smtptext
= {0};
137 substdio_get(&smtpfrom
,ch
,1);
139 if (smtptext
.len
< HUGESMTPTEXT
)
140 if (!stralloc_append(&smtptext
,ch
)) temp_nomem();
143 unsigned long smtpcode()
148 if (!stralloc_copys(&smtptext
,"")) temp_nomem();
150 get(&ch
); code
= ch
- '0';
151 get(&ch
); code
= code
* 10 + (ch
- '0');
152 get(&ch
); code
= code
* 10 + (ch
- '0');
155 if (ch
!= '-') break;
156 while (ch
!= '\n') get(&ch
);
161 while (ch
!= '\n') get(&ch
);
169 if (smtptext
.s
) if (smtptext
.len
) {
170 out("Remote host said: ");
171 for (i
= 0;i
< smtptext
.len
;++i
)
172 if (!smtptext
.s
[i
]) smtptext
.s
[i
] = '?';
173 if (substdio_put(subfdoutsmall
,smtptext
.s
,smtptext
.len
) == -1) _exit(0);
178 void quit(prepend
,append
)
182 substdio_putsflush(&smtpto
,"QUIT\r\n");
183 /* waiting for remote side is just too ridiculous */
192 stralloc verh
= {0}; /* quoted recipient */
193 int flagverh
; /* argc */
194 char *vp
; /* argv[3] */
198 unsigned int posat
, i
;
199 int flagdobody
,flagheader
;
203 posat
= 0; /* stays 0 if no VERH */
204 flagdobody
= 0; /* => 0 at first blank line */
206 if (flagverh
== 4) { /* only if single recipient */
207 if (!quote2(&verh
,vp
)) temp_nomem(); /* non-canonicalized */
208 for (i
= 0; i
< verh
.len
; i
++) /* \n would destroy message */
209 if (verh
.s
[i
] == '\n') verh
.s
[i
] = '_';
210 posat
= byte_rchr(verh
.s
,verh
.len
,'@'); /* posat=0 if no VERH */
211 if (posat
== verh
.len
) posat
= 0;
214 r
= substdio_get(&ssin
,&ch
,1);
216 if (r
== -1) temp_read();
218 substdio_put(&smtpto
,".",1);
220 if (ch
== '\n') { /* header ends */
222 if (!flagdobody
) posat
= 0;
223 } else if (ch
== '#') { /* # starting line => VERH ... */
224 flagdobody
= 1; /* continues in body and ... */
225 continue; /* character is suppressed. */
229 if (ch
== '#' && posat
) { /* ... # */
230 r
= substdio_get(&ssin
,&ch
,1);
231 if (r
== 0) perm_partialline();
232 if (r
== -1) temp_read();
233 if (ch
== '#') { /* ... ## */
235 ch1
= *substdio_peek(&ssin
);
236 if (ch1
!= 'L' && ch1
!= 'H') { /* ... ##x x!=L x!=H */
237 substdio_put(&smtpto
,"#",1);
240 r
= substdio_get(&ssin
,&ch
,1);
241 if (r
== 0) perm_partialline();
242 if (r
== -1) temp_read();
243 if (ch
== 'L') /* ... ##L */
244 substdio_put(&smtpto
,verh
.s
,posat
);
246 substdio_put(&smtpto
,verh
.s
+ posat
+ 1,verh
.len
- posat
- 1);
248 substdio_put(&smtpto
,"#",1);
249 if (ch
== '\n') break;
250 substdio_put(&smtpto
,&ch
,1);
253 substdio_put(&smtpto
,&ch
,1);
254 r
= substdio_get(&ssin
,&ch
,1);
255 if (r
== 0) perm_partialline();
256 if (r
== -1) temp_read();
258 substdio_put(&smtpto
,"\r\n",2);
262 substdio_put(&smtpto
,".\r\n",3);
263 substdio_flush(&smtpto
);
266 stralloc recip
= {0};
274 if (smtpcode() != 220) quit("ZConnected to "," but greeting failed");
276 substdio_puts(&smtpto
,"HELO ");
277 substdio_put(&smtpto
,helohost
.s
,helohost
.len
);
278 substdio_puts(&smtpto
,"\r\n");
279 substdio_flush(&smtpto
);
280 if (smtpcode() != 250) quit("ZConnected to "," but my name was rejected");
282 substdio_puts(&smtpto
,"MAIL FROM:<");
283 substdio_put(&smtpto
,sender
.s
,sender
.len
);
284 substdio_puts(&smtpto
,">\r\n");
285 substdio_flush(&smtpto
);
287 if (code
>= 500) quit("DConnected to "," but sender was rejected");
288 if (code
>= 400) quit("ZConnected to "," but sender was rejected");
291 for (i
= 0;i
< reciplist
.len
;++i
) {
292 substdio_puts(&smtpto
,"RCPT TO:<");
293 substdio_put(&smtpto
,reciplist
.sa
[i
].s
,reciplist
.sa
[i
].len
);
294 substdio_puts(&smtpto
,">\r\n");
295 substdio_flush(&smtpto
);
298 out("h"); outhost(); out(" does not like recipient.\n");
299 outsmtptext(); zero();
301 else if (code
>= 400) {
302 out("s"); outhost(); out(" does not like recipient.\n");
303 outsmtptext(); zero();
310 if (!flagbother
) quit("DGiving up on ","");
312 substdio_putsflush(&smtpto
,"DATA\r\n");
314 if (code
>= 500) quit("D"," failed on DATA command");
315 if (code
>= 400) quit("Z"," failed on DATA command");
320 if (code
>= 500) quit("D"," failed after I sent the message");
321 if (code
>= 400) quit("Z"," failed after I sent the message");
322 quit("K"," accepted message");
325 stralloc canonhost
= {0};
326 stralloc canonbox
= {0};
328 void addrmangle(saout
,s
,flagalias
,flagcname
)
329 stralloc
*saout
; /* host has to be canonical, box has to be quoted */
336 *flagalias
= flagcname
;
340 if (!stralloc_copys(saout
,s
)) temp_nomem();
343 if (!stralloc_copys(&canonbox
,s
)) temp_nomem();
345 if (!quote(saout
,&canonbox
)) temp_nomem();
346 if (!stralloc_cats(saout
,"@")) temp_nomem();
348 if (!stralloc_copys(&canonhost
,s
+ j
+ 1)) temp_nomem();
350 switch(dns_cname(&canonhost
)) {
351 case 0: *flagalias
= 0; break;
352 case DNS_MEM
: temp_nomem();
353 case DNS_SOFT
: temp_dnscanon();
354 case DNS_HARD
: ; /* alias loop, not our problem */
357 if (!stralloc_cat(saout
,&canonhost
)) temp_nomem();
362 if (control_init() == -1) temp_control();
363 if (control_readint(&timeout
,"control/timeoutremote") == -1) temp_control();
364 if (control_readint(&timeoutconnect
,"control/timeoutconnect") == -1)
366 if (control_rldef(&helohost
,"control/helohost",1,(char *) 0) != 1)
368 switch(control_readfile(&routes
,"control/smtproutes",0)) {
372 if (!constmap_init(&maproutes
,"",0,1)) temp_nomem(); break;
374 if (!constmap_init(&maproutes
,routes
.s
,routes
.len
,1)) temp_nomem(); break;
382 static ipalloc ip
= {0};
384 unsigned long random
;
386 unsigned long prefme
;
392 if (argc
< 4) perm_usage();
395 if (chdir(auto_qmail
) == -1) temp_chdir();
399 if (!stralloc_copys(&host
,argv
[1])) temp_nomem();
402 for (i
= 0;i
<= host
.len
;++i
)
403 if ((i
== 0) || (i
== host
.len
) || (host
.s
[i
] == '.'))
404 if (relayhost
= constmap(&maproutes
,host
.s
+ i
,host
.len
- i
))
406 if (relayhost
&& !*relayhost
) relayhost
= 0;
409 i
= str_chr(relayhost
,':');
411 scan_ulong(relayhost
+ i
+ 1,&port
);
414 if (!stralloc_copys(&host
,relayhost
)) temp_nomem();
418 addrmangle(&sender
,argv
[2],&flagalias
,0);
420 if (!saa_readyplus(&reciplist
,0)) temp_nomem();
421 if (ipme_init() != 1) temp_oserr();
426 if (!saa_readyplus(&reciplist
,1)) temp_nomem();
427 reciplist
.sa
[reciplist
.len
] = sauninit
;
428 addrmangle(reciplist
.sa
+ reciplist
.len
,*recips
,&flagalias
,!relayhost
);
429 if (!flagalias
) flagallaliases
= 0;
435 random
= now() + (getpid() << 16);
436 switch (relayhost ?
dns_ip(&ip
,&host
) : dns_mxip(&ip
,&host
,random
)) {
437 case DNS_MEM
: temp_nomem();
438 case DNS_SOFT
: temp_dns();
439 case DNS_HARD
: perm_dns();
441 if (ip
.len
<= 0) temp_dns();
444 if (ip
.len
<= 0) perm_nomx();
447 for (i
= 0;i
< ip
.len
;++i
)
448 if (ipme_is(&ip
.ix
[i
].ip
))
449 if (ip
.ix
[i
].pref
< prefme
)
450 prefme
= ip
.ix
[i
].pref
;
452 if (relayhost
) prefme
= 300000;
453 if (flagallaliases
) prefme
= 500000;
455 for (i
= 0;i
< ip
.len
;++i
)
456 if (ip
.ix
[i
].pref
< prefme
)
462 for (i
= 0;i
< ip
.len
;++i
) if (ip
.ix
[i
].pref
< prefme
) {
463 if (tcpto(&ip
.ix
[i
].ip
)) continue;
465 smtpfd
= socket(AF_INET
,SOCK_STREAM
,0);
466 if (smtpfd
== -1) temp_oserr();
468 if (timeoutconn(smtpfd
,&ip
.ix
[i
].ip
,(unsigned int) port
,timeoutconnect
) == 0) {
469 tcpto_err(&ip
.ix
[i
].ip
,0);
470 partner
= ip
.ix
[i
].ip
;
471 smtp(); /* does not return */
473 tcpto_err(&ip
.ix
[i
].ip
,errno
== error_timeout
);