2 * ircd-ratbox: an advanced Internet Relay Chat Daemon(ircd).
3 * s_newconf.c - code for dealing with conf stuff
5 * Copyright (C) 2004 Lee Hardy <lee@leeh.co.uk>
6 * Copyright (C) 2004-2005 ircd-ratbox development team
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions are
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.
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.
36 #include <openssl/evp.h>
37 #include <openssl/rsa.h>
40 #include "ircd_defs.h"
42 #include "s_newconf.h"
49 #include "rb_dictionary.h"
50 #include "rb_radixtree.h"
55 rb_dlink_list cluster_conf_list
;
56 rb_dlink_list oper_conf_list
;
57 rb_dlink_list server_conf_list
;
58 rb_dlink_list xline_conf_list
;
59 rb_dlink_list resv_conf_list
; /* nicks only! */
60 rb_dlink_list nd_list
; /* nick delay */
61 rb_dlink_list tgchange_list
;
63 rb_patricia_tree_t
*tgchange_tree
;
65 static rb_bh
*nd_heap
= NULL
;
67 static void expire_temp_rxlines(void *unused
);
68 static void expire_nd_entries(void *unused
);
70 struct ev_entry
*expire_nd_entries_ev
= NULL
;
71 struct ev_entry
*expire_temp_rxlines_ev
= NULL
;
76 tgchange_tree
= rb_new_patricia(PATRICIA_BITS
);
77 nd_heap
= rb_bh_create(sizeof(struct nd_entry
), ND_HEAP_SIZE
, "nd_heap");
78 expire_nd_entries_ev
= rb_event_addish("expire_nd_entries", expire_nd_entries
, NULL
, 30);
79 expire_temp_rxlines_ev
= rb_event_addish("expire_temp_rxlines", expire_temp_rxlines
, NULL
, 60);
85 struct server_conf
*server_p
;
87 rb_dlink_node
*next_ptr
;
89 RB_DLINK_FOREACH_SAFE(ptr
, next_ptr
, cluster_conf_list
.head
)
91 rb_dlinkDelete(ptr
, &cluster_conf_list
);
92 free_remote_conf(ptr
->data
);
95 RB_DLINK_FOREACH_SAFE(ptr
, next_ptr
, oper_conf_list
.head
)
97 free_oper_conf(ptr
->data
);
98 rb_dlinkDestroy(ptr
, &oper_conf_list
);
101 RB_DLINK_FOREACH_SAFE(ptr
, next_ptr
, server_conf_list
.head
)
103 server_p
= ptr
->data
;
105 if(!server_p
->servers
)
107 rb_dlinkDelete(ptr
, &server_conf_list
);
108 free_server_conf(ptr
->data
);
111 server_p
->flags
|= SERVER_ILLEGAL
;
116 clear_s_newconf_bans(void)
118 struct ConfItem
*aconf
;
119 rb_dlink_node
*ptr
, *next_ptr
;
121 RB_DLINK_FOREACH_SAFE(ptr
, next_ptr
, xline_conf_list
.head
)
129 rb_dlinkDestroy(ptr
, &xline_conf_list
);
132 RB_DLINK_FOREACH_SAFE(ptr
, next_ptr
, resv_conf_list
.head
)
141 rb_dlinkDestroy(ptr
, &resv_conf_list
);
148 make_remote_conf(void)
150 struct remote_conf
*remote_p
= rb_malloc(sizeof(struct remote_conf
));
155 free_remote_conf(struct remote_conf
*remote_p
)
157 s_assert(remote_p
!= NULL
);
161 rb_free(remote_p
->username
);
162 rb_free(remote_p
->host
);
163 rb_free(remote_p
->server
);
168 propagate_generic(struct Client
*source_p
, const char *command
,
169 const char *target
, int cap
, const char *format
, ...)
171 char buffer
[BUFSIZE
];
174 va_start(args
, format
);
175 vsnprintf(buffer
, sizeof(buffer
), format
, args
);
178 sendto_match_servs(source_p
, target
, cap
, NOCAPS
,
180 command
, target
, buffer
);
181 sendto_match_servs(source_p
, target
, CAP_ENCAP
, cap
,
183 target
, command
, buffer
);
187 cluster_generic(struct Client
*source_p
, const char *command
,
188 int cltype
, int cap
, const char *format
, ...)
190 char buffer
[BUFSIZE
];
191 struct remote_conf
*shared_p
;
195 va_start(args
, format
);
196 vsnprintf(buffer
, sizeof(buffer
), format
, args
);
199 RB_DLINK_FOREACH(ptr
, cluster_conf_list
.head
)
201 shared_p
= ptr
->data
;
203 if(!(shared_p
->flags
& cltype
))
206 sendto_match_servs(source_p
, shared_p
->server
, cap
, NOCAPS
,
208 command
, shared_p
->server
, buffer
);
209 sendto_match_servs(source_p
, shared_p
->server
, CAP_ENCAP
, cap
,
211 shared_p
->server
, command
, buffer
);
218 struct oper_conf
*oper_p
= rb_malloc(sizeof(struct oper_conf
));
223 free_oper_conf(struct oper_conf
*oper_p
)
225 s_assert(oper_p
!= NULL
);
229 rb_free(oper_p
->username
);
230 rb_free(oper_p
->host
);
231 rb_free(oper_p
->name
);
232 rb_free(oper_p
->certfp
);
236 memset(oper_p
->passwd
, 0, strlen(oper_p
->passwd
));
237 rb_free(oper_p
->passwd
);
240 #ifdef HAVE_LIBCRYPTO
241 rb_free(oper_p
->rsa_pubkey_file
);
243 if(oper_p
->rsa_pubkey
)
244 #if (OPENSSL_VERSION_NUMBER >= 0x30000000L)
245 EVP_PKEY_free(oper_p
->rsa_pubkey
);
247 RSA_free(oper_p
->rsa_pubkey
);
255 find_oper_conf(const char *username
, const char *host
, const char *locip
, const char *name
)
257 struct oper_conf
*oper_p
;
258 struct rb_sockaddr_storage ip
, cip
;
259 char addr
[HOSTLEN
+1];
263 parse_netmask(locip
, &cip
, &cbits
);
265 RB_DLINK_FOREACH(ptr
, oper_conf_list
.head
)
269 /* name/username doesnt match.. */
270 if(irccmp(oper_p
->name
, name
) || !match(oper_p
->username
, username
))
273 rb_strlcpy(addr
, oper_p
->host
, sizeof(addr
));
275 if(parse_netmask(addr
, &ip
, &bits
) != HM_HOST
)
277 if(GET_SS_FAMILY(&ip
) == GET_SS_FAMILY(&cip
) &&
278 comp_with_mask_sock((struct sockaddr
*)&ip
, (struct sockaddr
*)&cip
, bits
))
282 /* we have to compare against the host as well, because its
283 * valid to set a spoof to an IP, which if we only compare
284 * in ip form to sockhost will not necessarily match --anfl
286 if(match(oper_p
->host
, host
))
294 make_server_conf(void)
296 struct server_conf
*server_p
= rb_malloc(sizeof(struct server_conf
));
298 SET_SS_FAMILY(&server_p
->connect4
, AF_UNSPEC
);
299 SET_SS_LEN(&server_p
->connect4
, sizeof(struct sockaddr_in
));
301 SET_SS_FAMILY(&server_p
->bind4
, AF_UNSPEC
);
302 SET_SS_LEN(&server_p
->bind4
, sizeof(struct sockaddr_in
));
304 SET_SS_FAMILY(&server_p
->connect6
, AF_UNSPEC
);
305 SET_SS_LEN(&server_p
->connect6
, sizeof(struct sockaddr_in6
));
307 SET_SS_FAMILY(&server_p
->bind6
, AF_UNSPEC
);
308 SET_SS_LEN(&server_p
->bind6
, sizeof(struct sockaddr_in6
));
310 server_p
->aftype
= AF_UNSPEC
;
316 free_server_conf(struct server_conf
*server_p
)
318 s_assert(server_p
!= NULL
);
322 if(!EmptyString(server_p
->passwd
))
324 memset(server_p
->passwd
, 0, strlen(server_p
->passwd
));
325 rb_free(server_p
->passwd
);
328 if(!EmptyString(server_p
->spasswd
))
330 memset(server_p
->spasswd
, 0, strlen(server_p
->spasswd
));
331 rb_free(server_p
->spasswd
);
334 rb_free(server_p
->name
);
335 rb_free(server_p
->connect_host
);
336 rb_free(server_p
->bind_host
);
337 rb_free(server_p
->class_name
);
338 rb_free(server_p
->certfp
);
343 * conf_connect_dns_callback
344 * inputs - pointer to struct ConfItem
345 * - pointer to adns reply
347 * side effects - called when resolver query finishes
348 * if the query resulted in a successful search, hp will contain
349 * a non-null pointer, otherwise hp will be null.
350 * if successful save hp in the conf item it was called with
353 conf_connect_dns_callback(const char *result
, int status
, int aftype
, void *data
)
355 struct server_conf
*server_p
= data
;
357 if(aftype
== AF_INET
)
360 rb_inet_pton_sock(result
, &server_p
->connect4
);
362 server_p
->dns_query_connect4
= 0;
364 else if(aftype
== AF_INET6
)
367 rb_inet_pton_sock(result
, &server_p
->connect6
);
369 server_p
->dns_query_connect6
= 0;
374 * conf_bind_dns_callback
375 * inputs - pointer to struct ConfItem
376 * - pointer to adns reply
378 * side effects - called when resolver query finishes
379 * if the query resulted in a successful search, hp will contain
380 * a non-null pointer, otherwise hp will be null.
381 * if successful save hp in the conf item it was called with
384 conf_bind_dns_callback(const char *result
, int status
, int aftype
, void *data
)
386 struct server_conf
*server_p
= data
;
388 if(aftype
== AF_INET
)
391 rb_inet_pton_sock(result
, &server_p
->bind4
);
393 server_p
->dns_query_bind4
= 0;
395 else if(aftype
== AF_INET6
)
398 rb_inet_pton_sock(result
, &server_p
->bind6
);
400 server_p
->dns_query_bind6
= 0;
405 add_server_conf(struct server_conf
*server_p
)
407 if(EmptyString(server_p
->class_name
))
409 server_p
->class_name
= rb_strdup("default");
410 server_p
->class = default_class
;
414 server_p
->class = find_class(server_p
->class_name
);
416 if(server_p
->class == default_class
)
418 conf_report_error("Warning connect::class invalid for %s",
421 rb_free(server_p
->class_name
);
422 server_p
->class_name
= rb_strdup("default");
425 if(server_p
->connect_host
&& !strpbrk(server_p
->connect_host
, "*?"))
427 server_p
->dns_query_connect4
=
428 lookup_hostname(server_p
->connect_host
, AF_INET
, conf_connect_dns_callback
, server_p
);
429 server_p
->dns_query_connect6
=
430 lookup_hostname(server_p
->connect_host
, AF_INET6
, conf_connect_dns_callback
, server_p
);
433 if(server_p
->bind_host
)
435 server_p
->dns_query_bind4
=
436 lookup_hostname(server_p
->bind_host
, AF_INET
, conf_bind_dns_callback
, server_p
);
437 server_p
->dns_query_bind6
=
438 lookup_hostname(server_p
->bind_host
, AF_INET6
, conf_bind_dns_callback
, server_p
);
443 find_server_conf(const char *name
)
445 struct server_conf
*server_p
;
448 RB_DLINK_FOREACH(ptr
, server_conf_list
.head
)
450 server_p
= ptr
->data
;
452 if(ServerConfIllegal(server_p
))
455 if(match(name
, server_p
->name
))
463 attach_server_conf(struct Client
*client_p
, struct server_conf
*server_p
)
465 /* already have an attached conf */
466 if(client_p
->localClient
->att_sconf
)
468 /* short circuit this special case :) */
469 if(client_p
->localClient
->att_sconf
== server_p
)
472 detach_server_conf(client_p
);
475 CurrUsers(server_p
->class)++;
477 client_p
->localClient
->att_sconf
= server_p
;
482 detach_server_conf(struct Client
*client_p
)
484 struct server_conf
*server_p
= client_p
->localClient
->att_sconf
;
489 client_p
->localClient
->att_sconf
= NULL
;
491 CurrUsers(server_p
->class)--;
493 if(ServerConfIllegal(server_p
) && !server_p
->servers
)
495 /* the class this one is using may need destroying too */
496 if(MaxUsers(server_p
->class) < 0 && CurrUsers(server_p
->class) <= 0)
497 free_class(server_p
->class);
499 rb_dlinkDelete(&server_p
->node
, &server_conf_list
);
500 free_server_conf(server_p
);
505 set_server_conf_autoconn(struct Client
*source_p
, const char *name
, int newval
)
507 struct server_conf
*server_p
;
509 if((server_p
= find_server_conf(name
)) != NULL
)
512 server_p
->flags
|= SERVER_AUTOCONN
;
514 server_p
->flags
&= ~SERVER_AUTOCONN
;
516 sendto_realops_snomask(SNO_GENERAL
, L_NETWIDE
,
517 "%s has changed AUTOCONN for %s to %i",
518 get_oper_name(source_p
), name
, newval
);
521 sendto_one_notice(source_p
, ":Can't find %s", name
);
525 disable_server_conf_autoconn(const char *name
)
527 struct server_conf
*server_p
;
529 server_p
= find_server_conf(name
);
530 if(server_p
!= NULL
&& server_p
->flags
& SERVER_AUTOCONN
)
532 server_p
->flags
&= ~SERVER_AUTOCONN
;
534 sendto_realops_snomask(SNO_GENERAL
, L_NETWIDE
,
535 "Disabling AUTOCONN for %s because of error",
537 ilog(L_SERVER
, "Disabling AUTOCONN for %s because of error",
543 find_xline(const char *gecos
, int counter
)
545 struct ConfItem
*aconf
;
548 RB_DLINK_FOREACH(ptr
, xline_conf_list
.head
)
552 if(match_esc(aconf
->host
, gecos
))
564 find_xline_mask(const char *gecos
)
566 struct ConfItem
*aconf
;
569 RB_DLINK_FOREACH(ptr
, xline_conf_list
.head
)
573 if(!irccmp(aconf
->host
, gecos
))
581 find_nick_resv(const char *name
)
583 struct ConfItem
*aconf
;
586 RB_DLINK_FOREACH(ptr
, resv_conf_list
.head
)
590 if(match_esc(aconf
->host
, name
))
601 find_nick_resv_mask(const char *name
)
603 struct ConfItem
*aconf
;
606 RB_DLINK_FOREACH(ptr
, resv_conf_list
.head
)
610 if(!irccmp(aconf
->host
, name
))
620 * outputs - 1 if nick is vaild resv, 0 otherwise
624 clean_resv_nick(const char *nick
)
631 if(*nick
== '-' || IsDigit(*nick
))
634 while ((tmpch
= *nick
++))
636 if(tmpch
== '?' || tmpch
== '@' || tmpch
== '#')
638 else if(tmpch
== '*')
640 else if(IsNickChar(tmpch
))
652 /* valid_wild_card_simple()
654 * inputs - "thing" to test
655 * outputs - 1 if enough wildcards, else 0
659 valid_wild_card_simple(const char *data
)
666 /* check the string for minimum number of nonwildcard chars */
669 while((tmpch
= *p
++))
671 /* found an escape, p points to the char after it, so skip
674 if(tmpch
== '\\' && *p
)
677 if(++nonwild
>= ConfigFileEntry
.min_nonwildcard_simple
)
680 else if(!IsMWildChar(tmpch
))
682 /* if we have enough nonwildchars, return */
683 if(++nonwild
>= ConfigFileEntry
.min_nonwildcard_simple
)
690 /* strings without wilds are also ok */
695 valid_temp_time(const char *p
)
705 current
= strtol(p
, &endp
, 10);
713 case '\0': /* No unit was given so send it back as minutes */
730 if (current
> LONG_MAX
/ mul
)
731 return MAX_TEMP_TIME
;
735 if (current
> MAX_TEMP_TIME
- result
)
736 return MAX_TEMP_TIME
;
746 return MIN(result
, MAX_TEMP_TIME
);
749 /* Propagated bans are expired elsewhere. */
751 expire_temp_rxlines(void *unused
)
753 struct ConfItem
*aconf
;
755 rb_dlink_node
*next_ptr
;
756 rb_radixtree_iteration_state state
;
758 RB_RADIXTREE_FOREACH(aconf
, &state
, resv_tree
)
760 if(aconf
->lifetime
!= 0)
762 if(aconf
->hold
&& aconf
->hold
<= rb_current_time())
764 if(ConfigFileEntry
.tkline_expire_notices
)
765 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
766 "Temporary RESV for [%s] expired",
769 rb_radixtree_delete(resv_tree
, aconf
->host
);
774 RB_DLINK_FOREACH_SAFE(ptr
, next_ptr
, resv_conf_list
.head
)
778 if(aconf
->lifetime
!= 0)
780 if(aconf
->hold
&& aconf
->hold
<= rb_current_time())
782 if(ConfigFileEntry
.tkline_expire_notices
)
783 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
784 "Temporary RESV for [%s] expired",
787 rb_dlinkDestroy(ptr
, &resv_conf_list
);
791 RB_DLINK_FOREACH_SAFE(ptr
, next_ptr
, xline_conf_list
.head
)
795 if(aconf
->lifetime
!= 0)
797 if(aconf
->hold
&& aconf
->hold
<= rb_current_time())
799 if(ConfigFileEntry
.tkline_expire_notices
)
800 sendto_realops_snomask(SNO_GENERAL
, L_ALL
,
801 "Temporary X-line for [%s] expired",
804 rb_dlinkDestroy(ptr
, &xline_conf_list
);
812 return(rb_dlink_list_length(&nd_list
));
816 add_nd_entry(const char *name
)
820 if(rb_dictionary_find(nd_dict
, name
) != NULL
)
823 nd
= rb_bh_alloc(nd_heap
);
825 rb_strlcpy(nd
->name
, name
, sizeof(nd
->name
));
826 nd
->expire
= rb_current_time() + ConfigFileEntry
.nick_delay
;
828 /* this list is ordered */
829 rb_dlinkAddTail(nd
, &nd
->lnode
, &nd_list
);
831 rb_dictionary_add(nd_dict
, nd
->name
, nd
);
835 free_nd_entry(struct nd_entry
*nd
)
837 rb_dictionary_delete(nd_dict
, nd
->name
);
839 rb_dlinkDelete(&nd
->lnode
, &nd_list
);
840 rb_bh_free(nd_heap
, nd
);
844 expire_nd_entries(void *unused
)
848 rb_dlink_node
*next_ptr
;
850 RB_DLINK_FOREACH_SAFE(ptr
, next_ptr
, nd_list
.head
)
854 /* this list is ordered - we can stop when we hit the first
855 * entry that doesnt expire..
857 if(nd
->expire
> rb_current_time())
865 add_tgchange(const char *host
)
868 rb_patricia_node_t
*pnode
;
870 if(find_tgchange(host
))
873 target
= rb_malloc(sizeof(tgchange
));
874 pnode
= make_and_lookup(tgchange_tree
, host
);
876 pnode
->data
= target
;
877 target
->pnode
= pnode
;
879 target
->ip
= rb_strdup(host
);
880 target
->expiry
= rb_current_time() + (60*60*12);
882 rb_dlinkAdd(target
, &target
->node
, &tgchange_list
);
886 find_tgchange(const char *host
)
888 rb_patricia_node_t
*pnode
;
890 if((pnode
= rb_match_exact_string(tgchange_tree
, host
)))