/* $Id: mbbsd.c,v 1.1 2002/03/07 15:13:48 in2 Exp $ */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "config.h" #include "pttstruct.h" #include "common.h" #include "perm.h" #include "modes.h" #include "proto.h" #ifdef FreeBSD #include #else #include #endif #define SOCKET_QLEN 4 #define TH_LOW 100 #define TH_HIGH 120 extern int t_lines, t_columns; /* Screen size / width */ extern int b_lines; /* Screen bottom line number: t_lines-1 */ extern userinfo_t *currutmp; extern int curr_idle_timeout; static void do_aloha (char *hello); static jmp_buf byebye; int talkrequest = NA; static char remoteusername[40] = "?"; extern struct fromcache_t *fcache; extern struct utmpfile_t *utmpshm; extern int fcache_semid; static unsigned char enter_uflag; static int use_shell_login_mode = 0; char fromhost[STRLEN] = "\0"; static struct sockaddr_in xsin; /* set signal handler, which won't be reset once signal comes */ static void signal_restart (int signum, void (*handler) (int)) { struct sigaction act; act.sa_handler = handler; memset (&(act.sa_mask), 0, sizeof (sigset_t)); act.sa_flags = 0; sigaction (signum, &act, NULL); } static void start_daemon () { int n; char buf[80]; /* * 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_t dummy = time (NULL); struct tm *dummy_time = localtime (&dummy); strftime (buf, 80, "%d/%b/%Y:%H:%M:%S", dummy_time); if ((n = fork ())){ exit (0); } /* rocker.011018: it's a good idea to close all unexcept fd!! */ n = getdtablesize (); while (n) close (--n); /* rocker.011018: we don't need to remember original tty, so request a new session id */ setsid (); /* rocker.011018: after new session, we should insure the process is clean daemon */ if ((n = fork ())){ exit (0); } } static void reapchild (int sig) { int state, pid; while ((pid = waitpid (-1, &state, WNOHANG | WUNTRACED)) > 0) ; } #define BANNER \ "【" BBSNAME "】◎ 台大流行網 ◎(" MYHOSTNAME ") 調幅(" MYIP ") " /* #define BANNER \ "【" BBSNAME "】◎ 台大流行網 ◎(" MYHOSTNAME ")\r\n"\ " 調幅(" MYIP ") " */ /* check load and print approriate banner string in buf */ static int chkload (char *buf) { char cpu_load[30]; int i; i = cpuload (cpu_load); sprintf (buf, BANNER" 系統負荷\r\n %s %s \r\n", cpu_load, (i > MAX_CPULOAD ? "，高負荷量，請稍後再來 " "(請利用port 3000~3010連線)" : "")); #ifdef INSCREEN strcpy(buf, (i > MAX_CPULOAD ? BANNER "高負荷量，請稍後再來(請利用port 3000~3010連線)" : "")); #else sprintf(buf, BANNER "%s\r\n", (i > MAX_CPULOAD ? "高負荷量，請稍後再來(請利用port 3000~3010連線)":"")); #endif if (i > MAX_CPULOAD) return 1; else if (i > MAX_CPULOAD / 2) curr_idle_timeout = 10 * 60; else curr_idle_timeout = 30 * 60; return 0; } extern userec_t cuser; void log_user (char *msg) { char filename[200]; sprintf (filename, BBSHOME "/home/%c/%s/USERLOG", cuser.userid[0], cuser.userid); log_file (filename, msg); } extern time_t login_start_time; void log_usies (char *mode, char *mesg) { char genbuf[200]; time_t now = time (0); if (!mesg) sprintf (genbuf, cuser.userid[0] ? "%s %s %-12s Stay:%d (%s)" : "%s %s %s Stay:%d (%s)", Cdate (&now), mode, cuser.userid, (int)(now - login_start_time) / 60, cuser.username); else sprintf (genbuf, cuser.userid[0] ? "%s %s %-12s %s" : "%s %s %s%s", Cdate (&now), mode, cuser.userid, mesg); log_file (FN_USIES, genbuf); /* 追蹤使用者 */ if (HAS_PERM (PERM_LOGUSER)) log_user (genbuf); } static void setflags (int mask, int value) { if (value) cuser.uflag |= mask; else cuser.uflag &= ~mask; } extern int usernum; extern int currmode; void u_exit (char *mode) { //userec_t xuser; int diff = (time (0) - login_start_time) / 60; reload_money(); auto_backup (); save_brdbuf(); setflags (PAGER_FLAG, currutmp->pager != 1); setflags (CLOAK_FLAG, currutmp->invisible); cuser.invisible = currutmp->invisible; cuser.pager = currutmp->pager; cuser.mind = currutmp->mind; if (!(HAS_PERM (PERM_SYSOP) && HAS_PERM (PERM_DENYPOST)) && !currutmp->invisible ) do_aloha ("<<下站通知>> -- 我走囉！"); purge_utmp (currutmp); if ((cuser.uflag != enter_uflag) || (currmode & MODE_DIRTY) || diff) { if (!diff && cuser.numlogins) cuser.numlogins = --cuser.numlogins; /* Leeym 上站停留時間限制式 */ } passwd_update (usernum, &cuser); log_usies (mode, NULL); } static void system_abort () { if (currmode) u_exit ("ABORT"); clear (); refresh (); fprintf (stdout, "謝謝光臨, 記得常來喔 !\n"); exit (0); } void abort_bbs (int sig) { if (currmode) u_exit ("AXXED"); exit (0); } static void abort_bbs_debug (int sig) { static int reentrant = 0; if (!reentrant){ reentrant = 1; if (currmode) u_exit ("AXXED"); setproctitle("debug me!(%d)",sig); sleep(3600); /* wait 60 mins for debug */ } exit (0); } /* 登錄 BBS 程式 */ static void mysrand () { srand (time (NULL) + currutmp->pid); /* 時間跟 pid 當 rand 的 seed */ } extern userec_t xuser; int dosearchuser (char *userid) { if ((usernum = getuser (userid))) memcpy (&cuser, &xuser, sizeof (cuser)); else memset (&cuser, 0, sizeof (cuser)); return usernum; } static void talk_request () { bell (); bell (); if (currutmp->msgcount){ char buf[200]; time_t now = time (0); sprintf (buf, "\033[33;41m★%s\033[34;47m [%s] %s \033[0m", utmpshm->uinfo[currutmp->destuip].userid, my_ctime (&now), (currutmp->sig == 2)? "重要消息廣播！(請Ctrl-U,l查看熱訊記錄)" : "呼叫、呼叫，聽到請回答"); move (0, 0); clrtoeol (); outs (buf); refresh (); } else{ unsigned char mode0 = currutmp->mode; char c0 = currutmp->chatid[0]; screenline_t *screen0 = calloc (t_lines, sizeof (screenline_t)); extern screenline_t *big_picture; currutmp->mode = 0; currutmp->chatid[0] = 1; memcpy (screen0, big_picture, t_lines * sizeof (screenline_t)); talkreply (); currutmp->mode = mode0; currutmp->chatid[0] = c0; memcpy (big_picture, screen0, t_lines * sizeof (screenline_t)); free (screen0); redoscr (); } } extern char *fn_writelog; FILE *fp_writelog = NULL; void show_last_call_in (int save) { char buf[200]; sprintf (buf, "\033[1;33;46m★%s\033[37;45m %s \033[m", currutmp->msgs[0].userid, currutmp->msgs[0].last_call_in); move (b_lines, 0); clrtoeol (); refresh (); outmsg (buf); if (save){ char genbuf[200]; time_t now; if (!fp_writelog){ sethomefile (genbuf, cuser.userid, fn_writelog); fp_writelog = fopen (genbuf, "a"); } if (fp_writelog){ time (&now); fprintf (fp_writelog, "%s \033[0m[%s]\n", buf, Cdatelite (&now)); } } } extern unsigned int currstat; water_t water[6], *swater[6], *water_which=&water[0]; char water_usies=0; extern int watermode; static int add_history_water(water_t *w, msgque_t *msg) { memcpy(&w->msg[w->top], msg, sizeof(msgque_t)); w->top++; w->top %= WATERMODE(WATER_OFO) ? 5 : MAX_REVIEW; if (w->count < MAX_REVIEW) w->count++; return w->count; } static int add_history(msgque_t *msg) { int i,j; water_t *tmp; add_history_water(&water[0], msg); for(i = 0 ; i < 5 && swater[i] ; i++ ) if( swater[i]->pid == msg->pid ) break; if( i != 5 ){ if( !swater[i] ){ water_usies = i + 1; swater[i] = &water[i + 1]; strcpy(swater[i]->userid, msg->userid); swater[i]->pid = msg->pid; } tmp = swater[i]; } else{ tmp = swater[4]; memset(swater[4], 0, sizeof (water_t)); strcpy(swater[4]->userid, msg->userid); swater[4]->pid = msg->pid; i = 4; } for( j = i ; j > 0 ; j-- ) swater[j] = swater[j - 1]; swater[0] = tmp; add_history_water(swater[0], msg); if(WATERMODE(WATER_ORIG) || WATERMODE(WATER_NEW) ){ if( watermode > 0 && (water_which == swater[0] || water_which == &water[0]) ){ if (watermode < water_which->count) watermode++; t_display_new(); } } return i; } static void write_request (int sig) { struct tm *ptime; time_t now; time (&now); ptime = localtime (&now); if (currutmp->pager != 0 && cuser.userlevel != 0 && currutmp->msgcount != 0 && currutmp->mode != TALK && currutmp->mode != EDITING && currutmp->mode != CHATING && currutmp->mode != PAGE && currutmp->mode != IDLE && currutmp->mode != MAILALL && currutmp->mode != MONITOR) { int i; char c0 = currutmp->chatid[0]; int currstat0 = currstat; unsigned char mode0 = currutmp->mode; currutmp->mode = 0; currutmp->chatid[0] = 2; currstat = XMODE; do { bell (); show_last_call_in (1); igetch (); currutmp->msgcount--; if (currutmp->msgcount >= MAX_MSGS) { /* this causes chaos... jochang */ raise (SIGFPE); } add_history(&currutmp->msgs[0]); for (i = 0; i < currutmp->msgcount; i++) currutmp->msgs[i] = currutmp->msgs[i + 1]; } while (currutmp->msgcount); currutmp->chatid[0] = c0; currutmp->mode = mode0; currstat = currstat0; } else { bell (); show_last_call_in (1); add_history(&currutmp->msgs[0]); refresh (); currutmp->msgcount = 0; } } #if 0 static void write_request (int sig) { int i, mtimemin, wu; static char inlock = 0; if( inlock ) /* 如果已經進來了 (表示上個水球還沒有處理完, 新的水球又進來) 則不做任何事直接 return */ return; inlock = 1; do{ for( wu = 0 ; wu < 5 ; ++wu ) if( water[wu].pid == currutmp->msgs[0].pid ) break; if( wu == 5 ){ for( i = 0, mtimemin = INT_MAX ; i < 5 ; ++i ) if( water[i].pid == 0 ){ ++water_usies; wu = i; break; } else if( water[i].mtime < mtimemin ){ mtimemin = water[i].mtime; wu = i; } water[wu].pid = currutmp->msgs[0].pid; strcpy(water[wu].userid, currutmp->msgs[0].userid); water[wu].msgtop = 0; for( i = 0 ; i < 5 ; ++i ) water[wu].msg[i][0] = 0; } water[wu].mtime = time(NULL); strncpy(water[wu].msg[ (int)water[wu].msgtop ], currutmp->msgs[0].last_call_in, 64); ++water[wu].msgtop; water[wu].msgtop %= 5; bell (); show_last_call_in (1); refresh(); if( watermode == 0 ){ /* in waterball selection mode if( wu != 0 ){ water_scr(water_which, 0); qsort(water, 5, sizeof(water_t), cmpwatermtime); for( i = 0 ; i < 5 ; ++i ) if( water[i].pid == 0 ) break; else water_scr(i, 0); water_scr(water_which = 0, 1); refresh(); } */ } --currutmp->msgcount; for( i = 0 ; i < currutmp->msgcount - 1 ; ++i ) currutmp->msgs[i] = currutmp->msgs[i + 1]; } while( currutmp->msgcount > 0 ); inlock = 0; } #endif static void multi_user_check () { register userinfo_t *ui; register pid_t pid; char genbuf[3]; if (HAS_PERM (PERM_SYSOP)) return; /* don't check sysops */ if (cuser.userlevel){ if (!(ui = (userinfo_t *) search_ulist (usernum))) return; /* user isn't logged in */ pid = ui->pid; if (!pid /*|| (kill(pid, 0) == -1) */ ) return; /* stale entry in utmp file */ getdata (b_lines - 1, 0, "您想刪除其他重複的 login (Y/N)嗎？[Y] ", genbuf, 3, LCECHO); if (genbuf[0] != 'n'){ if (pid > 0) kill (pid, SIGHUP); log_usies ("KICK ", cuser.username); } else{ if (search_ulistn(usernum, 3)!=NULL) system_abort (); /* Goodbye(); */ } } else{ /* allow multiple guest user */ if (search_ulistn(usernum, 100)!=NULL){ outs ("\n抱歉，目前已有太多 guest, 請稍後再試。\n"); pressanykey (); oflush (); exit (1); } } } /* bad login */ static char str_badlogin[] = "logins.bad"; static void logattempt (char *uid, char type) { char fname[40]; int fd, len; char genbuf[200]; sprintf (genbuf, "%c%-12s[%s] %s@%s\n", type, uid, Cdate (&login_start_time), remoteusername, fromhost); len = strlen (genbuf); if ((fd = open (str_badlogin, O_WRONLY | O_CREAT | O_APPEND, 0644)) > 0){ write (fd, genbuf, len); close (fd); } if (type == '-'){ sprintf (genbuf, "[%s] %s\n", Cdate (&login_start_time), fromhost); len = strlen (genbuf); sethomefile (fname, uid, str_badlogin); if ((fd = open (fname, O_WRONLY | O_CREAT | O_APPEND, 0644)) > 0){ write (fd, genbuf, len); close (fd); } } } extern char *str_new; extern char *err_uid; static void login_query () { char uid[IDLEN + 1], passbuf[PASSLEN]; int attempts; char genbuf[200]; extern struct utmpfile_t *utmpshm; resolve_utmp (); attach_uhash (); attempts = utmpshm->number; show_file ("etc/Welcome", 1, -1, NO_RELOAD); output ("1", 1); if (attempts >= MAX_ACTIVE){ outs ("由於人數太多，請您稍後再來。\n"); refresh (); exit (1); } /* hint */ attempts = 0; while (1){ if (attempts++ >= LOGINATTEMPTS){ more ("etc/goodbye", NA); pressanykey (); exit (1); } getdata (20, 0, "請輸入代號，或以[guest]參觀，以[new]註冊：", uid, IDLEN + 1, DOECHO); if (strcasecmp (uid, str_new) == 0){ #ifdef LOGINASNEW new_register (); break; #else outs ("本系統目前無法以 new 註冊, 請用 guest 進入\n"); continue; #endif } else if (uid[0] == '\0' || !dosearchuser (uid)){ outs (err_uid); } else if (strcmp (uid, STR_GUEST)){ getdata (21, 0, MSG_PASSWD, passbuf, PASSLEN, NOECHO); passbuf[8] = '\0'; if (!checkpasswd (cuser.passwd, passbuf) /* || (HAS_PERM(PERM_SYSOP) && !use_shell_login_mode) */ ){ logattempt (cuser.userid, '-'); outs (ERR_PASSWD); } else{ logattempt (cuser.userid, ' '); if (strcasecmp ("SYSOP", cuser.userid) == 0) cuser.userlevel = PERM_BASIC | PERM_CHAT | PERM_PAGE | PERM_POST | PERM_LOGINOK | PERM_MAILLIMIT | PERM_CLOAK | PERM_SEECLOAK | PERM_XEMPT | PERM_DENYPOST | PERM_BM | PERM_ACCOUNTS | PERM_CHATROOM | PERM_BOARD | PERM_SYSOP | PERM_BBSADM; break; } } else{ /* guest */ cuser.userlevel = 0; cuser.uflag = COLOR_FLAG | PAGER_FLAG | BRDSORT_FLAG | MOVIE_FLAG; break; } } multi_user_check (); sethomepath (genbuf, cuser.userid); mkdir (genbuf, 0755); } void add_distinct (char *fname, char *line) { FILE *fp; int n = 0; if ((fp = fopen (fname, "a+"))){ char buffer[80]; char tmpname[100]; FILE *fptmp; strcpy (tmpname, fname); strcat (tmpname, "_tmp"); if (!(fptmp = fopen (tmpname, "w"))){ fclose (fp); return; } rewind (fp); while (fgets (buffer, 80, fp)){ char *p = buffer + strlen (buffer) - 1; if (p[-1] == '\n' || p[-1] == '\r') p[-1] = 0; if (!strcmp (buffer, line)) break; sscanf (buffer + strlen (buffer) + 2, "%d", &n); fprintf (fptmp, "%s%c#%d\n", buffer, 0, n); } if (feof (fp)) fprintf (fptmp, "%s%c#1\n", line, 0); else{ sscanf (buffer + strlen (buffer) + 2, "%d", &n); fprintf (fptmp, "%s%c#%d\n", buffer, 0, n + 1); while (fgets (buffer, 80, fp)){ sscanf (buffer + strlen (buffer) + 2, "%d", &n); fprintf (fptmp, "%s%c#%d\n", buffer, 0, n); } } fclose (fp); fclose (fptmp); unlink (fname); rename (tmpname, fname); } } void del_distinct (char *fname, char *line) { FILE *fp; int n = 0; if ((fp = fopen (fname, "r"))){ char buffer[80]; char tmpname[100]; FILE *fptmp; strcpy (tmpname, fname); strcat (tmpname, "_tmp"); if (!(fptmp = fopen (tmpname, "w"))){ fclose (fp); return; } rewind (fp); while (fgets (buffer, 80, fp)){ char *p = buffer + strlen (buffer) - 1; if (p[-1] == '\n' || p[-1] == '\r') p[-1] = 0; if (!strcmp (buffer, line)) break; sscanf (buffer + strlen (buffer) + 2, "%d", &n); fprintf (fptmp, "%s%c#%d\n", buffer, 0, n); } if (!feof (fp)) while (fgets (buffer, 80, fp)){ sscanf (buffer + strlen (buffer) + 2, "%d", &n); fprintf (fptmp, "%s%c#%d\n", buffer, 0, n); } fclose (fp); fclose (fptmp); unlink (fname); rename (tmpname, fname); } } #ifdef WHERE static int where (char *from) { register int i = 0, count = 0, j; for (j = 0; j < fcache->top; j++){ char *token = strtok (fcache->domain[j], "&"); i = 0; count = 0; while (token){ if (strstr (from, token)) count++; token = strtok (NULL, "&"); i++; } if (i == count) break; } if (i != count) return 0; return j; } #endif static void check_BM () { int i; boardheader_t *bhdr; extern boardheader_t *bcache; extern int numboards; cuser.userlevel &= ~PERM_BM; for (i = 0, bhdr = bcache; i < numboards && !is_BM (bhdr->BM); i++, bhdr++) ; } extern pid_t currpid; extern crosspost_t postrecord; static void setup_utmp (int mode) { userinfo_t uinfo; /* char buf[80]; char remotebuf[1024]; time_t now = time(NULL); */ memset (&uinfo, 0, sizeof (uinfo)); uinfo.pid = currpid = getpid (); uinfo.uid = usernum; uinfo.mode = currstat = mode; uinfo.msgcount = 0; uinfo.mailalert = load_mailalert (cuser.userid); if (!(cuser.numlogins % 20) && cuser.userlevel & PERM_BM) check_BM (); /* Ptt 自動取下離職板主權力 */ uinfo.userlevel = cuser.userlevel; uinfo.sex = cuser.sex % 8; uinfo.lastact = time (NULL); postrecord.times = 0; /* 計算crosspost數 */ strcpy (uinfo.userid, cuser.userid); strcpy (uinfo.realname, cuser.realname); strcpy (uinfo.username, cuser.username); strncpy (uinfo.from, fromhost, 23); uinfo.five_win = cuser.five_win; uinfo.five_lose = cuser.five_lose; uinfo.five_tie = cuser.five_tie; uinfo.invisible = cuser.invisible % 2; uinfo.pager = cuser.pager%5; uinfo.mind = cuser.mind; uinfo.brc_id = 0; #ifdef WHERE uinfo.from_alias = where (fromhost); #else uinfo.from_alias = 0; #endif #ifndef FAST_LOGIN setuserfile (buf, "remoteuser"); strcpy (remotebuf, fromhost); strcat (remotebuf, ctime (&now)); remotebuf[strlen (remotebuf) - 1] = 0; add_distinct (buf, remotebuf); #endif if (enter_uflag & CLOAK_FLAG) uinfo.invisible = YEA; getnewutmpent (&uinfo); #ifndef _BBS_UTIL_C_ friend_load (); #endif } extern char margs[]; extern char *str_sysop; extern char *loginview_file[NUMVIEWFILE][2]; static void user_login () { char ans[4], i; char genbuf[200]; struct tm *ptime, *tmp; time_t now; int a; /*** Heat:廣告詞 char *ADV[] = { "7/17 @LIVE 亂彈, 何欣穗 的 入場卷要送給 ptt 的愛用者!", "欲知詳情請看 PttAct 板!!", }; ***/ log_usies ("ENTER", fromhost); setproctitle ("%s: %s", margs, cuser.userid); resolve_garbage (); resolve_fcache (); resolve_boards (); memset( &water[0],0,sizeof(water_t) * 6); strcpy(water[0].userid, " 全部 "); /* 初始化 uinfo、flag、mode */ setup_utmp (LOGIN); mysrand (); /* 初始化: random number 增加user跟時間的差異 */ currmode = MODE_STARTED; enter_uflag = cuser.uflag; /* get local time */ time (&now); ptime = localtime (&now); tmp = localtime (&cuser.lastlogin); if ((a = utmpshm->number) > fcache->max_user){ fcache->max_user = a; fcache->max_time = now; } init_brdbuf(); brc_initial (DEFAULT_BOARD); set_board (); /* 畫面處理開始 */ if (!(HAS_PERM (PERM_SYSOP) && HAS_PERM (PERM_DENYPOST)) && !currutmp->invisible ) do_aloha ("<<上站通知>> -- 我來啦！"); if (ptime->tm_mday == cuser.day && ptime->tm_mon + 1 == cuser.month){ more ("etc/Welcome_birth", NA); currutmp->birth = 1; } else{ #ifdef MULTI_WELCOME_LOGIN char buf[80]; int nScreens; for( nScreens = 0 ; nScreens < 10 ; ++nScreens ){ sprintf(buf, "etc/Welcome_login.%d", nScreens); if( access(buf, 0) < 0 ) break; } printf("%d\n", nScreens); if( nScreens == 0 ){ // multi screen error? more ("etc/Welcome_login", NA); } else{ sprintf(buf, "etc/Welcome_login.%d", (int)login_start_time % nScreens); more (buf, NA); } #else more ("etc/Welcome_login", NA); #endif // pressanykey(); // more("etc/CSIE_Week", NA); currutmp->birth = 0; } if (cuser.userlevel){/* not guest */ move (t_lines - 4, 0); prints (" 歡迎您第 \033[1;33m%d\033[0;37m 度拜訪本站，" "上次您是從 \033[1;33m%s\033[0;37m 連往本站，\n" " 我記得那天是 \033[1;33m%s\033[0;37m。\n", ++cuser.numlogins, cuser.lasthost, Cdate (&cuser.lastlogin)); pressanykey (); if (currutmp->birth && tmp->tm_mday != ptime->tm_mday){ more ("etc/birth.post", YEA); brc_initial ("WhoAmI"); set_board (); do_post (); } setuserfile (genbuf, str_badlogin); if (more (genbuf, NA) != -1){ getdata (b_lines - 1, 0, "您要刪除以上錯誤嘗試的記錄嗎(Y/N)?[Y]", ans, 3, LCECHO); if (*ans != 'n') unlink (genbuf); } check_register (); strncpy (cuser.lasthost, fromhost, 16); cuser.lasthost[15] = '\0'; restore_backup (); } else if (!strcmp (cuser.userid, STR_GUEST)){ char *nick[13] = { "椰子", "貝殼", "內衣", "寶特瓶", "翻車魚", "樹葉", "浮萍", "鞋子", "潛水艇", "魔王", "鐵罐", "考卷", "大美女" }; char *name[13] = { "大王椰子", "鸚鵡螺", "比基尼", "可口可樂", "仰泳的魚", "憶", "高岡屋", "AIR Jordon", "紅色十月號", "批踢踢", "SASAYA椰奶", "鴨蛋", "布魯克鱈魚香絲" }; char *addr[13] = { "天堂樂園", "大海", "綠島小夜曲", "美國", "綠色珊瑚礁", "遠方", "原本海", "NIKE", "蘇聯", "男八618室", "愛之味", "天上", "藍色珊瑚礁" }; i = login_start_time % 13; sprintf (cuser.username, "海邊漂來的%s", nick[(int) i]); sprintf (currutmp->username, cuser.username); sprintf (cuser.realname, name[(int) i]); sprintf (currutmp->realname, cuser.realname); sprintf (cuser.address, addr[(int) i]); cuser.sex = i % 8; currutmp->pager = 2; pressanykey (); } else pressanykey (); if (!PERM_HIDE (currutmp)) cuser.lastlogin = login_start_time; passwd_update (usernum, &cuser); for (i = 0; i < NUMVIEWFILE; i++) if ((cuser.loginview >> i) & 1) more (loginview_file[(int) i][0], YEA); } static void do_aloha (char *hello) { FILE *fp; char userid[80]; char genbuf[200]; setuserfile (genbuf, "aloha"); if ((fp = fopen (genbuf, "r"))){ sprintf (genbuf, hello); while (fgets (userid, 80, fp)){ userinfo_t *uentp; int tuid; if ((tuid = searchuser (userid)) && tuid != usernum && (uentp = (userinfo_t *) search_ulist (tuid)) && isvisible(uentp, currutmp)){ my_write (uentp->pid, genbuf, uentp->userid, 2); } } fclose (fp); } } static void do_term_init () { term_init (); initscr (); } extern char *fn_register; extern int showansi; static void start_client () { extern struct commands_t cmdlist[]; #if FORCE_PROCESS_REGISTER_FORM int nreg; #endif /* system init */ nice (2); /* Ptt: lower priority */ login_start_time = time (0); currmode = 0; signal (SIGHUP, abort_bbs); signal (SIGTERM, abort_bbs); signal (SIGPIPE, abort_bbs); signal (SIGINT, abort_bbs_debug); signal (SIGQUIT, abort_bbs_debug); signal (SIGILL, abort_bbs_debug); signal (SIGABRT, abort_bbs_debug); signal (SIGFPE, abort_bbs_debug); signal (SIGBUS, abort_bbs_debug); signal (SIGSEGV, abort_bbs_debug); signal_restart (SIGUSR1, talk_request); signal_restart (SIGUSR2, write_request); dup2 (0, 1); do_term_init (); signal (SIGALRM, abort_bbs); alarm (600); login_query (); /* Ptt 加上login time out */ user_login (); m_init (); #if FORCE_PROCESS_REGISTER_FORM if (HAS_PERM (PERM_SYSOP) && (nreg = dashs (fn_register) / 163) > 100){ char cpu_load[30]; if (cpuload (cpu_load) > MAX_CPULOAD * 2 / 3) /* DickG: 根據目前的 load 來決定要審核的數目 */ scan_register_form (fn_register, 1, nreg / 20); else scan_register_form (fn_register, 1, nreg / 10); } #endif if (HAVE_PERM (PERM_SYSOP | PERM_BM)) b_closepolls (); if (!(cuser.uflag & COLOR_FLAG)) showansi = 0; #ifdef DOTIMEOUT /* init_alarm(); */// cause strange logout with saving post. signal (SIGALRM, SIG_IGN); #else signal (SIGALRM, SIG_IGN); #endif if (chkmailbox ()) m_read (); domenu (MMENU, "主功\能表", (currutmp->mailalert ? 'M' : 'C'), cmdlist); } /* FSA (finite state automata) for telnet protocol */ static void telnet_init () { static char svr[] = { IAC, DO, TELOPT_TTYPE, IAC, SB, TELOPT_TTYPE, TELQUAL_SEND, IAC, SE, IAC, WILL, TELOPT_ECHO, IAC, WILL, TELOPT_SGA }; char *cmd; int n, len, rset; struct timeval to; char buf[64]; for (n = 0, cmd = svr; n < 4; n++){ len = (n == 1 ? 6 : 3); write (0, cmd, len); cmd += len; to.tv_sec = 3; to.tv_usec = 0; rset=1; if (select (1, (fd_set *) & rset, NULL, NULL, &to) > 0) recv(0, buf, sizeof (buf),0); } } /* 取得 remote user name 以判定身份 */ /* * rfc931() speaks a common subset of the RFC 931, AUTH, TAP, IDENT and RFC * 1413 protocols. It queries an RFC 931 etc. compatible daemon on a remote * host to look up the owner of a connection. The information should not be * used for authentication purposes. This routine intercepts alarm signals. * * Author: Wietse Venema, Eindhoven University of Technology, The Netherlands. */ #define STRN_CPY(d,s,l) { strncpy((d),(s),(l)); (d)[(l)-1] = 0; } #define RFC931_TIMEOUT 10 #define RFC931_PORT 113 /* Semi-well-known port */ #define ANY_PORT 0 /* Any old port will do */ /* timeout - handle timeouts */ static void timeout (int sig) { longjmp (byebye, sig); } static void getremotename (struct sockaddr_in *from, char *rhost, char *rname) { /* get remote host name */ #ifdef FAST_LOGIN strcpy (rhost, (char *) inet_ntoa (from->sin_addr)); #else struct sockaddr_in our_sin; struct sockaddr_in rmt_sin; unsigned rmt_port, rmt_pt; unsigned our_port, our_pt; FILE *fp; char buffer[512], user[80], *cp; int s; static struct hostent *hp; hp = NULL; if (setjmp (byebye) == 0){ signal (SIGALRM, timeout); alarm (3); hp = gethostbyaddr ((char *) &from->sin_addr, sizeof (struct in_addr), from->sin_family); alarm (0); } strcpy (rhost, hp ? hp->h_name : (char *) inet_ntoa (from->sin_addr)); /* * Use one unbuffered stdio stream for writing to and for reading from the * RFC931 etc. server. This is done because of a bug in the SunOS 4.1.x * stdio library. The bug may live in other stdio implementations, too. * When we use a single, buffered, bidirectional stdio stream ("r+" or "w+" * mode) we read our own output. Such behaviour would make sense with * resources that support random-access operations, but not with sockets. */ s = sizeof (our_sin); if (getsockname (0, (struct sockaddr *) &our_sin, &s) < 0) return; if ((s = socket (AF_INET, SOCK_STREAM, 0)) < 0) return; if (!(fp = fdopen (s, "r+"))){ close (s); return; } /* Set up a timer so we won't get stuck while waiting for the server. */ if (setjmp (byebye) == 0){ signal (SIGALRM, timeout); alarm (RFC931_TIMEOUT); /* * Bind the local and remote ends of the query socket to the same IP * addresses as the connection under investigation. We go through all * this trouble because the local or remote system might have more than * one network address. The RFC931 etc. client sends only port numbers; * the server takes the IP addresses from the query socket. */ our_pt = ntohs (our_sin.sin_port); our_sin.sin_port = htons (ANY_PORT); rmt_sin = *from; rmt_pt = ntohs (rmt_sin.sin_port); rmt_sin.sin_port = htons (RFC931_PORT); setbuf (fp, (char *) 0); s = fileno (fp); if (bind (s, (struct sockaddr *) &our_sin, sizeof (our_sin)) >= 0 && connect (s, (struct sockaddr *) &rmt_sin, sizeof (rmt_sin)) >= 0){ /* * Send query to server. Neglect the risk that a 13-byte write would * have to be fragmented by the local system and cause trouble with * buggy System V stdio libraries. */ fprintf (fp, "%u,%u\r\n", rmt_pt, our_pt); fflush (fp); /* * Read response from server. Use fgets()/sscanf() so we can work * around System V stdio libraries that incorrectly assume EOF when a * read from a socket returns less than requested. */ if (fgets (buffer, sizeof (buffer), fp) && !ferror (fp) && !feof (fp) && sscanf (buffer, "%u , %u : USERID :%*[^:]:%79s", &rmt_port, &our_port, user) == 3 && rmt_pt == rmt_port && our_pt == our_port){ /* * Strip trailing carriage return. It is part of the protocol, not * part of the data. */ if ((cp = (char *) strchr (user, '\r'))) *cp = 0; strcpy (rname, user); } } alarm (0); } fclose (fp); #endif } static int bind_port (int port) { int sock, on; sock = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP); on = 1; setsockopt (sock, SOL_SOCKET, SO_REUSEADDR, (char *) &on, sizeof (on)); setsockopt (sock, SOL_SOCKET, SO_KEEPALIVE, (char *) &on, sizeof (on)); on = 0; setsockopt (sock, SOL_SOCKET, SO_LINGER, (char *) &on, sizeof (on)); xsin.sin_port = htons (port); if (bind (sock, (struct sockaddr *) &xsin, sizeof xsin) < 0){ syslog (LOG_INFO, "bbsd bind_port can't bind to %d", port); exit (1); } if (listen (sock, SOCKET_QLEN) < 0){ syslog (LOG_INFO, "bbsd bind_port can't listen to %d", port); exit (1); } return sock; } /*******************************************************/ static void shell_login (int argc, char *argv[], char *envp[]); static void daemon_login (int argc, char *argv[], char *envp[]); static int check_ban_and_load (int fd); #ifdef SUPPORT_GB extern int current_font_type; #endif int main (int argc, char *argv[], char *envp[]) { /* avoid SIGPIPE */ signal (SIGPIPE, SIG_IGN); /* avoid erroneous signal from other mbbsd */ signal (SIGUSR1, SIG_IGN); signal (SIGUSR2, SIG_IGN); /* check if invoked as "bbs" */ if (argc == 3) shell_login (argc, argv, envp); else daemon_login (argc, argv, envp); return 0; } static void shell_login (int argc, char *argv[], char *envp[]) { /* Give up root privileges: no way back from here */ setgid (BBSGID); setuid (BBSUID); chdir (BBSHOME); /* mmap passwd file */ if (passwd_mmap ()) exit (1); use_shell_login_mode = 1; initsetproctitle (argc, argv, envp); /* copy fromindent: Standard input:1138: Error:Unexpected end of file the original "bbs" */ if (argc > 1){ strcpy (fromhost, argv[1]); if (argc > 3) strcpy (remoteusername, argv[3]); } close (2); /* don't close fd 1, at least init_tty need it */ init_tty (); if (check_ban_and_load (0)){ exit (0); } start_client (); } static void daemon_login (int argc, char *argv[], char *envp[]) { int msock, csock; /* socket for Master and Child */ FILE *fp; int listen_port = 23; int len_of_sock_addr; char buf[256]; /* setup standalone */ start_daemon(); signal_restart(SIGCHLD, reapchild); /* choose port */ if(argc == 1) listen_port = 3006; else if(argc >= 2) listen_port = atoi(argv[1]); sprintf(margs, "%s %d ", argv[0],listen_port); /* port binding */ xsin.sin_family = AF_INET; msock = bind_port(listen_port); if(msock<0) { syslog(LOG_INFO, "mbbsd bind_port failed.\n"); exit(1); } initsetproctitle(argc, argv, envp); setproctitle("%s: listening ", margs); /* Give up root privileges: no way back from here */ setgid(BBSGID); setuid(BBSUID); chdir(BBSHOME); /* mmap passwd file */ if(passwd_mmap()) { exit(1); } sprintf(buf, "run/mbbsd.%d.pid", listen_port); if((fp = fopen(buf, "w"))) { fprintf(fp, "%d\n", getpid()); fclose(fp); } /* main loop */ for(;;) { len_of_sock_addr = sizeof(xsin); csock = accept(msock, (struct sockaddr *)&xsin, &len_of_sock_addr); if(csock < 0) { if(errno!=EINTR) sleep(1); continue; } if(check_ban_and_load(csock)) { close(csock); continue; } if(fork()==0) break; else close(csock); } /* here is only child running */ setproctitle("%s: ...login wait... ", margs); close(msock); dup2(csock, 0); close(csock); getremotename(&xsin, fromhost, remoteusername); telnet_init(); start_client(); close(0); close(1); } /* check if we're banning login and if the load is too high. if login is permitted, return 0; else return -1; approriate message is output to fd. */ static int check_ban_and_load(int fd) { FILE *fp; static char buf[256]; static time_t chkload_time = 0; static int overload = 0; /* overload or banned, update every 1 sec */ static int banned = 0; if((time(0) - chkload_time) > 1) { overload = chkload(buf); banned = !access(BBSHOME "/BAN",R_OK) && (strcmp(fromhost, "localhost") != 0); chkload_time = time(0); } write(fd, buf, strlen(buf)); if(banned && (fp = fopen(BBSHOME "/BAN", "r"))) { while(fgets(buf, 256, fp)) write(fd, buf, strlen(buf)); fclose(fp); } if(banned || overload) return -1; #ifdef INSCREEN write(fd, INSCREEN, strlen(INSCREEN)); #endif return 0; }