/* $Id$ */ #include "bbs.h" #include "xchatd.h" #define SERVER_USAGE #define WATCH_DOG #undef MONITOR /* 監督 chatroom 活動以解決糾紛 */ #undef DEBUG /* 程式除錯之用 */ #ifdef DEBUG #define MONITOR #endif static int gline; #ifdef WATCH_DOG #define MYDOG gline = __LINE__ #else #define MYDOG /* NOOP */ #endif #define CHAT_PIDFILE "log/chat.pid" #define CHAT_LOGFILE "log/chat.log" #define CHAT_INTERVAL (60 * 30) #define SOCK_QLEN 1 /* name of the main room (always exists) */ #define MAIN_NAME "main" #define MAIN_TOPIC "烹茶可貢西天佛" #define ROOM_LOCKED 1 #define ROOM_SECRET 2 #define ROOM_OPENTOPIC 4 #define ROOM_HANDUP 8 #define ROOM_ALL (NULL) #define LOCKED(room) (room->rflag & ROOM_LOCKED) #define SECRET(room) (room->rflag & ROOM_SECRET) #define OPENTOPIC(room) (room->rflag & ROOM_OPENTOPIC) #define RHANDUP(room) (room->rflag & ROOM_HANDUP) #define RESTRICTED(usr) (usr->uflag == 0) /* guest */ #define CHATSYSOP(usr) (usr->uflag & ( PERM_SYSOP | PERM_CHATROOM)) /* Thor: SYSOP 與 CHATROOM都是 chat總管 */ #define PERM_ROOMOP PERM_CHAT /* Thor: 借 PERM_CHAT為 PERM_ROOMOP */ #define PERM_HANDUP PERM_BM /* 借 PERM_BM 為有沒有舉手過 */ #define PERM_SAY PERM_NOTOP /* 借 PERM_NOTOP 為有沒有發表權 */ /* 進入時需清空 */ /* Thor: ROOMOP為房間管理員 */ #define ROOMOP(usr) (usr->uflag & ( PERM_ROOMOP | PERM_SYSOP | PERM_CHATROOM)) #define CLOAK(usr) (usr->uflag & PERM_CLOAK) #define HANDUP(usr) (usr->uflag & PERM_HANDUP) #define SAY(usr) (usr->uflag & PERM_SAY) /* Thor: 聊天室隱身術 */ /* ----------------------------------------------------- */ /* ChatRoom data structure */ /* ----------------------------------------------------- */ typedef struct ChatRoom ChatRoom; typedef struct ChatUser ChatUser; typedef struct UserList UserList; typedef struct ChatCmd ChatCmd; typedef struct ChatAction ChatAction; struct ChatUser { struct ChatUser *unext; int sock; /* user socket */ int talksock; /* talk socket */ ChatRoom *room; UserList *ignore; int userno; int uflag; int clitype; /* Xshadow: client type. 1 for common client, * 0 for bbs only client */ time_t uptime; /* Thor: unused */ char userid[IDLEN + 1]; /* real userid */ char chatid[9]; /* chat id */ char lasthost[30]; /* host address */ char ibuf[80]; /* buffer for non-blocking receiving */ int isize; /* current size of ibuf */ }; struct ChatRoom { struct ChatRoom *next, *prev; char name[IDLEN]; char topic[48]; /* Let the room op to define room topic */ int rflag; /* ROOM_LOCKED, ROOM_SECRET, ROOM_OPENTOPIC */ int occupants; /* number of users in room */ UserList *invite; }; struct UserList { struct UserList *next; int userno; char userid[IDLEN + 1]; }; struct ChatCmd { char *cmdstr; void (*cmdfunc) (); int exact; }; static ChatRoom mainroom; static ChatUser *mainuser; static fd_set mainfds; static int maxfds; /* number of sockets to select on */ static int totaluser; /* current number of connections */ static struct timeval zerotv; /* timeval for selecting */ static char chatbuf[256]; /* general purpose buffer */ static int common_client_command; static char msg_not_op[] = "◆ 您不是這間聊天室的 Op"; static char msg_no_such_id[] = "◆ 目前沒有人使用 [%s] 這個聊天代號"; static char msg_not_here[] = "◆ [%s] 不在這間聊天室"; #define FUZZY_USER ((ChatUser *) -1) typedef struct userec_t ACCT; /* ----------------------------------------------------- */ /* acct_load for check acct */ /* ----------------------------------------------------- */ int acct_load(acct, userid) ACCT *acct; char *userid; { int id; if((id=searchuser(userid))<0) { return -1; } else { return get_record(FN_PASSWD, acct, sizeof(ACCT), id); } } /* * str_ncpy() - similar to strncpy(3) but terminates string always with '\0' * if n != 0, and doesn't do padding */ void str_ncpy(dst, src, n) char *dst; char *src; int n; { char *end; end = dst + n; do { n = (dst == end) ? 0 : *src++; *dst++ = n; } while (n); } /* ----------------------------------------------------- */ /* usr_fpath for check acct */ /* ----------------------------------------------------- */ char *str_home_file = "home/%c/%s/%s"; void usr_fpath(buf, userid, fname) char *buf, *userid, *fname; { sprintf(buf, str_home_file, userid[0], userid, fname); } /* ----------------------------------------------------- */ /* chkpasswd for check passwd */ /* ----------------------------------------------------- */ char *crypt(); static char pwbuf[PASSLEN]; int chkpasswd(passwd, test) char *passwd, *test; { char *pw; str_ncpy(pwbuf, test, PASSLEN); pw = crypt(pwbuf, passwd); return (!strncmp(pw, passwd, PASSLEN)); } /* ----------------------------------------------------- */ /* operation log and debug information */ /* ----------------------------------------------------- */ static int flog; /* log file descriptor */ static void logit(key, msg) char *key; char *msg; { time_t now; struct tm *p; char buf[512]; time(&now); p = localtime(&now); sprintf(buf, "%02d/%02d %02d:%02d:%02d %-13s%s\n", p->tm_mon + 1, p->tm_mday, p->tm_hour, p->tm_min, p->tm_sec, key, msg); write(flog, buf, strlen(buf)); } static void log_init() { flog = open(CHAT_LOGFILE, O_WRONLY | O_CREAT | O_APPEND, 0644); logit("START", "chat daemon"); } static void log_close() { close(flog); } #ifdef DEBUG static void debug_user() { register ChatUser *user; int i; char buf[80]; i = 0; for (user = mainuser; user; user = user->unext) { sprintf(buf, "%d) %s %s", ++i, user->userid, user->chatid); logit("DEBUG_U", buf); } } static void debug_room() { register ChatRoom *room; int i; char buf[80]; i = 0; room = &mainroom; do { sprintf(buf, "%d) %s %d", ++i, room->name, room->occupants); logit("DEBUG_R", buf); } while (room = room->next); } #endif /* DEBUG */ /* ----------------------------------------------------- */ /* string routines */ /* ----------------------------------------------------- */ static int valid_chatid(register char *id) { register int ch, len; for(len = 0; (ch = *id); id++) { /* Thor: check for endless */ MYDOG; if(ch == '/' || ch == '*' || ch == ':') return 0; if(++len > 8) return 0; } return len; } /* Case Independent strcmp : 1 ==> euqal */ static int str_equal(s1, s2) register unsigned char *s1, *s2; /* Thor: 加上 unsigned, * 避免中文的問題 */ { register int c1, c2; for (;;) { /* Thor: check for endless */ MYDOG; c1 = *s1; if (c1 >= 'A' && c1 <= 'Z') c1 |= 32; c2 = *s2; if (c2 >= 'A' && c2 <= 'Z') c2 |= 32; if (c1 != c2) return 0; if (!c1) return 1; s1++; s2++; } } /* ----------------------------------------------------- */ /* match strings' similarity case-insensitively */ /* ----------------------------------------------------- */ /* str_match(keyword, string) */ /* ----------------------------------------------------- */ /* 0 : equal ("foo", "foo") */ /* -1 : mismatch ("abc", "xyz") */ /* ow : similar ("goo", "good") */ /* ----------------------------------------------------- */ static int str_match(s1, s2) register unsigned char *s1, *s2; /* Thor: 加上 unsigned, * 避免中文的問題 */ { register int c1, c2; for (;;) { /* Thor: check for endless */ MYDOG; c2 = *s2; c1 = *s1; if (!c1) { return c2; } if (c1 >= 'A' && c1 <= 'Z') c1 |= 32; if (c2 >= 'A' && c2 <= 'Z') c2 |= 32; if (c1 != c2) return -1; s1++; s2++; } } /* ----------------------------------------------------- */ /* search user/room by its ID */ /* ----------------------------------------------------- */ static ChatUser * cuser_by_userid(userid) char *userid; { register ChatUser *cu; for (cu = mainuser; cu; cu = cu->unext) { MYDOG; if (str_equal(userid, cu->userid)) break; } return cu; } static ChatUser * cuser_by_chatid(chatid) char *chatid; { register ChatUser *cu; for (cu = mainuser; cu; cu = cu->unext) { MYDOG; if (str_equal(chatid, cu->chatid)) break; } return cu; } static ChatUser * fuzzy_cuser_by_chatid(chatid) char *chatid; { register ChatUser *cu, *xuser; int mode; xuser = NULL; for (cu = mainuser; cu; cu = cu->unext) { MYDOG; mode = str_match(chatid, cu->chatid); if (mode == 0) return cu; if (mode > 0) { if (xuser == NULL) xuser = cu; else return FUZZY_USER; /* 符合者大於 2 人 */ } } return xuser; } static ChatRoom *croom_by_roomid(char *roomid) { register ChatRoom *room; room = &mainroom; do { MYDOG; if(str_equal(roomid, room->name)) break; } while((room = room->next)); return room; } /* ----------------------------------------------------- */ /* UserList routines */ /* ----------------------------------------------------- */ static void list_free(list) UserList *list; { UserList *tmp; while (list) { MYDOG; tmp = list->next; free(list); MYDOG; list = tmp; } } static void list_add(list, user) UserList **list; ChatUser *user; { UserList *node; MYDOG; if((node = (UserList *) malloc(sizeof(UserList)))) { /* Thor: 防止空間不夠 */ strcpy(node->userid, user->userid); node->userno = user->userno; node->next = *list; *list = node; } MYDOG; } static int list_delete(list, userid) UserList **list; char *userid; { UserList *node; while((node = *list)) { MYDOG; if (str_equal(node->userid, userid)) { *list = node->next; MYDOG; free(node); MYDOG; return 1; } list = &node->next; /* Thor: list要跟著前進 */ } return 0; } static int list_belong(list, userno) UserList *list; int userno; { while (list) { MYDOG; if (userno == list->userno) return 1; list = list->next; } return 0; } /* ------------------------------------------------------ */ /* non-blocking socket routines : send message to users */ /* ------------------------------------------------------ */ static void Xdo_send(nfds, wset, msg, number) int nfds; fd_set *wset; char *msg; int number; { int sr; /* Thor: for future reservation bug */ zerotv.tv_sec = 0; zerotv.tv_usec = 16384; /* Ptt: 改成16384 避免不按時for loop吃cpu time 16384 約每秒64次 */ MYDOG; sr = select(nfds + 1, NULL, wset, NULL, &zerotv); MYDOG; if (sr > 0) { register int len; len = strlen(msg) + 1; while (nfds >= 0) { MYDOG; if (FD_ISSET(nfds, wset)) { MYDOG; send(nfds, msg, len, 0);/* Thor: 如果buffer滿了, 仍會 block */ MYDOG; if (--sr <= 0) return; } nfds--; } } } static void send_to_room(room, msg, userno, number) ChatRoom *room; char *msg; int userno; int number; { ChatUser *cu; fd_set wset, *wptr; int sock, max; static char sendbuf[256]; int clitype; /* 分為 bbs client 及 common client 兩次處理 */ for (clitype = (number == MSG_MESSAGE || !number) ? 0 : 1; clitype < 2; clitype++) { FD_ZERO(wptr = &wset); max = -1; for (cu = mainuser; cu; cu = cu->unext) { MYDOG; if (room == cu->room || room == ROOM_ALL) { if (cu->clitype == clitype && (!userno || !list_belong(cu->ignore, userno))) { sock = cu->sock; FD_SET(sock, wptr); if (max < sock) max = sock; } } } if (max < 0) continue; if (clitype) { if (strlen(msg)) sprintf(sendbuf, "%3d %s", number, msg); else sprintf(sendbuf, "%3d", number); Xdo_send(max, wptr, sendbuf); } else Xdo_send(max, wptr, msg); } } static void send_to_user(user, msg, userno, number) ChatUser *user; char *msg; int userno; int number; { if (!user->clitype && number && number != MSG_MESSAGE) return; if (!userno || !list_belong(user->ignore, userno)) { fd_set wset, *wptr; int sock; static char sendbuf[256]; sock = user->sock; FD_ZERO(wptr = &wset); FD_SET(sock, wptr); if (user->clitype) { if (strlen(msg)) sprintf(sendbuf, "%3d %s", number, msg); else sprintf(sendbuf, "%3d", number); Xdo_send(sock, wptr, sendbuf); } else Xdo_send(sock, wptr, msg); } } #if 0 static void send_to_sock(sock, msg) /* Thor: unused */ int sock; char *msg; { fd_set wset, *wptr; FD_ZERO(wptr = &wset); FD_SET(sock, wptr); Xdo_send(sock, wptr, msg); } #endif /* ----------------------------------------------------- */ static void room_changed(room) ChatRoom *room; { if (!room) return; sprintf(chatbuf, "= %s %d %d %s", room->name, room->occupants, room->rflag, room->topic); send_to_room(ROOM_ALL, chatbuf, 0, MSG_ROOMNOTIFY); } static void user_changed(cu) ChatUser *cu; { if (!cu) return; sprintf(chatbuf, "= %s %s %s %s", cu->userid, cu->chatid, cu->room->name, cu->lasthost); if (ROOMOP(cu)) strcat(chatbuf, " Op"); send_to_room(cu->room, chatbuf, 0, MSG_USERNOTIFY); } static void exit_room(user, mode, msg) ChatUser *user; int mode; char *msg; { ChatRoom *room; if((room = user->room)) { user->room = NULL; user->uflag &= ~PERM_ROOMOP; if (--room->occupants > 0) { char *chatid; chatid = user->chatid; switch (mode) { case EXIT_LOGOUT: sprintf(chatbuf, "◆ %s 離開了 ...", chatid); if (msg && *msg) { strcat(chatbuf, ": "); msg[79] = 0; /* Thor:防止太長 */ strncat(chatbuf, msg, 80); } break; case EXIT_LOSTCONN: sprintf(chatbuf, "◆ %s 成了斷線的風箏囉", chatid); break; case EXIT_KICK: sprintf(chatbuf, "◆ 哈哈！%s 被踢出去了", chatid); break; } if (!CLOAK(user)) /* Thor: 聊天室隱身術 */ send_to_room(room, chatbuf, 0, MSG_MESSAGE); sprintf(chatbuf, "- %s", user->userid); send_to_room(room, chatbuf, 0, MSG_USERNOTIFY); room_changed(room); return; } else if (room != &mainroom) { /* Thor: 人數為0時,不是mainroom才free */ register ChatRoom *next; #ifdef DEBUG debug_room(); #endif sprintf(chatbuf, "- %s", room->name); send_to_room(ROOM_ALL, chatbuf, 0, MSG_ROOMNOTIFY); room->prev->next = room->next; if((next = room->next)) next->prev = room->prev; list_free(room->invite); MYDOG; free(room); MYDOG; #ifdef DEBUG debug_room(); #endif } } } /* ----------------------------------------------------- */ /* chat commands */ /* ----------------------------------------------------- */ /* ----------------------------------------------------- */ /* (.ACCT) 使用者帳號 (account) subroutines */ /* ----------------------------------------------------- */ static char datemsg[32]; char * Ctime(clock) time_t *clock; { struct tm *t = localtime(clock); static char week[] = "日一二三四五六"; sprintf(datemsg, "%d年%2d月%2d日%3d:%02d:%02d 星期%.2s", t->tm_year - 11, t->tm_mon + 1, t->tm_mday, t->tm_hour, t->tm_min, t->tm_sec, &week[t->tm_wday << 1]); return (datemsg); } static void chat_query(cu, msg) ChatUser *cu; char *msg; { char str[256]; int i; ACCT xuser; FILE *fp; if (acct_load(&xuser, msg) >= 0) { sprintf(chatbuf, "%s(%s) 共上站 %d 次，文章 %d 篇", xuser.userid, xuser.username, xuser.numlogins, xuser.numposts); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); sprintf(chatbuf, "最近(%s)從(%s)上站", Ctime(&xuser.lastlogin), (xuser.lasthost[0] ? xuser.lasthost : "外太空")); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); usr_fpath(chatbuf, xuser.userid, "plans"); fp = fopen(chatbuf, "rt"); i = 0; while (fp && fgets(str, 256, fp)) { if (!strlen(str)) continue; str[strlen(str) - 1] = 0; send_to_user(cu, str, 0, MSG_MESSAGE); if (++i >= MAX_QUERYLINES) break; } fclose(fp); } else { sprintf(chatbuf, msg_no_such_id, msg); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } } static void chat_clear(cu, msg) ChatUser *cu; char *msg; { if (cu->clitype) send_to_user(cu, "", 0, MSG_CLRSCR); else send_to_user(cu, "/c", 0, MSG_MESSAGE); } static void chat_date(cu, msg) ChatUser *cu; char *msg; { time_t thetime; time(&thetime); sprintf(chatbuf, "◆ 標準時間: %s", Ctime(&thetime)); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } static void chat_topic(cu, msg) ChatUser *cu; char *msg; { ChatRoom *room; char *topic; if (!ROOMOP(cu) && !OPENTOPIC(cu->room)) { send_to_user(cu, msg_not_op, 0, MSG_MESSAGE); return; } if (*msg == '\0') { send_to_user(cu, "※ 請指定話題", 0, MSG_MESSAGE); return; } room = cu->room; topic = room->topic; /* Thor: room 有可能 NULL嗎?? */ strncpy(topic, msg, 47); topic[47] = '\0'; if (cu->clitype) send_to_room(room, topic, 0, MSG_TOPIC); else { sprintf(chatbuf, "/t%s", topic); send_to_room(room, chatbuf, 0, 0); } room_changed(room); sprintf(chatbuf, "◆ %s 將話題改為 %s", cu->chatid, topic); if (!CLOAK(cu)) /* Thor: 聊天室隱身術 */ send_to_room(room, chatbuf, 0, MSG_MESSAGE); } static void chat_version(cu, msg) ChatUser *cu; char *msg; { sprintf(chatbuf, "%d %d", XCHAT_VERSION_MAJOR, XCHAT_VERSION_MINOR); send_to_user(cu, chatbuf, 0, MSG_VERSION); } static void chat_nick(cu, msg) ChatUser *cu; char *msg; { char *chatid, *str; ChatUser *xuser; chatid = nextword(&msg); chatid[8] = '\0'; if (!valid_chatid(chatid)) { send_to_user(cu, "※ 這個聊天代號是不正確的", 0, MSG_MESSAGE); return; } xuser = cuser_by_chatid(chatid); if (xuser != NULL && xuser != cu) { send_to_user(cu, "※ 已經有人捷足先登囉", 0, MSG_MESSAGE); return; } str = cu->chatid; sprintf(chatbuf, "※ %s 將聊天代號改為 %s", str, chatid); if (!CLOAK(cu)) /* Thor: 聊天室隱身術 */ send_to_room(cu->room, chatbuf, cu->userno, MSG_MESSAGE); strcpy(str, chatid); user_changed(cu); if (cu->clitype) send_to_user(cu, chatid, 0, MSG_NICK); else { sprintf(chatbuf, "/n%s", chatid); send_to_user(cu, chatbuf, 0, 0); } } static void chat_list_rooms(cuser, msg) ChatUser *cuser; char *msg; { ChatRoom *cr, *room; if (RESTRICTED(cuser)) { send_to_user(cuser, "※ 您沒有權限列出現有的聊天室", 0, MSG_MESSAGE); return; } if (common_client_command) send_to_user(cuser, "", 0, MSG_ROOMLISTSTART); else send_to_user(cuser, " 談天室名稱 │人數│話題 ", 0, MSG_MESSAGE); room = cuser->room; cr = &mainroom; do { MYDOG; if (!SECRET(cr) || CHATSYSOP(cuser) || (cr == room && ROOMOP(cuser))) { if (common_client_command) { sprintf(chatbuf, "%s %d %d %s", cr->name, cr->occupants, cr->rflag, cr->topic); send_to_user(cuser, chatbuf, 0, MSG_ROOMLIST); } else { sprintf(chatbuf, " %-12s│%4d│%s", cr->name, cr->occupants, cr->topic); if (LOCKED(cr)) strcat(chatbuf, " [鎖住]"); if (SECRET(cr)) strcat(chatbuf, " [秘密]"); if (OPENTOPIC(cr)) strcat(chatbuf, " [話題]"); send_to_user(cuser, chatbuf, 0, MSG_MESSAGE); } } } while((cr = cr->next)); if (common_client_command) send_to_user(cuser, "", 0, MSG_ROOMLISTEND); } static void chat_do_user_list(cu, msg, theroom) ChatUser *cu; char *msg; ChatRoom *theroom; { ChatRoom *myroom, *room; ChatUser *user; int start, stop, curr = 0; start = atoi(nextword(&msg)); stop = atoi(nextword(&msg)); myroom = cu->room; #ifdef DEBUG logit(cu->chatid, "do user list"); #endif if (common_client_command) send_to_user(cu, "", 0, MSG_USERLISTSTART); else send_to_user(cu, " 聊天代號│使用者代號 │聊天室 ", 0, MSG_MESSAGE); for (user = mainuser; user; user = user->unext) { MYDOG; room = user->room; if ((theroom != ROOM_ALL) && (theroom != room)) continue; if (myroom != room) { if (RESTRICTED(cu) || (room && SECRET(room) && !CHATSYSOP(cu))) continue; } if (CLOAK(user)) /* Thor: 隱身術 */ continue; curr++; if (start && curr < start) continue; else if (stop && (curr > stop)) break; if (common_client_command) { if (!room) continue; /* Xshadow: 還沒進入任何房間的就不列出 */ sprintf(chatbuf, "%s %s %s %s", user->chatid, user->userid, room->name, user->lasthost); if (ROOMOP(user)) strcat(chatbuf, " Op"); } else { sprintf(chatbuf, " %-8s│%-12s│%s", user->chatid, user->userid, room ? room->name : "[在門口徘徊]"); if (ROOMOP(user)) strcat(chatbuf, " [Op]"); } #ifdef DEBUG logit("list_U", chatbuf); #endif send_to_user(cu, chatbuf, 0, common_client_command ? MSG_USERLIST : MSG_MESSAGE); } if (common_client_command) send_to_user(cu, "", 0, MSG_USERLISTEND); } static void chat_list_by_room(cu, msg) ChatUser *cu; char *msg; { ChatRoom *whichroom; char *roomstr; roomstr = nextword(&msg); if (*roomstr == '\0') whichroom = cu->room; else { if ((whichroom = croom_by_roomid(roomstr)) == NULL) { sprintf(chatbuf, "※ 沒有 [%s] 這個聊天室", roomstr); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } if (whichroom != cu->room && SECRET(whichroom) && !CHATSYSOP(cu)) { /* Thor: 要不要測同一room雖SECRET但可以列? * Xshadow: 我改成同一 room 就可以列 */ send_to_user(cu, "※ 無法列出在秘密聊天室的使用者", 0, MSG_MESSAGE); return; } } chat_do_user_list(cu, msg, whichroom); } static void chat_list_users(cu, msg) ChatUser *cu; char *msg; { chat_do_user_list(cu, msg, ROOM_ALL); } static void chat_chatroom(cu, msg) ChatUser *cu; char *msg; { if (common_client_command) send_to_user(cu, "批踢踢茶藝館 4 21", 0, MSG_CHATROOM); } static void chat_map_chatids(cu, whichroom) ChatUser *cu; /* Thor: 還沒有作不同間的 */ ChatRoom *whichroom; { int c; ChatRoom *myroom, *room; ChatUser *user; /* myroom = cu->room; */ myroom = whichroom; send_to_user(cu, " 聊天代號 使用者代號 │ 聊天代號 使用者代號 │ 聊天代號 使用者代號 ", 0, MSG_MESSAGE); c = 0; for (user = mainuser; user; user = user->unext) { MYDOG; room = user->room; MYDOG; if (whichroom != ROOM_ALL && whichroom != room) continue; MYDOG; if (myroom != room) { if (RESTRICTED(cu) || /* Thor: 要先check room 是不是空的 */ (room && SECRET(room) && !CHATSYSOP(cu))) continue; } MYDOG; if (CLOAK(user)) /* Thor:隱身術 */ continue; sprintf(chatbuf + (c * 24), " %-8s%c%-12s%s", user->chatid, ROOMOP(user) ? '*' : ' ', user->userid, (c < 2 ? "│" : " ")); MYDOG; if (++c == 3) { send_to_user(cu, chatbuf, 0, MSG_MESSAGE); c = 0; } MYDOG; } if (c > 0) send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } static void chat_map_chatids_thisroom(cu, msg) ChatUser *cu; char *msg; { chat_map_chatids(cu, cu->room); } static void chat_setroom(cu, msg) ChatUser *cu; char *msg; { char *modestr; ChatRoom *room; char *chatid; int sign; int flag; char *fstr = NULL; if (!ROOMOP(cu)) { send_to_user(cu, msg_not_op, 0, MSG_MESSAGE); return; } modestr = nextword(&msg); sign = 1; if (*modestr == '+') modestr++; else if (*modestr == '-') { modestr++; sign = 0; } if (*modestr == '\0') { send_to_user(cu, "※ 請指定狀態: {[+(設定)][-(取消)]}{[l(鎖住)][s(秘密)][t(開放話題)}", 0, MSG_MESSAGE); return; } room = cu->room; chatid = cu->chatid; while (*modestr) { flag = 0; switch (*modestr) { case 'l': case 'L': flag = ROOM_LOCKED; fstr = "鎖住"; break; case 's': case 'S': flag = ROOM_SECRET; fstr = "秘密"; break; case 't': case 'T': flag = ROOM_OPENTOPIC; fstr = "開放話題"; break; case 'h': case 'H': flag = ROOM_OPENTOPIC; fstr = "舉手發言"; break; default: sprintf(chatbuf, "※ 狀態錯誤：[%c]", *modestr); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } /* Thor: check room 是不是空的, 應該不是空的 */ if (flag && (room->rflag & flag) != sign * flag) { room->rflag ^= flag; sprintf(chatbuf, "※ 本聊天室被 %s %s [%s] 狀態", chatid, sign ? "設定為" : "取消", fstr); if (!CLOAK(cu)) /* Thor: 聊天室隱身術 */ send_to_room(room, chatbuf, 0, MSG_MESSAGE); } modestr++; } room_changed(room); } static char *chat_msg[] = { "[//]help", "MUD-like 社交動詞", "[/h]elp op", "談天室管理員專用指令", "[/a]ct ", "做一個動作", "[/b]ye [msg]", "道別", "[/c]lear [/d]ate", "清除螢幕 目前時間", /* "[/d]ate", "目前時間", *//* Thor: 指令太多 */ #if 0 "[/f]ire ", "發送熱訊", /* Thor.0727: 和 flag 衝key */ #endif "[/i]gnore [user]", "忽略使用者", "[/j]oin ", "建立或加入談天室", "[/l]ist [start [stop]]", "列出談天室使用者", "[/m]sg ", "跟 說悄悄話", "[/n]ick ", "將談天代號換成 ", "[/p]ager", "切換呼叫器", "[/q]uery ", "查詢網友", "[/r]oom", "列出一般談天室", "[/t]ape", "開關錄音機", "[/u]nignore ", "取消忽略", #if 0 "[/u]sers", "列出站上使用者", #endif "[/w]ho", "列出本談天室使用者", "[/w]hoin ", "列出談天室 的使用者", NULL }; static char *room_msg[] = { "[/f]lag [+-][lsth]", "設定鎖定、秘密、開放話題、舉手發言", "[/i]nvite ", "邀請 加入談天室", "[/kick] ", "將 踢出談天室", "[/o]p ", "將 Op 的權力轉移給 ", "[/topic] ", "換個話題", "[/w]all", "廣播 (站長專用)", NULL }; static void chat_help(cu, msg) ChatUser *cu; char *msg; { char **table, *str; if (str_equal(nextword(&msg), "op")) { send_to_user(cu, "談天室管理員專用指令", 0, MSG_MESSAGE); table = room_msg; } else { table = chat_msg; } while((str = *table++)) { sprintf(chatbuf, " %-20s- %s", str, *table++); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } } static void chat_private(cu, msg) ChatUser *cu; char *msg; { char *recipient; ChatUser *xuser; int userno; userno = 0; recipient = nextword(&msg); xuser = (ChatUser *) fuzzy_cuser_by_chatid(recipient); if (xuser == NULL) { /* Thor.0724: 用 userid也可傳悄悄話 */ xuser = cuser_by_userid(recipient); } if (xuser == NULL) { sprintf(chatbuf, msg_no_such_id, recipient); } else if (xuser == FUZZY_USER) { /* ambiguous */ strcpy(chatbuf, "※ 請指明聊天代號"); } else if (*msg) { userno = cu->userno; sprintf(chatbuf, "*%s* ", cu->chatid); msg[79] = 0; /* Thor:防止太長 */ strncat(chatbuf, msg, 80); send_to_user(xuser, chatbuf, userno, MSG_MESSAGE); if (xuser->clitype) { /* Xshadow: 如果對方是用 client 上來的 */ sprintf(chatbuf, "%s %s ", cu->userid, cu->chatid); msg[79] = 0; strncat(chatbuf, msg, 80); send_to_user(xuser, chatbuf, userno, MSG_PRIVMSG); } if (cu->clitype) { sprintf(chatbuf, "%s %s ", xuser->userid, xuser->chatid); msg[79] = 0; strncat(chatbuf, msg, 80); send_to_user(cu, chatbuf, 0, MSG_MYPRIVMSG); } sprintf(chatbuf, "%s> ", xuser->chatid); strncat(chatbuf, msg, 80); } else { sprintf(chatbuf, "※ 您想對 %s 說什麼話呢？", xuser->chatid); } send_to_user(cu, chatbuf, userno, MSG_MESSAGE); /* Thor: userno 要改成 0 * 嗎? */ } static void chat_cloak(cu, msg) ChatUser *cu; char *msg; { if (CHATSYSOP(cu)) { cu->uflag ^= PERM_CLOAK; sprintf(chatbuf, "◆ %s", CLOAK(cu) ? MSG_CLOAKED : MSG_UNCLOAK); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } } /* ----------------------------------------------------- */ static void arrive_room(cuser, room) ChatUser *cuser; ChatRoom *room; { char *rname; /* Xshadow: 不必送給自己, 反正換房間就會重新 build user list */ sprintf(chatbuf, "+ %s %s %s %s", cuser->userid, cuser->chatid, room->name, cuser->lasthost); if (ROOMOP(cuser)) strcat(chatbuf, " Op"); send_to_room(room, chatbuf, 0, MSG_USERNOTIFY); cuser->room = room; room->occupants++; rname = room->name; room_changed(room); if (cuser->clitype) { send_to_user(cuser, rname, 0, MSG_ROOM); send_to_user(cuser, room->topic, 0, MSG_TOPIC); } else { sprintf(chatbuf, "/r%s", rname); send_to_user(cuser, chatbuf, 0, 0); sprintf(chatbuf, "/t%s", room->topic); send_to_user(cuser, chatbuf, 0, 0); } sprintf(chatbuf, "※ %s 進入 [%s] 包廂", cuser->chatid, rname); if (!CLOAK(cuser)) /* Thor: 聊天室隱身術 */ send_to_room(room, chatbuf, cuser->userno, MSG_MESSAGE); } static int enter_room(cuser, rname, msg) ChatUser *cuser; char *rname; char *msg; { ChatRoom *room; int create; create = 0; room = croom_by_roomid(rname); if (room == NULL) { /* new room */ #ifdef MONITOR logit(cuser->userid, "create new room"); #endif MYDOG; room = (ChatRoom *) malloc(sizeof(ChatRoom)); MYDOG; if (room == NULL) { send_to_user(cuser, "※ 無法再新闢包廂了", 0, MSG_MESSAGE); return 0; } memset(room, 0, sizeof(ChatRoom)); memcpy(room->name, rname, IDLEN - 1); strcpy(room->topic, "這是一個新天地"); sprintf(chatbuf, "+ %s 1 0 %s", room->name, room->topic); send_to_room(ROOM_ALL, chatbuf, 0, MSG_ROOMNOTIFY); if (mainroom.next != NULL) mainroom.next->prev = room; room->next = mainroom.next; mainroom.next = room; room->prev = &mainroom; create = 1; } else { if (cuser->room == room) { sprintf(chatbuf, "※ 您本來就在 [%s] 聊天室囉 :)", rname); send_to_user(cuser, chatbuf, 0, MSG_MESSAGE); return 0; } if (!CHATSYSOP(cuser) && LOCKED(room) && !list_belong(room->invite, cuser->userno)) { send_to_user(cuser, "※ 內有惡犬，非請莫入", 0, MSG_MESSAGE); return 0; } } exit_room(cuser, EXIT_LOGOUT, msg); arrive_room(cuser, room); if (create) cuser->uflag |= PERM_ROOMOP; return 0; } static void logout_user(cuser) ChatUser *cuser; { int sock; ChatUser *xuser, *prev; #ifdef DEBUG logit("before", "logout"); debug_user(); #endif sock = cuser->sock; shutdown(sock, 2); close(sock); MYDOG; FD_CLR(sock, &mainfds); #if 0 /* Thor: 也許不差這一個 */ if (sock >= maxfds) maxfds = sock - 1; #endif list_free(cuser->ignore); #ifdef DEBUG debug_user(); #endif xuser = mainuser; if (xuser == cuser) { mainuser = cuser->unext; } else { do { prev = xuser; xuser = xuser->unext; if (xuser == cuser) { prev->unext = cuser->unext; break; } } while (xuser); } MYDOG; #ifdef DEBUG sprintf(chatbuf, "%p", cuser); logit("free cuser", chatbuf); #endif free(cuser); #ifdef DEBUG logit("after", "logout"); debug_user(); #endif #if 0 next = cuser->next; prev = cuser->prev; prev->next = next; if (next) next->prev = prev; if (cuser) free(cuser); MYDOG; #endif totaluser--; } static void print_user_counts(cuser) ChatUser *cuser; { ChatRoom *room; int num, userc, suserc, roomc, number; userc = suserc = roomc = 0; room = &mainroom; do { MYDOG; num = room->occupants; if (SECRET(room)) { suserc += num; if (CHATSYSOP(cuser)) roomc++; } else { userc += num; roomc++; } } while((room = room->next)); number = (cuser->clitype) ? MSG_MOTD : MSG_MESSAGE; sprintf(chatbuf, "☉ 歡迎光臨【批踢踢茶藝館】，目前開了 %d 間包廂", roomc); send_to_user(cuser, chatbuf, 0, number); sprintf(chatbuf, "☉ 共有 %d 人來擺\龍門陣", userc); if (suserc) sprintf(chatbuf + strlen(chatbuf), " [%d 人在秘密聊天室]", suserc); send_to_user(cuser, chatbuf, 0, number); } static int login_user(cu, msg) ChatUser *cu; char *msg; { int utent; char *level; char *userid; char *chatid; struct sockaddr_in from; int fromlen; struct hostent *hp; ACCT acct; char buf[20]; /* * Thor.0819: SECURED_CHATROOM : /! userid chatid passwd , userno * el 在check完passwd後取得 */ /* Xshadow.0915: common client support : /-! userid chatid password */ /* 傳參數：userlevel, userid, chatid */ /* client/server 版本依據 userid 抓 .PASSWDS 判斷 userlevel */ userid = nextword(&msg); chatid = nextword(&msg); #ifdef DEBUG logit("ENTER", userid); #endif /* Thor.0730: parse space before passwd */ level = msg; /* Thor.0813: 跳過一空格即可, 因為反正如果chatid有空格, 密碼也不對 */ /* 就算密碼對, 也不會怎麼樣:p */ /* 可是如果密碼第一個字是空格, 那跳太多空格會進不來... */ if (*level == ' ') level++; /* Thor.0729: load acct */ if (!*userid || (acct_load(&acct, userid) < 0)) { #ifdef DEBUG logit("noexist", chatid); #endif if (cu->clitype) send_to_user(cu, "錯誤的使用者代號", 0, ERR_LOGIN_NOSUCHUSER); else send_to_user(cu, CHAT_LOGIN_INVALID, 0, 0); return -1; } else if(strncmp(level, acct.passwd, PASSLEN) && !chkpasswd(acct.passwd, level)) { #ifdef DEBUG logit("fake", chatid); #endif if (cu->clitype) send_to_user(cu, "密碼錯誤", 0, ERR_LOGIN_PASSERROR); else send_to_user(cu, CHAT_LOGIN_INVALID, 0, 0); return -1; } else { /* Thor.0729: if ok, read level. */ sprintf(buf, "%d", acct.userlevel); level = buf; /* Thor.0819: read userno for client/server bbs */ utent = searchuser(acct.userid); } /* Thor.0819: for client/server bbs */ /* for (xuser = mainuser; xuser; xuser = xuser->unext) { MYDOG; if (xuser->userno == utent) { #ifdef DEBUG logit("enter", "bogus"); #endif if (cu->clitype) send_to_user(cu, "請勿派遣分身進入聊天室 !!", 0, ERR_LOGIN_USERONLINE); else send_to_user(cu, CHAT_LOGIN_BOGUS, 0, 0); return -1; } } */ if (!valid_chatid(chatid)) { #ifdef DEBUG logit("enter", chatid); #endif if (cu->clitype) send_to_user(cu, "不合法的聊天室代號 !!", 0, ERR_LOGIN_NICKERROR); else send_to_user(cu, CHAT_LOGIN_INVALID, 0, 0); return 0; } #ifdef DEBUG debug_user(); #endif if (cuser_by_chatid(chatid) != NULL) { /* chatid in use */ #ifdef DEBUG logit("enter", "duplicate"); #endif if (cu->clitype) send_to_user(cu, "這個代號已經有人使用", 0, ERR_LOGIN_NICKINUSE); else send_to_user(cu, CHAT_LOGIN_EXISTS, 0, 0); return 0; } cu->userno = utent; cu->uflag = atoi(level) & ~(PERM_ROOMOP | PERM_CLOAK | PERM_HANDUP | PERM_SAY); /* Thor: 進來先清空ROOMOP(同PERM_CHAT), CLOAK */ strcpy(cu->userid, userid); memcpy(cu->chatid, chatid, 8); cu->chatid[8] = '\0'; /* Xshadow: 取得 client 的來源 */ fromlen = sizeof(from); if (!getpeername(cu->sock, (struct sockaddr *) & from, &fromlen)) { if ((hp = gethostbyaddr((char *) &from.sin_addr, sizeof(struct in_addr), from.sin_family))) { strcpy(cu->lasthost, hp->h_name); } else strcpy(cu->lasthost, (char *) inet_ntoa(from.sin_addr)); } else { strcpy(cu->lasthost, "[外太空]"); } if (cu->clitype) send_to_user(cu, "順利", 0, MSG_LOGINOK); else send_to_user(cu, CHAT_LOGIN_OK, 0, 0); arrive_room(cu, &mainroom); send_to_user(cu, "", 0, MSG_MOTDSTART); print_user_counts(cu); send_to_user(cu, "", 0, MSG_MOTDEND); #ifdef DEBUG logit("enter", "OK"); #endif return 0; } static void chat_act(cu, msg) ChatUser *cu; char *msg; { if (*msg && (!RHANDUP(cu->room) || SAY(cu) || ROOMOP(cu))) { sprintf(chatbuf, "%s %s", cu->chatid, msg); send_to_room(cu->room, chatbuf, cu->userno, MSG_MESSAGE); } } static void chat_ignore(cu, msg) ChatUser *cu; char *msg; { if (RESTRICTED(cu)) { strcpy(chatbuf, "※ 您沒有 ignore 別人的權利"); } else { char *ignoree; ignoree = nextword(&msg); if (*ignoree) { ChatUser *xuser; xuser = cuser_by_userid(ignoree); if (xuser == NULL) { sprintf(chatbuf, msg_no_such_id, ignoree); #if 0 sprintf(chatbuf, "◆ 談天室現在沒有 [%s] 這號人物", ignoree); #endif } else if (xuser == cu || CHATSYSOP(xuser) || (ROOMOP(xuser) && (xuser->room == cu->room))) { sprintf(chatbuf, "◆ 不可以 ignore [%s]", ignoree); } else { if (list_belong(cu->ignore, xuser->userno)) { sprintf(chatbuf, "※ %s 已經被凍結了", xuser->chatid); } else { list_add(&(cu->ignore), xuser); sprintf(chatbuf, "◆ 將 [%s] 打入冷宮了 :p", xuser->chatid); } } } else { UserList *list; if((list = cu->ignore)) { int len; char buf[16]; send_to_user(cu, "◆ 這些人被打入冷宮了：", 0, MSG_MESSAGE); len = 0; do { sprintf(buf, "%-13s", list->userid); strcpy(chatbuf + len, buf); len += 13; if (len >= 78) { send_to_user(cu, chatbuf, 0, MSG_MESSAGE); len = 0; } } while((list = list->next)); if (len == 0) return; } else { strcpy(chatbuf, "◆ 您目前並沒有 ignore 任何人"); } } } send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } static void chat_unignore(cu, msg) ChatUser *cu; char *msg; { char *ignoree; ignoree = nextword(&msg); if (*ignoree) { sprintf(chatbuf, (list_delete(&(cu->ignore), ignoree)) ? "◆ [%s] 不再被你冷落了" : "◆ 您並未 ignore [%s] 這號人物", ignoree); } else { strcpy(chatbuf, "◆ 請指明 user ID"); } send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } static void chat_join(cu, msg) ChatUser *cu; char *msg; { if (RESTRICTED(cu)) { send_to_user(cu, "※ 您沒有加入其他聊天室的權限", 0, MSG_MESSAGE); } else { char *roomid = nextword(&msg); if (*roomid) enter_room(cu, roomid, msg); else send_to_user(cu, "※ 請指定聊天室的名字", 0, MSG_MESSAGE); } } static void chat_kick(cu, msg) ChatUser *cu; char *msg; { char *twit; ChatUser *xuser; ChatRoom *room; if (!ROOMOP(cu)) { send_to_user(cu, msg_not_op, 0, MSG_MESSAGE); return; } twit = nextword(&msg); xuser = cuser_by_chatid(twit); if (xuser == NULL) { sprintf(chatbuf, msg_no_such_id, twit); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } room = cu->room; if (room != xuser->room || CLOAK(xuser)) { /* Thor: 聊天室隱身術 */ sprintf(chatbuf, msg_not_here, twit); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } if (CHATSYSOP(xuser)) { /* Thor: 踢不走 CHATSYSOP */ sprintf(chatbuf, "◆ 不可以 kick [%s]", twit); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } exit_room(xuser, EXIT_KICK, (char *) NULL); if (room == &mainroom) logout_user(xuser); else enter_room(xuser, MAIN_NAME, (char *) NULL); } static void chat_makeop(cu, msg) ChatUser *cu; char *msg; { char *newop; ChatUser *xuser; ChatRoom *room; if (!ROOMOP(cu)) { send_to_user(cu, msg_not_op, 0, MSG_MESSAGE); return; } newop = nextword(&msg); xuser = cuser_by_chatid(newop); if (xuser == NULL) { sprintf(chatbuf, msg_no_such_id, newop); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } if (cu == xuser) { sprintf(chatbuf, "※ 您早就已經是 Op 了啊"); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } room = cu->room; if (room != xuser->room || CLOAK(xuser)) { /* Thor: 聊天室隱身術 */ sprintf(chatbuf, msg_not_here, xuser->chatid); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } cu->uflag &= ~PERM_ROOMOP; xuser->uflag |= PERM_ROOMOP; user_changed(cu); user_changed(xuser); sprintf(chatbuf, "※ %s 將 Op 權力轉移給 %s", cu->chatid, xuser->chatid); if (!CLOAK(cu)) /* Thor: 聊天室隱身術 */ send_to_room(room, chatbuf, 0, MSG_MESSAGE, MSG_MESSAGE); } static void chat_invite(cu, msg) ChatUser *cu; char *msg; { char *invitee; ChatUser *xuser; ChatRoom *room; UserList **list; if (!ROOMOP(cu)) { send_to_user(cu, msg_not_op, 0, MSG_MESSAGE); return; } invitee = nextword(&msg); xuser = cuser_by_chatid(invitee); if (xuser == NULL) { sprintf(chatbuf, msg_no_such_id, invitee); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } room = cu->room; /* Thor: 是否要 check room 是否 NULL ? */ list = &(room->invite); if (list_belong(*list, xuser->userno)) { sprintf(chatbuf, "※ %s 已經接受過邀請了", xuser->chatid); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return; } list_add(list, xuser); sprintf(chatbuf, "※ %s 邀請您到 [%s] 聊天室", cu->chatid, room->name); send_to_user(xuser, chatbuf, 0, MSG_MESSAGE); /* Thor: 要不要可以 ignore? */ sprintf(chatbuf, "※ %s 收到您的邀請了", xuser->chatid); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } static void chat_broadcast(cu, msg) ChatUser *cu; char *msg; { if (!CHATSYSOP(cu)) { send_to_user(cu, "※ 您沒有在聊天室廣播的權力!", 0, MSG_MESSAGE); return; } if (*msg == '\0') { send_to_user(cu, "※ 請指定廣播內容", 0, MSG_MESSAGE); return; } sprintf(chatbuf, "※ " BBSNAME "談天室廣播中 [%s].....", cu->chatid); send_to_room(ROOM_ALL, chatbuf, 0, MSG_MESSAGE); sprintf(chatbuf, "◆ %s", msg); send_to_room(ROOM_ALL, chatbuf, 0, MSG_MESSAGE); } static void chat_goodbye(cu, msg) ChatUser *cu; char *msg; { exit_room(cu, EXIT_LOGOUT, msg); /* Thor: 要不要加 logout_user(cu) ? */ } /* --------------------------------------------- */ /* MUD-like social commands : action */ /* --------------------------------------------- */ struct ChatAction { char *verb; /* 動詞 */ char *chinese; /* 中文翻譯 */ char *part1_msg; /* 介詞 */ char *part2_msg; /* 動作 */ }; static ChatAction party_data[] = { {"aluba", "阿魯巴", "把", "架上柱子阿魯巴!!"}, {"aodre", "景仰", "對", "的景仰有如滔滔江水,連綿不絕……"}, {"bearhug", "熱擁", "熱情的擁抱", ""}, {"blade", "一刀", "一刀啟程把", "送上西天"}, {"bless", "祝福", "祝福", "心想事成"}, {"board", "主機板", "把", "抓去跪主機板"}, {"bokan", "氣功\", "雙掌微合，蓄勢待發……突然間，電光乍現，對", "使出了Ｂo--Ｋan！"}, {"bow", "鞠躬", "畢躬畢敬的向", "鞠躬"}, {"box", "幕之內", "開始輪擺\式移位，對", "作肝臟攻擊"}, {"boy", "平底鍋", "從背後拿出了平底鍋，把", "敲昏了"}, {"bye", "掰掰", "向", "說掰掰!!"}, {"call", "呼喚", "大聲的呼喚,啊~~", "啊~~~你在哪裡啊啊啊啊~~~~"}, {"caress", "輕撫", "輕輕的撫摸著", ""}, {"clap", "鼓掌", "向", "熱烈鼓掌"}, {"claw", "抓抓", "從貓咪樂園借了隻貓爪，把", "抓得死去活來"}, {"comfort", "安慰", "溫言安慰", ""}, {"cong", "恭喜", "從背後拿出了拉炮，呯！呯！恭喜", ""}, {"cpr", "口對口", "對著", "做口對口人工呼吸"}, {"cringe", "乞憐", "向", "卑躬屈膝，搖尾乞憐"}, {"cry", "大哭", "向", "嚎啕大哭"}, {"dance", "跳舞", "拉了", "的手翩翩起舞" }, {"destroy", "毀滅", "祭起了『極大毀滅咒文』，轟向", ""}, {"dogleg", "狗腿", "對", "狗腿"}, {"drivel", "流口水", "對著", "流口水"}, {"envy", "羨慕", "向", "流露出羨慕的眼光"}, {"eye", "送秋波", "對", "頻送秋波"}, {"fire", "銬問", "拿著火紅的鐵棒走向", ""}, {"forgive", "原諒", "接受道歉，原諒了", ""}, {"french", "法式吻", "把舌頭伸到", "喉嚨裡∼∼∼哇！一個浪漫的法國氏深吻"}, {"giggle", "傻笑", "對著", "傻傻的呆笑"}, {"glue", "補心", "用三秒膠，把", "的心黏了起來"}, {"goodbye", "告別", "淚\眼汪汪的向", "告別"}, {"grin", "奸笑", "對", "露出邪惡的笑容"}, {"growl", "咆哮", "對", "咆哮不已"}, {"hand", "握手", "跟", "握手"}, {"hide", "躲", "躲在", "背後"}, {"hospitl", "送醫院", "把", "送進醫院"}, {"hug", "擁抱", "輕輕地擁抱", ""}, {"hrk", "昇龍拳", "沉穩了身形，匯聚了內勁，對", "使出了一記Ｈo--Ｒyu--Ｋan！！！"}, {"jab", "戳人", "溫柔的戳著", ""}, {"judo", "過肩摔", "抓住了", "的衣襟，轉身……啊，是一記過肩摔！"}, {"kickout", "踢", "用大腳把", "踢到山下去了"}, {"kick", "踢人", "把", "踢的死去活來"}, {"kiss", "輕吻", "輕吻", "的臉頰"}, {"laugh", "嘲笑", "大聲嘲笑", ""}, {"levis", "給我", "說：給我", "！其餘免談！"}, {"lick", "舔", "狂舔", ""}, {"lobster", "壓制", "施展逆蝦形固定，把", "壓制在地板上"}, {"love", "表白", "對", "深情的表白"}, {"marry", "求婚", "捧著九百九十九朵玫瑰向", "求婚"}, {"no", "不要啊", "拼命對著", "搖頭~~~~不要啊~~~~"}, {"nod", "點頭", "向", "點頭稱是"}, {"nudge", "頂肚子", "用手肘頂", "的肥肚子"}, {"pad", "拍肩膀", "輕拍", "的肩膀"}, {"pettish", "撒嬌", "跟", "嗲聲嗲氣地撒嬌"}, {"pili", "霹靂", "使出 君子風 天地根 般若懺 三式合一打向", "~~~~~~"}, {"pinch", "擰人", "用力的把", "擰的黑青"}, {"roll", "打滾", "放出多爾袞的音樂,", "在地上滾來滾去"}, {"protect", "保護", "保護著", ""}, {"pull", "拉", "死命地拉住", "不放"}, {"punch", "揍人", "狠狠揍了", "一頓"}, {"rascal", "耍賴", "跟", "耍賴"}, {"recline", "入懷", "鑽到", "的懷裡睡著了……"}, {"respond", "負責", "安慰", "說：『不要哭，我會負責的……』"}, {"shrug", "聳肩", "無奈地向", "聳了聳肩膀"}, {"sigh", "歎氣", "對", "歎了一口氣"}, {"slap", "打耳光", "啪啪的巴了", "一頓耳光"}, {"smooch", "擁吻", "擁吻著", ""}, {"snicker", "竊笑", "嘿嘿嘿..的對", "竊笑"}, {"sniff", "不屑", "對", "嗤之以鼻"}, {"spank", "打屁屁", "用巴掌打", "的臀部"}, {"squeeze", "緊擁", "緊緊地擁抱著", ""}, {"sysop", "召喚", "叫出了批踢踢，把", "踩扁了！"}, {"thank", "感謝", "向", "感謝得五體投地"}, {"tickle", "搔癢", "咕嘰!咕嘰!搔", "的癢"}, {"wake", "搖醒", "輕輕地把", "搖醒"}, {"wave", "揮手", "對著", "拼命的搖手"}, {"welcome", "歡迎", "歡迎", "進來八卦一下"}, {"what", "什麼", "說：『", "哩公瞎密哇隴聽某?？?﹖?』"}, {"whip", "鞭子", "手上拿著蠟燭，用鞭子痛打", ""}, {"wink", "眨眼", "對", "神秘的眨眨眼睛"}, {"zap", "猛攻", "對", "瘋狂的攻擊"}, {NULL, NULL, NULL, NULL} }; static int chicken_action(cu, cmd, party) ChatUser *cu; char *cmd; char *party; { return 0; } static int party_action(cu, cmd, party) ChatUser *cu; char *cmd; char *party; { ChatAction *cap; char *verb; for (cap = party_data; (verb = cap->verb); cap++) { MYDOG; if (str_equal(cmd, verb)) { if (*party == '\0') { party = "大家"; } else { ChatUser *xuser; xuser = fuzzy_cuser_by_chatid(party); if (xuser == NULL) { /* Thor.0724: 用 userid也嘛通 */ xuser = cuser_by_userid(party); } if (xuser == NULL) { sprintf(chatbuf, msg_no_such_id, party); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return 0; } else if (xuser == FUZZY_USER) { sprintf(chatbuf, "※ 請指明聊天代號"); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return 0; } else if (cu->room != xuser->room || CLOAK(xuser)) { sprintf(chatbuf, msg_not_here, party); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); return 0; } else { party = xuser->chatid; } } sprintf(chatbuf, "%s %s %s %s", cu->chatid, cap->part1_msg, party, cap->part2_msg); send_to_room(cu->room, chatbuf, cu->userno, MSG_MESSAGE); return 0; /* Thor: cu->room 是否為 NULL? */ } } return 1; } /* --------------------------------------------- */ /* MUD-like social commands : speak */ /* --------------------------------------------- */ static ChatAction speak_data[] = { { "ask", "詢問", "問", NULL }, { "chant", "歌頌", "高聲歌頌", NULL }, { "cheer", "喝采", "喝采", NULL }, { "chuckle", "輕笑", "輕笑", NULL }, { "curse", "暗幹", "暗幹", NULL }, /* {"curse", "咒罵", NULL}, */ { "demand", "要求", "要求", NULL }, { "frown", "皺眉頭", "蹙眉", NULL }, { "groan", "呻吟", "呻吟", NULL }, { "grumble", "發牢騷", "發牢騷", NULL }, { "guitar", "彈唱", "邊彈著吉他，邊唱著", NULL }, /* {"helpme", "呼救","大聲呼救",NULL}, */ { "hum", "喃喃", "喃喃自語", NULL }, { "moan", "怨嘆", "怨嘆", NULL }, { "notice", "強調", "強調", NULL }, { "order", "命令", "命令", NULL }, { "ponder", "沈思", "沈思", NULL }, { "pout", "噘嘴", "噘著嘴說", NULL }, { "pray", "祈禱", "祈禱", NULL }, { "request", "懇求", "懇求", NULL }, { "shout", "大罵", "大罵", NULL }, { "sing", "唱歌", "唱歌", NULL }, { "smile", "微笑", "微笑", NULL }, { "smirk", "假笑", "假笑", NULL }, { "swear", "發誓", "發誓", NULL }, { "tease", "嘲笑", "嘲笑", NULL }, { "whimper", "嗚咽", "嗚咽的說", NULL }, { "yawn", "哈欠", "邊打哈欠邊說", NULL }, { "yell", "大喊", "大喊", NULL }, { NULL, NULL, NULL, NULL } }; static int speak_action(cu, cmd, msg) ChatUser *cu; char *cmd; char *msg; { ChatAction *cap; char *verb; for (cap = speak_data; (verb = cap->verb); cap++) { MYDOG; if (str_equal(cmd, verb)) { sprintf(chatbuf, "%s %s： %s", cu->chatid, cap->part1_msg, msg); send_to_room(cu->room, chatbuf, cu->userno, MSG_MESSAGE); return 0; /* Thor: cu->room 是否為 NULL? */ } } return 1; } /* -------------------------------------------- */ /* MUD-like social commands : condition */ /* -------------------------------------------- */ static ChatAction condition_data[] = { { "applaud", "拍手", "啪啪啪啪啪啪啪....", NULL }, { "ayo", "唉呦喂", "唉呦喂~~~", NULL }, { "back", "坐回來", "回來坐正繼續奮戰", NULL }, { "blood", "在血中", "倒在血泊之中", NULL }, { "blush", "臉紅", "臉都紅了", NULL }, { "broke", "心碎", "的心破碎成一片一片的", NULL }, /* Thor.0731:應觀眾要求 */ /* {"bokan", "Bo Kan! Bo Kan!", NULL}, */ { "careles", "沒人理", "嗚∼∼都沒有人理我 :~~~~", NULL }, { "chew", "嗑瓜子", "很悠閒的嗑起瓜子來了", NULL }, { "climb", "爬山", "自己慢慢爬上山來……", NULL }, { "cold", "感冒了", "感冒了,媽媽不讓我出去玩 :~~~(", NULL }, { "cough", "咳嗽", "咳了幾聲", NULL }, { "die", "暴斃", "當場暴斃", NULL }, { "faint", "昏倒", "當場昏倒", NULL }, { "flop", "香蕉皮", "踩到香蕉皮... 滑倒！", NULL }, { "fly", "飄飄然", "飄飄然", NULL }, { "frown", "蹙眉", "蹙眉", NULL }, { "gold", "拿金牌", "唱著：『金ㄍㄠˊ金ㄍㄠˊ 出國比賽! 得冠軍，拿金牌，光榮倒鄧來！』", NULL }, { "gulu", "肚子餓", "的肚子發出咕嚕~~~咕嚕~~~的聲音", NULL }, { "haha", "哇哈哈", "哇哈哈哈.....^o^", NULL }, /* {"haha", "大笑","哇哈哈哈哈哈哈哈哈~~~~!!!!!", NULL}, */ { "helpme", "求救", "大喊~~~救命啊~~~~", NULL }, { "hoho", "呵呵笑", "呵呵呵笑個不停", NULL }, { "happy", "高興", "高興得在地上打滾", NULL }, /* {"happy", "高興", "ＹＡ！ *^_^*", NULL}, */ /* {"happy", "", "r-o-O-m....聽了真爽！", NULL}, */ /* {"hurricane", "Ｈｏ---Ｒｙｕ--Ｋａｎ！！！", NULL}, */ { "idle", "呆住了", "呆住了", NULL }, { "jacky", "晃晃", "痞子般的晃來晃去", NULL }, #if 0 /* Thor.0729: 不知其意 */ { "lag", "網路慢", "lllllllaaaaaaaaaaaagggggggggggggg.................", NULL }, #endif { "luck", "幸運", "哇！福氣啦！", NULL }, { "macarn", "一種舞", "開始跳起了ＭaＣaＲeＮa∼∼∼∼", NULL }, { "miou", "喵喵", "喵喵口苗口苗∼∼∼∼∼", NULL }, { "mouth", "扁嘴", "扁嘴中!!", NULL }, { "nani", "怎麼會", "：奈ㄝ啊捏??", NULL }, { "nose", "流鼻血", "流鼻血", NULL }, { "puke", "嘔吐", "嘔吐中", NULL }, /* {"puke", "真噁心，我聽了都想吐", NULL}, */ { "rest", "休息", "休息中，請勿打擾", NULL }, { "reverse", "翻肚", "翻肚", NULL }, { "room", "開房間", "r-o-O-m-r-O-Ｏ-Mmm-rRＲ........", NULL }, { "shake", "搖頭", "搖了搖頭", NULL }, { "sleep", "睡著", "趴在鍵盤上睡著了，口水流進鍵盤，造成當機！", NULL }, /* {"sleep", "Zzzzzzzzzz，真無聊，都快睡著了", NULL}, */ { "so", "就醬子", "就醬子!!", NULL }, { "sorry", "道歉", "嗚啊!!我對不起大家,我對不起國家社會~~~~~~嗚啊~~~~~", NULL }, { "story", "講古", "開始講古了", NULL }, { "strut", "搖擺\走", "大搖大擺\地走", NULL }, { "suicide", "自殺", "自殺", NULL }, { "tea", "泡茶", "泡了壺好茶", NULL }, { "think", "思考", "歪著頭想了一下", NULL }, { "tongue", "吐舌", "吐了吐舌頭", NULL }, { "wall", "撞牆", "跑去撞牆", NULL }, { "wawa", "哇哇", "哇哇哇~~~~~!!!!! ~~~>_<~~~", NULL }, /* {"wawa","哇哇哇......>_<",NULL}, */ { "www", "汪汪", "汪汪汪!!!", NULL }, { "zzz", "打呼", "呼嚕~~~~ZZzZzｚＺZZzzZzzzZZ...", NULL }, { NULL, NULL, NULL, NULL } }; static int condition_action(cu, cmd) ChatUser *cu; char *cmd; { ChatAction *cap; char *verb; for (cap = condition_data; (verb = cap->verb); cap++) { MYDOG; if (str_equal(cmd, verb)) { sprintf(chatbuf, "%s %s", cu->chatid, cap->part1_msg); send_to_room(cu->room, chatbuf, cu->userno, MSG_MESSAGE); return 1; /* Thor: cu->room 是否為 NULL? */ } } return 0; } /* --------------------------------------------- */ /* MUD-like social commands : help */ /* --------------------------------------------- */ static char *dscrb[] = { "【 Verb + Nick： 動詞 + 對方名字 】 例：//kick piggy", "【 Verb + Message：動詞 + 要說的話 】 例：//sing 天天天藍", "【 Verb：動詞 】 ↑↓：舊話重提", NULL }; ChatAction *catbl[] = { party_data, speak_data, condition_data, NULL }; static void chat_partyinfo(cu, msg) ChatUser *cu; char *msg; { if (!common_client_command) return; /* only allow common client to retrieve it */ sprintf(chatbuf, "3 動作 交談 狀態"); send_to_user(cu, chatbuf, 0, MSG_PARTYINFO); } static void chat_party(cu, msg) ChatUser *cu; char *msg; { int kind, i; ChatAction *cap; if (!common_client_command) return; kind = atoi(nextword(&msg)); if (kind < 0 || kind > 2) return; sprintf(chatbuf, "%d %s", kind, kind == 2 ? "I" : ""); /* Xshadow: 只有 condition 才是 immediate mode */ send_to_user(cu, chatbuf, 0, MSG_PARTYLISTSTART); cap = catbl[kind]; for (i = 0; cap[i].verb; i++) { sprintf(chatbuf, "%-10s %-20s", cap[i].verb, cap[i].chinese); /* for (j=0;j<1000000;j++); */ send_to_user(cu, chatbuf, 0, MSG_PARTYLIST); } sprintf(chatbuf, "%d", kind); send_to_user(cu, chatbuf, 0, MSG_PARTYLISTEND); } #define SCREEN_WIDTH 80 #define MAX_VERB_LEN 8 #define VERB_NO 10 static void view_action_verb(cu, cmd) /* Thor.0726: 新加動詞分類顯示 */ register ChatUser *cu; char cmd; { register int i; register char *p, *q, *data, *expn; register ChatAction *cap; send_to_user(cu, "/c", 0, MSG_CLRSCR); data = chatbuf; if (cmd < '1' || cmd > '3') { /* Thor.0726: 寫得不好, 想辦法改進... */ for (i = 0; (p = dscrb[i]); i++) { sprintf(data, " [//]help %d - MUD-like 社交動詞 第 %d 類", i + 1, i + 1); MYDOG; send_to_user(cu, data, 0, MSG_MESSAGE); send_to_user(cu, p, 0, MSG_MESSAGE); send_to_user(cu, " ", 0, MSG_MESSAGE); /* Thor.0726: 換行, 需要 " " * 嗎? */ } } else { i = cmd - '1'; send_to_user(cu, dscrb[i], 0, MSG_MESSAGE); expn = chatbuf + 100; /* Thor.0726: 應該不會overlap吧? */ *data = '\0'; *expn = '\0'; cap = catbl[i]; for (i = 0; (p = cap[i].verb); i++) { MYDOG; q = cap[i].chinese; strcat(data, p); strcat(expn, q); if (((i + 1) % VERB_NO) == 0) { send_to_user(cu, data, 0, MSG_MESSAGE); send_to_user(cu, expn, 0, MSG_MESSAGE); /* Thor.0726: 顯示中文註解 */ *data = '\0'; *expn = '\0'; } else { strncat(data, " ", MAX_VERB_LEN - strlen(p)); strncat(expn, " ", MAX_VERB_LEN - strlen(q)); } } if (i % VERB_NO) { send_to_user(cu, data, 0, MSG_MESSAGE); send_to_user(cu, expn, 0, MSG_MESSAGE); /* Thor.0726: 顯示中文註解 */ } } /* send_to_user(cu, " ",0); *//* Thor.0726: 換行, 需要 " " 嗎? */ } void view_chicken_help(cu) /* Ptt: 鬥雞程式 的help */ register ChatUser *cu; { } /* ----------------------------------------------------- */ /* chat user service routines */ /* ----------------------------------------------------- */ static ChatCmd chatcmdlist[] = { {"act", chat_act, 0}, {"bye", chat_goodbye, 0}, {"chatroom", chat_chatroom, 1}, /* Xshadow: for common client */ {"clear", chat_clear, 0}, {"cloak", chat_cloak, 2}, {"date", chat_date, 0}, {"flags", chat_setroom, 0}, {"help", chat_help, 0}, {"ignore", chat_ignore, 1}, {"invite", chat_invite, 0}, {"join", chat_join, 0}, {"kick", chat_kick, 1}, {"msg", chat_private, 0}, {"nick", chat_nick, 0}, {"operator", chat_makeop, 0}, {"party", chat_party, 1}, /* Xshadow: party data for common client */ {"partyinfo", chat_partyinfo, 1}, /* Xshadow: party info for common * client */ {"query", chat_query, 0}, {"room", chat_list_rooms, 0}, {"unignore", chat_unignore, 1}, {"whoin", chat_list_by_room, 1}, {"wall", chat_broadcast, 2}, {"who", chat_map_chatids_thisroom, 0}, {"list", chat_list_users, 0}, {"topic", chat_topic, 1}, {"version", chat_version, 1}, {NULL, NULL, 0} }; /* Thor: 0 不用 exact, 1 要 exactly equal, 2 秘密指令 */ static int command_execute(cu) ChatUser *cu; { char *cmd, *msg; ChatCmd *cmdrec; int match, ch; msg = cu->ibuf; match = *msg; /* Validation routine */ if (cu->room == NULL) { /* MUST give special /! or /-! command if not in the room yet */ if (match == '/' && ((ch = msg[1]) == '!' || (ch == '-' && msg[2] == '!'))) { cu->clitype = (ch == '-') ? 1 : 0; return (login_user(cu, msg + 2 + cu->clitype)); } else return -1; } /* If not a /-command, it goes to the room. */ if (match != '/') { if (match) { char buf[16]; sprintf(buf, "%s:", cu->chatid); sprintf(chatbuf, "%-10s%s", buf, msg); if (!CLOAK(cu)) /* Thor: 聊天室隱身術 */ send_to_room(cu->room, chatbuf, cu->userno, MSG_MESSAGE); /* Thor: 要 check cu->room NULL嗎? */ } return 0; } msg++; cmd = nextword(&msg); match = 0; if (*cmd == '/') { cmd++; if (!*cmd || str_equal(cmd, "help")) { /* Thor.0726: 動詞分類 */ cmd = nextword(&msg); view_action_verb(cu, *cmd); match = 1; } else if (party_action(cu, cmd, msg) == 0) match = 1; else if (speak_action(cu, cmd, msg) == 0) match = 1; else match = condition_action(cu, cmd); } else if(*cmd == '.') { cmd++; if (!*cmd || str_equal(cmd, "help")) { view_chicken_help(cu); match = 1; } else match = chicken_action(cu, cmd, msg); } else { char *str; common_client_command = 0; if((*cmd == '-')) { if(cu->clitype) { cmd++; /* Xshadow: 指令從下一個字元才開始 */ common_client_command = 1; } } for(cmdrec = chatcmdlist; (str = cmdrec->cmdstr); cmdrec++) { MYDOG; switch (cmdrec->exact) { case 1: /* exactly equal */ match = str_equal(cmd, str); break; case 2: /* Thor: secret command */ if (CHATSYSOP(cu)) match = str_equal(cmd, str); break; default: /* not necessary equal */ match = str_match(cmd, str) >= 0; break; } if (match) { cmdrec->cmdfunc(cu, msg); break; } } } if (!match) { sprintf(chatbuf, "◆ 指令錯誤：/%s", cmd); send_to_user(cu, chatbuf, 0, MSG_MESSAGE); } return 0; } /* ----------------------------------------------------- */ /* serve chat_user's connection */ /* ----------------------------------------------------- */ static int cuser_serve(cu) ChatUser *cu; { register int ch, len, isize; register char *str, *cmd; static char buf[80]; str = buf; len = recv(cu->sock, str, sizeof(buf) - 1, 0); if (len <= 0) { /* disconnected */ exit_room(cu, EXIT_LOSTCONN, (char *) NULL); return -1; } #if 0 /* Xshadow: 將送達的資料忠實紀錄下來 */ memcpy(logbuf, buf, sizeof(buf)); for (ch = 0; ch < sizeof(buf); ch++) if (!logbuf[ch]) logbuf[ch] = '$'; logbuf[len + 1] = '\0'; logit("recv: ", logbuf); #endif #if 0 logit(cu->userid, str); #endif isize = cu->isize; cmd = cu->ibuf + isize; while (len--) { MYDOG; ch = *str++; if (ch == '\r' || !ch) continue; if (ch == '\n') { *cmd = '\0'; isize = 0; cmd = cu->ibuf; if (command_execute(cu) < 0) return -1; continue; } if (isize < 79) { *cmd++ = ch; isize++; } } cu->isize = isize; return 0; } /* ----------------------------------------------------- */ /* chatroom server core routines */ /* ----------------------------------------------------- */ static int start_daemon() { int fd, value; char buf[80]; struct sockaddr_in fsin; struct linger ld; struct rlimit limit; time_t dummy; struct tm *dummy_time; /* * More idiot speed-hacking --- the first time conversion makes the C * library open the files containing the locale definition and time zone. * If this hasn't happened in the parent process, it happens in the * children, once per connection --- and it does add up. */ time(&dummy); dummy_time = gmtime(&dummy); dummy_time = localtime(&dummy); strftime(buf, 80, "%d/%b/%Y:%H:%M:%S", dummy_time); /* --------------------------------------------------- */ /* speed-hacking DNS resolve */ /* --------------------------------------------------- */ gethostname(buf, sizeof(buf)); /* Thor: 萬一server尚未接受connection, 就回去的話, client 第一次會進入失敗 */ /* 所以移至 listen 後 */ /* --------------------------------------------------- */ /* detach daemon process */ /* --------------------------------------------------- */ close(0); close(1); close(2); if (fork()) exit(0); chdir(BBSHOME); setsid(); attach_SHM(); /* --------------------------------------------------- */ /* adjust the resource limit */ /* --------------------------------------------------- */ getrlimit(RLIMIT_NOFILE, &limit); limit.rlim_cur = limit.rlim_max; setrlimit(RLIMIT_NOFILE, &limit); #if 0 while (fd) { close(--fd); } value = getpid(); setpgrp(0, value); if ((fd = open("/dev/tty", O_RDWR)) >= 0) { ioctl(fd, TIOCNOTTY, 0); /* Thor : 為什麼還要用 tty? */ close(fd); } #endif fd = open(CHAT_PIDFILE, O_WRONLY | O_CREAT | O_TRUNC, 0600); if (fd >= 0) { /* sprintf(buf, "%5d\n", value); */ sprintf(buf, "%5d\n", getpid()); write(fd, buf, 6); close(fd); } #if 0 /* ------------------------------ */ /* trap signals */ /* ------------------------------ */ for (fd = 1; fd < NSIG; fd++) { signal(fd, SIG_IGN); } #endif fd = socket(PF_INET, SOCK_STREAM, 0); #if 0 value = fcntl(fd, F_GETFL, 0); fcntl(fd, F_SETFL, value | O_NDELAY); #endif value = 1; setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, (char *) &value, sizeof(value)); #if 0 setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, (char *) &value, sizeof(value)); value = 81920; setsockopt(fd, SOL_SOCKET, SO_RCVBUF, (char *) &value, sizeof(value)); #endif ld.l_onoff = ld.l_linger = 0; setsockopt(fd, SOL_SOCKET, SO_LINGER, (char *) &ld, sizeof(ld)); memset((char *) &fsin, 0, sizeof(fsin)); fsin.sin_family = AF_INET; fsin.sin_port = htons(NEW_CHATPORT); fsin.sin_addr.s_addr = htonl(INADDR_ANY); if (bind(fd, (struct sockaddr *) & fsin, sizeof(fsin)) < 0) exit(1); listen(fd, SOCK_QLEN); return fd; } static void free_resource(fd) int fd; { static int loop = 0; register ChatUser *user; register int sock, num; num = 0; for (user = mainuser; user; user = user->unext) { MYDOG; num++; sock = user->sock; if (fd < sock) fd = sock; } sprintf(chatbuf, "%d, %d user (%d -> %d)", ++loop, num, maxfds, fd); logit("LOOP", chatbuf); maxfds = fd + 1; } #ifdef SERVER_USAGE static void server_usage() { struct rusage ru; char buf[2048]; if (getrusage(RUSAGE_SELF, &ru)) return; sprintf(buf, "\n[Server Usage]\n\n" "user time: %.6f\n" "system time: %.6f\n" "maximum resident set size: %lu P\n" "integral resident set size: %lu\n" "page faults not requiring physical I/O: %ld\n" "page faults requiring physical I/O: %ld\n" "swaps: %ld\n" "block input operations: %ld\n" "block output operations: %ld\n" "messages sent: %ld\n" "messages received: %ld\n" "signals received: %ld\n" "voluntary context switches: %ld\n" "involuntary context switches: %ld\n" "gline: %d\n\n", (double) ru.ru_utime.tv_sec + (double) ru.ru_utime.tv_usec / 1000000.0, (double) ru.ru_stime.tv_sec + (double) ru.ru_stime.tv_usec / 1000000.0, ru.ru_maxrss, ru.ru_idrss, ru.ru_minflt, ru.ru_majflt, ru.ru_nswap, ru.ru_inblock, ru.ru_oublock, ru.ru_msgsnd, ru.ru_msgrcv, ru.ru_nsignals, ru.ru_nvcsw, ru.ru_nivcsw, gline); write(flog, buf, strlen(buf)); } #endif static void abort_server() { log_close(); exit(1); } static void reaper() { int state; while (waitpid(-1, &state, WNOHANG | WUNTRACED) > 0) { MYDOG; } } int main() { register int msock, csock, nfds; register ChatUser *cu; register fd_set *rptr, *xptr; fd_set rset, xset; struct timeval tv; time_t uptime, tmaintain; msock = start_daemon(); setgid(BBSGID); setuid(BBSUID); log_init(); signal(SIGBUS, SIG_IGN); signal(SIGSEGV, SIG_IGN); signal(SIGPIPE, SIG_IGN); signal(SIGURG, SIG_IGN); signal(SIGCHLD, reaper); signal(SIGTERM, abort_server); #ifdef SERVER_USAGE signal(SIGPROF, server_usage); #endif /* ----------------------------- */ /* init variable : rooms & users */ /* ----------------------------- */ mainuser = NULL; memset(&mainroom, 0, sizeof(mainroom)); strcpy(mainroom.name, MAIN_NAME); strcpy(mainroom.topic, MAIN_TOPIC); /* ----------------------------------- */ /* main loop */ /* ----------------------------------- */ #if 0 /* Thor: 在listen 後才回client, 每次進來就會成功 */ if (fork()) exit(0); #endif FD_ZERO(&mainfds); FD_SET(msock, &mainfds); rptr = &rset; xptr = &xset; maxfds = msock + 1; tmaintain = time(0) + CHAT_INTERVAL; for (;;) { uptime = time(0); if (tmaintain < uptime) { tmaintain = uptime + CHAT_INTERVAL; /* client/server 版本利用 ping-pong 方法判斷 user 是不是還活著 */ /* 如果 client 已經結束了，就釋放其 resource */ free_resource(msock); } MYDOG; memcpy(rptr, &mainfds, sizeof(fd_set)); memcpy(xptr, &mainfds, sizeof(fd_set)); /* Thor: for future reservation bug */ tv.tv_sec = CHAT_INTERVAL; tv.tv_usec = 0; MYDOG; nfds = select(maxfds, rptr, NULL, xptr, &tv); MYDOG; /* free idle user & chatroom's resource when no traffic */ if (nfds == 0) { continue; } /* check error condition */ if (nfds < 0) { csock = errno; continue; } /* accept new connection */ if (FD_ISSET(msock, rptr)) { for (;;) { MYDOG; /* Thor: check for endless */ csock = accept(msock, NULL, NULL); if (csock >= 0) { MYDOG; if((cu = (ChatUser *) malloc(sizeof(ChatUser)))) { memset(cu, 0, sizeof(ChatUser)); cu->sock = csock; cu->unext = mainuser; mainuser = cu; #if 0 if (mainuser.next) mainuser.next->prev = cu; cu->next = mainuser.next; mainuser.next = cu; cu->prev = &mainuser; #endif totaluser++; FD_SET(csock, &mainfds); if (csock >= maxfds) maxfds = csock + 1; #ifdef DEBUG logit("accept", "OK"); #endif } else { close(csock); logit("accept", "malloc fail"); } MYDOG; break; } csock = errno; if (csock != EINTR) { break; } } FD_CLR(msock, rptr); if (--nfds <= 0) continue; } for (cu = mainuser; cu; cu = cu->unext) { MYDOG; csock = cu->sock; if (FD_ISSET(csock, xptr)) { logout_user(cu); FD_CLR(csock, xptr); } else if (FD_ISSET(csock, rptr)) { if (cuser_serve(cu) < 0) logout_user(cu); } else { continue; } FD_CLR(csock, rptr); if (--nfds <= 0) break; } /* end of main loop */ } }