#include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #if defined(linux) #include #elif defined(__OpenBSD__) || defined(__NetBSD__) || defined(__APPLE__) #include #elif defined(__FreeBSD__) #include #elif defined(__sun) #include "os/sunos.h" #endif #if defined(ENABLE_WWW) #include #endif #include #include "bbs.h" #include "inih/ini.h" #include "hashmap/hashmap.h" map_t ip_guard_map; extern struct bbs_config conf; extern struct user_record *gUser; int ssh_pid = -1; int bbs_pid = 0; int server_socket = -1; int ipv6_pid = -1; int bbs_stdin; int bbs_stdout; int bbs_stderr; #if defined(ENABLE_WWW) struct MHD_Daemon *www_daemon; #endif void sigterm_handler(int s) { if (ssh_pid != -1) { kill(ssh_pid, SIGTERM); } if (server_socket != -1) { close(server_socket); } #if defined(ENABLE_WWW) if (www_daemon != NULL) { MHD_stop_daemon(www_daemon); } #endif if (ipv6_pid != -1) { kill(ipv6_pid, SIGTERM); } remove(conf.pid_file); exit(0); } void sigchld_handler(int s) { // waitpid() might overwrite errno, so we save and restore it: int saved_errno = errno; while (waitpid(-1, NULL, WNOHANG) > 0) ; errno = saved_errno; } static int protocol_config_handler(void *user, const char *section, const char *name, const char *value) { struct bbs_config *conf = (struct bbs_config *)user; int i; for (i = 0; i < conf->protocol_count; i++) { if (strcasecmp(conf->protocols[i]->name, section) == 0) { // found it if (strcasecmp(name, "upload command") == 0) { conf->protocols[i]->upload = strdup(value); } else if (strcasecmp(name, "download command") == 0) { conf->protocols[i]->download = strdup(value); } else if (strcasecmp(name, "internal zmodem") == 0) { if (strcasecmp(value, "true") == 0) { conf->protocols[i]->internal_zmodem = 1; } else { conf->protocols[i]->internal_zmodem = 0; } } else if (strcasecmp(name, "stdio") == 0) { if (strcasecmp(value, "true") == 0) { conf->protocols[i]->stdio = 1; } else { conf->protocols[i]->stdio = 0; } } else if (strcasecmp(name, "upload prompt") == 0) { if (strcasecmp(value, "true") == 0) { conf->protocols[i]->upload_prompt = 1; } else { conf->protocols[i]->upload_prompt = 0; } } return 1; } } if (conf->protocol_count == 0) { conf->protocols = (struct protocol **)malloz(sizeof(struct protocol *)); } else { conf->protocols = (struct protocol **)realloc(conf->protocols, sizeof(struct protocol *) * (conf->protocol_count + 1)); } conf->protocols[conf->protocol_count] = (struct protocol *)malloz(sizeof(struct protocol)); conf->protocols[conf->protocol_count]->name = strdup(section); conf->protocols[conf->protocol_count]->internal_zmodem = 0; conf->protocols[conf->protocol_count]->upload_prompt = 0; conf->protocols[conf->protocol_count]->stdio = 0; if (strcasecmp(name, "upload command") == 0) { conf->protocols[conf->protocol_count]->upload = strdup(value); } else if (strcasecmp(name, "download command") == 0) { conf->protocols[conf->protocol_count]->download = strdup(value); } else if (strcasecmp(name, "internal zmodem") == 0) { if (strcasecmp(value, "true") == 0) { conf->protocols[conf->protocol_count]->internal_zmodem = 1; } else { conf->protocols[conf->protocol_count]->internal_zmodem = 0; } } else if (strcasecmp(name, "stdio") == 0) { if (strcasecmp(value, "true") == 0) { conf->protocols[conf->protocol_count]->stdio = 1; } else { conf->protocols[conf->protocol_count]->stdio = 0; } } else if (strcasecmp(name, "upload prompt") == 0) { if (strcasecmp(value, "true") == 0) { conf->protocols[conf->protocol_count]->upload_prompt = 1; } else { conf->protocols[conf->protocol_count]->upload_prompt = 0; } } conf->protocol_count++; return 1; } static int archiver_config_handler(void *user, const char *section, const char *name, const char *value) { struct bbs_config *conf = (struct bbs_config *)user; int i; for (i = 0; i < conf->archiver_count; i++) { if (strcasecmp(conf->archivers[i]->name, section) == 0) { // found it if (strcasecmp(name, "extension") == 0) { conf->archivers[i]->extension = strdup(value); } else if (strcasecmp(name, "unpack") == 0) { conf->archivers[i]->unpack = strdup(value); } else if (strcasecmp(name, "pack") == 0) { conf->archivers[i]->pack = strdup(value); } return 1; } } if (conf->archiver_count == 0) { conf->archivers = (struct archiver **)malloz(sizeof(struct archiver *)); } else { conf->archivers = (struct archiver **)realloc(conf->archivers, sizeof(struct archiver *) * (conf->archiver_count + 1)); } conf->archivers[conf->archiver_count] = (struct archiver *)malloz(sizeof(struct archiver)); conf->archivers[conf->archiver_count]->name = strdup(section); if (strcasecmp(name, "extension") == 0) { conf->archivers[conf->archiver_count]->extension = strdup(value); } else if (strcasecmp(name, "unpack") == 0) { conf->archivers[conf->archiver_count]->unpack = strdup(value); } else if (strcasecmp(name, "pack") == 0) { conf->archivers[conf->archiver_count]->pack = strdup(value); } conf->archiver_count++; return 1; } static int door_config_handler(void *user, const char *section, const char *name, const char *value) { struct bbs_config *conf = (struct bbs_config *)user; int i; for (i = 0; i < conf->door_count; i++) { if (strcasecmp(conf->doors[i]->name, section) == 0) { // found it if (strcasecmp(name, "command") == 0) { conf->doors[i]->command = strdup(value); } else if (strcasecmp(name, "stdio") == 0) { if (strcasecmp(value, "true") == 0) { conf->doors[i]->stdio = 1; } else { conf->doors[i]->stdio = 0; } } else if (strcasecmp(name, "codepage") == 0) { conf->doors[i]->codepage = strdup(value); } return 1; } } if (conf->door_count == 0) { conf->doors = (struct door_config **)malloz(sizeof(struct door_config *)); } else { conf->doors = (struct door_config **)realloc(conf->doors, sizeof(struct door_config *) * (conf->door_count + 1)); } conf->doors[conf->door_count] = (struct door_config *)malloz(sizeof(struct door_config)); conf->doors[conf->door_count]->name = strdup(section); conf->doors[conf->door_count]->codepage = NULL; if (strcasecmp(name, "command") == 0) { conf->doors[conf->door_count]->command = strdup(value); } else if (strcasecmp(name, "stdio") == 0) { if (strcasecmp(value, "true") == 0) { conf->doors[conf->door_count]->stdio = 1; } else { conf->doors[conf->door_count]->stdio = 0; } } else if (strcasecmp(name, "codepage") == 0) { conf->doors[conf->door_count]->codepage = strdup(value); } conf->door_count++; return 1; } static int file_sub_handler(void *user, const char *section, const char *name, const char *value) { struct file_directory *fd = (struct file_directory *)user; int i; if (strcasecmp(section, "main") == 0) { if (strcasecmp(name, "visible sec level") == 0) { fd->sec_level = atoi(value); } else if (strcasecmp(name, "visible on web") == 0) { if (strcasecmp(value, "true") == 0) { fd->display_on_web = 1; } else { fd->display_on_web = 0; } } } else { // check if it's partially filled in for (i = 0; i < fd->file_sub_count; i++) { if (strcasecmp(fd->file_subs[i]->name, section) == 0) { if (strcasecmp(name, "upload sec level") == 0) { fd->file_subs[i]->upload_sec_level = atoi(value); } else if (strcasecmp(name, "download sec level") == 0) { fd->file_subs[i]->download_sec_level = atoi(value); } else if (strcasecmp(name, "database") == 0) { fd->file_subs[i]->database = strdup(value); } else if (strcasecmp(name, "upload path") == 0) { fd->file_subs[i]->upload_path = strdup(value); } return 1; } } if (fd->file_sub_count == 0) { fd->file_subs = (struct file_sub **)malloz(sizeof(struct file_sub *)); } else { fd->file_subs = (struct file_sub **)realloc(fd->file_subs, sizeof(struct file_sub *) * (fd->file_sub_count + 1)); } fd->file_subs[fd->file_sub_count] = (struct file_sub *)malloz(sizeof(struct file_sub)); fd->file_subs[fd->file_sub_count]->name = strdup(section); if (strcasecmp(name, "upload sec level") == 0) { fd->file_subs[fd->file_sub_count]->upload_sec_level = atoi(value); } else if (strcasecmp(name, "download sec level") == 0) { fd->file_subs[fd->file_sub_count]->download_sec_level = atoi(value); } else if (strcasecmp(name, "database") == 0) { fd->file_subs[fd->file_sub_count]->database = strdup(value); } else if (strcasecmp(name, "upload path") == 0) { fd->file_subs[fd->file_sub_count]->upload_path = strdup(value); } fd->file_sub_count++; } return 1; } static int mail_area_handler(void *user, const char *section, const char *name, const char *value) { struct mail_conference *mc = (struct mail_conference *)user; int i; if (strcasecmp(section, "main") == 0) { if (strcasecmp(name, "visible sec level") == 0) { mc->sec_level = atoi(value); } else if (strcasecmp(name, "networked") == 0) { if (strcasecmp(value, "true") == 0) { mc->networked = 1; } else { mc->networked = 0; } } else if (strcasecmp(name, "real names") == 0) { if (strcasecmp(value, "true") == 0) { mc->realnames = 1; } else { mc->realnames = 0; } } else if (strcasecmp(name, "tagline") == 0) { mc->tagline = strdup(value); } else if (strcasecmp(name, "header") == 0) { mc->header = strdup(value); } } else if (strcasecmp(section, "network") == 0) { if (strcasecmp(name, "type") == 0) { if (strcasecmp(value, "fido") == 0) { mc->nettype = NETWORK_FIDO; } else if (strcasecmp(value, "magi") == 0) { mc->nettype = NETWORK_MAGI; } else if (strcasecmp(value, "qwk") == 0) { mc->nettype = NETWORK_QWK; } } else if (strcasecmp(name, "fido node") == 0) { mc->fidoaddr = parse_fido_addr(value); } else if (strcasecmp(name, "domain") == 0) { mc->domain = strdup(value); } else if (strcasecmp(name, "magi node") == 0) { mc->maginode = atoi(value); } } else { // check if it's partially filled in for (i = 0; i < mc->mail_area_count; i++) { if (strcasecmp(mc->mail_areas[i]->name, section) == 0) { if (strcasecmp(name, "read sec level") == 0) { mc->mail_areas[i]->read_sec_level = atoi(value); } else if (strcasecmp(name, "write sec level") == 0) { mc->mail_areas[i]->write_sec_level = atoi(value); } else if (strcasecmp(name, "path") == 0) { mc->mail_areas[i]->path = strdup(value); } else if (strcasecmp(name, "type") == 0) { if (strcasecmp(value, "local") == 0) { mc->mail_areas[i]->type = TYPE_LOCAL_AREA; } else if (strcasecmp(value, "echo") == 0) { mc->mail_areas[i]->type = TYPE_ECHOMAIL_AREA; } else if (strcasecmp(value, "netmail") == 0) { mc->mail_areas[i]->type = TYPE_NETMAIL_AREA; } else if (strcasecmp(value, "newsgroup") == 0) { mc->mail_areas[i]->type = TYPE_NEWSGROUP_AREA; } } else if (strcasecmp(name, "qwk name") == 0) { mc->mail_areas[i]->qwkname = strdup(value); if (strlen(mc->mail_areas[i]->qwkname) > 8) { mc->mail_areas[i]->qwkname[8] = '\0'; } } return 1; } } if (mc->mail_area_count == 0) { mc->mail_areas = (struct mail_area **)malloz(sizeof(struct mail_area *)); } else { mc->mail_areas = (struct mail_area **)realloc(mc->mail_areas, sizeof(struct mail_area *) * (mc->mail_area_count + 1)); } mc->mail_areas[mc->mail_area_count] = (struct mail_area *)malloz(sizeof(struct mail_area)); mc->mail_areas[mc->mail_area_count]->qwkname = NULL; mc->mail_areas[mc->mail_area_count]->name = strdup(section); if (strcasecmp(name, "read sec level") == 0) { mc->mail_areas[mc->mail_area_count]->read_sec_level = atoi(value); } else if (strcasecmp(name, "write sec level") == 0) { mc->mail_areas[mc->mail_area_count]->write_sec_level = atoi(value); } else if (strcasecmp(name, "path") == 0) { mc->mail_areas[mc->mail_area_count]->path = strdup(value); } else if (strcasecmp(name, "type") == 0) { if (strcasecmp(value, "local") == 0) { mc->mail_areas[mc->mail_area_count]->type = TYPE_LOCAL_AREA; } else if (strcasecmp(value, "echo") == 0) { mc->mail_areas[mc->mail_area_count]->type = TYPE_ECHOMAIL_AREA; } else if (strcasecmp(value, "netmail") == 0) { mc->mail_areas[mc->mail_area_count]->type = TYPE_NETMAIL_AREA; } else if (strcasecmp(value, "newsgroup") == 0) { mc->mail_areas[mc->mail_area_count]->type = TYPE_NEWSGROUP_AREA; } } else if (strcasecmp(name, "qwk name") == 0) { mc->mail_areas[mc->mail_area_count]->qwkname = strdup(value); if (strlen(mc->mail_areas[mc->mail_area_count]->qwkname) > 8) { mc->mail_areas[mc->mail_area_count]->qwkname[8] = '\0'; } } mc->mail_area_count++; } return 1; } static int handler(void *user, const char *section, const char *name, const char *value) { struct bbs_config *conf = (struct bbs_config *)user; struct passwd *pwd; if (strcasecmp(section, "main") == 0) { if (strcasecmp(name, "bbs name") == 0) { conf->bbs_name = strdup(value); } else if (strcasecmp(name, "telnet port") == 0) { conf->telnet_port = atoi(value); } else if (strcasecmp(name, "enable ssh") == 0) { if (strcasecmp(value, "true") == 0) { conf->ssh_server = 1; } else { conf->ssh_server = 0; } } else if (strcasecmp(name, "enable ipv6") == 0) { if (strcasecmp(value, "true") == 0) { conf->ipv6 = 1; } else { conf->ipv6 = 0; } } else if (strcasecmp(name, "enable www") == 0) { if (strcasecmp(value, "true") == 0) { conf->www_server = 1; } else { conf->www_server = 0; } } else if (strcasecmp(name, "www port") == 0) { conf->www_port = atoi(value); } else if (strcasecmp(name, "www url") == 0) { if (value[strlen(value) - 1] == '/') { conf->www_url = strdup(value); } else { conf->www_url = str2dup(value, "/"); } } else if (strcasecmp(name, "ssh port") == 0) { conf->ssh_port = atoi(value); } else if (strcasecmp(name, "ssh dsa key") == 0) { conf->ssh_dsa_key = strdup(value); } else if (strcasecmp(name, "ssh rsa key") == 0) { conf->ssh_rsa_key = strdup(value); } else if (strcasecmp(name, "sysop name") == 0) { conf->sysop_name = strdup(value); } else if (strcasecmp(name, "nodes") == 0) { conf->nodes = atoi(value); } else if (strcasecmp(name, "new user level") == 0) { conf->newuserlvl = atoi(value); } else if (strcasecmp(name, "magichat server") == 0) { conf->mgchat_server = strdup(value); } else if (strcasecmp(name, "magichat port") == 0) { conf->mgchat_port = atoi(value); } else if (strcasecmp(name, "magichat bbstag") == 0) { conf->mgchat_bbstag = strdup(value); } else if (strcasecmp(name, "default tagline") == 0) { conf->default_tagline = strdup(value); } else if (strcasecmp(name, "external editor cmd") == 0) { conf->external_editor_cmd = strdup(value); } else if (strcasecmp(name, "external editor codepage") == 0) { conf->external_editor_codepage = strdup(value); } else if (strcasecmp(name, "external editor stdio") == 0) { if (strcasecmp(value, "true") == 0) { conf->external_editor_stdio = 1; } else { conf->external_editor_stdio = 0; } } else if (strcasecmp(name, "automessage write level") == 0) { conf->automsgwritelvl = atoi(value); } else if (strcasecmp(name, "fork") == 0) { if (strcasecmp(value, "true") == 0) { conf->fork = 1; } else { conf->fork = 0; } } else if (strcasecmp(name, "qwk name") == 0) { conf->bwave_name = strdup(value); if (strlen(conf->bwave_name) > 8) { conf->bwave_name[8] = '\0'; } } else if (strcasecmp(name, "main aka") == 0) { conf->main_aka = parse_fido_addr(value); } else if (strcasecmp(name, "qwk max messages") == 0) { conf->bwave_max_msgs = atoi(value); } else if (strcasecmp(name, "mqtt enable") == 0) { if (strcasecmp(value, "true") == 0) { conf->broadcast_enable = 1; } else { conf->broadcast_enable = 0; } } else if (strcasecmp(name, "mqtt port") == 0) { conf->broadcast_port = atoi(value); } else if (strcasecmp(name, "mqtt address") == 0) { conf->broadcast_address = strdup(value); } else if (strcasecmp(name, "mqtt topic") == 0) { conf->broadcast_topic = strdup(value); } else if (strcasecmp(name, "mqtt user") == 0) { conf->broadcast_user = strdup(value); } else if (strcasecmp(name, "mqtt pass") == 0) { conf->broadcast_pass = strdup(value); } else if (strcasecmp(name, "ip guard enable") == 0) { if (strcasecmp(value, "true") == 0) { conf->ipguard_enable = 1; } else { conf->ipguard_enable = 0; } } else if (strcasecmp(name, "ip guard timeout") == 0) { conf->ipguard_timeout = atoi(value); } else if (strcasecmp(name, "ip guard tries") == 0) { conf->ipguard_tries = atoi(value); } else if (strcasecmp(name, "root menu") == 0) { conf->root_menu = strdup(value); } else if (strcasecmp(name, "codepage") == 0) { if (strcasecmp(value, "cp437") == 0) { conf->codepage = 0; } else if (strcasecmp(value, "utf-8") == 0) { conf->codepage = 1; } } else if (strcasecmp(name, "date style") == 0) { if (strcasecmp(value, "us") == 0) { conf->date_style = 1; } else { conf->date_style = 0; } } else if (strcasecmp(name, "run as user") == 0) { pwd = getpwnam(value); if (pwd != NULL) { conf->uid = pwd->pw_uid; conf->gid = pwd->pw_gid; } } } else if (strcasecmp(section, "paths") == 0) { if (strcasecmp(name, "ansi path") == 0) { conf->ansi_path = strdup(value); } else if (strcasecmp(name, "bbs path") == 0) { conf->bbs_path = strdup(value); } else if (strcasecmp(name, "log path") == 0) { conf->log_path = strdup(value); } else if (strcasecmp(name, "script path") == 0) { conf->script_path = strdup(value); } else if (strcasecmp(name, "echomail semaphore") == 0) { conf->echomail_sem = strdup(value); } else if (strcasecmp(name, "netmail semaphore") == 0) { conf->netmail_sem = strdup(value); } else if (strcasecmp(name, "pid file") == 0) { conf->pid_file = strdup(value); } else if (strcasecmp(name, "string file") == 0) { conf->string_file = strdup(value); } else if (strcasecmp(name, "www path") == 0) { conf->www_path = strdup(value); } else if (strcasecmp(name, "config path") == 0) { conf->config_path = strdup(value); } else if (strcasecmp(name, "menu path") == 0) { conf->menu_path = strdup(value); } } else if (strcasecmp(section, "mail conferences") == 0) { if (conf->mail_conference_count == 0) { conf->mail_conferences = (struct mail_conference **)malloz(sizeof(struct mail_conference *)); } else { conf->mail_conferences = (struct mail_conference **)realloc(conf->mail_conferences, sizeof(struct mail_conference *) * (conf->mail_conference_count + 1)); } conf->mail_conferences[conf->mail_conference_count] = (struct mail_conference *)malloz(sizeof(struct mail_conference)); conf->mail_conferences[conf->mail_conference_count]->name = strdup(name); conf->mail_conferences[conf->mail_conference_count]->path = strdup(value); conf->mail_conferences[conf->mail_conference_count]->tagline = NULL; conf->mail_conferences[conf->mail_conference_count]->mail_area_count = 0; conf->mail_conferences[conf->mail_conference_count]->nettype = 0; conf->mail_conferences[conf->mail_conference_count]->domain = NULL; conf->mail_conferences[conf->mail_conference_count]->header = NULL; conf->mail_conference_count++; } else if (strcasecmp(section, "file directories") == 0) { if (conf->file_directory_count == 0) { conf->file_directories = (struct file_directory **)malloz(sizeof(struct file_directory *)); } else { conf->file_directories = (struct file_directory **)realloc(conf->file_directories, sizeof(struct file_directory *) * (conf->file_directory_count + 1)); } conf->file_directories[conf->file_directory_count] = (struct file_directory *)malloz(sizeof(struct file_directory)); conf->file_directories[conf->file_directory_count]->name = strdup(name); conf->file_directories[conf->file_directory_count]->path = strdup(value); conf->file_directories[conf->file_directory_count]->file_sub_count = 0; conf->file_directories[conf->file_directory_count]->display_on_web = 0; conf->file_directory_count++; } else if (strcasecmp(section, "text files") == 0) { if (conf->text_file_count == 0) { conf->text_files = (struct text_file **)malloz(sizeof(struct text_file *)); } else { conf->text_files = (struct text_file **)realloc(conf->text_files, sizeof(struct text_file *) * (conf->text_file_count + 1)); } conf->text_files[conf->text_file_count] = (struct text_file *)malloz(sizeof(struct text_file)); conf->text_files[conf->text_file_count]->name = strdup(name); conf->text_files[conf->text_file_count]->path = strdup(value); conf->text_file_count++; } return 1; } int ssh_authenticate(ssh_session p_ssh_session) { ssh_message message; char *username; char *password; do { message = ssh_message_get(p_ssh_session); if (message == NULL) { gUser = NULL; return 0; } switch (ssh_message_type(message)) { case SSH_REQUEST_AUTH: switch (ssh_message_subtype(message)) { case SSH_AUTH_METHOD_PASSWORD: username = ssh_message_auth_user(message); password = ssh_message_auth_password(message); if (strcasecmp(username, "new") == 0 && strcasecmp(password, "new") == 0) { ssh_message_auth_reply_success(message, 0); ssh_message_free(message); gUser = NULL; return 1; } gUser = check_user_pass(username, password); if (gUser != NULL) { ssh_message_auth_reply_success(message, 0); ssh_message_free(message); return 1; } ssh_message_free(message); return 0; case SSH_AUTH_METHOD_NONE: default: ssh_message_auth_set_methods(message, SSH_AUTH_METHOD_PASSWORD | SSH_AUTH_METHOD_INTERACTIVE); ssh_message_reply_default(message); break; } break; default: ssh_message_auth_set_methods(message, SSH_AUTH_METHOD_PASSWORD | SSH_AUTH_METHOD_INTERACTIVE); ssh_message_reply_default(message); break; } ssh_message_free(message); } while (1); } /* char *ssh_getip(ssh_session session) { struct sockaddr_storage tmp; struct sockaddr_in *sock; unsigned int len = 100; char ip[100] = "\0"; getpeername(ssh_get_fd(session), (struct sockaddr*)&tmp, &len); sock = (struct sockaddr_in *)&tmp; inet_ntop(AF_INET, &sock->sin_addr, ip, len); return strdup(ip); } */ static int ssh_copy_fd_to_chan(socket_t fd, int revents, void *userdata) { ssh_channel chan = (ssh_channel)userdata; char buf[2048]; int sz = 0; if (!chan) { close(fd); return -1; } if (revents & POLLIN) { sz = read(fd, buf, 2048); if (sz > 0) { ssh_channel_write(chan, buf, sz); } } if (revents & POLLHUP) { ssh_channel_close(chan); sz = -1; } return sz; } static int ssh_copy_chan_to_fd(ssh_session session, ssh_channel channel, void *data, uint32_t len, int is_stderr, void *userdata) { int fd = *(int *)userdata; int sz; (void)session; (void)channel; (void)is_stderr; sz = write(fd, data, len); return sz; } static void ssh_chan_close(ssh_session session, ssh_channel channel, void *userdata) { int fd = *(int *)userdata; int status; (void)session; (void)channel; close(fd); } struct ssh_channel_callbacks_struct ssh_cb = { .channel_data_function = ssh_copy_chan_to_fd, .channel_eof_function = ssh_chan_close, .channel_close_function = ssh_chan_close, .userdata = NULL}; void serverssh(int port, int ipv6) { ssh_session p_ssh_session; ssh_bind p_ssh_bind; int err; int pid; int shell = 0; int fd; ssh_channel chan = 0; char *ip; ssh_event event; short events; ssh_message message; struct termios tios; struct ip_address_guard *ip_guard; int i; char buffer[1024]; FILE *fptr; struct sockaddr_in6 server, client; struct sockaddr_in server4, client4; void *server_p, *client_p; int ssh_sock, csock, c; int on = 1; char str[INET6_ADDRSTRLEN]; bbs_stdin = dup(STDIN_FILENO); bbs_stdout = dup(STDOUT_FILENO); bbs_stderr = dup(STDERR_FILENO); err = ssh_init(); if (err == -1) { fprintf(stderr, "Error starting SSH server.\n"); exit(-1); } p_ssh_bind = ssh_bind_new(); if (p_ssh_bind == NULL) { fprintf(stderr, "Error starting SSH server.\n"); exit(-1); } ssh_bind_options_set(p_ssh_bind, SSH_BIND_OPTIONS_DSAKEY, conf.ssh_dsa_key); ssh_bind_options_set(p_ssh_bind, SSH_BIND_OPTIONS_RSAKEY, conf.ssh_rsa_key); //ssh_bind_listen(p_ssh_bind); if (ipv6) { ssh_sock = socket(AF_INET6, SOCK_STREAM, 0); } else { ssh_sock = socket(AF_INET, SOCK_STREAM, 0); } if (ssh_sock == -1) { fprintf(stderr, "Error starting SSH server.\n"); exit(-1); } if (setsockopt(ssh_sock, SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0) { fprintf(stderr, "setsockopt(SO_REUSEADDR) failed"); exit(-1); } if (ipv6) { if (setsockopt(ssh_sock, IPPROTO_IPV6, IPV6_V6ONLY, (void *)&on, sizeof(on)) < 0) { fprintf(stderr, "setsockopt(IPV6_V6ONLY) failed"); } memset(&server, 0, sizeof(server)); server.sin6_family = AF_INET6; server.sin6_addr = in6addr_any; server.sin6_port = htons(port); server_p = &server; client_p = &client; if (bind(ssh_sock, (struct sockaddr *)server_p, sizeof(struct sockaddr_in6)) < 0) { perror("Bind Failed, Error\n"); exit(1); } c = sizeof(struct sockaddr_in6); } else { memset(&server4, 0, sizeof(server4)); server4.sin_family = AF_INET; server4.sin_addr.s_addr = INADDR_ANY; server4.sin_port = htons(port); server_p = &server4; client_p = &client4; if (bind(ssh_sock, (struct sockaddr *)server_p, sizeof(struct sockaddr_in)) < 0) { perror("Bind Failed, Error\n"); exit(1); } c = sizeof(struct sockaddr_in); } if (conf.uid != getuid()) { if (setgid(conf.gid) != 0 || setuid(conf.uid) != 0) { perror("SetUID Failed: "); remove(conf.pid_file); exit(1); } } listen(ssh_sock, 3); while ((csock = accept(ssh_sock, (struct sockaddr *)client_p, (socklen_t *)&c))) { p_ssh_session = ssh_new(); if (p_ssh_session == NULL) { fprintf(stderr, "Error starting SSH session.\n"); close(csock); continue; } if (ssh_bind_accept_fd(p_ssh_bind, p_ssh_session, csock) == SSH_OK) { if (ipv6) { ip = strdup(inet_ntop(AF_INET6, &((struct sockaddr_in6 *)client_p)->sin6_addr, str, sizeof(str))); } else { ip = strdup(inet_ntop(AF_INET, &((struct sockaddr_in *)client_p)->sin_addr, str, sizeof(str))); } if (conf.ipguard_enable) { i = hashmap_get(ip_guard_map, ip, (void **)(&ip_guard)); if (i == MAP_MISSING) { ip_guard = (struct ip_address_guard *)malloz(sizeof(struct ip_address_guard)); ip_guard->status = IP_STATUS_UNKNOWN; ip_guard->last_connection = time(NULL); ip_guard->connection_count = 1; hashmap_put(ip_guard_map, strdup(ip), ip_guard); } else if (i == MAP_OK) { if (ip_guard->status == IP_STATUS_BLACKLISTED) { free(ip); ssh_disconnect(p_ssh_session); continue; } else if (ip_guard->status == IP_STATUS_UNKNOWN) { if (ip_guard->last_connection + conf.ipguard_timeout > time(NULL)) { ip_guard->connection_count++; if (ip_guard->connection_count == conf.ipguard_tries) { ip_guard->status = IP_STATUS_BLACKLISTED; snprintf(buffer, 1024, "%s/blacklist.ip%d", conf.bbs_path, (ipv6 ? 6 : 4)); fptr = fopen(buffer, "a"); fprintf(fptr, "%s\n", ip); fclose(fptr); free(ip); ssh_disconnect(p_ssh_session); continue; } } else { ip_guard->connection_count = 0; ip_guard->last_connection = time(NULL); } } } } pid = fork(); if (pid == 0) { close(ssh_sock); if (ssh_handle_key_exchange(p_ssh_session)) { fprintf(stderr, "Key exchange failed.\n"); exit(-1); } if (ssh_authenticate(p_ssh_session) == 1) { do { message = ssh_message_get(p_ssh_session); if (message) { if (ssh_message_type(message) == SSH_REQUEST_CHANNEL_OPEN && ssh_message_subtype(message) == SSH_CHANNEL_SESSION) { chan = ssh_message_channel_request_open_reply_accept(message); ssh_message_free(message); break; } else { ssh_message_reply_default(message); ssh_message_free(message); } } else { break; } } while (!chan); if (!chan) { fprintf(stderr, "Failed to get channel\n"); ssh_finalize(); exit(-1); } do { message = ssh_message_get(p_ssh_session); if (message) { if (ssh_message_type(message) == SSH_REQUEST_CHANNEL) { if (ssh_message_subtype(message) == SSH_CHANNEL_REQUEST_SHELL) { shell = 1; ssh_message_channel_request_reply_success(message); ssh_message_free(message); break; } else if (ssh_message_subtype(message) == SSH_CHANNEL_REQUEST_PTY) { ssh_message_channel_request_reply_success(message); ssh_message_free(message); continue; } } } else { break; } } while (!shell); if (!shell) { fprintf(stderr, "Failed to get shell\n"); ssh_finalize(); exit(-1); } bbs_pid = forkpty(&fd, NULL, NULL, NULL); if (bbs_pid == 0) { tcgetattr(STDIN_FILENO, &tios); tios.c_lflag &= ~(ICANON | ECHO | ECHONL); tios.c_iflag &= INLCR; tcsetattr(STDIN_FILENO, TCSAFLUSH, &tios); runbbs_ssh(ip); exit(0); } free(ip); ssh_cb.userdata = &fd; ssh_callbacks_init(&ssh_cb); ssh_set_channel_callbacks(chan, &ssh_cb); events = POLLIN | POLLPRI | POLLERR | POLLHUP | POLLNVAL; event = ssh_event_new(); if (event == NULL) { ssh_finalize(); exit(0); } if (ssh_event_add_fd(event, fd, events, ssh_copy_fd_to_chan, chan) != SSH_OK) { ssh_finalize(); exit(0); } if (ssh_event_add_session(event, p_ssh_session) != SSH_OK) { ssh_finalize(); exit(0); } do { ssh_event_dopoll(event, 1000); } while (!ssh_channel_is_closed(chan)); ssh_event_remove_fd(event, fd); ssh_event_remove_session(event, p_ssh_session); ssh_event_free(event); } ssh_disconnect(p_ssh_session); ssh_finalize(); close(csock); exit(0); } else if (pid > 0) { ssh_free(p_ssh_session); close(csock); free(ip); } else { } } } } void server(int port, int ipv6) { struct sigaction sa; struct sigaction st; struct sigaction sq; int client_sock, c; int pid; char *ip; struct sockaddr_in6 server, client; struct sockaddr_in server4, client4; void *client_p, *server_p; FILE *fptr; char buffer[1024]; struct ip_address_guard *ip_guard; int i; int on = 1; char str[INET6_ADDRSTRLEN]; struct stat s; #if defined(ENABLE_WWW) www_daemon = NULL; #endif if (conf.ipguard_enable) { ip_guard_map = hashmap_new(); snprintf(buffer, 1024, "%s/whitelist.ip%d", conf.bbs_path, (ipv6 ? 6 : 4)); fptr = fopen(buffer, "r"); if (fptr) { fgets(buffer, 1024, fptr); while (!feof(fptr)) { for (i = strlen(buffer) - 1; i > 0; i--) { if (buffer[i] == '\r' || buffer[i] == '\n') { buffer[i] = '\0'; } else { break; } } ip_guard = (struct ip_address_guard *)malloz(sizeof(struct ip_address_guard)); ip_guard->status = IP_STATUS_WHITELISTED; hashmap_put(ip_guard_map, strdup(buffer), ip_guard); fgets(buffer, 1024, fptr); } fclose(fptr); } snprintf(buffer, 1024, "%s/blacklist.ip%d", conf.bbs_path, (ipv6 ? 6 : 4)); fptr = fopen(buffer, "r"); if (fptr) { fgets(buffer, 1024, fptr); while (!feof(fptr)) { for (i = strlen(buffer) - 1; i > 0; i--) { if (buffer[i] == '\r' || buffer[i] == '\n') { buffer[i] = '\0'; } else { break; } } ip_guard = (struct ip_address_guard *)malloz(sizeof(struct ip_address_guard)); ip_guard->status = IP_STATUS_BLACKLISTED; hashmap_put(ip_guard_map, strdup(buffer), ip_guard); fgets(buffer, 1024, fptr); } fclose(fptr); } } sa.sa_handler = sigchld_handler; // reap all dead processes sigemptyset(&sa.sa_mask); sa.sa_flags = SA_RESTART | SA_SIGINFO; if (sigaction(SIGCHLD, &sa, NULL) == -1) { perror("sigaction - sigchld"); remove(conf.pid_file); exit(1); } st.sa_handler = sigterm_handler; sigemptyset(&st.sa_mask); st.sa_flags = SA_SIGINFO; if (sigaction(SIGTERM, &st, NULL) == -1) { perror("sigaction - sigterm"); remove(conf.pid_file); exit(1); } sq.sa_handler = sigterm_handler; sigemptyset(&sq.sa_mask); sq.sa_flags = SA_SIGINFO; if (sigaction(SIGQUIT, &sq, NULL) == -1) { perror("sigaction - sigquit"); remove(conf.pid_file); exit(1); } if (conf.ssh_server) { if (!conf.fork) { printf(" - SSH Starting on Port %d (IPv%d)\n", conf.ssh_port, (ipv6 ? 6 : 4)); } // fork ssh server ssh_pid = fork(); if (ssh_pid == 0) { ipv6_pid = -1; ssh_pid = -1; serverssh(conf.ssh_port, ipv6); exit(0); } if (ssh_pid < 0) { fprintf(stderr, "Error forking ssh server."); } } if (ipv6) { server_socket = socket(AF_INET6, SOCK_STREAM, 0); } else { server_socket = socket(AF_INET, SOCK_STREAM, 0); } if (server_socket == -1) { remove(conf.pid_file); fprintf(stderr, "Couldn't create socket..\n"); exit(1); } if (setsockopt(server_socket, SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) < 0) { remove(conf.pid_file); fprintf(stderr, "setsockopt(SO_REUSEADDR) failed"); exit(1); } if (!conf.fork) { printf(" - Telnet Starting on Port %d (IPv%d)\n", port, (ipv6 ? 6 : 4)); } if (ipv6) { if (setsockopt(server_socket, IPPROTO_IPV6, IPV6_V6ONLY, (void *)&on, sizeof(on)) < 0) { fprintf(stderr, "setsockopt(IPV6_V6ONLY) failed"); } memset(&server, 0, sizeof(server)); server.sin6_family = AF_INET6; server.sin6_addr = in6addr_any; server.sin6_port = htons(port); if (bind(server_socket, (struct sockaddr *)&server, sizeof(server)) < 0) { perror("Bind Failed, Error\n"); remove(conf.pid_file); exit(1); } c = sizeof(struct sockaddr_in6); server_p = &server; client_p = &client; } else { memset(&server4, 0, sizeof(server4)); server4.sin_family = AF_INET; server4.sin_addr.s_addr = INADDR_ANY; server4.sin_port = htons(port); if (bind(server_socket, (struct sockaddr *)&server4, sizeof(server4)) < 0) { perror("Bind Failed, Error\n"); remove(conf.pid_file); exit(1); } c = sizeof(struct sockaddr_in); server_p = &server4; client_p = &client4; } if (conf.uid != getuid()) { if (setgid(conf.gid) != 0 || setuid(conf.uid) != 0) { perror("SetUID Failed: "); remove(conf.pid_file); exit(1); } } #if defined(ENABLE_WWW) if (conf.www_server && conf.www_path != NULL && conf.www_url != NULL) { if (!conf.fork) { printf(" - HTTP Starting on Port %d (IPv%d)\n", conf.www_port, (ipv6 ? 6 : 4)); } www_init(); if (ipv6) { www_daemon = MHD_start_daemon(MHD_USE_THREAD_PER_CONNECTION | MHD_USE_IPv6, conf.www_port, NULL, NULL, &www_handler, NULL, MHD_OPTION_NOTIFY_COMPLETED, &www_request_completed, NULL, MHD_OPTION_URI_LOG_CALLBACK, &www_logger, NULL, MHD_OPTION_END); } else { www_daemon = MHD_start_daemon(MHD_USE_THREAD_PER_CONNECTION, conf.www_port, NULL, NULL, &www_handler, NULL, MHD_OPTION_NOTIFY_COMPLETED, &www_request_completed, NULL, MHD_OPTION_URI_LOG_CALLBACK, &www_logger, NULL, MHD_OPTION_END); } } #endif listen(server_socket, 3); while ((client_sock = accept(server_socket, (struct sockaddr *)client_p, (socklen_t *)&c))) { if (ipv6) { ip = strdup(inet_ntop(AF_INET6, &((struct sockaddr_in6 *)client_p)->sin6_addr, str, sizeof(str))); } else { ip = strdup(inet_ntop(AF_INET, &((struct sockaddr_in *)client_p)->sin_addr, str, sizeof(str))); } if (client_sock == -1) { if (errno == EINTR) { continue; } else { exit(-1); } } if (conf.ipguard_enable) { i = hashmap_get(ip_guard_map, ip, (void **)(&ip_guard)); if (i == MAP_MISSING) { ip_guard = (struct ip_address_guard *)malloz(sizeof(struct ip_address_guard)); ip_guard->status = IP_STATUS_UNKNOWN; ip_guard->last_connection = time(NULL); ip_guard->connection_count = 1; hashmap_put(ip_guard_map, strdup(ip), ip_guard); } else if (i == MAP_OK) { if (ip_guard->status == IP_STATUS_BLACKLISTED) { write(client_sock, "BLOCKED\r\n", 9); free(ip); close(client_sock); continue; } else if (ip_guard->status == IP_STATUS_UNKNOWN) { if (ip_guard->last_connection + conf.ipguard_timeout > time(NULL)) { ip_guard->connection_count++; if (ip_guard->connection_count == conf.ipguard_tries) { ip_guard->status = IP_STATUS_BLACKLISTED; snprintf(buffer, 1024, "%s/blacklist.ip%d", conf.bbs_path, (ipv6 ? 6 : 4)); fptr = fopen(buffer, "a"); fprintf(fptr, "%s\n", ip); fclose(fptr); write(client_sock, "BLOCKED\r\n", 9); free(ip); close(client_sock); continue; } } else { ip_guard->connection_count = 0; ip_guard->last_connection = time(NULL); } } } } pid = fork(); if (pid < 0) { perror("Error on fork\n"); exit(1); } if (pid == 0) { close(server_socket); server_socket = -1; runbbs(client_sock, ip); exit(0); } else { free(ip); close(client_sock); } } } int main(int argc, char **argv) { int i; int main_pid; FILE *fptr; struct stat s; char buffer[1024]; if (argc < 2) { fprintf(stderr, "Usage ./magicka config/bbs.ini\n"); exit(1); } conf.mail_conference_count = 0; conf.door_count = 0; conf.file_directory_count = 0; conf.mgchat_server = NULL; conf.mgchat_port = 2025; conf.mgchat_bbstag = NULL; conf.text_file_count = 0; conf.external_editor_cmd = NULL; conf.external_editor_codepage = NULL; conf.log_path = NULL; conf.script_path = NULL; conf.automsgwritelvl = 10; conf.echomail_sem = NULL; conf.netmail_sem = NULL; conf.telnet_port = 0; conf.string_file = NULL; conf.www_path = NULL; conf.www_url = NULL; conf.archiver_count = 0; conf.broadcast_enable = 0; conf.broadcast_port = 0; conf.broadcast_address = NULL; conf.broadcast_topic = NULL; conf.broadcast_user = NULL; conf.broadcast_pass = NULL; conf.config_path = NULL; conf.ipguard_enable = 0; conf.ipguard_tries = 4; conf.ipguard_timeout = 120; conf.protocol_count = 0; conf.codepage = 0; conf.date_style = 0; conf.ipv6 = 0; conf.uid = getuid(); conf.gid = getgid(); // Load BBS data if (ini_parse(argv[1], handler, &conf) < 0) { fprintf(stderr, "Unable to load configuration ini (%s)!\n", argv[1]); exit(-1); } if (conf.config_path == NULL) { fprintf(stderr, "Config Path must be set in your bbs ini!\n"); exit(-1); } if (conf.root_menu == NULL) { fprintf(stderr, "Root Menu must be set in your bbs ini!\n"); exit(-1); } // Load mail Areas for (i = 0; i < conf.mail_conference_count; i++) { if (ini_parse(conf.mail_conferences[i]->path, mail_area_handler, conf.mail_conferences[i]) < 0) { fprintf(stderr, "Unable to load configuration ini (%s)!\n", conf.mail_conferences[i]->path); exit(-1); } } // Load file Subs for (i = 0; i < conf.file_directory_count; i++) { if (ini_parse(conf.file_directories[i]->path, file_sub_handler, conf.file_directories[i]) < 0) { fprintf(stderr, "Unable to load configuration ini (%s)!\n", conf.file_directories[i]->path); exit(-1); } } snprintf(buffer, 1024, "%s/doors.ini", conf.config_path); if (ini_parse(buffer, door_config_handler, &conf) < 0) { fprintf(stderr, "Unable to load configuration ini (doors.ini)!\n"); exit(-1); } snprintf(buffer, 1024, "%s/archivers.ini", conf.config_path); if (ini_parse(buffer, archiver_config_handler, &conf) < 0) { fprintf(stderr, "Unable to load configuration ini %s\n", buffer); exit(-1); } snprintf(buffer, 1024, "%s/protocols.ini", conf.config_path); if (ini_parse(buffer, protocol_config_handler, &conf) < 0) { fprintf(stderr, "Unable to load configuration ini %s\n", buffer); exit(-1); } load_strings(); if (conf.fork) { if (stat(conf.pid_file, &s) == 0) { fprintf(stderr, "Magicka already running or stale pid file at: %s\n", conf.pid_file); exit(-1); } main_pid = fork(); if (main_pid < 0) { fprintf(stderr, "Error forking.\n"); exit(-1); } else if (main_pid > 0) { if (conf.uid != getuid()) { if (setgid(conf.gid) != 0 || setuid(conf.uid) != 0) { perror("Setuid Error: "); exit(1); } } fptr = fopen(conf.pid_file, "w"); if (!fptr) { fprintf(stderr, "Unable to open pid file for writing.\n"); } else { fprintf(fptr, "%d", main_pid); fclose(fptr); } } else { for (i = 1; i <= conf.nodes; i++) { snprintf(buffer, 1024, "%s/nodeinuse.%d", conf.bbs_path, i); if (stat(buffer, &s) == 0) { unlink(buffer); } } if (conf.ipv6) { ipv6_pid = fork(); if (ipv6_pid < 0) { fprintf(stderr, "Error forking.\n"); exit(-1); } else if (ipv6_pid > 0) { server(conf.telnet_port, 0); } else { ipv6_pid = -1; server(conf.telnet_port, 1); } } else { server(conf.telnet_port, 0); } } } else { printf("Magicka BBS Server Starting....\n"); for (i = 1; i <= conf.nodes; i++) { snprintf(buffer, 1024, "%s/nodeinuse.%d", conf.bbs_path, i); if (stat(buffer, &s) == 0) { printf(" - Removing stale file: nodeinuse.%d\n", i); unlink(buffer); } } if (conf.ipv6) { ipv6_pid = fork(); if (ipv6_pid < 0) { fprintf(stderr, "Error forking.\n"); exit(-1); } else if (ipv6_pid > 0) { server(conf.telnet_port, 0); } else { ipv6_pid = -1; server(conf.telnet_port, 1); } } else { server(conf.telnet_port, 0); } } }