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

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

TCP/IP协议栈

开发平台：

Visual C++

nntpcli.c：源码内容
  1. /*
  2.  * Client routines for Network News Tranfer Protocol ala RFC977
  3.  *
  4.  * Copyright 1990 Anders Klemets - SM0RGV, All Rights Reserved.
  5.  * Permission granted for non-commercial copying and use, provided
  6.  * this notice is retained.
  7.  *
  8.  * Changes copyright 1990 Bernie Roehl, All Rights Reserved.
  9.  * Permission granted for non-commercial copying and use, provided
  10.  * this notice is retained.
  11.  *
  12.  *  Revision history:
  13.  *
  14.  *     May 11, 1990 - br checked for invalid chars in news filenames
  15.  *
  16.  *     May 10, 1990 - br changed date stamp in 'From ' lines to
  17.  *            seconds since GMT (to make parsing and expiry easier)
  18.  *
  19.  *     May 9, 1990 - br added locking of nntp.dat and history files,
  20.  *            second parameter to NNTP DIR, fixed bug in updating of
  21.  *            nntp.dat
  22.  *
  23.  *     early May, 1990 -- br added NNTP TRACE, NNTP DIR,
  24.  *            server-specific newsgroups and connection windows,
  25.  *            locking of newsgroup files using mlock() and rmlock(),
  26.  *            date stamping of 'From ' lines, increased stack space,
  27.  *            updating of nntp.dat only on successful sessions.
  28.  *
  29.  *     July 19, 1990 pa0gri Delinted and cleaned up. (calls and includes)
  30.  *
  31.  */
  32. #include <stdio.h>
  33. #include <sys/types.h>
  34. #include <time.h>
  35. #include <sys/timeb.h>
  36. #include <ctype.h>
  37. #include <string.h>  /* for strchr() */
  38. #ifdef __TURBOC__
  39. #include <dir.h>
  40. #endif
  41. #include "global.h"
  42. #include "timer.h"
  43. #include "cmdparse.h"
  44. #include "commands.h"
  45. #include "socket.h"
  46. #include "usock.h"
  47. #include "netuser.h"
  48. #include "proc.h"
  49. #include "smtp.h"
  50. #include "files.h"
  52. #define NNTPMAXLEN 512
  54. struct nntpservers {
  55. struct timer nntpcli_t;
  56. char *name;
  57. char *groups;
  58. int lowtime, hightime;  /* for connect window */
  59. struct nntpservers *next;
  60. };
  62. #define MAXGROUPDIRS 10
  64. static struct grouploc {
  65. char *prefix;        /* e.g. comp, rec, net, talk, alt ... */
  66. char *directory;     /* directory where these groups should be */
  67. } groupdirs[MAXGROUPDIRS] = { NULL, NULL };
  69. struct nntpservers *Nntpservers = NULL;
  70. static char *Nntpgroups = NULL;
  71. static unsigned short nntptrace = 1;
  73. static char *validchars = "abcdefghijklmnopqrstuvwxyz0123456789-_";
  75. static void nntptick(void *tp);
  76. static void nntp_job(int i1,void *tp,void *v1);
  77. static int gettxt(FILE *network,FILE *fp);
  78. static int getreply(FILE *network);
  79. static int getarticle(FILE *network,char *msgid);
  80. static int dogroups(int argc,char *argv[],void *p);
  81. static int doadds(int argc,char *argv[],void *p);
  82. static int dodrops(int argc,char *argv[],void *p);
  83. static int dokicks(int argc,char *argv[],void *p);
  84. static int dolists(int argc,char *argv[],void *p);
  85. static int donntrace(int argc,char *argv[],void *p);
  86. static int dondir(int argc,char *argv[],void *p);
  88. /* Tracing levels:
  89. 0 - no tracing
  90. 1 - serious errors reported
  91. 2 - transient errors reported
  92. 3 - session progress reported
  93. 4 - actual received articles displayed
  94.  */
  96. static struct cmds Nntpcmds[] = {
  97. "addserver", doadds, 0, 3,
  98. "nntp addserver <nntpserver> <interval>",
  99. "directory", dondir, 0, 0, NULL,
  100. "dropserver", dodrops, 0, 2,
  101. "nntp dropserver <nntpserver>",
  102. "groups", dogroups, 0, 0, NULL,
  103. "kick", dokicks, 0, 2,
  104. "nntp kick <nntpserver>",
  105. "listservers", dolists, 0, 0, NULL,
  106. "trace", donntrace, 0, 0, NULL,
  107. NULL,
  108. };
  110. int
  111. donntp(argc,argv,p)
  112. int argc;
  113. char *argv[];
  114. void *p;
  115. {
  116. return subcmd(Nntpcmds,argc,argv,p);
  117. }
  119. static int
  120. doadds(argc,argv,p)
  121. int argc;
  122. char *argv[];
  123. void *p;
  124. {
  125. struct nntpservers *np;
  126. for(np = Nntpservers; np != NULL; np = np->next)
  127. if(stricmp(np->name,argv[1]) == 0)
  128. break;
  129. if (np == NULL) {
  130. np = (struct nntpservers *) callocw(1,sizeof(struct nntpservers));
  131. np->name = strdup(argv[1]);
  132. np->next = Nntpservers;
  133. Nntpservers = np;
  134. np->groups = NULL;
  135. np->lowtime = np->hightime = -1;
  136. np->nntpcli_t.func = nntptick; /* what to call on timeout */
  137. np->nntpcli_t.arg = (void *)np;
  138. }
  139. if (argc > 3) {
  140. int i;
  141. if (np->groups == NULL) {
  142. np->groups = mallocw(NNTPMAXLEN);
  143. *np->groups = '';
  144. }
  145. for (i = 3; i < argc; ++i) {
  146. if (isdigit(*argv[i])) {
  147. int lh, ll, hh, hl;
  148. sscanf(argv[i], "%d:%d-%d:%d", &lh, &ll, &hh, &hl);
  149. np->lowtime = lh * 100 + ll;
  150. np->hightime = hh * 100 + hl;
  151. } else if ((strlen(np->groups)+strlen(argv[i])+2) >= NNTPMAXLEN)
  152. printf("Group list too long!  Group '%s' ignored!n", argv[i]);
  153. else {  /* it's a group, and it fits... add it to list */
  154. if (*np->groups != '')
  155. strcat(np->groups, ",");
  156. strcat(np->groups, argv[i]);
  157. }
  158. }
  159. if (*np->groups == '') { /* No groups specified? */
  160. free(np->groups);
  161. np->groups = NULL;
  162. }
  163. }
  164. /* set timer duration */
  165. set_timer(&np->nntpcli_t,atol(argv[2])*1000L);
  166. start_timer(&np->nntpcli_t); /* and fire it up */
  167. return 0;
  168. }
  170. static int
  171. dodrops(argc,argv,p)
  172. int argc;
  173. char *argv[];
  174. void *p;
  175. {
  176. struct nntpservers *np, *npprev = NULL;
  177. for(np = Nntpservers; np != NULL; npprev = np, np = np->next)
  178. if(stricmp(np->name,argv[1]) == 0) {
  179. stop_timer(&np->nntpcli_t);
  180. free(np->name);
  181. if (np->groups)
  182. free(np->groups);
  183. if(npprev != NULL)
  184. npprev->next = np->next;
  185. else
  186. Nntpservers = np->next;
  187. free(np);
  188. return 0;
  189. }
  190. printf("No such server enabled.n");
  191. return 0;
  192. }
  194. static int
  195. dolists(argc,argv,p)
  196. int argc;
  197. char *argv[];
  198. void *p;
  199. {
  200. struct nntpservers *np;
  201. for(np = Nntpservers; np != NULL; np = np->next) {
  202. char tbuf[80];
  203. if (np->lowtime != -1 && np->hightime != -1)
  204. sprintf(tbuf, " -- %02d:%02d-%02d:%02d", np->lowtime/100, np->lowtime%100, np->hightime/100, np->hightime%100);
  205. else
  206. tbuf[0] = '';
  207. printf("%-32s (%lu/%lu%s) %sn", np->name,
  208. read_timer(&np->nntpcli_t) /1000L,
  209. dur_timer(&np->nntpcli_t) /1000L,
  210. tbuf, np->groups ? np->groups : "");
  211. }
  212. return 0;
  213. }
  215. static int donntrace(argc, argv, p)
  216. int argc;
  217. char *argv[];
  218. void *p;
  219. {
  220. return setshort(&nntptrace,"NNTP tracing",argc,argv);
  221. }
  223. static char *News_spool = NULL;
  224. static int np_all = 0;  /* non-zero if Newsdir is a malloc'ed space */
  226. static int dondir(argc, argv, p)
  227. int argc;
  228. char *argv[];
  229. void *p;
  230. {
  231. if (argc < 2) {
  232. int i;
  233. printf("spool: %sn", News_spool ? News_spool : Mailspool);
  234. printf("control: %sn", Newsdir);
  235. for (i = 0; i < MAXGROUPDIRS; ++i)
  236. if (groupdirs[i].prefix)
  237. printf("%-10.10s %sn", groupdirs[i].prefix, groupdirs[i].directory);
  238. } else {
  239. char *p;
  240. if ((p = strchr(argv[1], '=')) != NULL) {  /* set a groupdir */
  241. int i;
  242. *p++ = '';
  243. for (i = 0; i < MAXGROUPDIRS; ++i)
  244. if (groupdirs[i].prefix)
  245. if (!strnicmp(groupdirs[i].prefix, argv[1], strlen(argv[1]))) {
  246. if (groupdirs[i].directory) {
  247. free(groupdirs[i].directory);
  248. groupdirs[i].directory = NULL;
  249. }
  250. if (*p == '') {
  251. free(groupdirs[i].prefix);
  252. groupdirs[i].prefix = NULL;
  253. } else
  254. groupdirs[i].directory = strdup(p);
  255. return 0;
  256. }
  257. if (*p == '')  /* trashing a group that's not there */
  258. return 0;
  259. for (i = 0; i < MAXGROUPDIRS; ++i){
  260. if (groupdirs[i].prefix == NULL) {
  261. groupdirs[i].prefix = strdup(argv[1]);
  262. if (groupdirs[i].directory) {
  263. free(groupdirs[i].directory);
  264. groupdirs[i].directory = NULL;
  265. }
  266. groupdirs[i].directory = strdup(p);
  267. return 0;
  268. }
  269. }
  270. printf("Directory table fulln");
  271. }
  272. else {  /* no '=', so just set default */
  273. if (News_spool)
  274. free(News_spool);
  275. News_spool = strdup(argv[1]);
  276. }
  277. if (argc > 2) {  /* they specified a newsdir as well */
  278. if (np_all)
  279. free(Newsdir);
  280. Newsdir = strdup(argv[2]);
  281. np_all = 1;
  282. }
  283. }
  284. return 0;
  285. }
  287. static int
  288. dokicks(argc,argv,p)
  289. int argc;
  290. char *argv[];
  291. void *p;
  292. {
  293. struct nntpservers *np;
  294. for(np = Nntpservers; np != NULL; np = np->next)
  295. if(stricmp(np->name,argv[1]) == 0) {
  296. /* If the timer is not running, the timeout function has
  297. * already been called and we don't want to call it again.
  298. */
  299. if(run_timer(&np->nntpcli_t)) {
  300. stop_timer(&np->nntpcli_t);
  301. nntptick((void *)np);
  302. }
  303. return 0;
  304. }
  305. printf("No such server enabled.n");
  306. return 0;
  307. }
  309. static int
  310. dogroups(argc,argv,p)
  311. int argc;
  312. char *argv[];
  313. void *p;
  314. {
  315. int i;
  316. if(argc < 2) {
  317. if(Nntpgroups == NULL || (Nntpgroups != NULL && strcmp(Nntpgroups,"*") == 0))
  318. printf("All groups are currently enabled.n");
  319. else
  320. printf("Currently enabled newsgroups:n%sn",Nntpgroups);
  321. return 0;
  322. }
  323. if(Nntpgroups == NULL)
  324. Nntpgroups = mallocw(NNTPMAXLEN);
  325. *Nntpgroups = '';
  326. for(i=1; i < argc; ++i) {
  327. if(i > 1)
  328. strcat(Nntpgroups,",");
  329. strcat(Nntpgroups,argv[i]);
  330. }
  331. return 0;
  332. }
  334. /* This is the routine that gets called every so often to connect to
  335.  * NNTP servers.
  336.  */
  337. static void
  338. nntptick(tp)
  339. void *tp;
  340. {
  341. newproc("NNTP client", 3072, nntp_job, 0, tp, NULL,0);
  342. }
  344. static void
  345. nntp_job(i1,tp,v1)
  346. int i1;
  347. void *tp, *v1;
  348. {
  349. FILE *fp, *tmpf;
  350. int s = -1, i;
  351. FILE *network;
  352. /* long pos; */
  353. struct tm *ltm;
  354. time_t t;
  355. int now;
  356. struct nntpservers *np = (struct nntpservers *) tp;
  357. struct sockaddr_in fsocket;
  358. char tbuf[NNTPMAXLEN], buf[NNTPMAXLEN], *cp, *lastdate = NULL;
  359. if (nntptrace >= 3)
  360. printf("NNTP daemon entered, target = %sn",np->name);
  361. if(availmem() != 0){
  362. if (nntptrace >= 2)
  363. printf("NNTP daemon quit -- low memoryn");
  364. /* Memory is tight, don't do anything */
  365. start_timer(&np->nntpcli_t);
  366. return;
  367. }
  369. time(&t); /* more portable than gettime() */
  370. ltm = localtime(&t);
  371. now = ltm->tm_hour * 100 + ltm->tm_min;
  372. if (np->lowtime < np->hightime) {  /* doesn't cross midnight */
  373. if (now < np->lowtime || now >= np->hightime) {
  374. if (nntptrace >= 3)
  375. printf("NNTP window to '%s' not openn", np->name);
  376. start_timer(&np->nntpcli_t);
  377. return;
  378. }
  379. } else {
  380. if (now < np->lowtime && now >= np->hightime) {
  381. if (nntptrace >= 3)
  382. printf("NNTP window to '%s' not openn", np->name);
  383. start_timer(&np->nntpcli_t);
  384. return;
  385. }
  386. }
  388. fsocket.sin_addr.s_addr = resolve(np->name);
  389. if(fsocket.sin_addr.s_addr == 0) {  /* No IP address found */
  390. if (nntptrace >= 2)
  391. printf("NNTP can't resolve host '%s'n", np->name);
  392. /* Try again later */
  393. start_timer(&np->nntpcli_t);
  394. return;
  395. }
  396. fsocket.sin_family = AF_INET;
  397. fsocket.sin_port = IPPORT_NNTP;
  399. s = socket(AF_INET,SOCK_STREAM,0);
  400. if(connect(s,(struct sockaddr *)&fsocket,SOCKSIZE) == -1){
  401. cp = sockerr(s);
  402. logmsg(s,"NNTP %s Connect failed: %s",psocket(&fsocket),
  403. cp != NULL ? cp : "");
  404. if (nntptrace >= 2)
  405. printf("NNTP %s Connect failed: %sn",psocket(&fsocket),
  406. cp != NULL ? cp : "");
  407. goto quit;
  408. }
  409. network = fdopen(s,"r+t");
  411. /* Eat the banner */
  412. i = getreply(network);
  413. if(i == -1 || i >= 400) {
  414. logmsg(fileno(network),"NNTP %s bad reply on banner (response was %d)",psocket(&fsocket),i);
  415. if (nntptrace >= 1)
  416. printf("NNTP %s bad reply on banner (response was %d)n",psocket(&fsocket),i);
  417. goto quit;
  418. }
  420. if (mlock(Newsdir, "nntp")) {
  421. if (nntptrace >= 2)
  422. printf("NNTP %s Connect failed: cannot lock nntp.datn", psocket(&fsocket));
  423. goto quit;
  424. }
  425. sprintf(buf,"%s/nntp.dat",Newsdir);
  426. if((fp = fopen(buf,APPEND_TEXT)) == NULL) {
  427. logmsg(fileno(network),"NNTP %s Connect failed: Cannot open %s",psocket(&fsocket),
  428. buf);
  429. if (nntptrace >= 1)
  430. printf("NNTP %s Connect failed: Cannot open %sn",psocket(&fsocket), buf);
  431. rmlock(Newsdir, "nntp");
  432. goto quit;
  433. }
  434. rewind(fp);
  435. /* for(pos=0L; fgets(buf,NNTPMAXLEN,fp) != NULL;pos=ftell(fp)) { */
  436. for(; fgets(buf,NNTPMAXLEN,fp) != NULL;) {
  437. if((cp = strchr(buf,' ')) == NULL)
  438. continue; /* something wrong with this line, skip it */
  439. *cp = '';
  440. if(stricmp(buf,np->name) == 0) {
  441. rip(cp+1);
  442. lastdate = strdup(cp+1);
  443. break;
  444. }
  445. }
  446. fclose(fp);
  447. rmlock(Newsdir, "nntp");
  449. if(lastdate == NULL)
  450. lastdate = strdup("700101 000000");
  451. /* snapshot the time for use later in re-writing nntp.dat */
  452. time(&t);
  453. ltm = localtime(&t);
  455. /* Get a list of new message-id's */
  456. if (np->groups) {
  457. if (nntptrace >= 3)
  458. printf("==>NEWNEWS %s %sn", np->groups, lastdate);
  459. fprintf(network,"NEWNEWS %s %sn", np->groups, lastdate);
  460. } else {
  461. if (nntptrace >= 3)
  462. printf("==>NEWNEWS %s %sn", Nntpgroups != NULL ? Nntpgroups : "*", lastdate);
  463. fprintf(network,"NEWNEWS %s %sn",Nntpgroups != NULL ? Nntpgroups : "*", lastdate);
  464. }
  465. free(lastdate);
  466. /* Get the response */
  467. if((i = getreply(network)) != 230) { /* protocol error */
  468. logmsg(fileno(network),"NNTP %s protocol error (response was %d)",psocket(&fsocket),i);
  469. if (nntptrace >= 1)
  470. printf("NNTP %s protocol error (response was %d)n",psocket(&fsocket),i);
  471. goto quit;
  472. }
  473. if((tmpf = tmpfile()) == NULL) {
  474. if (nntptrace >= 1)
  475. printf("NNTP %s Cannot open temp filen", psocket(&fsocket));
  476. goto quit;
  477. }
  478. if(gettxt(network,tmpf) == -1) {
  479. logmsg(fileno(network), "NNTP %s giving up: gettxt() failure",psocket(&fsocket));
  480. if (nntptrace >= 1)
  481. printf("NNTP %s giving up: gettxt() failuren",psocket(&fsocket));
  482. fclose(tmpf);
  483. goto quit;
  484. }
  486. /* Open the history file */
  487. if (mlock(Newsdir, "history")) {
  488. if (nntptrace >= 1)
  489. printf("NNTP %s giving up: couldn't lock history filen", psocket(&fsocket));
  490. fclose(tmpf);
  491. goto quit;
  492. }
  493. sprintf(buf,"%s/history",Newsdir);
  494. if((fp = fopen(buf,APPEND_TEXT)) == NULL) {
  495. logmsg(fileno(network),"NNTP %s Connect failed: Cannot open %s",psocket(&fsocket), buf);
  496. if (nntptrace >= 1)
  497. printf("NNTP %s Connect failed: Cannot open %sn",psocket(&fsocket), buf);
  498. fclose(tmpf);
  499. goto quit;
  500. }
  501. /* search through the history file for matching message id's */
  502. rewind(tmpf);
  503. while(fgets(tbuf,NNTPMAXLEN,tmpf) != NULL) {
  504. i = 0;
  505. rewind(fp);
  506. while(fgets(buf,NNTPMAXLEN,fp) != NULL) {
  507. if(stricmp(buf,tbuf) == 0) {
  508. i = 1;
  509. break;
  510. }
  511. kwait(NULL);
  512. }
  513. if(i == 0) { /* not found, get the article */
  514. if(getarticle(network,tbuf) == -1) {
  515. logmsg(fileno(network),"NNTP %s Giving up: could not get article",psocket(&fsocket));
  516. if (nntptrace >= 2)
  517. printf("NNTP %s Giving up: could not get articlen",psocket(&fsocket));
  518. fclose(fp);
  519. rmlock(Newsdir, "history");
  520. fclose(tmpf);
  521. goto quit;
  522. }
  523. fprintf(fp,"%s",tbuf); /* add the new message id */
  524. }
  525. }
  526. fclose(fp);
  527. rmlock(Newsdir, "history");
  528. fclose(tmpf);
  529. if (nntptrace >= 3)
  530. printf("==>QUITn");
  531. fprintf(network,"QUITn");
  532. /* Eat the response */
  533. getreply(network);
  534. /* NOW, update the nntp.dat file */
  535. if (mlock(Newsdir, "nntp")) {
  536. if (nntptrace >= 2)
  537. printf("NNTP %s Could not lock nntp.dat for updaten", psocket(&fsocket));
  538. goto quit;
  539. }
  540. sprintf(buf,"%s/nntp.dat",Newsdir);
  541. fp = fopen(buf,READ_TEXT);
  542. sprintf(buf, "%s/nntp.tmp",Newsdir);
  543. if ((tmpf = fopen(buf, WRITE_TEXT)) == NULL)
  544. if (nntptrace >= 1)
  545. printf("NNTP %s Cannot create temp file '%s'n", psocket(&fsocket), buf);
  546. if (fp == NULL || tmpf == NULL) {
  547. logmsg(fileno(network),"NNTP %s Could not update %s", psocket(&fsocket), buf);
  548. if (nntptrace >= 2)
  549. printf("NNTP %s Could not update %sn",psocket(&fsocket), buf);
  550. if (fp)
  551. fclose(fp);
  552. if (tmpf)
  553. fclose(tmpf);
  554. rmlock(Newsdir, "nntp");
  555. goto quit;
  556. }
  557. while (fgets(tbuf, sizeof(tbuf), fp))
  558. if (strnicmp(tbuf, np->name, strlen(np->name)))
  559. fputs(tbuf, tmpf);
  560. fprintf(tmpf,"%s %02d%02d%02d %02d%02d%02dn",np->name,ltm->tm_year%100,ltm->tm_mon+1,
  561. ltm->tm_mday,ltm->tm_hour,ltm->tm_min,ltm->tm_sec);
  562. fclose(fp);
  563. fclose(tmpf);
  564. sprintf(buf, "%s/nntp.dat", Newsdir);
  565. sprintf(tbuf, "%s/nntp.tmp", Newsdir);
  566. unlink(buf);
  567. rename(tbuf, buf);
  568. rmlock(Newsdir, "nntp");
  569. quit:
  570. if (nntptrace >= 3)
  571. printf("NNTP daemon exitingn");
  572. fclose(network);
  573. /* Restart timer */
  574. start_timer(&np->nntpcli_t);
  575. return;
  576. }
  578. static int
  579. gettxt(network,fp)
  580. FILE *network;
  581. FILE *fp;
  582. {
  583. char buf[NNTPMAXLEN];
  584. int nlines;
  585. for (nlines = 0; fgets(buf,NNTPMAXLEN,network) != NULL; ++nlines) {
  586. if (nntptrace >= 4)
  587. printf("<==%s", buf);
  588. if(strcmp(buf,".n") == 0) {
  589. if (nntptrace >= 3)
  590. printf("NNTP received %d linesn", nlines);
  591. return 0;
  592. }
  593. /* check for escaped '.' characters */
  594. if(strcmp(buf,"..n") == 0)
  595. fputs(".n",fp);
  596. else
  597. fputs(buf,fp);
  598. }
  599. if (nntptrace >= 1)
  600. printf("NNTP receive error after %d linesn", nlines);
  601. return -1;
  602. }
  604. static int
  605. getreply(network)
  606. FILE *network;
  607. {
  608. char buf[NNTPMAXLEN];
  609. int response;
  610. while(fgets(buf,NNTPMAXLEN,network) != NULL) {
  611. /* skip informative messages and blank lines */
  612. if(buf[0] == '' || buf[0] == '1')
  613. continue;
  614. sscanf(buf,"%d",&response);
  615. if (nntptrace >= 3)
  616. printf("<==%sn", buf);
  617. return response;
  618. }
  619. if (nntptrace >= 3)
  620. printf("==No responsen");
  621. return -1;
  622. }
  624. static int
  625. getarticle(network,msgid)
  626. FILE *network;
  627. char *msgid;
  628. {
  629. char buf[NNTPMAXLEN], froml[NNTPMAXLEN], newgl[NNTPMAXLEN];
  630. FILE *fp, *tmpf;
  631. int r;
  632. char *cp;
  633. extern int Smtpquiet;
  635. if (nntptrace >= 3)
  636. printf("==>ARTICLE %s", msgid);
  637. fprintf(network,"ARTICLE %s", msgid);
  638. r = getreply(network);
  639. if(r == -1 || r >= 500)
  640. return -1;
  641. if(r >= 400)
  642. return 0;
  643. if((tmpf = tmpfile()) == NULL) {
  644. if (nntptrace >= 1)
  645. printf("NNTP Cannot open temp file for articlen");
  646. return -1;
  647. }
  648. if(gettxt(network,tmpf) == -1) {
  649. fclose(tmpf);
  650. return -1;
  651. }
  652. /* convert the article into mail format */
  653. rewind(tmpf);
  654. froml[0] = '';
  655. newgl[0] = '';
  656. while(fgets(buf,NNTPMAXLEN,tmpf) != NULL) {
  657. if(strncmp(buf,"From: ",6) == 0) {
  658. struct timeb t;
  659. ftime(&t);
  660. rip(&buf[6]);
  661. sprintf(froml,"From %s %ldn",&buf[6], t.time);
  662. if(newgl[0] != '')
  663. break;
  664. }
  665. if(strncmp(buf,"Newsgroups: ",12) == 0) {
  666. strcpy(newgl,&buf[12]);
  667. if(froml[0] != '')
  668. break;
  669. }
  670. /* invalid article - missing 'From:' line or 'Newsgroups:' line */
  671. if(strcmp(buf,"n") == 0 && (froml[0] == '' || newgl[0] == '')) {
  672. /* fclose(fp); */
  673. fclose(tmpf);
  674. return 0;
  675. }
  676. }
  677. sprintf(buf,"%s/",News_spool ? News_spool : Mailspool);
  678. for(cp=newgl;;++cp) {
  679. if(*cp == '.') {
  680. #ifdef __TURBOC__
  681. mkdir(buf); /* create a subdirectory, if necessary */
  682. #else
  683. mkdir(buf,0755); /* create a subdirectory, if necessary */
  684. #endif
  685. strcat(buf,"/");
  686. continue;
  687. }
  688. if(*cp == ',' || *cp == 'n') {
  689. char tempdir[80], prefix[20], *p;
  690. strcpy(tempdir, buf);
  691. if ((p = strrchr(tempdir, '/')) != NULL) {
  692. *p++ = '';
  693. strcpy(prefix, p);
  694. }
  695. if (mlock(tempdir, prefix)) {
  696. if (nntptrace >= 2)
  697. printf("NNTP group '%s' is lockedn", buf);
  698. return -1;
  699. }
  700. strcat(buf,".txt");
  701. /* open the mail file */
  702. if (nntptrace >= 3)
  703. printf("Writing article to '%s'n", buf);
  704. if((fp = fopen(buf,APPEND_TEXT)) != NULL) {
  705. fputs(froml,fp);
  706. rewind(tmpf);
  707. while(fgets(buf,NNTPMAXLEN,tmpf) != NULL) {
  708. /* for UNIX mail compatiblity */
  709. if(strncmp(buf,"From ",5) == 0)
  710. putc('>',fp);
  711. fputs(buf,fp);
  712. }
  713. putc('n',fp);
  714. fclose(fp);
  715. }
  716. rmlock(tempdir, prefix);
  717. if (*cp == 'n') 
  718. break;
  719. else
  720. sprintf(buf,"%s/",News_spool ? News_spool : Mailspool);
  721. continue;
  722. }
  723. buf[strlen(buf)+1] = '';
  724. buf[strlen(buf)] = strchr(validchars, tolower(*cp)) ? *cp : '_';
  725. }
  726. fclose(tmpf);
  727. strcpy(buf,msgid); /* Get a copy we can munge */
  728. rip(buf); /* remove trailing new-line */
  729. rip(newgl); /* ditto */
  730. #ifdef notdef
  731. printf("New news arrived: %s, article %s%cn",newgl,buf,Smtpquiet?' ':'07');
  732. #else
  733. printf("New news arrived: %s, article %sn",newgl,buf);
  734. #endif
  735. return 0;
  736. }