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

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

Telnet服务器

开发平台：

Unix_Linux

inntobbs.c：源码内容
  1. #include <stdio.h>
  2. #include "innbbsconf.h"
  3. #include "daemon.h"
  4. #include "bbslib.h"
  5. #include <time.h>
  7. #define INNTOBBS
  8. #include "inntobbs.h"
  9. #include "lang.h"
  11. typedef struct Header {
  12. char   *name;
  13. int     id;
  14. }       header_t;
  15. /*enum HeaderValue {
  16. SUBJECT_H, FROM_H, DATE_H, MID_H, NEWSGROUPS_H,
  17. NNTPPOSTINGHOST_H, NNTPHOST_H, CONTROL_H, PATH_H,
  18. ORGANIZATION_H, LASTHEADER,
  19. };
  20. */
  22. /*char *strchr ARG((char*,int));
  23. char *strrchr ARG((char*,int));
  24. char *strstr ARG((char*,char*));
  25. */
  27. header_t headertable[] = {
  28. "Subject", SUBJECT_H,
  29. "From", FROM_H,
  30. "Date", DATE_H,
  31. "Message-ID", MID_H,
  32. "Newsgroups", NEWSGROUPS_H,
  33. "NNTP-Posting-Host", NNTPPOSTINGHOST_H,
  34. "NNTP-Host", NNTPHOST_H,
  35. "Control", CONTROL_H,
  36. "Path", PATH_H,
  37. "Organization", ORGANIZATION_H,
  38. "X-Auth-From", X_Auth_From_H,
  39. "Approved", APPROVED_H,
  40. "Distribution", DISTRIBUTION_H,
  41. "Keywords", KEYWORDS_H,
  42. "Summary", SUMMARY_H,
  43. "References", REFERENCES_H,
  44. };
  46. char   *HEADER[LASTHEADER];
  47. char   *BODY;
  48. char   *FROM, *SUBJECT, *SITE, *DATE, *POSTHOST, *NNTPHOST, *PATH, *GROUPS,
  49.        *MSGID, *CONTROL;
  50. #ifdef PalmBBS
  51. char  **XHEADER;
  52. char   *XPATH;
  53. #endif
  56. int
  57. isexcluded(path1, nl)
  58. char   *path1;
  59. nodelist_t *nl;
  60. {
  61. char    path2[1024];
  62. /* path2 = (char*)mymalloc(strlen(nl->node) + 3); */
  63. sprintf(path2, "!%.*s!", sizeof path2 - 3, nl->node);
  64. if (strstr(path1, path2) != NULL)
  65. return 1;
  66. if (nl->exclusion && *nl->exclusion) {
  67. char   *exclude, *ptr;
  68. for (exclude = nl->exclusion, ptr = strchr(exclude, ',');
  69. exclude && *exclude; ptr = strchr(exclude, ',')) {
  70. if (ptr)
  71. *ptr = '';
  72. sprintf(path2, "!%.*s!", sizeof path2 - 3, exclude);
  73. if (strstr(path1, path2) != NULL)
  74. return 1;
  75. if (ptr) {
  76. *ptr = ',';
  77. exclude = ptr + 1;
  78. } else {
  79. break;
  80. }
  81. }
  82. }
  83. return 0;
  84. }
  85. feedfplog(nf, filepath, type)
  86. newsfeeds_t *nf;
  87. char   *filepath;
  88. int     type;
  89. {
  90. char   *path1, *path2, *hostptr;
  91. nodelist_t *nl;
  92. if (nf == NULL)
  93. return;
  94. if (nf->path != NULL) {
  95. char   *ptr1, *ptr2;
  96. char    savech;
  97. path1 = (char *) mymalloc(strlen(HEADER[PATH_H]) + 3);
  98. sprintf(path1, "!%s!", HEADER[PATH_H]);
  99. for (ptr1 = nf->path; ptr1 && *ptr1;) {
  100. for (; *ptr1 && isspace(*ptr1); ptr1++);
  101. if (!*ptr1)
  102. break;
  103. for (ptr2 = ptr1; *ptr2 && !isspace(*ptr2); ptr2++);
  104. savech = *ptr2;
  105. *ptr2 = '';
  106. /*
  107.  * bbslog("search node %sn",ptr1);
  108.  */
  109. nl = (nodelist_t *) search_nodelist_bynode(ptr1);
  110. /*
  111.  * bbslog("search node node %s, host %s fp
  112.  * %dn",nl->node, nl->host, nl->feedfp);
  113.  */
  114. *ptr2 = savech;
  115. ptr1 = ptr2++;
  116. if (nl == NULL)
  117. continue;
  118. if (nl->feedfp == NULL)
  119. continue;
  120. if (isexcluded(path1, nl))
  121. continue;
  122. /*
  123.  * path2 = (char*)mymalloc(strlen(nl->node) + 3);
  124.  * sprintf(path2, "!%s!",nl->node); free(path2);
  125.  */
  126. /*
  127.  * bbslog("path1 %s path2 %sn",path1, path2);
  128.  */
  129. /* if (strstr(path1, path2) != NULL) return; */
  130. /* to conform to the bntplink batch file */
  131. {
  132. char   *slash = strrchr(filepath, '/');
  133. if (slash != NULL)
  134. *slash = 't';
  135. fprintf(nl->feedfp, "%st%stt%st%st%ct%st%s!%sn",
  136. filepath == NULL ? "" : filepath,
  137. GROUPS, FROM, SUBJECT, type, MSGID, MYBBSID, HEADER[PATH_H]);
  138. if (slash != NULL)
  139. *slash = '/';
  140. }
  141. fflush(nl->feedfp);
  142. if (savech == '')
  143. break;
  144. }
  145. free(path1);
  146. }
  147. }
  149. static FILE *bbsfeedsfp = NULL;
  150. static  bbsfeedson = -1;
  151. init_bbsfeedsfp()
  152. {
  153. if (bbsfeedsfp != NULL) {
  154. fclose(bbsfeedsfp);
  155. bbsfeedsfp = NULL;
  156. }
  157. bbsfeedson = -1;
  158. }
  159. bbsfeedslog(filepath, type)
  160. char   *filepath;
  161. int     type;
  162. {
  164. char    datebuf[40];
  165. time_t  now;
  166. if (bbsfeedson == 0)
  167. return;
  168. if (bbsfeedson == -1) {
  169. if (!isfile(BBSFEEDS)) {
  170. bbsfeedson = 0;
  171. return;
  172. }
  173. bbsfeedson = 1;
  174. }
  175. if (bbsfeedsfp == NULL) {
  176. bbsfeedsfp = fopen(BBSFEEDS, "a");
  177. }
  178. time(&now);
  179. strftime(datebuf, sizeof(datebuf), "%b %d %X ", localtime(&now));
  181. if (bbsfeedsfp != NULL) {
  182. fprintf(bbsfeedsfp, "%s %c %s %s %s %s!%s %sn", datebuf, type,
  183. REMOTEHOSTNAME, GROUPS, MSGID, MYBBSID, HEADER[PATH_H], filepath == NULL ? "" : filepath);
  184. fflush(bbsfeedsfp);
  185. }
  186. }
  188. static FILE *echomailfp = NULL;
  189. static  echomaillogon = -1;
  190. init_echomailfp()
  191. {
  192. if (echomailfp != NULL) {
  193. fclose(echomailfp);
  194. echomailfp = NULL;
  195. }
  196. echomaillogon = -1;
  197. }
  198. echomaillog()
  199. {
  201. if (echomaillogon == 0)
  202. return;
  203. if (echomaillogon == -1) {
  204. if (!isfile(ECHOMAIL)) {
  205. echomaillogon = 0;
  206. return;
  207. }
  208. echomaillogon = 1;
  209. }
  210. if (echomailfp == NULL) {
  211. echomailfp = fopen(ECHOMAIL, "a");
  212. }
  213. if (echomailfp != NULL) {
  214. fprintf(echomailfp, "n");
  215. fprintf(echomailfp, "%s%s, %s%sn", FromTxt, FROM, BoardTxt, GROUPS);
  216. fprintf(echomailfp, "%s%sn", SubjectTxt, SUBJECT);
  217. fprintf(echomailfp, "%s%s (%s)n", OrganizationTxt, SITE, DATE);
  218. fprintf(echomailfp, "%s%s (%s)n", PathTxt, PATH, REMOTEHOSTNAME);
  219. fflush(echomailfp);
  220. }
  221. }
  224. #ifdef FILTER
  226. char   *
  227. cmdfilter(indata, filterbuffer, cmd)
  228. char   *indata, **filterbuffer;
  229. FuncPtr cmd;
  230. {
  231. char   *outdata;
  232. int     len = strlen(indata);
  233. if (*filterbuffer != NULL)
  234. *filterbuffer = (char *) myrealloc(*filterbuffer, len + 4096);
  235. else
  236. *filterbuffer = (char *) mymalloc(len + 4096);
  237. if (filterbuffer == NULL)
  238. return NULL;
  239. bcopy(indata, *filterbuffer, len);
  240. (*cmd) (*filterbuffer, &len, 0);
  241. (*filterbuffer)[len] = '';
  242. return *filterbuffer;
  243. }
  245. char   *
  246. externfilter(indata, filterbuffer, cmd)
  247. char   *indata, **filterbuffer, *cmd;
  248. {
  249. char   *outdata;
  250. FILE   *fp;
  251. int     fd;
  252. char   *tmpfile;
  254. int     len = strlen(indata);
  255. int     size;
  256. struct stat st;
  257. fp = (FILE *) popen((char *) fileglue("%s > /tmp/.innbbsdfilter%d%d", cmd, getpid(), getuid()), "w");
  258. if (fp == NULL) {
  259. bbslog("Err: can't popen %sn", cmd);
  260. return NULL;
  261. }
  262. if (fwrite(indata, 1, len, fp) != len) {
  263. bbslog("Err: fwrite to %s failed, len %dn", cmd, len);
  264. return NULL;
  265. }
  266. pclose(fp);
  268. tmpfile = (char *) fileglue("/tmp/.innbbsdfilter%d%d", getpid(), getuid());
  269. if (stat(tmpfile, &st) != 0)
  270. return NULL;
  272. if (*filterbuffer != NULL)
  273. *filterbuffer = myrealloc(*filterbuffer, st.st_size + 1);
  274. else
  275. *filterbuffer = mymalloc(st.st_size + 1);
  276. (*filterbuffer)[st.st_size] = '';
  277. if (*filterbuffer == NULL)
  278. return NULL;
  280. fd = open(tmpfile, O_RDONLY);
  281. if (fd < 0)
  282. return NULL;
  283. read(fd, *filterbuffer, st.st_size);
  284. close(fd);
  285. unlink(tmpfile);
  286. return *filterbuffer;
  287. }
  289. char   *
  290. filterdata(arp, direction, indata, filterdata)
  291. newsfeeds_t *arp;
  292. int     direction;
  293. char   *indata, **filterdata;
  294. {
  295. char   *outdata;
  296. FuncPtr fptr = NULL;
  297. char   *cmdptr = NULL;
  298. if (direction) {
  299. fptr = arp->sfilter;
  300. cmdptr = arp->scmdfilter;
  301. } else {
  302. fptr = arp->rfilter;
  303. cmdptr = arp->rcmdfilter;
  304. }
  305. if (fptr)
  306. outdata = cmdfilter(indata, filterdata, fptr);
  307. else if (cmdptr)
  308. outdata = externfilter(indata, filterdata, cmdptr);
  309. else
  310. outdata = NULL;
  311. return outdata;
  312. }
  314. char   *
  315. processfilter(indata, filterbuffer, direction)
  316. char   *indata, **filterbuffer;
  317. int     direction;
  318. {
  319. char   *front = indata, *ptr, *hptr;
  320. int     i;
  321. char   *outdata = indata;
  322. int     filterflag = 0;
  323. for (ptr = (char *) strchr(indata, 'n'); ptr != NULL && *ptr != ''; front = ptr + 1, ptr = (char *) strchr(front, 'n')) {
  324. *ptr = '';
  325. if (front[0] == 'r' || front[1] == 'n') {
  326. *ptr = 'n';
  327. break;
  328. }
  329. hptr = (char *) strchr(front, ':');
  330. if (hptr != NULL && hptr[1] == ' ') {
  331. *hptr = '';
  332. if (strcmp(front, "Newsgroups") == 0) {
  333. char   *ngp, *ongp;
  334. newsfeeds_t *arp;
  335. char   *tp;
  336. if ((tp = (char *) strchr(hptr + 2, 'r')) != NULL)
  337. *tp = '';
  338. for (ngp = hptr + 2, ongp = strchr(ngp, ',');
  339. ngp && *ngp; ongp = strchr(ngp, ',')) {
  340. if (ongp)
  341. *ongp = '';
  342. arp = search_group(ngp);
  343. if (arp) {
  344. if (ongp)
  345. *ongp = ',';
  346. if (tp != NULL)
  347. *tp = 'r';
  348. if (hptr)
  349. *hptr = ':';
  350. if (ptr)
  351. *ptr = 'n';
  352. outdata = filterdata(arp, direction, indata, filterbuffer);
  353. if (outdata)
  354. filterflag = 1;
  355. if (ongp)
  356. *ongp = '';
  357. if (tp != NULL)
  358. tp = '';
  359. if (hptr)
  360. *hptr = '';
  361. if (ptr)
  362. *ptr = '';
  363. }
  364. if (ongp) {
  365. *ongp = ',';
  366. ngp = ongp + 1;
  367. } else {
  368. break;
  369. }
  370. if (filterflag)
  371. break;
  372. }
  373. if (tp != NULL)
  374. *tp = 'r';
  375. filterflag = 1;
  376. }
  377. *hptr = ':';
  378. }
  379. *ptr = 'n';
  380. if (filterflag)
  381. break;
  382. }
  383. if (outdata)
  384. return outdata;
  385. else
  386. return indata;
  387. }
  388. #endif
  390. int 
  391. headercmp(a, b)
  392. header_t *a, *b;
  393. {
  394. return strcasecmp(a->name, b->name);
  395. }
  397. int 
  398. readlines(client)
  399. ClientType *client;
  400. {
  401. int     fd = client->fd;
  402. char   *buffer = client->buffer;
  403. buffer_t *in = &client->in;
  404. char   *indata = in->data;
  405. char   *front = in->data, *ptr, *hptr;
  406. int     i;
  407. for (i = 0; i < LASTHEADER; i++)
  408. HEADER[i] = NULL;
  410. #ifdef FILTER
  411. indata = processfilter(in->data, &client->filter_buffer, 0);
  412. #endif
  414. if (indata != NULL) {
  415. front = indata;
  416. } else {
  417. front = indata = in->data;
  418. }
  420. for (ptr = (char *) strchr(indata, 'n'); ptr != NULL && *ptr != ''; front = ptr + 1, ptr = (char *) strchr(front, 'n')) {
  421. *ptr = '';
  422. if (front[0] == 'r' || front[1] == 'n') {
  423. BODY = front + 2;
  424. break;
  425. }
  426. hptr = (char *) strchr(front, ':');
  427. if (hptr != NULL && hptr[1] == ' ') {
  428. int     value;
  429. *hptr = '';
  430. value = headervalue(front);
  431. if (value != -1) {
  432. char   *tp;
  433. HEADER[value] = hptr + 2;
  434. if ((tp = (char *) strchr(HEADER[value], 'r')) != NULL)
  435. *tp = '';
  436. }
  437. *hptr = ':';
  438. }
  439. /**ptr = 'n';*/
  440. }
  441. NNTPHOST = HEADER[NNTPHOST_H];
  442. PATH = HEADER[PATH_H];
  443. FROM = HEADER[FROM_H];
  444. GROUPS = HEADER[NEWSGROUPS_H];
  445. SUBJECT = HEADER[SUBJECT_H];
  446. DATE = HEADER[DATE_H];
  447. SITE = HEADER[ORGANIZATION_H];
  448. MSGID = HEADER[MID_H];
  449. CONTROL = HEADER[CONTROL_H];
  450. POSTHOST = HEADER[NNTPPOSTINGHOST_H];
  451. if (POSTHOST == NULL) {
  452. if (HEADER[X_Auth_From_H] != NULL) {
  453. POSTHOST = HEADER[X_Auth_From_H];
  454. HEADER[NNTPPOSTINGHOST_H] = POSTHOST;
  455. }
  456. }
  457. #ifdef PalmBBS
  458. XPATH = PATH;
  459. XHEADER = HEADER;
  460. #endif
  461. }
  463. int 
  464. headervalue(inputheader)
  465. char   *inputheader;
  466. {
  467. header_t key, *findkey;
  468. static int hasinit = 0;
  469. if (hasinit == 0) {
  470. article_init();
  471. hasinit = 1;
  472. }
  473. key.name = inputheader;
  474. findkey = (header_t *) bsearch(
  475. (char *) &key, (char *) headertable,
  476. sizeof(headertable) / sizeof(header_t), sizeof(key),
  477. headercmp);
  478. if (findkey != NULL)
  479. return findkey->id;
  480. return -1;
  481. }
  482. article_init()
  483. {
  484. int     i;
  485. static int article_inited = 0;
  486. if (article_inited)
  487. return;
  488. article_inited = 1;
  490. qsort(headertable, sizeof(headertable) / sizeof(header_t), sizeof(header_t),
  491. headercmp);
  492. for (i = 0; i < LASTHEADER; i++)
  493. HEADER[i] = NULL;
  494. }
  495. #ifdef INNTOBBS_MAIN
  496. main()
  497. {
  498. int     i, j, k, l, m, n, o, p, q;
  499. article_init();
  500. i = headervalue("Subject");
  501. j = headervalue("From");
  502. k = headervalue("Date");
  503. l = headervalue("NNTP-Posting-Host");
  504. m = headervalue("Newsgroups");
  505. n = headervalue("Message-ID");
  506. }
  507. #endif