#include "citadel.h"
#include "server.h"
#include "serv_extensions.h"
-#include <syslog.h>
#include "serv_chat.h"
#include "sysdep_decls.h"
#include "citserver.h"
struct ChatLine *ChatQueue = NULL;
int ChatLastMsg = 0;
-
-
+/*
+ * This message can be set to anything you want, but it is
+ * checked for consistency so don't move it away from here.
+ */
+#define KICKEDMSG "You have been kicked out of this room."
void allwrite(char *cmdbuf, int flag, char *username)
{
if (CC->fake_username[0])
un = CC->fake_username;
else
- un = CC->usersupp.fullname;
+ un = CC->user.fullname;
if (flag == 1) {
snprintf(bcast, sizeof bcast, ":|<%s %s>", un, cmdbuf);
} else if (flag == 0) {
snprintf(bcast, sizeof bcast, "%s|%s", un, cmdbuf);
} else if (flag == 2) {
snprintf(bcast, sizeof bcast, ":|<%s whispers %s>", un, cmdbuf);
+ } else if (flag == 3) {
+ snprintf(bcast, sizeof bcast, ":|%s", KICKEDMSG);
}
if ((strcasecmp(cmdbuf, "NOOP")) && (flag != 2)) {
fp = fopen(CHATLOG, "a");
fprintf(fp, "%s\n", bcast);
fclose(fp);
}
- clnew = (struct ChatLine *) mallok(sizeof(struct ChatLine));
+ clnew = (struct ChatLine *) malloc(sizeof(struct ChatLine));
memset(clnew, 0, sizeof(struct ChatLine));
if (clnew == NULL) {
fprintf(stderr, "citserver: cannot alloc chat line: %s\n",
time(&now);
clnew->next = NULL;
clnew->chat_time = now;
- safestrncpy(clnew->chat_room, CC->quickroom.QRname,
+ safestrncpy(clnew->chat_room, CC->room.QRname,
sizeof clnew->chat_room);
clnew->chat_room[sizeof clnew->chat_room - 1] = 0;
if (username) {
while ((ChatQueue != NULL) && (now - ChatQueue->chat_time >= 120L)) {
clptr = ChatQueue;
ChatQueue = ChatQueue->next;
- phree(clptr);
+ free(clptr);
}
end_critical_section(S_CHATQUEUE);
}
begin_critical_section(S_SESSION_TABLE);
for (ccptr = ContextList; ccptr != NULL; ccptr = ccptr->next) {
if (ccptr->cs_flags & CS_CHAT) {
- if (!strcasecmp(ccptr->quickroom.QRname,
- CC->quickroom.QRname)) {
+ if (!strcasecmp(ccptr->room.QRname,
+ CC->room.QRname)) {
++count;
}
else {
}
GenerateRoomDisplay(roomname, ccptr, CC);
- if ((CC->usersupp.axlevel < 6)
+ if ((CC->user.axlevel < 6)
&& (strlen(ccptr->fake_roomname)>0)) {
strcpy(roomname, ccptr->fake_roomname);
}
for (ccptr = ContextList; ccptr != NULL; ccptr = ccptr->next) {
GenerateRoomDisplay(roomname, ccptr, CC);
- if ((CC->usersupp.axlevel < 6)
+ if ((CC->user.axlevel < 6)
&& (strlen(ccptr->fake_roomname)>0)) {
strcpy(roomname, ccptr->fake_roomname);
}
cprintf(":|/whobbs (list users in chat -and- elsewhere) \n");
cprintf(":|/me ('action' line, ala irc) \n");
cprintf(":|/msg (send private message, ala irc) \n");
+ if (is_room_aide()) {
+ cprintf(":|/kick (kick another user out of this room) \n");
+ }
cprintf(":|/quit (return to the BBS) \n");
cprintf(":|\n");
ok_cmd = 1;
cprintf(":|User not found.\n");
cprintf("\n");
}
+ /* The /kick function is implemented by sending a specific
+ * message to the kicked-out user's context. When that message
+ * is processed by the read loop, that context will exit.
+ */
+ if ( (!strncasecmp(cmdbuf, "/kick ", 6)) && (is_room_aide()) ) {
+ ok_cmd = 1;
+ strptr1 = &cmdbuf[6];
+ strcat(strptr1, " ");
+ if ((t_context = find_context(&strptr1))) {
+ if (strcasecmp(CC->curr_user, t_context->curr_user))
+ allwrite(strptr1, 3, t_context->curr_user);
+ } else
+ cprintf(":|User not found.\n");
+ cprintf("\n");
+ }
if ((cmdbuf[0] != '/') && (strlen(cmdbuf) > 0)) {
ok_cmd = 1;
allwrite(cmdbuf, 0, NULL);
ThisLastMsg = ChatLastMsg;
for (clptr = ChatQueue; clptr != NULL; clptr = clptr->next) {
if ((clptr->chat_seq > MyLastMsg) && ((!clptr->chat_username[0]) || (!strncasecmp(un, clptr->chat_username, 32)))) {
- if ((!clptr->chat_room[0]) || (!strncasecmp(CC->quickroom.QRname, clptr->chat_room, ROOMNAMELEN))) {
+ if ((!clptr->chat_room[0]) || (!strncasecmp(CC->room.QRname, clptr->chat_room, ROOMNAMELEN))) {
+ /* Output new chat data */
cprintf("%s\n", clptr->chat_text);
+
+ /* See if we've been force-quitted (kicked etc.) */
+ if (!strcmp(&clptr->chat_text[2], KICKEDMSG)) {
+ allwrite("<kicked out of this room>", 0, NULL);
+ cprintf("000\n");
+ CC->cs_flags = CC->cs_flags - CS_CHAT;
+
+ /* Kick user out of room */
+ CtdlInvtKick(CC->user.fullname, 0);
+
+ /* And return to the Lobby */
+ usergoto(config.c_baseroom, 0, 0, NULL, NULL);
+ return;
+ }
}
}
}
while (CC->FirstExpressMessage != NULL) {
ptr = CC->FirstExpressMessage->next;
if (CC->FirstExpressMessage->text != NULL)
- phree(CC->FirstExpressMessage->text);
- phree(CC->FirstExpressMessage);
+ free(CC->FirstExpressMessage->text);
+ free(CC->FirstExpressMessage);
CC->FirstExpressMessage = ptr;
}
end_critical_section(S_SESSION_TABLE);
struct ExpressMessage *ptr, *holdptr;
if (CC->FirstExpressMessage == NULL) {
- cprintf("%d No express messages waiting.\n", ERROR);
+ cprintf("%d No express messages waiting.\n", ERROR + MESSAGE_NOT_FOUND);
return;
}
begin_critical_section(S_SESSION_TABLE);
memfmout(80, ptr->text, 0, "\n");
holdptr = ptr->next;
- if (ptr->text != NULL) phree(ptr->text);
- phree(ptr);
+ if (ptr->text != NULL) free(ptr->text);
+ free(ptr);
ptr = holdptr;
}
cprintf("000\n");
struct ExpressMessage *ptr;
if (CC->FirstExpressMessage == NULL) {
- cprintf("%d No express messages waiting.\n", ERROR);
+ cprintf("%d No express messages waiting.\n", ERROR + MESSAGE_NOT_FOUND);
return;
}
if (ptr->text != NULL) {
memfmout(80, ptr->text, 0, "\n");
if (ptr->text[strlen(ptr->text)-1] != '\n') cprintf("\n");
- phree(ptr->text);
+ free(ptr->text);
}
cprintf("000\n");
- phree(ptr);
+ free(ptr);
}
/*
if (ccptr->fake_username[0]) /* <bc> */
un = ccptr->fake_username;
else
- un = ccptr->usersupp.fullname;
+ un = ccptr->user.fullname;
if ( ((!strcasecmp(un, x_user))
|| (!strcasecmp(x_user, "broadcast")))
&& ((ccptr->disable_exp == 0)
- || (CC->usersupp.axlevel >= 6)) ) {
+ || (CC->user.axlevel >= 6)) ) {
if (do_send) {
newmsg = (struct ExpressMessage *)
- mallok(sizeof (struct ExpressMessage));
+ malloc(sizeof (struct ExpressMessage));
memset(newmsg, 0,
sizeof (struct ExpressMessage));
time(&(newmsg->timestamp));
sizeof newmsg->sender);
if (!strcasecmp(x_user, "broadcast"))
newmsg->flags |= EM_BROADCAST;
- newmsg->text = strdoop(x_msg);
+ newmsg->text = strdup(x_msg);
add_xmsg_to_context(ccptr, newmsg);
sptr->next = sl;
MailboxName(sptr->roomname,
sizeof sptr->roomname,
- &ccptr->usersupp, PAGELOGROOM);
+ &ccptr->user, PAGELOGROOM);
sl = sptr;
}
}
/* Log the page to disk if configured to do so */
if ( (do_send) && (message_sent) ) {
- logmsg = mallok(sizeof(struct CtdlMessage));
+ logmsg = malloc(sizeof(struct CtdlMessage));
memset(logmsg, 0, sizeof(struct CtdlMessage));
logmsg->cm_magic = CTDLMESSAGE_MAGIC;
logmsg->cm_anon_type = MES_NORMAL;
logmsg->cm_format_type = 0;
- logmsg->cm_fields['A'] = strdoop(lun);
- logmsg->cm_fields['N'] = strdoop(NODENAME);
- logmsg->cm_fields['O'] = strdoop(PAGELOGROOM);
- logmsg->cm_fields['R'] = strdoop(x_user);
- logmsg->cm_fields['M'] = strdoop(x_msg);
+ logmsg->cm_fields['A'] = strdup(lun);
+ logmsg->cm_fields['N'] = strdup(NODENAME);
+ logmsg->cm_fields['O'] = strdup(PAGELOGROOM);
+ logmsg->cm_fields['R'] = strdup(x_user);
+ logmsg->cm_fields['M'] = strdup(x_msg);
/* Save a copy of the message in the sender's log room,
create_room(sl->roomname, 5, "", 0, 1, 1);
CtdlSaveMsgPointerInRoom(sl->roomname, msgnum, 0);
sptr = sl->next;
- phree(sl);
+ free(sl);
sl = sptr;
}
if (CC->fake_username[0])
lun = CC->fake_username;
else
- lun = CC->usersupp.fullname;
+ lun = CC->user.fullname;
extract(x_user, argbuf, 0);
extract(x_msg, argbuf, 1);
if (!x_user[0]) {
- cprintf("%d You were not previously paged.\n", ERROR);
+ cprintf("%d You were not previously paged.\n", ERROR + NO_SUCH_USER);
return;
}
- if ((!strcasecmp(x_user, "broadcast")) && (CC->usersupp.axlevel < 6)) {
+ if ((!strcasecmp(x_user, "broadcast")) && (CC->user.axlevel < 6)) {
cprintf("%d Higher access required to send a broadcast.\n",
ERROR + HIGHER_ACCESS_REQUIRED);
return;
if (message_sent == 0) {
cprintf("%d '%s' is not logged in "
"or is not accepting pages.\n",
- ERROR, x_user);
+ ERROR + NO_SUCH_USER, x_user);
return;
}
cprintf("%d Transmit message (will deliver to %d users)\n",
SEND_LISTING, message_sent);
- x_big_msgbuf = mallok(SIZ);
+ x_big_msgbuf = malloc(SIZ);
memset(x_big_msgbuf, 0, SIZ);
while (client_gets(x_msg), strcmp(x_msg, "000")) {
- x_big_msgbuf = reallok(x_big_msgbuf,
+ x_big_msgbuf = realloc(x_big_msgbuf,
strlen(x_big_msgbuf) + strlen(x_msg) + 4);
if (strlen(x_big_msgbuf) > 0)
if (x_big_msgbuf[strlen(x_big_msgbuf)] != '\n')
strcat(x_big_msgbuf, x_msg);
}
PerformXmsgHooks(lun, x_user, x_big_msgbuf);
- phree(x_big_msgbuf);
+ free(x_big_msgbuf);
/* This loop handles inline pages */
} else {
} else {
cprintf("%d '%s' is not logged in "
"or is not accepting pages.\n",
- ERROR, x_user);
+ ERROR + NO_SUCH_USER, x_user);
}
if ((ccptr->cs_pid == which_session) || (which_session == 0)) {
newmsg = (struct ExpressMessage *)
- mallok(sizeof (struct ExpressMessage));
+ malloc(sizeof (struct ExpressMessage));
memset(newmsg, 0,
sizeof (struct ExpressMessage));
time(&(newmsg->timestamp));
- safestrncpy(newmsg->sender, CC->usersupp.fullname,
+ safestrncpy(newmsg->sender, CC->user.fullname,
sizeof newmsg->sender);
newmsg->flags |= EM_GO_AWAY;
- newmsg->text = strdoop("Automatic logoff requested.");
+ newmsg->text = strdup("Automatic logoff requested.");
add_xmsg_to_context(ccptr, newmsg);
++sessions;
-char *serv_inithat_init(void)
+char *serv_chat_init(void)
{
CtdlRegisterProtoHook(cmd_chat, "CHAT", "Begin real-time chat");
CtdlRegisterProtoHook(cmd_pexp, "PEXP", "Poll for express messages");