/* * BBS implementation dependendent part * * The only two interfaces you must provide * * #include "inntobbs.h" int receive_article(); 0 success not 0 fail * * if (storeDB(HEADER[MID_H], hispaths) < 0) { .... fail } * * int cancel_article_front( char *msgid ); 0 success not 0 fail * * char *ptr = (char*)DBfetch(msgid); * * 收到之文章內容 (body)在 char *BODY, 檔頭 (header)在 char *HEADER[] SUBJECT_H, * FROM_H, DATE_H, MID_H, NEWSGROUPS_H, NNTPPOSTINGHOST_H, NNTPHOST_H, * CONTROL_H, PATH_H, ORGANIZATION_H */ /* * Sample Implementation * * receive_article() --> post_article() --> bbspost_write_post(); * cacnel_article_front(mid) --> cancel_article() --> bbspost_write_cancel(); */ #ifndef PowerBBS #include "innbbsconf.h" #include "daemon.h" #include "bbslib.h" #include "inntobbs.h" #include "antisplam.h" extern int Junkhistory; char *post_article ARG((char *, char *, char *, int (*) (), char *, char *)); int cancel_article ARG((char *, char *, char *)); #ifdef MapleBBS #include "config.h" #include "pttstruct.h" #define _BBS_UTIL_C_ #else report() { /* Function called from record.o */ /* Please leave this function empty */ } #endif #if defined(PalmBBS) #ifndef PATH #define PATH XPATH #endif #ifndef HEADER #define HEADER XHEADER #endif #endif /* process post write */ bbspost_write_post(fh, board, filename) int fh; char *board; char *filename; { char *fptr, *ptr; FILE *fhfd = fdopen(fh, "w"); if (fhfd == NULL) { bbslog("can't fdopen, maybe disk full\n"); return -1; } fprintf(fhfd, "發信人: %.60s, 看板: %s\n", FROM, board); fprintf(fhfd, "標 題: %.70s\n", SUBJECT); fprintf(fhfd, "發信站: %.43s (%s)\n", SITE, DATE); fprintf(fhfd, "轉信站: %.70s\n", PATH); #ifndef MapleBBS if (POSTHOST != NULL) { fprintf(fhfd, "Origin: %.70s\n", POSTHOST); } #endif fprintf(fhfd, "\n"); for (fptr = BODY, ptr = strchr(fptr, '\r'); ptr != NULL && *ptr != '\0'; fptr = ptr + 1, ptr = strchr(fptr, '\r')) { int ch = *ptr; *ptr = '\0'; fputs(fptr, fhfd); *ptr = ch; } fputs(fptr, fhfd); fflush(fhfd); fclose(fhfd); return 0; } #ifdef KEEP_NETWORK_CANCEL /* process cancel write */ bbspost_write_cancel(fh, board, filename) int fh; char *board, *filename; { char *fptr, *ptr; FILE *fhfd = fdopen(fh, "w"), *fp; char buffer[256]; if (fhfd == NULL) { bbslog("can't fdopen, maybe disk full\n"); return -1; } fprintf(fhfd, "發信人: %s, 信區: %s\n", FROM, board); fprintf(fhfd, "標 題: %s\n", SUBJECT); fprintf(fhfd, "發信站: %.43s (%s)\n", SITE, DATE); fprintf(fhfd, "轉信站: %.70s\n", PATH); if (HEADER[CONTROL_H] != NULL) { fprintf(fhfd, "Control: %s\n", HEADER[CONTROL_H]); } if (POSTHOST != NULL) { fprintf(fhfd, "Origin: %s\n", POSTHOST); } fprintf(fhfd, "\n"); for (fptr = BODY, ptr = strchr(fptr, '\r'); ptr != NULL && *ptr != '\0'; fptr = ptr + 1, ptr = strchr(fptr, '\r')) { int ch = *ptr; *ptr = '\0'; fputs(fptr, fhfd); *ptr = ch; } fputs(fptr, fhfd); if (POSTHOST != NULL) { fprintf(fhfd, "\n * Origin: ● %.26s ● From: %.40s\n", SITE, POSTHOST); } fprintf(fhfd, "\n---------------------\n"); fp = fopen(filename, "r"); if (fp == NULL) { bbslog("can't open %s\n", filename); return -1; } while (fgets(buffer, sizeof buffer, fp) != NULL) { fputs(buffer, fhfd); } fclose(fp); fflush(fhfd); fclose(fhfd); { fp = fopen(filename, "w"); if (fp == NULL) { bbslog("can't write %s\n", filename); return -1; } fprintf(fp, "發信人: %s, 信區: %s\n", FROM, board); fprintf(fp, "標 題: %.70s\n", SUBJECT); fprintf(fp, "發信站: %.43s (%s)\n", SITE, DATE); fprintf(fp, "轉信站: %.70s\n", PATH); if (POSTHOST != NULL) { fprintf(fhfd, "Origin: %s\n", POSTHOST); } if (HEADER[CONTROL_H] != NULL) { fprintf(fhfd, "Control: %s\n", HEADER[CONTROL_H]); } fprintf(fp, "\n"); for (fptr = BODY, ptr = strchr(fptr, '\r'); ptr != NULL && *ptr != '\0'; fptr = ptr + 1, ptr = strchr(fptr, '\r')) { *ptr = '\0'; fputs(fptr, fp); } fputs(fptr, fp); if (POSTHOST != NULL) { fprintf(fp, "\n * Origin: ● %.26s ● From: %.40s\n", SITE, POSTHOST); } fclose(fp); } return 0; } #endif bbspost_write_control(fh, board, filename) int fh; char *board; char *filename; { char *fptr, *ptr; FILE *fhfd = fdopen(fh, "w"); if (fhfd == NULL) { bbslog("can't fdopen, maybe disk full\n"); return -1; } fprintf(fhfd, "Path: %s!%s\n", MYBBSID, HEADER[PATH_H]); fprintf(fhfd, "From: %s\n", FROM); fprintf(fhfd, "Newsgroups: %s\n", GROUPS); fprintf(fhfd, "Subject: %s\n", SUBJECT); fprintf(fhfd, "Date: %s\n", DATE); fprintf(fhfd, "Organization: %s\n", SITE); if (POSTHOST != NULL) { fprintf(fhfd, "NNTP-Posting-Host: %.70s\n", POSTHOST); } if (HEADER[CONTROL_H] != NULL) { fprintf(fhfd, "Control: %s\n", HEADER[CONTROL_H]); } if (HEADER[APPROVED_H] != NULL) { fprintf(fhfd, "Approved: %s\n", HEADER[APPROVED_H]); } if (HEADER[DISTRIBUTION_H] != NULL) { fprintf(fhfd, "Distribution: %s\n", HEADER[DISTRIBUTION_H]); } fprintf(fhfd, "\n"); for (fptr = BODY, ptr = strchr(fptr, '\r'); ptr != NULL && *ptr != '\0'; fptr = ptr + 1, ptr = strchr(fptr, '\r')) { int ch = *ptr; *ptr = '\0'; fputs(fptr, fhfd); *ptr = ch; } fputs(fptr, fhfd); fflush(fhfd); fclose(fhfd); return 0; } time_t datevalue; /* process cancel write */ receive_article() { int i; char *user, *userptr; char *ngptr, *nngptr, *pathptr; char **splitptr; static char userid[32]; static char xdate[32]; static char xpath[180]; newsfeeds_t *nf; char *boardhome; char hispaths[4096]; char firstpath[MAXPATHLEN], *firstpathbase; char *lesssym, *nameptrleft, *nameptrright; static char sitebuf[80]; #ifdef HMM_USE_ANTI_SPAM char *notitle[] = {"行銷", "業務代表", "徵", "資訊", "免費", "大贈送", "傳銷", "未滿", "年費", "傳呼", "價", "操你媽", "未成年", "馬賽克", "信用", "賺錢", "=?", "!!!", "操你", "操你", "幹妳", "操妳", "**", "★★", "＊＊", "＄＄", "泡麵", NULL}, *nofrom[] = {"TaipeiNet.Net", "hotmail.com", "mt.touc.edu.tw", "ms11.hinet.net", NULL}, *nocont[] = {"名額有限", "優惠價", "動作要快", "訂購", "特價", "專賣", "BBC", "幹你", "操你", "幹妳", "操妳", "每片", "最新目錄", "http://", "收錢", "創業", "付款", "廣告信", "只賣", "市價", "NCg", "ICAg", NULL}; #endif if (FROM == NULL) { bbslog(":Err: article without usrid %s\n", MSGID); return 0; } else { #ifdef HMM_USE_ANTI_SPAM for (i = 0; nofrom[i]; i++) if (strstr(FROM, nofrom[i])) { morelog_to(INNBBSD_SPAM, "spam from [%s]: %s\n", nofrom[i], FROM); morelog_to(INNBBSD_SPAM, " %s %s %s %s\n", FROM, PATH, GROUPS, SUBJECT); bbslog(":Ptt: spam from [%s]: %s\n", nofrom[i], FROM); return 0; } #endif } if (!BODY) { bbslog(":Err: article without body %s\n", MSGID); return 0; } else { #ifdef HMM_USE_ANTI_SPAM for (i = 0; nocont[i]; i++) if (strstr(BODY, nocont[i])) { morelog_to(INNBBSD_SPAM, "spam body [%s]: %s\n", nocont[i]); morelog_to(INNBBSD_SPAM, " %s %s %s %s\n", FROM, PATH, GROUPS, SUBJECT); bbslog(":Ptt: spam body [%s]: %s\n", nocont[i]); return 0; } #endif } if (!SUBJECT) { bbslog(":Err: article without subject %s\n", MSGID); return 0; } else { #ifdef HMM_USE_ANTI_SPAM for (i = 0; notitle[i]; i++) if (strstr(SUBJECT, notitle[i])) { morelog_to(INNBBSD_SPAM, "spam title [%s]: %s\n", notitle[i], SUBJECT); morelog_to(INNBBSD_SPAM, " %s %s %s %s\n", FROM, PATH, GROUPS, SUBJECT); bbslog(":Ptt: spam title [%s]: %s\n", notitle[i], SUBJECT); return 0; } #endif } user = (char *)strchr(FROM, '@'); lesssym = (char *)strchr(FROM, '<'); nameptrleft = NULL, nameptrright = NULL; if (lesssym == NULL || lesssym >= user) { lesssym = FROM; nameptrleft = strchr(FROM, '('); if (nameptrleft != NULL) nameptrleft++; nameptrright = strrchr(FROM, ')'); } else { nameptrleft = FROM; nameptrright = strrchr(FROM, '<'); lesssym++; } if (user != NULL) { *user = '\0'; userptr = (char *)strchr(FROM, '.'); if (userptr != NULL) { *userptr = '\0'; strncpy(userid, lesssym, sizeof userid); *userptr = '.'; } else { strncpy(userid, lesssym, sizeof userid); } *user = '@'; } else { strncpy(userid, lesssym, sizeof userid); } strcat(userid, "."); { struct tm tmbuf; strptime(DATE, "%d %b %Y %X GMT", &tmbuf); datevalue = timegm(&tmbuf); } if (datevalue > 0) { char *p; strncpy(xdate, ctime(&datevalue), sizeof(xdate)); p = (char *)strchr(xdate, '\n'); if (p != NULL) *p = '\0'; DATE = xdate; } #ifndef MapleBBS if (SITE == NULL || *SITE == '\0') { if (nameptrleft != NULL && nameptrright != NULL) { char savech = *nameptrright; *nameptrright = '\0'; strncpy(sitebuf, nameptrleft, sizeof sitebuf); *nameptrright = savech; SITE = sitebuf; } else /* SITE = "(Unknown)"; */ SITE = ""; } if (strlen(MYBBSID) > 70) { bbslog(" :Err: your bbsid %s too long\n", MYBBSID); return 0; } #endif sprintf(xpath, "%s!%.*s", MYBBSID, sizeof(xpath) - strlen(MYBBSID) - 2, PATH); PATH = xpath; for (pathptr = PATH; pathptr != NULL && (pathptr = strstr(pathptr, ".edu.tw")) != NULL;) { if (pathptr != NULL) { strcpy(pathptr, pathptr + 7); } } xpath[71] = '\0'; #ifndef MapleBBS echomaillog(); #endif *hispaths = '\0'; splitptr = (char **)BNGsplit(GROUPS); firstpath[0] = '\0'; firstpathbase = firstpath; for (ngptr = *splitptr; ngptr != NULL; ngptr = *(++splitptr)) { char *boardptr, *nboardptr; if (*ngptr == '\0') continue; nf = (newsfeeds_t *) search_group(ngptr); if (nf == NULL) { bbslog("unwanted \'%s\'\n", ngptr); continue; } if (nf->board == NULL || !*nf->board) continue; if (nf->path == NULL || !*nf->path) continue; for (boardptr = nf->board, nboardptr = (char *)strchr(boardptr, ','); boardptr != NULL && *boardptr != '\0'; nboardptr = (char *)strchr(boardptr, ',')) { if (nboardptr != NULL) { *nboardptr = '\0'; } if (*boardptr == '\t') { goto boardcont; } boardhome = (char *)fileglue("%s/boards/%c/%s", BBSHOME, boardptr[0], boardptr); if (!isdir(boardhome)) { bbslog(":Err: unable to write %s\n", boardhome); } else { char *fname; /* * if ( !isdir( boardhome )) { bbslog( ":Err: unable to write * %s\n",boardhome); testandmkdir(boardhome); } */ fname = (char *)post_article(boardhome, userid, boardptr, bbspost_write_post, NULL, firstpath); if (fname != NULL) { fname = (char *)fileglue("%s/%s", boardptr, fname); if (firstpath[0] == '\0') { sprintf(firstpath, "%s/boards/%c, %s", BBSHOME, fname[0], fname); firstpathbase = firstpath + strlen(BBSHOME) + strlen("/boards/x/"); } if (strlen(fname) + strlen(hispaths) + 1 < sizeof(hispaths)) { strcat(hispaths, fname); strcat(hispaths, " "); } } else { bbslog("fname is null %s\n", boardhome); return -1; } } boardcont: if (nboardptr != NULL) { *nboardptr = ','; boardptr = nboardptr + 1; } else break; } /* for board1,board2,... */ /* * if (nngptr != NULL) ngptr = nngptr + 1; else break; */ if (*firstpathbase) feedfplog(nf, firstpathbase, 'P'); } if (*hispaths) bbsfeedslog(hispaths, 'P'); if (Junkhistory || *hispaths) { if (storeDB(HEADER[MID_H], hispaths) < 0) { bbslog("store DB fail\n"); /* I suspect here will introduce duplicated articles */ /* return -1; */ } } return 0; } receive_control() { char *boardhome, *fname; char firstpath[MAXPATHLEN], *firstpathbase; char **splitptr, *ngptr; newsfeeds_t *nf; bbslog("control post %s\n", HEADER[CONTROL_H]); boardhome = (char *)fileglue("%s/boards/c/control", BBSHOME); testandmkdir(boardhome); *firstpath = '\0'; if (isdir(boardhome)) { fname = (char *)post_article(boardhome, FROM, "control", bbspost_write_control, NULL, firstpath); if (fname != NULL) { if (firstpath[0] == '\0') sprintf(firstpath, "%s/boards/c/control/%s", BBSHOME, fname); if (storeDB(HEADER[MID_H], (char *)fileglue("control/%s", fname)) < 0) { } bbsfeedslog(fileglue("control/%s", fname), 'C'); firstpathbase = firstpath + strlen(BBSHOME) + strlen("/boards/x/"); splitptr = (char **)BNGsplit(GROUPS); for (ngptr = *splitptr; ngptr != NULL; ngptr = *(++splitptr)) { if (*ngptr == '\0') continue; nf = (newsfeeds_t *) search_group(ngptr); if (nf == NULL) continue; if (nf->board == NULL) continue; if (nf->path == NULL) continue; feedfplog(nf, firstpathbase, 'C'); } } } return 0; } cancel_article_front(msgid) char *msgid; { char *ptr = (char *)DBfetch(msgid); char *filelist, filename[2048]; char histent[4096]; char firstpath[MAXPATHLEN], *firstpathbase; if (ptr == NULL) { bbslog("cancel failed(DBfetch): %s\n", msgid); return 0; } strncpy(histent, ptr, sizeof histent); ptr = histent; #ifdef DEBUG printf("**** try to cancel %s *****\n", ptr); #endif filelist = strchr(ptr, '\t'); if (filelist != NULL) { filelist++; } *firstpath = '\0'; for (ptr = filelist; ptr && *ptr;) { char *file; for (; *ptr && isspace(*ptr); ptr++); if (*ptr == '\0') break; file = ptr; for (ptr++; *ptr && !isspace(*ptr); ptr++); if (*ptr != '\0') { *ptr++ = '\0'; } sprintf(filename, "%s/boards/%c/%s", BBSHOME, file[0], file); bbslog("cancel post %s\n", filename); if (isfile(filename)) { FILE *fp = fopen(filename, "r"); char buffer[1024]; char xfrom0[100], xfrom[100], xpath[1024], *boardhome; if (fp == NULL) continue; strncpy(xfrom0, HEADER[FROM_H], 99); xfrom0[99] = 0; strtok(xfrom0, ", "); while (fgets(buffer, sizeof buffer, fp) != NULL) { char *hptr; if (buffer[0] == '\n') break; hptr = strchr(buffer, '\n'); if (hptr != NULL) *hptr = '\0'; if (strncmp(buffer, "發信人: ", 8) == 0) { strncpy(xfrom, buffer + 8, 99); xfrom[99] = 0; strtok(xfrom, ", "); } else if (strncmp(buffer, "轉信站: ", 8) == 0) { strcpy(xpath, buffer + 8); } } fclose(fp); if (strcmp(xfrom0, xfrom)) { bbslog("Invalid cancel %s, path: %s!%s, [`%s` != `%s`]\n", FROM, MYBBSID, PATH, xfrom0, xfrom); return 0; } #ifdef KEEP_NETWORK_CANCEL bbslog("cancel post %s\n", filename); boardhome = (char *)fileglue("%s/boards/d/deleted", BBSHOME); testandmkdir(boardhome); if (isdir(boardhome)) { char subject[1024]; char *fname; if (POSTHOST) { sprintf(subject, "cancel by: %.1000s", POSTHOST); } else { char *body, *body2; body = strchr(BODY, '\r'); if (body != NULL) *body = '\0'; body2 = strchr(BODY, '\n'); if (body2 != NULL) *body = '\0'; sprintf(subject, "%.1000s", BODY); if (body != NULL) *body = '\r'; if (body2 != NULL) *body = '\n'; } if (*subject) { SUBJECT = subject; } fname = (char *)post_article(boardhome, FROM, "deleted", bbspost_write_cancel, filename, firstpath); if (fname != NULL) { if (firstpath[0] == '\0') { sprintf(firstpath, "%s/boards/d/deleted/%s", BBSHOME, fname); firstpathbase = firstpath + strlen(BBSHOME) + strlen("/boards/x/"); } if (storeDB(HEADER[MID_H], (char *)fileglue("deleted/%s", fname)) < 0) { /* should do something */ bbslog("store DB fail\n"); /* return -1; */ } bbsfeedslog(fileglue("deleted/%s", fname), 'D'); #ifdef OLDDISPATCH { char board[256]; newsfeeds_t *nf; char *filebase = filename + strlen(BBSHOME) + strlen("/boards/x/"); char *filetail = strrchr(filename, '/'); if (filetail != NULL) { strncpy(board, filebase, filetail - filebase); nf = (newsfeeds_t *) search_board(board); if (nf != NULL && nf->board && nf->path) { feedfplog(nf, firstpathbase, 'D'); } } } #endif } else { bbslog(" fname is null %s %s\n", boardhome, filename); return -1; } } #else /* bbslog("**** %s should be removed\n", filename); */ /* * unlink(filename); */ #endif { char *fp = strrchr(file, '/'); if (fp != NULL) { *fp = '\0'; cancel_article(BBSHOME, file, fp + 1); *fp = '/'; } } } } if (*firstpath) { char **splitptr, *ngptr; newsfeeds_t *nf; splitptr = (char **)BNGsplit(GROUPS); for (ngptr = *splitptr; ngptr != NULL; ngptr = *(++splitptr)) { if (*ngptr == '\0') continue; nf = (newsfeeds_t *) search_group(ngptr); if (nf == NULL) continue; if (nf->board == NULL) continue; if (nf->path == NULL) continue; feedfplog(nf, firstpathbase, 'D'); } } return 0; } #if defined(PhoenixBBS) || defined(SecretBBS) || defined(PivotBBS) || defined(MapleBBS) /* for PhoenixBBS's post article and cancel article */ #include "config.h" char * post_article(homepath, userid, board, writebody, pathname, firstpath) char *homepath; char *userid, *board; int (*writebody) (); char *pathname, *firstpath; { struct userec_t record; struct fileheader_t header; char *subject = SUBJECT; char index[MAXPATHLEN]; static char name[MAXPATHLEN]; char article[MAXPATHLEN]; char buf[MAXPATHLEN], *ptr; FILE *fidx; int fh, bid; time_t now; int linkflag; /* * Ptt if(bad_subject(subject)) return NULL; */ sprintf(index, "%s/.DIR", homepath); if ((fidx = fopen(index, "r")) == NULL) { if ((fidx = fopen(index, "w")) == NULL) { bbslog(":Err: Unable to post in %s.\n", homepath); return NULL; } } fclose(fidx); now = time(NULL); while (1) { sprintf(name, "M.%d.A", ++now); sprintf(article, "%s/%s", homepath, name); fh = open(article, O_CREAT | O_EXCL | O_WRONLY, 0644); if (fh >= 0) break; if (errno != EEXIST) { bbslog(" Err: can't writable or other errors\n"); return NULL; } } #ifdef DEBUG printf("post to %s\n", article); #endif linkflag = 1; if (firstpath && *firstpath) { close(fh); unlink(article); #ifdef DEBUGLINK bbslog("try to link %s to %s", firstpath, article); #endif linkflag = link(firstpath, article); if (linkflag) { fh = open(article, O_CREAT | O_EXCL | O_WRONLY, 0644); } } if (linkflag) { if (writebody) { if ((*writebody) (fh, board, pathname) < 0) return NULL; } else { if (bbspost_write_post(fh, board, pathname) < 0) return NULL; } close(fh); } bzero((void *)&header, sizeof(header)); #ifndef MapleBBS strcpy(header.filename, name); strncpy(header.owner, userid, IDLEN); strncpy(header.title, subject, STRLEN); header.filename[STRLEN - 1] = 'M'; #else strcpy(header.filename, name); if (userid[IDLEN]) strcpy(&userid[IDLEN], "."); strcpy(header.owner, userid); strncpy(header.title, subject, TTLEN); header.filemode |= FILE_MULTI; { struct tm *ptime; ptime = localtime(&datevalue); sprintf(header.date, "%2d/%02d", ptime->tm_mon + 1, ptime->tm_mday); } #endif append_record(index, &header, sizeof(header)); if ((bid = getbnum(board)) > 0) { touchbtotal(bid); } return name; } /* * woju Cross-fs rename() */ Rename(char *src, char *dst) { char cmd[200]; bbslog("Rename: %s -> %s\n", src, dst); if (rename(src, dst) == 0) return 0; sprintf(cmd, "/bin/mv %s %s", src, dst); return system(cmd); } cancelpost(fileheader_t * fhdr, char *boardname) { int fd; char fpath[MAXPATHLEN]; sprintf(fpath, BBSHOME "/boards/%c/%s/%s", boardname[0], boardname, fhdr->filename); if ((fd = open(fpath, O_RDONLY)) >= 0) { fileheader_t postfile; char fn2[MAXPATHLEN] = BBSHOME "/boards/d/deleted", *junkdir; stampfile(fn2, &postfile); memcpy(postfile.owner, fhdr->owner, IDLEN + TTLEN + 10); close(fd); Rename(fpath, fn2); strcpy(strrchr(fn2, '/') + 1, ".DIR"); append_record(fn2, &postfile, sizeof(postfile)); } else bbslog("cancelpost: %s opened error\n", fpath); } /* ---------------------------- */ /* new/old/lock file processing */ /* ---------------------------- */ typedef struct { char newfn[MAXPATHLEN]; char oldfn[MAXPATHLEN]; char lockfn[MAXPATHLEN]; } nol; static void nolfilename(n, fpath) nol *n; char *fpath; { sprintf(n->newfn, "%s.new", fpath); sprintf(n->oldfn, "%s.old", fpath); sprintf(n->lockfn, "%s.lock", fpath); } static int delete_record(char *fpath, int size, int id) { nol my; char abuf[512]; int fdr, fdw, fd; int count; fileheader_t fhdr; nolfilename(&my, fpath); if ((fd = open(my.lockfn, O_RDWR | O_CREAT | O_APPEND, 0644)) == -1) return -1; flock(fd, LOCK_EX); if ((fdr = open(fpath, O_RDONLY, 0)) == -1) { #ifdef HAVE_REPORT report("delete_record failed!!! (open)"); #endif flock(fd, LOCK_UN); close(fd); return -1; } if ((fdw = open(my.newfn, O_WRONLY | O_CREAT | O_EXCL, 0644)) == -1) { flock(fd, LOCK_UN); #ifdef HAVE_REPORT report("delete_record failed!!! (open tmpfile)"); #endif close(fd); close(fdr); return -1; } count = 1; while (read(fdr, abuf, size) == size) { if (id == count) { memcpy(&fhdr, abuf, sizeof(fhdr)); bbslog("delete_record: %d, %s, %s\n", count, fhdr.owner, fhdr.title); } if (id != count++ && (write(fdw, abuf, size) == -1)) { bbslog("delete_record: %s failed!!! (write)\n", fpath); #ifdef HAVE_REPORT report("delete_record failed!!! (write)"); #endif unlink(my.newfn); close(fdr); close(fdw); flock(fd, LOCK_UN); close(fd); return -1; } } close(fdr); close(fdw); if (Rename(fpath, my.oldfn) == -1 || Rename(my.newfn, fpath) == -1) { #ifdef HAVE_REPORT report("delete_record failed!!! (Rename)"); #endif flock(fd, LOCK_UN); close(fd); return -1; } flock(fd, LOCK_UN); close(fd); return 0; } cancel_article(homepath, board, file) char *homepath; char *board, *file; { struct fileheader_t header; struct stat state; char dirname[MAXPATHLEN]; char buf[MAXPATHLEN]; long numents, size, time, now; int fd, lower, ent; if (file == NULL || file[0] != 'M' || file[1] != '.' || (time = atoi(file + 2)) <= 0) { bbslog("cancel_article: invalid filename `%s`\n", file); return 0; } size = sizeof(header); sprintf(dirname, "%s/boards/%c/%s/.DIR", homepath, board[0], board); if ((fd = open(dirname, O_RDONLY)) == -1) { bbslog("cancel_article: open `%s` error\n", dirname); return 0; } fstat(fd, &state); ent = ((long)state.st_size) / size; lower = 0; while (1) { ent -= 8; if (ent <= 0 || lower >= 2) break; lseek(fd, size * ent, SEEK_SET); if (read(fd, &header, size) != size) { ent = 0; break; } now = atoi(header.filename + 2); lower = (now < time) ? lower + 1 : 0; } if (ent < 0) ent = 0; while (read(fd, &header, size) == size) { if (strcmp(file, header.filename) == 0) { if ((header.filemode & FILE_MARKED) || (header.filemode & FILE_DIGEST) || (header.owner[0] == '-')) break; delete_record(dirname, sizeof(fileheader_t), lseek(fd, 0, SEEK_CUR) / size); cancelpost(&header, board); break; } now = atoi(header.filename + 2); if (now > time) break; } close(fd); return 0; } #elif defined(PalmBBS) #undef PATH XPATH #undef HEADER XHEADER #include "server.h" char * post_article(homepath, userid, board, writebody, pathname, firstpath) char *homepath; char *userid, *board; int (*writebody) (); char *pathname, *firstpath; { PATH msgdir, msgfile; static PATH name; READINFO readinfo; SHORT fileid; char buf[MAXPATHLEN]; struct stat stbuf; int fh; strcpy(msgdir, homepath); if (stat(msgdir, &stbuf) == -1 || !S_ISDIR(stbuf.st_mode)) { /* A directory is missing! */ bbslog(":Err: Unable to post in %s.\n", msgdir); return NULL; } get_filelist_ids(msgdir, &readinfo); for (fileid = 1; fileid <= BBS_MAX_FILES; fileid++) { int oumask; if (test_readbit(&readinfo, fileid)) continue; fileid_to_fname(msgdir, fileid, msgfile); sprintf(name, "%04x", fileid); #ifdef DEBUG printf("post to %s\n", msgfile); #endif if (firstpath && *firstpath) { #ifdef DEBUGLINK bbslog("try to link %s to %s", firstpath, msgfile); #endif if (link(firstpath, msgfile) == 0) break; } oumask = umask(0); fh = open(msgfile, O_CREAT | O_EXCL | O_WRONLY, 0664); umask(oumask); if (writebody) { if ((*writebody) (fh, board, pathname) < 0) return NULL; } else { if (bbspost_write_post(fh, board, pathname) < 0) return NULL; } close(fh); break; } #ifdef CACHED_OPENBOARD { char *bname; bname = strrchr(msgdir, '/'); if (bname) notify_new_post(++bname, 1, fileid, stbuf.st_mtime); } #endif return name; } cancel_article(homepath, board, file) char *homepath; char *board, *file; { PATH fname; #ifdef CACHED_OPENBOARD PATH bdir; struct stat stbuf; sprintf(bdir, "%s/boards/%c/%s", homepath, board[0], board); stat(bdir, &stbuf); #endif sprintf(fname, "%s/boards/%c/%s/%s", homepath, board[0], board, file); unlink(fname); /* kill it now! the function is far small then original.. :) */ /* because it won't make system load heavy like before */ #ifdef CACHED_OPENBOARD notify_new_post(board, -1, hex2SHORT(file), stbuf.st_mtime); #endif } #else error("You should choose one of the systems: PhoenixBBS, PowerBBS, or PalmBBS") #endif #else receive_article() { } cancel_article_front(msgid) char *msgid; { } #endif