/* $Id: chat.c,v 1.1 2002/03/07 15:13:48 in2 Exp $ */
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <ctype.h>
#include <netdb.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include "config.h"
#include "pttstruct.h"
#include "perm.h"
#include "common.h"
#include "modes.h"
#include "proto.h"

extern userinfo_t *currutmp;
static int chatline;
static int stop_line;    /* next line of bottom of message window area */
static FILE *flog;

static void printchatline(char *str) {
    move(chatline, 0);
    if(*str == '>' && !PERM_HIDE(currutmp))
	return;
    else if(chatline < stop_line - 1)
	chatline++;
    else {
	region_scroll_up(2, stop_line - 2);
	move(stop_line - 2, 0);
    }
    outs(str);
    outc('\n');
    outs("→");
    
    if(flog)
	fprintf(flog, "%s\n", str);
}

extern int b_lines;             /* Screen bottom line number: t_lines-1 */

static void chat_clear() {
    for(chatline = 2; chatline < stop_line; chatline++) {
	move(chatline, 0);
	clrtoeol();
    }
    move(b_lines, 0);
    clrtoeol();
    move(chatline = 2, 0);
    outs("→");
}

static void print_chatid(char *chatid) {
    move(b_lines - 1, 0);
    clrtoeol();
    outs(chatid);
    outc(':');
}

static int chat_send(int fd, char *buf) {
    int len;
    char genbuf[200];

    sprintf(genbuf, "%s\n", buf);
    len = strlen(genbuf);
    return (send(fd, genbuf, len, 0) == len);
}

static char chatroom[IDLEN];         /* Chat-Room Name */

static int chat_recv(int fd, char *chatid) {
    static char buf[512];
    static int bufstart = 0;
    char genbuf[200];
    int c, len;
    char *bptr;

    len = sizeof(buf) - bufstart - 1;
    if((c = recv(fd, buf + bufstart, len, 0)) <= 0)
	return -1;
    c += bufstart;

    bptr = buf;
    while(c > 0) {
	len = strlen(bptr) + 1;
	if(len > c && len < (sizeof buf / 2))
	    break;

	if(*bptr == '/') {
	    switch(bptr[1]) {
	    case 'c':
		chat_clear();
		break;
	    case 'n':
		strncpy(chatid, bptr + 2, 8);
		print_chatid(chatid);
		clrtoeol();
		break;
	    case 'r':
		strncpy(chatroom, bptr + 2, IDLEN - 1);
		break;
	    case 't':
		move(0, 0);
		clrtoeol();
		sprintf(genbuf, "談天室 [%s]", chatroom);
		prints("\033[1;37;46m %-21s \033[45m 話題：%-48s\033[m",
		       genbuf, bptr + 2);
	    }
	} else
	    printchatline(bptr);

	c -= len;
	bptr += len;
    }

    if(c > 0) {
	strcpy(genbuf, bptr);
	strcpy(buf, genbuf);
	bufstart = len - 1;
    } else
	bufstart = 0;
    return 0;
}

extern userec_t cuser;

static int printuserent(userinfo_t *uentp) {
    static char uline[80];
    static int cnt;
    char pline[30];

    if(!uentp) {
	if(cnt)
	    printchatline(uline);
	bzero(uline, 80);
	cnt = 0;
	return 0;
    }
    if(!HAS_PERM(PERM_SYSOP) && !HAS_PERM(PERM_SEECLOAK) && uentp->invisible)
	return 0;

    sprintf(pline, "%-13s%c%-10s ", uentp->userid,
	    uentp->invisible ? '#' : ' ',
	    modestring(uentp, 1));
    if(cnt < 2)
	strcat(pline, "│");
    strcat(uline, pline);
    if(++cnt == 3) {
	printchatline(uline);
	memset(uline, 0, 80);
	cnt = 0;
    }
    return 0;
}

static void chathelp(char *cmd, char *desc) {
    char buf[STRLEN];
    
    sprintf(buf, "  %-20s- %s", cmd, desc);
    printchatline(buf);
}

static void chat_help(char *arg) {
    if(strstr(arg, " op")) {
	printchatline("談天室管理員專用指令");
	chathelp("[/f]lag [+-][ls]", "設定鎖定、秘密狀態");
	chathelp("[/i]nvite <id>", "邀請 <id> 加入談天室");
	chathelp("[/k]ick <id>", "將 <id> 踢出談天室");
	chathelp("[/o]p <id>", "將 Op 的權力轉移給 <id>");
	chathelp("[/t]opic <text>", "換個話題");
	chathelp("[/w]all", "廣播 (站長專用)");
    } else {
	chathelp("[//]help", "MUD-like 社交動詞");
	chathelp("[/.]help", "chicken 鬥雞用指令");
	chathelp("[/h]elp op", "談天室管理員專用指令");
	chathelp("[/a]ct <msg>", "做一個動作");
	chathelp("[/b]ye [msg]", "道別");
	chathelp("[/c]lear", "清除螢幕");
	chathelp("[/j]oin <room>", "建立或加入談天室");
	chathelp("[/l]ist [room]", "列出談天室使用者");
	chathelp("[/m]sg <id> <msg>", "跟 <id> 說悄悄話");
	chathelp("[/n]ick <id>", "將談天代號換成 <id>");
	chathelp("[/p]ager", "切換呼叫器");
	chathelp("[/q]uery", "查詢網友");
	chathelp("[/r]oom", "列出一般談天室");
	chathelp("[/u]sers", "列出站上使用者");
	chathelp("[/w]ho", "列出本談天室使用者");
	chathelp("[/w]hoin <room>", "列出談天室<room> 的使用者");
    }
}

static void chat_date() {
    time_t thetime;
    char genbuf[200];

    time(&thetime);
    sprintf(genbuf, "◆ " BBSNAME "標準時間: %s", Cdate(&thetime));
    printchatline(genbuf);
}

static void chat_pager() {
    char genbuf[200];

    char *msgs[] = {"關閉", "打開", "拔掉", "防水","好友"};
    sprintf(genbuf, "◆ 您的呼叫器:[%s]",
	    msgs[currutmp->pager = (currutmp->pager+1)%5]);
    printchatline(genbuf);
}

extern char *str_space;
extern userec_t xuser;
extern char *fn_plans;
extern char *err_uid;

static void chat_query(char *arg) {
    char *uid;
    int tuid;
    
    printchatline("");
    strtok(arg, str_space);
    if((uid = strtok(NULL, str_space)) && (tuid = getuser(uid))) {
	char buf[128], *ptr;
	FILE *fp;
	
	sprintf(buf, "%s(%s) 共上站 %d 次，發表過 %d 篇文章",
		xuser.userid, xuser.username, xuser.numlogins, xuser.numposts);
	printchatline(buf);
	
	sprintf(buf, "最近(%s)從[%s]上站", Cdate(&xuser.lastlogin),
		(xuser.lasthost[0] ? xuser.lasthost : "(不詳)"));
	printchatline(buf);
	
	sethomefile(buf, xuser.userid, fn_plans);
	if((fp = fopen(buf, "r"))) {
	    tuid = 0;
	    while(tuid++ < MAX_QUERYLINES && fgets(buf, 128, fp)) {
		if((ptr = strchr(buf, '\n')))
		    ptr[0] = '\0';
		printchatline(buf);
	    }
	    fclose(fp);
	}
    } else
	printchatline(err_uid);
}

extern char *msg_shortulist;

static void chat_users() {
    printchatline("");
    printchatline("【 " BBSNAME "的遊客列表 】");
    printchatline(msg_shortulist);

    if(apply_ulist(printuserent) == -1)
	printchatline("空無一人");
    printuserent(NULL);
}

typedef struct chat_command_t {
    char *cmdname;                /* Chatroom command length */
    void (*cmdfunc) ();           /* Pointer to function */
} chat_command_t;

static chat_command_t chat_cmdtbl[] = {
    {"help", chat_help},
    {"clear", chat_clear},
    {"date", chat_date},
    {"pager", chat_pager},
    {"query", chat_query},
    {"users", chat_users},
    {NULL, NULL}
};

static int chat_cmd_match(char *buf, char *str) {
    while(*str && *buf && !isspace(*buf))
	if(tolower(*buf++) != *str++)
	    return 0;
    return 1;
}

static int chat_cmd(char *buf, int fd) {
    int i;

    if(*buf++ != '/')
	return 0;

    for(i = 0; chat_cmdtbl[i].cmdname; i++) {
	if(chat_cmd_match(buf, chat_cmdtbl[i].cmdname)) {
	    chat_cmdtbl[i].cmdfunc(buf);
	    return 1;
	}
    }
    return 0;
}

extern char trans_buffer[256];         /* 一般傳遞變數 add by Ptt */

#if 0
static char *select_address() {
    int c;
    FILE *fp;
    char nametab[25][90];
    char iptab[25][18], buf[80];

    move(1, 0);
    clrtobot();
    outs("\n          \033[36m【找個地方抬抬槓吧!】\033[m "
	 "◎  【以下為本站登記有案的茶樓】          \n");
    trans_buffer[0]=0;
    if((fp = fopen("etc/teashop", "r"))) {
	for(c = 0; fscanf(fp, "%s%s", iptab[c], nametab[c]) != EOF; c++) {
            sprintf(buf,"\n            (\033[36m%d\033[0m) %-30s     [%s]",
		    c + 1, nametab[c], iptab[c]);
            outs(buf);
	}
	getdata(20, 10, "★\033[32m 請選擇，[0]離開：\033[0m", buf, 3, 
		LCECHO);
	if(buf[1])
	    buf[0] = (buf[0] + 1) * 10 + (buf[1] - '1');
	else
	    buf[0] -= '1';
	if(buf[0] >= 0 && buf[0] < c)
	    strcpy(trans_buffer,iptab[(int)buf[0]]);
    } else {
	outs("本站沒有登記任何合格茶樓");
	pressanykey();
    }
    return trans_buffer;
}
#endif

extern int usernum;
extern int t_lines;
extern char *msg_seperator;
#define MAXLASTCMD 6
static int chatid_len = 10;

int t_chat() {
    char inbuf[80], chatid[20], lastcmd[MAXLASTCMD][80], *ptr = "";
    struct sockaddr_in sin;
    struct hostent *h;
    int cfd, cmdpos, ch;
    int currchar;
    int newmail;
    int chatting = YEA;
    char fpath[80];
    char genbuf[200];
    char roomtype; 

    if(inbuf[0] == 0)
	return -1;

    outs("                     驅車前往 請梢候........         ");
    if(!(h = gethostbyname("localhost"))) {
	perror("gethostbyname");
	return -1;
    }
    memset(&sin, 0, sizeof sin);
#ifdef FreeBSD
    sin.sin_len = sizeof(sin);
#endif
    sin.sin_family = PF_INET;
    memcpy(&sin.sin_addr, h->h_addr, h->h_length);
    sin.sin_port = htons(NEW_CHATPORT);
    cfd = socket(sin.sin_family, SOCK_STREAM, 0);
    if(!(connect(cfd, (struct sockaddr *) & sin, sizeof sin)))
	roomtype = 1;
    else {
	sin.sin_port = CHATPORT;
	cfd = socket(sin.sin_family, SOCK_STREAM, 0);
	if(!(connect(cfd, (struct sockaddr *) & sin, sizeof sin)))
	    roomtype = 2;
	else {
	    outs("\n              "
		 "哇! 沒人在那邊耶...要有那地方的人先去開門啦!...");
            system("bin/xchatd");
	    pressanykey();
	    return -1;
	}
    }
  
    while(1) {
	getdata(b_lines - 1, 0, "請輸入聊天代號：", inbuf, 9, DOECHO);
	sprintf(chatid, "%s", (inbuf[0] ? inbuf : cuser.userid));
	chatid[8] = '\0';
/*
  舊格式:    /! 使用者編號 使用者等級 UserID ChatID
  新格式:    /! UserID ChatID Password
*/
	if(roomtype == 1)
	    sprintf(inbuf, "/! %s %s %s",
		    cuser.userid, chatid, cuser.passwd);
	else
	    sprintf(inbuf, "/! %d %d %s %s",
		    usernum, cuser.userlevel, cuser.userid, chatid);
	chat_send(cfd, inbuf);
	if(recv(cfd, inbuf, 3, 0) != 3)
	    return 0;
	if(!strcmp(inbuf, CHAT_LOGIN_OK))
	    break;
	else if(!strcmp(inbuf, CHAT_LOGIN_EXISTS))
	    ptr = "這個代號已經有人用了";
	else if(!strcmp(inbuf, CHAT_LOGIN_INVALID))
	    ptr = "這個代號是錯誤的";
	else if(!strcmp(inbuf, CHAT_LOGIN_BOGUS))
	    ptr = "請勿派遣分身進入聊天室 !!";
	
	move(b_lines - 2, 0);
	outs(ptr);
	clrtoeol();
	bell();
    }
    
    add_io(cfd, 0);
    
    newmail = currchar = 0;
    cmdpos = -1;
    memset(lastcmd, 0, MAXLASTCMD * 80);
    
    setutmpmode(CHATING);
    currutmp->in_chat = YEA;
    strcpy(currutmp->chatid, chatid);
    
    clear();
    chatline = 2;
    strcpy(inbuf, chatid);
    stop_line = t_lines - 3;
    
    move(stop_line, 0);
    outs(msg_seperator);
    move(1, 0);
    outs(msg_seperator);
    print_chatid(chatid);
    memset(inbuf, 0, 80);

    sethomepath(fpath, cuser.userid);
    strcpy(fpath, tempnam(fpath, "chat_"));
    flog = fopen(fpath, "w");

    while(chatting) {
	move(b_lines - 1, currchar + chatid_len);
	ch = igetkey();

	switch(ch) {
	case KEY_DOWN:
	    cmdpos += MAXLASTCMD - 2;
	case KEY_UP:
	    cmdpos++;
	    cmdpos %= MAXLASTCMD;
	    strcpy(inbuf, lastcmd[cmdpos]);
	    move(b_lines - 1, chatid_len);
	    clrtoeol();
	    outs(inbuf);
	    currchar = strlen(inbuf);
	    continue;
	case KEY_LEFT:
	    if(currchar)
		--currchar;
	    continue;
	case KEY_RIGHT:
	    if(inbuf[currchar])
		++currchar;
	    continue;
	}

	if(!newmail && currutmp->mailalert ) {
	    newmail = 1;
	    printchatline("◆ 噹！郵差又來了...");
	}
	
	if(ch == I_OTHERDATA) {     /* incoming */
	    if(chat_recv(cfd, chatid) == -1) {
		chatting = chat_send(cfd, "/b");
		break;
	    }
	    continue;
	}
	if(isprint2(ch)) {
	    if(currchar < 68) {
		if(inbuf[currchar]) {   /* insert */
		    int i;
		    
		    for(i = currchar; inbuf[i] && i < 68; i++);
		    inbuf[i + 1 ] = '\0';
		    for(; i > currchar; i--)
			inbuf[i] = inbuf[i - 1];
		} else                  /* append */
		    inbuf[currchar + 1] = '\0';
		inbuf[currchar] = ch;
		move(b_lines - 1, currchar + chatid_len);
		outs(&inbuf[currchar++]);
	    }
	    continue;
	}

	if(ch == '\n' || ch == '\r') {
	    if(*inbuf) {
		chatting = chat_cmd(inbuf, cfd);
		if(chatting == 0)
		    chatting = chat_send(cfd, inbuf);
		if(!strncmp(inbuf, "/b", 2))
		    break;
		
		for(cmdpos = MAXLASTCMD - 1; cmdpos; cmdpos--)
		    strcpy(lastcmd[cmdpos], lastcmd[cmdpos - 1]);
		strcpy(lastcmd[0], inbuf);
		
		inbuf[0] = '\0';
		currchar = 0;
		cmdpos = -1;
	    }
	    print_chatid(chatid);
	    move(b_lines - 1, chatid_len);
	    continue;
	}

	if(ch == Ctrl('H') || ch == '\177') {
	    if(currchar) {
		currchar--;
		inbuf[69] = '\0';
		memcpy(&inbuf[currchar], &inbuf[currchar + 1], 69 - currchar);
		move(b_lines - 1, currchar + chatid_len);
		clrtoeol();
		outs(&inbuf[currchar]);
	    }
	    continue;
	}
	if(ch == Ctrl('Z') || ch == Ctrl('Y')) {
	    inbuf[0] = '\0';
	    currchar = 0;
	    print_chatid(chatid);
	    move(b_lines - 1, chatid_len);
	    continue;
	}
	
	if(ch == Ctrl('C')) {
	    chat_send(cfd, "/b");
	    break;
	}
	if(ch == Ctrl('D')) {
	    if(currchar < strlen(inbuf)) {
		inbuf[69] = '\0';
		memcpy(&inbuf[currchar], &inbuf[currchar + 1], 69 - currchar);
		move(b_lines - 1, currchar + chatid_len);
		clrtoeol();
		outs(&inbuf[currchar]);
	    }
	    continue;
	}
	if(ch == Ctrl('K')) {
	    inbuf[currchar] = 0;
	    move(b_lines - 1, currchar + chatid_len);
	    clrtoeol();
	    continue;
	}
	if(ch == Ctrl('A')) {
	    currchar = 0;
	    continue;
	}
	if(ch == Ctrl('E')) {
	    currchar = strlen(inbuf);
	    continue;
	}
	if(ch == Ctrl('I')) {
	    extern screenline_t *big_picture;
	    screenline_t *screen0 = calloc(t_lines, sizeof(screenline_t));

	    memcpy(screen0, big_picture, t_lines * sizeof(screenline_t));
	    add_io(0, 0);
	    t_idle();
	    memcpy(big_picture, screen0, t_lines * sizeof(screenline_t));
	    free(screen0);
	    redoscr();
	    add_io(cfd, 0);
	    continue;
	}
	if(ch == Ctrl('Q')) {
	    print_chatid(chatid);
	    move(b_lines - 1, chatid_len);
	    outs(inbuf);
	    continue;
	}
    }
    
    close(cfd);
    add_io(0, 0);
    currutmp->in_chat = currutmp->chatid[0] = 0;
    
    if(flog) {
	char ans[4];
	
	fclose(flog);
	more(fpath, NA);
	getdata(b_lines - 1, 0, "清除(C) 移至備忘錄(M) (C/M)?[C]",
		ans, 4, LCECHO);
	if (*ans == 'm') {
	    fileheader_t mymail;
	    char title[128];
	    
	    sethomepath(genbuf, cuser.userid);
	    stampfile(genbuf, &mymail);
	    mymail.savemode = 'H';        /* hold-mail flag */
	    mymail.filemode = FILE_READ;
	    strcpy(mymail.owner, "[備.忘.錄]");
	    strcpy(mymail.title, "會議\033[1;33m記錄\033[m");
	    sethomedir(title, cuser.userid);
	    append_record(title, &mymail, sizeof(mymail));
	    Rename(fpath, genbuf);
	} else
	    unlink(fpath);
    }
    
    return 0;
}
/* -------------------------------------------------- */
#if 0

extern char page_requestor[];
extern userinfo_t *currutmp;

#endif