开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Email客户端 > 查看源码
srvrsmtp.c
资源名称：sendmail.8.10.0.Beta10.tar.Z　[点击查看]
上传用户：xu_441
上传日期：2007-01-04
资源大小：1640k
文件大小：55k
源码类别：

Email客户端

开发平台：

Unix_Linux

srvrsmtp.c：源码内容
  1. /*
  2.  * Copyright (c) 1998, 1999 Sendmail, Inc. and its suppliers.
  3.  * All rights reserved.
  4.  * Copyright (c) 1983, 1995-1997 Eric P. Allman.  All rights reserved.
  5.  * Copyright (c) 1988, 1993
  6.  * The Regents of the University of California.  All rights reserved.
  7.  *
  8.  * By using this file, you agree to the terms and conditions set
  9.  * forth in the LICENSE file which can be found at the top level of
  10.  * the sendmail distribution.
  11.  *
  12.  */
  14. #include <sendmail.h>
  16. #ifndef lint
  17. # if SMTP
  18. static char id[] = "@(#)$Id: srvrsmtp.c,v 8.403 1999/12/08 18:38:23 ca Exp $ (with SMTP)";
  19. # else /* SMTP */
  20. static char id[] = "@(#)$Id: srvrsmtp.c,v 8.403 1999/12/08 18:38:23 ca Exp $ (without SMTP)";
  21. # endif /* SMTP */
  22. #endif /* ! lint */
  24. #if SMTP
  25. # if SASL
  26. #  define ENC64LEN(l) (((l) + 2) * 4 / 3 + 1)
  27. # endif /* SASL */
  29. static time_t checksmtpattack __P((volatile int *, int, bool,
  30.      char *, ENVELOPE *));
  31. static void mail_esmtp_args __P((char *, char *, ENVELOPE *));
  32. static void printvrfyaddr __P((ADDRESS *, bool, bool));
  33. static void rcpt_esmtp_args __P((ADDRESS *, char *, char *, ENVELOPE *));
  34. static int runinchild __P((char *, ENVELOPE *));
  35. static char *skipword __P((char *volatile, char *));
  36. extern ENVELOPE BlankEnvelope;
  38. /*
  39. **  SMTP -- run the SMTP protocol.
  40. **
  41. ** Parameters:
  42. ** nullserver -- if non-NULL, rejection message for
  43. ** all SMTP commands.
  44. ** e -- the envelope.
  45. **
  46. ** Returns:
  47. ** never.
  48. **
  49. ** Side Effects:
  50. ** Reads commands from the input channel and processes
  51. ** them.
  52. */
  54. struct cmd
  55. {
  56. char *cmd_name; /* command name */
  57. int cmd_code; /* internal code, see below */
  58. };
  60. /* values for cmd_code */
  61. # define CMDERROR 0 /* bad command */
  62. # define CMDMAIL 1 /* mail -- designate sender */
  63. # define CMDRCPT 2 /* rcpt -- designate recipient */
  64. # define CMDDATA 3 /* data -- send message text */
  65. # define CMDRSET 4 /* rset -- reset state */
  66. # define CMDVRFY 5 /* vrfy -- verify address */
  67. # define CMDEXPN 6 /* expn -- expand address */
  68. # define CMDNOOP 7 /* noop -- do nothing */
  69. # define CMDQUIT 8 /* quit -- close connection and die */
  70. # define CMDHELO 9 /* helo -- be polite */
  71. # define CMDHELP 10 /* help -- give usage info */
  72. # define CMDEHLO 11 /* ehlo -- extended helo (RFC 1425) */
  73. # define CMDETRN 12 /* etrn -- flush queue */
  74. # if SASL
  75. #  define CMDAUTH 13 /* auth -- SASL authenticate */
  76. # endif /* SASL */
  77. /* non-standard commands */
  78. # define CMDONEX 16 /* onex -- sending one transaction only */
  79. # define CMDVERB 17 /* verb -- go into verbose mode */
  80. # define CMDXUSR 18 /* xusr -- initial (user) submission */
  81. /* unimplemented commands from RFC 821 */
  82. # define CMDUNIMPL 19 /* unimplemented rfc821 commands */
  83. /* use this to catch and log "door handle" attempts on your system */
  84. # define CMDLOGBOGUS 23 /* bogus command that should be logged */
  85. /* debugging-only commands, only enabled if SMTPDEBUG is defined */
  86. # define CMDDBGQSHOW 24 /* showq -- show send queue */
  87. # define CMDDBGDEBUG 25 /* debug -- set debug mode */
  89. static struct cmd CmdTab[] =
  90. {
  91. { "mail", CMDMAIL },
  92. { "rcpt", CMDRCPT },
  93. { "data", CMDDATA },
  94. { "rset", CMDRSET },
  95. { "vrfy", CMDVRFY },
  96. { "expn", CMDEXPN },
  97. { "help", CMDHELP },
  98. { "noop", CMDNOOP },
  99. { "quit", CMDQUIT },
  100. { "helo", CMDHELO },
  101. { "ehlo", CMDEHLO },
  102. { "etrn", CMDETRN },
  103. { "verb", CMDVERB },
  104. { "onex", CMDONEX },
  105. { "xusr", CMDXUSR },
  106. { "send", CMDUNIMPL },
  107. { "saml", CMDUNIMPL },
  108. { "soml", CMDUNIMPL },
  109. { "turn", CMDUNIMPL },
  110. # if SASL
  111. { "auth", CMDAUTH, },
  112. # endif /* SASL */
  113.     /* remaining commands are here only to trap and log attempts to use them */
  114. { "showq", CMDDBGQSHOW },
  115. { "debug", CMDDBGDEBUG },
  116. { "wiz", CMDLOGBOGUS },
  118. { NULL, CMDERROR }
  119. };
  121. static bool OneXact = FALSE; /* one xaction only this run */
  122. static char *CurSmtpClient; /* who's at the other end of channel */
  124. # define MAXBADCOMMANDS 25 /* maximum number of bad commands */
  125. # define MAXNOOPCOMMANDS 20 /* max "noise" commands before slowdown */
  126. # define MAXHELOCOMMANDS 3 /* max HELO/EHLO commands before slowdown */
  127. # define MAXVRFYCOMMANDS 6 /* max VRFY/EXPN commands before slowdown */
  128. # define MAXETRNCOMMANDS 8 /* max ETRN commands before slowdown */
  129. # define MAXTIMEOUT (4 * 60) /* max timeout for bad commands */
  131. void
  132. smtp(nullserver, d_flags, e)
  133. char *nullserver;
  134. BITMAP256 d_flags;
  135. register ENVELOPE *volatile e;
  136. {
  137. register char *volatile p;
  138. register struct cmd *volatile c = NULL;
  139. char *cmd;
  140. auto ADDRESS *vrfyqueue;
  141. ADDRESS *a;
  142. volatile bool gotmail; /* mail command received */
  143. volatile bool gothello; /* helo command received */
  144. bool vrfy; /* set if this is a vrfy command */
  145. char *volatile protocol; /* sending protocol */
  146. char *volatile sendinghost; /* sending hostname */
  147. char *volatile peerhostname; /* name of SMTP peer or "localhost" */
  148. auto char *delimptr;
  149. char *id;
  150. volatile int nrcpts = 0; /* number of RCPT commands */
  151. bool doublequeue;
  152. volatile bool discard;
  153. volatile int badcommands = 0; /* count of bad commands */
  154. volatile int nverifies = 0; /* count of VRFY/EXPN commands */
  155. volatile int n_etrn = 0; /* count of ETRN commands */
  156. volatile int n_noop = 0; /* count of NOOP/VERB/ONEX etc cmds */
  157. volatile int n_helo = 0; /* count of HELO/EHLO commands */
  158. volatile int delay = 1; /* timeout for bad commands */
  159. bool ok;
  160. bool tempfail = FALSE;
  161. volatile time_t wt; /* timeout after too many commands */
  162. volatile time_t previous; /* time after checksmtpattack() */
  163. volatile int lognullconnection = TRUE;
  164. register char *q;
  165. char *addr;
  166. char *greetcode = "220";
  167. QUEUE_CHAR *new;
  168. int argno;
  169. char *args[MAXSMTPARGS];
  170. char inp[MAXLINE];
  171. char cmdbuf[MAXLINE];
  172. # if SASL
  173. sasl_conn_t *conn;
  174. volatile bool sasl_ok;
  175. bool ismore;
  176. int result;
  177. volatile int authenticating;
  178. char *hostname;
  179. char *user;
  180. char *in, *out, *out2;
  181. const char *errstr;
  182. int inlen, out2len;
  183. unsigned int outlen;
  184. char *volatile auth_type;
  185. char *mechlist;
  186. int len, num;
  187. # endif /* SASL */
  189. if (fileno(OutChannel) != fileno(stdout))
  190. {
  191. /* arrange for debugging output to go to remote host */
  192. (void) dup2(fileno(OutChannel), fileno(stdout));
  193. }
  195. settime(e);
  196. (void)sm_getla(e);
  197. peerhostname = RealHostName;
  198. if (peerhostname == NULL)
  199. peerhostname = "localhost";
  200. CurHostName = peerhostname;
  201. CurSmtpClient = macvalue('_', e);
  202. if (CurSmtpClient == NULL)
  203. CurSmtpClient = CurHostName;
  205. /* check_relay may have set discard bit, save for later */
  206. discard = bitset(EF_DISCARD, e->e_flags);
  208. sm_setproctitle(TRUE, e, "server %s startup", CurSmtpClient);
  211. # if SASL
  212. sasl_ok = FALSE; /* SASL can't be used (yet) */
  214. /* SASL server new connection */
  215. hostname = macvalue('j', e);
  216. /* XXX input parameter for realm? */
  217. #  if SASL > 10505
  218. /* use empty realm: doesn't work in SASL <= 1.5.5 */
  219. result = sasl_server_new("smtp", hostname, "", NULL, 0, &conn);
  220. #  else /* SASL > 10505 */
  221. /* use no realm -> realm is set to hostname by SASL lib */
  222. result = sasl_server_new("smtp", hostname, NULL, NULL, 0, &conn);
  223. #  endif /* SASL > 10505 */
  224. if (result == SASL_OK)
  225. {
  226. sasl_ok = TRUE;
  228. /*
  229. **  SASL set properties for sasl
  230. **  set local/remote IP
  231. **  XXX only IPv4: Cyrus SASL doesn't support anything else
  232. **
  233. **  XXX where exactly are these used/required?
  234. **  Kerberos_v4
  235. */
  237. # if NETINET
  238. in = macvalue(macid("{daemon_family}", NULL), e);
  239. if (in != NULL && strcmp(in, "inet") == 0)
  240. {
  241. SOCKADDR_LEN_T addrsize;
  242. struct sockaddr_in saddr_l;
  243. struct sockaddr_in saddr_r;
  245. addrsize = sizeof(struct sockaddr_in);
  246. if (getpeername(fileno(InChannel),
  247. (struct sockaddr *)&saddr_r,
  248. &addrsize) == 0)
  249. {
  250. sasl_setprop(conn, SASL_IP_REMOTE, &saddr_r);
  251. addrsize = sizeof(struct sockaddr_in);
  252. if (getsockname(fileno(InChannel),
  253. (struct sockaddr *)&saddr_l,
  254. &addrsize) == 0)
  255. sasl_setprop(conn, SASL_IP_LOCAL,
  256.      &saddr_l);
  257. }
  258. }
  259. # endif /* NETINET */
  260. /* end setting properties */
  262. authenticating = SASL_NOT_AUTH;
  263. auth_type = NULL;
  264. mechlist = NULL;
  265. user = NULL;
  266. #  if 0
  267. define(macid("{auth_author}", NULL), NULL, &BlankEnvelope);
  268. #  endif /* 0 */
  269. if (sasl_ok)
  270. {
  271. /* "user" is currently (cyrus-sasl 1.4.1) unused */
  272. result = sasl_listmech(conn, "user", /* XXX */
  273.        "", " ", "", &mechlist,
  274.        (u_int *)&len, (u_int *)&num);
  275. if (result == SASL_OK && num > 0)
  276. {
  277. if (LogLevel > 11)
  278. sm_syslog(LOG_INFO, NOQID,
  279.   "SASL: available mech=%s, allowed mech=%s",
  280.   mechlist, AuthMechanisms);
  281. mechlist = intersect(AuthMechanisms, mechlist);
  282. }
  283. else
  284. {
  285. sasl_ok = FALSE;
  286. if (LogLevel > 9)
  287. sm_syslog(LOG_WARNING, NOQID,
  288.   "SASL error: listmech=%d, num=%d",
  289.   result, num);
  290. }
  291. }
  292. else if (LogLevel > 9)
  293. sm_syslog(LOG_WARNING, NOQID,
  294.   "SASL error: get*name()");
  295. }
  296. else
  297. {
  298. sasl_ok = FALSE; /* SASL can't be used */
  299. if (LogLevel > 9)
  300. sm_syslog(LOG_WARNING, NOQID,
  301.   "SASL error: sasl_server_new=%d", result);
  302. }
  303. # endif /* SASL */
  306. /* output the first line, inserting "ESMTP" as second word */
  307. expand(SmtpGreeting, inp, sizeof inp, e);
  308. p = strchr(inp, 'n');
  309. if (p != NULL)
  310. *p++ = '';
  311. id = strchr(inp, ' ');
  312. if (id == NULL)
  313. id = &inp[strlen(inp)];
  314. if (p == NULL)
  315. snprintf(cmdbuf, sizeof cmdbuf,
  316.  "%s %%.*s ESMTP%%s", greetcode);
  317. else
  318. snprintf(cmdbuf, sizeof cmdbuf,
  319.  "%s-%%.*s ESMTP%%s", greetcode);
  320. message(cmdbuf, id - inp, inp, id);
  322. /* output remaining lines */
  323. while ((id = p) != NULL && (p = strchr(id, 'n')) != NULL)
  324. {
  325. *p++ = '';
  326. if (isascii(*id) && isspace(*id))
  327. id++;
  328. (void) snprintf(cmdbuf, sizeof cmdbuf, "%s-%%s", greetcode);
  329. message(cmdbuf, id);
  330. }
  331. if (id != NULL)
  332. {
  333. if (isascii(*id) && isspace(*id))
  334. id++;
  335. (void) snprintf(cmdbuf, sizeof cmdbuf, "%s %%s", greetcode);
  336. message(cmdbuf, id);
  337. }
  339. protocol = NULL;
  340. sendinghost = macvalue('s', e);
  341. gothello = FALSE;
  342. gotmail = FALSE;
  343. for (;;)
  344. {
  345. /* arrange for backout */
  346. (void) setjmp(TopFrame);
  347. QuickAbort = FALSE;
  348. HoldErrs = FALSE;
  349. SuprErrs = FALSE;
  350. LogUsrErrs = FALSE;
  351. OnlyOneError = TRUE;
  352. e->e_flags &= ~(EF_VRFYONLY|EF_GLOBALERRS);
  354. /* setup for the read */
  355. e->e_to = NULL;
  356. Errors = 0;
  357. FileName = NULL;
  358. (void) fflush(stdout);
  360. /* read the input line */
  361. SmtpPhase = "server cmd read";
  362. sm_setproctitle(TRUE, e, "server %s cmd read", CurSmtpClient);
  363. # if SASL
  364. /*
  365. **  SMTP AUTH requires accepting any length,
  366. **  at least for challenge/response
  367. **  XXX
  368. */
  369. # endif /* SASL */
  370. p = sfgets(inp, sizeof inp, InChannel, TimeOuts.to_nextcommand,
  371. SmtpPhase);
  373. /* handle errors */
  374. if (p == NULL)
  375. {
  376. char *d;
  378. d = macvalue(macid("{daemon_name}", NULL), e);
  379. if (d == NULL)
  380. d = "stdin";
  381. /* end of file, just die */
  382. disconnect(1, e);
  385. message("421 4.4.1 %s Lost input channel from %s",
  386. MyHostName, CurSmtpClient);
  387. if (LogLevel > (gotmail ? 1 : 19))
  388. sm_syslog(LOG_NOTICE, e->e_id,
  389.   "lost input channel from %.100s to %s after %s",
  390.   CurSmtpClient, d,
  391.   (c == NULL || c->cmd_name == NULL) ? "startup" : c->cmd_name);
  392. /*
  393. **  If have not accepted mail (DATA), do not bounce
  394. **  bad addresses back to sender.
  395. */
  397. if (bitset(EF_CLRQUEUE, e->e_flags))
  398. e->e_sendqueue = NULL;
  399. goto doquit;
  400. }
  402. /* clean up end of line */
  403. fixcrlf(inp, TRUE);
  405. # if SASL
  406. if (authenticating == SASL_PROC_AUTH)
  407. {
  408. if (tTd(95, 2))
  409. dprintf("AUTH: got "%s"n", inp);
  410. #  if 0
  411. if (*inp == '')
  412. {
  413. authenticating = SASL_NOT_AUTH;
  414. message("501 5.5.2 missing input");
  415. continue;
  416. }
  417. #  endif /* 0 */
  418. if (*inp == '*' && *(inp + 1) == '')
  419. {
  420. authenticating = SASL_NOT_AUTH;
  422. /* rfc 2254 4. */
  423. message("501 5.0.0 AUTH aborted");
  424. continue;
  425. }
  427. /* could this be shorter? XXX */
  428. out = xalloc(strlen(inp));
  429. result = sasl_decode64(inp, strlen(inp), out, &outlen);
  430. if (result != SASL_OK)
  431. {
  432. authenticating = SASL_NOT_AUTH;
  434. /* rfc 2254 4. */
  435. message("501 5.5.4 cannot decode AUTH parameter %s",
  436. inp);
  437. continue;
  438. }
  440. result = sasl_server_step(conn, out, outlen,
  441.   &out, &outlen, &errstr);
  443. /* get an OK if we're done */
  444. if (result == SASL_OK)
  445. {
  446.   authenticated:
  447. message("235 2.0.0 OK Authenticated");
  448. authenticating = SASL_IS_AUTH;
  449. define(macid("{auth_type}", NULL),
  450.        newstr(auth_type), &BlankEnvelope);
  451. if (tTd(95, 8))
  452. dprintf("SASL auth_type: '%s'n",
  453. auth_type);
  455. result = sasl_getprop(conn, SASL_USERNAME,
  456.       (void **)&user);
  457. if (result != SASL_OK)
  458. {
  459. user = NULL;
  460. define(macid("{auth_authen}", NULL),
  461.        NULL, &BlankEnvelope);
  462. }
  463. else
  464. {
  465. define(macid("{auth_authen}", NULL),
  466.        newstr(user), &BlankEnvelope);
  467. if (tTd(95, 8))
  468. dprintf("SASL auth_authen: '%s'n",
  469. user);
  470. }
  472. #  if 0
  473. /* get realm? */
  474. sasl_getprop(conn, SASL_REALM, (void **) &data);
  475. #  endif /* 0 */
  479. }
  480. else if (result == SASL_CONTINUE)
  481. {
  482. len = ENC64LEN(outlen);
  483. out2 = xalloc(len);
  484. result = sasl_encode64(out, outlen, out2, len,
  485.        (u_int *)&out2len);
  486. if (result != SASL_OK)
  487. {
  488. /* correct code? XXX */
  489. /* 454 Temp. authentication failure */
  490. message("454 4.5.4 Internal error: unable to encode64");
  491. if (LogLevel > 5)
  492. sm_syslog(LOG_WARNING, e->e_id,
  493.   "SASL encode64 error [%d for "%s"]",
  494.   result, out);
  495. /* start over? */
  496. authenticating = SASL_NOT_AUTH;
  497. }
  498. else
  499. {
  500. message("334 %s", out2);
  501. if (tTd(95, 2))
  502. dprintf("SASL continue: msg='%s' len=%dn",
  503. out2, out2len);
  504. }
  505. }
  506. else
  507. {
  508. /* not SASL_OK or SASL_CONT */
  509. message("500 5.7.0 authentication failed");
  510. if (LogLevel > 5)
  511. sm_syslog(LOG_WARNING, e->e_id,
  512.   "authentication failed: %s (%d)",
  513.   sasl_errstring(result, NULL,
  514.  NULL),
  515.   result);
  516. authenticating = SASL_NOT_AUTH;
  517. }
  518. }
  519. else
  520. {
  521. /* don't want to do any of this if authenticating */
  522. # endif /* SASL */
  524. /* echo command to transcript */
  525. if (e->e_xfp != NULL)
  526. fprintf(e->e_xfp, "<<< %sn", inp);
  528. if (LogLevel >= 15)
  529. sm_syslog(LOG_INFO, e->e_id,
  530.   "<-- %s",
  531.   inp);
  533. if (e->e_id == NULL)
  534. sm_setproctitle(TRUE, e, "%s: %.80s",
  535. CurSmtpClient, inp);
  536. else
  537. sm_setproctitle(TRUE, e, "%s %s: %.80s",
  538. qid_printname(e),
  539. CurSmtpClient, inp);
  541. /* break off command */
  542. for (p = inp; isascii(*p) && isspace(*p); p++)
  543. continue;
  544. cmd = cmdbuf;
  545. while (*p != '' &&
  546.        !(isascii(*p) && isspace(*p)) &&
  547.        cmd < &cmdbuf[sizeof cmdbuf - 2])
  548. *cmd++ = *p++;
  549. *cmd = '';
  551. /* throw away leading whitespace */
  552. while (isascii(*p) && isspace(*p))
  553. p++;
  555. /* decode command */
  556. for (c = CmdTab; c->cmd_name != NULL; c++)
  557. {
  558. if (!strcasecmp(c->cmd_name, cmdbuf))
  559. break;
  560. }
  562. /* reset errors */
  563. errno = 0;
  565. /*
  566. **  Process command.
  567. **
  568. ** If we are running as a null server, return 550
  569. ** to everything.
  570. */
  572. if (nullserver != NULL || bitnset(D_ETRNONLY, d_flags))
  573. {
  574. switch (c->cmd_code)
  575. {
  576.   case CMDQUIT:
  577.   case CMDHELO:
  578.   case CMDEHLO:
  579.   case CMDNOOP:
  580.   case CMDRSET:
  581. /* process normally */
  582. break;
  584.   case CMDETRN:
  585. if (bitnset(D_ETRNONLY, d_flags) &&
  586.     nullserver == NULL)
  587. break;
  588. continue;
  590.   default:
  591. if (++badcommands > MAXBADCOMMANDS)
  592. {
  593. delay *= 2;
  594. if (delay >= MAXTIMEOUT)
  595. delay = MAXTIMEOUT;
  596. (void) sleep(delay);
  597. }
  598. if (nullserver != NULL)
  599. {
  600. if (ISSMTPREPLY(nullserver))
  601. usrerr(nullserver);
  602. else
  603. usrerr("550 5.0.0 %s", nullserver);
  604. }
  605. else
  606. usrerr("452 4.4.5 Insufficient disk space; try again later");
  607. continue;
  608. }
  609. }
  611. /* non-null server */
  612. switch (c->cmd_code)
  613. {
  614.   case CMDMAIL:
  615.   case CMDEXPN:
  616.   case CMDVRFY:
  617.   case CMDETRN:
  618. lognullconnection = FALSE;
  619. }
  621. switch (c->cmd_code)
  622. {
  623. # if SASL
  624.   case CMDAUTH: /* sasl */
  625. if (!sasl_ok)
  626. {
  627. message("503 5.3.3 AUTH not available");
  628. break;
  629. }
  630. if (authenticating == SASL_IS_AUTH)
  631. {
  632. message("503 5.5.0 Already Authenticated");
  633. break;
  634. }
  635. if (gotmail)
  636. {
  637. message("503 5.5.0 AUTH not permitted during a mail transaction");
  638. break;
  639. }
  640. ismore = FALSE;
  642. /* make sure it's a valid string */
  643. for (q = p; *q != '' && isascii(*q); q++)
  644. {
  645. if (isspace(*q))
  646. {
  647. *q = '';
  648. while (*++q != '' &&
  649.        isascii(*q) && isspace(*q))
  650. continue;
  651. *(q - 1) = '';
  652. ismore = (*q != '');
  653. break;
  654. }
  655. }
  657. /* check whether mechanism is available */
  658. if (iteminlist(p, mechlist, " ") == NULL)
  659. {
  660. message("503 5.3.3 AUTH mechanism %s not available",
  661. p);
  662. break;
  663. }
  665. if (ismore)
  666. {
  667. /* could this be shorter? XXX */
  668. in = xalloc(strlen(q));
  669. result = sasl_decode64(q, strlen(q), in,
  670.        (u_int *)&inlen);
  671. if (result != SASL_OK)
  672. {
  673. message("501 5.5.4 cannot BASE64 decode '%s'",
  674. q);
  675. if (LogLevel > 5)
  676. sm_syslog(LOG_WARNING, e->e_id,
  677.   "SASL decode64 error [%d for "%s"]",
  678.   result, q);
  679. /* start over? */
  680. authenticating = SASL_NOT_AUTH;
  681. in = NULL;
  682. inlen = 0;
  683. break;
  684. }
  685. if (tTd(95, 99))
  686. {
  687. int i;
  689. dprintf("AUTH: more "");
  690. for (i = 0; i < inlen; i++)
  691. {
  692. if (isascii(in[i]) &&
  693.     isprint(in[i]))
  694. dprintf("%c", in[i]);
  695. else
  696. dprintf("_");
  697. }
  698. dprintf(""n");
  699. }
  700. q = in;
  701. }
  702. else
  703. {
  704. in = NULL;
  705. inlen = 0;
  706. }
  708. /* see if that auth type exists */
  709. result = sasl_server_start(conn, p, in, inlen,
  710.    &out, &outlen, &errstr);
  712. /* XXX other errors */
  713. ismore = FALSE;
  714. switch (result)
  715. {
  716.   case SASL_OK:
  717.   case SASL_CONTINUE:
  718. ismore = TRUE;
  719. break;
  721.   case SASL_NOMECH:
  722. message("504 5.7.0 Unrecognized authentication type [%s]", p);
  723. break;
  725.   case SASL_NOUSER:
  726. message("504 5.7.0 Unrecognized user");
  727. break;
  729.   case SASL_BADAUTH:
  730. message("504 5.7.0 Authentication failure");
  731. break;
  733.   case SASL_BADPROT:
  734. message("504 5.7.0 Bad protocol");
  735. break;
  737.   case SASL_NOAUTHZ:
  738. message("504 5.7.0 Authorization failure");
  739. break;
  741.   case SASL_TOOWEAK:
  742. message("504 5.7.0 Mechanism too weak for this user");
  743. break;
  745.   case SASL_ENCRYPT:
  746. message("504 5.7.0 Encryption needed to use mechanism");
  747. break;
  749.   case SASL_TRANS:
  750. message("504 5.7.1 One time use of a plaintext password will enable requested mechanism for user");
  751. break;
  753.   case SASL_EXPIRED:
  754. message("504 5.7.1 Passphrase expired, has to be reset");
  755. break;
  757.   case SASL_DISABLED:
  758. message("504 5.7.1 Account disabled");
  759. break;
  761.   case SASL_PWLOCK:
  762. message("504 5.7.0 Password locked");
  763. break;
  765.   case SASL_NOCHANGE:
  766. message("504 5.7.0 Requested change was not needed");
  767. break;
  769.   case SASL_BADVERS:
  770. message("504 5.3.5 Version mismatch with plug-in");
  771. break;
  773.   default:
  774. message("500 5.3.5 Internal SASL error: %s (%d)",
  775. sasl_errstring(result, NULL, NULL),
  776. result);
  777. if (LogLevel > 0)
  778. sm_syslog(LOG_ERR, e->e_id,
  779.   "Internal SASL error: %s (%d)",
  780.   sasl_errstring(result, NULL,
  781.  NULL),
  782.   result);
  783. break;
  784. }
  786. if (!ismore)
  787. break; /* we had an error: break out */
  788. auth_type = newstr(p);
  790. if (result == SASL_OK)
  791. {
  792. /* ugly, but same code */
  793. goto authenticated;
  794. /* authenticated by the initial response */
  795. }
  797. /* len is at least 2 */
  798. len = ENC64LEN(outlen);
  799. out2 = xalloc(len);
  800. result = sasl_encode64(out, outlen, out2, len,
  801. (u_int *)&out2len);
  803. if (result != SASL_OK)
  804. {
  805. /* correct code? XXX */
  806. /* 454 Temporary authentication failure */
  807. message("454 4.5.4 Internal error: unable to encode64");
  808. if (LogLevel > 5)
  809. sm_syslog(LOG_WARNING, e->e_id,
  810.   "SASL encode64 error [%d for "%s"]",
  811.   result, out);
  812. /* start over? */
  813. authenticating = SASL_NOT_AUTH;
  814. }
  815. else
  816. {
  817. message("334 %s", out2);
  818. authenticating = SASL_PROC_AUTH;
  819. }
  821. break;
  822. # endif /* SASL */
  825.   case CMDHELO: /* hello -- introduce yourself */
  826.   case CMDEHLO: /* extended hello */
  827. if (c->cmd_code == CMDEHLO)
  828. {
  829. protocol = "ESMTP";
  830. SmtpPhase = "server EHLO";
  831. }
  832. else
  833. {
  834. protocol = "SMTP";
  835. SmtpPhase = "server HELO";
  836. }
  838. /* avoid denial-of-service */
  839. (void) checksmtpattack(&n_helo, MAXHELOCOMMANDS, TRUE,
  840.        "HELO/EHLO", e);
  842. /* check for duplicate HELO/EHLO per RFC 1651 4.2 */
  843. if (gothello)
  844. {
  845. usrerr("503 %s Duplicate HELO/EHLO",
  846. MyHostName);
  847. break;
  848. }
  850. /* check for valid domain name (re 1123 5.2.5) */
  851. if (*p == '' && !AllowBogusHELO)
  852. {
  853. usrerr("501 %s requires domain address",
  854. cmdbuf);
  855. break;
  856. }
  858. /* check for long domain name (hides Received: info) */
  859. if (strlen(p) > MAXNAME)
  860. {
  861. usrerr("501 Invalid domain name");
  862. if (LogLevel > 9)
  863. sm_syslog(LOG_INFO, CurEnv->e_id,
  864.   "invalid domain name (too long) from %.100s",
  865.   CurSmtpClient);
  866. break;
  867. }
  869. for (q = p; *q != ''; q++)
  870. {
  871. if (!isascii(*q))
  872. break;
  873. if (isalnum(*q))
  874. continue;
  875. if (isspace(*q))
  876. {
  877. *q = '';
  878. break;
  879. }
  880. if (strchr("[].-_#", *q) == NULL)
  881. break;
  882. }
  884. if (*q == '')
  885. {
  886. q = "pleased to meet you";
  887. sendinghost = newstr(p);
  888. }
  889. else if (!AllowBogusHELO)
  890. {
  891. usrerr("501 Invalid domain name");
  892. if (LogLevel > 9)
  893. sm_syslog(LOG_INFO, CurEnv->e_id,
  894.   "invalid domain name (%.100s) from %.100s",
  895.   p, CurSmtpClient);
  896. break;
  897. }
  898. else
  899. {
  900. q = "accepting invalid domain name";
  901. }
  904. gothello = TRUE;
  906. /* print HELO response message */
  907. if (c->cmd_code != CMDEHLO)
  908. {
  909. message("250 %s Hello %s, %s",
  910. MyHostName, CurSmtpClient, q);
  911. break;
  912. }
  914. message("250-%s Hello %s, %s",
  915. MyHostName, CurSmtpClient, q);
  917. /* offer ENHSC even for nullserver */
  918. if (nullserver != NULL)
  919. {
  920. message("250 ENHANCEDSTATUSCODES");
  921. break;
  922. }
  924. /* print EHLO features list */
  925. message("250-ENHANCEDSTATUSCODES");
  926. if (!bitset(PRIV_NOEXPN, PrivacyFlags))
  927. {
  928. message("250-EXPN");
  929. if (!bitset(PRIV_NOVERB, PrivacyFlags))
  930. message("250-VERB");
  931. }
  932. # if MIME8TO7
  933. message("250-8BITMIME");
  934. # endif /* MIME8TO7 */
  935. if (MaxMessageSize > 0)
  936. message("250-SIZE %ld", MaxMessageSize);
  937. else
  938. message("250-SIZE");
  939. # if DSN
  940. if (SendMIMEErrors &&
  941.     !bitset(PRIV_NORECEIPTS, PrivacyFlags))
  942. message("250-DSN");
  943. # endif /* DSN */
  944. message("250-ONEX");
  945. if (!bitset(PRIV_NOETRN, PrivacyFlags) &&
  946.     !bitnset(D_NOETRN, d_flags))
  947. message("250-ETRN");
  948. message("250-XUSR");
  950. # if SASL
  951. if (sasl_ok && mechlist != NULL && *mechlist != '')
  952. message("250-AUTH %s", mechlist);
  953. # endif /* SASL */
  954. message("250 HELP");
  955. break;
  957.   case CMDMAIL: /* mail -- designate sender */
  958. SmtpPhase = "server MAIL";
  960. /* check for validity of this command */
  961. if (!gothello && bitset(PRIV_NEEDMAILHELO, PrivacyFlags))
  962. {
  963. usrerr("503 5.0.0 Polite people say HELO first");
  964. break;
  965. }
  966. if (gotmail)
  967. {
  968. usrerr("503 5.5.0 Sender already specified");
  969. break;
  970. }
  971. if (InChild)
  972. {
  973. errno = 0;
  974. syserr("503 5.5.0 Nested MAIL command: MAIL %s", p);
  975. finis(TRUE, ExitStat);
  976. }
  977. # if SASL
  978. if (bitnset(D_AUTHREQ, d_flags) &&
  979.     authenticating != SASL_IS_AUTH)
  980. {
  981. usrerr("530 5.7.0 Authentication required");
  982. break;
  983. }
  984. # endif /* SASL */
  986. if (tempfail)
  987. {
  988. if (LogLevel > 9)
  989. sm_syslog(LOG_INFO, e->e_id,
  990.   "MAIL From:<%.100s> from %.100s tempfailed (from previous HELO/EHLO check)",
  991.   args[0], CurSmtpClient);
  992. usrerr("451 4.7.1 Please try again later");
  993. break;
  994. }
  995. /* make sure we know who the sending host is */
  996. if (sendinghost == NULL)
  997. sendinghost = peerhostname;
  999. p = skipword(p, "from");
  1000. if (p == NULL)
  1001. break;
  1003. /* fork a subprocess to process this command */
  1004. if (runinchild("SMTP-MAIL", e) > 0)
  1005. break;
  1006. if (Errors > 0)
  1007. goto undo_subproc_no_pm;
  1008. if (!gothello)
  1009. {
  1010. auth_warning(e,
  1011. "%s didn't use HELO protocol",
  1012. CurSmtpClient);
  1013. }
  1014. # ifdef PICKY_HELO_CHECK
  1015. if (strcasecmp(sendinghost, peerhostname) != 0 &&
  1016.     (strcasecmp(peerhostname, "localhost") != 0 ||
  1017.      strcasecmp(sendinghost, MyHostName) != 0))
  1018. {
  1019. auth_warning(e, "Host %s claimed to be %s",
  1020. CurSmtpClient, sendinghost);
  1021. }
  1022. # endif /* PICKY_HELO_CHECK */
  1024. if (protocol == NULL)
  1025. protocol = "SMTP";
  1026. define('r', protocol, e);
  1027. define('s', sendinghost, e);
  1029. if (Errors > 0)
  1030. goto undo_subproc_no_pm;
  1031. nrcpts = 0;
  1032. define(macid("{ntries}", NULL), "0", e);
  1033. e->e_flags |= EF_LOGSENDER|EF_CLRQUEUE;
  1034. sm_setproctitle(TRUE, e, "%s %s: %.80s",
  1035. qid_printname(e),
  1036. CurSmtpClient, inp);
  1038. /* child -- go do the processing */
  1039. if (setjmp(TopFrame) > 0)
  1040. {
  1041. /* this failed -- undo work */
  1042.  undo_subproc_no_pm:
  1043. e->e_flags &= ~EF_PM_NOTIFY;
  1044.  undo_subproc:
  1045. if (InChild)
  1046. {
  1047. QuickAbort = FALSE;
  1048. SuprErrs = TRUE;
  1049. e->e_flags &= ~EF_FATALERRS;
  1051. if (LogLevel > 4 &&
  1052.     bitset(EF_LOGSENDER, e->e_flags))
  1053. logsender(e, NULL);
  1054. e->e_flags &= ~EF_LOGSENDER;
  1056. finis(TRUE, ExitStat);
  1057. }
  1058. break;
  1059. }
  1060. QuickAbort = TRUE;
  1062. /* must parse sender first */
  1063. delimptr = NULL;
  1064. setsender(p, e, &delimptr, ' ', FALSE);
  1065. if (delimptr != NULL && *delimptr != '')
  1066. *delimptr++ = '';
  1067. if (Errors > 0)
  1068. goto undo_subproc_no_pm;
  1070. /* put resulting triple from parseaddr() into macros */
  1071. if (e->e_from.q_mailer != NULL)
  1072.  define(macid("{mail_mailer}", NULL),
  1073. e->e_from.q_mailer->m_name, e);
  1074. else
  1075.  define(macid("{mail_mailer}", NULL),
  1076. NULL, e);
  1077. if (e->e_from.q_host != NULL)
  1078. define(macid("{mail_host}", NULL),
  1079.        e->e_from.q_host, e);
  1080. else
  1081. define(macid("{mail_host}", NULL),
  1082.        "localhost", e);
  1083. if (e->e_from.q_user != NULL)
  1084. define(macid("{mail_addr}", NULL),
  1085.        e->e_from.q_user, e);
  1086. else
  1087. define(macid("{mail_addr}", NULL),
  1088.        NULL, e);
  1089. if (Errors > 0)
  1090.   goto undo_subproc_no_pm;
  1092. /* check for possible spoofing */
  1093. if (RealUid != 0 && OpMode == MD_SMTP &&
  1094.     !wordinclass(RealUserName, 't') &&
  1095.     (!bitnset(M_LOCALMAILER,
  1096.       e->e_from.q_mailer->m_flags) ||
  1097.      strcmp(e->e_from.q_user, RealUserName) != 0))
  1098. {
  1099. auth_warning(e, "%s owned process doing -bs",
  1100. RealUserName);
  1101. }
  1103. /* now parse ESMTP arguments */
  1104. e->e_msgsize = 0;
  1105. addr = p;
  1106. argno = 0;
  1107. args[argno++] = p;
  1108. p = delimptr;
  1109. while (p != NULL && *p != '')
  1110. {
  1111. char *kp;
  1112. char *vp = NULL;
  1113. char *equal = NULL;
  1115. /* locate the beginning of the keyword */
  1116. while (isascii(*p) && isspace(*p))
  1117. p++;
  1118. if (*p == '')
  1119. break;
  1120. kp = p;
  1122. /* skip to the value portion */
  1123. while ((isascii(*p) && isalnum(*p)) || *p == '-')
  1124. p++;
  1125. if (*p == '=')
  1126. {
  1127. equal = p;
  1128. *p++ = '';
  1129. vp = p;
  1131. /* skip to the end of the value */
  1132. while (*p != '' && *p != ' ' &&
  1133.        !(isascii(*p) && iscntrl(*p)) &&
  1134.        *p != '=')
  1135. p++;
  1136. }
  1138. if (*p != '')
  1139. *p++ = '';
  1141. if (tTd(19, 1))
  1142. dprintf("MAIL: got arg %s="%s"n", kp,
  1143. vp == NULL ? "<null>" : vp);
  1145. mail_esmtp_args(kp, vp, e);
  1146. if (equal != NULL)
  1147. *equal = '=';
  1148. args[argno++] = kp;
  1149. if (argno >= MAXSMTPARGS - 1)
  1150. usrerr("501 5.5.4 Too many parameters");
  1151. if (Errors > 0)
  1152. goto undo_subproc_no_pm;
  1153. }
  1154. args[argno] = NULL;
  1155. if (Errors > 0)
  1156. goto undo_subproc_no_pm;
  1158. /* do config file checking of the sender */
  1159. if (rscheck("check_mail", addr,
  1160.     NULL, e, TRUE, TRUE) != EX_OK ||
  1161.     Errors > 0)
  1162. goto undo_subproc_no_pm;
  1164. if (MaxMessageSize > 0 && e->e_msgsize > MaxMessageSize)
  1165. {
  1166. usrerr("552 5.2.3 Message size exceeds fixed maximum message size (%ld)",
  1167. MaxMessageSize);
  1168. goto undo_subproc_no_pm;
  1169. }
  1171. if (!enoughdiskspace(e->e_msgsize, TRUE))
  1172. {
  1173. usrerr("452 4.4.5 Insufficient disk space; try again later");
  1174. goto undo_subproc_no_pm;
  1175. }
  1176. if (Errors > 0)
  1177. goto undo_subproc_no_pm;
  1179. if (Errors > 0)
  1180. goto undo_subproc_no_pm;
  1182. message("250 2.1.0 Sender ok");
  1183. gotmail = TRUE;
  1184. break;
  1186.   case CMDRCPT: /* rcpt -- designate recipient */
  1187. if (!gotmail)
  1188. {
  1189. usrerr("503 5.0.0 Need MAIL before RCPT");
  1190. break;
  1191. }
  1192. SmtpPhase = "server RCPT";
  1193. if (setjmp(TopFrame) > 0)
  1194. {
  1195. e->e_flags &= ~EF_FATALERRS;
  1196. break;
  1197. }
  1198. QuickAbort = TRUE;
  1199. LogUsrErrs = TRUE;
  1201. /* limit flooding of our machine */
  1202. if (MaxRcptPerMsg > 0 && nrcpts >= MaxRcptPerMsg)
  1203. {
  1204. usrerr("452 4.5.3 Too many recipients");
  1205. break;
  1206. }
  1208. if (e->e_sendmode != SM_DELIVER)
  1209. e->e_flags |= EF_VRFYONLY;
  1212. p = skipword(p, "to");
  1213. if (p == NULL)
  1214. break;
  1215. # if _FFR_ADDR_TYPE
  1216. define(macid("{addr_type}", NULL), "e r", e);
  1217. # endif /* _FFR_ADDR_TYPE */
  1218. a = parseaddr(p, NULLADDR, RF_COPYALL, ' ', &delimptr, e);
  1219. #if _FFR_ADDR_TYPE
  1220. define(macid("{addr_type}", NULL), NULL, e);
  1221. #endif /* _FFR_ADDR_TYPE */
  1222. if (Errors > 0)
  1223. break;
  1224. if (a == NULL)
  1225. {
  1226. usrerr("501 5.0.0 Missing recipient");
  1227. break;
  1228. }
  1230. if (delimptr != NULL && *delimptr != '')
  1231. *delimptr++ = '';
  1233. /* put resulting triple from parseaddr() into macros */
  1234. if (a->q_mailer != NULL)
  1235. define(macid("{rcpt_mailer}", NULL),
  1236.        a->q_mailer->m_name, e);
  1237. else
  1238. define(macid("{rcpt_mailer}", NULL),
  1239.        NULL, e);
  1240. if (a->q_host != NULL)
  1241. define(macid("{rcpt_host}", NULL),
  1242.        a->q_host, e);
  1243. else
  1244. define(macid("{rcpt_host}", NULL),
  1245.        "localhost", e);
  1246. if (a->q_user != NULL)
  1247. define(macid("{rcpt_addr}", NULL),
  1248.        a->q_user, e);
  1249. else
  1250. define(macid("{rcpt_addr}", NULL),
  1251.        NULL, e);
  1252. if (Errors > 0)
  1253. break;
  1255. /* now parse ESMTP arguments */
  1256. addr = p;
  1257. argno = 0;
  1258. args[argno++] = p;
  1259. p = delimptr;
  1260. while (p != NULL && *p != '')
  1261. {
  1262. char *kp;
  1263. char *vp = NULL;
  1264. char *equal = NULL;
  1266. /* locate the beginning of the keyword */
  1267. while (isascii(*p) && isspace(*p))
  1268. p++;
  1269. if (*p == '')
  1270. break;
  1271. kp = p;
  1273. /* skip to the value portion */
  1274. while ((isascii(*p) && isalnum(*p)) || *p == '-')
  1275. p++;
  1276. if (*p == '=')
  1277. {
  1278. equal = p;
  1279. *p++ = '';
  1280. vp = p;
  1282. /* skip to the end of the value */
  1283. while (*p != '' && *p != ' ' &&
  1284.        !(isascii(*p) && iscntrl(*p)) &&
  1285.        *p != '=')
  1286. p++;
  1287. }
  1289. if (*p != '')
  1290. *p++ = '';
  1292. if (tTd(19, 1))
  1293. dprintf("RCPT: got arg %s="%s"n", kp,
  1294. vp == NULL ? "<null>" : vp);
  1296. rcpt_esmtp_args(a, kp, vp, e);
  1297. if (equal != NULL)
  1298. *equal = '=';
  1299. args[argno++] = kp;
  1300. if (argno >= MAXSMTPARGS - 1)
  1301. usrerr("501 5.5.4 Too many parameters");
  1302. if (Errors > 0)
  1303. break;
  1304. }
  1305. args[argno] = NULL;
  1306. if (Errors > 0)
  1307. break;
  1309. /* do config file checking of the recipient */
  1310. if (rscheck("check_rcpt", addr,
  1311.     NULL, e, TRUE, TRUE) != EX_OK ||
  1312.     Errors > 0)
  1313. break;
  1316. define(macid("{rcpt_mailer}", NULL), NULL, e);
  1317. define(macid("{rcpt_relay}", NULL), NULL, e);
  1318. define(macid("{rcpt_addr}", NULL), NULL, e);
  1319. define(macid("{dsn_notify}", NULL), NULL, e);
  1320. if (Errors > 0)
  1321. break;
  1323. /* save in recipient list after ESMTP mods */
  1324. a = recipient(a, &e->e_sendqueue, 0, e);
  1325. if (Errors > 0)
  1326. break;
  1328. /* no errors during parsing, but might be a duplicate */
  1329. e->e_to = a->q_paddr;
  1330. if (!QS_IS_BADADDR(a->q_state))
  1331. {
  1332. if (e->e_queuedir == NOQDIR)
  1333. initsys(e);
  1334. message("250 2.1.5 Recipient ok%s",
  1335. QS_IS_QUEUEUP(a->q_state) ?
  1336. " (will queue)" : "");
  1337. nrcpts++;
  1338. }
  1339. else
  1340. {
  1341. /* punt -- should keep message in ADDRESS.... */
  1342. usrerr("550 5.1.1 Addressee unknown");
  1343. }
  1344. break;
  1346.   case CMDDATA: /* data -- text of mail */
  1347. SmtpPhase = "server DATA";
  1348. if (!gotmail)
  1349. {
  1350. usrerr("503 5.0.0 Need MAIL command");
  1351. break;
  1352. }
  1353. else if (nrcpts <= 0)
  1354. {
  1355. usrerr("503 5.0.0 Need RCPT (recipient)");
  1356. break;
  1357. }
  1359. /* put back discard bit */
  1360. if (discard)
  1361. e->e_flags |= EF_DISCARD;
  1363. /* check to see if we need to re-expand aliases */
  1364. /* also reset QS_BADADDR on already-diagnosted addrs */
  1365. doublequeue = FALSE;
  1366. for (a = e->e_sendqueue; a != NULL; a = a->q_next)
  1367. {
  1368. if (QS_IS_VERIFIED(a->q_state) &&
  1369.     !bitset(EF_DISCARD, e->e_flags))
  1370. {
  1371. /* need to re-expand aliases */
  1372. doublequeue = TRUE;
  1373. }
  1374. if (QS_IS_BADADDR(a->q_state))
  1375. {
  1376. /* make this "go away" */
  1377. a->q_state = QS_DONTSEND;
  1378. }
  1379. }
  1381. /* collect the text of the message */
  1382. SmtpPhase = "collect";
  1383. buffer_errors();
  1384. collect(InChannel, TRUE, NULL, e);
  1387. /* redefine message size */
  1388. if ((q = macvalue(macid("{msg_size}", NULL), e))
  1389.     != NULL)
  1390. free(q);
  1391. snprintf(inp, sizeof inp, "%ld", e->e_msgsize);
  1392. define(macid("{msg_size}", NULL), newstr(inp), e);
  1393. if (Errors > 0)
  1394. {
  1395. /* Log who the mail would have gone to */
  1396. if (LogLevel > 8 &&
  1397.     e->e_message != NULL)
  1398. {
  1399. for (a = e->e_sendqueue;
  1400.      a != NULL;
  1401.      a = a->q_next)
  1402. {
  1403. if (!QS_IS_UNDELIVERED(a->q_state))
  1404. continue;
  1406. e->e_to = a->q_paddr;
  1407. logdelivery(NULL, NULL,
  1408.     e->e_message,
  1409.     NULL,
  1410.     (time_t) 0, e);
  1411. }
  1412. e->e_to = NULL;
  1413. }
  1414. flush_errors(TRUE);
  1415. buffer_errors();
  1416. goto abortmessage;
  1417. }
  1419. /* make sure we actually do delivery */
  1420. e->e_flags &= ~EF_CLRQUEUE;
  1422. /* from now on, we have to operate silently */
  1423. buffer_errors();
  1424. e->e_errormode = EM_MAIL;
  1426. /*
  1427. **  Arrange to send to everyone.
  1428. ** If sending to multiple people, mail back
  1429. ** errors rather than reporting directly.
  1430. ** In any case, don't mail back errors for
  1431. ** anything that has happened up to
  1432. ** now (the other end will do this).
  1433. ** Truncate our transcript -- the mail has gotten
  1434. ** to us successfully, and if we have
  1435. ** to mail this back, it will be easier
  1436. ** on the reader.
  1437. ** Then send to everyone.
  1438. ** Finally give a reply code.  If an error has
  1439. ** already been given, don't mail a
  1440. ** message back.
  1441. ** We goose error returns by clearing error bit.
  1442. */
  1444. SmtpPhase = "delivery";
  1445. (void) bftruncate(e->e_xfp);
  1446. id = e->e_id;
  1448. if (doublequeue)
  1449. {
  1450. /* make sure it is in the queue */
  1451. queueup(e, FALSE);
  1452. }
  1453. else
  1454. {
  1455. /* send to all recipients */
  1456. # if NAMED_BIND
  1457. _res.retry = TimeOuts.res_retry[RES_TO_FIRST];
  1458. _res.retrans = TimeOuts.res_retrans[RES_TO_FIRST];
  1459. # endif /* NAMED_BIND */
  1460. sendall(e, SM_DEFAULT);
  1461. }
  1462. e->e_to = NULL;
  1464. /* issue success message */
  1465. message("250 2.0.0 %s Message accepted for delivery", id);
  1467. /* if we just queued, poke it */
  1468. if (doublequeue &&
  1469.     e->e_sendmode != SM_QUEUE &&
  1470.     e->e_sendmode != SM_DEFER)
  1471. {
  1472. CurrentLA = sm_getla(e);
  1474. if (!shouldqueue(e->e_msgpriority, e->e_ctime))
  1475. {
  1476. unlockqueue(e);
  1477. (void) dowork(e->e_queuedir, id,
  1478.       TRUE, TRUE, e);
  1479. }
  1480. }
  1482.   abortmessage:
  1483. if (LogLevel > 4 && bitset(EF_LOGSENDER, e->e_flags))
  1484. logsender(e, NULL);
  1485. e->e_flags &= ~EF_LOGSENDER;
  1487. /* if in a child, pop back to our parent */
  1488. if (InChild)
  1489. finis(TRUE, ExitStat);
  1491. /* clean up a bit */
  1492. gotmail = FALSE;
  1493. dropenvelope(e, TRUE);
  1494. CurEnv = e = newenvelope(e, CurEnv);
  1495. e->e_flags = BlankEnvelope.e_flags;
  1496. break;
  1498.   case CMDRSET: /* rset -- reset state */
  1499. if (tTd(94, 100))
  1500. message("451 4.0.0 Test failure");
  1501. else
  1502. message("250 2.0.0 Reset state");
  1504. /* arrange to ignore any current send list */
  1505. e->e_sendqueue = NULL;
  1506. e->e_flags |= EF_CLRQUEUE;
  1508. if (LogLevel > 4 && bitset(EF_LOGSENDER, e->e_flags))
  1509. logsender(e, NULL);
  1510. e->e_flags &= ~EF_LOGSENDER;
  1512. if (InChild)
  1513. finis(TRUE, ExitStat);
  1515. /* clean up a bit */
  1516. gotmail = FALSE;
  1517. SuprErrs = TRUE;
  1518. dropenvelope(e, TRUE);
  1519. CurEnv = e = newenvelope(e, CurEnv);
  1520. break;
  1522.   case CMDVRFY: /* vrfy -- verify address */
  1523.   case CMDEXPN: /* expn -- expand address */
  1524. wt = checksmtpattack(&nverifies, MAXVRFYCOMMANDS, FALSE,
  1525. c->cmd_code == CMDVRFY ? "VRFY" : "EXPN", e);
  1526. previous = curtime();
  1527. vrfy = c->cmd_code == CMDVRFY;
  1528. if (bitset(vrfy ? PRIV_NOVRFY : PRIV_NOEXPN,
  1529. PrivacyFlags))
  1530. {
  1531. if (vrfy)
  1532. message("252 2.5.2 Cannot VRFY user; try RCPT to attempt delivery (or try finger)");
  1533. else
  1534. message("502 5.7.0 Sorry, we do not allow this operation");
  1535. if (LogLevel > 5)
  1536. sm_syslog(LOG_INFO, e->e_id,
  1537.   "%.100s: %s [rejected]",
  1538.   CurSmtpClient,
  1539.   shortenstring(inp, MAXSHORTSTR));
  1540. break;
  1541. }
  1542. else if (!gothello &&
  1543.  bitset(vrfy ? PRIV_NEEDVRFYHELO : PRIV_NEEDEXPNHELO,
  1544. PrivacyFlags))
  1545. {
  1546. usrerr("503 5.0.0 I demand that you introduce yourself first");
  1547. break;
  1548. }
  1549. if (runinchild(vrfy ? "SMTP-VRFY" : "SMTP-EXPN", e) > 0)
  1550. break;
  1551. if (Errors > 0)
  1552. goto undo_subproc;
  1553. if (LogLevel > 5)
  1554. sm_syslog(LOG_INFO, e->e_id,
  1555.   "%.100s: %s",
  1556.   CurSmtpClient,
  1557.   shortenstring(inp, MAXSHORTSTR));
  1558. if (setjmp(TopFrame) > 0)
  1559. goto undo_subproc;
  1560. QuickAbort = TRUE;
  1561. vrfyqueue = NULL;
  1562. if (vrfy)
  1563. e->e_flags |= EF_VRFYONLY;
  1564. while (*p != '' && isascii(*p) && isspace(*p))
  1565. p++;
  1566. if (*p == '')
  1567. {
  1568. usrerr("501 5.5.2 Argument required");
  1569. }
  1570. else
  1571. {
  1572. /* do config file checking of the address */
  1573. if (rscheck(vrfy ? "check_vrfy" : "check_expn",
  1574.     p, NULL, e, TRUE, FALSE) != EX_OK ||
  1575.     Errors > 0)
  1576. goto undo_subproc;
  1577. (void) sendtolist(p, NULLADDR, &vrfyqueue, 0, e);
  1578. }
  1579. if (wt > 0)
  1580. (void) sleep(wt - (curtime() - previous));
  1581. if (Errors > 0)
  1582. goto undo_subproc;
  1583. if (vrfyqueue == NULL)
  1584. {
  1585. usrerr("554 5.5.2 Nothing to %s", vrfy ? "VRFY" : "EXPN");
  1586. }
  1587. while (vrfyqueue != NULL)
  1588. {
  1589. if (!QS_IS_UNDELIVERED(vrfyqueue->q_state))
  1590. {
  1591. vrfyqueue = vrfyqueue->q_next;
  1592. continue;
  1593. }
  1595. /* see if there is more in the vrfy list */
  1596. a = vrfyqueue;
  1597. while ((a = a->q_next) != NULL &&
  1598.        (!QS_IS_UNDELIVERED(vrfyqueue->q_state)))
  1599. continue;
  1600. printvrfyaddr(vrfyqueue, a == NULL, vrfy);
  1601. vrfyqueue = a;
  1602. }
  1603. if (InChild)
  1604. finis(TRUE, ExitStat);
  1605. break;
  1607.   case CMDETRN: /* etrn -- force queue flush */
  1608. if (bitset(PRIV_NOETRN, PrivacyFlags) ||
  1609.     bitnset(D_NOETRN, d_flags))
  1610. {
  1611. /* different message for MSA ? */
  1612. message("502 5.7.0 Sorry, we do not allow this operation");
  1613. if (LogLevel > 5)
  1614. sm_syslog(LOG_INFO, e->e_id,
  1615.   "%.100s: %s [rejected]",
  1616.   CurSmtpClient,
  1617.   shortenstring(inp, MAXSHORTSTR));
  1618. break;
  1619. }
  1621. if (strlen(p) <= 0)
  1622. {
  1623. usrerr("500 5.5.2 Parameter required");
  1624. break;
  1625. }
  1627. /* crude way to avoid denial-of-service attacks */
  1628. (void) checksmtpattack(&n_etrn, MAXETRNCOMMANDS, TRUE,
  1629.      "ETRN", e);
  1631. /* do config file checking of the parameter */
  1632. if (rscheck("check_etrn", p, NULL, e, TRUE, FALSE)
  1633.     != EX_OK || Errors > 0)
  1634. break;
  1636. if (LogLevel > 5)
  1637. sm_syslog(LOG_INFO, e->e_id,
  1638.   "%.100s: ETRN %s",
  1639.   CurSmtpClient,
  1640.   shortenstring(p, MAXSHORTSTR));
  1642. id = p;
  1643. if (*id == '@')
  1644. id++;
  1645. else
  1646. *--id = '@';
  1648. if ((new = (QUEUE_CHAR *)malloc(sizeof(QUEUE_CHAR))) == NULL)
  1649. {
  1650. syserr("500 5.5.0 ETRN out of memory");
  1651. break;
  1652. }
  1653. new->queue_match = id;
  1654. new->queue_next = NULL;
  1655. QueueLimitRecipient = new;
  1656. ok = runqueue(TRUE, TRUE);
  1657. free(QueueLimitRecipient);
  1658. QueueLimitRecipient = NULL;
  1659. if (ok && Errors == 0)
  1660. message("250 2.0.0 Queuing for node %s started", p);
  1661. break;
  1663.   case CMDHELP: /* help -- give user info */
  1664. help(p, e);
  1665. break;
  1667.   case CMDNOOP: /* noop -- do nothing */
  1668. (void) checksmtpattack(&n_noop, MAXNOOPCOMMANDS, TRUE,
  1669.        "NOOP", e);
  1670. message("250 2.0.0 OK");
  1671. break;
  1673.   case CMDQUIT: /* quit -- leave mail */
  1674. message("221 2.0.0 %s closing connection", MyHostName);
  1676. /* arrange to ignore any current send list */
  1677. e->e_sendqueue = NULL;
  1679. doquit:
  1680. /* avoid future 050 messages */
  1681. disconnect(1, e);
  1684. if (InChild)
  1685. ExitStat = EX_QUIT;
  1687. if (LogLevel > 4 && bitset(EF_LOGSENDER, e->e_flags))
  1688. logsender(e, NULL);
  1689. e->e_flags &= ~EF_LOGSENDER;
  1691. if (lognullconnection && LogLevel > 5)
  1692. {
  1693. char *d;
  1695. d = macvalue(macid("{daemon_name}", NULL), e);
  1696. if (d == NULL)
  1697. d = "stdin";
  1698. sm_syslog(LOG_INFO, NULL,
  1699.  "Null connection from %.100s to %s",
  1700.   CurSmtpClient, d);
  1701. }
  1703. finis(TRUE, ExitStat);
  1704. /* NOTREACHED */
  1706.   case CMDVERB: /* set verbose mode */
  1707. if (bitset(PRIV_NOEXPN, PrivacyFlags) ||
  1708.     bitset(PRIV_NOVERB, PrivacyFlags))
  1709. {
  1710. /* this would give out the same info */
  1711. message("502 5.7.0 Verbose unavailable");
  1712. break;
  1713. }
  1714. (void) checksmtpattack(&n_noop, MAXNOOPCOMMANDS, TRUE,
  1715.        "VERB", e);
  1716. Verbose = 1;
  1717. set_delivery_mode(SM_DELIVER, e);
  1718. message("250 2.0.0 Verbose mode");
  1719. break;
  1721.   case CMDONEX: /* doing one transaction only */
  1722. (void) checksmtpattack(&n_noop, MAXNOOPCOMMANDS, TRUE,
  1723.        "ONEX", e);
  1724. OneXact = TRUE;
  1725. message("250 2.0.0 Only one transaction");
  1726. break;
  1728.   case CMDXUSR: /* initial (user) submission */
  1729. (void) checksmtpattack(&n_noop, MAXNOOPCOMMANDS, TRUE,
  1730.        "XUSR", e);
  1731. define(macid("{daemon_flags}", NULL), "cu", CurEnv);
  1732. message("250 2.0.0 Initial submission");
  1733. break;
  1735. # if SMTPDEBUG
  1736.   case CMDDBGQSHOW: /* show queues */
  1737. printf("Send Queue=");
  1738. printaddr(e->e_sendqueue, TRUE);
  1739. break;
  1741.   case CMDDBGDEBUG: /* set debug mode */
  1742. tTsetup(tTdvect, sizeof tTdvect, "0-99.1");
  1743. tTflag(p);
  1744. message("200 Debug set");
  1745. break;
  1747. # else /* SMTPDEBUG */
  1748.   case CMDDBGQSHOW: /* show queues */
  1749.   case CMDDBGDEBUG: /* set debug mode */
  1750. # endif /* SMTPDEBUG */
  1751.   case CMDLOGBOGUS: /* bogus command */
  1752. if (LogLevel > 0)
  1753. sm_syslog(LOG_CRIT, e->e_id,
  1754.   ""%s" command from %.100s (%.100s)",
  1755.   c->cmd_name, CurSmtpClient,
  1756.   anynet_ntoa(&RealHostAddr));
  1757. /* FALLTHROUGH */
  1759.   case CMDERROR: /* unknown command */
  1760. if (++badcommands > MAXBADCOMMANDS)
  1761. {
  1762. message("421 4.7.0 %s Too many bad commands; closing connection",
  1763. MyHostName);
  1765. /* arrange to ignore any current send list */
  1766. e->e_sendqueue = NULL;
  1767. goto doquit;
  1768. }
  1770. usrerr("500 5.5.1 Command unrecognized: "%s"",
  1771.        shortenstring(inp, MAXSHORTSTR));
  1772. break;
  1774.   case CMDUNIMPL:
  1775. usrerr("502 5.5.1 Command not implemented: "%s"",
  1776.        shortenstring(inp, MAXSHORTSTR));
  1777. break;
  1779.   default:
  1780. errno = 0;
  1781. syserr("500 5.5.0 smtp: unknown code %d", c->cmd_code);
  1782. break;
  1783. }
  1784. # if SASL
  1785. }
  1786. # endif /* SASL */
  1787. }
  1789. }
  1790. /*
  1791. **  CHECKSMTPATTACK -- check for denial-of-service attack by repetition
  1792. **
  1793. ** Parameters:
  1794. ** pcounter -- pointer to a counter for this command.
  1795. ** maxcount -- maximum value for this counter before we
  1796. ** slow down.
  1797. ** waitnow -- sleep now (in this routine)?
  1798. ** cname -- command name for logging.
  1799. ** e -- the current envelope.
  1800. **
  1801. ** Returns:
  1802. ** none.
  1803. **
  1804. ** Side Effects:
  1805. ** Slows down if we seem to be under attack.
  1806. */
  1808. static time_t
  1809. checksmtpattack(pcounter, maxcount, waitnow, cname, e)
  1810. volatile int *pcounter;
  1811. int maxcount;
  1812. bool waitnow;
  1813. char *cname;
  1814. ENVELOPE *e;
  1815. {
  1816. if (++(*pcounter) >= maxcount)
  1817. {
  1818. time_t s;
  1820. if (*pcounter == maxcount && LogLevel > 5)
  1821. {
  1822. sm_syslog(LOG_INFO, e->e_id,
  1823.   "%.100s: %.40s attack?",
  1824.   CurSmtpClient, cname);
  1825. }
  1826. s = 1 << (*pcounter - maxcount);
  1827. if (s >= MAXTIMEOUT)
  1828. s = MAXTIMEOUT;
  1829. /* sleep at least 1 second before returning */
  1830. (void) sleep(*pcounter / maxcount);
  1831. s -= *pcounter / maxcount;
  1832. if (waitnow)
  1833. {
  1834. (void) sleep(s);
  1835. return(0);
  1836. }
  1837. return(s);
  1838. }
  1839. return((time_t) 0);
  1840. }
  1841. /*
  1842. **  SKIPWORD -- skip a fixed word.
  1843. **
  1844. ** Parameters:
  1845. ** p -- place to start looking.
  1846. ** w -- word to skip.
  1847. **
  1848. ** Returns:
  1849. ** p following w.
  1850. ** NULL on error.
  1851. **
  1852. ** Side Effects:
  1853. ** clobbers the p data area.
  1854. */
  1856. static char *
  1857. skipword(p, w)
  1858. register char *volatile p;
  1859. char *w;
  1860. {
  1861. register char *q;
  1862. char *firstp = p;
  1864. /* find beginning of word */
  1865. while (isascii(*p) && isspace(*p))
  1866. p++;
  1867. q = p;
  1869. /* find end of word */
  1870. while (*p != '' && *p != ':' && !(isascii(*p) && isspace(*p)))
  1871. p++;
  1872. while (isascii(*p) && isspace(*p))
  1873. *p++ = '';
  1874. if (*p != ':')
  1875. {
  1876.   syntax:
  1877. usrerr("501 5.5.2 Syntax error in parameters scanning "%s"",
  1878. shortenstring(firstp, MAXSHORTSTR));
  1879. return NULL;
  1880. }
  1881. *p++ = '';
  1882. while (isascii(*p) && isspace(*p))
  1883. p++;
  1885. if (*p == '')
  1886. goto syntax;
  1888. /* see if the input word matches desired word */
  1889. if (strcasecmp(q, w))
  1890. goto syntax;
  1892. return p;
  1893. }
  1894. /*
  1895. **  MAIL_ESMTP_ARGS -- process ESMTP arguments from MAIL line
  1896. **
  1897. ** Parameters:
  1898. ** kp -- the parameter key.
  1899. ** vp -- the value of that parameter.
  1900. ** e -- the envelope.
  1901. **
  1902. ** Returns:
  1903. ** none.
  1904. */
  1906. static void
  1907. mail_esmtp_args(kp, vp, e)
  1908. char *kp;
  1909. char *vp;
  1910. ENVELOPE *e;
  1911. {
  1912. if (strcasecmp(kp, "size") == 0)
  1913. {
  1914. if (vp == NULL)
  1915. {
  1916. usrerr("501 5.5.2 SIZE requires a value");
  1917. /* NOTREACHED */
  1918. }
  1919. define(macid("{msg_size}", NULL), newstr(vp), e);
  1920. # if defined(__STDC__) && !defined(BROKEN_ANSI_LIBRARY)
  1921. e->e_msgsize = strtoul(vp, (char **) NULL, 10);
  1922. # else /* defined(__STDC__) && !defined(BROKEN_ANSI_LIBRARY) */
  1923. e->e_msgsize = strtol(vp, (char **) NULL, 10);
  1924. # endif /* defined(__STDC__) && !defined(BROKEN_ANSI_LIBRARY) */
  1925. }
  1926. else if (strcasecmp(kp, "body") == 0)
  1927. {
  1928. if (vp == NULL)
  1929. {
  1930. usrerr("501 5.5.2 BODY requires a value");
  1931. /* NOTREACHED */
  1932. }
  1933. else if (strcasecmp(vp, "8bitmime") == 0)
  1934. {
  1935. SevenBitInput = FALSE;
  1936. }
  1937. else if (strcasecmp(vp, "7bit") == 0)
  1938. {
  1939. SevenBitInput = TRUE;
  1940. }
  1941. else
  1942. {
  1943. usrerr("501 5.5.4 Unknown BODY type %s",
  1944. vp);
  1945. /* NOTREACHED */
  1946. }
  1947. e->e_bodytype = newstr(vp);
  1948. }
  1949. else if (strcasecmp(kp, "envid") == 0)
  1950. {
  1951. if (bitset(PRIV_NORECEIPTS, PrivacyFlags))
  1952. {
  1953. usrerr("504 5.7.0 Sorry, ENVID not supported, we do not allow DSN");
  1954. /* NOTREACHED */
  1955. }
  1956. if (vp == NULL)
  1957. {
  1958. usrerr("501 5.5.2 ENVID requires a value");
  1959. /* NOTREACHED */
  1960. }
  1961. if (!xtextok(vp))
  1962. {
  1963. usrerr("501 5.5.4 Syntax error in ENVID parameter value");
  1964. /* NOTREACHED */
  1965. }
  1966. if (e->e_envid != NULL)
  1967. {
  1968. usrerr("501 5.5.0 Duplicate ENVID parameter");
  1969. /* NOTREACHED */
  1970. }
  1971. e->e_envid = newstr(vp);
  1972. define(macid("{dsn_envid}", NULL), newstr(vp), e);
  1973. }
  1974. else if (strcasecmp(kp, "ret") == 0)
  1975. {
  1976. if (bitset(PRIV_NORECEIPTS, PrivacyFlags))
  1977. {
  1978. usrerr("504 5.7.0 Sorry, RET not supported, we do not allow DSN");
  1979. /* NOTREACHED */
  1980. }
  1981. if (vp == NULL)
  1982. {
  1983. usrerr("501 5.5.2 RET requires a value");
  1984. /* NOTREACHED */
  1985. }
  1986. if (bitset(EF_RET_PARAM, e->e_flags))
  1987. {
  1988. usrerr("501 5.5.0 Duplicate RET parameter");
  1989. /* NOTREACHED */
  1990. }
  1991. e->e_flags |= EF_RET_PARAM;
  1992. if (strcasecmp(vp, "hdrs") == 0)
  1993. e->e_flags |= EF_NO_BODY_RETN;
  1994. else if (strcasecmp(vp, "full") != 0)
  1995. {
  1996. usrerr("501 5.5.2 Bad argument "%s" to RET", vp);
  1997. /* NOTREACHED */
  1998. }
  1999. define(macid("{dsn_ret}", NULL), newstr(vp), e);
  2000. }
  2001. # if SASL
  2002. else if (strcasecmp(kp, "auth") == 0)
  2003. {
  2004. int len;
  2005. char *q;
  2006. char *auth_param; /* the value of the AUTH=x */
  2007. bool saveQuickAbort = QuickAbort;
  2008. bool saveSuprErrs = SuprErrs;
  2009. char pbuf[256];
  2011. if (vp == NULL)
  2012. {
  2013. usrerr("501 5.5.2 AUTH= requires a value");
  2014. /* NOTREACHED */
  2015. }
  2016. if (e->e_auth_param != NULL)
  2017. {
  2018. usrerr("501 5.5.0 Duplicate AUTH parameter");
  2019. /* NOTREACHED */
  2020. }
  2021. if ((q = strchr(vp, ' ')) != NULL)
  2022. len = q - vp + 1;
  2023. else
  2024. len = strlen(vp) + 1;
  2025. auth_param = xalloc(len);
  2026. (void) strlcpy(auth_param, vp, len);
  2027. if (!xtextok(auth_param))
  2028. {
  2029. usrerr("501 5.5.4 Syntax error in AUTH parameter value");
  2030. /* just a warning? */
  2031. /* NOTREACHED */
  2032. }
  2034. /* XXX this might be cut off */
  2035. snprintf(pbuf, sizeof pbuf, "%s", xuntextify(auth_param));
  2036. /* xalloc() the buffer instead? */
  2038. /* XXX define this always or only if trusted? */
  2039. define(macid("{auth_author}", NULL), newstr(pbuf), e);
  2041. /*
  2042. **  call Strust_auth to find out whether
  2043. **  auth_param is acceptable (trusted)
  2044. **  we shouldn't trust it if not authenticated
  2045. **  (required by RFC, leave it to ruleset?)
  2046. */
  2048. SuprErrs = TRUE;
  2049. QuickAbort = FALSE;
  2050. if (strcmp(auth_param, "<>") != 0 &&
  2051.      (rscheck("trust_auth", pbuf, NULL, e, TRUE, FALSE)
  2052.       != EX_OK || Errors > 0))
  2053. {
  2054. if (tTd(95, 8))
  2055. {
  2056. q = e->e_auth_param;
  2057. dprintf("auth="%.100s" not trusted user="%.100s"n",
  2058. pbuf, (q == NULL) ? "" : q);
  2059. }
  2060. /* not trusted */
  2061. e->e_auth_param = newstr("<>");
  2062. }
  2063. else
  2064. {
  2065. if (tTd(95, 8))
  2066. dprintf("auth="%.100s" trustedn", pbuf);
  2067. e->e_auth_param = newstr(auth_param);
  2068. }
  2069. free(auth_param);
  2070. /* reset values */
  2071. Errors = 0;
  2072. QuickAbort = saveQuickAbort;
  2073. SuprErrs = saveSuprErrs;
  2074. }
  2075. # endif /* SASL */
  2076. else
  2077. {
  2078. usrerr("501 5.5.4 %s parameter unrecognized", kp);
  2079. /* NOTREACHED */
  2080. }
  2081. }
  2082. /*
  2083. **  RCPT_ESMTP_ARGS -- process ESMTP arguments from RCPT line
  2084. **
  2085. ** Parameters:
  2086. ** a -- the address corresponding to the To: parameter.
  2087. ** kp -- the parameter key.
  2088. ** vp -- the value of that parameter.
  2089. ** e -- the envelope.
  2090. **
  2091. ** Returns:
  2092. ** none.
  2093. */
  2095. static void
  2096. rcpt_esmtp_args(a, kp, vp, e)
  2097. ADDRESS *a;
  2098. char *kp;
  2099. char *vp;
  2100. ENVELOPE *e;
  2101. {
  2102. if (strcasecmp(kp, "notify") == 0)
  2103. {
  2104. char *p;
  2106. if (bitset(PRIV_NORECEIPTS, PrivacyFlags))
  2107. {
  2108. usrerr("504 5.7.0 Sorry, NOTIFY not supported, we do not allow DSN");
  2109. /* NOTREACHED */
  2110. }
  2111. if (vp == NULL)
  2112. {
  2113. usrerr("501 5.5.2 NOTIFY requires a value");
  2114. /* NOTREACHED */
  2115. }
  2116. a->q_flags &= ~(QPINGONSUCCESS|QPINGONFAILURE|QPINGONDELAY);
  2117. a->q_flags |= QHASNOTIFY;
  2118. define(macid("{dsn_notify}", NULL), newstr(vp), e);
  2120. if (strcasecmp(vp, "never") == 0)
  2121. return;
  2122. for (p = vp; p != NULL; vp = p)
  2123. {
  2124. p = strchr(p, ',');
  2125. if (p != NULL)
  2126. *p++ = '';
  2127. if (strcasecmp(vp, "success") == 0)
  2128. a->q_flags |= QPINGONSUCCESS;
  2129. else if (strcasecmp(vp, "failure") == 0)
  2130. a->q_flags |= QPINGONFAILURE;
  2131. else if (strcasecmp(vp, "delay") == 0)
  2132. a->q_flags |= QPINGONDELAY;
  2133. else
  2134. {
  2135. usrerr("501 5.5.4 Bad argument "%s"  to NOTIFY",
  2136. vp);
  2137. /* NOTREACHED */
  2138. }
  2139. }
  2140. }
  2141. else if (strcasecmp(kp, "orcpt") == 0)
  2142. {
  2143. if (bitset(PRIV_NORECEIPTS, PrivacyFlags))
  2144. {
  2145. usrerr("504 5.7.0 Sorry, ORCPT not supported, we do not allow DSN");
  2146. /* NOTREACHED */
  2147. }
  2148. if (vp == NULL)
  2149. {
  2150. usrerr("501 5.5.2 ORCPT requires a value");
  2151. /* NOTREACHED */
  2152. }
  2153. if (strchr(vp, ';') == NULL || !xtextok(vp))
  2154. {
  2155. usrerr("501 5.5.4 Syntax error in ORCPT parameter value");
  2156. /* NOTREACHED */
  2157. }
  2158. if (a->q_orcpt != NULL)
  2159. {
  2160. usrerr("501 5.5.0 Duplicate ORCPT parameter");
  2161. /* NOTREACHED */
  2162. }
  2163. a->q_orcpt = newstr(vp);
  2164. }
  2165. else
  2166. {
  2167. usrerr("501 5.5.4 %s parameter unrecognized", kp);
  2168. /* NOTREACHED */
  2169. }
  2170. }
  2171. /*
  2172. **  PRINTVRFYADDR -- print an entry in the verify queue
  2173. **
  2174. ** Parameters:
  2175. ** a -- the address to print
  2176. ** last -- set if this is the last one.
  2177. ** vrfy -- set if this is a VRFY command.
  2178. **
  2179. ** Returns:
  2180. ** none.
  2181. **
  2182. ** Side Effects:
  2183. ** Prints the appropriate 250 codes.
  2184. */
  2185. #define OFFF (3 + 1 + 5 + 1) /* offset in fmt: SMTP reply + enh. code */
  2187. static void
  2188. printvrfyaddr(a, last, vrfy)
  2189. register ADDRESS *a;
  2190. bool last;
  2191. bool vrfy;
  2192. {
  2193. char fmtbuf[30];
  2195. if (vrfy && a->q_mailer != NULL &&
  2196.     !bitnset(M_VRFY250, a->q_mailer->m_flags))
  2197. (void) strlcpy(fmtbuf, "252", sizeof fmtbuf);
  2198. else
  2199. (void) strlcpy(fmtbuf, "250", sizeof fmtbuf);
  2200. fmtbuf[3] = last ? ' ' : '-';
  2201. (void) strlcpy(&fmtbuf[4], "2.1.5 ", sizeof fmtbuf - 4);
  2202. if (a->q_fullname == NULL)
  2203. {
  2204. if ((a->q_mailer == NULL ||
  2205.      a->q_mailer->m_addrtype == NULL ||
  2206.      strcasecmp(a->q_mailer->m_addrtype, "rfc822") == 0) &&
  2207.     strchr(a->q_user, '@') == NULL)
  2208. (void) strlcpy(&fmtbuf[OFFF], "<%s@%s>",
  2209.        sizeof fmtbuf - OFFF);
  2210. else
  2211. (void) strlcpy(&fmtbuf[OFFF], "<%s>",
  2212.        sizeof fmtbuf - OFFF);
  2213. message(fmtbuf, a->q_user, MyHostName);
  2214. }
  2215. else
  2216. {
  2217. if ((a->q_mailer == NULL ||
  2218.      a->q_mailer->m_addrtype == NULL ||
  2219.      strcasecmp(a->q_mailer->m_addrtype, "rfc822") == 0) &&
  2220.     strchr(a->q_user, '@') == NULL)
  2221. (void) strlcpy(&fmtbuf[OFFF], "%s <%s@%s>",
  2222.        sizeof fmtbuf - OFFF);
  2223. else
  2224. (void) strlcpy(&fmtbuf[OFFF], "%s <%s>",
  2225.        sizeof fmtbuf - OFFF);
  2226. message(fmtbuf, a->q_fullname, a->q_user, MyHostName);
  2227. }
  2228. }
  2229. /*
  2230. **  RUNINCHILD -- return twice -- once in the child, then in the parent again
  2231. **
  2232. ** Parameters:
  2233. ** label -- a string used in error messages
  2234. **
  2235. ** Returns:
  2236. ** zero in the child
  2237. ** one in the parent
  2238. **
  2239. ** Side Effects:
  2240. ** none.
  2241. */
  2243. static int
  2244. runinchild(label, e)
  2245. char *label;
  2246. register ENVELOPE *e;
  2247. {
  2248. pid_t childpid;
  2250. if (!OneXact)
  2251. {
  2252. /*
  2253. **  Disable child process reaping, in case ETRN has preceded
  2254. **  MAIL command, and then fork.
  2255. */
  2257. (void) blocksignal(SIGCHLD);
  2259. childpid = dofork();
  2260. if (childpid < 0)
  2261. {
  2262. syserr("451 4.3.0 %s: cannot fork", label);
  2263. (void) releasesignal(SIGCHLD);
  2264. return 1;
  2265. }
  2266. if (childpid > 0)
  2267. {
  2268. auto int st;
  2270. /* parent -- wait for child to complete */
  2271. sm_setproctitle(TRUE, e, "server %s child wait",
  2272. CurSmtpClient);
  2273. st = waitfor(childpid);
  2274. if (st == -1)
  2275. syserr("451 4.3.0 %s: lost child", label);
  2276. else if (!WIFEXITED(st))
  2277. syserr("451 4.3.0 %s: died on signal %d",
  2278. label, st & 0177);
  2280. /* if we exited on a QUIT command, complete the process */
  2281. if (WEXITSTATUS(st) == EX_QUIT)
  2282. {
  2283. disconnect(1, e);
  2284. finis(TRUE, ExitStat);
  2285. }
  2287. /* restore the child signal */
  2288. (void) releasesignal(SIGCHLD);
  2290. return 1;
  2291. }
  2292. else
  2293. {
  2294. /* child */
  2295. InChild = TRUE;
  2296. QuickAbort = FALSE;
  2297. clearstats();
  2298. clearenvelope(e, FALSE);
  2299. assign_queueid(e);
  2300. (void) setsignal(SIGCHLD, SIG_DFL);
  2301. (void) releasesignal(SIGCHLD);
  2302. }
  2303. }
  2304. return 0;
  2305. }
  2307. # if SASL
  2308. int
  2309. proxy_policy(context, auth_identity, requested_user, user, errstr)
  2310. void *context;
  2311. const char *auth_identity;
  2312. const char *requested_user;
  2313. const char **user;
  2314. const char **errstr;
  2315. {
  2316. if (user != NULL)
  2317. {
  2318. *user = newstr(auth_identity);
  2319. return SASL_OK;
  2320. }
  2321. return SASL_FAIL;
  2322. }
  2324. # endif /* SASL */
  2326. #endif /* SMTP */
  2327. /*
  2328. **  HELP -- implement the HELP command.
  2329. **
  2330. ** Parameters:
  2331. ** topic -- the topic we want help for.
  2332. ** e -- envelope
  2333. **
  2334. ** Returns:
  2335. ** none.
  2336. **
  2337. ** Side Effects:
  2338. ** outputs the help file to message output.
  2339. */
  2340. #define HELPVSTR "#vers "
  2341. #define HELPVERSION 2
  2343. void
  2344. help(topic, e)
  2345. char *topic;
  2346. ENVELOPE *e;
  2347. {
  2348. register FILE *hf;
  2349. register char *p;
  2350. int len;
  2351. bool noinfo;
  2352. bool first = TRUE;
  2353. long sff = SFF_OPENASROOT|SFF_REGONLY;
  2354. char buf[MAXLINE];
  2355. char inp[MAXLINE];
  2356. static int foundvers = -1;
  2357. extern char Version[];
  2359. if (DontLockReadFiles)
  2360. sff |= SFF_NOLOCK;
  2361. if (!bitnset(DBS_HELPFILEINUNSAFEDIRPATH, DontBlameSendmail))
  2362. sff |= SFF_SAFEDIRPATH;
  2364. if (HelpFile == NULL ||
  2365.     (hf = safefopen(HelpFile, O_RDONLY, 0444, sff)) == NULL)
  2366. {
  2367. /* no help */
  2368. errno = 0;
  2369. message("502 5.3.0 Sendmail %s -- HELP not implemented",
  2370. Version);
  2371. return;
  2372. }
  2374. if (topic == NULL || *topic == '')
  2375. {
  2376. topic = "smtp";
  2377. noinfo = FALSE;
  2378. }
  2379. else
  2380. {
  2381. makelower(topic);
  2382. noinfo = TRUE;
  2383. }
  2385. len = strlen(topic);
  2387. while (fgets(buf, sizeof buf, hf) != NULL)
  2388. {
  2389. if (buf[0] == '#')
  2390. {
  2391. if (foundvers < 0 &&
  2392.     strncmp(buf, HELPVSTR, strlen(HELPVSTR)) == 0)
  2393. {
  2394. int h;
  2396. if (sscanf(buf + strlen(HELPVSTR), "%d",
  2397.    &h) == 1)
  2398. foundvers = h;
  2399. }
  2400. continue;
  2401. }
  2402. if (strncmp(buf, topic, len) == 0)
  2403. {
  2404. if (first)
  2405. {
  2406. first = FALSE;
  2408. /* print version if no/old vers# in file */
  2409. if (foundvers < 2 && !noinfo)
  2410. message("214-2.0.0 This is Sendmail version %s", Version);
  2411. }
  2412. p = strpbrk(buf, " t");
  2413. if (p == NULL)
  2414. p = buf + strlen(buf) - 1;
  2415. else
  2416. p++;
  2417. fixcrlf(p, TRUE);
  2418. if (foundvers >= 2)
  2419. {
  2420. translate_dollars(p);
  2421. expand(p, inp, sizeof inp, e);
  2422. p = inp;
  2423. }
  2424. message("214-2.0.0 %s", p);
  2425. noinfo = FALSE;
  2426. }
  2427. }
  2429. if (noinfo)
  2430. message("504 5.3.0 HELP topic "%.10s" unknown", topic);
  2431. else
  2432. message("214 2.0.0 End of HELP info");
  2434. if (foundvers != 0 && foundvers < HELPVERSION)
  2435. {
  2436. if (LogLevel > 1)
  2437. sm_syslog(LOG_WARNING, e->e_id,
  2438.   "%s too old (require version %d)",
  2439.   HelpFile, HELPVERSION);
  2441. /* avoid log next time */
  2442. foundvers = 0;
  2443. }
  2445. (void) fclose(hf);
  2446. }