]> jfr.im git - irc/rqf/shadowircd.git/blame - src/channel.c
Add an include
[irc/rqf/shadowircd.git] / src / channel.c
CommitLineData
212380e3 1/*
2 * ircd-ratbox: A slightly useful ircd.
3 * channel.c: Controls channels.
4 *
5 * Copyright (C) 1990 Jarkko Oikarinen and University of Oulu, Co Center
6 * Copyright (C) 1996-2002 Hybrid Development Team
7 * Copyright (C) 2002-2005 ircd-ratbox development team
8 *
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 2 of the License, or
12 * (at your option) any later version.
13 *
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.
18 *
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., 59 Temple Place, Suite 330, Boston, MA 02111-1307
22 * USA
23 *
83294285 24 * $Id: channel.c 3580 2007-11-07 23:45:14Z jilles $
212380e3 25 */
26
27#include "stdinc.h"
212380e3 28#include "channel.h"
fba62b01 29#include "chmode.h"
212380e3 30#include "client.h"
31#include "common.h"
32#include "hash.h"
33#include "hook.h"
13ae2f4b 34#include "match.h"
212380e3 35#include "ircd.h"
36#include "numeric.h"
37#include "s_serv.h" /* captab */
38#include "s_user.h"
39#include "send.h"
40#include "whowas.h"
41#include "s_conf.h" /* ConfigFileEntry, ConfigChannel */
42#include "s_newconf.h"
d3455e2c 43#include "logger.h"
3472ff3f 44#include "packet.h"
212380e3 45
9813daca 46struct config_channel_entry ConfigChannel;
1a218aaf 47rb_dlink_list global_channel_list;
5475a932
VY
48static rb_bh *channel_heap;
49static rb_bh *ban_heap;
50static rb_bh *topic_heap;
51static rb_bh *member_heap;
52
212380e3 53static int channel_capabs[] = { CAP_EX, CAP_IE,
54 CAP_SERVICE,
55 CAP_TS6
56};
57
58#define NCHCAPS (sizeof(channel_capabs)/sizeof(int))
59#define NCHCAP_COMBOS (1 << NCHCAPS)
60
61static struct ChCapCombo chcap_combos[NCHCAP_COMBOS];
62
63static void free_topic(struct Channel *chptr);
64
65static int h_can_join;
67b90240
JH
66static int h_can_create_channel;
67static int h_channel_join;
212380e3 68
69/* init_channels()
70 *
71 * input -
72 * output -
73 * side effects - initialises the various blockheaps
74 */
75void
76init_channels(void)
77{
dd9be678
WP
78 channel_heap = rb_bh_create(sizeof(struct Channel), CHANNEL_HEAP_SIZE, "channel_heap");
79 ban_heap = rb_bh_create(sizeof(struct Ban), BAN_HEAP_SIZE, "ban_heap");
80 topic_heap = rb_bh_create(TOPICLEN + 1 + USERHOST_REPLYLEN, TOPIC_HEAP_SIZE, "topic_heap");
81 member_heap = rb_bh_create(sizeof(struct membership), MEMBER_HEAP_SIZE, "member_heap");
212380e3 82
83 h_can_join = register_hook("can_join");
67b90240
JH
84 h_channel_join = register_hook("channel_join");
85 h_can_create_channel = register_hook("can_create_channel");
212380e3 86}
87
88/*
89 * allocate_channel - Allocates a channel
90 */
91struct Channel *
92allocate_channel(const char *chname)
93{
94 struct Channel *chptr;
6e9b4415 95 chptr = rb_bh_alloc(channel_heap);
62d28946 96 chptr->chname = rb_strdup(chname);
212380e3 97 return (chptr);
98}
99
100void
101free_channel(struct Channel *chptr)
102{
90a3c35b 103 rb_free(chptr->chname);
6e9b4415 104 rb_bh_free(channel_heap, chptr);
212380e3 105}
106
107struct Ban *
108allocate_ban(const char *banstr, const char *who)
109{
110 struct Ban *bptr;
6e9b4415 111 bptr = rb_bh_alloc(ban_heap);
62d28946
VY
112 bptr->banstr = rb_strdup(banstr);
113 bptr->who = rb_strdup(who);
212380e3 114
115 return (bptr);
116}
117
118void
119free_ban(struct Ban *bptr)
120{
90a3c35b
VY
121 rb_free(bptr->banstr);
122 rb_free(bptr->who);
6e9b4415 123 rb_bh_free(ban_heap, bptr);
212380e3 124}
125
126
127/* find_channel_membership()
128 *
129 * input - channel to find them in, client to find
130 * output - membership of client in channel, else NULL
131 * side effects -
132 */
133struct membership *
134find_channel_membership(struct Channel *chptr, struct Client *client_p)
135{
136 struct membership *msptr;
af81d5a0 137 rb_dlink_node *ptr;
212380e3 138
139 if(!IsClient(client_p))
140 return NULL;
141
142 /* Pick the most efficient list to use to be nice to things like
143 * CHANSERV which could be in a large number of channels
144 */
af81d5a0 145 if(rb_dlink_list_length(&chptr->members) < rb_dlink_list_length(&client_p->user->channel))
212380e3 146 {
8e69bb4e 147 RB_DLINK_FOREACH(ptr, chptr->members.head)
212380e3 148 {
149 msptr = ptr->data;
150
151 if(msptr->client_p == client_p)
152 return msptr;
153 }
154 }
155 else
156 {
8e69bb4e 157 RB_DLINK_FOREACH(ptr, client_p->user->channel.head)
212380e3 158 {
159 msptr = ptr->data;
160
161 if(msptr->chptr == chptr)
162 return msptr;
163 }
164 }
165
166 return NULL;
167}
168
169/* find_channel_status()
170 *
171 * input - membership to get status for, whether we can combine flags
172 * output - flags of user on channel
173 * side effects -
174 */
175const char *
176find_channel_status(struct membership *msptr, int combine)
177{
178 static char buffer[3];
179 char *p;
180
181 p = buffer;
182
183 if(is_chanop(msptr))
184 {
185 if(!combine)
186 return "@";
187 *p++ = '@';
188 }
189
190 if(is_voiced(msptr))
191 *p++ = '+';
192
193 *p = '\0';
194 return buffer;
195}
196
197/* add_user_to_channel()
198 *
199 * input - channel to add client to, client to add, channel flags
200 * output -
201 * side effects - user is added to channel
202 */
203void
204add_user_to_channel(struct Channel *chptr, struct Client *client_p, int flags)
205{
206 struct membership *msptr;
207
208 s_assert(client_p->user != NULL);
209 if(client_p->user == NULL)
210 return;
211
6e9b4415 212 msptr = rb_bh_alloc(member_heap);
212380e3 213
214 msptr->chptr = chptr;
215 msptr->client_p = client_p;
216 msptr->flags = flags;
217
af81d5a0
WP
218 rb_dlinkAdd(msptr, &msptr->usernode, &client_p->user->channel);
219 rb_dlinkAdd(msptr, &msptr->channode, &chptr->members);
212380e3 220
221 if(MyClient(client_p))
af81d5a0 222 rb_dlinkAdd(msptr, &msptr->locchannode, &chptr->locmembers);
212380e3 223}
224
225/* remove_user_from_channel()
226 *
227 * input - membership pointer to remove from channel
228 * output -
229 * side effects - membership (thus user) is removed from channel
230 */
231void
232remove_user_from_channel(struct membership *msptr)
233{
234 struct Client *client_p;
235 struct Channel *chptr;
236 s_assert(msptr != NULL);
237 if(msptr == NULL)
238 return;
239
240 client_p = msptr->client_p;
241 chptr = msptr->chptr;
242
af81d5a0
WP
243 rb_dlinkDelete(&msptr->usernode, &client_p->user->channel);
244 rb_dlinkDelete(&msptr->channode, &chptr->members);
212380e3 245
246 if(client_p->servptr == &me)
af81d5a0 247 rb_dlinkDelete(&msptr->locchannode, &chptr->locmembers);
212380e3 248
af81d5a0 249 if(!(chptr->mode.mode & MODE_PERMANENT) && rb_dlink_list_length(&chptr->members) <= 0)
212380e3 250 destroy_channel(chptr);
251
6e9b4415 252 rb_bh_free(member_heap, msptr);
212380e3 253
254 return;
255}
256
257/* remove_user_from_channels()
258 *
259 * input - user to remove from all channels
260 * output -
261 * side effects - user is removed from all channels
262 */
263void
264remove_user_from_channels(struct Client *client_p)
265{
266 struct Channel *chptr;
267 struct membership *msptr;
af81d5a0 268 rb_dlink_node *ptr;
90a3c35b 269 rb_dlink_node *next_ptr;
212380e3 270
271 if(client_p == NULL)
272 return;
273
90a3c35b 274 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, client_p->user->channel.head)
212380e3 275 {
276 msptr = ptr->data;
277 chptr = msptr->chptr;
278
af81d5a0 279 rb_dlinkDelete(&msptr->channode, &chptr->members);
212380e3 280
281 if(client_p->servptr == &me)
af81d5a0 282 rb_dlinkDelete(&msptr->locchannode, &chptr->locmembers);
212380e3 283
af81d5a0 284 if(!(chptr->mode.mode & MODE_PERMANENT) && rb_dlink_list_length(&chptr->members) <= 0)
212380e3 285 destroy_channel(chptr);
286
6e9b4415 287 rb_bh_free(member_heap, msptr);
212380e3 288 }
289
290 client_p->user->channel.head = client_p->user->channel.tail = NULL;
291 client_p->user->channel.length = 0;
292}
293
294/* invalidate_bancache_user()
295 *
296 * input - user to invalidate ban cache for
297 * output -
298 * side effects - ban cache is invalidated for all memberships of that user
299 * to be used after a nick change
300 */
301void
302invalidate_bancache_user(struct Client *client_p)
303{
304 struct membership *msptr;
af81d5a0 305 rb_dlink_node *ptr;
212380e3 306
307 if(client_p == NULL)
308 return;
309
8e69bb4e 310 RB_DLINK_FOREACH(ptr, client_p->user->channel.head)
212380e3 311 {
312 msptr = ptr->data;
313 msptr->bants = 0;
314 msptr->flags &= ~CHFL_BANNED;
315 }
316}
317
318/* check_channel_name()
319 *
320 * input - channel name
321 * output - 1 if valid channel name, else 0
322 * side effects -
323 */
324int
325check_channel_name(const char *name)
326{
327 s_assert(name != NULL);
328 if(name == NULL)
329 return 0;
330
331 for (; *name; ++name)
332 {
333 if(!IsChanChar(*name))
334 return 0;
335 }
336
337 return 1;
338}
339
340/* free_channel_list()
341 *
af81d5a0 342 * input - rb_dlink list to free
212380e3 343 * output -
344 * side effects - list of b/e/I modes is cleared
345 */
346void
af81d5a0 347free_channel_list(rb_dlink_list * list)
212380e3 348{
af81d5a0 349 rb_dlink_node *ptr;
90a3c35b 350 rb_dlink_node *next_ptr;
212380e3 351 struct Ban *actualBan;
352
90a3c35b 353 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, list->head)
212380e3 354 {
355 actualBan = ptr->data;
356 free_ban(actualBan);
357 }
358
359 list->head = list->tail = NULL;
360 list->length = 0;
361}
362
363/* destroy_channel()
364 *
365 * input - channel to destroy
366 * output -
367 * side effects - channel is obliterated
368 */
369void
370destroy_channel(struct Channel *chptr)
371{
90a3c35b 372 rb_dlink_node *ptr, *next_ptr;
212380e3 373
90a3c35b 374 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, chptr->invites.head)
212380e3 375 {
376 del_invite(chptr, ptr->data);
377 }
378
379 /* free all bans/exceptions/denies */
380 free_channel_list(&chptr->banlist);
381 free_channel_list(&chptr->exceptlist);
382 free_channel_list(&chptr->invexlist);
fea1ad52 383 free_channel_list(&chptr->quietlist);
212380e3 384
385 /* Free the topic */
386 free_topic(chptr);
387
af81d5a0 388 rb_dlinkDelete(&chptr->node, &global_channel_list);
212380e3 389 del_from_channel_hash(chptr->chname, chptr);
390 free_channel(chptr);
391}
392
393/* channel_pub_or_secret()
394 *
395 * input - channel
396 * output - "=" if public, "@" if secret, else "*"
397 * side effects -
398 */
399static const char *
400channel_pub_or_secret(struct Channel *chptr)
401{
402 if(PubChannel(chptr))
403 return ("=");
404 else if(SecretChannel(chptr))
405 return ("@");
406 return ("*");
407}
408
409/* channel_member_names()
410 *
411 * input - channel to list, client to list to, show endofnames
412 * output -
413 * side effects - client is given list of users on channel
414 */
415void
416channel_member_names(struct Channel *chptr, struct Client *client_p, int show_eon)
417{
418 struct membership *msptr;
419 struct Client *target_p;
af81d5a0 420 rb_dlink_node *ptr;
212380e3 421 char lbuf[BUFSIZE];
422 char *t;
423 int mlen;
424 int tlen;
425 int cur_len;
426 int is_member;
427 int stack = IsCapable(client_p, CLICAP_MULTI_PREFIX);
428
429 if(ShowChannel(client_p, chptr))
430 {
431 is_member = IsMember(client_p, chptr);
432
38e6acdd 433 cur_len = mlen = rb_sprintf(lbuf, form_str(RPL_NAMREPLY),
212380e3 434 me.name, client_p->name,
435 channel_pub_or_secret(chptr), chptr->chname);
436
437 t = lbuf + cur_len;
438
8e69bb4e 439 RB_DLINK_FOREACH(ptr, chptr->members.head)
212380e3 440 {
441 msptr = ptr->data;
442 target_p = msptr->client_p;
443
444 if(IsInvisible(target_p) && !is_member)
445 continue;
446
447 /* space, possible "@+" prefix */
448 if(cur_len + strlen(target_p->name) + 3 >= BUFSIZE - 3)
449 {
450 *(t - 1) = '\0';
451 sendto_one(client_p, "%s", lbuf);
452 cur_len = mlen;
453 t = lbuf + mlen;
454 }
455
38e6acdd 456 tlen = rb_sprintf(t, "%s%s ", find_channel_status(msptr, stack),
212380e3 457 target_p->name);
458
459 cur_len += tlen;
460 t += tlen;
461 }
462
463 /* The old behaviour here was to always output our buffer,
464 * even if there are no clients we can show. This happens
465 * when a client does "NAMES" with no parameters, and all
466 * the clients on a -sp channel are +i. I dont see a good
467 * reason for keeping that behaviour, as it just wastes
468 * bandwidth. --anfl
469 */
470 if(cur_len != mlen)
471 {
472 *(t - 1) = '\0';
473 sendto_one(client_p, "%s", lbuf);
474 }
475 }
476
477 if(show_eon)
478 sendto_one(client_p, form_str(RPL_ENDOFNAMES),
479 me.name, client_p->name, chptr->chname);
480}
481
482/* del_invite()
483 *
484 * input - channel to remove invite from, client to remove
485 * output -
486 * side effects - user is removed from invite list, if exists
487 */
488void
489del_invite(struct Channel *chptr, struct Client *who)
490{
af81d5a0
WP
491 rb_dlinkFindDestroy(who, &chptr->invites);
492 rb_dlinkFindDestroy(chptr, &who->user->invited);
212380e3 493}
494
495/* is_banned()
496 *
497 * input - channel to check bans for, user to check bans against
498 * optional prebuilt buffers
499 * output - 1 if banned, else 0
500 * side effects -
501 */
502int
503is_banned(struct Channel *chptr, struct Client *who, struct membership *msptr,
504 const char *s, const char *s2)
505{
506 char src_host[NICKLEN + USERLEN + HOSTLEN + 6];
507 char src_iphost[NICKLEN + USERLEN + HOSTLEN + 6];
508 char src_althost[NICKLEN + USERLEN + HOSTLEN + 6];
509 char *s3 = NULL;
af81d5a0 510 rb_dlink_node *ptr;
212380e3 511 struct Ban *actualBan = NULL;
512 struct Ban *actualExcept = NULL;
513
514 if(!MyClient(who))
515 return 0;
516
517 /* if the buffers havent been built, do it here */
518 if(s == NULL)
519 {
38e6acdd
WP
520 rb_sprintf(src_host, "%s!%s@%s", who->name, who->username, who->host);
521 rb_sprintf(src_iphost, "%s!%s@%s", who->name, who->username, who->sockhost);
212380e3 522
523 s = src_host;
524 s2 = src_iphost;
525 }
526 if(who->localClient->mangledhost != NULL)
527 {
528 /* if host mangling mode enabled, also check their real host */
529 if(!strcmp(who->host, who->localClient->mangledhost))
530 {
38e6acdd 531 rb_sprintf(src_althost, "%s!%s@%s", who->name, who->username, who->orighost);
212380e3 532 s3 = src_althost;
533 }
534 /* if host mangling mode not enabled and no other spoof,
535 * also check the mangled form of their host */
536 else if (!IsDynSpoof(who))
537 {
38e6acdd 538 rb_sprintf(src_althost, "%s!%s@%s", who->name, who->username, who->localClient->mangledhost);
212380e3 539 s3 = src_althost;
540 }
541 }
542
8e69bb4e 543 RB_DLINK_FOREACH(ptr, chptr->banlist.head)
212380e3 544 {
545 actualBan = ptr->data;
546 if(match(actualBan->banstr, s) ||
547 match(actualBan->banstr, s2) ||
548 match_cidr(actualBan->banstr, s2) ||
549 match_extban(actualBan->banstr, who, chptr, CHFL_BAN) ||
550 (s3 != NULL && match(actualBan->banstr, s3)))
551 break;
552 else
553 actualBan = NULL;
554 }
555
556 if((actualBan != NULL) && ConfigChannel.use_except)
557 {
8e69bb4e 558 RB_DLINK_FOREACH(ptr, chptr->exceptlist.head)
212380e3 559 {
560 actualExcept = ptr->data;
561
562 /* theyre exempted.. */
563 if(match(actualExcept->banstr, s) ||
564 match(actualExcept->banstr, s2) ||
565 match_cidr(actualExcept->banstr, s2) ||
566 match_extban(actualExcept->banstr, who, chptr, CHFL_EXCEPTION) ||
567 (s3 != NULL && match(actualExcept->banstr, s3)))
568 {
569 /* cache the fact theyre not banned */
570 if(msptr != NULL)
571 {
572 msptr->bants = chptr->bants;
573 msptr->flags &= ~CHFL_BANNED;
574 }
575
576 return CHFL_EXCEPTION;
577 }
578 }
579 }
580
581 /* cache the banned/not banned status */
582 if(msptr != NULL)
583 {
584 msptr->bants = chptr->bants;
585
586 if(actualBan != NULL)
587 {
588 msptr->flags |= CHFL_BANNED;
589 return CHFL_BAN;
590 }
591 else
592 {
593 msptr->flags &= ~CHFL_BANNED;
594 return 0;
595 }
596 }
597
598 return ((actualBan ? CHFL_BAN : 0));
599}
600
601/* is_quieted()
602 *
603 * input - channel to check bans for, user to check bans against
604 * optional prebuilt buffers
605 * output - 1 if banned, else 0
606 * side effects -
607 */
608int
609is_quieted(struct Channel *chptr, struct Client *who, struct membership *msptr,
610 const char *s, const char *s2)
611{
612 char src_host[NICKLEN + USERLEN + HOSTLEN + 6];
613 char src_iphost[NICKLEN + USERLEN + HOSTLEN + 6];
614 char src_althost[NICKLEN + USERLEN + HOSTLEN + 6];
615 char *s3 = NULL;
af81d5a0 616 rb_dlink_node *ptr;
212380e3 617 struct Ban *actualBan = NULL;
618 struct Ban *actualExcept = NULL;
619
620 if(!MyClient(who))
621 return 0;
622
623 /* if the buffers havent been built, do it here */
624 if(s == NULL)
625 {
38e6acdd
WP
626 rb_sprintf(src_host, "%s!%s@%s", who->name, who->username, who->host);
627 rb_sprintf(src_iphost, "%s!%s@%s", who->name, who->username, who->sockhost);
212380e3 628
629 s = src_host;
630 s2 = src_iphost;
631 }
632 if(who->localClient->mangledhost != NULL)
633 {
634 /* if host mangling mode enabled, also check their real host */
635 if(!strcmp(who->host, who->localClient->mangledhost))
636 {
38e6acdd 637 rb_sprintf(src_althost, "%s!%s@%s", who->name, who->username, who->orighost);
212380e3 638 s3 = src_althost;
639 }
640 /* if host mangling mode not enabled and no other spoof,
641 * also check the mangled form of their host */
642 else if (!IsDynSpoof(who))
643 {
38e6acdd 644 rb_sprintf(src_althost, "%s!%s@%s", who->name, who->username, who->localClient->mangledhost);
212380e3 645 s3 = src_althost;
646 }
647 }
648
8e69bb4e 649 RB_DLINK_FOREACH(ptr, chptr->quietlist.head)
212380e3 650 {
651 actualBan = ptr->data;
652 if(match(actualBan->banstr, s) ||
653 match(actualBan->banstr, s2) ||
654 match_cidr(actualBan->banstr, s2) ||
655 match_extban(actualBan->banstr, who, chptr, CHFL_QUIET) ||
656 (s3 != NULL && match(actualBan->banstr, s3)))
657 break;
658 else
659 actualBan = NULL;
660 }
661
662 if((actualBan != NULL) && ConfigChannel.use_except)
663 {
8e69bb4e 664 RB_DLINK_FOREACH(ptr, chptr->exceptlist.head)
212380e3 665 {
666 actualExcept = ptr->data;
667
668 /* theyre exempted.. */
669 if(match(actualExcept->banstr, s) ||
670 match(actualExcept->banstr, s2) ||
671 match_cidr(actualExcept->banstr, s2) ||
672 match_extban(actualExcept->banstr, who, chptr, CHFL_EXCEPTION) ||
673 (s3 != NULL && match(actualExcept->banstr, s3)))
674 {
675 /* cache the fact theyre not banned */
676 if(msptr != NULL)
677 {
678 msptr->bants = chptr->bants;
679 msptr->flags &= ~CHFL_BANNED;
680 }
681
682 return CHFL_EXCEPTION;
683 }
684 }
685 }
686
687 /* cache the banned/not banned status */
688 if(msptr != NULL)
689 {
690 msptr->bants = chptr->bants;
691
692 if(actualBan != NULL)
693 {
694 msptr->flags |= CHFL_BANNED;
695 return CHFL_BAN;
696 }
697 else
698 {
699 msptr->flags &= ~CHFL_BANNED;
700 return 0;
701 }
702 }
703
704 return ((actualBan ? CHFL_BAN : 0));
705}
706
707/* can_join()
708 *
709 * input - client to check, channel to check for, key
710 * output - reason for not being able to join, else 0
711 * side effects -
712 */
713int
714can_join(struct Client *source_p, struct Channel *chptr, char *key)
715{
af81d5a0
WP
716 rb_dlink_node *invite = NULL;
717 rb_dlink_node *ptr;
212380e3 718 struct Ban *invex = NULL;
719 char src_host[NICKLEN + USERLEN + HOSTLEN + 6];
720 char src_iphost[NICKLEN + USERLEN + HOSTLEN + 6];
721 char src_althost[NICKLEN + USERLEN + HOSTLEN + 6];
722 int use_althost = 0;
1ebf4db4 723 int i = 0;
212380e3 724 hook_data_channel moduledata;
725
726 s_assert(source_p->localClient != NULL);
727
38e6acdd
WP
728 rb_sprintf(src_host, "%s!%s@%s", source_p->name, source_p->username, source_p->host);
729 rb_sprintf(src_iphost, "%s!%s@%s", source_p->name, source_p->username, source_p->sockhost);
212380e3 730 if(source_p->localClient->mangledhost != NULL)
731 {
732 /* if host mangling mode enabled, also check their real host */
733 if(!strcmp(source_p->host, source_p->localClient->mangledhost))
734 {
38e6acdd 735 rb_sprintf(src_althost, "%s!%s@%s", source_p->name, source_p->username, source_p->orighost);
212380e3 736 use_althost = 1;
737 }
738 /* if host mangling mode not enabled and no other spoof,
739 * also check the mangled form of their host */
740 else if (!IsDynSpoof(source_p))
741 {
38e6acdd 742 rb_sprintf(src_althost, "%s!%s@%s", source_p->name, source_p->username, source_p->localClient->mangledhost);
212380e3 743 use_althost = 1;
744 }
745 }
746
747 if((is_banned(chptr, source_p, NULL, src_host, src_iphost)) == CHFL_BAN)
748 return (ERR_BANNEDFROMCHAN);
749
750 if(chptr->mode.mode & MODE_INVITEONLY)
751 {
8e69bb4e 752 RB_DLINK_FOREACH(invite, source_p->user->invited.head)
212380e3 753 {
1ebf4db4 754 if(invite->data == chptr)
212380e3 755 break;
756 }
1ebf4db4 757 if(invite == NULL)
212380e3 758 {
759 if(!ConfigChannel.use_invex)
760 return (ERR_INVITEONLYCHAN);
8e69bb4e 761 RB_DLINK_FOREACH(ptr, chptr->invexlist.head)
212380e3 762 {
763 invex = ptr->data;
764 if(match(invex->banstr, src_host)
765 || match(invex->banstr, src_iphost)
766 || match_cidr(invex->banstr, src_iphost)
767 || match_extban(invex->banstr, source_p, chptr, CHFL_INVEX)
768 || (use_althost && match(invex->banstr, src_althost)))
769 break;
770 }
771 if(ptr == NULL)
772 return (ERR_INVITEONLYCHAN);
773 }
774 }
775
776 if(*chptr->mode.key && (EmptyString(key) || irccmp(chptr->mode.key, key)))
777 return (ERR_BADCHANNELKEY);
778
779 if(chptr->mode.limit &&
af81d5a0 780 rb_dlink_list_length(&chptr->members) >= (unsigned long) chptr->mode.limit)
1ebf4db4 781 i = ERR_CHANNELISFULL;
212380e3 782 if(chptr->mode.mode & MODE_REGONLY && EmptyString(source_p->user->suser))
1ebf4db4 783 i = ERR_NEEDREGGEDNICK;
212380e3 784 /* join throttling stuff --nenolod */
1ebf4db4 785 else if(chptr->mode.join_num > 0 && chptr->mode.join_time > 0)
212380e3 786 {
9f6bbe3c 787 if ((rb_current_time() - chptr->join_delta <=
212380e3 788 chptr->mode.join_time) && (chptr->join_count >=
789 chptr->mode.join_num))
1ebf4db4 790 i = ERR_THROTTLE;
791 }
792
793 /* allow /invite to override +l/+r/+j also -- jilles */
794 if (i != 0 && invite == NULL)
795 {
8e69bb4e 796 RB_DLINK_FOREACH(invite, source_p->user->invited.head)
1ebf4db4 797 {
798 if(invite->data == chptr)
799 break;
800 }
801 if (invite == NULL)
802 return i;
212380e3 803 }
804
805 moduledata.client = source_p;
806 moduledata.chptr = chptr;
807 moduledata.approved = 0;
808
809 call_hook(h_can_join, &moduledata);
810
811 return moduledata.approved;
812}
813
814/* can_send()
815 *
816 * input - user to check in channel, membership pointer
817 * output - whether can explicitly send or not, else CAN_SEND_NONOP
818 * side effects -
819 */
820int
821can_send(struct Channel *chptr, struct Client *source_p, struct membership *msptr)
822{
823 if(IsServer(source_p) || IsService(source_p))
824 return CAN_SEND_OPV;
825
826 if(MyClient(source_p) && hash_find_resv(chptr->chname) &&
827 !IsOper(source_p) && !IsExemptResv(source_p))
828 return CAN_SEND_NO;
829
830 if(msptr == NULL)
831 {
832 msptr = find_channel_membership(chptr, source_p);
833
834 if(msptr == NULL)
835 {
836 /* if its +m or +n and theyre not in the channel,
837 * they cant send. we dont check bans here because
838 * theres no possibility of caching them --fl
839 */
840 if(chptr->mode.mode & MODE_NOPRIVMSGS || chptr->mode.mode & MODE_MODERATED)
841 return CAN_SEND_NO;
842 else
843 return CAN_SEND_NONOP;
844 }
845 }
846
847 if(is_chanop_voiced(msptr))
848 return CAN_SEND_OPV;
849
850 if(chptr->mode.mode & MODE_MODERATED)
851 return CAN_SEND_NO;
852
853 if(MyClient(source_p))
854 {
855 /* cached can_send */
856 if(msptr->bants == chptr->bants)
857 {
858 if(can_send_banned(msptr))
859 return CAN_SEND_NO;
860 }
861 else if(is_banned(chptr, source_p, msptr, NULL, NULL) == CHFL_BAN
862 || is_quieted(chptr, source_p, msptr, NULL, NULL) == CHFL_BAN)
863 return CAN_SEND_NO;
864 }
865
866 return CAN_SEND_NONOP;
867}
868
869/* find_bannickchange_channel()
870 * Input: client to check
871 * Output: channel preventing nick change
872 */
873struct Channel *
874find_bannickchange_channel(struct Client *client_p)
875{
876 struct Channel *chptr;
877 struct membership *msptr;
af81d5a0 878 rb_dlink_node *ptr;
212380e3 879 char src_host[NICKLEN + USERLEN + HOSTLEN + 6];
880 char src_iphost[NICKLEN + USERLEN + HOSTLEN + 6];
881
882 if (!MyClient(client_p))
883 return NULL;
884
38e6acdd
WP
885 rb_sprintf(src_host, "%s!%s@%s", client_p->name, client_p->username, client_p->host);
886 rb_sprintf(src_iphost, "%s!%s@%s", client_p->name, client_p->username, client_p->sockhost);
212380e3 887
8e69bb4e 888 RB_DLINK_FOREACH(ptr, client_p->user->channel.head)
212380e3 889 {
890 msptr = ptr->data;
891 chptr = msptr->chptr;
892 if (is_chanop_voiced(msptr))
893 continue;
894 /* cached can_send */
895 if (msptr->bants == chptr->bants)
896 {
897 if (can_send_banned(msptr))
898 return chptr;
899 }
900 else if (is_banned(chptr, client_p, msptr, src_host, src_iphost) == CHFL_BAN
901 || is_quieted(chptr, client_p, msptr, src_host, src_iphost) == CHFL_BAN)
902 return chptr;
903 }
904 return NULL;
905}
906
907/* void check_spambot_warning(struct Client *source_p)
908 * Input: Client to check, channel name or NULL if this is a part.
909 * Output: none
910 * Side-effects: Updates the client's oper_warn_count_down, warns the
911 * IRC operators if necessary, and updates join_leave_countdown as
912 * needed.
913 */
914void
915check_spambot_warning(struct Client *source_p, const char *name)
916{
917 int t_delta;
918 int decrement_count;
919 if((GlobalSetOptions.spam_num &&
920 (source_p->localClient->join_leave_count >= GlobalSetOptions.spam_num)))
921 {
922 if(source_p->localClient->oper_warn_count_down > 0)
923 source_p->localClient->oper_warn_count_down--;
924 else
925 source_p->localClient->oper_warn_count_down = 0;
05d8a68c
JT
926 if(source_p->localClient->oper_warn_count_down == 0 &&
927 name != NULL)
212380e3 928 {
929 /* Its already known as a possible spambot */
05d8a68c
JT
930 sendto_realops_snomask(SNO_BOTS, L_NETWIDE,
931 "User %s (%s@%s) trying to join %s is a possible spambot",
932 source_p->name,
933 source_p->username, source_p->orighost, name);
212380e3 934 source_p->localClient->oper_warn_count_down = OPER_SPAM_COUNTDOWN;
935 }
936 }
937 else
938 {
939 if((t_delta =
9f6bbe3c 940 (rb_current_time() - source_p->localClient->last_leave_time)) >
212380e3 941 JOIN_LEAVE_COUNT_EXPIRE_TIME)
942 {
943 decrement_count = (t_delta / JOIN_LEAVE_COUNT_EXPIRE_TIME);
b6698246
JT
944 if(name != NULL)
945 ;
946 else if(decrement_count > source_p->localClient->join_leave_count)
212380e3 947 source_p->localClient->join_leave_count = 0;
948 else
949 source_p->localClient->join_leave_count -= decrement_count;
950 }
951 else
952 {
9f6bbe3c 953 if((rb_current_time() -
212380e3 954 (source_p->localClient->last_join_time)) < GlobalSetOptions.spam_time)
955 {
956 /* oh, its a possible spambot */
957 source_p->localClient->join_leave_count++;
958 }
959 }
960 if(name != NULL)
9f6bbe3c 961 source_p->localClient->last_join_time = rb_current_time();
212380e3 962 else
9f6bbe3c 963 source_p->localClient->last_leave_time = rb_current_time();
212380e3 964 }
965}
966
967/* check_splitmode()
968 *
969 * input -
970 * output -
971 * side effects - compares usercount and servercount against their split
972 * values and adjusts splitmode accordingly
973 */
974void
975check_splitmode(void *unused)
976{
977 if(splitchecking && (ConfigChannel.no_join_on_split || ConfigChannel.no_create_on_split))
978 {
979 /* not split, we're being asked to check now because someone
980 * has left
981 */
982 if(!splitmode)
983 {
984 if(eob_count < split_servers || Count.total < split_users)
985 {
986 splitmode = 1;
987 sendto_realops_snomask(SNO_GENERAL, L_ALL,
988 "Network split, activating splitmode");
dd9be678 989 check_splitmode_ev = rb_event_addish("check_splitmode", check_splitmode, NULL, 2);
212380e3 990 }
991 }
992 /* in splitmode, check whether its finished */
993 else if(eob_count >= split_servers && Count.total >= split_users)
994 {
995 splitmode = 0;
996
997 sendto_realops_snomask(SNO_GENERAL, L_ALL,
998 "Network rejoined, deactivating splitmode");
999
dd9be678 1000 rb_event_delete(check_splitmode_ev);
0ae330b4 1001 check_splitmode_ev = NULL;
212380e3 1002 }
1003 }
1004}
1005
1006
1007/* allocate_topic()
1008 *
1009 * input - channel to allocate topic for
1010 * output - 1 on success, else 0
1011 * side effects - channel gets a topic allocated
1012 */
1013static void
1014allocate_topic(struct Channel *chptr)
1015{
1016 void *ptr;
1017
1018 if(chptr == NULL)
1019 return;
1020
6e9b4415 1021 ptr = rb_bh_alloc(topic_heap);
212380e3 1022
1023 /* Basically we allocate one large block for the topic and
1024 * the topic info. We then split it up into two and shove it
1025 * in the chptr
1026 */
1027 chptr->topic = ptr;
1028 chptr->topic_info = (char *) ptr + TOPICLEN + 1;
1029 *chptr->topic = '\0';
1030 *chptr->topic_info = '\0';
1031}
1032
1033/* free_topic()
1034 *
1035 * input - channel which has topic to free
1036 * output -
1037 * side effects - channels topic is free'd
1038 */
1039static void
1040free_topic(struct Channel *chptr)
1041{
1042 void *ptr;
1043
1044 if(chptr == NULL || chptr->topic == NULL)
1045 return;
1046
1047 /* This is safe for now - If you change allocate_topic you
1048 * MUST change this as well
1049 */
1050 ptr = chptr->topic;
6e9b4415 1051 rb_bh_free(topic_heap, ptr);
212380e3 1052 chptr->topic = NULL;
1053 chptr->topic_info = NULL;
1054}
1055
1056/* set_channel_topic()
1057 *
1058 * input - channel, topic to set, topic info and topic ts
1059 * output -
1060 * side effects - channels topic, topic info and TS are set.
1061 */
1062void
1063set_channel_topic(struct Channel *chptr, const char *topic, const char *topic_info, time_t topicts)
1064{
1065 if(strlen(topic) > 0)
1066 {
1067 if(chptr->topic == NULL)
1068 allocate_topic(chptr);
907468c4
VY
1069 rb_strlcpy(chptr->topic, topic, TOPICLEN + 1);
1070 rb_strlcpy(chptr->topic_info, topic_info, USERHOST_REPLYLEN);
212380e3 1071 chptr->topic_time = topicts;
1072 }
1073 else
1074 {
1075 if(chptr->topic != NULL)
1076 free_topic(chptr);
1077 chptr->topic_time = 0;
1078 }
1079}
1080
212380e3 1081/* channel_modes()
1082 *
1083 * inputs - pointer to channel
1084 * - pointer to client
f1e35c19 1085 * output - string with simple modes
1086 * side effects - result from previous calls overwritten
212380e3 1087 *
1088 * Stolen from ShadowIRCd 4 --nenolod
1089 */
1090const char *
1091channel_modes(struct Channel *chptr, struct Client *client_p)
1092{
1093 int i;
1094 char buf1[BUFSIZE];
1095 char buf2[BUFSIZE];
1096 static char final[BUFSIZE];
1097 char *mbuf = buf1;
1098 char *pbuf = buf2;
1099
1100 *mbuf++ = '+';
1101 *pbuf = '\0';
1102
75818939
VY
1103 for (i = 0; i < 256; i++)
1104 if(chptr->mode.mode & chmode_flags[i])
1105 *mbuf++ = i;
212380e3 1106
1107 if(chptr->mode.limit)
1108 {
1109 *mbuf++ = 'l';
1110
f1e35c19 1111 if(!IsClient(client_p) || IsMember(client_p, chptr))
38e6acdd 1112 pbuf += rb_sprintf(pbuf, " %d", chptr->mode.limit);
212380e3 1113 }
1114
1115 if(*chptr->mode.key)
1116 {
1117 *mbuf++ = 'k';
1118
f1e35c19 1119 if(pbuf > buf2 || !IsClient(client_p) || IsMember(client_p, chptr))
38e6acdd 1120 pbuf += rb_sprintf(pbuf, " %s", chptr->mode.key);
212380e3 1121 }
1122
1123 if(chptr->mode.join_num)
1124 {
1125 *mbuf++ = 'j';
1126
f1e35c19 1127 if(pbuf > buf2 || !IsClient(client_p) || IsMember(client_p, chptr))
38e6acdd 1128 pbuf += rb_sprintf(pbuf, " %d:%d", chptr->mode.join_num,
212380e3 1129 chptr->mode.join_time);
1130 }
1131
f1e35c19 1132 if(*chptr->mode.forward && (ConfigChannel.use_forward || !IsClient(client_p)))
212380e3 1133 {
1134 *mbuf++ = 'f';
1135
f1e35c19 1136 if(pbuf > buf2 || !IsClient(client_p) || IsMember(client_p, chptr))
38e6acdd 1137 pbuf += rb_sprintf(pbuf, " %s", chptr->mode.forward);
212380e3 1138 }
1139
1140 *mbuf = '\0';
1141
907468c4 1142 rb_strlcpy(final, buf1, sizeof final);
a64c5173 1143 rb_strlcat(final, buf2, sizeof final);
212380e3 1144 return final;
1145}
1146
1147/* Now lets do some stuff to keep track of what combinations of
1148 * servers exist...
1149 * Note that the number of combinations doubles each time you add
1150 * something to this list. Each one is only quick if no servers use that
1151 * combination, but if the numbers get too high here MODE will get too
1152 * slow. I suggest if you get more than 7 here, you consider getting rid
1153 * of some and merging or something. If it wasn't for irc+cs we would
1154 * probably not even need to bother about most of these, but unfortunately
1155 * we do. -A1kmm
1156 */
1157
1158/* void init_chcap_usage_counts(void)
1159 *
1160 * Inputs - none
1161 * Output - none
1162 * Side-effects - Initialises the usage counts to zero. Fills in the
1163 * chcap_yes and chcap_no combination tables.
1164 */
1165void
1166init_chcap_usage_counts(void)
1167{
1168 unsigned long m, c, y, n;
1169
1170 memset(chcap_combos, 0, sizeof(chcap_combos));
1171
1172 /* For every possible combination */
1173 for (m = 0; m < NCHCAP_COMBOS; m++)
1174 {
1175 /* Check each capab */
1176 for (c = y = n = 0; c < NCHCAPS; c++)
1177 {
1178 if((m & (1 << c)) == 0)
1179 n |= channel_capabs[c];
1180 else
1181 y |= channel_capabs[c];
1182 }
1183 chcap_combos[m].cap_yes = y;
1184 chcap_combos[m].cap_no = n;
1185 }
1186}
1187
1188/* void set_chcap_usage_counts(struct Client *serv_p)
1189 * Input: serv_p; The client whose capabs to register.
1190 * Output: none
1191 * Side-effects: Increments the usage counts for the correct capab
1192 * combination.
1193 */
1194void
1195set_chcap_usage_counts(struct Client *serv_p)
1196{
1197 int n;
1198
1199 for (n = 0; n < NCHCAP_COMBOS; n++)
1200 {
1201 if(IsCapable(serv_p, chcap_combos[n].cap_yes) &&
1202 NotCapable(serv_p, chcap_combos[n].cap_no))
1203 {
1204 chcap_combos[n].count++;
1205 return;
1206 }
1207 }
1208
1209 /* This should be impossible -A1kmm. */
1210 s_assert(0);
1211}
1212
1213/* void set_chcap_usage_counts(struct Client *serv_p)
1214 *
1215 * Inputs - serv_p; The client whose capabs to register.
1216 * Output - none
1217 * Side-effects - Decrements the usage counts for the correct capab
1218 * combination.
1219 */
1220void
1221unset_chcap_usage_counts(struct Client *serv_p)
1222{
1223 int n;
1224
1225 for (n = 0; n < NCHCAP_COMBOS; n++)
1226 {
1227 if(IsCapable(serv_p, chcap_combos[n].cap_yes) &&
1228 NotCapable(serv_p, chcap_combos[n].cap_no))
1229 {
1230 /* Hopefully capabs can't change dynamically or anything... */
1231 s_assert(chcap_combos[n].count > 0);
1232
1233 if(chcap_combos[n].count > 0)
1234 chcap_combos[n].count--;
1235 return;
1236 }
1237 }
1238
1239 /* This should be impossible -A1kmm. */
1240 s_assert(0);
1241}
1242
1243/* void send_cap_mode_changes(struct Client *client_p,
1244 * struct Client *source_p,
1245 * struct Channel *chptr, int cap, int nocap)
1246 * Input: The client sending(client_p), the source client(source_p),
1247 * the channel to send mode changes for(chptr)
1248 * Output: None.
1249 * Side-effects: Sends the appropriate mode changes to capable servers.
1250 *
1251 * Reverted back to my original design, except that we now keep a count
1252 * of the number of servers which each combination as an optimisation, so
1253 * the capabs combinations which are not needed are not worked out. -A1kmm
1254 */
1255void
1256send_cap_mode_changes(struct Client *client_p, struct Client *source_p,
1257 struct Channel *chptr, struct ChModeChange mode_changes[], int mode_count)
1258{
1259 static char modebuf[BUFSIZE];
1260 static char parabuf[BUFSIZE];
1261 int i, mbl, pbl, nc, mc, preflen, len;
1262 char *pbuf;
1263 const char *arg;
1264 int dir;
1265 int j;
1266 int cap;
1267 int nocap;
1268 int arglen;
1269
1270 /* Now send to servers... */
1271 for (j = 0; j < NCHCAP_COMBOS; j++)
1272 {
1273 if(chcap_combos[j].count == 0)
1274 continue;
1275
1276 mc = 0;
1277 nc = 0;
1278 pbl = 0;
1279 parabuf[0] = 0;
1280 pbuf = parabuf;
1281 dir = MODE_QUERY;
1282
1283 cap = chcap_combos[j].cap_yes;
1284 nocap = chcap_combos[j].cap_no;
1285
9f9b4d7b
WP
1286 mbl = preflen = rb_sprintf(modebuf, ":%s TMODE %ld %s ",
1287 use_id(source_p), (long) chptr->channelts,
1288 chptr->chname);
212380e3 1289
1290 /* loop the list of - modes we have */
1291 for (i = 0; i < mode_count; i++)
1292 {
1293 /* if they dont support the cap we need, or they do support a cap they
1294 * cant have, then dont add it to the modebuf.. that way they wont see
1295 * the mode
1296 */
1297 if((mode_changes[i].letter == 0) ||
1298 ((cap & mode_changes[i].caps) != mode_changes[i].caps)
1299 || ((nocap & mode_changes[i].nocaps) != mode_changes[i].nocaps))
1300 continue;
1301
7592f950
JT
1302 if(!EmptyString(mode_changes[i].id))
1303 arg = mode_changes[i].id;
1304 else
1305 arg = mode_changes[i].arg;
212380e3 1306
1307 if(arg)
1308 {
1309 arglen = strlen(arg);
1310
1311 /* dont even think about it! --fl */
1312 if(arglen > MODEBUFLEN - 5)
1313 continue;
1314 }
1315
1316 /* if we're creeping past the buf size, we need to send it and make
1317 * another line for the other modes
1318 * XXX - this could give away server topology with uids being
1319 * different lengths, but not much we can do, except possibly break
1320 * them as if they were the longest of the nick or uid at all times,
1321 * which even then won't work as we don't always know the uid -A1kmm.
1322 */
1323 if(arg && ((mc == MAXMODEPARAMSSERV) ||
1324 ((mbl + pbl + arglen + 4) > (BUFSIZE - 3))))
1325 {
1326 if(nc != 0)
1327 sendto_server(client_p, chptr, cap, nocap,
1328 "%s %s", modebuf, parabuf);
1329 nc = 0;
1330 mc = 0;
1331
1332 mbl = preflen;
1333 pbl = 0;
1334 pbuf = parabuf;
1335 parabuf[0] = 0;
1336 dir = MODE_QUERY;
1337 }
1338
1339 if(dir != mode_changes[i].dir)
1340 {
1341 modebuf[mbl++] = (mode_changes[i].dir == MODE_ADD) ? '+' : '-';
1342 dir = mode_changes[i].dir;
1343 }
1344
1345 modebuf[mbl++] = mode_changes[i].letter;
1346 modebuf[mbl] = 0;
1347 nc++;
1348
1349 if(arg != NULL)
1350 {
38e6acdd 1351 len = rb_sprintf(pbuf, "%s ", arg);
212380e3 1352 pbuf += len;
1353 pbl += len;
1354 mc++;
1355 }
1356 }
1357
1358 if(pbl && parabuf[pbl - 1] == ' ')
1359 parabuf[pbl - 1] = 0;
1360
1361 if(nc != 0)
1362 sendto_server(client_p, chptr, cap, nocap, "%s %s", modebuf, parabuf);
1363 }
1364}
080bb5cf
JH
1365
1366/* Check what we will forward to, without sending any notices to the user
1367 * -- jilles
1368 */
1369struct Channel *
1370check_forward(struct Client *source_p, struct Channel *chptr,
1371 char *key)
1372{
1373 int depth = 0, i;
1374
1375 /* User is +Q */
1376 if (IsNoForward(source_p))
1377 return NULL;
1378
1379 while (depth < 16)
1380 {
1381 chptr = find_channel(chptr->mode.forward);
1382 /* Can only forward to existing channels */
1383 if (chptr == NULL)
1384 return NULL;
1385 /* Already on there, show original error message */
1386 if (IsMember(source_p, chptr))
1387 return NULL;
1388 /* Juped. Sending a warning notice would be unfair */
1389 if (hash_find_resv(chptr->chname))
1390 return NULL;
1391 /* Don't forward to +Q channel */
1392 if (chptr->mode.mode & MODE_DISFORWARD)
1393 return NULL;
1394 i = can_join(source_p, chptr, key);
1395 if (i == 0)
1396 return chptr;
1397 if (i != ERR_INVITEONLYCHAN && i != ERR_NEEDREGGEDNICK && i != ERR_THROTTLE && i != ERR_CHANNELISFULL)
1398 return NULL;
1399 depth++;
1400 }
1401
1402 return NULL;
1403}
67b90240 1404
9230426e
JH
1405/*
1406 * do_join_0
1407 *
1408 * inputs - pointer to client doing join 0
1409 * output - NONE
1410 * side effects - Use has decided to join 0. This is legacy
1411 * from the days when channels were numbers not names. *sigh*
1412 * There is a bunch of evilness necessary here due to
1413 * anti spambot code.
1414 */
1415void
1416do_join_0(struct Client *client_p, struct Client *source_p)
1417{
1418 struct membership *msptr;
1419 struct Channel *chptr = NULL;
1420 rb_dlink_node *ptr;
1421
1422 /* Finish the flood grace period... */
1423 if(MyClient(source_p) && !IsFloodDone(source_p))
1424 flood_endgrace(source_p);
1425
1426 sendto_server(client_p, NULL, CAP_TS6, NOCAPS, ":%s JOIN 0", use_id(source_p));
1427
1428 if(source_p->user->channel.head && MyConnect(source_p) &&
1429 !IsOper(source_p) && !IsExemptSpambot(source_p))
1430 check_spambot_warning(source_p, NULL);
1431
1432 while((ptr = source_p->user->channel.head))
1433 {
1434 msptr = ptr->data;
1435 chptr = msptr->chptr;
1436 sendto_channel_local(ALL_MEMBERS, chptr, ":%s!%s@%s PART %s",
1437 source_p->name,
1438 source_p->username, source_p->host, chptr->chname);
1439 remove_user_from_channel(msptr);
1440 }
1441}
1442
1443int
1444check_channel_name_loc(struct Client *source_p, const char *name)
1445{
1446 s_assert(name != NULL);
1447 if(EmptyString(name))
1448 return 0;
1449
1450 if(ConfigFileEntry.disable_fake_channels && !IsOper(source_p))
1451 {
1452 for(; *name; ++name)
1453 {
1454 if(!IsChanChar(*name) || IsFakeChanChar(*name))
1455 return 0;
1456 }
1457 }
1458 else
1459 {
1460 for(; *name; ++name)
1461 {
1462 if(!IsChanChar(*name))
1463 return 0;
1464 }
1465 }
1466
1467 return 1;
1468}
1469
1470void user_join(struct Client * client_p, struct Client * source_p, char * channels, char * keys)
67b90240
JH
1471{
1472 static char jbuf[BUFSIZE];
1473 struct Channel *chptr = NULL;
1474 struct ConfItem *aconf;
1475 char *name;
1476 char *key = NULL;
1477 const char *modes;
1478 int i, flags = 0;
1479 char *p = NULL, *p2 = NULL;
1480 char *chanlist;
1481 char *mykey;
1482 int successful_join_count = 0; /* Number of channels successfully joined */
1483
1484 jbuf[0] = '\0';
1485
1486 if(channels == NULL)
1487 return;
1488
1489 /* rebuild the list of channels theyre supposed to be joining.
1490 * this code has a side effect of losing keys, but..
1491 */
1492 chanlist = LOCAL_COPY(channels);
1493 for(name = rb_strtok_r(chanlist, ",", &p); name; name = rb_strtok_r(NULL, ",", &p))
1494 {
1495 /* check the length and name of channel is ok */
1496 if(!check_channel_name_loc(source_p, name) || (strlen(name) > LOC_CHANNELLEN))
1497 {
1498 sendto_one_numeric(source_p, ERR_BADCHANNAME,
1499 form_str(ERR_BADCHANNAME), (unsigned char *) name);
1500 continue;
1501 }
1502
1503 /* join 0 parts all channels */
1504 if(*name == '0' && (name[1] == ',' || name[1] == '\0') && name == chanlist)
1505 {
1506 (void) strcpy(jbuf, "0");
1507 continue;
1508 }
1509
1510 /* check it begins with # or &, and local chans are disabled */
1511 else if(!IsChannelName(name))
1512 {
1513 sendto_one_numeric(source_p, ERR_NOSUCHCHANNEL,
1514 form_str(ERR_NOSUCHCHANNEL), name);
1515 continue;
1516 }
1517
1518 /* see if its resv'd */
1519 if(!IsExemptResv(source_p) && (aconf = hash_find_resv(name)))
1520 {
1521 sendto_one_numeric(source_p, ERR_BADCHANNAME,
1522 form_str(ERR_BADCHANNAME), name);
1523
1524 /* dont warn for opers */
1525 if(!IsExemptJupe(source_p) && !IsOper(source_p))
1526 sendto_realops_snomask(SNO_SPY, L_NETWIDE,
1527 "User %s (%s@%s) is attempting to join locally juped channel %s (%s)",
1528 source_p->name, source_p->username,
1529 source_p->orighost, name, aconf->passwd);
1530 /* dont update tracking for jupe exempt users, these
1531 * are likely to be spamtrap leaves
1532 */
1533 else if(IsExemptJupe(source_p))
1534 aconf->port--;
1535
1536 continue;
1537 }
1538
1539 if(splitmode && !IsOper(source_p) && (*name != '&') &&
1540 ConfigChannel.no_join_on_split)
1541 {
1542 sendto_one(source_p, form_str(ERR_UNAVAILRESOURCE),
1543 me.name, source_p->name, name);
1544 continue;
1545 }
1546
1547 if(*jbuf)
1548 (void) strcat(jbuf, ",");
1549 (void) rb_strlcat(jbuf, name, sizeof(jbuf));
1550 }
1551
1552 if(keys != NULL)
1553 {
1554 mykey = LOCAL_COPY(keys);
1555 key = rb_strtok_r(mykey, ",", &p2);
1556 }
1557
1558 for(name = rb_strtok_r(jbuf, ",", &p); name;
1559 key = (key) ? rb_strtok_r(NULL, ",", &p2) : NULL, name = rb_strtok_r(NULL, ",", &p))
1560 {
1561 hook_data_channel_activity hook_info;
1562
1563 /* JOIN 0 simply parts all channels the user is in */
1564 if(*name == '0' && !atoi(name))
1565 {
1566 if(source_p->user->channel.head == NULL)
1567 continue;
1568
1569 do_join_0(&me, source_p);
1570 continue;
1571 }
1572
1573 /* look for the channel */
1574 if((chptr = find_channel(name)) != NULL)
1575 {
1576 if(IsMember(source_p, chptr))
1577 continue;
1578
1579 flags = 0;
1580 }
1581 else
1582 {
1583 hook_data_client_approval moduledata;
1584
1585 moduledata.client = source_p;
1586 moduledata.approved = 0;
1587
1588 call_hook(h_can_create_channel, &moduledata);
1589
1590 if(moduledata.approved != 0)
1591 {
1592 sendto_one(source_p, form_str(moduledata.approved),
1593 me.name, source_p->name, name);
1594 continue;
1595 }
1596
1597 if(splitmode && !IsOper(source_p) && (*name != '&') &&
1598 ConfigChannel.no_create_on_split)
1599 {
1600 sendto_one(source_p, form_str(ERR_UNAVAILRESOURCE),
1601 me.name, source_p->name, name);
1602 continue;
1603 }
1604
1605 flags = CHFL_CHANOP;
1606 }
1607
1608 if((rb_dlink_list_length(&source_p->user->channel) >=
1609 (unsigned long) ConfigChannel.max_chans_per_user) &&
1610 (!IsOper(source_p) ||
1611 (rb_dlink_list_length(&source_p->user->channel) >=
1612 (unsigned long) ConfigChannel.max_chans_per_user * 3)))
1613 {
1614 sendto_one(source_p, form_str(ERR_TOOMANYCHANNELS),
1615 me.name, source_p->name, name);
1616 if(successful_join_count)
1617 source_p->localClient->last_join_time = rb_current_time();
1618 return;
1619 }
1620
1621 if(flags == 0) /* if channel doesn't exist, don't penalize */
1622 successful_join_count++;
1623
1624 if(chptr == NULL) /* If I already have a chptr, no point doing this */
1625 {
1626 chptr = get_or_create_channel(source_p, name, NULL);
1627
1628 if(chptr == NULL)
1629 {
1630 sendto_one(source_p, form_str(ERR_UNAVAILRESOURCE),
1631 me.name, source_p->name, name);
1632 if(successful_join_count > 0)
1633 successful_join_count--;
1634 continue;
1635 }
1636 }
1637
1638 if(!IsOper(source_p) && !IsExemptSpambot(source_p))
1639 check_spambot_warning(source_p, name);
1640
1641 /* can_join checks for +i key, bans etc */
1642 if((i = can_join(source_p, chptr, key)))
1643 {
1644 if ((i != ERR_NEEDREGGEDNICK && i != ERR_THROTTLE && i != ERR_INVITEONLYCHAN && i != ERR_CHANNELISFULL) ||
1645 (!ConfigChannel.use_forward || (chptr = check_forward(source_p, chptr, key)) == NULL))
1646 {
1647 /* might be wrong, but is there any other better location for such?
1648 * see extensions/chm_operonly.c for other comments on this
1649 * -- dwr
1650 */
1651 if(i != ERR_CUSTOM)
1652 sendto_one(source_p, form_str(i), me.name, source_p->name, name);
1653
1654 if(successful_join_count > 0)
1655 successful_join_count--;
1656 continue;
1657 }
1658
1659 sendto_one_numeric(source_p, ERR_LINKCHANNEL, form_str(ERR_LINKCHANNEL), name, chptr->chname);
1660 }
1661
1662 /* add the user to the channel */
1663 add_user_to_channel(chptr, source_p, flags);
1664 if (chptr->mode.join_num &&
1665 rb_current_time() - chptr->join_delta >= chptr->mode.join_time)
1666 {
1667 chptr->join_count = 0;
1668 chptr->join_delta = rb_current_time();
1669 }
1670 chptr->join_count++;
1671
1672 /* we send the user their join here, because we could have to
1673 * send a mode out next.
1674 */
1675 sendto_channel_local(ALL_MEMBERS, chptr, ":%s!%s@%s JOIN :%s",
1676 source_p->name,
1677 source_p->username, source_p->host, chptr->chname);
1678
1679 /* its a new channel, set +nt and burst. */
1680 if(flags & CHFL_CHANOP)
1681 {
1682 chptr->channelts = rb_current_time();
1683 chptr->mode.mode |= MODE_TOPICLIMIT;
1684 chptr->mode.mode |= MODE_NOPRIVMSGS;
1685 modes = channel_modes(chptr, &me);
1686
1687 sendto_channel_local(ONLY_CHANOPS, chptr, ":%s MODE %s %s",
1688 me.name, chptr->chname, modes);
1689
1690 sendto_server(client_p, chptr, CAP_TS6, NOCAPS,
1691 ":%s SJOIN %ld %s %s :@%s",
1692 me.id, (long) chptr->channelts,
1693 chptr->chname, modes, source_p->id);
1694 }
1695 else
1696 {
1697 sendto_server(client_p, chptr, CAP_TS6, NOCAPS,
1698 ":%s JOIN %ld %s +",
1699 use_id(source_p), (long) chptr->channelts,
1700 chptr->chname);
1701 }
1702
1703 del_invite(chptr, source_p);
1704
1705 if(chptr->topic != NULL)
1706 {
1707 sendto_one(source_p, form_str(RPL_TOPIC), me.name,
1708 source_p->name, chptr->chname, chptr->topic);
1709
1710 sendto_one(source_p, form_str(RPL_TOPICWHOTIME),
1711 me.name, source_p->name, chptr->chname,
1712 chptr->topic_info, chptr->topic_time);
1713 }
1714
1715 channel_member_names(chptr, source_p, 1);
1716
1717 if(successful_join_count)
1718 source_p->localClient->last_join_time = rb_current_time();
1719
1720 hook_info.client = source_p;
1721 hook_info.chptr = chptr;
1722 hook_info.key = key;
1723 call_hook(h_channel_join, &hook_info);
1724 }
1725
1726 return;
1727}