/* $Id$ */
#include "bbs.h"
// XXX why linux use smaller buffer?
#if defined(linux)
#define OBUFSIZE 2048
#define IBUFSIZE 128
#else
#define OBUFSIZE 4096
#define IBUFSIZE 256
#endif
static char outbuf[OBUFSIZE], inbuf[IBUFSIZE];
static int obufsize = 0, ibufsize = 0;
static int icurrchar = 0;
/* ----------------------------------------------------- */
/* convert routines */
/* ----------------------------------------------------- */
#ifdef CONVERT
read_write_type write_type = (read_write_type)write;
read_write_type read_type = read;
inline static int read_wrapper(int fd, void *buf, size_t count) {
return (*read_type)(fd, buf, count);
}
inline static int write_wrapper(int fd, void *buf, size_t count) {
return (*write_type)(fd, buf, count);
}
#endif
/* ----------------------------------------------------- */
/* output routines */
/* ----------------------------------------------------- */
void
oflush()
{
if (obufsize) {
#ifdef CONVERT
write_wrapper(1, outbuf, obufsize);
#else
write(1, outbuf, obufsize);
#endif
obufsize = 0;
}
}
void
init_buf()
{
memset(inbuf, 0, IBUFSIZE);
}
void
output(char *s, int len)
{
/* Invalid if len >= OBUFSIZE */
assert(len<OBUFSIZE);
if (obufsize + len > OBUFSIZE) {
#ifdef CONVERT
write_wrapper(1, outbuf, obufsize);
#else
write(1, outbuf, obufsize);
#endif
obufsize = 0;
}
memcpy(outbuf + obufsize, s, len);
obufsize += len;
}
int
ochar(int c)
{
if (obufsize > OBUFSIZE - 1) {
/* suppose one byte data doesn't need to be converted. */
write(1, outbuf, obufsize);
obufsize = 0;
}
outbuf[obufsize++] = c;
return 0;
}
/* ----------------------------------------------------- */
/* input routines */
/* ----------------------------------------------------- */
static int i_newfd = 0;
static struct timeval i_to, *i_top = NULL;
static int (*flushf) () = NULL;
void
add_io(int fd, int timeout)
{
i_newfd = fd;
if (timeout) {
i_to.tv_sec = timeout;
i_to.tv_usec = 16384; /* Ptt: 改成16384 避免不按時for loop吃cpu
* time 16384 約每秒64次 */
i_top = &i_to;
} else
i_top = NULL;
}
int
num_in_buf()
{
return icurrchar - ibufsize;
}
/*
* dogetch() is not reentrant-safe. SIGUSR[12] might happen at any time, and
* dogetch() might be called again, and then ibufsize/icurrchar/inbuf might
* be inconsistent. We try to not segfault here...
*/
static int
dogetch()
{
int len;
static time_t lastact;
if (ibufsize <= icurrchar) {
if (flushf)
(*flushf) ();
refresh();
if (i_newfd) {
struct timeval timeout;
fd_set readfds;
if (i_top)
timeout = *i_top; /* copy it because select() might
* change it */
FD_ZERO(&readfds);
FD_SET(0, &readfds);
FD_SET(i_newfd, &readfds);
/* jochang: modify first argument of select from FD_SETSIZE */
/* since we are only waiting input from fd 0 and i_newfd(>0) */
while ((len = select(i_newfd + 1, &readfds, NULL, NULL,
i_top ? &timeout : NULL)) < 0) {
if (errno != EINTR)
abort_bbs(0);
/* raise(SIGHUP); */
}
if (len == 0){
#ifdef OUTTA_TIMER
now = SHM->GV2.e.now;
#else
now = time(0);
#endif
return I_TIMEOUT;
}
if (i_newfd && FD_ISSET(i_newfd, &readfds)){
#ifdef OUTTA_TIMER
now = SHM->GV2.e.now;
#else
now = time(0);
#endif
return I_OTHERDATA;
}
}
#ifdef NOKILLWATERBALL
if( currutmp && currutmp->msgcount && !reentrant_write_request )
write_request(1);
#endif
#ifdef SKIP_TELNET_CONTROL_SIGNAL
do{
#endif
#ifdef CONVERT
while ((len = read_wrapper(0, inbuf, IBUFSIZE)) <= 0) {
#else
while ((len = read(0, inbuf, IBUFSIZE)) <= 0) {
#endif
if (len == 0 || errno != EINTR)
abort_bbs(0);
/* raise(SIGHUP); */
}
#ifdef SKIP_TELNET_CONTROL_SIGNAL
} while( inbuf[0] == -1 );
#endif
ibufsize = len;
icurrchar = 0;
}
if (currutmp) {
#ifdef OUTTA_TIMER
now = SHM->GV2.e.now;
#else
now = time(0);
#endif
if (now - lastact < 3)
currutmp->lastact = now;
lastact = now;
}
return inbuf[icurrchar++];
}
static int water_which_flag = 0;
int
igetch()
{
register int ch, mode = 0, last = 0;
while ((ch = dogetch())) {
if (mode == 0 && ch == KEY_ESC) // here is state machine for 2 bytes key
mode = 1;
else if (mode == 1) { /* Escape sequence */
if (ch == '[' || ch == 'O')
mode = 2;
else if (ch == '1' || ch == '4')
{ mode = 3; last = ch; }
else
{
KEY_ESC_arg = ch;
return KEY_ESC;
}
} else if (mode == 2 && ch >= 'A' && ch <= 'D') /* Cursor key */
return KEY_UP + (ch - 'A');
else if (mode == 2 && ch >= '1' && ch <= '6')
{ mode = 3; last = ch; }
else if (mode == 3 && ch == '~') { /* Ins Del Home End PgUp PgDn */
return KEY_HOME + (last - '1');
}
else // here is switch for default keys
switch (ch) {
case IAC:
continue;
#ifdef DEBUG
case Ctrl('Q'):{
struct rusage ru;
getrusage(RUSAGE_SELF, &ru);
vmsg("sbrk: %d KB, idrss: %d KB, isrss: %d KB",
((int)sbrk(0) - 0x8048000) / 1024,
(int)ru.ru_idrss, (int)ru.ru_isrss);
}
continue;
#endif
case Ctrl('L'):
redoscr();
continue;
case Ctrl('U'):
if (currutmp != NULL && currutmp->mode != EDITING
&& currutmp->mode != LUSERS && currutmp->mode) {
screenline_t *screen0 = calloc(t_lines, sizeof(screenline_t));
int oldroll = roll;
int y, x, my_newfd;
getyx(&y, &x);
memcpy(screen0, big_picture, t_lines * sizeof(screenline_t));
my_newfd = i_newfd;
i_newfd = 0;
t_users();
i_newfd = my_newfd;
memcpy(big_picture, screen0, t_lines * sizeof(screenline_t));
roll = oldroll;
move(y, x);
free(screen0);
redoscr();
continue;
}
return ch;
case KEY_TAB:
if (WATERMODE(WATER_ORIG) || WATERMODE(WATER_NEW))
if (currutmp != NULL && watermode > 0) {
watermode = (watermode + water_which->count)
% water_which->count + 1;
t_display_new();
continue;
}
return ch;
case Ctrl('R'):
if (currutmp == NULL)
return (ch);
if (currutmp->msgs[0].pid &&
WATERMODE(WATER_OFO) && wmofo == NOTREPLYING) {
int y, x, my_newfd;
screenline_t *screen0 = calloc(t_lines, sizeof(screenline_t));
memcpy(screen0, big_picture, t_lines * sizeof(screenline_t));
getyx(&y, &x);
my_newfd = i_newfd;
i_newfd = 0;
my_write2();
memcpy(big_picture, screen0, t_lines * sizeof(screenline_t));
i_newfd = my_newfd;
move(y, x);
free(screen0);
redoscr();
continue;
} else if (!WATERMODE(WATER_OFO)) {
if (watermode > 0) {
watermode = (watermode + water_which->count)
% water_which->count + 1;
t_display_new();
continue;
} else if (currutmp->mode == 0 &&
(currutmp->chatid[0] == 2 || currutmp->chatid[0] == 3) &&
water_which->count != 0 && watermode == 0) {
/* 第二次按 Ctrl-R */
watermode = 1;
t_display_new();
continue;
} else if (watermode == -1 && currutmp->msgs[0].pid) {
/* 第一次按 Ctrl-R (必須先被丟過水球) */
screenline_t *screen0;
int y, x, my_newfd;
screen0 = calloc(t_lines, sizeof(screenline_t));
getyx(&y, &x);
memcpy(screen0, big_picture, t_lines * sizeof(screenline_t));
/* 如果正在talk的話先不處理對方送過來的封包 (不去select) */
my_newfd = i_newfd;
i_newfd = 0;
show_call_in(0, 0);
watermode = 0;
#ifndef PLAY_ANGEL
my_write(currutmp->msgs[0].pid, "水球丟過去: ",
currutmp->msgs[0].userid, WATERBALL_GENERAL, NULL);
#else
switch (currutmp->msgs[0].msgmode) {
case MSGMODE_WRITE:
my_write(currutmp->msgs[0].pid, "水球丟過去: ",
currutmp->msgs[0].userid, WATERBALL_GENERAL, NULL);
break;
case MSGMODE_FROMANGEL:
my_write(currutmp->msgs[0].pid, "再問他一次: ",
currutmp->msgs[0].userid, WATERBALL_ANGEL, NULL);
break;
case MSGMODE_TOANGEL:
my_write(currutmp->msgs[0].pid, "回答小主人: ",
currutmp->msgs[0].userid, WATERBALL_ANSWER, NULL);
break;
}
#endif
i_newfd = my_newfd;
/* 還原螢幕 */
memcpy(big_picture, screen0, t_lines * sizeof(screenline_t));
move(y, x);
free(screen0);
redoscr();
continue;
}
}
return ch;
case Ctrl('T'):
if (WATERMODE(WATER_ORIG) || WATERMODE(WATER_NEW)) {
if (watermode > 0) {
if (watermode > 1)
watermode--;
else
watermode = water_which->count;
t_display_new();
continue;
}
}
return ch;
case Ctrl('F'):
if (WATERMODE(WATER_NEW)) {
if (watermode > 0) {
if (water_which_flag == (int)water_usies)
water_which_flag = 0;
else
water_which_flag =
(water_which_flag + 1) % (int)(water_usies + 1);
if (water_which_flag == 0)
water_which = &water[0];
else
water_which = swater[water_which_flag - 1];
watermode = 1;
t_display_new();
continue;
}
}
return ch;
case Ctrl('G'):
if (WATERMODE(WATER_NEW)) {
if (watermode > 0) {
water_which_flag = (water_which_flag + water_usies) % (water_usies + 1);
if (water_which_flag == 0)
water_which = &water[0];
else
water_which = swater[water_which_flag - 1];
watermode = 1;
t_display_new();
continue;
}
}
return ch;
case Ctrl('J'): /* Ptt 把 \n 拿掉 */
#ifdef PLAY_ANGEL
/* Seams some telnet client still send CR LF when changing lines.
CallAngel();
*/
#endif
continue;
default:
return ch;
}
}
return 0;
}
int
strip_ansi(char *buf, char *str, int mode)
{
register int count = 0;
const static char EscapeFlag[] = {
/* 0 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* 10 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 ,0, 0, 0, 0, 0,
/* 20 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* 30 */ 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 0, 1, 0, 1, 0, 0, /* 0~9 ;= */
/* 40 */ 0, 2, 2, 2, 2, 0, 0, 0, 2, 2, 2, 2, 0, 0, 0, 0, /* ABCDHIJK */
/* 50 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* 60 */ 0, 0, 0, 0, 0, 0, 2, 0, 2, 0, 0, 0, 2, 2, 0, 0, /* fhlm */
/* 70 */ 0, 0, 0, 2, 0, 2, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, /* su */
/* 80 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* 90 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* A0 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* B0 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* C0 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* D0 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* E0 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
/* F0 */ 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
};
#define isEscapeParam(X) (EscapeFlag[(int)(X)] & 1)
#define isEscapeCommand(X) (EscapeFlag[(int)(X)] & 2)
for(; *str; ++str)
if( *str != '\033' ){
if( buf )
*buf++ = *str;
++count;
}else{
register char* p = str + 1;
if( *p != '[' ){
++str;
continue;
}
while(isEscapeParam(*++p));
if( (mode == NO_RELOAD && isEscapeCommand(*p)) ||
(mode == ONLY_COLOR && *p == 'm' )){
register int len = p - str + 1;
if( buf ){
strncpy(buf, str, len);
buf += len;
}
count += len;
}
str = p;
}
if( buf )
*buf = 0;
return count;
/* Rewritten by scw.
* Moved from vote.c (here is a better place for this function).
* register int ansi, count = 0;
* for (ansi = 0; *str ; str++) { if (*str == 27) { if (mode) { if (buf)
* *buf++ = *str; count++; } ansi = 1; } else if (ansi && strchr(
* "[;1234567890mfHABCDnsuJKc=n", *str)) { if ((mode == NO_RELOAD &&
* !strchr("c=n", *str)) || (mode == ONLY_COLOR && strchr("[;1234567890m",
* *str))) { if (buf) *buf++ = *str; count++; } if (strchr("mHn ", *str))
* ansi = 0; } else { ansi = 0; if (buf) *buf++ = *str; count++; } } if
* (buf) *buf = '\0'; return count; */
}
int
oldgetdata(int line, int col, char *prompt, char *buf, int len, int echo)
{
register int ch, i;
int clen;
int x = col, y = line;
#define MAXLASTCMD 12
static char lastcmd[MAXLASTCMD][80];
strip_ansi(buf, buf, STRIP_ALL);
if (prompt) {
move(line, col);
clrtoeol();
outs(prompt);
x += strip_ansi(NULL, prompt, STRIP_ALL);
}
if (!echo) {
len--;
clen = 0;
while ((ch = igetch()) != '\r') {
if (ch == '\177' || ch == Ctrl('H')) {
if (!clen) {
bell();
continue;
}
clen--;
continue;
}
if (!isprint(ch)) {
continue;
}
if (clen >= len) {
continue;
}
buf[clen++] = ch;
}
buf[clen] = '\0';
outc('\n');
oflush();
} else {
int cmdpos = 0;
int currchar = 0;
standout();
for(i=0; i<len; i++)
outc(' ');
standend();
len--;
buf[len] = '\0';
move(y, x);
edit_outs(buf);
clen = currchar = strlen(buf);
while (move(y, x + currchar), (ch = igetch()) != '\r') {
switch (ch) {
case KEY_DOWN: case Ctrl('N'):
case KEY_UP: case Ctrl('P'):
strlcpy(lastcmd[cmdpos], buf, sizeof(lastcmd[0]));
if (ch == KEY_UP || ch == Ctrl('P'))
cmdpos++;
else
cmdpos += MAXLASTCMD - 1;
cmdpos %= MAXLASTCMD;
strlcpy(buf, lastcmd[cmdpos], len+1);
move(y, x); /* clrtoeof */
for (i = 0; i <= clen; i++)
outc(' ');
move(y, x);
edit_outs(buf);
clen = currchar = strlen(buf);
break;
case KEY_LEFT:
if (currchar)
--currchar;
break;
case KEY_RIGHT:
if (buf[currchar])
++currchar;
break;
case '\177':
case Ctrl('H'):
if (currchar) {
currchar--;
clen--;
for (i = currchar; i <= clen; i++)
buf[i] = buf[i + 1];
move(y, x + clen);
outc(' ');
move(y, x);
edit_outs(buf);
}
break;
case Ctrl('Y'):
currchar = 0;
case Ctrl('K'):
buf[currchar] = '\0';
move(y, x + currchar);
for (i = currchar; i < clen; i++)
outc(' ');
clen = currchar;
break;
case Ctrl('D'):
case KEY_DEL:
if (buf[currchar]) {
clen--;
for (i = currchar; i <= clen; i++)
buf[i] = buf[i + 1];
move(y, x + clen);
outc(' ');
move(y, x);
edit_outs(buf);
}
break;
case Ctrl('A'):
case KEY_HOME:
currchar = 0;
break;
case Ctrl('E'):
case KEY_END:
currchar = clen;
break;
default:
if (isprint2(ch) && clen < len && x + clen < scr_cols) {
for (i = clen + 1; i > currchar; i--)
buf[i] = buf[i - 1];
buf[currchar] = ch;
move(y, x + currchar);
edit_outs(buf + currchar);
currchar++;
clen++;
}
break;
} /* end case */
} /* end while */
if (clen > 1) {
strlcpy(lastcmd[0], buf, sizeof(lastcmd[0]));
memmove(lastcmd+1, lastcmd, (MAXLASTCMD-1)*sizeof(lastcmd[0]));
}
outc('\n');
refresh();
}
if ((echo == LCECHO) && isupper((int)buf[0]))
buf[0] = tolower(buf[0]);
return clen;
}
/* Ptt */
int
getdata_buf(int line, int col, char *prompt, char *buf, int len, int echo)
{
return oldgetdata(line, col, prompt, buf, len, echo);
}
int
getdata_str(int line, int col, char *prompt, char *buf, int len, int echo, char *defaultstr)
{
strlcpy(buf, defaultstr, len);
return oldgetdata(line, col, prompt, buf, len, echo);
}
int
getdata(int line, int col, char *prompt, char *buf, int len, int echo)
{
buf[0] = 0;
return oldgetdata(line, col, prompt, buf, len, echo);
}