2 * IRC - Internet Relay Chat, ircd/m_join.c
3 * Copyright (C) 1990 Jarkko Oikarinen and
4 * University of Oulu, Computing Center
6 * See file AUTHORS in IRC package for additional names of
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 1, or (at your option)
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
33 #include "ircd_chattr.h"
34 #include "ircd_features.h"
36 #include "ircd_reply.h"
37 #include "ircd_string.h"
46 /* #include <assert.h> -- Now using assert in ircd_log.h */
50 /** Searches for and handles a 0 in a join list.
51 * @param[in] cptr Client that sent us the message.
52 * @param[in] sptr Original source of message.
53 * @param[in] chanlist List of channels to join.
54 * @return First token in \a chanlist after the final 0 entry, which
55 * may be its nul terminator (if the final entry is a 0 entry).
58 last0(struct Client *cptr, struct Client *sptr, char *chanlist)
63 for (p = chanlist; p[0]; p++) /* find last "JOIN 0" */
64 if (p[0] == '0' && (p[1] == ',' || p[1] == '\0')) {
70 while (p[0] != ',' && p[0] != '\0') /* skip past channel name */
73 if (!p[0]) /* hit the end */
79 struct Membership *member;
81 joinbuf_init(&part, sptr, cptr, JOINBUF_TYPE_PARTALL,
82 "Left all channels", 0);
84 joinbuf_join(&part, 0, 0);
86 while ((member = cli_user(sptr)->channel))
87 joinbuf_join(&part, member->channel,
88 IsZombie(member) ? CHFL_ZOMBIE :
89 IsDelayedJoin(member) ? CHFL_DELAYED :
98 /** Handle a JOIN message from a client connection.
99 * See @ref m_functions for discussion of the arguments.
100 * @param[in] cptr Client that sent us the message.
101 * @param[in] sptr Original source of message.
102 * @param[in] parc Number of arguments.
103 * @param[in] parv Argument vector.
105 int m_join(struct Client *cptr, struct Client *sptr, int parc, char *parv[])
107 struct Channel *chptr;
109 struct JoinBuf create;
116 if (parc < 2 || *parv[1] == '\0')
117 return need_more_params(sptr, "JOIN");
119 joinbuf_init(&join, sptr, cptr, JOINBUF_TYPE_JOIN, 0, 0);
120 joinbuf_init(&create, sptr, cptr, JOINBUF_TYPE_CREATE, 0, TStime());
122 chanlist = last0(cptr, sptr, parv[1]); /* find last "JOIN 0" */
124 keys = parv[2]; /* remember where keys are */
126 for (name = ircd_strtok(&p, chanlist, ","); name;
127 name = ircd_strtok(&p, 0, ",")) {
130 /* If we have any more keys, take the first for this channel. */
132 && (keys = strchr(key = keys, ',')))
135 /* Empty keys are the same as no keys. */
139 if (!IsChannelName(name) || !strIsIrcCh(name))
141 /* bad channel name */
142 send_reply(sptr, ERR_NOSUCHCHANNEL, name);
146 if (cli_user(sptr)->joined >= feature_int(FEAT_MAXCHANNELSPERUSER)
147 && !HasPriv(sptr, PRIV_CHAN_LIMIT)) {
148 send_reply(sptr, ERR_TOOMANYCHANNELS, name);
149 break; /* no point processing the other channels */
152 /* BADCHANed channel */
153 if ((gline = gline_find(name, GLINE_BADCHAN | GLINE_EXACT)) &&
154 GlineIsActive(gline) && !IsAnOper(sptr)) {
155 send_reply(sptr, ERR_BANNEDFROMCHAN, name);
159 if (!(chptr = FindChannel(name))) {
160 if (((name[0] == '&') && !feature_bool(FEAT_LOCAL_CHANNELS))
161 || strlen(name) >= IRCD_MIN(CHANNELLEN, feature_int(FEAT_CHANNELLEN))) {
162 send_reply(sptr, ERR_NOSUCHCHANNEL, name);
166 if (!(chptr = get_channel(sptr, name, CGT_CREATE)))
169 /* Try to add the new channel as a recent target for the user. */
170 if (check_target_limit(sptr, chptr, chptr->chname, 0)) {
172 destruct_channel(chptr);
176 joinbuf_join(&create, chptr, CHFL_CHANOP | CHFL_CHANNEL_MANAGER);
177 } else if (find_member_link(chptr, sptr)) {
178 continue; /* already on channel */
179 } else if (check_target_limit(sptr, chptr, chptr->chname, 0)) {
182 int flags = CHFL_DEOPPED;
185 /* Check Apass/Upass -- since we only ever look at a single
186 * "key" per channel now, this hampers brute force attacks. */
187 if (key && !strcmp(key, chptr->mode.apass))
188 flags = CHFL_CHANOP | CHFL_CHANNEL_MANAGER;
189 else if (key && !strcmp(key, chptr->mode.upass))
191 else if (chptr->users == 0 && !chptr->mode.apass[0]) {
192 /* Joining a zombie channel (zannel): give ops and increment TS. */
194 chptr->creationtime++;
195 } else if (IsInvited(sptr, chptr)) {
196 /* Invites bypass these other checks. */
197 } else if (chptr->mode.mode & MODE_INVITEONLY)
198 err = ERR_INVITEONLYCHAN;
199 else if (chptr->mode.limit && (chptr->users >= chptr->mode.limit))
200 err = ERR_CHANNELISFULL;
201 else if ((chptr->mode.mode & MODE_REGONLY) && !IsAccount(sptr))
202 err = ERR_NEEDREGGEDNICK;
203 else if (find_ban(sptr, chptr->banlist))
204 err = ERR_BANNEDFROMCHAN;
205 else if (*chptr->mode.key && (!key || strcmp(key, chptr->mode.key)))
206 err = ERR_BADCHANNELKEY;
208 /* An oper with WALK_LCHAN privilege can join a local channel
209 * he otherwise could not join by using "OVERRIDE" as the key.
210 * This will generate a HACK(4) notice, but fails if the oper
211 * could normally join the channel. */
212 if (IsLocalChannel(chptr->chname)
213 && HasPriv(sptr, PRIV_WALK_LCHAN)
214 && !(flags & CHFL_CHANOP)
215 && key && !strcmp(key, "OVERRIDE"))
219 if (strcmp(chptr->mode.key, "OVERRIDE")
220 && strcmp(chptr->mode.apass, "OVERRIDE")
221 && strcmp(chptr->mode.upass, "OVERRIDE")) {
222 send_reply(sptr, ERR_DONTCHEAT, chptr->chname);
226 case ERR_INVITEONLYCHAN: err = 'i'; break;
227 case ERR_CHANNELISFULL: err = 'l'; break;
228 case ERR_BANNEDFROMCHAN: err = 'b'; break;
229 case ERR_BADCHANNELKEY: err = 'k'; break;
230 case ERR_NEEDREGGEDNICK: err = 'r'; break;
231 default: err = '?'; break;
233 /* send accountability notice */
235 sendto_opmask_butone(0, SNO_HACK4, "OPER JOIN: %C JOIN %H "
236 "(overriding +%c)", sptr, chptr, err);
240 /* Is there some reason the user may not join? */
242 send_reply(sptr, err, chptr->chname);
246 joinbuf_join(&join, chptr, flags);
247 if (flags & CHFL_CHANOP) {
249 /* Always let the server op him: this is needed on a net with older servers
250 because they 'destruct' channels immediately when they become empty without
251 sending out a DESTRUCT message. As a result, they would always bounce a mode
252 (as HACK(2)) when the user ops himself.
253 (There is also no particularly good reason to have the user op himself.)
255 modebuf_init(&mbuf, &me, cptr, chptr, MODEBUF_DEST_SERVER);
256 modebuf_mode_client(&mbuf, MODE_ADD | MODE_CHANOP, sptr,
257 chptr->mode.apass[0] ? ((flags & CHFL_CHANNEL_MANAGER) ? 0 : 1) : MAXOPLEVEL);
258 modebuf_flush(&mbuf);
262 del_invite(sptr, chptr);
264 if (chptr->topic[0]) {
265 send_reply(sptr, RPL_TOPIC, chptr->chname, chptr->topic);
266 send_reply(sptr, RPL_TOPICWHOTIME, chptr->chname, chptr->topic_nick,
270 do_names(sptr, chptr, NAMES_ALL|NAMES_EON); /* send /names list */
273 joinbuf_flush(&join); /* must be first, if there's a JOIN 0 */
274 joinbuf_flush(&create);
279 /** Handle a JOIN message from a server connection.
280 * See @ref m_functions for discussion of the arguments.
281 * @param[in] cptr Client that sent us the message.
282 * @param[in] sptr Original source of message.
283 * @param[in] parc Number of arguments.
284 * @param[in] parv Argument vector.
286 int ms_join(struct Client *cptr, struct Client *sptr, int parc, char *parv[])
288 struct Membership *member;
289 struct Channel *chptr;
299 return protocol_violation(cptr,
300 "%s tried to JOIN %s, duh!",
302 (parc < 2 || *parv[1] == '\0') ? "a channel" :
307 if (parc < 2 || *parv[1] == '\0')
308 return need_more_params(sptr, "JOIN");
310 if (parc > 2 && parv[2])
311 creation = atoi(parv[2]);
313 joinbuf_init(&join, sptr, cptr, JOINBUF_TYPE_JOIN, 0, 0);
315 chanlist = last0(cptr, sptr, parv[1]); /* find last "JOIN 0" */
317 for (name = ircd_strtok(&p, chanlist, ","); name;
318 name = ircd_strtok(&p, 0, ",")) {
320 flags = CHFL_DEOPPED;
322 if (IsLocalChannel(name) || !IsChannelName(name))
324 protocol_violation(cptr, "%s tried to join %s", cli_name(sptr), name);
328 if (!(chptr = FindChannel(name)))
330 /* No channel exists, so create one */
331 if (!(chptr = get_channel(sptr, name, CGT_CREATE)))
333 protocol_violation(sptr,"couldn't get channel %s for %s",
334 name,cli_name(sptr));
337 flags |= HasFlag(sptr, FLAG_TS8) ? CHFL_SERVOPOK : 0;
339 chptr->creationtime = creation;
341 else { /* We have a valid channel? */
342 if ((member = find_member_link(chptr, sptr)))
344 /* It is impossible to get here --Run */
345 if (!IsZombie(member)) /* already on channel */
348 flags = member->status & (CHFL_DEOPPED | CHFL_SERVOPOK);
349 remove_user_from_channel(sptr, chptr);
350 chptr = FindChannel(name);
353 flags |= HasFlag(sptr, FLAG_TS8) ? CHFL_SERVOPOK : 0;
354 /* Always copy the timestamp when it is older, that is the only way to
355 ensure network-wide synchronization of creation times.
356 We now also copy a creation time that only 1 second younger...
357 this is needed because the timestamp must be incremented
358 by one when someone joins an existing, but empty, channel.
359 However, this is only necessary when the channel is still
360 empty (also here) and when this channel doesn't have +A set.
362 To prevent this from allowing net-rides on the channel, we
363 clear all modes from the channel.
365 (Scenario for a net ride: c1 - s1 - s2 - c2, with c1 the only
366 user in the channel; c1 parts and rejoins, gaining ops.
367 Before s2 sees c1's part, c2 joins the channel and parts
368 immediately. s1 sees c1 part, c1 create, c2 join, c2 part;
369 c2's join resets the timestamp. s2 sees c2 join, c2 part, c1
370 part, c1 create; but since s2 sees the channel as a zannel or
371 non-existent, it does not bounce the create with the newer
374 if (creation && (creation < chptr->creationtime ||
375 (!chptr->mode.apass[0] && chptr->users == 0))) {
376 struct Membership *member;
379 chptr->creationtime = creation;
380 /* Wipe out the current modes on the channel. */
381 modebuf_init(&mbuf, sptr, cptr, chptr, MODEBUF_DEST_CHANNEL | MODEBUF_DEST_HACK3);
383 modebuf_mode(&mbuf, MODE_DEL | chptr->mode.mode);
384 chptr->mode.mode &= MODE_BURSTADDED | MODE_WASDELJOINS;
386 if (chptr->mode.limit) {
387 modebuf_mode_uint(&mbuf, MODE_DEL | MODE_LIMIT, chptr->mode.limit);
388 chptr->mode.limit = 0;
391 if (chptr->mode.key[0]) {
392 modebuf_mode_string(&mbuf, MODE_DEL | MODE_KEY, chptr->mode.key, 0);
393 chptr->mode.key[0] = '\0';
396 if (chptr->mode.upass[0]) {
397 modebuf_mode_string(&mbuf, MODE_DEL | MODE_UPASS, chptr->mode.upass, 0);
398 chptr->mode.upass[0] = '\0';
401 if (chptr->mode.apass[0]) {
402 modebuf_mode_string(&mbuf, MODE_DEL | MODE_APASS, chptr->mode.apass, 0);
403 chptr->mode.apass[0] = '\0';
406 for (member = chptr->members; member; member = member->next_member)
408 if (IsChanOp(member)) {
409 modebuf_mode_client(&mbuf, MODE_DEL | MODE_CHANOP, member->user, OpLevel(member));
410 member->status &= ~CHFL_CHANOP;
412 if (HasVoice(member)) {
413 modebuf_mode_client(&mbuf, MODE_DEL | MODE_VOICE, member->user, OpLevel(member));
414 member->status &= ~CHFL_VOICE;
417 modebuf_flush(&mbuf);
421 joinbuf_join(&join, chptr, flags);
424 joinbuf_flush(&join); /* flush joins... */