]> jfr.im git - irc/rqf/shadowircd.git/blob - src/s_newconf.c
Disable autoconnect for a server with excessive TS delta.
[irc/rqf/shadowircd.git] / src / s_newconf.c
1 /*
2 * ircd-ratbox: an advanced Internet Relay Chat Daemon(ircd).
3 * s_newconf.c - code for dealing with conf stuff
4 *
5 * Copyright (C) 2004 Lee Hardy <lee@leeh.co.uk>
6 * Copyright (C) 2004-2005 ircd-ratbox development team
7 *
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions are
10 * met:
11 *
12 * 1.Redistributions of source code must retain the above copyright notice,
13 * this list of conditions and the following disclaimer.
14 * 2.Redistributions in binary form must reproduce the above copyright
15 * notice, this list of conditions and the following disclaimer in the
16 * documentation and/or other materials provided with the distribution.
17 * 3.The name of the author may not be used to endorse or promote products
18 * derived from this software without specific prior written permission.
19 *
20 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
21 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
22 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
23 * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT,
24 * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
25 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
26 * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
28 * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
29 * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
30 * POSSIBILITY OF SUCH DAMAGE.
31 *
32 * $Id: s_newconf.c 3508 2007-06-04 16:04:49Z jilles $
33 */
34
35 #include "stdinc.h"
36 #include "ircd_defs.h"
37 #include "common.h"
38 #include "s_conf.h"
39 #include "s_newconf.h"
40 #include "client.h"
41 #include "s_serv.h"
42 #include "send.h"
43 #include "hostmask.h"
44 #include "newconf.h"
45 #include "hash.h"
46 #include "irc_dictionary.h"
47
48 rb_dlink_list shared_conf_list;
49 rb_dlink_list cluster_conf_list;
50 rb_dlink_list oper_conf_list;
51 rb_dlink_list hubleaf_conf_list;
52 rb_dlink_list server_conf_list;
53 rb_dlink_list xline_conf_list;
54 rb_dlink_list resv_conf_list; /* nicks only! */
55 rb_dlink_list nd_list; /* nick delay */
56 rb_dlink_list tgchange_list;
57
58 rb_patricia_tree_t *tgchange_tree;
59
60 static rb_bh *nd_heap = NULL;
61
62 static void expire_temp_rxlines(void *unused);
63 static void expire_nd_entries(void *unused);
64
65 struct ev_entry *expire_nd_entries_ev = NULL;
66 struct ev_entry *expire_temp_rxlines_ev = NULL;
67
68 void
69 init_s_newconf(void)
70 {
71 tgchange_tree = rb_new_patricia(PATRICIA_BITS);
72 nd_heap = rb_bh_create(sizeof(struct nd_entry), ND_HEAP_SIZE, "nd_heap");
73 expire_nd_entries_ev = rb_event_addish("expire_nd_entries", expire_nd_entries, NULL, 30);
74 expire_temp_rxlines_ev = rb_event_addish("expire_temp_rxlines", expire_temp_rxlines, NULL, 60);
75 }
76
77 void
78 clear_s_newconf(void)
79 {
80 struct server_conf *server_p;
81 rb_dlink_node *ptr;
82 rb_dlink_node *next_ptr;
83
84 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, shared_conf_list.head)
85 {
86 /* ptr here is ptr->data->node */
87 rb_dlinkDelete(ptr, &shared_conf_list);
88 free_remote_conf(ptr->data);
89 }
90
91 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, cluster_conf_list.head)
92 {
93 rb_dlinkDelete(ptr, &cluster_conf_list);
94 free_remote_conf(ptr->data);
95 }
96
97 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, hubleaf_conf_list.head)
98 {
99 rb_dlinkDelete(ptr, &hubleaf_conf_list);
100 free_remote_conf(ptr->data);
101 }
102
103 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, oper_conf_list.head)
104 {
105 free_oper_conf(ptr->data);
106 rb_dlinkDestroy(ptr, &oper_conf_list);
107 }
108
109 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, server_conf_list.head)
110 {
111 server_p = ptr->data;
112
113 if(!server_p->servers)
114 {
115 rb_dlinkDelete(ptr, &server_conf_list);
116 free_server_conf(ptr->data);
117 }
118 else
119 server_p->flags |= SERVER_ILLEGAL;
120 }
121 }
122
123 void
124 clear_s_newconf_bans(void)
125 {
126 struct ConfItem *aconf;
127 rb_dlink_node *ptr, *next_ptr;
128
129 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, xline_conf_list.head)
130 {
131 aconf = ptr->data;
132
133 if(aconf->hold)
134 continue;
135
136 free_conf(aconf);
137 rb_dlinkDestroy(ptr, &xline_conf_list);
138 }
139
140 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, resv_conf_list.head)
141 {
142 aconf = ptr->data;
143
144 /* temporary resv */
145 if(aconf->hold)
146 continue;
147
148 free_conf(aconf);
149 rb_dlinkDestroy(ptr, &resv_conf_list);
150 }
151
152 clear_resv_hash();
153 }
154
155 struct remote_conf *
156 make_remote_conf(void)
157 {
158 struct remote_conf *remote_p = rb_malloc(sizeof(struct remote_conf));
159 return remote_p;
160 }
161
162 void
163 free_remote_conf(struct remote_conf *remote_p)
164 {
165 s_assert(remote_p != NULL);
166 if(remote_p == NULL)
167 return;
168
169 rb_free(remote_p->username);
170 rb_free(remote_p->host);
171 rb_free(remote_p->server);
172 rb_free(remote_p);
173 }
174
175 int
176 find_shared_conf(const char *username, const char *host,
177 const char *server, int flags)
178 {
179 struct remote_conf *shared_p;
180 rb_dlink_node *ptr;
181
182 RB_DLINK_FOREACH(ptr, shared_conf_list.head)
183 {
184 shared_p = ptr->data;
185
186 if(match(shared_p->username, username) &&
187 match(shared_p->host, host) &&
188 match(shared_p->server, server))
189 {
190 if(shared_p->flags & flags)
191 return YES;
192 else
193 return NO;
194 }
195 }
196
197 return NO;
198 }
199
200 void
201 propagate_generic(struct Client *source_p, const char *command,
202 const char *target, int cap, const char *format, ...)
203 {
204 char buffer[BUFSIZE];
205 va_list args;
206
207 va_start(args, format);
208 rb_vsnprintf(buffer, sizeof(buffer), format, args);
209 va_end(args);
210
211 sendto_match_servs(source_p, target, cap, NOCAPS,
212 "%s %s %s",
213 command, target, buffer);
214 sendto_match_servs(source_p, target, CAP_ENCAP, cap,
215 "ENCAP %s %s %s",
216 target, command, buffer);
217 }
218
219 void
220 cluster_generic(struct Client *source_p, const char *command,
221 int cltype, int cap, const char *format, ...)
222 {
223 char buffer[BUFSIZE];
224 struct remote_conf *shared_p;
225 va_list args;
226 rb_dlink_node *ptr;
227
228 va_start(args, format);
229 rb_vsnprintf(buffer, sizeof(buffer), format, args);
230 va_end(args);
231
232 RB_DLINK_FOREACH(ptr, cluster_conf_list.head)
233 {
234 shared_p = ptr->data;
235
236 if(!(shared_p->flags & cltype))
237 continue;
238
239 sendto_match_servs(source_p, shared_p->server, cap, NOCAPS,
240 "%s %s %s",
241 command, shared_p->server, buffer);
242 sendto_match_servs(source_p, shared_p->server, CAP_ENCAP, cap,
243 "ENCAP %s %s %s",
244 shared_p->server, command, buffer);
245 }
246 }
247
248 struct oper_conf *
249 make_oper_conf(void)
250 {
251 struct oper_conf *oper_p = rb_malloc(sizeof(struct oper_conf));
252 return oper_p;
253 }
254
255 void
256 free_oper_conf(struct oper_conf *oper_p)
257 {
258 s_assert(oper_p != NULL);
259 if(oper_p == NULL)
260 return;
261
262 rb_free(oper_p->username);
263 rb_free(oper_p->host);
264 rb_free(oper_p->name);
265
266 if(oper_p->passwd)
267 {
268 memset(oper_p->passwd, 0, strlen(oper_p->passwd));
269 rb_free(oper_p->passwd);
270 }
271
272 #ifdef HAVE_LIBCRYPTO
273 rb_free(oper_p->rsa_pubkey_file);
274
275 if(oper_p->rsa_pubkey)
276 RSA_free(oper_p->rsa_pubkey);
277 #endif
278
279 rb_free(oper_p);
280 }
281
282 struct oper_conf *
283 find_oper_conf(const char *username, const char *host, const char *locip, const char *name)
284 {
285 struct oper_conf *oper_p;
286 struct rb_sockaddr_storage ip, cip;
287 char addr[HOSTLEN+1];
288 int bits, cbits;
289 rb_dlink_node *ptr;
290
291 parse_netmask(locip, (struct sockaddr *)&cip, &cbits);
292
293 RB_DLINK_FOREACH(ptr, oper_conf_list.head)
294 {
295 oper_p = ptr->data;
296
297 /* name/username doesnt match.. */
298 if(irccmp(oper_p->name, name) || !match(oper_p->username, username))
299 continue;
300
301 rb_strlcpy(addr, oper_p->host, sizeof(addr));
302
303 if(parse_netmask(addr, (struct sockaddr *)&ip, &bits) != HM_HOST)
304 {
305 if(ip.ss_family == cip.ss_family &&
306 comp_with_mask_sock((struct sockaddr *)&ip, (struct sockaddr *)&cip, bits))
307 return oper_p;
308 }
309
310 /* we have to compare against the host as well, because its
311 * valid to set a spoof to an IP, which if we only compare
312 * in ip form to sockhost will not necessarily match --anfl
313 */
314 if(match(oper_p->host, host))
315 return oper_p;
316 }
317
318 return NULL;
319 }
320
321 struct server_conf *
322 make_server_conf(void)
323 {
324 struct server_conf *server_p = rb_malloc(sizeof(struct server_conf));
325 server_p->aftype = AF_INET;
326 return server_p;
327 }
328
329 void
330 free_server_conf(struct server_conf *server_p)
331 {
332 s_assert(server_p != NULL);
333 if(server_p == NULL)
334 return;
335
336 if(!EmptyString(server_p->passwd))
337 {
338 memset(server_p->passwd, 0, strlen(server_p->passwd));
339 rb_free(server_p->passwd);
340 }
341
342 if(!EmptyString(server_p->spasswd))
343 {
344 memset(server_p->spasswd, 0, strlen(server_p->spasswd));
345 rb_free(server_p->spasswd);
346 }
347
348 rb_free(server_p->name);
349 rb_free(server_p->host);
350 rb_free(server_p->class_name);
351 rb_free(server_p);
352 }
353
354 void
355 add_server_conf(struct server_conf *server_p)
356 {
357 if(EmptyString(server_p->class_name))
358 {
359 server_p->class_name = rb_strdup("default");
360 server_p->class = default_class;
361 return;
362 }
363
364 server_p->class = find_class(server_p->class_name);
365
366 if(server_p->class == default_class)
367 {
368 conf_report_error("Warning connect::class invalid for %s",
369 server_p->name);
370
371 rb_free(server_p->class_name);
372 server_p->class_name = rb_strdup("default");
373 }
374
375 if(strchr(server_p->host, '*') || strchr(server_p->host, '?'))
376 return;
377 }
378
379 struct server_conf *
380 find_server_conf(const char *name)
381 {
382 struct server_conf *server_p;
383 rb_dlink_node *ptr;
384
385 RB_DLINK_FOREACH(ptr, server_conf_list.head)
386 {
387 server_p = ptr->data;
388
389 if(ServerConfIllegal(server_p))
390 continue;
391
392 if(match(name, server_p->name))
393 return server_p;
394 }
395
396 return NULL;
397 }
398
399 void
400 attach_server_conf(struct Client *client_p, struct server_conf *server_p)
401 {
402 /* already have an attached conf */
403 if(client_p->localClient->att_sconf)
404 {
405 /* short circuit this special case :) */
406 if(client_p->localClient->att_sconf == server_p)
407 return;
408
409 detach_server_conf(client_p);
410 }
411
412 CurrUsers(server_p->class)++;
413
414 client_p->localClient->att_sconf = server_p;
415 server_p->servers++;
416 }
417
418 void
419 detach_server_conf(struct Client *client_p)
420 {
421 struct server_conf *server_p = client_p->localClient->att_sconf;
422
423 if(server_p == NULL)
424 return;
425
426 client_p->localClient->att_sconf = NULL;
427 server_p->servers--;
428 CurrUsers(server_p->class)--;
429
430 if(ServerConfIllegal(server_p) && !server_p->servers)
431 {
432 /* the class this one is using may need destroying too */
433 if(MaxUsers(server_p->class) < 0 && CurrUsers(server_p->class) <= 0)
434 free_class(server_p->class);
435
436 rb_dlinkDelete(&server_p->node, &server_conf_list);
437 free_server_conf(server_p);
438 }
439 }
440
441 void
442 set_server_conf_autoconn(struct Client *source_p, const char *name, int newval)
443 {
444 struct server_conf *server_p;
445
446 if((server_p = find_server_conf(name)) != NULL)
447 {
448 if(newval)
449 server_p->flags |= SERVER_AUTOCONN;
450 else
451 server_p->flags &= ~SERVER_AUTOCONN;
452
453 sendto_realops_snomask(SNO_GENERAL, L_ALL,
454 "%s has changed AUTOCONN for %s to %i",
455 get_oper_name(source_p), name, newval);
456 }
457 else
458 sendto_one_notice(source_p, ":Can't find %s", name);
459 }
460
461 void
462 disable_server_conf_autoconn(const char *name)
463 {
464 struct server_conf *server_p;
465
466 server_p = find_server_conf(name);
467 if(server_p != NULL && server_p->flags & SERVER_AUTOCONN)
468 {
469 server_p->flags &= ~SERVER_AUTOCONN;
470
471 sendto_realops_snomask(SNO_GENERAL, L_ALL,
472 "Disabling AUTOCONN for %s because of error",
473 name);
474 ilog(L_SERVER, "Disabling AUTOCONN for %s because of error",
475 name);
476 }
477 }
478
479 struct ConfItem *
480 find_xline(const char *gecos, int counter)
481 {
482 struct ConfItem *aconf;
483 rb_dlink_node *ptr;
484
485 RB_DLINK_FOREACH(ptr, xline_conf_list.head)
486 {
487 aconf = ptr->data;
488
489 if(match_esc(aconf->name, gecos))
490 {
491 if(counter)
492 aconf->port++;
493 return aconf;
494 }
495 }
496
497 return NULL;
498 }
499
500 struct ConfItem *
501 find_xline_mask(const char *gecos)
502 {
503 struct ConfItem *aconf;
504 rb_dlink_node *ptr;
505
506 RB_DLINK_FOREACH(ptr, xline_conf_list.head)
507 {
508 aconf = ptr->data;
509
510 if(!irccmp(aconf->name, gecos))
511 return aconf;
512 }
513
514 return NULL;
515 }
516
517 struct ConfItem *
518 find_nick_resv(const char *name)
519 {
520 struct ConfItem *aconf;
521 rb_dlink_node *ptr;
522
523 RB_DLINK_FOREACH(ptr, resv_conf_list.head)
524 {
525 aconf = ptr->data;
526
527 if(match_esc(aconf->name, name))
528 {
529 aconf->port++;
530 return aconf;
531 }
532 }
533
534 return NULL;
535 }
536
537 struct ConfItem *
538 find_nick_resv_mask(const char *name)
539 {
540 struct ConfItem *aconf;
541 rb_dlink_node *ptr;
542
543 RB_DLINK_FOREACH(ptr, resv_conf_list.head)
544 {
545 aconf = ptr->data;
546
547 if(!irccmp(aconf->name, name))
548 return aconf;
549 }
550
551 return NULL;
552 }
553
554 /* clean_resv_nick()
555 *
556 * inputs - nick
557 * outputs - 1 if nick is vaild resv, 0 otherwise
558 * side effects -
559 */
560 int
561 clean_resv_nick(const char *nick)
562 {
563 char tmpch;
564 int as = 0;
565 int q = 0;
566 int ch = 0;
567
568 if(*nick == '-' || IsDigit(*nick))
569 return 0;
570
571 while ((tmpch = *nick++))
572 {
573 if(tmpch == '?' || tmpch == '@' || tmpch == '#')
574 q++;
575 else if(tmpch == '*')
576 as++;
577 else if(IsNickChar(tmpch))
578 ch++;
579 else
580 return 0;
581 }
582
583 if(!ch && as)
584 return 0;
585
586 return 1;
587 }
588
589 /* valid_wild_card_simple()
590 *
591 * inputs - "thing" to test
592 * outputs - 1 if enough wildcards, else 0
593 * side effects -
594 */
595 int
596 valid_wild_card_simple(const char *data)
597 {
598 const char *p;
599 char tmpch;
600 int nonwild = 0;
601 int wild = 0;
602
603 /* check the string for minimum number of nonwildcard chars */
604 p = data;
605
606 while((tmpch = *p++))
607 {
608 /* found an escape, p points to the char after it, so skip
609 * that and move on.
610 */
611 if(tmpch == '\\' && *p)
612 {
613 p++;
614 if(++nonwild >= ConfigFileEntry.min_nonwildcard_simple)
615 return 1;
616 }
617 else if(!IsMWildChar(tmpch))
618 {
619 /* if we have enough nonwildchars, return */
620 if(++nonwild >= ConfigFileEntry.min_nonwildcard_simple)
621 return 1;
622 }
623 else
624 wild++;
625 }
626
627 /* strings without wilds are also ok */
628 return wild == 0;
629 }
630
631 time_t
632 valid_temp_time(const char *p)
633 {
634 time_t result = 0;
635
636 while(*p)
637 {
638 if(IsDigit(*p))
639 {
640 result *= 10;
641 result += ((*p) & 0xF);
642 p++;
643 }
644 else
645 return -1;
646 }
647
648 if(result > (60 * 24 * 7 * 52))
649 result = (60 * 24 * 7 * 52);
650
651 return(result * 60);
652 }
653
654 static void
655 expire_temp_rxlines(void *unused)
656 {
657 struct ConfItem *aconf;
658 rb_dlink_node *ptr;
659 rb_dlink_node *next_ptr;
660 int i;
661
662 HASH_WALK_SAFE(i, R_MAX, ptr, next_ptr, resvTable)
663 {
664 aconf = ptr->data;
665
666 if(aconf->hold && aconf->hold <= rb_current_time())
667 {
668 if(ConfigFileEntry.tkline_expire_notices)
669 sendto_realops_snomask(SNO_GENERAL, L_ALL,
670 "Temporary RESV for [%s] expired",
671 aconf->name);
672
673 free_conf(aconf);
674 rb_dlinkDestroy(ptr, &resvTable[i]);
675 }
676 }
677 HASH_WALK_END
678
679 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, resv_conf_list.head)
680 {
681 aconf = ptr->data;
682
683 if(aconf->hold && aconf->hold <= rb_current_time())
684 {
685 if(ConfigFileEntry.tkline_expire_notices)
686 sendto_realops_snomask(SNO_GENERAL, L_ALL,
687 "Temporary RESV for [%s] expired",
688 aconf->name);
689 free_conf(aconf);
690 rb_dlinkDestroy(ptr, &resv_conf_list);
691 }
692 }
693
694 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, xline_conf_list.head)
695 {
696 aconf = ptr->data;
697
698 if(aconf->hold && aconf->hold <= rb_current_time())
699 {
700 if(ConfigFileEntry.tkline_expire_notices)
701 sendto_realops_snomask(SNO_GENERAL, L_ALL,
702 "Temporary X-line for [%s] expired",
703 aconf->name);
704 free_conf(aconf);
705 rb_dlinkDestroy(ptr, &xline_conf_list);
706 }
707 }
708 }
709
710 unsigned long
711 get_nd_count(void)
712 {
713 return(rb_dlink_list_length(&nd_list));
714 }
715
716 void
717 add_nd_entry(const char *name)
718 {
719 struct nd_entry *nd;
720
721 if(irc_dictionary_find(nd_dict, name) != NULL)
722 return;
723
724 nd = rb_bh_alloc(nd_heap);
725
726 rb_strlcpy(nd->name, name, sizeof(nd->name));
727 nd->expire = rb_current_time() + ConfigFileEntry.nick_delay;
728
729 /* this list is ordered */
730 rb_dlinkAddTail(nd, &nd->lnode, &nd_list);
731
732 irc_dictionary_add(nd_dict, nd->name, nd);
733 }
734
735 void
736 free_nd_entry(struct nd_entry *nd)
737 {
738 irc_dictionary_delete(nd_dict, nd->name);
739
740 rb_dlinkDelete(&nd->lnode, &nd_list);
741 rb_bh_free(nd_heap, nd);
742 }
743
744 void
745 expire_nd_entries(void *unused)
746 {
747 struct nd_entry *nd;
748 rb_dlink_node *ptr;
749 rb_dlink_node *next_ptr;
750
751 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, nd_list.head)
752 {
753 nd = ptr->data;
754
755 /* this list is ordered - we can stop when we hit the first
756 * entry that doesnt expire..
757 */
758 if(nd->expire > rb_current_time())
759 return;
760
761 free_nd_entry(nd);
762 }
763 }
764
765 void
766 add_tgchange(const char *host)
767 {
768 tgchange *target;
769 rb_patricia_node_t *pnode;
770
771 if(find_tgchange(host))
772 return;
773
774 target = rb_malloc(sizeof(tgchange));
775 pnode = make_and_lookup(tgchange_tree, host);
776
777 pnode->data = target;
778 target->pnode = pnode;
779
780 target->ip = rb_strdup(host);
781 target->expiry = rb_current_time() + (60*60*12);
782
783 rb_dlinkAdd(target, &target->node, &tgchange_list);
784 }
785
786 tgchange *
787 find_tgchange(const char *host)
788 {
789 rb_patricia_node_t *pnode;
790
791 if((pnode = rb_match_exact_string(tgchange_tree, host)))
792 return pnode->data;
793
794 return NULL;
795 }
796