| 1 |
/*************************************************************************** |
/* SPDX-License-Identifier: GPL-3.0-or-later */ |
| 2 |
login.c - description |
/* |
| 3 |
------------------- |
* login |
| 4 |
Copyright : (C) 2004-2025 by Leaflet |
* - user authentication and online status manager |
| 5 |
Email : leaflet@leafok.com |
* |
| 6 |
***************************************************************************/ |
* Copyright (C) 2004-2025 Leaflet <leaflet@leafok.com> |
| 7 |
|
*/ |
| 8 |
/*************************************************************************** |
|
| 9 |
* * |
#ifdef HAVE_CONFIG_H |
| 10 |
* This program is free software; you can redistribute it and/or modify * |
#include "config.h" |
| 11 |
* it under the terms of the GNU General Public License as published by * |
#endif |
|
* the Free Software Foundation; either version 3 of the License, or * |
|
|
* (at your option) any later version. * |
|
|
* * |
|
|
***************************************************************************/ |
|
| 12 |
|
|
| 13 |
#include "bbs.h" |
#include "bbs.h" |
| 14 |
#include "common.h" |
#include "common.h" |
| 25 |
#include <string.h> |
#include <string.h> |
| 26 |
#include <regex.h> |
#include <regex.h> |
| 27 |
#include <unistd.h> |
#include <unistd.h> |
| 28 |
#include <mysql/mysql.h> |
#include <mysql.h> |
| 29 |
|
#include <sys/param.h> |
| 30 |
|
|
| 31 |
|
static const int BBS_username_min_len = 3; // common len = 5, special len = 3 |
| 32 |
|
static const int BBS_password_min_len = 5; // legacy len = 5, current len = 6 |
| 33 |
|
|
| 34 |
|
static const int BBS_allowed_login_failures_within_interval = 10; |
| 35 |
|
static const int BBS_login_failures_count_interval = 10; // minutes |
| 36 |
|
static const int BBS_allowed_login_failures_per_account = 3; |
| 37 |
|
|
| 38 |
|
const int BBS_login_retry_times = 3; |
| 39 |
|
|
| 40 |
int bbs_login(void) |
int bbs_login(void) |
| 41 |
{ |
{ |
| 43 |
char password[BBS_password_max_len + 1]; |
char password[BBS_password_max_len + 1]; |
| 44 |
int i = 0; |
int i = 0; |
| 45 |
int ok = 0; |
int ok = 0; |
| 46 |
|
int ret; |
| 47 |
|
|
| 48 |
for (; !SYS_server_exit && !ok && i < BBS_login_retry_times; i++) |
for (; !SYS_server_exit && !ok && i < BBS_login_retry_times; i++) |
| 49 |
{ |
{ |
| 80 |
continue; |
continue; |
| 81 |
} |
} |
| 82 |
|
|
| 83 |
ok = (check_user(username, password) == 0); |
ret = check_user(username, password); |
| 84 |
|
if (ret == 2) // Enforce update user agreement |
| 85 |
|
{ |
| 86 |
|
BBS_update_eula = 1; |
| 87 |
|
ret = 0; |
| 88 |
|
} |
| 89 |
|
|
| 90 |
|
ok = (ret == 0); |
| 91 |
iflush(); |
iflush(); |
| 92 |
} |
} |
| 93 |
} |
} |
| 98 |
return -1; |
return -1; |
| 99 |
} |
} |
| 100 |
|
|
|
log_common("User \"%s\"(%ld) login from %s:%d\n", |
|
|
BBS_username, BBS_priv.uid, hostaddr_client, port_client); |
|
|
|
|
| 101 |
return 0; |
return 0; |
| 102 |
} |
} |
| 103 |
|
|
| 124 |
// Verify format |
// Verify format |
| 125 |
for (i = 0; ok && username[i] != '\0'; i++) |
for (i = 0; ok && username[i] != '\0'; i++) |
| 126 |
{ |
{ |
| 127 |
if (!(isalpha(username[i]) || (i > 0 && isdigit(username[i])))) |
if (!(isalpha((int)username[i]) || (i > 0 && (isdigit((int)username[i]) || username[i] == '_')))) |
| 128 |
{ |
{ |
| 129 |
ok = 0; |
ok = 0; |
| 130 |
} |
} |
| 131 |
} |
} |
| 132 |
if (ok && (i < 3 || i > 12)) |
if (ok && (i < BBS_username_min_len || i > BBS_username_max_len)) |
| 133 |
{ |
{ |
| 134 |
ok = 0; |
ok = 0; |
| 135 |
} |
} |
| 136 |
for (i = 0; ok && password[i] != '\0'; i++) |
for (i = 0; ok && password[i] != '\0'; i++) |
| 137 |
{ |
{ |
| 138 |
if (!isalnum(password[i])) |
if (!isalnum((int)password[i])) |
| 139 |
{ |
{ |
| 140 |
ok = 0; |
ok = 0; |
| 141 |
} |
} |
| 142 |
} |
} |
| 143 |
if (ok && (i < 5 || i > 12)) |
if (ok && (i < BBS_password_min_len || i > BBS_password_max_len)) |
| 144 |
{ |
{ |
| 145 |
ok = 0; |
ok = 0; |
| 146 |
} |
} |
| 324 |
goto cleanup; |
goto cleanup; |
| 325 |
} |
} |
| 326 |
|
|
| 327 |
|
if (!SSH_v2 && checklevel2(&BBS_priv, P_MAN_S)) |
| 328 |
|
{ |
| 329 |
|
prints("\033[1;31m非普通账户必须使用SSH方式登录\033[m\r\n"); |
| 330 |
|
ret = 1; |
| 331 |
|
goto cleanup; |
| 332 |
|
} |
| 333 |
|
|
| 334 |
ret = load_user_info(db, BBS_uid); |
ret = load_user_info(db, BBS_uid); |
| 335 |
|
|
| 336 |
switch (ret) |
switch (ret) |
| 341 |
prints("\033[1;31m读取用户数据错误...\033[m\r\n"); |
prints("\033[1;31m读取用户数据错误...\033[m\r\n"); |
| 342 |
ret = -1; |
ret = -1; |
| 343 |
goto cleanup; |
goto cleanup; |
| 344 |
case -2: // Unused |
case -2: // Enforce update user agreement |
| 345 |
prints("\033[1;31m请通过Web登录更新用户许可协议...\033[m\r\n"); |
ret = 2; |
|
ret = 1; |
|
| 346 |
goto cleanup; |
goto cleanup; |
| 347 |
case -3: // Dead |
case -3: // Dead |
| 348 |
prints("\033[1;31m很遗憾,您已经永远离开了我们的世界!\033[m\r\n"); |
prints("\033[1;31m很遗憾,您已经永远离开了我们的世界!\033[m\r\n"); |
| 450 |
|
|
| 451 |
if (load_priv(db, &BBS_priv, BBS_uid) != 0) |
if (load_priv(db, &BBS_priv, BBS_uid) != 0) |
| 452 |
{ |
{ |
| 453 |
ret = -1; |
ret = -1; // Data not found |
| 454 |
|
goto cleanup; |
| 455 |
|
} |
| 456 |
|
|
| 457 |
|
if (last_login_dt < BBS_eula_tm) |
| 458 |
|
{ |
| 459 |
|
ret = -2; // require update agreement first |
| 460 |
goto cleanup; |
goto cleanup; |
| 461 |
} |
} |
| 462 |
|
|
| 510 |
{ |
{ |
| 511 |
char sql[SQL_BUFFER_LEN]; |
char sql[SQL_BUFFER_LEN]; |
| 512 |
|
|
| 513 |
if (user_online_del(db) != 0) |
snprintf(sql, sizeof(sql), |
| 514 |
|
"INSERT INTO visit_log(dt, IP) VALUES(NOW(), '%s')", |
| 515 |
|
hostaddr_client); |
| 516 |
|
if (mysql_query(db, sql) != 0) |
| 517 |
{ |
{ |
| 518 |
|
log_error("Add visit log error: %s\n", mysql_error(db)); |
| 519 |
return -1; |
return -1; |
| 520 |
} |
} |
| 521 |
|
|
| 522 |
|
if (user_online_del(db) != 0) |
| 523 |
|
{ |
| 524 |
|
return -2; |
| 525 |
|
} |
| 526 |
|
|
| 527 |
snprintf(sql, sizeof(sql), |
snprintf(sql, sizeof(sql), |
| 528 |
"INSERT INTO user_online(SID, UID, ip, login_tm, last_tm) " |
"INSERT INTO user_online(SID, UID, ip, current_action, login_tm, last_tm) " |
| 529 |
"VALUES('Telnet_Process_%d', %d, '%s', NOW(), NOW())", |
"VALUES('Telnet_Process_%d', %d, '%s', 'LOGIN', NOW(), NOW())", |
| 530 |
getpid(), BBS_priv.uid, hostaddr_client); |
getpid(), BBS_priv.uid, hostaddr_client); |
| 531 |
if (mysql_query(db, sql) != 0) |
if (mysql_query(db, sql) != 0) |
| 532 |
{ |
{ |
| 533 |
log_error("Add user_online error: %s\n", mysql_error(db)); |
log_error("Add user_online error: %s\n", mysql_error(db)); |
| 534 |
return -1; |
return -3; |
| 535 |
} |
} |
| 536 |
|
|
| 537 |
return 0; |
return 0; |
| 553 |
return 0; |
return 0; |
| 554 |
} |
} |
| 555 |
|
|
| 556 |
|
int user_online_exp(MYSQL *db) |
| 557 |
|
{ |
| 558 |
|
char sql[SQL_BUFFER_LEN]; |
| 559 |
|
|
| 560 |
|
// +1 exp for every 5 minutes online since last logout |
| 561 |
|
// but at most 24 hours worth of exp can be gained in Telnet session |
| 562 |
|
snprintf(sql, sizeof(sql), |
| 563 |
|
"UPDATE user_pubinfo SET exp = exp + FLOOR(LEAST(TIMESTAMPDIFF(" |
| 564 |
|
"SECOND, GREATEST(last_login_dt, IF(last_logout_dt IS NULL, last_login_dt, last_logout_dt)), NOW()" |
| 565 |
|
") / 60 / 5, 12 * 24)), last_logout_dt = NOW() " |
| 566 |
|
"WHERE UID = %d", |
| 567 |
|
BBS_priv.uid); |
| 568 |
|
if (mysql_query(db, sql) != 0) |
| 569 |
|
{ |
| 570 |
|
log_error("Update user_pubinfo error: %s\n", mysql_error(db)); |
| 571 |
|
return -1; |
| 572 |
|
} |
| 573 |
|
|
| 574 |
|
return 0; |
| 575 |
|
} |
| 576 |
|
|
| 577 |
int user_online_update(const char *action) |
int user_online_update(const char *action) |
| 578 |
{ |
{ |
| 579 |
MYSQL *db = NULL; |
MYSQL *db = NULL; |
| 601 |
} |
} |
| 602 |
|
|
| 603 |
snprintf(sql, sizeof(sql), |
snprintf(sql, sizeof(sql), |
| 604 |
"UPDATE user_online SET current_action = '%s', last_tm=NOW() " |
"UPDATE user_online SET current_action = '%s', last_tm = NOW() " |
| 605 |
"WHERE SID = 'Telnet_Process_%d'", |
"WHERE SID = 'Telnet_Process_%d'", |
| 606 |
BBS_current_action, getpid()); |
BBS_current_action, getpid()); |
| 607 |
if (mysql_query(db, sql) != 0) |
if (mysql_query(db, sql) != 0) |
| 614 |
|
|
| 615 |
return 1; |
return 1; |
| 616 |
} |
} |
| 617 |
|
|
| 618 |
|
int user_update_agreement(void) |
| 619 |
|
{ |
| 620 |
|
MYSQL *db = NULL; |
| 621 |
|
char sql[SQL_BUFFER_LEN]; |
| 622 |
|
int ch; |
| 623 |
|
int ret = 0; |
| 624 |
|
|
| 625 |
|
clearscr(); |
| 626 |
|
moveto(2, 1); |
| 627 |
|
prints("尊敬的用户:"); |
| 628 |
|
moveto(3, 1); |
| 629 |
|
prints(" 本站的《用户许可协议》已更新,您必须在仔细阅读并接受后,才能继续使用本站提供的服务。"); |
| 630 |
|
press_any_key(); |
| 631 |
|
|
| 632 |
|
clearscr(); |
| 633 |
|
display_file(DATA_EULA, 1); |
| 634 |
|
|
| 635 |
|
while (!SYS_server_exit) |
| 636 |
|
{ |
| 637 |
|
clearscr(); |
| 638 |
|
moveto(2, 1); |
| 639 |
|
|
| 640 |
|
ch = press_any_key_ex("您是否接受本站的《用户许可协议》? (A)接受, (D)拒绝, (R)再看看协议 [D]", 60); |
| 641 |
|
switch (toupper(ch)) |
| 642 |
|
{ |
| 643 |
|
case KEY_NULL: |
| 644 |
|
return -1; |
| 645 |
|
case KEY_TIMEOUT: |
| 646 |
|
case CR: |
| 647 |
|
case 'D': |
| 648 |
|
moveto(3, 1); |
| 649 |
|
prints("您已拒绝《用户许可协议》,再见!"); |
| 650 |
|
press_any_key(); |
| 651 |
|
return 0; |
| 652 |
|
case 'R': |
| 653 |
|
clearscr(); |
| 654 |
|
display_file(DATA_EULA, 1); |
| 655 |
|
continue; |
| 656 |
|
case 'A': |
| 657 |
|
db = db_open(); |
| 658 |
|
if (db == NULL) |
| 659 |
|
{ |
| 660 |
|
ret = -1; |
| 661 |
|
goto cleanup; |
| 662 |
|
} |
| 663 |
|
|
| 664 |
|
snprintf(sql, sizeof(sql), |
| 665 |
|
"UPDATE user_pubinfo SET visit_count = visit_count + 1, " |
| 666 |
|
"last_login_dt = NOW() WHERE UID = %d", |
| 667 |
|
BBS_priv.uid); |
| 668 |
|
if (mysql_query(db, sql) != 0) |
| 669 |
|
{ |
| 670 |
|
log_error("Update user_pubinfo error: %s\n", mysql_error(db)); |
| 671 |
|
ret = -1; |
| 672 |
|
goto cleanup; |
| 673 |
|
} |
| 674 |
|
|
| 675 |
|
mysql_close(db); |
| 676 |
|
db = NULL; |
| 677 |
|
|
| 678 |
|
moveto(3, 1); |
| 679 |
|
prints("您已接受《用户许可协议》,请重新登陆。"); |
| 680 |
|
press_any_key(); |
| 681 |
|
return 1; |
| 682 |
|
default: |
| 683 |
|
continue; |
| 684 |
|
} |
| 685 |
|
|
| 686 |
|
break; |
| 687 |
|
} |
| 688 |
|
|
| 689 |
|
cleanup: |
| 690 |
|
mysql_close(db); |
| 691 |
|
|
| 692 |
|
return ret; |
| 693 |
|
} |