| 22 |
#include "io.h" |
#include "io.h" |
| 23 |
#include "file_loader.h" |
#include "file_loader.h" |
| 24 |
#include <fcntl.h> |
#include <fcntl.h> |
|
#include <string.h> |
|
| 25 |
#include <ctype.h> |
#include <ctype.h> |
| 26 |
#include <unistd.h> |
#include <unistd.h> |
| 27 |
#include <stdlib.h> |
#include <stdlib.h> |
| 31 |
#include <sys/param.h> |
#include <sys/param.h> |
| 32 |
#include <sys/shm.h> |
#include <sys/shm.h> |
| 33 |
|
|
| 34 |
|
#define _POSIX_C_SOURCE 200809L |
| 35 |
|
#include <string.h> |
| 36 |
|
|
| 37 |
#define ACTIVE_BOARD_HEIGHT 8 |
#define ACTIVE_BOARD_HEIGHT 8 |
| 38 |
|
|
| 39 |
|
#define STR_TOP_LEFT_MAX_LEN 40 |
| 40 |
|
#define STR_TOP_MIDDLE_MAX_LEN 20 |
| 41 |
|
#define STR_TOP_RIGHT_MAX_LEN 20 |
| 42 |
|
|
| 43 |
void moveto(int row, int col) |
void moveto(int row, int col) |
| 44 |
{ |
{ |
| 45 |
if (row >= 0) |
if (row >= 0) |
| 54 |
|
|
| 55 |
void clrtoeol() |
void clrtoeol() |
| 56 |
{ |
{ |
| 57 |
prints("\033[K"); |
prints(CTRL_SEQ_CLR_LINE); |
| 58 |
} |
} |
| 59 |
|
|
| 60 |
void clrline(int line_begin, int line_end) |
void clrline(int line_begin, int line_end) |
| 64 |
for (i = line_begin; i <= line_end; i++) |
for (i = line_begin; i <= line_end; i++) |
| 65 |
{ |
{ |
| 66 |
moveto(i, 0); |
moveto(i, 0); |
| 67 |
prints("\033[K"); |
prints(CTRL_SEQ_CLR_LINE); |
| 68 |
} |
} |
| 69 |
} |
} |
| 70 |
|
|
| 222 |
int len; |
int len; |
| 223 |
|
|
| 224 |
moveto(row, col); |
moveto(row, col); |
| 225 |
prints(prompt); |
prints("%s", prompt); |
| 226 |
prints(buffer); |
prints("%s", buffer); |
| 227 |
iflush(); |
iflush(); |
| 228 |
|
|
| 229 |
len = _str_input(buffer, buf_size, echo_mode); |
len = _str_input(buffer, buf_size, echo_mode); |
| 231 |
return len; |
return len; |
| 232 |
} |
} |
| 233 |
|
|
| 234 |
int display_file_ex(const char *filename, int begin_line, int wait) |
int display_data(const void *p_data, long line_total, const long *p_line_offsets, int begin_line, int wait) |
| 235 |
{ |
{ |
| 236 |
static int show_help = 1; |
static int show_help = 1; |
| 237 |
char buffer[LINE_BUFFER_LEN]; |
char buffer[LINE_BUFFER_LEN]; |
| 238 |
int ch = KEY_NULL; |
int ch = KEY_NULL; |
| 239 |
int input_ok, line, max_lines; |
int input_ok, line, max_lines; |
| 240 |
long int line_current = 0; |
long int line_current = 0; |
|
const void *p_file_shm; |
|
|
const void *p_data; |
|
|
size_t data_len; |
|
|
long line_total; |
|
|
const long *p_line_offsets; |
|
| 241 |
long int len; |
long int len; |
| 242 |
long int percentile; |
long int percentile; |
| 243 |
int loop; |
int loop; |
| 244 |
|
int eol, display_len; |
|
if ((p_file_shm = get_file_shm(filename)) == NULL) |
|
|
{ |
|
|
log_error("get_file_shm(%s) error\n", filename); |
|
|
return KEY_NULL; |
|
|
} |
|
|
|
|
|
data_len = *((size_t *)p_file_shm); |
|
|
line_total = *((long *)(p_file_shm + sizeof(size_t))); |
|
|
p_data = p_file_shm + sizeof(data_len) + sizeof(line_total); |
|
|
p_line_offsets = p_data + data_len + 1; |
|
| 245 |
|
|
| 246 |
clrline(begin_line, SCREEN_ROWS); |
clrline(begin_line, SCREEN_ROWS); |
| 247 |
line = begin_line; |
line = begin_line; |
| 276 |
percentile = 100; |
percentile = 100; |
| 277 |
} |
} |
| 278 |
|
|
| 279 |
|
snprintf(buffer, sizeof(buffer), |
| 280 |
|
"\033[1;44;33m第\033[32m%ld\033[33m-\033[32m%ld\033[33m行 (\033[32m%ld%%\033[33m) │ " |
| 281 |
|
"返回[\033[32m←\033[33m,\033[32mESC\033[33m] │ 移动[\033[32m↑\033[33m/\033[32m↓\033[33m/\033[32mPgUp\033[33m/\033[32mPgDn\033[33m] │ " |
| 282 |
|
"帮助[\033[32mh\033[33m] │", |
| 283 |
|
line_current - (line - 1) + 1, |
| 284 |
|
MIN(line_current - (line - 1) + (SCREEN_ROWS - 2), line_total), |
| 285 |
|
percentile); |
| 286 |
|
|
| 287 |
|
len = split_line(buffer, SCREEN_COLS, &eol, &display_len); |
| 288 |
|
for (;display_len < SCREEN_COLS; display_len++) |
| 289 |
|
{ |
| 290 |
|
buffer[len++] = ' '; |
| 291 |
|
} |
| 292 |
|
buffer[len] = '\0'; |
| 293 |
|
strncat(buffer, "\033[m", sizeof(buffer) - 1 - strnlen(buffer, sizeof(buffer))); |
| 294 |
|
|
| 295 |
moveto(SCREEN_ROWS, 0); |
moveto(SCREEN_ROWS, 0); |
| 296 |
prints("\033[1;44;32m%s (%d%%)%s\033[33m │ 结束 ← <q> │ ↑/↓/PgUp/PgDn 移动 │ ? 辅助说明 │ \033[m", |
prints("%s", buffer); |
|
(percentile < 100 ? "下面还有喔" : "没有更多了"), percentile, |
|
|
(percentile < 10 ? " " : (percentile < 100 ? " " : ""))); |
|
| 297 |
iflush(); |
iflush(); |
| 298 |
|
|
| 299 |
input_ok = 0; |
input_ok = 0; |
| 303 |
input_ok = 1; |
input_ok = 1; |
| 304 |
switch (ch) |
switch (ch) |
| 305 |
{ |
{ |
| 306 |
// case KEY_NULL: |
case KEY_NULL: |
| 307 |
case KEY_TIMEOUT: |
case KEY_TIMEOUT: |
| 308 |
goto cleanup; |
goto cleanup; |
| 309 |
case KEY_HOME: |
case KEY_HOME: |
| 331 |
break; |
break; |
| 332 |
case CR: |
case CR: |
| 333 |
igetch_reset(); |
igetch_reset(); |
| 334 |
|
case KEY_SPACE: |
| 335 |
case KEY_DOWN: |
case KEY_DOWN: |
| 336 |
if (line_current + ((SCREEN_ROWS - 2) - (line - 1)) >= line_total) // Reach bottom |
if (line_current + ((SCREEN_ROWS - 2) - (line - 1)) >= line_total) // Reach bottom |
| 337 |
{ |
{ |
| 345 |
prints("\033[S"); // Scroll up 1 line |
prints("\033[S"); // Scroll up 1 line |
| 346 |
break; |
break; |
| 347 |
case KEY_PGUP: |
case KEY_PGUP: |
|
case Ctrl('B'): |
|
| 348 |
if (line_current - line < 0) // Reach top |
if (line_current - line < 0) // Reach top |
| 349 |
{ |
{ |
| 350 |
break; |
break; |
| 358 |
max_lines = SCREEN_ROWS - 1; |
max_lines = SCREEN_ROWS - 1; |
| 359 |
clrline(begin_line, SCREEN_ROWS); |
clrline(begin_line, SCREEN_ROWS); |
| 360 |
break; |
break; |
|
case KEY_RIGHT: |
|
| 361 |
case KEY_PGDN: |
case KEY_PGDN: |
|
case Ctrl('F'): |
|
|
case KEY_SPACE: |
|
| 362 |
if (line_current + (SCREEN_ROWS - 2) - (line - 1) >= line_total) // Reach bottom |
if (line_current + (SCREEN_ROWS - 2) - (line - 1) >= line_total) // Reach bottom |
| 363 |
{ |
{ |
| 364 |
break; |
break; |
| 372 |
max_lines = SCREEN_ROWS - 1; |
max_lines = SCREEN_ROWS - 1; |
| 373 |
clrline(begin_line, SCREEN_ROWS); |
clrline(begin_line, SCREEN_ROWS); |
| 374 |
break; |
break; |
| 375 |
|
case KEY_ESC: |
| 376 |
case KEY_LEFT: |
case KEY_LEFT: |
|
case 'q': |
|
|
case 'Q': |
|
| 377 |
loop = 0; |
loop = 0; |
| 378 |
break; |
break; |
|
case '?': |
|
| 379 |
case 'h': |
case 'h': |
|
case 'H': |
|
| 380 |
if (!show_help) |
if (!show_help) |
| 381 |
{ |
{ |
| 382 |
break; |
break; |
| 384 |
|
|
| 385 |
// Display help information |
// Display help information |
| 386 |
show_help = 0; |
show_help = 0; |
| 387 |
display_file_ex(DATA_READ_HELP, begin_line, 1); |
display_file(DATA_READ_HELP, begin_line, 1); |
| 388 |
show_help = 1; |
show_help = 1; |
| 389 |
|
|
| 390 |
// Refresh after display help information |
// Refresh after display help information |
| 407 |
len = p_line_offsets[line_current + 1] - p_line_offsets[line_current]; |
len = p_line_offsets[line_current + 1] - p_line_offsets[line_current]; |
| 408 |
if (len >= LINE_BUFFER_LEN) |
if (len >= LINE_BUFFER_LEN) |
| 409 |
{ |
{ |
| 410 |
log_error("Error length exceeds buffer size: %d\n", len); |
log_error("buffer overflow: len=%ld(%ld - %ld) line=%ld \n", |
| 411 |
|
len, p_line_offsets[line_current + 1], p_line_offsets[line_current], line_current); |
| 412 |
len = LINE_BUFFER_LEN - 1; |
len = LINE_BUFFER_LEN - 1; |
| 413 |
} |
} |
| 414 |
|
|
| 423 |
} |
} |
| 424 |
|
|
| 425 |
cleanup: |
cleanup: |
|
if (shmdt(p_file_shm) == -1) |
|
|
{ |
|
|
log_error("shmdt() error (%d)\n", errno); |
|
|
} |
|
|
|
|
| 426 |
return ch; |
return ch; |
| 427 |
} |
} |
| 428 |
|
|
| 429 |
int show_top(const char *status) |
int display_file(const char *filename, int begin_line, int wait) |
| 430 |
{ |
{ |
| 431 |
char status_f[21]; |
int ch = KEY_NULL; |
| 432 |
int truncate; |
const void *p_shm; |
| 433 |
int status_len; |
size_t data_len; |
| 434 |
int section_name_len; |
long line_total; |
| 435 |
int len; |
const void *p_data; |
| 436 |
|
const long *p_line_offsets; |
|
strncpy(status_f, status, sizeof(status_f) - 1); |
|
|
status_f[sizeof(status_f) - 1] = '\0'; |
|
| 437 |
|
|
| 438 |
len = split_line(status_f, 20, &truncate, &status_len); |
if ((p_shm = get_file_shm_readonly(filename, &data_len, &line_total, &p_data, &p_line_offsets)) == NULL) |
|
if (truncate) |
|
| 439 |
{ |
{ |
| 440 |
log_error("Status string is truncated\n"); |
log_error("get_file_shm(%s) error\n", filename); |
| 441 |
status_f[len] = '\0'; |
return KEY_NULL; |
| 442 |
} |
} |
| 443 |
|
|
| 444 |
len = split_line(BBS_current_section_name, 20, &truncate, §ion_name_len); |
ch = display_data(p_data, line_total, p_line_offsets, begin_line, wait); |
| 445 |
if (truncate) |
|
| 446 |
|
if (detach_file_shm(p_shm) < 0) |
| 447 |
{ |
{ |
| 448 |
log_error("Section name is truncated\n"); |
log_error("detach_file_shm(%s) error\n", filename); |
| 449 |
} |
} |
| 450 |
|
|
| 451 |
|
return ch; |
| 452 |
|
} |
| 453 |
|
|
| 454 |
|
int show_top(const char *str_left, const char *str_middle, const char *str_right) |
| 455 |
|
{ |
| 456 |
|
char str_left_f[STR_TOP_LEFT_MAX_LEN + 1]; |
| 457 |
|
char str_middle_f[STR_TOP_MIDDLE_MAX_LEN + 1]; |
| 458 |
|
char str_right_f[STR_TOP_RIGHT_MAX_LEN + 1]; |
| 459 |
|
int str_left_len; |
| 460 |
|
int str_middle_len; |
| 461 |
|
int str_right_len; |
| 462 |
|
int eol; |
| 463 |
|
int len; |
| 464 |
|
|
| 465 |
|
strncpy(str_left_f, str_left, sizeof(str_left_f) - 1); |
| 466 |
|
str_left_f[sizeof(str_left_f) - 1] = '\0'; |
| 467 |
|
len = split_line(str_left_f, STR_TOP_LEFT_MAX_LEN, &eol, &str_left_len); |
| 468 |
|
str_left_f[len] = '\0'; |
| 469 |
|
|
| 470 |
|
strncpy(str_middle_f, str_middle, sizeof(str_middle_f) - 1); |
| 471 |
|
str_middle_f[sizeof(str_middle_f) - 1] = '\0'; |
| 472 |
|
len = split_line(str_middle, STR_TOP_MIDDLE_MAX_LEN, &eol, &str_middle_len); |
| 473 |
|
str_middle_f[len] = '\0'; |
| 474 |
|
|
| 475 |
|
strncpy(str_right_f, str_right, sizeof(str_right_f) - 1); |
| 476 |
|
str_right_f[sizeof(str_right_f) - 1] = '\0'; |
| 477 |
|
len = split_line(str_right, STR_TOP_RIGHT_MAX_LEN, &eol, &str_right_len); |
| 478 |
|
str_right_f[len] = '\0'; |
| 479 |
|
|
| 480 |
moveto(1, 0); |
moveto(1, 0); |
| 481 |
clrtoeol(); |
clrtoeol(); |
| 482 |
prints("\033[1;44;33m%s\033[37m%*s%*s\033[33m 讨论区 [%s]\033[m", |
prints("\033[1;44;33m%s\033[37m%*s\033[33m%*s\033[m", |
| 483 |
status_f, 32, BBS_name, 26, "", BBS_current_section_name); |
str_left_f, 44 - str_left_len, str_middle_f, 36, str_right_f); |
|
iflush(); |
|
| 484 |
|
|
| 485 |
return 0; |
return 0; |
| 486 |
} |
} |
| 490 |
char str_time[LINE_BUFFER_LEN]; |
char str_time[LINE_BUFFER_LEN]; |
| 491 |
time_t time_online; |
time_t time_online; |
| 492 |
struct tm *tm_online; |
struct tm *tm_online; |
| 493 |
char msg_f[21]; |
char msg_f[LINE_BUFFER_LEN]; |
| 494 |
int truncate; |
int eol; |
| 495 |
int msg_len; |
int msg_len; |
| 496 |
int len; |
int len; |
| 497 |
int len_username; |
int len_username; |
| 498 |
|
|
| 499 |
get_time_str(str_time, sizeof(str_time)); |
get_time_str(str_time, sizeof(str_time)); |
| 500 |
|
|
| 501 |
strncpy(msg_f, msg, sizeof(msg_f) - 1); |
msg_f[0] = '\0'; |
| 502 |
msg_f[sizeof(msg_f) - 1] = '\0'; |
msg_len = 0; |
| 503 |
|
if (msg != NULL) |
| 504 |
len = split_line(msg_f, 20, &truncate, &msg_len); |
{ |
| 505 |
if (truncate) |
strncpy(msg_f, msg, sizeof(msg_f) - 1); |
| 506 |
{ |
msg_f[sizeof(msg_f) - 1] = '\0'; |
| 507 |
log_error("Status string is truncated\n"); |
len = split_line(msg_f, 23, &eol, &msg_len); |
| 508 |
msg_f[len] = '\0'; |
msg_f[len] = '\0'; |
| 509 |
} |
} |
| 510 |
|
|
| 515 |
|
|
| 516 |
moveto(SCREEN_ROWS, 0); |
moveto(SCREEN_ROWS, 0); |
| 517 |
clrtoeol(); |
clrtoeol(); |
| 518 |
prints("\033[1;44;33m[\033[36m%s\033[33m]%*s%*s帐号[\033[36m%s\033[33m]" |
prints("\033[1;44;33m时间[\033[36m%s\033[33m]%s%*s \033[33m帐号[\033[36m%s\033[33m]" |
| 519 |
"[\033[36m%1d\033[33m:\033[36m%2d\033[33m:\033[36m%2d\033[33m]\033[m", |
"[\033[36m%1d\033[33m天\033[36m%2d\033[33m时\033[36m%2d\033[33m分]\033[m", |
| 520 |
str_time, 21, msg_f, 13 - len_username, "", BBS_username, |
str_time, msg_f, 35 - msg_len - len_username, "", BBS_username, |
| 521 |
tm_online->tm_mday - 1, tm_online->tm_hour, tm_online->tm_min); |
tm_online->tm_mday - 1, tm_online->tm_hour, tm_online->tm_min); |
|
iflush(); |
|
| 522 |
|
|
| 523 |
return 0; |
return 0; |
| 524 |
} |
} |
| 526 |
int show_active_board() |
int show_active_board() |
| 527 |
{ |
{ |
| 528 |
static int line_current = 0; |
static int line_current = 0; |
| 529 |
static const void *p_file_shm = NULL; |
static const void *p_shm = NULL; |
|
static const void *p_data; |
|
| 530 |
static size_t data_len; |
static size_t data_len; |
| 531 |
static long line_total; |
static long line_total; |
| 532 |
|
static const void *p_data; |
| 533 |
static const long *p_line_offsets; |
static const long *p_line_offsets; |
| 534 |
|
|
| 535 |
|
static time_t t_last_show = 0; |
| 536 |
|
static int line_last = 0; |
| 537 |
|
|
| 538 |
char buffer[LINE_BUFFER_LEN]; |
char buffer[LINE_BUFFER_LEN]; |
| 539 |
long int len; |
long int len; |
| 540 |
|
|
| 541 |
if (p_file_shm == NULL) |
if (p_shm == NULL) |
| 542 |
{ |
{ |
| 543 |
if ((p_file_shm = get_file_shm(DATA_ACTIVE_BOARD)) == NULL) |
if ((p_shm = get_file_shm_readonly(DATA_ACTIVE_BOARD, &data_len, &line_total, &p_data, &p_line_offsets)) == NULL) |
| 544 |
{ |
{ |
| 545 |
log_error("get_file_shm(%s) error\n", DATA_ACTIVE_BOARD); |
log_error("get_file_shm(%s) error\n", DATA_ACTIVE_BOARD); |
| 546 |
return KEY_NULL; |
return KEY_NULL; |
| 547 |
} |
} |
| 548 |
|
} |
| 549 |
|
|
| 550 |
data_len = *((size_t *)p_file_shm); |
if (time(0) - t_last_show >= 10) |
| 551 |
line_total = *((long *)(p_file_shm + sizeof(size_t))); |
{ |
| 552 |
p_data = p_file_shm + sizeof(data_len) + sizeof(line_total); |
line_last = line_current; |
| 553 |
p_line_offsets = p_data + data_len + 1; |
t_last_show = time(0); |
| 554 |
|
} |
| 555 |
|
else |
| 556 |
|
{ |
| 557 |
|
line_current = line_last; |
| 558 |
} |
} |
| 559 |
|
|
| 560 |
clrline(3, 2 + ACTIVE_BOARD_HEIGHT); |
clrline(2, 2 + ACTIVE_BOARD_HEIGHT); |
| 561 |
|
|
| 562 |
for (int i = 0; i < ACTIVE_BOARD_HEIGHT; i++) |
for (int i = 0; i < ACTIVE_BOARD_HEIGHT; i++) |
| 563 |
{ |
{ |
| 564 |
len = p_line_offsets[line_current + 1] - p_line_offsets[line_current]; |
len = p_line_offsets[line_current + 1] - p_line_offsets[line_current]; |
| 565 |
if (len >= LINE_BUFFER_LEN) |
if (len >= LINE_BUFFER_LEN) |
| 566 |
{ |
{ |
| 567 |
log_error("Error length exceeds buffer size: %d\n", len); |
log_error("buffer overflow: len=%ld(%ld - %ld) line=%ld \n", |
| 568 |
|
len, p_line_offsets[line_current + 1], p_line_offsets[line_current], line_current); |
| 569 |
len = LINE_BUFFER_LEN - 1; |
len = LINE_BUFFER_LEN - 1; |
| 570 |
} |
} |
| 571 |
|
|
| 582 |
break; |
break; |
| 583 |
} |
} |
| 584 |
} |
} |
|
iflush(); |
|
| 585 |
|
|
| 586 |
return 0; |
return 0; |
| 587 |
} |
} |