]> jfr.im git - solanum.git/blob - src/s_newconf.c
86d20b93d16fc834e356cd0eb758abc7f8cec317
[solanum.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 oper_flags
322 {
323 int flag;
324 const char *name;
325 };
326 static struct oper_flags oper_flagtable[] =
327 {
328 { OPER_KLINE, "kline" },
329 { OPER_XLINE, "xline" },
330 { OPER_RESV, "resv" },
331 { OPER_GLOBKILL, "global_kill" },
332 { OPER_LOCKILL, "local_kill" },
333 { OPER_REMOTE, "remote" },
334 { OPER_UNKLINE, "unkline" },
335 { OPER_REHASH, "rehash" },
336 { OPER_DIE, "die" },
337 { OPER_ADMIN, "admin" },
338 { OPER_HADMIN, "hidden_admin" },
339 { OPER_NICKS, "nick_changes" },
340 { OPER_OPERWALL, "operwall" },
341 { OPER_SPY, "spy" },
342 { OPER_INVIS, "hidden_oper" },
343 { OPER_REMOTEBAN, "remoteban" },
344 { OPER_MASSNOTICE, "mass_notice" },
345 { 0, NULL }
346 };
347
348 const char *
349 get_oper_privs(int flags)
350 {
351 static char buf[BUFSIZE];
352 char *p;
353 int i;
354
355 p = buf;
356 *p = '\0';
357
358 for(i = 0; oper_flagtable[i].flag; i++)
359 {
360 if(i)
361 rb_strlcat(buf, ", ", sizeof(buf));
362
363 rb_strlcat(buf, oper_flagtable[i].name, sizeof(buf));
364 }
365
366 return buf;
367 }
368
369 struct server_conf *
370 make_server_conf(void)
371 {
372 struct server_conf *server_p = rb_malloc(sizeof(struct server_conf));
373 server_p->aftype = AF_INET;
374 return server_p;
375 }
376
377 void
378 free_server_conf(struct server_conf *server_p)
379 {
380 s_assert(server_p != NULL);
381 if(server_p == NULL)
382 return;
383
384 if(!EmptyString(server_p->passwd))
385 {
386 memset(server_p->passwd, 0, strlen(server_p->passwd));
387 rb_free(server_p->passwd);
388 }
389
390 if(!EmptyString(server_p->spasswd))
391 {
392 memset(server_p->spasswd, 0, strlen(server_p->spasswd));
393 rb_free(server_p->spasswd);
394 }
395
396 rb_free(server_p->name);
397 rb_free(server_p->host);
398 rb_free(server_p->class_name);
399 rb_free(server_p);
400 }
401
402 void
403 add_server_conf(struct server_conf *server_p)
404 {
405 if(EmptyString(server_p->class_name))
406 {
407 server_p->class_name = rb_strdup("default");
408 server_p->class = default_class;
409 return;
410 }
411
412 server_p->class = find_class(server_p->class_name);
413
414 if(server_p->class == default_class)
415 {
416 conf_report_error("Warning connect::class invalid for %s",
417 server_p->name);
418
419 rb_free(server_p->class_name);
420 server_p->class_name = rb_strdup("default");
421 }
422
423 if(strchr(server_p->host, '*') || strchr(server_p->host, '?'))
424 return;
425 }
426
427 struct server_conf *
428 find_server_conf(const char *name)
429 {
430 struct server_conf *server_p;
431 rb_dlink_node *ptr;
432
433 RB_DLINK_FOREACH(ptr, server_conf_list.head)
434 {
435 server_p = ptr->data;
436
437 if(ServerConfIllegal(server_p))
438 continue;
439
440 if(match(name, server_p->name))
441 return server_p;
442 }
443
444 return NULL;
445 }
446
447 void
448 attach_server_conf(struct Client *client_p, struct server_conf *server_p)
449 {
450 /* already have an attached conf */
451 if(client_p->localClient->att_sconf)
452 {
453 /* short circuit this special case :) */
454 if(client_p->localClient->att_sconf == server_p)
455 return;
456
457 detach_server_conf(client_p);
458 }
459
460 CurrUsers(server_p->class)++;
461
462 client_p->localClient->att_sconf = server_p;
463 server_p->servers++;
464 }
465
466 void
467 detach_server_conf(struct Client *client_p)
468 {
469 struct server_conf *server_p = client_p->localClient->att_sconf;
470
471 if(server_p == NULL)
472 return;
473
474 client_p->localClient->att_sconf = NULL;
475 server_p->servers--;
476 CurrUsers(server_p->class)--;
477
478 if(ServerConfIllegal(server_p) && !server_p->servers)
479 {
480 /* the class this one is using may need destroying too */
481 if(MaxUsers(server_p->class) < 0 && CurrUsers(server_p->class) <= 0)
482 free_class(server_p->class);
483
484 rb_dlinkDelete(&server_p->node, &server_conf_list);
485 free_server_conf(server_p);
486 }
487 }
488
489 void
490 set_server_conf_autoconn(struct Client *source_p, char *name, int newval)
491 {
492 struct server_conf *server_p;
493
494 if((server_p = find_server_conf(name)) != NULL)
495 {
496 if(newval)
497 server_p->flags |= SERVER_AUTOCONN;
498 else
499 server_p->flags &= ~SERVER_AUTOCONN;
500
501 sendto_realops_snomask(SNO_GENERAL, L_ALL,
502 "%s has changed AUTOCONN for %s to %i",
503 get_oper_name(source_p), name, newval);
504 }
505 else
506 sendto_one_notice(source_p, ":Can't find %s", name);
507 }
508
509 struct ConfItem *
510 find_xline(const char *gecos, int counter)
511 {
512 struct ConfItem *aconf;
513 rb_dlink_node *ptr;
514
515 RB_DLINK_FOREACH(ptr, xline_conf_list.head)
516 {
517 aconf = ptr->data;
518
519 if(match_esc(aconf->name, gecos))
520 {
521 if(counter)
522 aconf->port++;
523 return aconf;
524 }
525 }
526
527 return NULL;
528 }
529
530 struct ConfItem *
531 find_xline_mask(const char *gecos)
532 {
533 struct ConfItem *aconf;
534 rb_dlink_node *ptr;
535
536 RB_DLINK_FOREACH(ptr, xline_conf_list.head)
537 {
538 aconf = ptr->data;
539
540 if(!irccmp(aconf->name, gecos))
541 return aconf;
542 }
543
544 return NULL;
545 }
546
547 struct ConfItem *
548 find_nick_resv(const char *name)
549 {
550 struct ConfItem *aconf;
551 rb_dlink_node *ptr;
552
553 RB_DLINK_FOREACH(ptr, resv_conf_list.head)
554 {
555 aconf = ptr->data;
556
557 if(match_esc(aconf->name, name))
558 {
559 aconf->port++;
560 return aconf;
561 }
562 }
563
564 return NULL;
565 }
566
567 struct ConfItem *
568 find_nick_resv_mask(const char *name)
569 {
570 struct ConfItem *aconf;
571 rb_dlink_node *ptr;
572
573 RB_DLINK_FOREACH(ptr, resv_conf_list.head)
574 {
575 aconf = ptr->data;
576
577 if(!irccmp(aconf->name, name))
578 return aconf;
579 }
580
581 return NULL;
582 }
583
584 /* clean_resv_nick()
585 *
586 * inputs - nick
587 * outputs - 1 if nick is vaild resv, 0 otherwise
588 * side effects -
589 */
590 int
591 clean_resv_nick(const char *nick)
592 {
593 char tmpch;
594 int as = 0;
595 int q = 0;
596 int ch = 0;
597
598 if(*nick == '-' || IsDigit(*nick))
599 return 0;
600
601 while ((tmpch = *nick++))
602 {
603 if(tmpch == '?' || tmpch == '@' || tmpch == '#')
604 q++;
605 else if(tmpch == '*')
606 as++;
607 else if(IsNickChar(tmpch))
608 ch++;
609 else
610 return 0;
611 }
612
613 if(!ch && as)
614 return 0;
615
616 return 1;
617 }
618
619 /* valid_wild_card_simple()
620 *
621 * inputs - "thing" to test
622 * outputs - 1 if enough wildcards, else 0
623 * side effects -
624 */
625 int
626 valid_wild_card_simple(const char *data)
627 {
628 const char *p;
629 char tmpch;
630 int nonwild = 0;
631 int wild = 0;
632
633 /* check the string for minimum number of nonwildcard chars */
634 p = data;
635
636 while((tmpch = *p++))
637 {
638 /* found an escape, p points to the char after it, so skip
639 * that and move on.
640 */
641 if(tmpch == '\\' && *p)
642 {
643 p++;
644 if(++nonwild >= ConfigFileEntry.min_nonwildcard_simple)
645 return 1;
646 }
647 else if(!IsMWildChar(tmpch))
648 {
649 /* if we have enough nonwildchars, return */
650 if(++nonwild >= ConfigFileEntry.min_nonwildcard_simple)
651 return 1;
652 }
653 else
654 wild++;
655 }
656
657 /* strings without wilds are also ok */
658 return wild == 0;
659 }
660
661 time_t
662 valid_temp_time(const char *p)
663 {
664 time_t result = 0;
665
666 while(*p)
667 {
668 if(IsDigit(*p))
669 {
670 result *= 10;
671 result += ((*p) & 0xF);
672 p++;
673 }
674 else
675 return -1;
676 }
677
678 if(result > (60 * 24 * 7 * 52))
679 result = (60 * 24 * 7 * 52);
680
681 return(result * 60);
682 }
683
684 static void
685 expire_temp_rxlines(void *unused)
686 {
687 struct ConfItem *aconf;
688 rb_dlink_node *ptr;
689 rb_dlink_node *next_ptr;
690 int i;
691
692 HASH_WALK_SAFE(i, R_MAX, ptr, next_ptr, resvTable)
693 {
694 aconf = ptr->data;
695
696 if(aconf->hold && aconf->hold <= rb_current_time())
697 {
698 if(ConfigFileEntry.tkline_expire_notices)
699 sendto_realops_snomask(SNO_GENERAL, L_ALL,
700 "Temporary RESV for [%s] expired",
701 aconf->name);
702
703 free_conf(aconf);
704 rb_dlinkDestroy(ptr, &resvTable[i]);
705 }
706 }
707 HASH_WALK_END
708
709 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, resv_conf_list.head)
710 {
711 aconf = ptr->data;
712
713 if(aconf->hold && aconf->hold <= rb_current_time())
714 {
715 if(ConfigFileEntry.tkline_expire_notices)
716 sendto_realops_snomask(SNO_GENERAL, L_ALL,
717 "Temporary RESV for [%s] expired",
718 aconf->name);
719 free_conf(aconf);
720 rb_dlinkDestroy(ptr, &resv_conf_list);
721 }
722 }
723
724 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, xline_conf_list.head)
725 {
726 aconf = ptr->data;
727
728 if(aconf->hold && aconf->hold <= rb_current_time())
729 {
730 if(ConfigFileEntry.tkline_expire_notices)
731 sendto_realops_snomask(SNO_GENERAL, L_ALL,
732 "Temporary X-line for [%s] expired",
733 aconf->name);
734 free_conf(aconf);
735 rb_dlinkDestroy(ptr, &xline_conf_list);
736 }
737 }
738 }
739
740 unsigned long
741 get_nd_count(void)
742 {
743 return(rb_dlink_list_length(&nd_list));
744 }
745
746 void
747 add_nd_entry(const char *name)
748 {
749 struct nd_entry *nd;
750
751 if(irc_dictionary_find(nd_dict, name) != NULL)
752 return;
753
754 nd = rb_bh_alloc(nd_heap);
755
756 rb_strlcpy(nd->name, name, sizeof(nd->name));
757 nd->expire = rb_current_time() + ConfigFileEntry.nick_delay;
758
759 /* this list is ordered */
760 rb_dlinkAddTail(nd, &nd->lnode, &nd_list);
761
762 irc_dictionary_add(nd_dict, nd->name, nd);
763 }
764
765 void
766 free_nd_entry(struct nd_entry *nd)
767 {
768 irc_dictionary_delete(nd_dict, nd->name);
769
770 rb_dlinkDelete(&nd->lnode, &nd_list);
771 rb_bh_free(nd_heap, nd);
772 }
773
774 void
775 expire_nd_entries(void *unused)
776 {
777 struct nd_entry *nd;
778 rb_dlink_node *ptr;
779 rb_dlink_node *next_ptr;
780
781 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, nd_list.head)
782 {
783 nd = ptr->data;
784
785 /* this list is ordered - we can stop when we hit the first
786 * entry that doesnt expire..
787 */
788 if(nd->expire > rb_current_time())
789 return;
790
791 free_nd_entry(nd);
792 }
793 }
794
795 void
796 add_tgchange(const char *host)
797 {
798 tgchange *target;
799 rb_patricia_node_t *pnode;
800
801 if(find_tgchange(host))
802 return;
803
804 target = rb_malloc(sizeof(tgchange));
805 pnode = make_and_lookup(tgchange_tree, host);
806
807 pnode->data = target;
808 target->pnode = pnode;
809
810 target->ip = rb_strdup(host);
811 target->expiry = rb_current_time() + (60*60*12);
812
813 rb_dlinkAdd(target, &target->node, &tgchange_list);
814 }
815
816 tgchange *
817 find_tgchange(const char *host)
818 {
819 rb_patricia_node_t *pnode;
820
821 if((pnode = rb_match_exact_string(tgchange_tree, host)))
822 return pnode->data;
823
824 return NULL;
825 }
826