#include <ctype.h>
#include <string.h>
#include <errno.h>
+#include <limits.h>
#include <pthread.h>
#include <syslog.h>
#include <dlfcn.h>
#include "config.h"
#include "database.h"
#include "housekeeping.h"
-#include "hooks.h"
#include "user_ops.h"
#include "logging.h"
#include "support.h"
#include "msgbase.h"
#include "locate_host.h"
-#include "serv_chat.h"
#include "room_ops.h"
#include "file_ops.h"
+#include "dynloader.h"
struct CitContext *ContextList = NULL;
int ScheduledShutdown = 0;
lprintf(7, "Checking floor reference counts\n");
check_ref_counts();
+
+ lprintf(7, "Creating base rooms (if necessary)\n");
+ create_room(BASEROOM, 0, "", 0);
+ create_room(AIDEROOM, 4, "", 0);
+ create_room(config.c_twitroom, 0, "", 0);
}
/*
* Cleanup routine to be called when the server is shutting down.
*/
void master_cleanup(void) {
+ struct CleanupFunctionHook *fcn;
/* Cancel all running sessions */
lprintf(7, "Cancelling running sessions...\n");
kill_session(ContextList->cs_pid);
}
+ /* Run any cleanup routines registered by loadable modules */
+ for (fcn = CleanupHookTable; fcn != NULL; fcn = fcn->next) {
+ (*fcn->h_function_pointer)();
+ }
+
/* Close databases */
lprintf(7, "Closing databases\n");
close_databases();
sysdep_master_cleanup();
/* Now go away. */
- hook_cleanup();
lprintf(3, "citserver: exiting.\n");
exit(0);
}
rec_log(CL_TERMINATE,CC->curr_user);
unlink(CC->temp);
lprintf(3, "citserver[%3d]: ended.\n",CC->cs_pid);
- hook_end_session(CC->cs_pid);
+
+ /* Run any cleanup routines registered by loadable modules */
+ PerformSessionHooks(EVT_STOP);
+
syslog(LOG_NOTICE,"session %d ended", CC->cs_pid);
/* Deallocate any unsent express messages */
*/
void set_wtmpsupp(char *newtext)
{
- strncpy(CC->cs_room,newtext,19);
- CC->cs_room[19] = 0;
+ strncpy(CC->cs_room,newtext,ROOMNAMELEN-1);
+ CC->cs_room[ROOMNAMELEN-1] = 0;
time(&CC->cs_lastupdt);
- hook_room_name(CC->cs_pid, CC->cs_room);
+
+ /* Run any routines registered by loadable modules */
+ PerformSessionHooks(EVT_NEWROOM);
}
{
if ((newroomname) && (newroomname[0]))
{
- bzero(CC->fake_roomname, 20);
- strncpy(CC->fake_roomname, newroomname, 19);
+ bzero(CC->fake_roomname, ROOMNAMELEN);
+ strncpy(CC->fake_roomname, newroomname, ROOMNAMELEN-1);
}
else
CC->fake_roomname[0] = '\0';
}
-/*
- * Run a server extension (FIX FIX FIX initial hack; polish this up)
- */
-void cmd_extn(char *argbuf) {
- char ExtensionName[256];
- int is_ipgm;
- int pid;
- char portstr[16];
- char ipgm[32];
- char sess[16];
-
-
- extract(ExtensionName, argbuf, 0);
- is_ipgm = extract_int(argbuf, 1);
-
- pid = fork();
- lprintf(9, "fork() returned %d\n", pid);
- if (pid < 0) {
- cprintf("%d fork failed: %s\n",
- ERROR + INTERNAL_ERROR,
- strerror(errno));
- return;
- }
- else if (pid == 0) {
-
- sprintf(portstr, "%d", config.c_port_number);
-
- if (is_ipgm)
- sprintf(ipgm, "%d", config.c_ipgm_secret);
- else
- strcpy(ipgm, "");
-
- sprintf(sess, "%d", CC->cs_pid);
-
- execlp(ExtensionName, ExtensionName,
- "localhost", /* server address */
- portstr, /* port number */
- ipgm, /* ipgm secret */
- CC->usersupp.fullname, /* user name */
- CC->usersupp.password, /* password */
- CC->quickroom.QRname, /* current room */
- sess, /* assoc session id */
- NULL);
-
- lprintf(9, "exec() failed: %s\n", strerror(errno));
- exit(1);
- }
- else {
- cprintf("%d Ok\n", OK);
- }
- }
-
-
-
-
/*
* main context loop
*/
void *context_loop(struct CitContext *con)
{
- void *fcn_handle;
- void (*h_cmd_chat)(char *);
- void (*cmd_pexp)(void);
- void (*cmd_sexp)(char *);
- char *dl_error;
char cmdbuf[256];
int session_num;
/*
* Initialize some variables specific to our context.
*/
- CC->curr_rm = (-1);
CC->logged_in = 0;
CC->internal_pgm = 0;
CC->download_fp = NULL;
}
lprintf(3, "citserver[%3d]: started.\n", CC->cs_pid);
- hook_start_session(CC->cs_pid);
+
+ /* Run any session startup routines registered by loadable modules */
+ PerformSessionHooks(EVT_START);
+
rec_log(CL_CONNECT, "");
do {
time(&CC->lastcmd);
if (client_gets(cmdbuf) < 1) cleanup(EXIT_NULL);
lprintf(5, "citserver[%3d]: %s\n", CC->cs_pid, cmdbuf);
- hook_command_received(CC->cs_pid, cmdbuf);
+ /* hook_command_received(CC->cs_pid, cmdbuf); FIX */
/*
* Let other clients see the last command we executed, but
cmd_ipgm(&cmdbuf[5]);
}
- else if (!strncasecmp(cmdbuf,"CHAT",4))
- {
- syslog(LOG_NOTICE, "Opening chat connection");
- if (!(fcn_handle = dlopen("/usr/bbs/CVS/citadel/serv_chat.so", RTLD_LAZY)))
- {
- dl_error = dlerror();
- syslog(LOG_NOTICE, "WARNING: chat subsystem mod failed to load! (%s)", dl_error);
- exit(1);
- }
-
- h_cmd_chat = dlsym(fcn_handle, "cmd_chat");
- if ((dl_error = dlerror()) != NULL)
- {
- syslog(LOG_NOTICE, "Error: %s", dl_error);
- exit(1);
- }
- (*h_cmd_chat)(&cmdbuf[5]);
- dlclose(fcn_handle);
- if ((dl_error = dlerror()) != NULL)
- {
- syslog(LOG_NOTICE, "dlclose Error: %s", dl_error);
- exit(1);
- }
- }
-
- else if (!strncasecmp(cmdbuf,"PEXP",4))
- {
- if (!(fcn_handle = dlopen("serv_chat.so", RTLD_LAZY)))
- {
- dl_error = dlerror();
- syslog(LOG_NOTICE, "WARNING: chat subsystem mod failed to load! (%s)", dl_error);
- exit(1);
- }
-
- cmd_pexp = dlsym(fcn_handle, "cmd_pexp");
- if ((dl_error = dlerror()) != NULL)
- {
- syslog(LOG_NOTICE, "Error: %s", dl_error);
- exit(1);
- }
- (*cmd_pexp)();
- dlclose(fcn_handle);
- if ((dl_error = dlerror()) != NULL)
- {
- syslog(LOG_NOTICE, "dlclose Error: %s", dl_error);
- exit(1);
- }
- }
- else if (!strncasecmp(cmdbuf,"SEXP",4))
- {
- if (!(fcn_handle = dlopen("serv_chat.so", RTLD_LAZY)))
- {
- dl_error = dlerror();
- syslog(LOG_NOTICE, "WARNING: chat subsystem mod failed to load! (%s)", dl_error);
- exit(1);
- }
-
- cmd_sexp = dlsym(fcn_handle, "cmd_sexp");
- if ((dl_error = dlerror()) != NULL)
- {
- syslog(LOG_NOTICE, "Error: %s", dl_error);
- exit(1);
- }
- (*cmd_sexp)(&cmdbuf[5]);
- dlclose(fcn_handle);
- if ((dl_error = dlerror()) != NULL)
- {
- syslog(LOG_NOTICE, "dlclose Error: %s", dl_error);
- exit(1);
- }
- }
-
else if (!strncasecmp(cmdbuf,"EBIO",4)) {
cmd_ebio();
}
cmd_rchg(&cmdbuf[5]);
}
- else if (!strncasecmp(cmdbuf, "EXTN", 4)) {
- cmd_extn(&cmdbuf[5]);
- }
-
else if (!strncasecmp(cmdbuf, "AGUP", 4)) {
cmd_agup(&cmdbuf[5]);
}
cmd_asup(&cmdbuf[5]);
}
- else {
- cprintf("%d Unrecognized or unsupported command.\n",
- ERROR);
- }
+ else if (!DLoader_Exec_Cmd(cmdbuf))
+ {
+ cprintf("%d Unrecognized or unsupported command.\n",
+ ERROR);
+ }
} while(strncasecmp(cmdbuf, "QUIT", 4));