/* $Id: more.c,v 1.20 2004/10/27 14:34:37 Starfish Exp $ */
#include "bbs.h"
#define MORE_BUFSIZE	4096
#define MORE_WINSIZE	4096
#define STR_ANSICODE    "[0123456789;,"

static int      more_base, more_size, more_head;
static unsigned char more_pool[MORE_BUFSIZE];


int             beep = 0;

static void
more_goto(int fd, off_t off)
{
    int             base = more_base;

    if (off < base || off >= base + more_size) {
	more_base = base = off & (-MORE_WINSIZE);
	lseek(fd, base, SEEK_SET);
	more_size = read(fd, more_pool, MORE_BUFSIZE);
    }
    more_head = off - base;
}

static int
more_readln(int fd, unsigned char *buf)
{
    int             ch;

    unsigned char  *data, *tail, *cc;
    int             len, bytes, in_ansi, in_big5;
    int             size, head, ansilen;

    len = bytes = in_ansi = in_big5 = ansilen = 0;
    tail = buf + ANSILINELEN - 1;
    size = more_size;
    head = more_head;
    data = &more_pool[head];

    do {
	if (head >= size) {
	    more_base += size;
	    data = more_pool;
	    more_size = size = read(fd, data, MORE_BUFSIZE);
	    if (size == 0)
		break;
	    head = 0;
	}
	ch = *data++;
	head++;
	bytes++;
	if (ch == '\n') {
	    break;
	}
	if (ch == '\t') {
	    do {
		*buf++ = ' ';
	    }
	    while ((++len & 7) && len < t_columns);
	} else if (ch == '\033') {
	    if (atoi((char *)(data + 1)) > 47) {
		if ((cc = (unsigned char *)strchr((char *)(data + 1), 'm')) != NULL) {
		    ch = cc - data + 1;

		    data += ch;
		    head += ch;
		    bytes += ch;
		}
	    } else {
		if (showansi)
		    *buf++ = ch;
		in_ansi = 1;
	    }
	} else if (in_ansi) {
	    if (showansi)
		*buf++ = ch;
	    if (!strchr(STR_ANSICODE, ch))
		in_ansi = 0;
	} else if (in_big5) {
	    ++len;
	    *buf++ = ch;
	    in_big5 = 0;
	} else if (isprint2(ch)) {
	    len++;
	    *buf++ = ch;
	    if (ch >= 0xa1 && ch <= 0xf9) /* first byte of big5 encoding */
		in_big5 = 1;
	}
    } while (len < t_columns && buf < tail);

    if (in_big5) {
	strcpy(buf - 1, "\033[1;34m>\033[m");
	buf += 10;
	// --head;
	// --data;
	// --bytes;
    }

    if (len == t_columns && head < size && *data == '\n') {
      /* XXX: not handle head==size, should read data */
      /* no extra newline dirty hack for exact 80byte line */
      data++; bytes++; head++;
    }
    *buf = '\0';
    more_head = head;
    return bytes;
}

int
more(char *fpath, int promptend)
{
    char           *ptr, *word = NULL, buf[ANSILINELEN + 1];
    struct stat     st;

    int             fd, fsize;

    unsigned int    pagebreak[MAX_PAGES], pageno, lino = 0;
    int             line, ch, viewed, pos, numbytes, len;
    int             header = 0;
    int             local = 0;
    char            search_char0 = 0;
    static char     search_str[81] = "";
    typedef char   *(*FPTR) ();
    static FPTR     fptr;
    int             searching = 0;
    int             scrollup = 0;
    char           *printcolor[3] = {"35;42", "33;45", "0;34;46"}, color = 0;
    char            printbuf[40];
    /* Ptt */

    memset(pagebreak, 0, sizeof(pagebreak));
    if (*search_str)
	search_char0 = *search_str;
    *search_str = 0;

    fd = open(fpath, O_RDONLY, 0600);
    if (fd < 0)
	return -1;

    if (fstat(fd, &st) || ((fsize = st.st_size) <= 0) || S_ISDIR(st.st_mode)) {
	close(fd);
	//Ptt
	    return -1;
    }
    pagebreak[0] = pageno = viewed = line = pos = 0;
    clear();

    /* rocker */

    more_base = more_head = more_size = 0;

    while ((numbytes = more_readln(fd, (unsigned char *)buf)) || (line == t_lines)) {
	if (scrollup) {
	    rscroll();
	    move(0, 0);
	}
	if (numbytes) {		/* 一般資料處理 */
	    if (!viewed) {	/* begin of file */
		if (showansi) {	/* header processing */
                    for (;;) {
                        if (pos && numbytes==1) {
                            prints("\e[36m%s\e[m\n", msg_seperator);
                            viewed += numbytes;
                            numbytes = more_readln(fd, (unsigned char *)buf);
                            ++line;
                            ++pos;
                            break;
                        }
                        word = strchr(buf, ':');
                        if (word == NULL)
                            break;
                        *word = '\0';
                        ++word;
                        ptr = strstr(word, str_post1);
                        if (ptr == NULL)
                            ptr = strstr(word, str_post2);
                        len = strlen(buf);
                        if (!pos && ptr!=NULL && ptr!=buf) {
                            ptr[-1] = '\0';
                            prints(
                                "\e[47;34m %s \e[44;37m%-*.*s"
                                "\e[47;34m %.4s \e[44;37m%-13s\e[m\n",
                                buf, 59-len, 59-len, word, ptr, ptr+5);
                        } else {
                            prints(
                                "\e[47;34m %s \e[44;37m%-*.*s\e[m\n",
                                buf, 78-len, 78-len, word);
                        }

			viewed += numbytes;
			numbytes = more_readln(fd, (unsigned char *)buf);
                        ++line;
			++pos;
		    }
                    if (pos)
                        header = 1;
		}
		lino = pos;
                word = NULL;
	    }
	    /* ※處理引用者 & 引言 */
	    if ((buf[1] == ' ') && (buf[0] == ':' || buf[0] == '>'))
		word = "\033[36m";
	    else if (!strncmp(buf, "※", 2) || !strncmp(buf, "==>", 3))
		word = "\033[32m";

	    if (word)
		outs(word);
	    {
		char            msg[500], *pos;

		if (*search_str && (pos = fptr(buf, search_str))) {
		    char            SearchStr[81];
		    char            buf1[100], *pos1;

		    strncpy(SearchStr, pos, strlen(search_str));
		    SearchStr[strlen(search_str)] = 0;
		    searching = 0;
		    snprintf(msg, sizeof(msg),
			     "%.*s\033[7m%s\033[m", pos - buf, buf,
			     SearchStr);
		    while ((pos = fptr(pos1 = pos + strlen(search_str),
				       search_str))) {
			snprintf(buf1, sizeof(buf1),
				 "%.*s\033[7m%s\033[m", pos - pos1,
				 pos1, SearchStr);
			strlcat(msg, buf1, sizeof(msg));
		    }
		    strlcat(msg, pos1, sizeof(msg));
		    if (promptend)
                        outs(msg);
                    else
                        outs(Ptt_prints(msg, NO_RELOAD));
		} else {
		    if (promptend)
                        outs(buf);
                    else
                        outs(Ptt_prints(buf, NO_RELOAD));
                }
	    }
	    if (word) {
		outs("\033[m");
		word = NULL;
	    }
	    outch('\n');

	    if (beep) {
		bell();
		beep = 0;
	    }
	    if (line < b_lines)	/* 一般資料讀取 */
		line++;

	    if (line == b_lines && searching == -1) {
		if (pageno > 0)
		    more_goto(fd, viewed = pagebreak[--pageno]);
		else
		    searching = 0;
		lino = pos = line = 0;
		clear();
		continue;
	    }
	    if (scrollup) {
		move(line = b_lines, 0);
		clrtoeol();
		for (pos = 1; pos < b_lines; pos++)
		    viewed += more_readln(fd, (unsigned char *)buf);
	    } else if (pos == b_lines)	/* 捲動螢幕 */
		scroll();
	    else
		pos++;

	    if (!scrollup                   &&
		++lino >= (unsigned)b_lines &&
		pageno < MAX_PAGES - 1         ) {
		pagebreak[++pageno] = viewed;
		lino = 1;
	    }
	    if (scrollup) {
		lino = scrollup;
		scrollup = 0;
	    }
	    viewed += numbytes;	/* 累計讀過資料 */
	} else
	    line = b_lines;	/* end of END */

	if (promptend &&
	    ((!searching && line == b_lines) || viewed == fsize)) {
	    /* Kaede 剛好 100% 時不停 */
	    move(b_lines, 0);
	    if (viewed == fsize) {
		if (searching == 1)
		    searching = 0;
		color = 0;
	    } else if (pageno == 1 && lino == 1) {
		if (searching == -1)
		    searching = 0;
		color = 1;
	    } else
		color = 2;

            snprintf(printbuf, sizeof printbuf,
                     "瀏覽 P.%d(%d%%)",
                     pageno, (int)((viewed*100)/fsize));
            prints("\e[m\e[%sm  %-15.15s  \e[0;37;44m   %s  \e[m",
                   printcolor[(int)color],
                   printbuf,
                   "求助[\e[1;32;44mh\e[0;37;44m]  "
                   "游標移動[\e[1;32;44m→,↓,PgUp,PgDn,Home,End\e[0;37;44m]  "
                   "結束[\e[1;32;44m←,q\e[0;37;44m]");

	    while (line == b_lines || (line > 0 && viewed == fsize)) {
	        /* 這裡的傳回值請參看 read_post (bbs.c) */
	        /*  1 - READ_PREV */
	        /*  2 - RELATE_PREV */
	        /*  3 - READ_NEXT */
	        /*  4 - RELATE_NEXT */
	        /*  5 - RELATE_FIRST */
	        /*  6 - FULLUPDATE */
		/*  7 - mail_reply + FULLUPDATE */
	        /*  8 - do_reply + FULLUPDATE */
	        /*  9 - 'A' */
	        /* 10 - 'a' */
	        /* 11 - '/' */
	        /* 12 - '?' */
		switch ((ch = egetch())) {
		case ':':
		    {
			char            buf[10];
			int             i = 0;

			getdata(b_lines - 1, 0, "Goto Page: ", buf, 5, DOECHO);
			sscanf(buf, "%d", &i);
			if (0 < i && i < MAX_PAGES && (i == 1 || pagebreak[i - 1]))
			    pageno = i - 1;
			else if (pageno)
			    pageno--;
			lino = line = 0;
			break;
		    }
		case '/':
		    {
			char            ans[4] = "n";

			*search_str = search_char0;
			getdata_buf(b_lines - 1, 0, "[搜尋]關鍵字:", search_str,
				    40, DOECHO);
			if (*search_str) {
			    searching = 1;
			    if (getdata(b_lines - 1, 0, "區分大小寫(Y/N/Q)? [N] ",
				   ans, sizeof(ans), LCECHO) && *ans == 'y')
				fptr = strstr;
			    else
				fptr = strcasestr;
			}
			if (*ans == 'q')
			    searching = 0;
			if (pageno)
			    pageno--;
			lino = line = 0;
			break;
		    }
		case 'n':
		    if (*search_str) {
			searching = 1;
			if (pageno)
			    pageno--;
			lino = line = 0;
		    }
		    break;
		case 'N':
		    if (*search_str) {
			searching = -1;
			if (pageno)
			    pageno--;
			lino = line = 0;
		    }
		    break;
		case 'z':
		case 'Z':
		    close(fd);
		    return 7;
		case 'r':
		case 'R':
		case 'Y':
		case 'y':
		    close(fd);
		    return 8;
		case 'A':
		    close(fd);
		    return 9;
		case 'a':
		    close(fd);
		    return 10;
		case 'F':
                    close(fd);
                    return 11;
		case 'B':
		    close(fd);
		    return 12;
		case KEY_LEFT:
        case 'q':
	case 'e':
		    close(fd);
		    return 0;
		case 'b':
		    close(fd);
		    return 1;
		case 'f':
		    close(fd);
		    return 3;
		case ']':	/* Kaede 為了主題閱讀方便 */
		    close(fd);
		    return 4;
		case '[':	/* Kaede 為了主題閱讀方便 */
		    close(fd);
		    return 2;
		case '=':	/* Kaede 為了主題閱讀方便 */
		    close(fd);
		    return 5;
		case 'w':
		case '!':
		    close(fd);
		    return 13;
		case Ctrl('C'):
		    close(fd);
		    return 14;
		case Ctrl('F'):
		case KEY_PGDN:
		    line = 1;
		    break;
		case 't':
		    if (viewed == fsize) {
			close(fd);
			return 4;
		    }
		    line = 1;
		    break;
		case ' ':
		    if (viewed == fsize) {
			close(fd);
                        if (cuser->uflag2 & SPACE_THREAD)
                            return 4;  /* read thread */
                        else
                            return 3;  /* read next */
		    }
		    line = 1;
		    break;
		case KEY_RIGHT:
		    if (viewed == fsize) {
			close(fd);
			return 0;
		    }
		    line = 1;
		    break;
		case '\r':
		case '\n':
		case KEY_DOWN:
		    if (viewed == fsize ||
			(promptend == 2 && (ch == '\r' || ch == '\n'))) {
			close(fd);
			return 3;
		    }
		    line = t_lines - 2;
		    break;
		case '$':
		case KEY_END:
		    line = t_lines;
		    break;
		case '#':
		case KEY_HOME:
		    pageno = line = 0;
		    break;
		case 'h':
		case 'H':
		case '?':
		    /* Kaede Buggy ... lxb: changed*/
		    more("etc/read.help", NA);
                    pressanykey(); 
                    if (pageno)
			pageno--;
		    lino = line = 0;
		    break;
		case 'E':
		    if (HAS_PERM(PERM_SYSOP) && strcmp(fpath, "etc/ve.hlp")) {
			close(fd);
			vedit(fpath, NA, NULL);
			return 0;
		    }
		    break;

		case Ctrl('T'):
		    getdata(b_lines - 2, 0, "把這篇文章收入到暫存檔？[y/N] ",
			    buf, 4, LCECHO);
		    if (buf[0] == 'y') {
			char            tmpbuf[128];

			setuserfile(tmpbuf, ask_tmpbuf(b_lines - 1));
			snprintf(buf, sizeof(buf),
				 "cp -f %s %s", fpath, tmpbuf);
			system(buf);
		    }
		    if (pageno)
			pageno--;
		    lino = line = 0;
		    break;
		case KEY_UP:
		    line = -1;
		    break;
		case Ctrl('B'):
		case KEY_PGUP:
		    if (pageno > 1) {
			if (lino < 2)
			    pageno -= 2;
			else
			    pageno--;
			lino = line = 0;
		    } else if (pageno && lino > 1)
			pageno = line = 0;
		    break;
		case Ctrl('H'):
		    if (pageno > 1) {
			if (lino < 2)
			    pageno -= 2;
			else
			    pageno--;
			lino = line = 0;
		    } else if (pageno && lino > 1)
			pageno = line = 0;
		    else {
			close(fd);
			return 1;
		    }
		}
	    }

	    if (line > 0) {
		move(b_lines, 0);
		clrtoeol();
		refresh();
	    } else if (line < 0) {	/* Line scroll up */
		if (pageno <= 1) {
		    if (lino == 1 || !pageno) {
			close(fd);
			return 1;
		    }
		    if (header && lino <= 5) {
			more_goto(fd, viewed = pagebreak[scrollup = lino =
							 pageno = 0] = 0);
			clear();
		    }
		}
		if (pageno && (int)lino > 1 + local) {
		    line = (lino - 2) - local;
		    if (pageno > 1 && viewed == fsize)
			line += local;
		    scrollup = lino - 1;
		    more_goto(fd, viewed = pagebreak[pageno - 1]);
		    while (line--)
			viewed += more_readln(fd, (unsigned char *)buf);
		} else if (pageno > 1) {
		    scrollup = b_lines - 1;
		    line = (b_lines - 2) - local;
		    more_goto(fd, viewed = pagebreak[--pageno - 1]);
		    while (line--)
			viewed += more_readln(fd, (unsigned char *)buf);
		}
		line = pos = 0;
	    } else {
		pos = 0;
		more_goto(fd, viewed = pagebreak[pageno]);
		move(0, 0);
		clear();
	    }
	}
    }

    close(fd);
    if (promptend) {
	pressanykey();
	clear();
    } else
	outs(reset_color);
    return 0;
}