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 */
198 r = substdio_get(&ssin,&ch,1);
200 if (r == -1) temp_read();
202 substdio_put(&smtpto,".",1);
204 substdio_put(&smtpto,&ch,1);
205 r = substdio_get(&ssin,&ch,1);
206 if (r == 0) perm_partialline();
207 if (r == -1) temp_read();
209 substdio_put(&smtpto,"\r\n",2);
213 substdio_put(&smtpto,".\r\n",3);
214 substdio_flush(&smtpto);
217 stralloc recip = {0};
225 if (smtpcode() != 220) quit("ZConnected to "," but greeting failed");
227 substdio_puts(&smtpto,"HELO ");
228 substdio_put(&smtpto,helohost.s,helohost.len);
229 substdio_puts(&smtpto,"\r\n");
230 substdio_flush(&smtpto);
231 if (smtpcode() != 250) quit("ZConnected to "," but my name was rejected");
233 substdio_puts(&smtpto,"MAIL FROM:<");
234 substdio_put(&smtpto,sender.s,sender.len);
235 substdio_puts(&smtpto,">\r\n");
236 substdio_flush(&smtpto);
238 if (code >= 500) quit("DConnected to "," but sender was rejected");
239 if (code >= 400) quit("ZConnected to "," but sender was rejected");
242 for (i = 0;i < reciplist.len;++i) {
243 substdio_puts(&smtpto,"RCPT TO:<");
244 substdio_put(&smtpto,reciplist.sa[i].s,reciplist.sa[i].len);
245 substdio_puts(&smtpto,">\r\n");
246 substdio_flush(&smtpto);
249 out("h"); outhost(); out(" does not like recipient.\n");
250 outsmtptext(); zero();
252 else if (code >= 400) {
253 out("s"); outhost(); out(" does not like recipient.\n");
254 outsmtptext(); zero();
261 if (!flagbother) quit("DGiving up on ","");
263 substdio_putsflush(&smtpto,"DATA\r\n");
265 if (code >= 500) quit("D"," failed on DATA command");
266 if (code >= 400) quit("Z"," failed on DATA command");
271 if (code >= 500) quit("D"," failed after I sent the message");
272 if (code >= 400) quit("Z"," failed after I sent the message");
273 quit("K"," accepted message");
276 stralloc canonhost = {0};
277 stralloc canonbox = {0};
279 void addrmangle(saout,s,flagalias,flagcname)
280 stralloc *saout; /* host has to be canonical, box has to be quoted */
287 *flagalias = flagcname;
291 if (!stralloc_copys(saout,s)) temp_nomem();
294 if (!stralloc_copys(&canonbox,s)) temp_nomem();
296 if (!quote(saout,&canonbox)) temp_nomem();
297 if (!stralloc_cats(saout,"@")) temp_nomem();
299 if (!stralloc_copys(&canonhost,s + j + 1)) temp_nomem();
301 switch(dns_cname(&canonhost)) {
302 case 0: *flagalias = 0; break;
303 case DNS_MEM: temp_nomem();
304 case DNS_SOFT: temp_dnscanon();
305 case DNS_HARD: ; /* alias loop, not our problem */
308 if (!stralloc_cat(saout,&canonhost)) temp_nomem();
313 if (control_init() == -1) temp_control();
314 if (control_readint(&timeout,"control/timeoutremote") == -1) temp_control();
315 if (control_readint(&timeoutconnect,"control/timeoutconnect") == -1)
317 if (control_rldef(&helohost,"control/helohost",1,(char *) 0) != 1)
319 switch(control_readfile(&routes,"control/smtproutes",0)) {
323 if (!constmap_init(&maproutes,"",0,1)) temp_nomem(); break;
325 if (!constmap_init(&maproutes,routes.s,routes.len,1)) temp_nomem(); break;
333 static ipalloc ip = {0};
335 unsigned long random;
337 unsigned long prefme;
343 if (argc < 4) perm_usage();
344 if (chdir(auto_qmail) == -1) temp_chdir();
348 if (!stralloc_copys(&host,argv[1])) temp_nomem();
351 for (i = 0;i <= host.len;++i)
352 if ((i == 0) || (i == host.len) || (host.s[i] == '.'))
353 if (relayhost = constmap(&maproutes,host.s + i,host.len - i))
355 if (relayhost && !*relayhost) relayhost = 0;
358 i = str_chr(relayhost,':');
360 scan_ulong(relayhost + i + 1,&port);
363 if (!stralloc_copys(&host,relayhost)) temp_nomem();
367 addrmangle(&sender,argv[2],&flagalias,0);
369 if (!saa_readyplus(&reciplist,0)) temp_nomem();
370 if (ipme_init() != 1) temp_oserr();
375 if (!saa_readyplus(&reciplist,1)) temp_nomem();
376 reciplist.sa[reciplist.len] = sauninit;
377 addrmangle(reciplist.sa + reciplist.len,*recips,&flagalias,!relayhost);
378 if (!flagalias) flagallaliases = 0;
384 random = now() + (getpid() << 16);
385 switch (relayhost ? dns_ip(&ip,&host) : dns_mxip(&ip,&host,random)) {
386 case DNS_MEM: temp_nomem();
387 case DNS_SOFT: temp_dns();
388 case DNS_HARD: perm_dns();
390 if (ip.len <= 0) temp_dns();
393 if (ip.len <= 0) perm_nomx();
396 for (i = 0;i < ip.len;++i)
397 if (ipme_is(&ip.ix[i].ip))
398 if (ip.ix[i].pref < prefme)
399 prefme = ip.ix[i].pref;
401 if (relayhost) prefme = 300000;
402 if (flagallaliases) prefme = 500000;
404 for (i = 0;i < ip.len;++i)
405 if (ip.ix[i].pref < prefme)
411 for (i = 0;i < ip.len;++i) if (ip.ix[i].pref < prefme) {
412 if (tcpto(&ip.ix[i].ip)) continue;
414 smtpfd = socket(AF_INET,SOCK_STREAM,0);
415 if (smtpfd == -1) temp_oserr();
417 if (timeoutconn(smtpfd,&ip.ix[i].ip,(unsigned int) port,timeoutconnect) == 0) {
418 tcpto_err(&ip.ix[i].ip,0);
419 partner = ip.ix[i].ip;
420 smtp(); /* does not return */
422 tcpto_err(&ip.ix[i].ip,errno == error_timeout);