![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to nntp.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDTahoe / new / news / src|
Return to nntp.c CVS log | Up to [CSRG BSD Unix] / 43BSDTahoe / new / news / src |
1.1 ! root 1: /* ! 2: * This software is Copyright 1987 by Stan Barber. ! 3: * ! 4: * Permission is hereby granted to copy, reproduce, redistribute or otherwise ! 5: * use this software as long as: there is no monetary profit gained ! 6: * specifically from the use or reproduction or this software, it is not ! 7: * sold, rented, traded or otherwise marketed, and this copyright notice is ! 8: * included prominently in any copy made. ! 9: * ! 10: * The author make no claims as to the fitness or correctness of this software ! 11: * for any use whatsoever, and it is provided as is. Any use of this software ! 12: * is at the user's own risk. ! 13: * ! 14: * this is a file full of functions used by the various news client programs ! 15: */ ! 16: #ifdef SCCSID ! 17: static char *SccsId = "@(#)nntp.c 2.2 10/15/87"; ! 18: #endif /* SCCSID */ ! 19: ! 20: #include "params.h" ! 21: ! 22: static char *nntpserver; ! 23: static char ser_line[256]; ! 24: static char active_file_name[512]; ! 25: static char article_file_name[512]; ! 26: static char last_group[256]; ! 27: /* ! 28: * open_server open a connection to the server ! 29: */ ! 30: open_server() ! 31: { ! 32: int response; ! 33: ! 34: /* open connection to nntpserver if appropriate */ ! 35: ! 36: nntpserver = getserverbyfile(SERVER_FILE); ! 37: if (nntpserver == NULL) { ! 38: fprintf(stderr, "Can't get the name of the news server from %s\n", ! 39: SERVER_FILE); ! 40: fprintf(stderr, "Either fix this file, or put NNTPSERVER in your environment."); ! 41: return -1; ! 42: } ! 43: response = server_init(nntpserver); ! 44: if (response < 0) { ! 45: fprintf(stderr, "Couldn't connect to %s news server, try again later.\n", ! 46: nntpserver); ! 47: return -1; ! 48: } ! 49: if (handle_server_response(response, nntpserver) < 0) { ! 50: fprintf(stderr, "Cannot handle response from nntpserver.\n"); ! 51: return -1; ! 52: } ! 53: return 0; ! 54: } ! 55: ! 56: /* ! 57: * open_active gets the active file and returns an open file descriptor to ! 58: * the calling program ! 59: */ ! 60: ! 61: FILE * ! 62: open_active() ! 63: { ! 64: FILE *openfp; ! 65: bzero(active_file_name, sizeof(active_file_name)); ! 66: put_server("LIST"); /* tell server we want the active file */ ! 67: (void) get_server(ser_line, sizeof(ser_line)); ! 68: if (*ser_line != CHAR_OK) { /* and then see if that's ok */ ! 69: xerror("Can't get active file from server: \n%s\n", ser_line); ! 70: } ! 71: strcpy(active_file_name, "/tmp/nsact.XXXXXX"); ! 72: (void) mktemp(active_file_name); /* make a temporary name */ ! 73: openfp = fopen(active_file_name, "w+"); /* and get ready */ ! 74: if (openfp == NULL) ! 75: return NULL; ! 76: ! 77: while (get_server(ser_line, sizeof(ser_line)) >= 0) { /* while */ ! 78: if (ser_line[0] == '.' && strlen(ser_line) == 1) ! 79: /* there's another line */ ! 80: break; /* get it and write it to */ ! 81: fputs(ser_line, openfp); ! 82: putc('\n', openfp); ! 83: } ! 84: ! 85: fseek(openfp, 0L, 0); /* just get to the beginning */ ! 86: ! 87: return openfp; ! 88: } ! 89: ! 90: /* ! 91: * active_name() returns the name of the temporary file that contains the ! 92: * name of the current active file. ! 93: */ ! 94: ! 95: char * ! 96: active_name() ! 97: { ! 98: if (active_file_name[0] == '\0') ! 99: return NULL; ! 100: return &active_file_name[0]; ! 101: } ! 102: ! 103: /* ! 104: * set_group() set the current group returns NULL if failure "string" if ! 105: * successful ! 106: */ ! 107: ! 108: char * ! 109: set_group(newsgroup) ! 110: char *newsgroup; ! 111: { ! 112: char nntpbfr[256]; ! 113: if (newsgroup == NULL || *newsgroup == '\0') ! 114: return NULL; ! 115: if (strcmp(newsgroup, last_group)) { ! 116: (void) sprintf(nntpbfr, "GROUP %s", newsgroup); ! 117: put_server(nntpbfr); ! 118: (void) get_server(ser_line, sizeof(ser_line)); ! 119: if (*ser_line != CHAR_OK) ! 120: return NULL; ! 121: strcpy(last_group, newsgroup); ! 122: } ! 123: return &ser_line[0]; ! 124: } ! 125: ! 126: /* ! 127: * getarticle() returns an open file descriptor to the requested article. ! 128: */ ! 129: ! 130: FILE * ! 131: getarticle(newsgroup, number, command) ! 132: char *newsgroup, *command; ! 133: int number; ! 134: { ! 135: FILE *fp; ! 136: char nntpbfr[256]; ! 137: bzero(article_file_name, sizeof(article_file_name)); ! 138: if (set_group(newsgroup) == NULL) ! 139: return NULL; ! 140: strcpy(article_file_name, "/tmp/nsart.XXXXXX"); ! 141: if (mktemp(article_file_name) == NULL) ! 142: return NULL; ! 143: (void) sprintf(nntpbfr, "%s %ld", command, number); ! 144: put_server(nntpbfr); ! 145: (void) get_server(ser_line, sizeof(ser_line)); ! 146: if (*ser_line != CHAR_OK) ! 147: return NULL; ! 148: if ((fp = fopen(article_file_name, "w+")) == NULL) { ! 149: /* and get ready */ ! 150: sync_server(); ! 151: return NULL; ! 152: } ! 153: while (get_server(ser_line, sizeof(ser_line)) >= 0) { /* while */ ! 154: if (ser_line[0] == '.' && strlen(ser_line) == 1) ! 155: /* there's another line */ ! 156: break; /* get it and write it to */ ! 157: fputs(ser_line, fp); /* the temp file */ ! 158: putc('\n', fp); ! 159: } ! 160: fseek(fp, 0L, 0); /* just get to the beginning */ ! 161: return fp; ! 162: } ! 163: /* ! 164: * article_name() returns the name of the temporary file that contains the ! 165: * name of the current article file. ! 166: */ ! 167: ! 168: char * ! 169: article_name() ! 170: { ! 171: if (article_file_name[0] == '\0') ! 172: return NULL; ! 173: return &article_file_name[0]; ! 174: } ! 175: ! 176: /* ! 177: * group_name() returns the name of the last group accessed from nntp ! 178: */ ! 179: ! 180: char * ! 181: group_name() ! 182: { ! 183: if (last_group[0] == '\0') ! 184: return NULL; ! 185: return &last_group[0]; ! 186: } ! 187: ! 188: /* ! 189: * getartbyid retrieves an article by id number and returns an open file ! 190: * descriptor for that article ! 191: */ ! 192: ! 193: FILE * ! 194: getartbyid(id) ! 195: char *id; ! 196: { ! 197: FILE *fp; ! 198: char nntpbfr[256]; ! 199: (void) sprintf(nntpbfr, "ARTICLE %s", id); ! 200: put_server(nntpbfr); ! 201: (void) get_server(ser_line, sizeof(ser_line)); ! 202: if (*ser_line != CHAR_OK) { ! 203: fprintf(stderr, "Cannot fetch article %s\n", id); ! 204: return NULL; ! 205: } ! 206: strcpy(article_file_name, "/tmp/nsart.XXXXXX"); ! 207: if (mktemp(article_file_name) == NULL) ! 208: return NULL; ! 209: if ((fp = fopen(article_file_name, "w+")) == NULL) { ! 210: /* and get ready */ ! 211: sync_server(); ! 212: return NULL; ! 213: } ! 214: while (get_server(ser_line, sizeof(ser_line)) >= 0) { /* while */ ! 215: if (ser_line[0] == '.' && strlen(ser_line) == 1) ! 216: /* there's another line */ ! 217: break; /* get it and write it to */ ! 218: fputs(ser_line, fp); /* the temp file */ ! 219: putc('\n', fp); ! 220: } ! 221: fseek(fp, 0L, 0); /* just get to the beginning */ ! 222: return fp; ! 223: } ! 224: ! 225: /* ! 226: * sync_server gobbles up the rest of the server output until it sees the . ! 227: * on the beginning of a line by itself ! 228: */ ! 229: ! 230: void ! 231: sync_server() ! 232: { ! 233: while (get_server(ser_line, sizeof(ser_line)) >= 0) { /* while */ ! 234: if (ser_line[0] == '.' && strlen(ser_line) == 1) ! 235: /* there's another line */ ! 236: break; /* get it and throw it away */ ! 237: } ! 238: ! 239: } ! 240: ! 241: /* ! 242: * strindex returns location of tx in sx ! 243: */ ! 244: int ! 245: strindex(sx, tx) ! 246: char *sx, *tx; ! 247: { ! 248: int i, n; ! 249: n = strlen(tx); ! 250: for (i = 0; sx[i] != '\0'; i++) ! 251: if (strncmp(sx + i, tx, n) == 0) ! 252: return i; ! 253: return -1; ! 254: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.