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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > TCP/IP协议栈 > 查看源码
mailbox.c
资源名称：export.zip　[点击查看]
上传用户：hepax88
上传日期：2007-01-03
资源大小：1101k
文件大小：41k
源码类别：

TCP/IP协议栈

开发平台：

Visual C++

mailbox.c：源码内容
  1. /* There are only two functions in this mailbox code that depend on the
  2.  * underlying protocol, namely mbx_getname() and dochat(). All the other
  3.  * functions can hopefully be used without modification on other stream
  4.  * oriented protocols than AX.25 or NET/ROM.
  5.  *
  6.  * SM0RGV 890506, most work done previously by W9NK
  7.  *
  8.  *** Changed 900114 by KA9Q to use newline mapping features in stream socket
  9.  * interface code; everything here uses C eol convention (n)
  10.  *
  11.  * Numerous new commands and other changes by SM0RGV, 900120
  12.  */
  13. #include <stdio.h>
  14. #include <time.h>
  15. #include <ctype.h>
  16. #ifdef UNIX
  17. #include <sys/types.h>
  18. #include <sys/stat.h>
  19. #endif
  21. #include "global.h"
  22. #include "config.h"
  23. #include "timer.h"
  24. #include "proc.h"
  25. #include "socket.h"
  26. #include "usock.h"
  27. #include "session.h"
  28. #include "smtp.h"
  29. #include "dirutil.h"
  30. #include "telnet.h"
  31. #include "ftp.h"
  32. #include "ftpserv.h"
  33. #include "commands.h"
  34. #include "netuser.h"
  35. #include "files.h"
  36. #include "bm.h"
  37. #include "mailbox.h"
  38. #include "ax25mail.h"
  39. #include "nr4mail.h"
  40. #include "cmdparse.h"
  42. /*
  43. #define MBDEBUG
  44. */
  46. struct mbx *Mbox[NUMMBX];
  47. static char *Motd = NULL;
  48. static int Attended = TRUE; /* default to attended mode */
  49. unsigned Maxlet = BM_NLET;
  51. char Noperm[] = "Permission denied.n";
  52. char Nosock[] = "Can't create socketn";
  54. static char Mbbanner[] = "[NET-H$]nWelcome %s to the %s TCP/IP Mailbox (%s)n%s";
  55. static char Mbmenu[] = "Current msg# %d : A,B,C,D,E,F,G,H,I,J,K,L,N,R,S,T,U,V,W,Z,? >n";
  56. static char Longmenu1[] = "(?)help    (A)rea     (B)ye      (C)hat     (D)ownload (E)scape   (F)ingern";
  57. static char Longmenu2[] = "(G)ateway  (H)elp     (I)nfo     (J)heard   (K)ill     (L)ist     (N)etromn";
  58. static char Longmenu3[] = "(R)ead     (S)end     (T)elnet   (U)pload   (V)erbose  (W)hat     (Z)apn";
  59. static char Loginbanner[] = "nKA9Q NOS (%s)nn";
  60. static char Howtoend[] = "Terminate with /EX or ^Z in first column (^A aborts):n";
  62. static int doarea(int argc,char *argv[],void *p);
  63. static int mbx_getname(struct mbx *m);
  65. /************************************************************************/
  66. /* C O M M A N D S */
  67. /************************************************************************/
  69. static int doattend(int argc,char *argv[],void *p);
  70. static int domaxmsg(int argc,char *argv[],void *p);
  71. static int domotd(int argc,char *argv[],void *p);
  72. static int dotimeout(int argc,char *argv[],void *p);
  74. /* mbox subcommand table */
  75. static struct cmds Mbtab[] = {
  76. "attend", doattend, 0, 0, NULL,
  77. #ifdef AX25
  78. "kick", dombkick, 0, 0, NULL,
  79. #endif
  80. "maxmsg", domaxmsg, 0, 0, NULL,
  81. "motd", domotd, 0, 0, NULL,
  82. "status", domboxdisplay, 0, 0, NULL,
  83. #ifdef AX25
  84. "timer", dombtimer, 0, 0, NULL,
  85. #endif
  86. "tiptimeout", dotimeout, 0, 0, NULL,
  87. NULL,
  88. };
  91. int
  92. dombox(argc,argv,p)
  93. int argc;
  94. char *argv[];
  95. void *p;
  96. {
  97. if(argc == 1)
  98. return domboxdisplay(argc,argv,p);
  99. return subcmd(Mbtab,argc,argv,p);
  100. }
  102. /* if unattended mode is set, ax25, telnet and maybe other sessions will
  103.  * be restricted.
  104.  */
  105. static int
  106. doattend(argc,argv,p)
  107. int argc;
  108. char *argv[];
  109. void *p;
  110. {
  111. return setbool(&Attended,"Attended flag",argc,argv);
  112. }
  114. static int
  115. domaxmsg(argc,argv,p)
  116. int argc;
  117. char *argv[];
  118. void *p;
  119. {
  120. return setuns(&Maxlet,"Maximum messages per area",argc,argv);
  121. }
  123. static int
  124. domotd(argc,argv,p)
  125. int argc;
  126. char *argv[];
  127. void *p;
  128. {
  129. if(argc > 2) {
  130. printf("Usage: mbox motd "<your message>"n");
  131. return 0;
  132. }
  134. if(argc < 2) {
  135. if(Motd != NULL)
  136. puts(Motd);
  137. }
  138. else {
  139. if(Motd != NULL){
  140. free(Motd);
  141. Motd = NULL; /* reset the pointer */
  142. }
  143. if(!strlen(argv[1]))
  144. return 0; /* clearing the buffer */
  145. Motd = mallocw(strlen(argv[1])+5);/* allow for the EOL char */
  146. strcpy(Motd, argv[1]);
  147. strcat(Motd, "n"); /* add the EOL char */
  148. }
  149. return 0;
  150. }
  152. int
  153. domboxdisplay(argc,argv,p)
  154. int argc;
  155. char *argv[];
  156. void *p;
  157. {
  158. int i, j, len;
  159. struct mbx *m;
  160. struct sockaddr fsocket;
  161. static char *states[] = {"LOGIN","CMD","SUBJ","DATA","REVFWD",
  162. "TRYING","FORWARD"};
  164. printf("User       State    S#  Wheren");
  166. for (i = 0; i < NUMMBX; i++){
  167. if((m = Mbox[i]) != NULL){
  168. len = MAXSOCKSIZE;
  169. j = getpeername(fileno(m->user),&fsocket,&len);
  170. printf("%-11s%-9s%-4u%sn",m->name,
  171.  states[m->state],fileno(m->user),
  172.  j != -1 ? psocket(&fsocket): "");
  173. }
  174. }
  175. return 0;
  176. }
  178. static int
  179. dotimeout(argc,argv,p)
  180. int argc;
  181. char *argv[];
  182. void *p;
  183. {
  184. return setuns(&Tiptimeout,"Tip connection timeout",argc,argv);
  185. }
  188. /**********************************************************************/
  190. void
  191. listusers(network)
  192. FILE *network;
  193. {
  194. FILE *outsave;
  196. fprintf(network,"nCurrent remote users:n");
  197. outsave = stdout;
  198. stdout = network;
  199. domboxdisplay(0,NULL,NULL);
  200. stdout = outsave;
  201. }
  203. struct mbx *
  204. newmbx()
  205. {
  206. int i;
  207. struct mbx *m;
  209. for(i = 0; i < NUMMBX; i++){
  210. if(Mbox[i] == NULL){
  211. m = Mbox[i] = (struct mbx *)callocw(1,sizeof(struct mbx));
  212. m->mbnum = i;
  213. return m;
  214. }
  215. }
  216. /* If we get here, there are no free mailbox sessions */
  217. return NULL;
  218. }
  220. static int
  221. mbx_getname(m)
  222. struct mbx *m;
  223. {
  224. #ifdef AX25
  225. char *cp;
  226. #endif
  227. union sp sp;
  228. struct sockaddr tmp;
  229. char buf[MBXLINE];
  230. int len = MAXSOCKSIZE;
  231. int anony = 0;
  232. int oldmode;
  234. sp.sa = &tmp;
  235. sp.sa->sa_family = AF_LOCAL; /* default to AF_LOCAL */
  236. getpeername(fileno(m->user),&tmp,&len);
  237. m->path = mallocw(MBXLINE);
  238. /* This is one of the two parts of the mbox code that depends on the
  239.  * underlying protocol. We have to figure out the name of the
  240.  * calling station. This is only practical when AX.25 or NET/ROM is
  241.  * used. Telnet users have to identify themselves by a login procedure.
  242.  */
  243. switch(sp.sa->sa_family){
  244. #ifdef AX25
  245. case AF_NETROM:
  246. case AF_AX25:
  247. /* NETROM and AX25 socket address structures are "compatible" */
  248. pax25(m->name,sp.ax->ax25_addr);
  249. cp = strchr(m->name,'-');
  250. if(cp != NULL) /* get rid of SSID */
  251. *cp = '';
  252. /* SMTP wants the name to be in lower case */
  253. cp = m->name;
  254. while(*cp){
  255. if(isupper(*cp))
  256. *cp = tolower(*cp);
  257. ++cp;
  258. }
  259. anony = 1;
  260. /* Try to find the privileges of this user from the userfile */
  261. if((m->privs = userlogin(m->name,buf,&m->path,MBXLINE,&anony)) == -1)
  262. if((m->privs = userlogin("bbs",buf,&m->path,MBXLINE,&anony)) == -1)
  263. if((m->privs = userlogin("anonymous",buf,&m->path,MBXLINE,
  264.  &anony)) == -1){
  265. m->privs = 0;
  266. free(m->path);
  267. m->path = NULL;
  268. }
  269. if(m->privs & EXCLUDED_CMD)
  270. return -1;
  271. return 0;
  272. #endif
  273. case AF_LOCAL:
  274. case AF_INET:
  275. m->state = MBX_LOGIN;
  276. printf(Loginbanner,Hostname);
  277. for(;;){
  278. fputs("login: ",stdout);
  279. if(mbxrecvline(m->user,m->name,sizeof(m->name),-1) == EOF)
  280. return -1;
  281. if(*m->name == '')
  282. continue;
  283. printf("Password: %c%c%c",IAC,WILL,TN_ECHO);
  284. oldmode = fmode(m->user,STREAM_BINARY);
  285. if(mbxrecvline(m->user,buf,MBXLINE,-1) == EOF)
  286. return -1;
  287. printf("%c%c%c",IAC,WONT,TN_ECHO);
  288. fmode(m->user,oldmode);
  289. putchar('n');
  290. #ifdef notdef
  291. /* This is needed if the password was send before the
  292.  * telnet no-echo options were received. We neeed to
  293.  * flush the eold sequence from the input buffers, sigh
  294.  */
  295. if(socklen(fileno(m->user),0))/* discard any remaining input */
  296. recv_mbuf(fileno(m->user),NULL,0,NULL,0);
  297. #endif
  298. if((m->privs = userlogin(m->name,buf,&m->path,MBXLINE,&anony))
  299.  != -1){
  300. if(anony)
  301. logmsg(fileno(m->user),"MBOX login: %s Password: %s",m->name,buf);
  302. else
  303. logmsg(fileno(m->user),"MBOX login: %s",m->name);
  304. if(m->privs & EXCLUDED_CMD)
  305. return -1;
  306. return 0;
  307. }
  308. printf("Login incorrectn");
  309. *m->name = ''; /* wipe any garbage */
  310. }
  311. }
  312. return 0;
  313. }
  315. /* Incoming mailbox session */
  316. void
  317. mbx_incom(s,t,p)
  318. int s;
  319. void *t;
  320. void *p;
  321. {
  322. struct mbx *m;
  323. struct usock *up;
  324. char *buf[3];
  325. int rval;
  326. FILE *network;
  328. sockowner(s,Curproc); /* We own it now */
  329. if(p == NULL)
  330. network = fdopen(s,"r+t");
  331. else
  332. network = (FILE *)p;
  334. /* Secede from the parent's sockets, and use the network socket that
  335.  * was passed to us for both input and output. The reference
  336.  * count on this socket will still be 1; this allows the domboxbye()
  337.  * command to work by closing that socket with a single call.
  338.  * If we return, the socket will be closed automatically.
  339.  */
  340. fclose(stdin);
  341. stdin = fdup(network);
  342. fclose(stdout);
  343. stdout = fdup(network);
  345. logmsg(fileno(network),"open MBOX");
  346. if((m = newmbx()) == NULL){
  347. printf("Too many mailbox sessionsn");
  348. return;
  349. }
  350. m->user = network;
  351. m->escape = 24; /* default escape character is Ctrl-X */
  352. m->type = (int) t;
  353. /* get the name of the remote station */
  354. if(mbx_getname(m) == -1) {
  355. exitbbs(m);
  356. return;
  357. }
  359. m->state = MBX_CMD; /* start in command state */
  361. /* Now say hi */
  362. printf(Mbbanner,m->name,Hostname,Version,
  363. Motd != NULL ? Motd : "");
  364. /* Enable our local message area */
  365. buf[1] = m->name;
  366. doarea(2,buf,m);
  367. printf(Mbmenu,m->current);
  368. while(mbxrecvline(network,m->line,MBXLINE,-1) != EOF){
  369. if((rval = mbx_parse(m)) == -2)
  370. break;
  371. if(rval == 1)
  372. printf("Bad syntax.n");
  373. if(!(m->sid & MBX_SID) && isnewprivmail(m) > 0L)
  374. printf("You have new mail.n");
  375. scanmail(m);
  376. printf((m->sid & MBX_SID) ? ">n" : Mbmenu, m->current);
  377. m->state = MBX_CMD;
  378. }
  379. exitbbs(m);
  380. /* nasty hack! we may have screwed up reference count */
  381. /* by invoking newproc("smtp_send",....); Fudge it!   */
  382. if((up = itop(fileno(stdout))) != NULL)
  383. up->refcnt = 1;
  384. fclose(stdout);
  385. }
  387. void
  388. exitbbs(m)
  389. struct mbx *m;
  390. {
  391. closenotes(m);
  392. free(m->to);
  393. free(m->tofrom);
  394. free(m->origto);
  395. free(m->tomsgid);
  396. free(m->path);
  397. free(m->mbox);
  398. Mbox[m->mbnum] = NULL;
  399. free(m);
  400. }
  402. /**********************************************************************/
  404. static int dochat(int argc,char *argv[],void *p);
  405. static int dodownload(int argc,char *argv[],void *p);
  406. static int dombupload(int argc,char *argv[],void *p);
  407. static int dowhat(int argc,char *argv[],void *p);
  408. static int dozap(int argc,char *argv[],void *p);
  409. static int dosend(int argc,char *argv[],void *p);
  410. static int dosid(int argc,char *argv[],void *p);
  411. static int dosysop(int argc,char *argv[],void *p);
  412. static int dostars(int argc,char *argv[],void *p);
  413. static int dombhelp(int argc,char *argv[],void *p);
  414. static int dombtelnet(int argc,char *argv[],void *p);
  415. static int dombfinger(int argc,char *argv[],void *p);
  416. static void gw_alarm(void *p);
  417. static void gw_input(int s,void *notused,void *p);
  418. static void gw_superv(int null,void *proc,void *p);
  419. static int mbx_to(int argc,char *argv[],void *p);
  420. static int mbx_data(struct mbx *m,struct list *cclist,char *extra);
  421. static int msgidcheck(char *string);
  422. static int uuencode(FILE *infile,FILE *outfile,char *infilename);
  424. static struct cmds Mbcmds[] = {
  425. "", doreadnext, 0, 0, NULL,
  426. "area", doarea, 0, 0, NULL,
  427. "send", dosend, 0, 0, NULL,
  428. "read", doreadmsg, 0, 2, "R numbers",
  429. "verbose", doreadmsg, 0, 2, "V numbers",
  430. #ifdef AX25
  431. "jheard", doaxheard, 0, 0, NULL,
  432. #endif
  433. "kill", dodelmsg, 0, 2, "K numbers",
  434. "list", dolistnotes, 0, 0, NULL,
  435. "escape", dombescape, 0, 0, NULL,
  436. "download", dodownload, 0, 2, "D[U] filename",
  437. "upload", dombupload, 0, 2, "U filename",
  438. "what", dowhat, 0, 0, NULL,
  439. "zap", dozap, 0, 2, "Z filename",
  440. #ifdef AX25
  441. "gateway", dogateway, 0, 3, "G interface callsigns",
  442. #endif
  443. "telnet", dombtelnet, 0, 2, "T hostname",
  444. "finger", dombfinger, 0, 0, NULL,
  445. #ifdef NETROM
  446. "netrom", dombnetrom, 0, 0, NULL,
  447. #endif
  448. "chat", dochat, 0, 0, NULL,
  449. "bye", domboxbye, 0, 0, NULL,
  450. "help", dombhelp, 0, 0, NULL,
  451. "info", dombhelp, 0, 0, NULL,
  452. "?", dombhelp, 0, 0, NULL,
  453. "[", dosid, 0, 0, NULL,
  454. #ifdef AX25
  455. "f>", dorevfwd, 0, 0, NULL,
  456. #endif
  457. "@", dosysop, 0, 0, NULL,
  458. "***", dostars, 0, 0, NULL,
  459. NULL, NULL, 0, 0, "Huh?",
  460. };
  462. /* "twocmds" defines the MBL/RLI two-letter commands, eg. "SB", "SP" and so on.
  463.  * They have to be treated specially since cmdparse() wants a space between
  464.  * the actual command and its arguments.
  465.  * "SP FOO" is converted to "s  foo" and the second command letter is saved
  466.  * in m->stype. Longer commands like "SEND" are unaffected, except for
  467.  * commands starting with "[", i.e. the SID, since we don't know what it will
  468.  * look like.
  469.  */
  470. static char twocmds[] = "slrd["; /* S,L,R,D are two-letter commands */
  471. int
  472. mbx_parse(m)
  473. struct mbx *m;
  474. {
  475. char *cp;
  476. int i;
  477. char *newargv[2];
  478. /* Translate entire buffer to lower case */
  479. for (cp = m->line; *cp != ''; ++cp)
  480. if(isupper(*cp))
  481. *cp = tolower(*cp);
  482. /* Skip any spaces at the begining */
  483. for(cp = m->line;isspace(*cp);++cp)
  484. ;
  485. m->stype = ' ';
  486. if(*cp != '' && *(cp+1) != '')
  487. for(i=0; i<strlen(twocmds); ++i){
  488. if(*cp == twocmds[i] && (isspace(*(cp+2)) || *(cp+2) == ''
  489.  || *cp == '[')){
  490. if(islower(*(++cp)))
  491. m->stype = toupper(*cp); /* Save the second character */
  492. else
  493. m->stype = *cp;
  494. *cp = ' ';
  495. break;
  496. }
  497. }
  498. /* See if the input line consists solely of digits */
  499. cp = m->line;
  500. for(cp = m->line;isspace(*cp);++cp)
  501. ;
  502. newargv[1] = cp;
  503. for(;*cp != '' && isdigit(*cp);++cp)
  504. ;
  505. if(*cp == '' && strlen(newargv[1]) > 0) {
  506. newargv[0] = "read";
  507. return doreadmsg(2,newargv,(void *)m);
  508. }
  509. else
  510. return cmdparse(Mbcmds,m->line,(void *)m);
  511. }
  513. /* This works like recvline(), but telnet options are answered and the
  514.  * terminating newline character is not put into the buffer. If the
  515.  * incoming character equals the value of escape, any queued input is
  516.  * flushed and -2 returned.
  517.  */
  518. int
  519. mbxrecvline(network,buf,len,escape)
  520. FILE *network;
  521. char *buf;
  522. int len;
  523. int escape;
  524. {
  525. int c, cnt = 0, opt;
  526. if(buf == NULL)
  527. return 0;
  528. fflush(stdout);
  529. while((c = getc(network)) != EOF){
  530. if(c == IAC){ /* Telnet command escape */
  531. if((c = getc(network)) == EOF)
  532. break;
  533. if(c > 250 && c < 255 && (opt = getc(network)) != EOF){
  534. #ifdef foo
  535. switch(c){
  536. case WILL:
  537. printf("%c%c%c",IAC,DONT,opt);
  538. break;
  539. case WONT:
  540. printf("%c%c%c",IAC,DONT,opt);
  541. break;
  542. case DO:
  543. printf("%c%c%c",IAC,WONT,opt);
  544. break;
  545. case DONT:
  546. printf("%c%c%c",IAC,WONT,opt);
  547. }
  548. #endif
  549. /* to be fixed  fflush(stdout);*/
  550. continue;
  551. }
  552. if(c != IAC && (c = fgetc(network)) == EOF)
  553. break;
  554. }
  555. /* ordinary character */
  556. if(c == 'r' || c == 'n')
  557. break;
  558. if(c == escape){
  559. if(socklen(fileno(network),0)) /* discard any remaining input */
  560. recv_mbuf(fileno(network),NULL,0,NULL,0);
  561. cnt = -2;
  562. break;
  563. }
  564. *buf++ = c;
  565. ++cnt;
  566. if(cnt == len - 1)
  567. break;
  568. }
  569. if(c == EOF && cnt == 0)
  570. return -1;
  571. *buf = '';
  572. return cnt;
  573. }
  575. int
  576. domboxbye(argc,argv,p)
  577. int argc;
  578. char *argv[];
  579. void *p;
  580. {
  581. struct mbx *m;
  583. m = (struct mbx *)p;
  584. /* Now say goodbye */
  585. printf("Thank you %s, for calling the %s Tcp/Ip Mailbox.n",m->name,
  586. Hostname);
  587. if(m->type == TIP)
  588. printf("Please hang up now.n");
  590. return -2; /* signal that exitbbs() should be called */
  591. }
  592. static int
  593. dombhelp(argc,argv,p)
  594. int argc;
  595. char *argv[];
  596. void *p;
  597. {
  598. char buf[255];
  599. int i;
  600. FILE *fp;
  601. if(*argv[0] == '?') {
  602. fputs(Longmenu1,stdout);
  603. fputs(Longmenu2,stdout);
  604. fputs(Longmenu3,stdout);
  605. return 0;
  606. }
  607. buf[0] = '';
  608. if(argc > 1)
  609. for(i=0; Mbcmds[i].name != NULL; ++i)
  610. if(!strncmp(Mbcmds[i].name,argv[1],strlen(argv[1]))) {
  611. sprintf(buf,"%s/%s.hlp",Helpdir,Mbcmds[i].name);
  612. break;
  613. }
  614. if(buf[0] == '')
  615. if(*argv[0] == 'i') /* INFO command */
  616. sprintf(buf,"%s/info.hlp",Helpdir);
  617. else
  618. sprintf(buf,"%s/help.hlp",Helpdir);
  619. if((fp = fopen(buf,READ_TEXT)) != NULL) {
  620. sendfile(fp,Curproc->output,ASCII_TYPE,0);
  621. fclose(fp);
  622. }
  623. else
  624. printf("No help available. (%s not found)n",buf);
  625. return 0;
  626. }
  628. static int
  629. dochat(argc,argv,p)
  630. int argc;
  631. char *argv[];
  632. void *p;
  633. {
  634. char buf[8], *newargv[3];
  636. if(Attended){
  637. newargv[0] = "telnet";
  638. newargv[1] = Hostname;
  639. sprintf(buf,"%d",IPPORT_TTYLINK);
  640. newargv[2] = buf;
  641. return dombtelnet(3,newargv,p);
  642. }
  643. else {
  644. printf("Sorry - the system is unattended.07n");
  645. }
  646. /* It returns only after a disconnect or refusal */
  647. return 0;
  648. }
  650. static int
  651. dosend(argc,argv,p)
  652. int argc;
  653. char *argv[];
  654. void *p;
  655. {
  656. int cccnt = 0, fail = 0;
  657. char *host, *cp, fullfrom[MBXLINE], sigwork[LINELEN], *rhdr = NULL;
  658. struct list *ap, *cclist = NULL;
  659. struct mbx *m;
  660. FILE *fp;
  662. m = (struct mbx *)p;
  663. if((m->stype != 'R' || (m->sid & MBX_SID)) && mbx_to(argc,argv,m)
  664.    == -1){
  665. if(m->sid & MBX_SID)
  666. printf("NO - syntax errorn");
  667. else {
  668. printf("S command syntax error - format is:n");
  669. printf("  S[F] name [@ host] [< from_addr] [$bulletin_id]n");
  670. printf("  SR [number]n");
  671. }
  672. return 0;
  673. }
  674. if(m->stype != 'R' && msgidcheck(m->tomsgid)) {
  675. if(m->sid & MBX_SID)
  676. fputs("NO - ",stdout);
  677. printf("Already have %sn",m->tomsgid);
  678. return 0;
  679. }
  680. if(m->stype == 'R' && !(m->sid & MBX_SID) &&
  681.    mbx_reply(argc,argv,m,&cclist,&rhdr) == -1)
  682. return 0;
  683. if((cp = rewrite_address(m->to)) != NULL)
  684.      if(strcmp(m->to,cp) != 0){
  685.   m->origto = m->to;
  686.   m->to = cp;
  687.      }
  688.      else
  689.   free(cp);
  690. if((m->origto != NULL || m->stype == 'R') && !(m->sid & MBX_SID))
  691. printf("To: %sn", m->to);
  692. if(validate_address(m->to) == 0){
  693. if(m->sid & MBX_SID)
  694. printf("NO - bad addressn");
  695. else
  696. printf("Bad user or host namen");
  697. free(rhdr);
  698. del_list(cclist);
  699. /* We don't free any more buffers here. They are freed upon
  700.  * the next call to mbx_to() or to domboxbye()
  701.  */
  702. return 0;
  703. }
  704. /* Display the Cc: line (during SR command) */
  705. for(ap = cclist; ap != NULL; ap = ap->next) {
  706. if(cccnt == 0){
  707. printf("%s",Hdrs[CC]);
  708. cccnt = 4;
  709. }
  710. else {
  711. fputs(", ",stdout);
  712. cccnt += 2;
  713. }
  714. if(cccnt + strlen(ap->val) > 80 - 3) {
  715. fputs("n    ",stdout);
  716. cccnt = 4;
  717. }
  718. fputs(ap->val,stdout);
  719. cccnt += strlen(ap->val);
  720. }
  721. if(cccnt)
  722. putchar('n');
  723. m->state = MBX_SUBJ;
  724. if(m->stype != 'R' || (m->sid & MBX_SID) != 0) {
  725. printf((m->sid & MBX_SID) ? "OKn" : "Subject: ");
  726. if(mbxrecvline(m->user,m->line,MBXLINE,-1) == -1)
  727. return 0;
  728. }
  729. else /* Replying to a message */
  730. printf("Subject: %sn",m->line);
  731. if(mbx_data(m,cclist,rhdr) == -1){
  732. free(rhdr);
  733. del_list(cclist);
  734. puts("Can't create temp file for mail");
  735. return 0;
  736. }
  737. free(rhdr);
  738. m->state = MBX_DATA;
  739. if((m->sid & MBX_SID) == 0 && m->stype != 'F')
  740. printf("Enter message.  %s",Howtoend);
  742. if(m->stype != 'F' || (m->sid & MBX_SID) != 0)
  743. while(mbxrecvline(m->user,m->line,MBXLINE,-1) != -1){
  744. if(m->line[0] == 0x01){  /* CTRL-A */
  745. fclose(m->tfile);
  746. puts("Aborted.");
  747. del_list(cclist);
  748. return 0;
  749. }
  750. if(m->line[0] != CTLZ && stricmp(m->line, "/ex"))
  751. fprintf(m->tfile,"%sn",m->line);
  752. else
  753. break; /* all done */
  754. }
  755. else {
  756. fprintf(m->tfile,"----- Forwarded message -----nn");
  757. msgtofile(m,m->current,m->tfile,0);
  758. fprintf(m->tfile,"----- End of forwarded message -----n");
  759. }
  761. /* Insert customised signature if one is found */
  762. if(!(m->sid & MBX_SID)) { /* not a forwarding BBS */
  763.      sprintf(sigwork,"%s/%s.sig",Signature,
  764.      m->tofrom ? m->tofrom : m->name);
  765.      if((fp = fopen(sigwork,READ_TEXT)) != NULL){
  766.   while(fgets(sigwork,LINELEN,fp) != NULL)
  767. fputs(sigwork,m->tfile);
  768.   fclose(fp);
  769.      }
  770. }
  772. if((host = strrchr(m->to,'@')) == NULL) {
  773. host = Hostname; /* use our hostname */
  774. if(m->origto != NULL) {
  775. /* rewrite_address() will be called again by our
  776.  * SMTP server, so revert to the original address.
  777.  */
  778.   free(m->to);
  779. m->to = m->origto;
  780. m->origto = NULL;
  781. }
  782. }
  783. else
  784. host++; /* use the host part of address */
  786. /* make up full from name for work file */
  787. if(m->tofrom != NULL)
  788. sprintf(fullfrom,"%s%%%s.bbs@%s",m->tofrom, m->name, Hostname);
  789. else
  790. sprintf(fullfrom,"%s@%s",m->name,Hostname);
  791. if(cclist != NULL && stricmp(host,Hostname) != 0) {
  792. fseek(m->tfile,0L,0); /* reset to beginning */
  793. fail = queuejob(m->tfile,Hostname,cclist,fullfrom);
  794. del_list(cclist);
  795. cclist = NULL;
  796. }
  797. addlist(&cclist,m->to,0);
  798. fseek(m->tfile,0L,0);
  799. fail += queuejob(m->tfile,host,cclist,fullfrom);
  800. del_list(cclist);
  801. fclose(m->tfile);
  802. if(fail)
  803.      puts("Couldn't queue message for delivery");
  804. else
  805.      if(m->tomsgid != NULL &&
  806. (fp = fopen(Historyfile,APPEND_TEXT)) != NULL) {
  807.   fprintf(fp,"%sn",m->tomsgid); /* Save BID in history file */
  808.   fclose(fp);
  809.      }
  810. smtptick(0L); /* wake SMTP to send that mail */
  811. return 0;
  812. }
  814. static int
  815. dosid(argc,argv,p)
  816. int argc;
  817. char *argv[];
  818. void *p;
  819. {
  820. struct mbx *m;
  821. char *cp;
  823. m = (struct mbx *)p;
  824. if(argc == 1)
  825. return 1;
  826. if(argv[1][strlen(argv[1]) - 1] != ']') /* must be an SID */
  827. return 1;
  828. m->sid = MBX_SID;
  829. /* Now check to see if this is an RLI board.
  830.  * As usual, Hank does it a bit differently from
  831.  * the rest of the world.
  832.  */
  833. if(m->stype == 'R' && strncmp(argv[1],"li",2) == 0)/* [RLI] at a minimum */
  834. m->sid |= MBX_RLI_SID;
  835. /* Check to see if the BBS supports a kludge called "hierarchical
  836.  * routing designators."
  837.  *
  838.  * No need to check for ']' -- it must be there or this is not
  839.  * a valid mbox id -- it is checked earlier (fix de OH3LKU)
  840.  */
  841. if((cp = strchr(argv[1],'-')) != NULL
  842.  && (cp=strchr(cp+1,'h')) != NULL
  843.  && strchr(cp+1,'$'))
  844. m->sid |= MBX_HIER_SID;
  845. return 0;
  846. }
  848. int
  849. dombescape(argc,argv,p)
  850. int argc;
  851. char *argv[];
  852. void *p;
  853. {
  854. struct mbx *m;
  856. m = (struct mbx *)p;
  857. if(argc < 2){
  858. printf("The escape character is: ");
  859. if(m->escape < 32)
  860. printf("CTRL-%cn",m->escape+'A'-1);
  861. else
  862. printf("'%c'n",m->escape);
  863. return 0;
  864. }
  865. if(strlen(argv[1]) > 1)
  866. if(isdigit(*argv[1]))
  867. m->escape = (char) atoi(argv[1]);
  868. else
  869. return 1;
  870. else
  871. m->escape = *argv[1];
  872. return 0;
  873. }
  875. static int
  876. dodownload(argc,argv,p)
  877. int argc;
  878. char *argv[];
  879. void *p;
  880. {
  881. struct mbx *m;
  882. FILE *fp;
  883. char *file;
  885. m = (struct mbx *)p;
  886. file = pathname(m->path,argv[1]);
  887. if(!permcheck(m->path,m->privs,RETR_CMD,file)){
  888. printf(Noperm);
  889. return 0;
  890. }
  891. if((fp = fopen(file,READ_TEXT)) == NULL)
  892. printf("Can't open "%s": %sn",file,sys_errlist[errno]);
  893. else
  894. if(m->stype == 'U'){ /* uuencode ? */
  895. fclose(fp);
  896. fp = fopen(file,READ_BINARY); /* assume non-ascii */
  897. uuencode(fp,m->user,file);
  898. } else
  899. sendfile(fp,m->user,ASCII_TYPE,0);
  900. free(file);
  901. fclose(fp);
  902. return 0;
  903. }
  905. static int
  906. dombupload(argc,argv,p)
  907. int argc;
  908. char *argv[];
  909. void *p;
  910. {
  911. struct mbx *m;
  912. FILE *fp;
  913. char *file, buf[LINELEN];
  915. m = (struct mbx *)p;
  916. file = pathname(m->path,argv[1]);
  917. if(!permcheck(m->path,m->privs,STOR_CMD,file)){
  918. printf(Noperm);
  919. return 0;
  920. }
  921. if((fp = fopen(file,WRITE_TEXT)) == NULL){
  922. printf("Can't create "%s": %sn",file,sys_errlist[errno]);
  923. free(file);
  924. return 0;
  925. }
  926. logmsg(fileno(m->user),"MBOX upload: %s",file);
  927. printf("Send file,  %s",Howtoend);
  928. for(;;){
  929. if(mbxrecvline(m->user,buf,LINELEN,-1) == -1){
  930. unlink(file);
  931. break;
  932. }
  933. if(buf[0] == 0x01){  /* CTRL-A */
  934. unlink(file);
  935. printf("Aborted.n");
  936. break;
  937. }
  938. if(buf[0] == CTLZ || !stricmp("/ex",buf))
  939. break;
  940. fputs(buf,fp);
  941. #if !defined(UNIX) && !defined(__TURBOC__) && !defined(AMIGA)
  942. /* Needed only if the OS uses a CR/LF
  943.  * convention and putc doesn't do
  944.  * an automatic translation
  945.  */
  946. if(putc('r',fp) == EOF)
  947. break;
  948. #endif
  949. if(putc('n',fp) == EOF)
  950. break;
  951. }
  952. free(file);
  953. fclose(fp);
  954. return 0;
  955. }
  957. static int
  958. dowhat(argc,argv,p)
  959. int argc;
  960. char *argv[];
  961. void *p;
  962. {
  963. struct mbx *m;
  964. FILE *fp;
  965. char *file;
  967. m = (struct mbx *)p;
  968. if(argc < 2)
  969. file = strdup(m->path);
  970. else
  971. file = pathname(m->path,argv[1]);
  972. if(!permcheck(m->path,m->privs,RETR_CMD,file)){
  973. printf(Noperm);
  974. return 0;
  975. }
  976. if((fp = dir(file,1)) == NULL)
  977. printf("Can't read directory: "%s": %sn",file,sys_errlist[errno]);
  978. else
  979. sendfile(fp,m->user,ASCII_TYPE,0);
  980. free(file);
  981. fclose(fp);
  982. return 0;
  983. }
  985. static int
  986. dozap(argc,argv,p)
  987. int argc;
  988. char *argv[];
  989. void *p;
  990. {
  991. struct mbx *m;
  992. char *file;
  994. m = (struct mbx *)p;
  995. file = pathname(m->path,argv[1]);
  996. if(!permcheck(m->path,m->privs,DELE_CMD,file)){
  997. printf(Noperm);
  998. return 0;
  999. }
  1000. if(unlink(file))
  1001. printf("Zap failed: %sn",sys_errlist[errno]);
  1002. logmsg(fileno(m->user),"MBOX Zap: %s",file);
  1003. free(file);
  1004. return 0;
  1005. }
  1007. static int
  1008. dosysop(argc,argv,p)
  1009. int argc;
  1010. char *argv[];
  1011. void *p;
  1012. {
  1013. struct mbx *m;
  1014. int c;
  1015. extern struct cmds Cmds[];
  1017. m = (struct mbx *) p;
  1018. if(!(m->privs & SYSOP_CMD)){
  1019. printf(Noperm);
  1020. return 0;
  1021. }
  1022. dombescape(1,NULL,p);
  1023. for(;;){
  1024. printf("Net> ");
  1025. fflush(stdout);
  1026. c = mbxrecvline(stdin,m->line,MBXLINE,m->escape);
  1027. if(c == EOF || c == -2)
  1028. break;
  1029. logmsg(fileno(m->user),"MBOX sysop: %s",m->line);
  1030. cmdparse(Cmds,m->line,NULL);
  1031. }
  1032. return 0;
  1033. }
  1035. /* Handle the "*** Done" command when reverse forwarding ends or the
  1036.  * "*** LINKED to" command.
  1037.  */
  1038. static int
  1039. dostars(argc,argv,p)
  1040. int argc;
  1041. char *argv[];
  1042. void *p;
  1043. {
  1044. struct mbx *m;
  1045. int anony = 1;
  1046. m = (struct mbx *)p;
  1047. /* The "*** LINKED to" command is only allowed to stations with
  1048.  * SYSOP privileges to prevent others from obtaining the same.
  1049.  */
  1050. if((m->privs & SYSOP_CMD) && argc == 4 && !strcmp(argv[1],"linked")) {
  1051. strcpy(m->name,argv[3]);
  1052. /* Try to find the privileges of this user from the userfile */
  1053. if((m->privs = userlogin(m->name,NULL,&m->path,MBXLINE,
  1054.  &anony)) == -1)
  1055.      if((m->privs = userlogin("bbs",NULL,&m->path,
  1056.       MBXLINE,&anony)) == -1)
  1057.   if((m->privs = userlogin("anonymous",NULL,
  1058.    &m->path,MBXLINE,&anony)) == -1){
  1059. m->privs = 0;
  1060. free(m->path);
  1061. m->path = NULL;
  1062.   }
  1063. printf("Oh, hello %s.n",m->name);
  1064. if(m->privs & EXCLUDED_CMD)
  1065. return domboxbye(0,NULL,p);
  1066. changearea(m,m->name);
  1067. return 0;
  1068. }
  1069. if(argc > 1 && (m->sid & MBX_SID)) /* "*** Done" or similar */
  1070. return 2;
  1071. return -1;
  1072. }
  1074. static int
  1075. doarea(argc,argv,p)
  1076. int argc;
  1077. char *argv[];
  1078. void *p;
  1079. {
  1080. struct mbx *m;
  1081. FILE *fp;
  1083. m = (struct mbx *) p;
  1084. if(argc < 2){
  1085. printf("Current message area is: %sn",m->area);
  1086. printf("Available areas are:n%-15s  Your private mail arean",
  1087.   m->name);
  1088. if((fp = fopen(Arealist,READ_TEXT)) == NULL)
  1089. return 0;
  1090. sendfile(fp,m->user,ASCII_TYPE,0);
  1091. fclose(fp);
  1092. return 0;
  1093. }
  1094. if((m->privs & SYSOP_CMD) || strcmp(m->name,argv[1]) == 0){
  1095. changearea(m,argv[1]);
  1096. if(m->nmsgs){
  1097. if(!strcmp(m->name,m->area))
  1098. printf("You have ");
  1099. else
  1100. printf("%s: ",m->area);
  1101. printf("%d message%s -  %d new.n", m->nmsgs,
  1102.   m->nmsgs == 1 ? " " : "s ", m->newmsgs);
  1103. }
  1104. return 0;
  1105. }
  1106. if(isarea(argv[1])) {
  1107. changearea(m,argv[1]);
  1108. printf("%s: %d message%s.n", m->area, m->nmsgs,
  1109.   m->nmsgs == 1 ? "" : "s");
  1110. }
  1111. else
  1112. printf("No such message area: %sn",argv[1]);
  1113. return 0;
  1114. }
  1116. /* subroutine to do the actual switch from one area to another */
  1117. void
  1118. changearea(m,area)
  1119. struct mbx *m;
  1120. char *area;
  1121. {
  1122. closenotes(m);
  1123. m->nmsgs = m->newmsgs = m->current = 0;
  1124. strcpy(m->area,area);
  1125. scanmail(m);
  1126. }
  1128. static int
  1129. dombtelnet(argc,argv,p)
  1130. int argc;
  1131. char *argv[];
  1132. void *p;
  1133. {
  1134. struct mbx *m;
  1135. int s, len, i;
  1136. struct sockaddr dsocket;
  1137. struct sockaddr_in fsocket;
  1139. m = (struct mbx *) p;
  1140. fsocket.sin_family = AF_INET;
  1141. if(argc < 3)
  1142. fsocket.sin_port = IPPORT_TELNET;
  1143. else
  1144. fsocket.sin_port = atoi(argv[2]);
  1146. if((fsocket.sin_addr.s_addr = resolve(argv[1])) == 0){
  1147. printf(Badhost,argv[1]);
  1148. return 0;
  1149. }
  1150. /* Only local telnets are are allowed to the unprivileged user */
  1151. if(!(m->privs & TELNET_CMD) && !ismyaddr(fsocket.sin_addr.s_addr)){
  1152. printf(Noperm);
  1153. return 0;
  1154. }
  1155. if((s = socket(AF_INET,SOCK_STREAM,0)) == -1){
  1156. printf(Nosock);
  1157. return 0;
  1158. }
  1159. if(fsocket.sin_port == IPPORT_TTYLINK) {
  1160. m->startmsg = mallocw(80);
  1161. len = MAXSOCKSIZE;
  1162. i = getpeername(fileno(m->user),&dsocket,&len);
  1163. sprintf(m->startmsg,"*** Incoming call from %s@%s ***n",
  1164. m->name,i != -1 ? psocket(&dsocket): Hostname);
  1165. }
  1166. return gw_connect(m,s,(struct sockaddr *)&fsocket,SOCKSIZE);
  1167. }
  1169. static int
  1170. dombfinger(argc,argv,p)
  1171. int argc;
  1172. char *argv[];
  1173. void *p;
  1174. {
  1175. struct mbx *m;
  1176. char *host, *user = NULL, buf[8], *newargv[3];
  1178. if(argc > 2){
  1179. printf("Usage: F user@host  or  F @host  or  F user.n");
  1180. return 0;
  1181. }
  1182. host = Hostname;
  1183. if(argc == 2){
  1184. if((host = strchr(argv[1], '@')) != NULL){
  1185. *host = '';
  1186. host++;
  1187. } else
  1188. host = Hostname;
  1189. user = argv[1];
  1190. }
  1191. m = (struct mbx *) p;
  1192. m->startmsg = mallocw(80);
  1193. if(user != NULL)
  1194. sprintf(m->startmsg,"%sn",user);
  1195. else
  1196. strcpy(m->startmsg,"n");
  1197. newargv[0] = "telnet";
  1198. newargv[1] = host;
  1199. sprintf(buf,"%d",IPPORT_FINGER);
  1200. newargv[2] = buf;
  1201. return dombtelnet(3,newargv,p);
  1202. }
  1204. /* Generic mbox gateway code. It sends and frees the contents of m->startmsg
  1205.  * when the connection has been established unless it a null pointer.
  1206.  */
  1207. int
  1208. gw_connect(m,s,fsocket,len)
  1209. struct mbx *m;
  1210. int s;
  1211. struct sockaddr *fsocket;
  1212. int len;
  1213. {
  1214. int c;
  1215. char *cp;
  1216. struct proc *child;
  1217. struct gwalarm *gwa;
  1218. FILE *network;
  1220. child = newproc("gateway supervisor",256,gw_superv,0,Curproc,m,0);
  1221. printf("Trying %s...  ",psocket(fsocket));
  1222. dombescape(0,NULL,(void *)m);
  1223. fflush(stdout);
  1224. if(connect(s,fsocket,len) == -1){
  1225. cp = sockerr(s);
  1226. printf("Connection failed: ");
  1227. if(cp != NULL)
  1228. printf("%s errno %dn",cp,errno);
  1229. else
  1230. printf("Escape character sent.n");
  1231. free(m->startmsg);
  1232. m->startmsg = NULL;
  1233. killproc(child);
  1234. close_s(s);
  1235. return 0;
  1236. }
  1237. network = fdopen(s,"r+t");
  1238. /* The user did not type the escape character */
  1239. killproc(child);
  1240. puts("Connected.");
  1242. if(m->startmsg != NULL){
  1243. fputs(m->startmsg,network);
  1244. free(m->startmsg);
  1245. m->startmsg = NULL;
  1246. }
  1247. /* Since NOS does not flush the output socket after a certain
  1248.  * period of time, we have to arrange that ourselves.
  1249.  */
  1250. gwa = (struct gwalarm *) mallocw(sizeof(struct gwalarm));
  1251. gwa->s1 = stdout;
  1252. gwa->s2 = network;
  1253. set_timer(&gwa->t,240L);
  1254. gwa->t.func = gw_alarm;
  1255. gwa->t.arg = (void *) gwa;
  1256. start_timer(&gwa->t);
  1257. /* Fork off the receive process */
  1258. child = newproc("gateway in",1024,gw_input,s,(void *)network,Curproc,0);
  1260. for(;;){
  1261. if((c = getchar()) == EOF)
  1262. break;
  1263. if(c == m->escape){
  1264. puts("Disconnecting.");
  1265. if(socklen(fileno(stdin),0))
  1266. recv_mbuf(fileno(stdin),NULL,0,NULL,0);
  1267. break;
  1268. }
  1269. if(putc(c,network) == EOF)
  1270. break;
  1271. }
  1272. stop_timer(&gwa->t);
  1273. free(gwa);
  1274. fclose(network);
  1275. killproc(child); /* get rid of the receive process */
  1276. printf("%c%c%cn",IAC,WONT,TN_ECHO);
  1277. return 0;
  1278. }
  1280. static void
  1281. gw_input(s,n,p)
  1282. int s;
  1283. void *n;
  1284. void *p;
  1285. {
  1286. int c;
  1287. char *cp;
  1288. struct proc *parent;
  1289. FILE *network;
  1291. network = (FILE *)n;
  1292. parent = (struct proc *) p;
  1293. while((c = getc(network)) != EOF)
  1294. putchar((char)c);
  1295. printf("Disconnected ");
  1296. cp = sockerr(fileno(network));
  1297. if(cp != NULL)
  1298. puts(cp);
  1299. /* Tell the parent that we are no longer connected */
  1300. alert(parent,ENOTCONN);
  1301. kwait(Curproc); /* Now wait to be killed */
  1302. }
  1304. /* Check if the escape character is typed while the parent process is busy
  1305.  * doing other things. 
  1306.  */
  1307. static void
  1308. gw_superv(null,proc,p)
  1309. int null;
  1310. void *proc;
  1311. void *p;
  1312. {
  1313. struct proc *parent;
  1314. struct mbx *m;
  1315. int c;
  1316. parent = (struct proc *) proc;
  1317. m = (struct mbx *) p;
  1318. while((c = getchar()) != EOF)
  1319. if(c == m->escape){
  1320. /* flush anything in the input queue */
  1321. if(socklen(fileno(stdin),0))
  1322. recv_mbuf(fileno(stdin),NULL,0,NULL,0);
  1323. break;
  1324. }
  1325. alert(parent,EINTR);  /* Tell the parent to quit */
  1326. kwait(Curproc);  /* Please kill me */
  1327. }
  1329. static void
  1330. gw_alarm(p)
  1331. void *p;
  1332. {
  1333. struct gwalarm *gwa = (struct gwalarm *)p;
  1334. char oldbl;
  1335. struct usock *up;
  1337. /* Flush sockets s1 and s2, but first make sure that the socket
  1338.  * is set to non-blocking mode, to prevent the flush from blocking
  1339.  * if the high water mark has been reached.
  1340.  */
  1341. if((up = itop(fileno(gwa->s1))) != NULL) {
  1342. oldbl = up->noblock;
  1343. up->noblock = 1;
  1344. fflush(gwa->s1);
  1345. up->noblock = oldbl;
  1346. }
  1347. if((up = itop(fileno(gwa->s2))) != NULL) {
  1348. oldbl = up->noblock;
  1349. up->noblock = 1;
  1350. fflush(gwa->s2);
  1351. up->noblock = oldbl;
  1352. }
  1353. start_timer(&gwa->t);
  1354. }
  1356. /* States for send line parser state machine */
  1357. #define LOOK_FOR_USER 2
  1358. #define IN_USER 3
  1359. #define AFTER_USER 4
  1360. #define LOOK_FOR_HOST 5
  1361. #define IN_HOST 6
  1362. #define AFTER_HOST 7
  1363. #define LOOK_FOR_FROM 8
  1364. #define IN_FROM 9
  1365. #define AFTER_FROM 10
  1366. #define LOOK_FOR_MSGID 11
  1367. #define IN_MSGID 12
  1368. #define FINAL_STATE 13
  1369. #define ERROR_STATE 14
  1371. /* Prepare the addressee.  If the address is bad, return -1, otherwise
  1372.  * return 0
  1373.  */
  1374. static int
  1375. mbx_to(argc,argv,p)
  1376. int argc;
  1377. char *argv[];
  1378. void *p;
  1379. {
  1380. register char *cp;
  1381. int state, i;
  1382. char *user, *host, *from, *msgid;
  1383. int userlen = 0, hostlen = 0, fromlen = 0, msgidlen = 0;
  1384. struct mbx *m;
  1386. m = (struct mbx *)p;
  1387. /* Free anything that might be allocated
  1388.  * since the last call to mbx_to() or mbx_reply()
  1389.  */
  1390. free(m->to);
  1391. m->to = NULL;
  1392. free(m->tofrom);
  1393. m->tofrom = NULL;
  1394. free(m->tomsgid);
  1395. m->tomsgid = NULL;
  1396. free(m->origto);
  1397. m->origto = NULL;
  1399. if(argc == 1)
  1400. return -1;
  1401. i = 1;
  1402. cp = argv[i];
  1403. state = LOOK_FOR_USER;
  1404. while(state < FINAL_STATE){
  1405. #ifdef MBDEBUG
  1406. printf("State is %d, char is %cn", state, *cp);
  1407. #endif
  1408. switch(state){
  1409. case LOOK_FOR_USER:
  1410. if(*cp == '@' || *cp == '<' || *cp == '$'){
  1411. state = ERROR_STATE; /* no user */
  1412. } else {
  1413. user = cp; /* point at start */
  1414. userlen++; /* start counting */
  1415. state = IN_USER;
  1416. }
  1417. break;
  1418. case IN_USER:
  1419. switch(*cp){
  1420. case '':
  1421. state = AFTER_USER; /* done with username */
  1422. break;
  1423. case '@':
  1424. state = LOOK_FOR_HOST; /* hostname should follow */
  1425. break;
  1426. case '<':
  1427. state = LOOK_FOR_FROM; /* from name should follow */
  1428. break;
  1429. case '$':
  1430. state = LOOK_FOR_MSGID; /* message id should follow */
  1431. break;
  1432. default:
  1433. userlen++; /* part of username */
  1434. }
  1435. break;
  1436. case AFTER_USER:
  1437. switch(*cp){
  1438. case '@':
  1439. state = LOOK_FOR_HOST; /* hostname follows */
  1440. break;
  1441. case '<':
  1442. state = LOOK_FOR_FROM; /* fromname follows */
  1443. break;
  1444. case '$':
  1445. state = LOOK_FOR_MSGID; /* message id follows */
  1446. break;
  1447. default:
  1448. state = ERROR_STATE;
  1449. }
  1450. break;
  1451. case LOOK_FOR_HOST:
  1452. if(*cp == '@' || *cp == '<' || *cp == '$'){
  1453. state = ERROR_STATE;
  1454. break;
  1455. }
  1456. if(*cp == '')
  1457. break;
  1458. host = cp;
  1459. hostlen++;
  1460. state = IN_HOST;
  1461. break;
  1462. case IN_HOST:
  1463. switch(*cp){
  1464. case '':
  1465. state = AFTER_HOST; /* found user@host */
  1466. break;
  1467. case '@':
  1468. state = ERROR_STATE; /* user@host@? */
  1469. break;
  1470. case '<':
  1471. state = LOOK_FOR_FROM; /* fromname follows */
  1472. break;
  1473. case '$':
  1474. state = LOOK_FOR_MSGID; /* message id follows */
  1475. break;
  1476. default:
  1477. hostlen++;
  1478. }
  1479. break;
  1480. case AFTER_HOST:
  1481. switch(*cp){
  1482. case '@':
  1483. state = ERROR_STATE; /* user@host @ */
  1484. break;
  1485. case '<':
  1486. state = LOOK_FOR_FROM; /* user@host < */
  1487. break;
  1488. case '$':
  1489. state = LOOK_FOR_MSGID; /* user@host $ */
  1490. break;
  1491. default:
  1492. state = ERROR_STATE; /* user@host foo */
  1493. }
  1494. break;
  1495. case LOOK_FOR_FROM:
  1496. if(*cp == '@' || *cp == '<' || *cp == '$'){
  1497. state = ERROR_STATE;
  1498. break;
  1499. }
  1500. if(*cp == '')
  1501. break;
  1502. from = cp;
  1503. fromlen++;
  1504. state = IN_FROM;
  1505. break;
  1506. case IN_FROM:
  1507. switch(*cp){
  1508. case '':
  1509. state = AFTER_FROM; /* user@host <foo */
  1510. break;
  1511. case '<':
  1512. state = ERROR_STATE; /* user@host <foo< */
  1513. break;
  1514. case '$':
  1515. state = LOOK_FOR_MSGID; /* message id follows */
  1516. break;
  1517. default:
  1518. fromlen++;
  1519. }
  1520. break;
  1521. case AFTER_FROM:
  1522. switch(*cp){
  1523. case '@': /* user@host <foo @ */
  1524. case '<': /* user@host <foo < */
  1525. state = ERROR_STATE;
  1526. break;
  1527. case '$':
  1528. state = LOOK_FOR_MSGID; /* user@host <foo $ */
  1529. break;
  1530. default:
  1531. state = ERROR_STATE; /* user@host foo */
  1532. }
  1533. break;
  1534. case LOOK_FOR_MSGID:
  1535. if(*cp == '')
  1536. break;
  1537. msgid = cp;
  1538. msgidlen++;
  1539. state = IN_MSGID;
  1540. break;
  1541. case IN_MSGID:
  1542. if(*cp == '')
  1543. state = FINAL_STATE;
  1544. else
  1545. msgidlen++;
  1546. break;
  1547. default:
  1548. /* what are we doing in this state? */
  1549. state = ERROR_STATE;
  1550. }
  1551. if(*(cp) == ''){
  1552. ++i;
  1553. if(i < argc)
  1554. cp = argv[i];
  1555. else break;
  1556. } else
  1557. ++cp;
  1558. }
  1559. if(state == ERROR_STATE || state == LOOK_FOR_HOST
  1560.  || state == LOOK_FOR_FROM || state == LOOK_FOR_MSGID)
  1561. return -1; /* syntax error */
  1563. m->to = mallocw(userlen + hostlen + 2);
  1565. strncpy(m->to, user, userlen);
  1566. m->to[userlen] = '';
  1568. if(hostlen){
  1569. m->to[userlen] = '@';
  1570. strncpy(m->to + userlen + 1, host, hostlen);
  1571. m->to[userlen + hostlen + 1] = '';
  1572. }
  1573. if(fromlen){
  1574. m->tofrom = mallocw(fromlen + 1);
  1575. strncpy(m->tofrom, from, fromlen);
  1576. m->tofrom[fromlen] = '';
  1577. }
  1578. if(msgidlen){
  1579. m->tomsgid = mallocw(msgidlen + 1);
  1580. strncpy(m->tomsgid, msgid, msgidlen);
  1581. m->tomsgid[msgidlen] = '';
  1582. }
  1583. return 0;
  1584. }
  1586. /* This opens the data file and writes the mail header into it.
  1587.  * Returns 0 if OK, and -1 if not.
  1588.  */
  1589. static int
  1590. mbx_data(m,cclist,extra)
  1591. struct mbx *m;
  1592. struct list *cclist; /* list of carbon copy recipients */
  1593. char *extra; /* optional extra header lines */
  1594. {
  1595. time_t t;
  1596. struct list *ap;
  1597. int cccnt = 0;
  1599. if((m->tfile = tmpfile()) == NULL)
  1600. return -1;
  1601. time(&t);
  1602. fprintf(m->tfile,Hdrs[RECEIVED]);
  1603. if(m->tofrom != NULL)
  1604. fprintf(m->tfile,"from %s.bbs ",m->name);
  1605. fprintf(m->tfile,"by %s (%s)ntid AA%ld ; %s",
  1606. Hostname, Version, get_msgid(), ptime(&t));
  1607. fprintf(m->tfile,"%s%s",Hdrs[DATE],ptime(&t));
  1608. fprintf(m->tfile,Hdrs[MSGID]);
  1609. if(m->tomsgid)
  1610. fprintf(m->tfile,"<%s@%s.bbs>n", m->tomsgid, m->name);
  1611. else
  1612. fprintf(m->tfile,"<%ld@%s>n",get_msgid(), Hostname);
  1613. fprintf(m->tfile,Hdrs[FROM]);
  1614. if(m->tofrom)
  1615. fprintf(m->tfile,"%s%%%s.bbs@%sn",
  1616. m->tofrom, m->name, Hostname);
  1617. else
  1618. fprintf(m->tfile,"%s@%sn", m->name, Hostname);
  1619. fprintf(m->tfile,"%s%sn",Hdrs[TO],m->origto != NULL ? m->origto : m->to);
  1620. /* Write Cc: line */
  1621. for(ap = cclist; ap != NULL; ap = ap->next) {
  1622. if(cccnt == 0){
  1623. fprintf(m->tfile,"%s",Hdrs[CC]);
  1624. cccnt = 4;
  1625. }
  1626. else {
  1627.        fprintf(m->tfile,", ");
  1628.        cccnt += 2;
  1629. }
  1630. if(cccnt + strlen(ap->val) > 80 - 3) {
  1631.        fprintf(m->tfile,"n    ");
  1632.        cccnt = 4;
  1633. }
  1634. fputs(ap->val,m->tfile);
  1635. cccnt += strlen(ap->val);
  1636. }
  1637. if(cccnt)
  1638. fputc('n',m->tfile);
  1639. fprintf(m->tfile,"%s%sn",Hdrs[SUBJECT],m->line);
  1640. if(!isspace(m->stype) && ((m->stype != 'R' && m->stype != 'F') ||
  1641.   (m->sid & MBX_SID) !=0))
  1642.   fprintf(m->tfile,"%s%cn", Hdrs[BBSTYPE],m->stype);
  1643. if(extra != NULL)
  1644. fprintf(m->tfile,extra);
  1645. fprintf(m->tfile,"n");
  1647. return 0;
  1648. }
  1650. /* Returns true if string is in history file or if string appears to be a
  1651.  * message id generated by our system.
  1652.  */
  1653. static int
  1654. msgidcheck(string)
  1655. char *string;
  1656. {
  1657.      FILE *fp;
  1658.      char buf[LINELEN], *cp;
  1659.      if(string == NULL)
  1660.   return 0;
  1661.      /* BID's that we have generated ourselves are not kept in the history
  1662.       * file. Such BID's are in the nnnn_hhhh form, where hhhh is a part of
  1663.       * our hostname, truncated so that the BID is no longer than 11
  1664.       * characters.
  1665.       */
  1666.      if((cp = strchr(string,'_')) != NULL && *(cp+1) != '' && 
  1667. strnicmp(cp+1,Hostname,strlen(cp+1)) == 0)
  1668.   return 1;
  1670.      if((fp = fopen(Historyfile,READ_TEXT)) == NULL)
  1671.   return 0;
  1672.      while(fgets(buf,LINELEN,fp) != NULL) {
  1673.   rip(buf);
  1674.   if(stricmp(string,buf) == 0) { /* found */
  1675.        fclose(fp);
  1676.        return 1;
  1677.   }
  1678.      }
  1679.      fclose(fp);
  1680.      return 0;
  1681. }
  1682.      
  1684. /* uuencode a file -- translated from C++; both versions copyright 1990
  1685.    by David R. Evans, G4AMJ/NQ0I
  1686. */
  1688. static int
  1689. uuencode(infile,outfile,infilename)
  1690. FILE *infile;
  1691. FILE *outfile;
  1692. char *infilename;
  1693. {
  1694.   int n_read_so_far = 0, n_written_so_far = 0, in_chars, n, mode = 0755;
  1695.   int32 cnt = 0;
  1696.   unsigned char in[3], out[4], line[100];
  1697. #ifdef UNIX
  1698.   struct stat stb;
  1699.   
  1700.   if(stat(infilename,&stb) != -1)
  1701.        mode = stb.st_mode & 0777; /* get real file protection mode */
  1702. #endif
  1703.   fprintf(outfile, "begin %03o %sn", mode, infilename);
  1705.   /* do the encode */
  1706.   for(;;) {
  1707.     in_chars = fread(in, 1, 3, infile);
  1708.     out[0] = in[0] >> 2;
  1709.     out[1] = in[0] << 6;
  1710.     out[1] = out[1] >> 2;
  1711.     out[1] = out[1] | (in[1] >> 4);
  1712.     out[2] = in[1] << 4;
  1713.     out[2] = out[2] >> 2;
  1714.     out[2] = out[2] | (in[2] >> 6);
  1715.     out[3] = in[2] << 2;
  1716.     out[3] = out[3] >> 2;
  1717.     for (n = 0; n < 4; n++)
  1718.       out[n] += ' ';
  1719.     n_read_so_far += in_chars;
  1720.     for (n = 0; n < 4; n++)
  1721.       line[n_written_so_far++] = out[n];
  1722.     if (((in_chars != 3) || (n_written_so_far == 60)) && n_read_so_far > 0) {
  1723.       line[(n_read_so_far + 2) / 3 * 4] = '';
  1724.       
  1725.       fprintf(outfile,"%c%sn",n_read_so_far + ' ', line);
  1726.       cnt += n_read_so_far;
  1727.       n_read_so_far = 0;
  1728.       n_written_so_far = 0;
  1729.     }
  1730.     if (in_chars == 0)
  1731.       break;
  1732.   }
  1733.   if (fprintf(outfile," nendnsize %lun", cnt) == EOF)
  1734.     return 1;
  1735.   return 0;
  1736. }