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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Telnet服务器 > 查看源码
daemon.c
资源名称：3.0-20000220-SNAP.tar.gz　[点击查看]
上传用户：minyiyu
上传日期：2018-12-24
资源大小：864k
文件大小：19k
源码类别：

Telnet服务器

开发平台：

Unix_Linux

daemon.c：源码内容
  1. /*
  2.  * daemon.c -- a standalone server of this project
  3.  *
  4.  * A part of BBS Express Project
  5.  *
  6.  * Copyright (c) 1998, 1999, Edward Ping-Da Chuang <edwardc@edwardc.dhs.org>
  7.  * of BBS Express Project, All rights reserved.
  8.  *
  9.  * Redistribution and use in source and binary forms, with or without
  10.  * modification, are permitted provided that the following conditions
  11.  * are met:
  12.  * 1. Redistributions of source code must retain the above copyright
  13.  *    notice, this list of conditions and the following disclaimer.
  14.  * 2. Redistributions in binary form must reproduce the above copyright
  15.  *    notice, this list of conditions and the following disclaimer in the
  16.  *    documentation and/or other materials provided with the distribution.
  17.  *
  18.  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
  19.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  20.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  21.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
  22.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  23.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  24.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  25.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  26.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  27.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  28.  * SUCH DAMAGE.
  29.  *
  30.  * CVS: $Id: daemon.c,v 1.1 2000/01/15 01:45:32 edwardc Exp $
  31.  */
  32.         
  33. #include <sys/ioctl.h>
  34. #include "bbs.h"
  36. #include <sys/wait.h>
  37. #include <netinet/in.h>
  38. #include <sys/socket.h>
  39. #include <netdb.h>
  40. #include <sys/termios.h>
  42. static const char daemon_c[] =
  43.    "$Id: daemon.c,v 1.1 2000/01/15 01:45:32 edwardc Exp $";
  44. /* Edit these lines to fit the configuration of your server */
  46. #define DEF_PORT  2000
  48. #define BBSUID      9999
  49. #define BBSGID      99
  50. #define BUFSIZE     1024
  52. #ifndef BBSHOME
  53.   #define BBSHOME     "/service/bbs"
  54. #endif
  55. #define BBSPASSWDS  BBSHOME"/.PASSWDS"
  57. /* You needn't modify any lines below unless you know what you're doing */
  59. struct fileheader currentmail;
  60. struct userec   currentuser;
  62. char            LowUserid[20];
  63. char            hostname[80];
  65. #define QLEN            5
  67. #define S_CONNECT       1
  68. #define S_LOGIN         2
  71. #define STRN_CPY(d,s,l) { strncpy((d),(s),(l)); (d)[(l)-1] = 0; }
  72. #define ANY_PORT        0
  73. #define RFC931_PORT     113
  74. #define RFC931_TIMEOUT  20
  75. #define POP3_TIMEOUT    1200
  77. static jmp_buf  timebuf;
  79. int             State;
  80. int             msock, sock; /* master server socket */
  81. static int      reaper();
  82. char            fromhost[STRLEN];
  83. char            inbuf[BUFSIZE];
  84. char            remote_userid[STRLEN];
  85. FILE           *cfp;
  86. char           *msg, *cmd;
  87. int             fd;
  88. struct fileheader *fcache;
  89. int             totalnum, totalbyte, markdel, idletime;
  90. int            *postlen;
  91. int             loginok = 0;
  93. void            log_usies();
  94. int             Quit(), User(), Pass(), Conf(), Stat(), List(), Retr(), Rset();
  95. int             Last(), Dele(), Dump(), Upld(), Mtag(), Grup(), Version(), Mget();
  97. struct commandlist {
  98. char           *name;
  99. int             (*fptr) ();
  100. }               cmdlists[] = {
  101. "retr", Retr,
  102. "dele", Dele,
  103. "user", User,
  104. "pass", Pass,
  105. "stat", Stat,
  106. "list", List,
  107. "dump", Dump,
  108. "quit", Quit,
  109. "rset", Rset,
  110. "last", Last,
  111. "conf", Conf,
  112. "upld", Upld,
  113. "mtag", Mtag,
  114. "group", Grup,
  115. "version", Version,
  116. "mget", Mget,
  117. NULL, NULL
  118. };
  120. char           *crypt();
  122. int
  123. checkpasswd(passwd, test)
  124. char           *passwd, *test;
  125. {
  126. static char     pwbuf[14];
  127. char           *pw;
  129. strncpy(pwbuf, test, 14);
  130. pw = crypt(pwbuf, passwd);
  131. return (!strcmp(pw, passwd));
  132. }
  134. static int
  135. abort_server()
  136. {
  137. log_usies("ABORT SERVER");
  138. close(msock);
  139. close(sock);
  140. exit(1);
  141. }
  143. int
  144. dokill()
  145. {
  146. return kill(0, SIGKILL);
  147. }
  149. static FILE    *
  150. fsocket(domain, type, protocol)
  151. int             domain;
  152. int             type;
  153. int             protocol;
  154. {
  155. int             s;
  156. FILE           *fp;
  158. if ((s = socket(domain, type, protocol)) < 0) {
  159. return (0);
  160. } else {
  161. if ((fp = fdopen(s, "r+")) == 0) {
  162. close(s);
  163. }
  164. return (fp);
  165. }
  166. }
  168. void
  169. outs(str)
  170. char           *str;
  171. {
  172. char            sendbuf[BUFSIZE];
  174. (void) bzero(sendbuf, sizeof(sendbuf));
  175. (void) sprintf(sendbuf, "%srn", str);
  176. (void) write(sock, sendbuf, strlen(sendbuf));
  177. }
  179. /* timeout - handle timeouts */
  180. static void
  181. timeout(sig)
  182. int             sig;
  183. {
  184. longjmp(timebuf, sig);
  185. }
  188. void
  189. rfc931(rmt_sin, our_sin, dest)
  190. struct sockaddr_in *rmt_sin;
  191. struct sockaddr_in *our_sin;
  192. char           *dest;
  193. {
  194. unsigned        rmt_port;
  195. unsigned        our_port;
  196. struct sockaddr_in rmt_query_sin;
  197. struct sockaddr_in our_query_sin;
  198. char            user[256];
  199. char            buffer[512];
  200. char           *cp;
  201. FILE           *fp;
  202. char           *result = "unknown";
  203. struct hostent *hp;
  205. /*
  206.  * Use one unbuffered stdio stream for writing to and for reading
  207.  * from the RFC931 etc. server. This is done because of a bug in the
  208.  * SunOS 4.1.x stdio library. The bug may live in other stdio
  209.  * implementations, too. When we use a single, buffered,
  210.  * bidirectional stdio stream ("r+" or "w+" mode) we read our own
  211.  * output. Such behaviour would make sense with resources that
  212.  * support random-access operations, but not with   sockets.
  213.  */
  214. if ((fp = fsocket(AF_INET, SOCK_STREAM, 0)) != 0) {
  215. setbuf(fp, (char *) 0);
  217. /*
  218.  * Set up a timer so we won't get stuck while waiting for the
  219.  * server.
  220.  */
  222. if (setjmp(timebuf) == 0) {
  223. signal(SIGALRM, (void *) timeout);
  224. alarm(RFC931_TIMEOUT);
  226. /*
  227.  * Bind the local and remote ends of the query socket
  228.  * to the same IP addresses as the connection under
  229.  * investigation. We go through all this trouble
  230.  * because the local or remote system might have more
  231.  * than one network address. The RFC931 etc.  client
  232.  * sends only port numbers; the server takes the IP
  233.  * addresses from the query socket.
  234.  */
  236. our_query_sin = *our_sin;
  237. our_query_sin.sin_port = htons(ANY_PORT);
  238. rmt_query_sin = *rmt_sin;
  239. rmt_query_sin.sin_port = htons(RFC931_PORT);
  241. if (bind(fileno(fp), (struct sockaddr *) & our_query_sin,
  242.  sizeof(our_query_sin)) >= 0 &&
  243.     connect(fileno(fp), (struct sockaddr *) & rmt_query_sin,
  244.     sizeof(rmt_query_sin)) >= 0) {
  246. /*
  247.  * Send query to server. Neglect the risk
  248.  * that a 13-byte write would have to be
  249.  * fragmented by the local system and cause
  250.  * trouble with buggy System V stdio
  251.  * libraries.
  252.  */
  254. fprintf(fp, "%u,%urn",
  255. ntohs(rmt_sin->sin_port),
  256. ntohs(our_sin->sin_port));
  257. fflush(fp);
  259. /*
  260.  * Read response from server. Use
  261.  * fgets()/sscanf() so we can work around
  262.  * System V stdio libraries that incorrectly
  263.  * assume EOF when a read from a socket
  264.  * returns less than requested.
  265.  */
  267. if (fgets(buffer, sizeof(buffer), fp) != 0
  268.     && ferror(fp) == 0 && feof(fp) == 0
  269.     && sscanf(buffer, "%u , %u : USERID :%*[^:]:%255s",
  270.     &rmt_port, &our_port, user) == 3
  271.     && ntohs(rmt_sin->sin_port) == rmt_port
  272.   && ntohs(our_sin->sin_port) == our_port) {
  274. /*
  275.  * Strip trailing carriage return. It
  276.  * is part of the protocol, not part
  277.  * of the data.
  278.  */
  280. if (cp = strchr(user, 'r'))
  281. *cp = 0;
  282. result = user;
  283. }
  284. }
  285. alarm(0);
  286. }
  287. fclose(fp);
  288. }
  289. STRN_CPY(dest, result, 60);
  291. if (strcmp(dest, "unknown") == 0)
  292. strcpy(dest, "");
  293. else
  294. strcat(dest, "@");
  296. hp = gethostbyaddr((char *) &rmt_sin->sin_addr, sizeof(struct in_addr),
  297.    rmt_sin->sin_family);
  298. if (hp)
  299. strcat(dest, hp->h_name);
  300. else
  301. strcat(dest, (char *) inet_ntoa(rmt_sin->sin_addr));
  303. }
  305. int
  306. Isspace(ch)
  307. char            ch;
  308. {
  309. return (ch == ' ' || ch == 't' || ch == 10 || ch == 13);
  310. }
  312. char           *
  313. nextwordlower(str)
  314. char          **str;
  315. {
  316. char           *p;
  318. while (Isspace(**str))
  319. (*str)++;
  320. p = (*str);
  322. while (**str && !Isspace(**str)) {
  323. **str = tolower(**str);
  324. (*str)++;
  325. }
  327. if (**str) {
  328. **str = '';
  329. (*str)++;
  330. }
  331. return p;
  332. }
  334. char           *
  335. nextword(str)
  336. char          **str;
  337. {
  338. char           *p;
  340. while (Isspace(**str))
  341. (*str)++;
  342. p = (*str);
  344. while (**str && !Isspace(**str))
  345. (*str)++;
  347. if (**str) {
  348. **str = '';
  349. (*str)++;
  350. }
  351. return p;
  352. }
  354. void
  355. Init()
  356. {
  357. State = S_CONNECT;
  358. LowUserid[0] = '';
  359. markdel = 0;
  360. idletime = 0;
  361. (void) gethostname(hostname, 80);
  362. }
  364. void
  365. Login_init()
  366. {
  367. int             fd, i;
  368. char           *ptr;
  369. struct stat     st;
  371. totalnum = totalbyte = 0;
  372. sprintf(genbuf, "mail/%c/%s/.DIR", toupper(*LowUserid), LowUserid);
  373. if (stat(genbuf, &st) == -1 || st.st_size == 0) {
  374. return;
  375. }
  376. totalnum = st.st_size / sizeof(struct fileheader);
  377. fcache = (struct fileheader *) malloc(st.st_size);
  378. postlen = (int *) malloc(sizeof(int) * totalnum);
  379. fd = open(genbuf, O_RDONLY);
  380. read(fd, fcache, st.st_size);
  381. close(fd);
  383. for (i = 0; i < totalnum; i++) {
  384. if (index(fcache[i].owner, '@') == NULL) {
  385. if (ptr = strchr(fcache[i].owner, ' '))
  386. *ptr = '';
  387. sprintf(genbuf, ".bbs@%s", hostname);
  388. strcat(fcache[i].owner, genbuf);
  389. }
  390. sprintf(genbuf, "mail/%c/%s/%s", toupper(*LowUserid), LowUserid, fcache[i].filename);
  391. if (stat(genbuf, &st) == -1)
  392. st.st_size = 0;
  393. postlen[i] = st.st_size + strlen(fcache[i].owner) + 10 + strlen(fcache[i].title)
  394. + 10 + 40;
  395. totalbyte += postlen[i];
  396. fcache[i].accessed[0] = ' ';
  397. }
  398. }
  400. void
  401. pop3_timeout()
  402. {
  403. idletime++;
  404. if (idletime > 5) {
  405. log_usies("ABORT - TIMEOUT");
  406. fclose(cfp);
  407. close(sock);
  408. exit(1);
  409. }
  410. alarm(POP3_TIMEOUT);
  411. }
  414. main(argc, argv)
  415. int             argc;
  416. char          **argv;
  417. {
  419. struct sockaddr_in fsin, our;
  420. int             on, alen, len, i, n;
  421. char           *str;
  422. int             portnum;
  423. int             childpid;
  425. if ( argc == 1 )
  426. portnum = (int) DEF_PORT;
  427. else
  428. portnum = atoi(argv[1]);
  430. if (fork())
  431. exit(0);
  433. fprintf(stderr,"nexpress[%d] at port %d startedn",getpid(),portnum);
  435. for (n = 0; n < 10; n++)
  436. close(n);
  437. open("/dev/null", O_RDONLY);
  438. dup2(0, 1);
  439. dup2(0, 2);
  440. if ((n = open("/dev/tty", O_RDWR)) > 0) {
  441. ioctl(n, TIOCNOTTY, 0);
  442. close(n);
  443. }
  444. if ((msock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
  445. exit(1);
  446. }
  447. setsockopt(msock, SOL_SOCKET, SO_REUSEADDR, (char *) &on, sizeof(on));
  448. bzero((char *) &fsin, sizeof(fsin));
  449. fsin.sin_family = AF_INET;
  450. fsin.sin_addr.s_addr = htonl(INADDR_ANY);
  451. fsin.sin_port = htons(portnum);
  453. if (bind(msock, (struct sockaddr *) & fsin, sizeof(fsin)) < 0) {
  454. exit(1);
  455. }
  456. signal(SIGHUP, (void *) abort_server);
  457. signal(SIGCHLD, (void *) reaper);
  459. listen(msock, QLEN);
  461. while (1) {
  463. alen = sizeof(fsin);
  464. sock = accept(msock, (struct sockaddr *) & fsin, &alen);
  465. if ((sock < 0) && (errno == EINTR))
  466. continue;
  468. if ((childpid = fork()) < 0) {
  469. exit(1);
  470. }
  471. switch (childpid) {
  472. case 0: /* child process */
  473. close(msock);
  475. setgid(BBSGID);
  476. setuid(BBSUID);
  478. strcpy(fromhost, (char *) inet_ntoa(fsin.sin_addr));
  479. len = sizeof our;
  480. getsockname(sock, (struct sockaddr *) & our, &len);
  482. Init();
  484. rfc931(&fsin, &our, remote_userid);
  486. cfp = fdopen(sock, "r+");
  487. setbuf(cfp, (char *) 0);
  489. sprintf(genbuf, "200 BlueWave Express server at %s starting, nice to see you.", hostname);
  490. outs(genbuf);
  492. chdir(BBSHOME);
  494. log_usies("CONNECT");
  495. alarm(0);
  496. signal(SIGALRM, (void *) pop3_timeout);
  497. alarm(POP3_TIMEOUT);
  499. while (fgets(inbuf, sizeof(inbuf), cfp) != 0) {
  501. idletime = 0;
  503. msg = inbuf;
  505. inbuf[strlen(inbuf) - 1] = '';
  506. if (inbuf[strlen(inbuf) - 1] == 'r')
  507. inbuf[strlen(inbuf) - 1] = '';
  508. cmd = nextwordlower(&msg);
  510. if (*cmd == 0)
  511. continue;
  513. i = 0;
  514. while ((str = cmdlists[i].name) != NULL) {
  515. if (strcmp(cmd, str) == 0)
  516. break;
  517. i++;
  518. }
  520. if (str == NULL) {
  521. sprintf(genbuf, "500 Unknown command: "%s".", cmd);
  522. outs(genbuf);
  523. } else
  524. (*cmdlists[i].fptr) ();
  526. }
  528. if (State == S_LOGIN) {
  529. free(fcache);
  530. free(postlen);
  531. }
  532. log_usies("ABORT");
  533. fclose(cfp);
  534. close(sock);
  535. exit(0);
  536. break;
  537. default: /* parent process */
  538. close(sock);
  539. break;
  540. }
  541. }
  542. }
  544. static int
  545. reaper()
  546. {
  547. int             state, pid;
  548. while ((pid = waitpid(-1, &state, WNOHANG | WUNTRACED)) > 0);
  549. return 0;
  550. }
  552. int
  553. Conf()
  554. {
  555. if (State != S_LOGIN) {
  556. outs("999 Unknown command: "conf".");
  557. return -1;
  558. }
  560. b_create();
  561. return 0;
  562. }
  564. int
  565. Grup()
  566. {
  567. if (State != S_LOGIN) {
  568. outs("999 Unknown command: "group".");
  569. return -1;
  570. }
  572. return(group());
  573. }
  575. int
  576. Version()
  577. {
  578. extern char c_express_c[], mmencode_c[], stuff_c[], bigfile_c[];
  580. sprintf(genbuf, "200 %s",daemon_c);
  581. outs(genbuf);
  582. sprintf(genbuf, "200 %s",c_express_c);
  583. outs(genbuf);
  584. sprintf(genbuf, "200 %s",mmencode_c);
  585. outs(genbuf);
  586. sprintf(genbuf, "200 %s",stuff_c);
  587. outs(genbuf);
  588. sprintf(genbuf, "200 %s",bigfile_c);
  589. outs(genbuf);
  590. }
  592. int
  593. Mtag()
  594. {
  595. if (!loginok) {
  596. outs("402 USER assign first.");
  597. return -1;
  598. }
  600. tagmail();
  601. return 0;
  603. }
  605. int
  606. get_userdata(user)
  607. char           *user;
  608. {
  609. FILE           *rec;
  610. int             found = 0;
  612. if ((rec = fopen(BBSPASSWDS, "rb")) == NULL)
  613. return -1;
  614. while (1) {
  615. if (fread(&currentuser, sizeof(currentuser), 1, rec) <= 0)
  616. break;
  617. if (currentuser.numlogins <= 0)
  618. continue;
  619. /* edwardc.990111 it may case insensetive */
  620. if (strcasecmp(user, currentuser.userid) == 0 ) {
  621. found = 1;
  622. break;
  623. }
  624. }
  625. fclose(rec);
  626. return found;
  627. }
  629. int
  630. User()
  631. {
  633. if (State == S_LOGIN) {
  634. outs("999 Unknown command: "user".");
  635. return -1;
  636. }
  637. cmd = nextwordlower(&msg);
  639. if ( strcasecmp(cmd, "guest") == 0 ) {
  640. sprintf(genbuf, "501 Unknown user "%s".", cmd);
  641. outs(genbuf);
  642. return -1;
  643. }
  645. if (get_userdata(cmd) == 1) {
  646. strcpy(LowUserid, cmd);
  647. sprintf(genbuf, "300 Password required for [%s]", currentuser.userid);
  648. outs(genbuf);
  649. return 0;
  650. } else {
  651. sprintf(genbuf, "501 Unknown user: "%s".", cmd);
  652. outs(genbuf);
  653. return -1;
  654. }
  655. }
  657. void
  658. log_usies(buf)
  659. char           *buf;
  660. {
  661. FILE           *fp;
  663. if ((fp = fopen("reclog/express.log", "a")) != NULL) {
  664. time_t          now;
  665. struct tm      *p;
  667. time(&now);
  668. p = localtime(&now);
  669. fprintf(fp, "%02d/%02d/%02d %02d:%02d:%02d [%s](%s) %sn",
  670. p->tm_year, p->tm_mon + 1, p->tm_mday, p->tm_hour, p->tm_min,
  671.     p->tm_sec, currentuser.userid ? currentuser.userid : "",
  672. remote_userid ? remote_userid : "", buf);
  673. fflush(fp);
  674. fclose(fp);
  675. }
  676. }
  678. int
  679. Retr()
  680. {
  682. if (State != S_LOGIN) {
  683. outs("999 Unknown command: "retr".");
  684. return -1;
  685. }
  686. compress();
  687. }
  690. int
  691. Stat()
  692. {
  693. if (State != S_LOGIN) {
  694. outs("999 Unknown command: "stat".");
  695. return -1;
  696. }
  697. cmd = nextword(&msg);
  699. if ( *cmd == 0 ) {
  700.      sprintf(genbuf, "200 %d %d", totalnum, totalbyte);
  701.    outs(genbuf);
  702. } else if ( strcasecmp(cmd, "blist") == 0 ) {
  703.    statblist();
  704. } else {
  705.    outs("511 unknow parameter for "stat"");
  706. }
  708. return 0;
  709. }
  712. int
  713. Rset()
  714. {
  715. int             i;
  717. if (State != S_LOGIN) {
  718. outs("999 Unknown command: "rset".");
  719. return -1;
  720. }
  721. for (i = 0; i < totalnum; i++) {
  722. fcache[i].accessed[0] = ' ';
  723. }
  724. markdel = 0;
  725. sprintf(genbuf, "204 Maildrop has %d messages (%d octets)", totalnum, totalbyte);
  726. outs(genbuf);
  727. return 0;
  728. }
  730. int
  731. List()
  732. {
  733. int             i;
  735. if (State != S_LOGIN) {
  736. outs("999 Unknown command: "list".");
  737. return -1;
  738. }
  739. cmd = nextword(&msg);
  741. if (*cmd == 0) {
  742. sprintf(genbuf, "205 %d messages (%d octets)", totalnum, totalbyte);
  743. outs(genbuf);
  744. for (i = 0; i < totalnum; i++) {
  745. if (fcache[i].accessed[0] == ' ') {
  746. sprintf(genbuf, "%d %d", i + 1, postlen[i]);
  747. outs(genbuf);
  748. }
  749. }
  750. outs(".");
  751. } else {
  752. i = atoi(cmd);
  753. if (i <= 0 || totalnum < i) {
  754. sprintf(genbuf, "503 Message %d does not exist.", i);
  755. outs(genbuf);
  756. return -1;
  757. } else if (fcache[i - 1].accessed[0] == 'X') {
  758. sprintf(genbuf, "504 Message %d has been deleted.", i);
  759. outs(genbuf);
  760. return -1;
  761. }
  762. sprintf(genbuf, "205 %d %d", i, postlen[i - 1]);
  763. outs(genbuf);
  764. }
  765. return 0;
  766. }
  768. int
  769. Dump()
  770. {
  772. if (State != S_LOGIN) {
  773. outs("999 Unknown command: "uidl".");
  774. return -1;
  775. }
  776. cmd = nextword(&msg);
  778. outs("250 Data follow up");
  779. if ( strcasecmp(cmd, "boards") == 0 )
  780. boardlist();
  781. else {
  782. outs("250 Data follow up");
  783. dumplist();
  784. }
  786. return 0;
  788. }
  791. int
  792. Pass()
  793. {
  794. if (State == S_LOGIN) {
  795. outs("-ERR Unknown command: "pass".");
  796. return -1;
  797. }
  798. cmd = nextword(&msg);
  800. if (*cmd == 0) {
  801. outs("-ERR Too few arguments for the pass command.");
  802. return -1;
  803. }
  804. if (LowUserid[0] == '') {
  805. outs("-ERR need a USER");
  806. return -1;
  807. }
  808. if (!checkpasswd(currentuser.passwd, cmd)) {
  809. sprintf(genbuf, "-ERR Password supplied for "%s.bbs" is incorrect.", LowUserid);
  810. outs(genbuf);
  811. LowUserid[0] = '';
  812. log_usies("ERROR PASSWD");
  813. return -1;
  814. }
  815. if (State == S_CONNECT) {
  816. log_usies("ENTER");
  817. State = S_LOGIN;
  818. }
  819. Login_init();
  820. loginok = 1;
  821. express();
  822. return 0;
  823. }
  825. int
  826. Last()
  827. {
  828. if (State != S_LOGIN) {
  829. outs("-ERR Unknown command: "last".");
  830. return -1;
  831. }
  832.  
  833. cmd = nextword(&msg);
  835. tagnew();
  836. }
  838. int
  839. Upld()
  840. {
  841. if (State != S_LOGIN) {
  842. outs("-ERR Unknown command: "Upld".");
  843. return -1;
  844. }
  845. }
  847. int
  848. Dele()
  849. {
  850. int             num;
  852. if (State != S_LOGIN) {
  853. outs("-ERR Unknown command: "dele".");
  854. return -1;
  855. }
  856. cmd = nextword(&msg);
  858. if (*cmd == 0) {
  859. outs("-ERR Too few arguments for the dele command.");
  860. return -1;
  861. }
  862. num = atoi(cmd);
  863. if (num <= 0 || totalnum < num) {
  864. sprintf(genbuf, "-ERR Message %d does not exist.", num);
  865. outs(genbuf);
  866. return -1;
  867. } else if (fcache[num - 1].accessed[0] == 'X') {
  868. sprintf(genbuf, "-ERR Message %d has already been deleted.", num);
  869. outs(genbuf);
  870. return -1;
  871. }
  872. fcache[num-1].accessed[0] = 'X';
  873. markdel++;
  874. sprintf(genbuf, "+OK Message %d has been deleted.", num);
  875. outs(genbuf);
  876. return 0;
  877. }
  879. int
  880. do_delete()
  881. {
  882. int             i, fdr, fdw, count;
  883. char            fpath[80], fnew[80];
  885. sprintf(fpath, "mail/%c/%s/.DIR", toupper(*LowUserid), LowUserid);
  886. sprintf(fnew, "mail/%c/%s/pop3.DIR", toupper(*LowUserid), LowUserid);
  887. if ((fdr = open(fpath, O_RDONLY)) == -1)
  888. return -1;
  889. if ((fdw = open(fnew, O_RDWR | O_CREAT, 0644)) == -1)
  890. return -1;
  891. i = count = 0;
  892. while (read(fdr, &currentmail, sizeof(currentmail))) {
  893. if (i >= totalnum || fcache[i].accessed[0] == ' ') {
  894. write(fdw, &currentmail, sizeof(currentmail));
  895. count++;
  896. } else {
  897. sprintf(genbuf, "mail/%c/%s/%s", toupper(*LowUserid), LowUserid,
  898. currentmail.filename);
  899. unlink(genbuf);
  900. }
  901. i++;
  902. }
  903. close(fdr);
  904. close(fdw);
  905. unlink(fpath);
  906. if (count) {
  907. rename(fnew, fpath);
  908. } else
  909. unlink(fnew);
  910. return 0;
  911. }
  913. int
  914. Fatal()
  915. {
  916. Quit();
  917. }
  919. int
  920. Mget()
  921. {
  922. maxget();
  923. }
  925. int
  926. Quit()
  927. {
  928. if (State == S_LOGIN) {
  929. free(fcache);
  930. free(postlen);
  931. if (markdel)
  932. do_delete();
  933. }
  934. log_usies("EXIT");
  935. sprintf(genbuf, "200 BlueWave Express server at %s signing off, bye bye.", hostname);
  936. outs(genbuf);
  937. fclose(cfp);
  938. close(sock);
  939. exit(0);
  940. }
  942. void
  943. oouts(int status, char *str, int havereturn)
  944. {
  945. char            sendbuf[200];
  947. (void) bzero(sendbuf, sizeof(sendbuf));
  948. (void) sprintf(sendbuf, "%d %sr%s", status, str, (havereturn == 0) ? "n" : "");
  949. (void) write(sock, sendbuf, strlen(sendbuf));
  950. }