/* $Id$ */ #include "bbs.h" static fileheader_t *headers = NULL; static int last_line; // PTT: last_line 游標可指的最後一個 #include /* ----------------------------------------------------- */ /* Tag List 標籤 */ /* ----------------------------------------------------- */ void UnTagger(int locus) { if (locus > TagNum) return; TagNum--; if (TagNum > locus) memcpy(&TagList[locus], &TagList[locus + 1], (TagNum - locus) * sizeof(TagItem)); } int Tagger(time_t chrono, int recno, int mode) { int head, tail, posi = 0, comp; for (head = 0, tail = TagNum - 1, comp = 1; head <= tail;) { posi = (head + tail) >> 1; comp = TagList[posi].chrono - chrono; if (!comp) { break; } else if (comp < 0) { head = posi + 1; } else { tail = posi - 1; } } if (mode == TAG_NIN) { if (!comp && recno) /* 絕對嚴謹:連 recno 一起比對 */ comp = recno - TagList[posi].recno; return comp; } if (!comp) { if (mode != TAG_TOGGLE) return NA; TagNum--; memcpy(&TagList[posi], &TagList[posi + 1], (TagNum - posi) * sizeof(TagItem)); } else if (TagNum < MAXTAGS) { TagItem *tagp, buf[MAXTAGS]; tail = (TagNum - head) * sizeof(TagItem); tagp = &TagList[head]; memcpy(buf, tagp, tail); tagp->chrono = chrono; tagp->recno = recno; memcpy(++tagp, buf, tail); TagNum++; } else { bell(); return 0; /* full */ } return YEA; } void EnumTagName(char *fname, int locus) { snprintf(fname, sizeof(fname), "M.%d.A", (int)TagList[locus].chrono); } void EnumTagFhdr(fileheader_t * fhdr, char *direct, int locus) { get_record(direct, fhdr, sizeof(fileheader_t), TagList[locus].recno); } /* -1 : 取消 */ /* 0 : single article */ /* ow: whole tag list */ int AskTag(char *msg) { char buf[80]; int num; num = TagNum; snprintf(buf, sizeof(buf), "◆ %s A)文章 T)標記 Q)uit?", msg); switch (getans(buf)) { case 'q': num = -1; break; case 'a': num = 0; } return num; } #include #define BATCH_SIZE 65536 char * f_map(char *fpath, int *fsize) { int fd, size; struct stat st; if ((fd = open(fpath, O_RDONLY)) < 0) return (char *)-1; if (fstat(fd, &st) || !S_ISREG(st.st_mode) || (size = st.st_size) <= 0) { close(fd); return (char *)-1; } fpath = (char *)mmap(NULL, size, PROT_READ, MAP_SHARED, fd, 0); close(fd); *fsize = size; return fpath; } static int TagThread(char *direct) { int fsize, count; char *title, *fimage; fileheader_t *head, *tail; fimage = f_map(direct, &fsize); if (fimage == (char *)-1) return DONOTHING; head = (fileheader_t *) fimage; tail = (fileheader_t *) (fimage + fsize); count = 0; do { count++; title = subject(head->title); if (!strncmp(currtitle, title, TTLEN)) { if (!Tagger(atoi(head->filename + 2), count, TAG_INSERT)) break; } } while (++head < tail); munmap(fimage, fsize); return FULLUPDATE; } int TagPruner(int bid) { boardheader_t *bp=NULL; assert(bid >= 0); /* bid == 0 means in mailbox */ if (bid){ bp = getbcache(bid); if (strcmp(bp->brdname, "Security") == 0) return DONOTHING; } if (TagNum && ((currstat != READING) || (currmode & MODE_BOARD))) { if (getans("刪除所有標記[N]?") != 'y') return READ_REDRAW; #ifdef SAFE_ARTICLE_DELETE if(bp && !(currmode & MODE_DIGEST) && bp->nuser>20 ) safe_delete_range(currdirect, 0, 0); else #endif delete_range(currdirect, 0, 0); TagNum = 0; if (bid) setbtotal(bid); return NEWDIRECT; } return DONOTHING; } /* ----------------------------------------------------- */ /* cursor & reading record position control */ /* ----------------------------------------------------- */ keeploc_t * getkeep(char *s, int def_topline, int def_cursline) { static struct keeploc_t *keeplist = NULL; struct keeploc_t *p; if (def_cursline >= 0) for (p = keeplist; p; p = p->next) { if (!strcmp(s, p->key)) { if (p->crs_ln < 1) p->crs_ln = 1; return p; } } else def_cursline = -def_cursline; p = (keeploc_t *) malloc(sizeof(keeploc_t)); assert(p); p->key = (char *)malloc(strlen(s) + 1); assert(p->key); strcpy(p->key, s); p->top_ln = def_topline; p->crs_ln = def_cursline; p->next = keeplist; return (keeplist = p); } void fixkeep(char *s, int first) { keeploc_t *k; k = getkeep(s, 1, 1); if (k->crs_ln >= first) { k->crs_ln = (first == 1 ? 1 : first - 1); k->top_ln = (first < 11 ? 1 : first - 10); } } /* calc cursor pos and show cursor correctly */ static int cursor_pos(keeploc_t * locmem, int val, int from_top, int isshow) { int top=locmem->top_ln; if (!last_line){ cursor_show(3 , 0); return DONOTHING; } if (val > last_line){ bell(); val = last_line; } if (val <= 0){ bell(); val = 1; } if (val >= top && val < top + p_lines) { if(isshow){ cursor_clear(3 + locmem->crs_ln - top, 0); cursor_show(3 + val - top, 0); } locmem->crs_ln = val; return DONOTHING; } locmem->top_ln = val - from_top; if (locmem->top_ln <= 0) locmem->top_ln = 1; locmem->crs_ln = val; return isshow ? PARTUPDATE : HEADERS_RELOAD; } static int thread(keeploc_t * locmem, int stypen) { fileheader_t fh; int pos = locmem->crs_ln, jump = 200, new_ln; int fd = -1, step = stypen & RS_FORWARD ? 1 : -1; char *key = (stypen & RS_AUTHOR ? headers[pos - locmem->top_ln].owner : (subject( stypen & RS_CURRENT ? currtitle : headers[pos - locmem->top_ln].title ))); for(new_ln = pos + step ; new_ln > 0 && new_ln <= last_line && --jump>0; new_ln += step) { get_record_keep(currdirect, &fh, sizeof(fileheader_t), new_ln, &fd); if(stypen & RS_TITLE){ if(stypen & RS_FIRST) { if(!strcmp(fh.title, key)) break; } else if(!strcmp(subject(fh.title), key)) break; } else if(stypen & RS_NEWPOST){ if(strncmp(fh.title,"Re:",3)) break; } else{ // RS_AUTHOR if(!strcmp(subject(fh.owner), key)) break; } } if( fd != -1 ) close(fd); if( jump <=0 || new_ln<=0 || new_ln > last_line ) new_ln = pos; //didn't find else{ strncpy(currtitle, fh.title, TTLEN); strncpy(currtitle, fh.title, TTLEN); } return new_ln; } #ifdef INTERNET_EMAIL static void mail_forward(fileheader_t * fhdr, char *direct, int mode) { int i; char buf[STRLEN]; char *p; strncpy(buf, direct, sizeof(buf)); if ((p = strrchr(buf, '/'))) *p = '\0'; switch (i = doforward(buf, fhdr, mode)) { case 0: vmsg(msg_fwd_ok); break; case -1: vmsg(msg_fwd_err1); break; case -2: vmsg(msg_fwd_err2); break; default: break; } } #endif static int select_read(keeploc_t * locmem, int sr_mode) { #define READSIZE 64 // 8192 / sizeof(fileheader_t) fileheader_t fhs[READSIZE]; char newdirect[MAXPATHLEN]; char keyword[TTLEN + 1] = ""; char genbuf[MAXPATHLEN], *p = strstr(currdirect, "SR"); static int _mode = 0; int len, fd, fr, i, count=0, reference = 0; fileheader_t *fh = &headers[locmem->crs_ln - locmem->top_ln]; if(sr_mode & RS_AUTHOR) { if(!getdata(b_lines, 0, currmode & MODE_SELECT ? "增加條件 作者:":"搜尋作者:", keyword, IDLEN+1, LCECHO)) return READ_REDRAW; } else if(sr_mode & RS_KEYWORD) { if(!getdata(b_lines, 0, currmode & MODE_SELECT ? "增加條件 標題:":"搜尋標題:", keyword, TTLEN, DOECHO)) return READ_REDRAW; #ifdef KEYWORD_LOG log_file("keyword_search_log", LOG_CREAT | LOG_VF, "%s:%s\n", currboard, keyword); #endif } else { if(p && _mode & sr_mode & (RS_TITLE | RS_NEWPOST | RS_MARK)) return DONOTHING; // Ptt: only once for these modes. if(sr_mode & RS_TITLE) strcpy(keyword, subject(fh->title)); } if(p == NULL) _mode = sr_mode; else _mode |= sr_mode; snprintf(genbuf, sizeof(genbuf), "%s.%X.%X.%X", p ? p : "SR", sr_mode, strlen(keyword), StringHash(keyword)); if( strlen(genbuf) > MAXPATHLEN - 50 ) return READ_REDRAW; // avoid overflow if (currstat == RMAIL) sethomefile(newdirect, cuser.userid, genbuf); else setbfile(newdirect, currboard, genbuf); if( now - dasht(newdirect) < 3600 ) count = dashs(newdirect) / sizeof(fileheader_t); else { if( (fd = open(newdirect, O_CREAT | O_RDWR, 0600)) == -1 ) return READ_REDRAW; if( (fr = open(currdirect, O_RDONLY, 0)) != -1 ) { while( (len = read(fr, fhs, sizeof(fhs))) > 0 ){ len /= sizeof(fileheader_t); for( i = 0 ; i < len ; ++i ){ reference++; if( sr_mode & RS_MARK && !(fhs[i].filemode & FILE_MARKED) ) continue; else if(sr_mode & RS_NEWPOST && !strncmp(fhs[i].title, "Re:", 3)) continue; else if(sr_mode & RS_AUTHOR && !strcasestr(fhs[i].owner, keyword)) continue; else if(sr_mode & RS_KEYWORD && !strcasestr(fhs[i].title, keyword)) continue; else if(sr_mode & RS_TITLE && strcmp(subject(fhs[i].title), keyword)) continue; ++count; if(p == NULL) fhs[i].money = reference | FHR_REFERENCE; write(fd, &fhs[i], sizeof(fileheader_t)); } } // end while close(fr); } ftruncate(fd, count*sizeof(fileheader_t)); close(fd); } if(count) { strlcpy(currdirect, newdirect, sizeof(currdirect)); currmode |= MODE_SELECT; return NEWDIRECT; } return READ_REDRAW; } static int i_read_key(onekey_t * rcmdlist, keeploc_t * locmem, int bid, int bottom_line) { int mode = DONOTHING, num, new_top=10; int ch, new_ln = locmem->crs_ln, lastmode=0; char direct[60]; static char default_ch = 0; do { if( (mode = cursor_pos(locmem, new_ln, new_top, default_ch ? 0 : 1)) != DONOTHING ) return mode; if( !default_ch ) ch = igetch(); else{ if(new_ln != locmem->crs_ln) {// move fault default_ch=0; return FULLUPDATE; } ch = default_ch; } new_top = 10; // default 10 switch (ch) { case '0': case '1': case '2': case '3': case '4': case '5': case '6': case '7': case '8': case '9': if( (num = search_num(ch, last_line)) != -1 ) new_ln = num + 1; break; case 'q': case 'e': case KEY_LEFT: if(currmode & MODE_SELECT){ char genbuf[256]; fileheader_t *fhdr = &headers[locmem->crs_ln - locmem->top_ln]; board_select(); setbdir(genbuf, currboard); locmem = getkeep(genbuf, 0, 1); locmem->crs_ln = fhdr->money & ~FHR_REFERENCE; num = locmem->crs_ln - p_lines + 1; locmem->top_ln = num < 1 ? 1 : num; mode = NEWDIRECT; } else mode = (currmode & MODE_DIGEST) ? board_digest() : DOQUIT; break; case Ctrl('L'): redoscr(); break; case Ctrl('H'): mode = select_read(locmem, RS_NEWPOST); break; case 'a': case 'A': mode = select_read(locmem, RS_AUTHOR); break; case 'G': mode = select_read(locmem, RS_MARK); break; case '/': case '?': mode = select_read(locmem, RS_KEYWORD); break; case 'S': mode = select_read(locmem, RS_TITLE); break; case '=': new_ln = thread(locmem, RELATE_FIRST); break; case '\\': new_ln = thread(locmem, CURSOR_FIRST); break; case ']': new_ln = thread(locmem, RELATE_NEXT); break; case '+': new_ln = thread(locmem, CURSOR_NEXT); break; case '[': new_ln = thread(locmem, RELATE_PREV); break; case '-': new_ln = thread(locmem, CURSOR_PREV); break; case '<': case ',': new_ln = thread(locmem, NEWPOST_PREV); break; case '.': case '>': new_ln = thread(locmem, NEWPOST_NEXT); break; case 'p': case 'k': case KEY_UP: new_ln = locmem->crs_ln - 1; new_top = p_lines - 2; break; case 'n': case 'j': case KEY_DOWN: new_ln = locmem->crs_ln + 1; new_top = 1; break; case ' ': case KEY_PGDN: case 'N': case Ctrl('F'): new_ln = locmem->top_ln + p_lines; new_top = 0; break; case KEY_PGUP: case Ctrl('B'): case 'P': new_ln = locmem->top_ln - p_lines; new_top = 0; break; case KEY_END: case '$': new_ln = last_line; new_top = p_lines-1; break; case 'F': case 'U': if (HAS_PERM(PERM_FORWARD)) { mail_forward(&headers[locmem->crs_ln - locmem->top_ln], currdirect, ch /* == 'U' */ ); /* by CharlieL */ mode = READ_REDRAW; } break; case Ctrl('Q'): mode = my_query(headers[locmem->crs_ln - locmem->top_ln].owner); break; case Ctrl('S'): if (HAS_PERM(PERM_ACCOUNTS)) { int id; userec_t muser; strlcpy(currauthor, headers[locmem->crs_ln - locmem->top_ln].owner, sizeof(currauthor)); stand_title("使用者設定"); move(1, 0); if ((id = getuser(headers[locmem->crs_ln - locmem->top_ln].owner))) { memcpy(&muser, &xuser, sizeof(muser)); user_display(&muser, 1); uinfo_query(&muser, 1, id); } mode = FULLUPDATE; } break; /* rocker.011018: 採用新的tag模式 */ case 't': /* 將原本在 Read() 裡面的 "TagNum = 0" 移至此處 */ if ((currstat & RMAIL && TagBoard != 0) || (!(currstat & RMAIL) && TagBoard != bid)) { if (currstat & RMAIL) TagBoard = 0; else TagBoard = bid; TagNum = 0; } /* rocker.011112: 解決再select mode標記文章的問題 */ if (Tagger(atoi(headers[locmem->crs_ln - locmem->top_ln].filename + 2), (currmode & MODE_SELECT) ? (headers[locmem->crs_ln - locmem->top_ln].money & ~FHR_REFERENCE) : locmem->crs_ln, TAG_TOGGLE)) locmem->crs_ln = locmem->crs_ln + 1; mode = PART_REDRAW; break; case Ctrl('C'): if (TagNum) { TagNum = 0; mode = FULLUPDATE; } break; case Ctrl('T'): mode = TagThread(currdirect); break; case Ctrl('D'): mode = TagPruner(bid); break; case '\n': case '\r': case 'l': case KEY_RIGHT: ch = 'r'; default: if( ch == 'h' && currmode & (MODE_DIGEST) ) break; if (ch > 0 && ch <= onekey_size) { int (*func)() = rcmdlist[ch - 1]; if (func != NULL){ num = locmem->crs_ln - bottom_line; if( num > 0 ){ sprintf(direct,"%s.bottom", currdirect); mode= (*func)(num, &headers[locmem->crs_ln-locmem->top_ln], direct); } else mode = (*func)(locmem->crs_ln, &headers[locmem->crs_ln - locmem->top_ln], currdirect); if(mode == READ_SKIP) mode = lastmode; // 以下這幾種 mode 要再處理游標 if(mode == READ_PREV || mode == READ_NEXT || mode == RELATE_PREV || mode == RELATE_FIRST || mode == AUTHOR_NEXT || mode == AUTHOR_PREV || mode == RELATE_NEXT){ lastmode = mode; switch(mode){ case READ_PREV: new_ln = locmem->crs_ln - 1; break; case READ_NEXT: new_ln = locmem->crs_ln + 1; break; case RELATE_PREV: new_ln = thread(locmem, RELATE_PREV); break; case RELATE_NEXT: new_ln = thread(locmem, RELATE_NEXT); /* XXX: 讀到最後一篇要跳出來 */ if( new_ln == locmem->crs_ln ){ default_ch = 0; return FULLUPDATE; } break; case RELATE_FIRST: new_ln = thread(locmem, RELATE_FIRST); break; case AUTHOR_PREV: new_ln = thread(locmem, AUTHOR_PREV); break; case AUTHOR_NEXT: new_ln = thread(locmem, AUTHOR_NEXT); break; } mode = DONOTHING; default_ch = 'r'; } else { default_ch = 0; lastmode = 0; } } //end if (func != NULL) } // ch > 0 && ch <= onekey_size break; } // end switch } while (mode == DONOTHING); return mode; } int get_records_and_bottom(char *direct, fileheader_t* headers, int recbase, int p_lines, int last_line, int bottom_line) { int n = bottom_line - recbase + 1, rv; char directbottom[60]; if( !last_line ) return 0; if( n >= p_lines || (currmode & (MODE_SELECT | MODE_DIGEST)) ) return get_records(direct, headers, sizeof(fileheader_t), recbase, p_lines); sprintf(directbottom, "%s.bottom", direct); if( n <= 0 ) return get_records(directbottom, headers, sizeof(fileheader_t), 1-n, last_line-recbase + 1); rv = get_records(direct, headers, sizeof(fileheader_t), recbase, n); if( bottom_line < last_line ) rv += get_records(directbottom, headers+n, sizeof(fileheader_t), 1, p_lines - n ); return rv; } void i_read(int cmdmode, char *direct, void (*dotitle) (), void (*doentry) (), onekey_t * rcmdlist, int bidcache) { keeploc_t *locmem = NULL; int recbase = 0, mode; int num = 0, entries = 0, n_bottom=0; int i; char currdirect0[64]; int last_line0 = last_line; int bottom_line = 0; fileheader_t *headers0 = headers; strlcpy(currdirect0, currdirect, sizeof(currdirect0)); #define FHSZ sizeof(fileheader_t) /* Ptt: 這邊 headers 可以針對看板的最後 60 篇做 cache */ headers = (fileheader_t *) calloc(p_lines, FHSZ); strlcpy(currdirect, direct, sizeof(currdirect)); mode = NEWDIRECT; do { /* 依據 mode 顯示 fileheader */ setutmpmode(cmdmode); switch (mode) { case NEWDIRECT: /* 第一次載入此目錄 */ case DIRCHANGED: if (bidcache > 0 && !(currmode & (MODE_SELECT | MODE_DIGEST))){ if( (last_line = getbtotal(currbid)) == 0 ){ setbtotal(currbid); setbottomtotal(currbid); last_line = getbtotal(currbid); } bottom_line = last_line; last_line += (n_bottom = getbottomtotal(currbid)); } else bottom_line = last_line = get_num_records(currdirect, FHSZ); if (mode == NEWDIRECT) { num = last_line - p_lines + 1; locmem = getkeep(currdirect, num < 1 ? 1 : num, last_line); } recbase = -1; case FULLUPDATE: (*dotitle) (); case PARTUPDATE: if (last_line < locmem->top_ln + p_lines) { if (bidcache > 0 && !(currmode & (MODE_SELECT | MODE_DIGEST))){ bottom_line = getbtotal(currbid); num = bottom_line+getbottomtotal(currbid); } else num = get_num_records(currdirect, FHSZ); if (last_line != num) { last_line = num; recbase = -1; } } if (recbase != locmem->top_ln) { //headers reload recbase = locmem->top_ln; if (recbase > last_line) { recbase = last_line - p_lines + 1; if (recbase < 1) recbase = 1; locmem->top_ln = recbase; } entries=get_records_and_bottom(currdirect, headers, recbase, p_lines, last_line, bottom_line); } if (locmem->crs_ln > last_line) locmem->crs_ln = last_line; move(3, 0); clrtobot(); case PART_REDRAW: move(3, 0); if( last_line == 0 ) outs(" 沒有文章..."); else for( i = 0; i < entries ; i++ ) (*doentry) (locmem->top_ln + i, &headers[i]); case READ_REDRAW: outmsg(curredit & EDIT_ITEM ? "\033[44m 私人收藏 \033[30;47m 繼續? \033[m" : curredit & EDIT_MAIL ? msg_mailer : MSG_POSTER); break; case TITLE_REDRAW: (*dotitle) (); break; case HEADERS_RELOAD: if (recbase != locmem->top_ln) { recbase = locmem->top_ln; if (recbase > last_line) { recbase = last_line - p_lines + 1; if (recbase < 1) recbase = 1; locmem->top_ln = recbase; } entries = get_records_and_bottom(currdirect, headers, recbase, p_lines, last_line, bottom_line); } break; } //end switch mode = i_read_key(rcmdlist, locmem, currbid, bottom_line); } while (mode != DOQUIT); #undef FHSZ free(headers); last_line = last_line0; headers = headers0; strlcpy(currdirect, currdirect0, sizeof(currdirect)); return; }