X-Git-Url: https://jfr.im/git/irc/evilnet/x3.git/blobdiff_plain/b1bf690d5e16c7f79d3ec308ffdc705e007ce6e5..09a3057ce9cc09138dd04f07e5390f49a033f2f6:/src/global.c diff --git a/src/global.c b/src/global.c index 32dae6a..6944caa 100644 --- a/src/global.c +++ b/src/global.c @@ -3,7 +3,7 @@ * * This file is part of x3. * - * srvx is free software; you can redistribute it and/or modify + * x3 is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. @@ -20,6 +20,7 @@ #include "conf.h" #include "global.h" +#include "hash.h" #include "modcmd.h" #include "nickserv.h" #include "saxdb.h" @@ -55,21 +56,58 @@ static const struct message_entry msgtab[] = { { "GMSG_ID_INVALID", "$b%s$b is an invalid message ID." }, { "GMSG_MESSAGE_COUNT", "$b%d$b messages found." }, { "GMSG_NO_MESSAGES", "There are no messages for you." }, - { "GMSG_NOTICE_SOURCE", "[$b%s$b] Notice from %s:" }, - { "GMSG_MESSAGE_SOURCE", "[$b%s$b] Notice from %s, posted %s:" }, - { "GMSG_MOTD_HEADER", "$b------------- MESSAGE(S) OF THE DAY --------------$b" }, - { "GMSG_MOTD_FOOTER", "$b---------- END OF MESSAGE(S) OF THE DAY ----------$b" }, + { "GMSG_NOTICE_SOURCE", "Notice to [$b%s$b] from %s:" }, + { "GMSG_MESSAGE_SOURCE", "Notice to [$b%s$b] from %s, posted %s:" }, + //{ "GMSG_MOTD_HEADER", "$b------------- MESSAGE(S) OF THE DAY --------------$b" }, + { "GMSG_MOTD_HEADER", "$bNetwork Announcements$b" }, + { "GMSG_MOTD_BAR", "---------------------------------------" }, + { "GMSG_MOTD_FOOTER", "--------------- Thank You--------------" }, + + /* These definitions are for other files that make use of global + * notices. Make sure you grep for them if you ever add args + * to the notice. + */ + /* chanserv.c */ + { "CSMSG_REGISTERED_TO", "%s registered to %s by %s." }, + { "CSMSG_CHANNEL_MOVED", "%s moved to %s by %s." }, + { "CSMSG_SUSPENSION_MODIFIED", "%s suspension modified by %s." }, + { "CSMSG_SUSPENDED_BY", "%s suspended by %s." }, + { "CSMSG_UNSUSPENDED_BY", "%s unsuspended by %s." }, + { "CSMSG_OWNERSHIP_TRANSFERRED", "%s ownership transferred to %s by %s." }, + + /* opserv.c */ + { "DEFCON_NETWORK_CHANGED", "Network DefCon level has changed to level %d" }, + { "DEFCON_OPER_LEVEL_CHANGE", "%s is changing the DefCon level to %d" }, + { "DEFCON_TIMEOUT_LEVEL_CHANGE", "The DefCon has changed back to level %d (timeout)" }, + { NULL, NULL } }; #define GLOBAL_SYNTAX() svccmd_send_help_brief(user, global, cmd) #define GLOBAL_FUNC(NAME) MODCMD_FUNC(NAME) +struct globalMessage +{ + unsigned long id; + long flags; + + time_t posted; + char posted_s[24]; + unsigned long duration; + + char *from; + char *message; + + struct globalMessage *prev; + struct globalMessage *next; +}; + struct userNode *global; static struct module *global_module; static struct service *global_service; static struct globalMessage *messageList; +extern struct string_list *autojoin_channels; static long messageCount; static time_t last_max_alert; static struct log_type *G_LOG; @@ -88,9 +126,9 @@ static struct globalMessage* message_add(long flags, time_t posted, unsigned long duration, char *from, const char *msg) { struct globalMessage *message; + struct tm tm; message = malloc(sizeof(struct globalMessage)); - if(!message) { return NULL; @@ -103,11 +141,16 @@ message_add(long flags, time_t posted, unsigned long duration, char *from, const message->from = strdup(from); message->message = strdup(msg); + if ((flags & MESSAGE_OPTION_IMMEDIATE) == 0) { + localtime_r(&message->posted, &tm); + strftime(message->posted_s, sizeof(message->posted_s), + "%I:%M %p, %m/%d/%Y", &tm); + } + if(messageList) { messageList->prev = message; } - message->prev = NULL; message->next = messageList; @@ -152,9 +195,12 @@ message_create(struct userNode *user, unsigned int argc, char *argv[]) { unsigned long duration = 0; char *text = NULL; + char *sender; long flags = 0; unsigned int i; + sender = user->handle_info->handle; + for(i = 0; i < argc; i++) { if((i + 1) > argc) @@ -194,6 +240,8 @@ message_create(struct userNode *user, unsigned int argc, char *argv[]) } } else if (irccasecmp(argv[i], "duration") == 0) { duration = ParseInterval(argv[++i]); + } else if (irccasecmp(argv[i], "from") == 0) { + sender = argv[++i]; } else { global_notice(user, "MSG_INVALID_CRITERIA", argv[i]); return NULL; @@ -210,7 +258,7 @@ message_create(struct userNode *user, unsigned int argc, char *argv[]) return NULL; } - return message_add(flags, now, duration, user->handle_info->handle, text); + return message_add(flags, now, duration, sender, text); } static const char * @@ -257,12 +305,7 @@ notice_target(const char *target, struct globalMessage *message) } else { - char posted[24]; - struct tm tm; - - localtime_r(&message->posted, &tm); - strftime(posted, sizeof(posted), "%I:%M %p, %m/%d/%Y", &tm); - send_target_message(0, target, global, "GMSG_MESSAGE_SOURCE", messageType(message), message->from, posted); + send_target_message(0, target, global, "GMSG_MESSAGE_SOURCE", messageType(message), message->from, message->posted_s); } } @@ -336,6 +379,59 @@ message_send(struct globalMessage *message) } } +void +global_message_args(long targets, const char *language_entry, ...) +{ + struct globalMessage *message; + va_list arg_list; + dict_iterator_t it; + char response[MAXLEN]; + const char *fmt; + + if(!targets || !global) + return; + + fmt = strdup(language_entry); + + /* Notice users/opers/helpers */ + for (it = dict_first(clients); it; it = iter_next(it)) { + struct userNode *luser = iter_data(it); + + language_entry = user_find_message(luser, fmt); + + va_start(arg_list, language_entry); + vsnprintf(response, MAXLEN-2, language_entry, arg_list); + response[MAXLEN-1] = 0; + + message = message_add(targets | MESSAGE_OPTION_SOURCELESS, now, 0, "", response); + if (!message) + continue; + + /* opers */ + if(message->flags & MESSAGE_RECIPIENT_OPERS && IsOper(luser)) { + if(luser->uplink != self) + notice_target(luser->nick, message); + + if ((message->flags & MESSAGE_RECIPIENT_LUSERS) || (message->flags & MESSAGE_RECIPIENT_HELPERS)) + continue; + } + + /* helpers */ + if (message->flags & MESSAGE_RECIPIENT_HELPERS && IsHelper(luser)) { + notice_target(luser->nick, message); + + if (message->flags & MESSAGE_RECIPIENT_LUSERS) + continue; + } + + /* users */ + if (message->flags & MESSAGE_RECIPIENT_LUSERS) + notice_target(luser->nick, message); + } + + message_del(message); +} + void global_message(long targets, char *text) { @@ -356,9 +452,11 @@ static GLOBAL_FUNC(cmd_notice) { struct globalMessage *message = NULL; const char *recipient = NULL, *text; + char *sender; long target = 0; assert(argc >= 3); + sender = user->handle_info->handle; if(!irccasecmp(argv[1], "all")) { target = MESSAGE_RECIPIENT_ALL; } else if(!irccasecmp(argv[1], "users")) { @@ -377,17 +475,23 @@ static GLOBAL_FUNC(cmd_notice) global_notice(user, "GMSG_INVALID_TARGET", argv[1]); return 0; } + if(!irccasecmp(argv[2], "from")) { + if (argc < 5) { + reply("MSG_MISSING_PARAMS", argv[0]); + GLOBAL_SYNTAX(); + return 0; + } + sender = argv[3]; + text = unsplit_string(argv + 4, argc - 4, NULL); + } else { + text = unsplit_string(argv + 2, argc - 2, NULL); + } - text = unsplit_string(argv + 2, argc - 2, NULL); - message = message_add(target | MESSAGE_OPTION_IMMEDIATE, now, 0, user->handle_info->handle, text); - + message = message_add(target | MESSAGE_OPTION_IMMEDIATE, now, 0, sender, text); if(!message) - { return 0; - } recipient = messageType(message); - message_send(message); message_del(message); @@ -503,7 +607,10 @@ send_messages(struct userNode *user, long mask, int obstreperize) if(message->flags & mask) { if (obstreperize && !count) + { send_target_message(0, user->nick, global, "GMSG_MOTD_HEADER"); + send_target_message(0, user->nick, global, "GMSG_MOTD_BAR"); + } notice_target(user->nick, message); count++; } @@ -658,6 +765,8 @@ global_db_cleanup(void) void init_global(const char *nick) { + struct chanNode *chan; + unsigned int i; G_LOG = log_register_type("Global", "file:global.log"); reg_new_user_func(global_process_user); reg_auth_func(global_process_auth); @@ -678,6 +787,14 @@ init_global(const char *nick) global = AddService(nick, modes ? modes : NULL, "Global Services", NULL); global_service = service_register(global); } + + if(autojoin_channels && global) { + for (i = 0; i < autojoin_channels->used; i++) { + chan = AddChannel(autojoin_channels->list[i], now, "+nt", NULL, NULL); + AddChannelUser(global, chan)->modes |= MODE_CHANOP; + } + } + saxdb_register("Global", global_saxdb_read, global_saxdb_write); reg_exit_func(global_db_cleanup); message_register_table(msgtab);