X-Git-Url: https://jfr.im/git/solanum.git/blobdiff_plain/b0f30fa1cae6ce975784f54cbfb12994949c2612..1548c140218b956485b3fd5c386447a2add59864:/modules/m_resv.c diff --git a/modules/m_resv.c b/modules/m_resv.c index 3cbf4a86..4160326c 100644 --- a/modules/m_resv.c +++ b/modules/m_resv.c @@ -19,8 +19,6 @@ * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 * USA - * - * $Id: m_resv.c 3045 2006-12-26 23:16:57Z jilles $ */ #include "stdinc.h" @@ -37,56 +35,61 @@ #include "s_newconf.h" #include "hash.h" #include "logger.h" +#include "bandbi.h" +#include "operhash.h" + +static const char resv_desc[] = + "Provides management of reserved nicknames and channels using (UN)RESV"; -static int mo_resv(struct Client *, struct Client *, int, const char **); -static int ms_resv(struct Client *, struct Client *, int, const char **); -static int me_resv(struct Client *, struct Client *, int, const char **); -static int mo_unresv(struct Client *, struct Client *, int, const char **); -static int ms_unresv(struct Client *, struct Client *, int, const char **); -static int me_unresv(struct Client *, struct Client *, int, const char **); +static void mo_resv(struct MsgBuf *, struct Client *, struct Client *, int, const char **); +static void ms_resv(struct MsgBuf *, struct Client *, struct Client *, int, const char **); +static void me_resv(struct MsgBuf *, struct Client *, struct Client *, int, const char **); +static void mo_unresv(struct MsgBuf *, struct Client *, struct Client *, int, const char **); +static void ms_unresv(struct MsgBuf *, struct Client *, struct Client *, int, const char **); +static void me_unresv(struct MsgBuf *, struct Client *, struct Client *, int, const char **); struct Message resv_msgtab = { - "RESV", 0, 0, 0, MFLG_SLOW | MFLG_UNREG, + "RESV", 0, 0, 0, 0, {mg_ignore, mg_not_oper, {ms_resv, 4}, {ms_resv, 4}, {me_resv, 5}, {mo_resv, 3}} }; + struct Message unresv_msgtab = { - "UNRESV", 0, 0, 0, MFLG_SLOW | MFLG_UNREG, + "UNRESV", 0, 0, 0, 0, {mg_ignore, mg_not_oper, {ms_unresv, 3}, {ms_unresv, 3}, {me_unresv, 2}, {mo_unresv, 2}} }; -mapi_clist_av1 resv_clist[] = { &resv_msgtab, &unresv_msgtab, NULL }; -DECLARE_MODULE_AV1(resv, NULL, NULL, resv_clist, NULL, NULL, "$Revision: 3045 $"); +mapi_clist_av1 resv_clist[] = { &resv_msgtab, &unresv_msgtab, NULL }; + +DECLARE_MODULE_AV2(resv, NULL, NULL, resv_clist, NULL, NULL, NULL, NULL, resv_desc); static void parse_resv(struct Client *source_p, const char *name, - const char *reason, int temp_time); + const char *reason, int temp_time, int propagated); static void propagate_resv(struct Client *source_p, const char *target, - int temp_time, const char *name, const char *reason); -static void cluster_resv(struct Client *source_p, int temp_time, - const char *name, const char *reason); + int temp_time, const char *name, const char *reason); +static void cluster_resv(struct Client *source_p, int temp_time, + const char *name, const char *reason); -static void handle_remote_unresv(struct Client *source_p, const char *name); -static void remove_resv(struct Client *source_p, const char *name); -static int remove_resv_from_file(struct Client *source_p, const char *name); +static void remove_resv(struct Client *source_p, const char *name, int propagated); /* * mo_resv() * parv[1] = channel/nick to forbid * parv[2] = reason */ -static int -mo_resv(struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) +static void +mo_resv(struct MsgBuf *msgbuf_p, struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) { const char *name; const char *reason; const char *target_server = NULL; int temp_time; int loc = 1; + int propagated = ConfigFileEntry.use_propagated_bans; if(!IsOperResv(source_p)) { - sendto_one(source_p, form_str(ERR_NOPRIVS), - me.name, source_p->name, "resv"); - return 0; + sendto_one(source_p, form_str(ERR_NOPRIVS), me.name, source_p->name, "resv"); + return; } /* RESV [time] [ON ] : */ @@ -100,24 +103,26 @@ mo_resv(struct Client *client_p, struct Client *source_p, int parc, const char * name = parv[loc]; loc++; - if((parc >= loc+2) && (irccmp(parv[loc], "ON") == 0)) + if((parc >= loc + 2) && (irccmp(parv[loc], "ON") == 0)) { if(!IsOperRemoteBan(source_p)) { sendto_one(source_p, form_str(ERR_NOPRIVS), - me.name, source_p->name, "remoteban"); - return 0; + me.name, source_p->name, "remoteban"); + return; } - target_server = parv[loc+1]; + target_server = parv[loc + 1]; loc += 2; + + /* Set as local-only. */ + propagated = 0; } if(parc <= loc || EmptyString(parv[loc])) { - sendto_one(source_p, form_str(ERR_NEEDMOREPARAMS), - me.name, source_p->name, "RESV"); - return 0; + sendto_one(source_p, form_str(ERR_NEEDMOREPARAMS), me.name, source_p->name, "RESV"); + return; } reason = parv[loc]; @@ -125,17 +130,28 @@ mo_resv(struct Client *client_p, struct Client *source_p, int parc, const char * /* remote resv.. */ if(target_server) { + if (temp_time) + sendto_realops_snomask(SNO_GENERAL, L_NETWIDE, "%s is adding a %d min. RESV for [%s] on %s [%s]", + get_oper_name(source_p), temp_time / 60, name, target_server, reason); + else + sendto_realops_snomask(SNO_GENERAL, L_NETWIDE, "%s is adding a permanent RESV for [%s] on %s [%s]", + get_oper_name(source_p), name, target_server, reason); + propagate_resv(source_p, target_server, temp_time, name, reason); if(match(target_server, me.name) == 0) - return 0; + return; } - else if(rb_dlink_list_length(&cluster_conf_list) > 0) + else if(!propagated && rb_dlink_list_length(&cluster_conf_list) > 0) cluster_resv(source_p, temp_time, name, reason); - parse_resv(source_p, name, reason, temp_time); + if(propagated && temp_time == 0) + { + sendto_one_notice(source_p, ":Cannot set a permanent global ban"); + return; + } - return 0; + parse_resv(source_p, name, reason, temp_time, propagated); } /* ms_resv() @@ -143,35 +159,31 @@ mo_resv(struct Client *client_p, struct Client *source_p, int parc, const char * * parv[2] = channel/nick to forbid * parv[3] = reason */ -static int -ms_resv(struct Client *client_p, struct Client *source_p, - int parc, const char *parv[]) +static void +ms_resv(struct MsgBuf *msgbuf_p, struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) { - /* source_p parv[1] parv[2] parv[3] - * oper target server resv reason + /* parv[0] parv[1] parv[2] parv[3] + * oper target server resv reason */ propagate_resv(source_p, parv[1], 0, parv[2], parv[3]); if(!match(parv[1], me.name)) - return 0; + return; if(!IsPerson(source_p)) - return 0; + return; - parse_resv(source_p, parv[2], parv[3], 0); - return 0; + parse_resv(source_p, parv[2], parv[3], 0, 0); } -static int -me_resv(struct Client *client_p, struct Client *source_p, - int parc, const char *parv[]) +static void +me_resv(struct MsgBuf *msgbuf_p, struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) { /* time name 0 :reason */ if(!IsPerson(source_p)) - return 0; + return; - parse_resv(source_p, parv[2], parv[4], atoi(parv[1])); - return 0; + parse_resv(source_p, parv[2], parv[4], atoi(parv[1]), 0); } /* parse_resv() @@ -183,162 +195,193 @@ me_resv(struct Client *client_p, struct Client *source_p, * side effects - will parse the resv and create it if valid */ static void -parse_resv(struct Client *source_p, const char *name, - const char *reason, int temp_time) +parse_resv(struct Client *source_p, const char *name, const char *reason, int temp_time, int propagated) { struct ConfItem *aconf; - if(!MyClient(source_p) && - !find_shared_conf(source_p->username, source_p->host, - source_p->servptr->name, - (temp_time > 0) ? SHARED_TRESV : SHARED_PRESV)) - return; - if(IsChannelName(name)) { if(hash_find_resv(name)) { sendto_one_notice(source_p, - ":A RESV has already been placed on channel: %s", - name); + ":A RESV has already been placed on channel: %s", name); return; } if(strlen(name) > CHANNELLEN) { - sendto_one_notice(source_p, ":Invalid RESV length: %s", - name); - return; - } - - if(strchr(name, ',')) - { - sendto_one_notice(source_p, - ":Invalid character ',' in channel RESV"); - return; - } - - if(strchr(reason, '"')) - { - sendto_one_notice(source_p, - ":Invalid character '\"' in comment"); + sendto_one_notice(source_p, ":Invalid RESV length: %s", name); return; } aconf = make_conf(); aconf->status = CONF_RESV_CHANNEL; aconf->port = 0; - aconf->name = rb_strdup(name); + aconf->created = rb_current_time(); + aconf->host = rb_strdup(name); aconf->passwd = rb_strdup(reason); - add_to_resv_hash(aconf->name, aconf); + aconf->info.oper = operhash_add(get_oper_name(source_p)); + + if(propagated) + { + aconf->flags |= CONF_FLAGS_MYOPER | CONF_FLAGS_TEMPORARY; + aconf->hold = rb_current_time() + temp_time; + aconf->lifetime = aconf->hold; + replace_old_ban(aconf); + add_prop_ban(aconf); - if(temp_time > 0) + sendto_realops_snomask(SNO_GENERAL, L_ALL, + "%s added global %d min. RESV for [%s] [%s]", + get_oper_name(source_p), temp_time / 60, + name, reason); + ilog(L_KLINE, "R %s %d %s %s", + get_oper_name(source_p), temp_time / 60, name, reason); + sendto_one_notice(source_p, ":Added global %d min. RESV [%s]", + temp_time / 60, name); + sendto_server(NULL, NULL, CAP_BAN|CAP_TS6, NOCAPS, + ":%s BAN R * %s %lu %d %d * :%s", + source_p->id, aconf->host, + (unsigned long)aconf->created, + (int)(aconf->hold - aconf->created), + (int)(aconf->lifetime - aconf->created), + reason); + } + else if(temp_time > 0) { aconf->hold = rb_current_time() + temp_time; sendto_realops_snomask(SNO_GENERAL, L_ALL, - "%s added temporary %d min. RESV for [%s] [%s]", - get_oper_name(source_p), temp_time / 60, - name, reason); + "%s added temporary %d min. RESV for [%s] [%s]", + get_oper_name(source_p), temp_time / 60, + name, reason); ilog(L_KLINE, "R %s %d %s %s", - get_oper_name(source_p), temp_time / 60, - name, reason); + get_oper_name(source_p), temp_time / 60, name, reason); sendto_one_notice(source_p, ":Added temporary %d min. RESV [%s]", - temp_time / 60, name); + temp_time / 60, name); } else - write_confitem(RESV_TYPE, source_p, NULL, aconf->name, - aconf->passwd, NULL, NULL, 0); - } - else if(clean_resv_nick(name)) - { - if(strlen(name) > NICKLEN*2) { - sendto_one_notice(source_p, ":Invalid RESV length: %s", - name); - return; + sendto_realops_snomask(SNO_GENERAL, L_ALL, + "%s added RESV for [%s] [%s]", + get_oper_name(source_p), name, reason); + ilog(L_KLINE, "R %s 0 %s %s", + get_oper_name(source_p), name, reason); + sendto_one_notice(source_p, ":Added RESV [%s]", name); + + bandb_add(BANDB_RESV, source_p, aconf->host, NULL, aconf->passwd, NULL, 0); } - if(strchr(reason, '"')) + add_to_resv_hash(aconf->host, aconf); + resv_chan_forcepart(aconf->host, aconf->passwd, temp_time); + } + else if(clean_resv_nick(name)) + { + if(strlen(name) > NICKLEN * 2) { - sendto_one_notice(source_p, - ":Invalid character '\"' in comment"); + sendto_one_notice(source_p, ":Invalid RESV length: %s", name); return; } if(!valid_wild_card_simple(name)) { sendto_one_notice(source_p, - ":Please include at least %d non-wildcard " - "characters with the resv", - ConfigFileEntry.min_nonwildcard_simple); + ":Please include at least %d non-wildcard " + "characters with the resv", + ConfigFileEntry.min_nonwildcard_simple); return; } if(find_nick_resv_mask(name)) { sendto_one_notice(source_p, - ":A RESV has already been placed on nick: %s", - name); + ":A RESV has already been placed on nick: %s", name); return; } aconf = make_conf(); aconf->status = CONF_RESV_NICK; aconf->port = 0; - aconf->name = rb_strdup(name); + aconf->created = rb_current_time(); + aconf->host = rb_strdup(name); aconf->passwd = rb_strdup(reason); - rb_dlinkAddAlloc(aconf, &resv_conf_list); + aconf->info.oper = operhash_add(get_oper_name(source_p)); - if(temp_time > 0) + if(propagated) { + aconf->flags |= CONF_FLAGS_MYOPER | CONF_FLAGS_TEMPORARY; aconf->hold = rb_current_time() + temp_time; + aconf->lifetime = aconf->hold; + replace_old_ban(aconf); + add_prop_ban(aconf); sendto_realops_snomask(SNO_GENERAL, L_ALL, - "%s added temporary %d min. RESV for [%s] [%s]", - get_oper_name(source_p), temp_time / 60, - name, reason); + "%s added global %d min. RESV for [%s] [%s]", + get_oper_name(source_p), temp_time / 60, + name, reason); ilog(L_KLINE, "R %s %d %s %s", - get_oper_name(source_p), temp_time / 60, - name, reason); + get_oper_name(source_p), temp_time / 60, name, reason); + sendto_one_notice(source_p, ":Added global %d min. RESV [%s]", + temp_time / 60, name); + sendto_server(NULL, NULL, CAP_BAN|CAP_TS6, NOCAPS, + ":%s BAN R * %s %lu %d %d * :%s", + source_p->id, aconf->host, + (unsigned long)aconf->created, + (int)(aconf->hold - aconf->created), + (int)(aconf->lifetime - aconf->created), + reason); + } + else if(temp_time > 0) + { + aconf->hold = rb_current_time() + temp_time; + + sendto_realops_snomask(SNO_GENERAL, L_ALL, + "%s added temporary %d min. RESV for [%s] [%s]", + get_oper_name(source_p), temp_time / 60, + name, reason); + ilog(L_KLINE, "R %s %d %s %s", + get_oper_name(source_p), temp_time / 60, name, reason); sendto_one_notice(source_p, ":Added temporary %d min. RESV [%s]", - temp_time / 60, name); + temp_time / 60, name); } else - write_confitem(RESV_TYPE, source_p, NULL, aconf->name, - aconf->passwd, NULL, NULL, 0); + { + sendto_realops_snomask(SNO_GENERAL, L_ALL, + "%s added RESV for [%s] [%s]", + get_oper_name(source_p), name, reason); + ilog(L_KLINE, "R %s 0 %s %s", + get_oper_name(source_p), name, reason); + sendto_one_notice(source_p, ":Added RESV [%s]", name); + + bandb_add(BANDB_RESV, source_p, aconf->host, NULL, aconf->passwd, NULL, 0); + } + + rb_dlinkAddAlloc(aconf, &resv_conf_list); + resv_nick_fnc(aconf->host, aconf->passwd, temp_time); } else - sendto_one_notice(source_p, - ":You have specified an invalid resv: [%s]", - name); + sendto_one_notice(source_p, ":You have specified an invalid resv: [%s]", name); } -static void +static void propagate_resv(struct Client *source_p, const char *target, - int temp_time, const char *name, const char *reason) + int temp_time, const char *name, const char *reason) { if(!temp_time) { sendto_match_servs(source_p, target, - CAP_CLUSTER, NOCAPS, - "RESV %s %s :%s", - target, name, reason); + CAP_CLUSTER, NOCAPS, "RESV %s %s :%s", target, name, reason); sendto_match_servs(source_p, target, - CAP_ENCAP, CAP_CLUSTER, - "ENCAP %s RESV %d %s 0 :%s", - target, temp_time, name, reason); + CAP_ENCAP, CAP_CLUSTER, + "ENCAP %s RESV %d %s 0 :%s", target, temp_time, name, reason); } else sendto_match_servs(source_p, target, - CAP_ENCAP, NOCAPS, - "ENCAP %s RESV %d %s 0 :%s", - target, temp_time, name, reason); + CAP_ENCAP, NOCAPS, + "ENCAP %s RESV %d %s 0 :%s", target, temp_time, name, reason); } static void -cluster_resv(struct Client *source_p, int temp_time, const char *name, - const char *reason) +cluster_resv(struct Client *source_p, int temp_time, const char *name, const char *reason) { struct remote_conf *shared_p; rb_dlink_node *ptr; @@ -356,19 +399,18 @@ cluster_resv(struct Client *source_p, int temp_time, const char *name, continue; sendto_match_servs(source_p, shared_p->server, - CAP_CLUSTER, NOCAPS, - "RESV %s %s :%s", - shared_p->server, name, reason); + CAP_CLUSTER, NOCAPS, + "RESV %s %s :%s", shared_p->server, name, reason); sendto_match_servs(source_p, shared_p->server, - CAP_ENCAP, CAP_CLUSTER, - "ENCAP %s RESV 0 %s 0 :%s", - shared_p->server, name, reason); + CAP_ENCAP, CAP_CLUSTER, + "ENCAP %s RESV 0 %s 0 :%s", + shared_p->server, name, reason); } else if(shared_p->flags & SHARED_TRESV) sendto_match_servs(source_p, shared_p->server, - CAP_ENCAP, NOCAPS, - "ENCAP %s RESV %d %s 0 :%s", - shared_p->server, temp_time, name, reason); + CAP_ENCAP, NOCAPS, + "ENCAP %s RESV %d %s 0 :%s", + shared_p->server, temp_time, name, reason); } } @@ -377,14 +419,15 @@ cluster_resv(struct Client *source_p, int temp_time, const char *name, * mo_unresv() * parv[1] = channel/nick to unforbid */ -static int -mo_unresv(struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) +static void +mo_unresv(struct MsgBuf *msgbuf_p, struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) { + int propagated = 1; + if(!IsOperResv(source_p)) { - sendto_one(source_p, form_str(ERR_NOPRIVS), - me.name, source_p->name, "resv"); - return 0; + sendto_one(source_p, form_str(ERR_NOPRIVS), me.name, source_p->name, "resv"); + return; } if((parc == 4) && (irccmp(parv[2], "ON") == 0)) @@ -392,107 +435,134 @@ mo_unresv(struct Client *client_p, struct Client *source_p, int parc, const char if(!IsOperRemoteBan(source_p)) { sendto_one(source_p, form_str(ERR_NOPRIVS), - me.name, source_p->name, "remoteban"); - return 0; + me.name, source_p->name, "remoteban"); + return; } - propagate_generic(source_p, "UNRESV", parv[3], CAP_CLUSTER, - "%s", parv[1]); + propagate_generic(source_p, "UNRESV", parv[3], CAP_CLUSTER, "%s", parv[1]); if(match(parv[3], me.name) == 0) - return 0; + return; + + propagated = 0; } +#if 0 else if(rb_dlink_list_length(&cluster_conf_list) > 0) - cluster_generic(source_p, "UNRESV", SHARED_UNRESV, CAP_CLUSTER, - "%s", parv[1]); + cluster_generic(source_p, "UNRESV", SHARED_UNRESV, CAP_CLUSTER, "%s", parv[1]); +#endif + /* cluster{} moved to remove_resv */ - remove_resv(source_p, parv[1]); - return 0; + remove_resv(source_p, parv[1], propagated); } /* ms_unresv() * parv[1] = target server * parv[2] = resv to remove */ -static int -ms_unresv(struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) +static void +ms_unresv(struct MsgBuf *msgbuf_p, struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) { - /* source_p parv[1] parv[2] - * oper target server resv to remove + /* parv[0] parv[1] parv[2] + * oper target server resv to remove */ - propagate_generic(source_p, "UNRESV", parv[1], CAP_CLUSTER, - "%s", parv[2]); + propagate_generic(source_p, "UNRESV", parv[1], CAP_CLUSTER, "%s", parv[2]); if(!match(parv[1], me.name)) - return 0; + return; if(!IsPerson(source_p)) - return 0; + return; - handle_remote_unresv(source_p, parv[2]); - return 0; + remove_resv(source_p, parv[2], 0); } -static int -me_unresv(struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) +static void +me_unresv(struct MsgBuf *msgbuf_p, struct Client *client_p, struct Client *source_p, int parc, const char *parv[]) { /* name */ if(!IsPerson(source_p)) - return 0; - - handle_remote_unresv(source_p, parv[1]); - return 0; -} - -static void -handle_remote_unresv(struct Client *source_p, const char *name) -{ - if(!find_shared_conf(source_p->username, source_p->host, - source_p->servptr->name, SHARED_UNRESV)) return; - remove_resv(source_p, name); - - return; + remove_resv(source_p, parv[1], 0); } static void -remove_resv(struct Client *source_p, const char *name) +remove_resv(struct Client *source_p, const char *name, int propagated) { struct ConfItem *aconf = NULL; + rb_dlink_node *ptr; + time_t now; if(IsChannelName(name)) { if((aconf = hash_find_resv(name)) == NULL) { + if(propagated && rb_dlink_list_length(&cluster_conf_list)) + cluster_generic(source_p, "UNRESV", SHARED_UNRESV, CAP_CLUSTER, "%s", name); + sendto_one_notice(source_p, ":No RESV for %s", name); return; } - if(!aconf->hold) + if(aconf->lifetime) { - if (!remove_resv_from_file(source_p, name)) + if(!propagated) + { + sendto_one_notice(source_p, ":Cannot remove global RESV %s on specific servers", name); + return; + } + if (!lookup_prop_ban(aconf)) return; + sendto_one_notice(source_p, ":RESV for [%s] is removed", name); + sendto_realops_snomask(SNO_GENERAL, L_ALL, + "%s has removed the global RESV for: [%s]", + get_oper_name(source_p), name); + ilog(L_KLINE, "UR %s %s", get_oper_name(source_p), name); + now = rb_current_time(); + if(aconf->created < now) + aconf->created = now; + else + aconf->created++; + aconf->hold = aconf->created; + operhash_delete(aconf->info.oper); + aconf->info.oper = operhash_add(get_oper_name(source_p)); + aconf->flags |= CONF_FLAGS_MYOPER | CONF_FLAGS_TEMPORARY; + sendto_server(NULL, NULL, CAP_BAN|CAP_TS6, NOCAPS, + ":%s BAN R * %s %lu %d %d * :*", + source_p->id, aconf->host, + (unsigned long)aconf->created, + 0, + (int)(aconf->lifetime - aconf->created)); + deactivate_conf(aconf, now); + return; + } + else if(propagated && rb_dlink_list_length(&cluster_conf_list) > 0) + cluster_generic(source_p, "UNRESV", SHARED_UNRESV, CAP_CLUSTER, "%s", name); + + sendto_one_notice(source_p, ":RESV for [%s] is removed", name); + ilog(L_KLINE, "UR %s %s", get_oper_name(source_p), name); + if(!aconf->hold) + { + bandb_del(BANDB_RESV, aconf->host, NULL); + sendto_realops_snomask(SNO_GENERAL, L_ALL, + "%s has removed the RESV for: [%s]", + get_oper_name(source_p), name); } else { - sendto_one_notice(source_p, ":RESV for [%s] is removed", name); sendto_realops_snomask(SNO_GENERAL, L_ALL, - "%s has removed the RESV for: [%s]", - get_oper_name(source_p), name); - ilog(L_KLINE, "UR %s %s", get_oper_name(source_p), name); + "%s has removed the temporary RESV for: [%s]", + get_oper_name(source_p), name); } del_from_resv_hash(name, aconf); } else { - rb_dlink_node *ptr; - RB_DLINK_FOREACH(ptr, resv_conf_list.head) { aconf = ptr->data; - if(irccmp(aconf->name, name)) + if(irccmp(aconf->host, name)) aconf = NULL; else break; @@ -500,141 +570,67 @@ remove_resv(struct Client *source_p, const char *name) if(aconf == NULL) { + if(propagated && rb_dlink_list_length(&cluster_conf_list)) + cluster_generic(source_p, "UNRESV", SHARED_UNRESV, CAP_CLUSTER, "%s", name); + sendto_one_notice(source_p, ":No RESV for %s", name); return; } - if(!aconf->hold) + if(aconf->lifetime) { - if (!remove_resv_from_file(source_p, name)) + if(!propagated) + { + sendto_one_notice(source_p, ":Cannot remove global RESV %s on specific servers", name); + return; + } + if (!lookup_prop_ban(aconf)) return; - } - else - { sendto_one_notice(source_p, ":RESV for [%s] is removed", name); sendto_realops_snomask(SNO_GENERAL, L_ALL, - "%s has removed the RESV for: [%s]", - get_oper_name(source_p), name); + "%s has removed the global RESV for: [%s]", + get_oper_name(source_p), name); ilog(L_KLINE, "UR %s %s", get_oper_name(source_p), name); + now = rb_current_time(); + if(aconf->created < now) + aconf->created = now; + else + aconf->created++; + aconf->hold = aconf->created; + operhash_delete(aconf->info.oper); + aconf->info.oper = operhash_add(get_oper_name(source_p)); + aconf->flags |= CONF_FLAGS_MYOPER | CONF_FLAGS_TEMPORARY; + sendto_server(NULL, NULL, CAP_BAN|CAP_TS6, NOCAPS, + ":%s BAN R * %s %lu %d %d * :*", + source_p->id, aconf->host, + (unsigned long)aconf->created, + 0, + (int)(aconf->lifetime - aconf->created)); + deactivate_conf(aconf, now); + return; } - /* already have ptr from the loop above.. */ - rb_dlinkDestroy(ptr, &resv_conf_list); - } - free_conf(aconf); - - return; -} - -/* remove_resv_from_file() - * - * inputs - client removing the resv - * - resv to remove - * outputs - - * side effects - resv if found, is removed from conf - * - does not touch resv hash or resv_conf_list - */ -static int -remove_resv_from_file(struct Client *source_p, const char *name) -{ - FILE *in, *out; - char buf[BUFSIZE]; - char buff[BUFSIZE]; - char temppath[BUFSIZE]; - const char *filename; - mode_t oldumask; - char *p; - int error_on_write = 0; - int found_resv = 0; - - rb_sprintf(temppath, "%s.tmp", ConfigFileEntry.resvfile); - filename = get_conf_name(RESV_TYPE); - - if((in = fopen(filename, "r")) == NULL) - { - sendto_one_notice(source_p, ":Cannot open %s", filename); - return 0; - } - - oldumask = umask(0); - - if((out = fopen(temppath, "w")) == NULL) - { - sendto_one_notice(source_p, ":Cannot open %s", temppath); - fclose(in); - umask(oldumask); - return 0; - } - - umask(oldumask); - - while (fgets(buf, sizeof(buf), in)) - { - const char *resv_name; - - if(error_on_write) - { - if(temppath != NULL) - (void) unlink(temppath); - - break; - } - - rb_strlcpy(buff, buf, sizeof(buff)); - - if((p = strchr(buff, '\n')) != NULL) - *p = '\0'; - - if((*buff == '\0') || (*buff == '#')) - { - error_on_write = (fputs(buf, out) < 0) ? YES : NO; - continue; - } - - if((resv_name = getfield(buff)) == NULL) - { - error_on_write = (fputs(buf, out) < 0) ? YES : NO; - continue; - } + else if(propagated && rb_dlink_list_length(&cluster_conf_list) > 0) + cluster_generic(source_p, "UNRESV", SHARED_UNRESV, CAP_CLUSTER, "%s", name); - if(irccmp(resv_name, name) == 0) + sendto_one_notice(source_p, ":RESV for [%s] is removed", name); + ilog(L_KLINE, "UR %s %s", get_oper_name(source_p), name); + if(!aconf->hold) { - found_resv++; + bandb_del(BANDB_RESV, aconf->host, NULL); + sendto_realops_snomask(SNO_GENERAL, L_ALL, + "%s has removed the RESV for: [%s]", + get_oper_name(source_p), name); } else { - error_on_write = (fputs(buf, out) < 0) ? YES : NO; + sendto_realops_snomask(SNO_GENERAL, L_ALL, + "%s has removed the temporary RESV for: [%s]", + get_oper_name(source_p), name); } + /* already have ptr from the loop above.. */ + rb_dlinkDestroy(ptr, &resv_conf_list); } + free_conf(aconf); - fclose(in); - if (fclose(out)) - error_on_write = YES; - - if(error_on_write) - { - sendto_one_notice(source_p, ":Couldn't write temp resv file, aborted"); - return 0; - } - else if(!found_resv) - { - sendto_one_notice(source_p, ":Cannot find RESV for %s in file", name); - - if(temppath != NULL) - (void) unlink(temppath); - - return 0; - } - - if (rename(temppath, filename)) - { - sendto_one_notice(source_p, ":Couldn't rename temp file, aborted"); - return 0; - } - - sendto_one_notice(source_p, ":RESV for [%s] is removed", name); - sendto_realops_snomask(SNO_GENERAL, L_ALL, - "%s has removed the RESV for: [%s]", get_oper_name(source_p), name); - ilog(L_KLINE, "UR %s %s", get_oper_name(source_p), name); - - return 1; + return; }