/* $Id$ */
#include "bbs.h"
static fileheader_t *headers = NULL;
static int last_line; // PTT: last_line 游標可指的最後一個
#include <sys/mman.h>
/* ----------------------------------------------------- */
/* 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 <sys/mman.h>
#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;
}