]> git.netwichtig.de Git - user/henk/code/inspircd.git/blob - src/configreader.cpp
Merge pull request #213 from attilamolnar/insp20+namesx
[user/henk/code/inspircd.git] / src / configreader.cpp
1 /*
2  * InspIRCd -- Internet Relay Chat Daemon
3  *
4  *   Copyright (C) 2009-2010 Daniel De Graaf <danieldg@inspircd.org>
5  *   Copyright (C) 2007-2009 Robin Burchell <robin+git@viroteck.net>
6  *   Copyright (C) 2006-2009 Dennis Friis <peavey@inspircd.org>
7  *   Copyright (C) 2006-2008 Craig Edwards <craigedwards@brainbox.cc>
8  *   Copyright (C) 2008 Thomas Stagner <aquanight@inspircd.org>
9  *   Copyright (C) 2006 Oliver Lupton <oliverlupton@gmail.com>
10  *
11  * This file is part of InspIRCd.  InspIRCd is free software: you can
12  * redistribute it and/or modify it under the terms of the GNU General Public
13  * License as published by the Free Software Foundation, version 2.
14  *
15  * This program is distributed in the hope that it will be useful, but WITHOUT
16  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
17  * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
18  * details.
19  *
20  * You should have received a copy of the GNU General Public License
21  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
22  */
23
24
25 #include "inspircd.h"
26 #include <fstream>
27 #include "xline.h"
28 #include "exitcodes.h"
29 #include "commands/cmd_whowas.h"
30 #include "configparser.h"
31
32 ServerConfig::ServerConfig()
33 {
34         WhoWasGroupSize = WhoWasMaxGroups = WhoWasMaxKeep = 0;
35         RawLog = NoUserDns = HideBans = HideSplits = UndernetMsgPrefix = false;
36         WildcardIPv6 = CycleHosts = InvBypassModes = true;
37         dns_timeout = 5;
38         MaxTargets = 20;
39         NetBufferSize = 10240;
40         SoftLimit = ServerInstance->SE->GetMaxFds();
41         MaxConn = SOMAXCONN;
42         MaxChans = 20;
43         OperMaxChans = 30;
44         c_ipv4_range = 32;
45         c_ipv6_range = 128;
46 }
47
48 void ServerConfig::Update005()
49 {
50         std::stringstream out(data005);
51         std::vector<std::string> data;
52         std::string token;
53         while (out >> token)
54                 data.push_back(token);
55         sort(data.begin(), data.end());
56
57         std::string line5;
58         isupport.clear();
59         for(unsigned int i=0; i < data.size(); i++)
60         {
61                 token = data[i];
62                 line5 = line5 + token + " ";
63                 if (i % 13 == 12)
64                 {
65                         line5.append(":are supported by this server");
66                         isupport.push_back(line5);
67                         line5.clear();
68                 }
69         }
70         if (!line5.empty())
71         {
72                 line5.append(":are supported by this server");
73                 isupport.push_back(line5);
74         }
75 }
76
77 void ServerConfig::Send005(User* user)
78 {
79         for (std::vector<std::string>::iterator line = ServerInstance->Config->isupport.begin(); line != ServerInstance->Config->isupport.end(); line++)
80                 user->WriteNumeric(RPL_ISUPPORT, "%s %s", user->nick.c_str(), line->c_str());
81 }
82
83 template<typename T, typename V>
84 static void range(T& value, V min, V max, V def, const char* msg)
85 {
86         if (value >= (T)min && value <= (T)max)
87                 return;
88         ServerInstance->Logs->Log("CONFIG", DEFAULT,
89                 "WARNING: %s value of %ld is not between %ld and %ld; set to %ld.",
90                 msg, (long)value, (long)min, (long)max, (long)def);
91         value = def;
92 }
93
94
95 static void ValidIP(const std::string& ip, const std::string& key)
96 {
97         irc::sockets::sockaddrs dummy;
98         if (!irc::sockets::aptosa(ip, 0, dummy))
99                 throw CoreException("The value of "+key+" is not an IP address");
100 }
101
102 static void ValidHost(const std::string& p, const std::string& msg)
103 {
104         int num_dots = 0;
105         if (p.empty() || p[0] == '.')
106                 throw CoreException("The value of "+msg+" is not a valid hostname");
107         for (unsigned int i=0;i < p.length();i++)
108         {
109                 switch (p[i])
110                 {
111                         case ' ':
112                                 throw CoreException("The value of "+msg+" is not a valid hostname");
113                         case '.':
114                                 num_dots++;
115                         break;
116                 }
117         }
118         if (num_dots == 0)
119                 throw CoreException("The value of "+msg+" is not a valid hostname");
120 }
121
122 bool ServerConfig::ApplyDisabledCommands(const std::string& data)
123 {
124         std::stringstream dcmds(data);
125         std::string thiscmd;
126
127         /* Enable everything first */
128         for (Commandtable::iterator x = ServerInstance->Parser->cmdlist.begin(); x != ServerInstance->Parser->cmdlist.end(); x++)
129                 x->second->Disable(false);
130
131         /* Now disable all the ones which the user wants disabled */
132         while (dcmds >> thiscmd)
133         {
134                 Commandtable::iterator cm = ServerInstance->Parser->cmdlist.find(thiscmd);
135                 if (cm != ServerInstance->Parser->cmdlist.end())
136                 {
137                         cm->second->Disable(true);
138                 }
139         }
140         return true;
141 }
142
143 #ifdef WINDOWS
144 // Note: the windows validator is in win32wrapper.cpp
145 void FindDNS(std::string& server);
146 #else
147 static void FindDNS(std::string& server)
148 {
149         if (!server.empty())
150                 return;
151
152         // attempt to look up their nameserver from /etc/resolv.conf
153         ServerInstance->Logs->Log("CONFIG",DEFAULT,"WARNING: <dns:server> not defined, attempting to find working server in /etc/resolv.conf...");
154
155         std::ifstream resolv("/etc/resolv.conf");
156
157         while (resolv >> server)
158         {
159                 if (server == "nameserver")
160                 {
161                         resolv >> server;
162                         if (server.find_first_not_of("0123456789.") == std::string::npos)
163                         {
164                                 ServerInstance->Logs->Log("CONFIG",DEFAULT,"<dns:server> set to '%s' as first resolver in /etc/resolv.conf.",server.c_str());
165                                 return;
166                         }
167                 }
168         }
169
170         ServerInstance->Logs->Log("CONFIG",DEFAULT,"/etc/resolv.conf contains no viable nameserver entries! Defaulting to nameserver '127.0.0.1'!");
171         server = "127.0.0.1";
172 }
173 #endif
174
175 static void ReadXLine(ServerConfig* conf, const std::string& tag, const std::string& key, XLineFactory* make)
176 {
177         ConfigTagList tags = conf->ConfTags(tag);
178         for(ConfigIter i = tags.first; i != tags.second; ++i)
179         {
180                 ConfigTag* ctag = i->second;
181                 std::string mask;
182                 if (!ctag->readString(key, mask))
183                         throw CoreException("<"+tag+":"+key+"> missing at " + ctag->getTagLocation());
184                 std::string reason = ctag->getString("reason", "<Config>");
185                 XLine* xl = make->Generate(ServerInstance->Time(), 0, "<Config>", reason, mask);
186                 if (!ServerInstance->XLines->AddLine(xl, NULL))
187                         delete xl;
188         }
189 }
190
191 typedef std::map<std::string, ConfigTag*> LocalIndex;
192 void ServerConfig::CrossCheckOperClassType()
193 {
194         LocalIndex operclass;
195         ConfigTagList tags = ConfTags("class");
196         for(ConfigIter i = tags.first; i != tags.second; ++i)
197         {
198                 ConfigTag* tag = i->second;
199                 std::string name = tag->getString("name");
200                 if (name.empty())
201                         throw CoreException("<class:name> missing from tag at " + tag->getTagLocation());
202                 if (operclass.find(name) != operclass.end())
203                         throw CoreException("Duplicate class block with name " + name + " at " + tag->getTagLocation());
204                 operclass[name] = tag;
205         }
206         tags = ConfTags("type");
207         for(ConfigIter i = tags.first; i != tags.second; ++i)
208         {
209                 ConfigTag* tag = i->second;
210                 std::string name = tag->getString("name");
211                 if (name.empty())
212                         throw CoreException("<type:name> is missing from tag at " + tag->getTagLocation());
213                 if (!ServerInstance->IsNick(name.c_str(), Limits.NickMax))
214                         throw CoreException("<type:name> is invalid (value '" + name + "')");
215                 if (oper_blocks.find(" " + name) != oper_blocks.end())
216                         throw CoreException("Duplicate type block with name " + name + " at " + tag->getTagLocation());
217
218                 OperInfo* ifo = new OperInfo;
219                 oper_blocks[" " + name] = ifo;
220                 ifo->name = name;
221                 ifo->type_block = tag;
222
223                 std::string classname;
224                 irc::spacesepstream str(tag->getString("classes"));
225                 while (str.GetToken(classname))
226                 {
227                         LocalIndex::iterator cls = operclass.find(classname);
228                         if (cls == operclass.end())
229                                 throw CoreException("Oper type " + name + " has missing class " + classname);
230                         ifo->class_blocks.push_back(cls->second);
231                 }
232         }
233
234         tags = ConfTags("oper");
235         for(ConfigIter i = tags.first; i != tags.second; ++i)
236         {
237                 ConfigTag* tag = i->second;
238
239                 std::string name = tag->getString("name");
240                 if (name.empty())
241                         throw CoreException("<oper:name> missing from tag at " + tag->getTagLocation());
242
243                 std::string type = tag->getString("type");
244                 OperIndex::iterator tblk = oper_blocks.find(" " + type);
245                 if (tblk == oper_blocks.end())
246                         throw CoreException("Oper block " + name + " has missing type " + type);
247                 if (oper_blocks.find(name) != oper_blocks.end())
248                         throw CoreException("Duplicate oper block with name " + name + " at " + tag->getTagLocation());
249
250                 OperInfo* ifo = new OperInfo;
251                 ifo->name = type;
252                 ifo->oper_block = tag;
253                 ifo->type_block = tblk->second->type_block;
254                 ifo->class_blocks.assign(tblk->second->class_blocks.begin(), tblk->second->class_blocks.end());
255                 oper_blocks[name] = ifo;
256         }
257 }
258
259 void ServerConfig::CrossCheckConnectBlocks(ServerConfig* current)
260 {
261         typedef std::map<std::string, ConnectClass*> ClassMap;
262         ClassMap oldBlocksByMask;
263         if (current)
264         {
265                 for(ClassVector::iterator i = current->Classes.begin(); i != current->Classes.end(); ++i)
266                 {
267                         ConnectClass* c = *i;
268                         if (c->name.substr(0, 8) != "unnamed-")
269                         {
270                                 oldBlocksByMask["n" + c->name] = c;
271                         }
272                         else if (c->type == CC_ALLOW || c->type == CC_DENY)
273                         {
274                                 std::string typeMask = (c->type == CC_ALLOW) ? "a" : "d";
275                                 typeMask += c->host;
276                                 oldBlocksByMask[typeMask] = c;
277                         }
278                 }
279         }
280
281         int blk_count = config_data.count("connect");
282         if (blk_count == 0)
283         {
284                 // No connect blocks found; make a trivial default block
285                 std::vector<KeyVal>* items;
286                 ConfigTag* tag = ConfigTag::create("connect", "<auto>", 0, items);
287                 items->push_back(std::make_pair("allow", "*"));
288                 config_data.insert(std::make_pair("connect", tag));
289                 blk_count = 1;
290         }
291
292         Classes.resize(blk_count);
293         std::map<std::string, int> names;
294
295         bool try_again = true;
296         for(int tries=0; try_again; tries++)
297         {
298                 try_again = false;
299                 ConfigTagList tags = ConfTags("connect");
300                 int i=0;
301                 for(ConfigIter it = tags.first; it != tags.second; ++it, ++i)
302                 {
303                         ConfigTag* tag = it->second;
304                         if (Classes[i])
305                                 continue;
306
307                         ConnectClass* parent = NULL;
308                         std::string parentName = tag->getString("parent");
309                         if (!parentName.empty())
310                         {
311                                 std::map<std::string,int>::iterator parentIter = names.find(parentName);
312                                 if (parentIter == names.end())
313                                 {
314                                         try_again = true;
315                                         // couldn't find parent this time. If it's the last time, we'll never find it.
316                                         if (tries >= blk_count)
317                                                 throw CoreException("Could not find parent connect class \"" + parentName + "\" for connect block at " + tag->getTagLocation());
318                                         continue;
319                                 }
320                                 parent = Classes[parentIter->second];
321                         }
322
323                         std::string name = tag->getString("name");
324                         std::string mask, typeMask;
325                         char type;
326
327                         if (tag->readString("allow", mask, false))
328                         {
329                                 type = CC_ALLOW;
330                                 typeMask = 'a' + mask;
331                         }
332                         else if (tag->readString("deny", mask, false))
333                         {
334                                 type = CC_DENY;
335                                 typeMask = 'd' + mask;
336                         }
337                         else if (!name.empty())
338                         {
339                                 type = CC_NAMED;
340                                 mask = name;
341                                 typeMask = 'n' + mask;
342                         }
343                         else
344                         {
345                                 throw CoreException("Connect class must have allow, deny, or name specified at " + tag->getTagLocation());
346                         }
347
348                         if (name.empty())
349                         {
350                                 name = "unnamed-" + ConvToStr(i);
351                         }
352                         else
353                         {
354                                 typeMask = 'n' + name;
355                         }
356
357                         if (names.find(name) != names.end())
358                                 throw CoreException("Two connect classes with name \"" + name + "\" defined!");
359                         names[name] = i;
360
361                         ConnectClass* me = parent ? 
362                                 new ConnectClass(tag, type, mask, *parent) :
363                                 new ConnectClass(tag, type, mask);
364
365                         me->name = name;
366
367                         me->registration_timeout = tag->getInt("timeout", me->registration_timeout);
368                         me->pingtime = tag->getInt("pingfreq", me->pingtime);
369                         std::string sendq;
370                         if (tag->readString("sendq", sendq))
371                         {
372                                 // attempt to guess a good hard/soft sendq from a single value
373                                 long value = atol(sendq.c_str());
374                                 if (value > 16384)
375                                         me->softsendqmax = value / 16;
376                                 else
377                                         me->softsendqmax = value;
378                                 me->hardsendqmax = value * 8;
379                         }
380                         me->softsendqmax = tag->getInt("softsendq", me->softsendqmax);
381                         me->hardsendqmax = tag->getInt("hardsendq", me->hardsendqmax);
382                         me->recvqmax = tag->getInt("recvq", me->recvqmax);
383                         me->penaltythreshold = tag->getInt("threshold", me->penaltythreshold);
384                         me->commandrate = tag->getInt("commandrate", me->commandrate);
385                         me->fakelag = tag->getBool("fakelag", me->fakelag);
386                         me->maxlocal = tag->getInt("localmax", me->maxlocal);
387                         me->maxglobal = tag->getInt("globalmax", me->maxglobal);
388                         me->maxchans = tag->getInt("maxchans", me->maxchans);
389                         me->maxconnwarn = tag->getBool("maxconnwarn", me->maxconnwarn);
390                         me->limit = tag->getInt("limit", me->limit);
391
392                         ClassMap::iterator oldMask = oldBlocksByMask.find(typeMask);
393                         if (oldMask != oldBlocksByMask.end())
394                         {
395                                 ConnectClass* old = oldMask->second;
396                                 oldBlocksByMask.erase(oldMask);
397                                 old->Update(me);
398                                 delete me;
399                                 me = old;
400                         }
401                         Classes[i] = me;
402                 }
403         }
404 }
405
406 /** Represents a deprecated configuration tag.
407  */
408 struct Deprecated
409 {
410         /** Tag name
411          */
412         const char* tag;
413         /** Tag value
414          */
415         const char* value;
416         /** Reason for deprecation
417          */
418         const char* reason;
419 };
420
421 static const Deprecated ChangedConfig[] = {
422         {"options", "hidelinks",                "has been moved to <security:hidelinks> as of 1.2a3"},
423         {"options", "hidewhois",                "has been moved to <security:hidewhois> as of 1.2a3"},
424         {"options", "userstats",                "has been moved to <security:userstats> as of 1.2a3"},
425         {"options", "customversion",    "has been moved to <security:customversion> as of 1.2a3"},
426         {"options", "hidesplits",               "has been moved to <security:hidesplits> as of 1.2a3"},
427         {"options", "hidebans",         "has been moved to <security:hidebans> as of 1.2a3"},
428         {"options", "hidekills",                "has been moved to <security:hidekills> as of 1.2a3"},
429         {"options", "operspywhois",             "has been moved to <security:operspywhois> as of 1.2a3"},
430         {"options", "announceinvites",  "has been moved to <security:announceinvites> as of 1.2a3"},
431         {"options", "hidemodes",                "has been moved to <security:hidemodes> as of 1.2a3"},
432         {"options", "maxtargets",               "has been moved to <security:maxtargets> as of 1.2a3"},
433         {"options",     "nouserdns",            "has been moved to <performance:nouserdns> as of 1.2a3"},
434         {"options",     "maxwho",               "has been moved to <performance:maxwho> as of 1.2a3"},
435         {"options",     "softlimit",            "has been moved to <performance:softlimit> as of 1.2a3"},
436         {"options", "somaxconn",                "has been moved to <performance:somaxconn> as of 1.2a3"},
437         {"options", "netbuffersize",    "has been moved to <performance:netbuffersize> as of 1.2a3"},
438         {"options", "maxwho",           "has been moved to <performance:maxwho> as of 1.2a3"},
439         {"options",     "loglevel",             "1.2 does not use the loglevel value. Please define <log> tags instead."},
440         {"die",     "value",            "you need to reread your config"},
441 };
442
443 void ServerConfig::Fill()
444 {
445         ConfigTag* options = ConfValue("options");
446         ConfigTag* security = ConfValue("security");
447         if (sid.empty())
448         {
449                 ServerName = ConfValue("server")->getString("name");
450                 sid = ConfValue("server")->getString("id");
451                 ValidHost(ServerName, "<server:name>");
452                 if (!sid.empty() && !ServerInstance->IsSID(sid))
453                         throw CoreException(sid + " is not a valid server ID. A server ID must be 3 characters long, with the first character a digit and the next two characters a digit or letter.");
454         }
455         else
456         {
457                 if (ServerName != ConfValue("server")->getString("name"))
458                         throw CoreException("You must restart to change the server name or SID");
459                 std::string nsid = ConfValue("server")->getString("id");
460                 if (!nsid.empty() && nsid != sid)
461                         throw CoreException("You must restart to change the server name or SID");
462         }
463         diepass = ConfValue("power")->getString("diepass");
464         restartpass = ConfValue("power")->getString("restartpass");
465         powerhash = ConfValue("power")->getString("hash");
466         PrefixQuit = options->getString("prefixquit");
467         SuffixQuit = options->getString("suffixquit");
468         FixedQuit = options->getString("fixedquit");
469         PrefixPart = options->getString("prefixpart");
470         SuffixPart = options->getString("suffixpart");
471         FixedPart = options->getString("fixedpart");
472         SoftLimit = ConfValue("performance")->getInt("softlimit", ServerInstance->SE->GetMaxFds());
473         MaxConn = ConfValue("performance")->getInt("somaxconn", SOMAXCONN);
474         MoronBanner = options->getString("moronbanner", "You're banned!");
475         ServerDesc = ConfValue("server")->getString("description", "Configure Me");
476         Network = ConfValue("server")->getString("network", "Network");
477         AdminName = ConfValue("admin")->getString("name", "");
478         AdminEmail = ConfValue("admin")->getString("email", "null@example.com");
479         AdminNick = ConfValue("admin")->getString("nick", "admin");
480         ModPath = ConfValue("path")->getString("moduledir", MOD_PATH);
481         NetBufferSize = ConfValue("performance")->getInt("netbuffersize", 10240);
482         dns_timeout = ConfValue("dns")->getInt("timeout", 5);
483         DisabledCommands = ConfValue("disabled")->getString("commands", "");
484         DisabledDontExist = ConfValue("disabled")->getBool("fakenonexistant");
485         UserStats = security->getString("userstats");
486         CustomVersion = security->getString("customversion", Network + " IRCd");
487         HideSplits = security->getBool("hidesplits");
488         HideBans = security->getBool("hidebans");
489         HideWhoisServer = security->getString("hidewhois");
490         HideKillsServer = security->getString("hidekills");
491         RestrictBannedUsers = security->getBool("restrictbannedusers", true);
492         GenericOper = security->getBool("genericoper");
493         NoUserDns = ConfValue("performance")->getBool("nouserdns");
494         SyntaxHints = options->getBool("syntaxhints");
495         CycleHosts = options->getBool("cyclehosts");
496         CycleHostsFromUser = options->getBool("cyclehostsfromuser");
497         UndernetMsgPrefix = options->getBool("ircumsgprefix");
498         FullHostInTopic = options->getBool("hostintopic");
499         MaxTargets = security->getInt("maxtargets", 20);
500         DefaultModes = options->getString("defaultmodes", "nt");
501         PID = ConfValue("pid")->getString("file");
502         WhoWasGroupSize = ConfValue("whowas")->getInt("groupsize");
503         WhoWasMaxGroups = ConfValue("whowas")->getInt("maxgroups");
504         WhoWasMaxKeep = ServerInstance->Duration(ConfValue("whowas")->getString("maxkeep"));
505         MaxChans = ConfValue("channels")->getInt("users", 20);
506         OperMaxChans = ConfValue("channels")->getInt("opers", 60);
507         c_ipv4_range = ConfValue("cidr")->getInt("ipv4clone", 32);
508         c_ipv6_range = ConfValue("cidr")->getInt("ipv6clone", 128);
509         Limits.NickMax = ConfValue("limits")->getInt("maxnick", 32);
510         Limits.ChanMax = ConfValue("limits")->getInt("maxchan", 64);
511         Limits.MaxModes = ConfValue("limits")->getInt("maxmodes", 20);
512         Limits.IdentMax = ConfValue("limits")->getInt("maxident", 11);
513         Limits.MaxQuit = ConfValue("limits")->getInt("maxquit", 255);
514         Limits.MaxTopic = ConfValue("limits")->getInt("maxtopic", 307);
515         Limits.MaxKick = ConfValue("limits")->getInt("maxkick", 255);
516         Limits.MaxGecos = ConfValue("limits")->getInt("maxgecos", 128);
517         Limits.MaxAway = ConfValue("limits")->getInt("maxaway", 200);
518         InvBypassModes = options->getBool("invitebypassmodes", true);
519         NoSnoticeStack = options->getBool("nosnoticestack", false);
520
521         range(SoftLimit, 10, ServerInstance->SE->GetMaxFds(), ServerInstance->SE->GetMaxFds(), "<performance:softlimit>");
522         range(MaxConn, 0, SOMAXCONN, SOMAXCONN, "<performance:somaxconn>");
523         range(MaxTargets, 1, 31, 20, "<security:maxtargets>");
524         range(NetBufferSize, 1024, 65534, 10240, "<performance:netbuffersize>");
525         range(WhoWasGroupSize, 0, 10000, 10, "<whowas:groupsize>");
526         range(WhoWasMaxGroups, 0, 1000000, 10240, "<whowas:maxgroups>");
527         range(WhoWasMaxKeep, 3600, INT_MAX, 3600, "<whowas:maxkeep>");
528
529         ValidIP(DNSServer, "<dns:server>");
530
531         std::string defbind = options->getString("defaultbind");
532         if (assign(defbind) == "ipv4")
533         {
534                 WildcardIPv6 = false;
535         }
536         else if (assign(defbind) == "ipv6")
537         {
538                 WildcardIPv6 = true;
539         }
540         else
541         {
542                 WildcardIPv6 = true;
543                 int socktest = socket(AF_INET6, SOCK_STREAM, 0);
544                 if (socktest < 0)
545                         WildcardIPv6 = false;
546                 else
547                         ServerInstance->SE->Close(socktest);
548         }
549         ConfigTagList tags = ConfTags("uline");
550         for(ConfigIter i = tags.first; i != tags.second; ++i)
551         {
552                 ConfigTag* tag = i->second;
553                 std::string server;
554                 if (!tag->readString("server", server))
555                         throw CoreException("<uline> tag missing server at " + tag->getTagLocation());
556                 ulines[assign(server)] = tag->getBool("silent");
557         }
558
559         tags = ConfTags("banlist");
560         for(ConfigIter i = tags.first; i != tags.second; ++i)
561         {
562                 ConfigTag* tag = i->second;
563                 std::string chan;
564                 if (!tag->readString("chan", chan))
565                         throw CoreException("<banlist> tag missing chan at " + tag->getTagLocation());
566                 maxbans[chan] = tag->getInt("limit");
567         }
568
569         ReadXLine(this, "badip", "ipmask", ServerInstance->XLines->GetFactory("Z"));
570         ReadXLine(this, "badnick", "nick", ServerInstance->XLines->GetFactory("Q"));
571         ReadXLine(this, "badhost", "host", ServerInstance->XLines->GetFactory("K"));
572         ReadXLine(this, "exception", "host", ServerInstance->XLines->GetFactory("E"));
573
574         memset(DisabledUModes, 0, sizeof(DisabledUModes));
575         for (const unsigned char* p = (const unsigned char*)ConfValue("disabled")->getString("usermodes").c_str(); *p; ++p)
576         {
577                 if (*p < 'A' || *p > ('A' + 64)) throw CoreException(std::string("Invalid usermode ")+(char)*p+" was found.");
578                 DisabledUModes[*p - 'A'] = 1;
579         }
580
581         memset(DisabledCModes, 0, sizeof(DisabledCModes));
582         for (const unsigned char* p = (const unsigned char*)ConfValue("disabled")->getString("chanmodes").c_str(); *p; ++p)
583         {
584                 if (*p < 'A' || *p > ('A' + 64)) throw CoreException(std::string("Invalid chanmode ")+(char)*p+" was found.");
585                 DisabledCModes[*p - 'A'] = 1;
586         }
587
588         memset(HideModeLists, 0, sizeof(HideModeLists));
589         for (const unsigned char* p = (const unsigned char*)ConfValue("security")->getString("hidemodes").c_str(); *p; ++p)
590                 HideModeLists[*p] = true;
591
592         std::string v = security->getString("announceinvites");
593
594         if (v == "ops")
595                 AnnounceInvites = ServerConfig::INVITE_ANNOUNCE_OPS;
596         else if (v == "all")
597                 AnnounceInvites = ServerConfig::INVITE_ANNOUNCE_ALL;
598         else if (v == "dynamic")
599                 AnnounceInvites = ServerConfig::INVITE_ANNOUNCE_DYNAMIC;
600         else
601                 AnnounceInvites = ServerConfig::INVITE_ANNOUNCE_NONE;
602
603         v = security->getString("operspywhois");
604         if (v == "splitmsg")
605                 OperSpyWhois = SPYWHOIS_SPLITMSG;
606         else if (v == "on" || v == "yes")
607                 OperSpyWhois = SPYWHOIS_SINGLEMSG;
608         else
609                 OperSpyWhois = SPYWHOIS_NONE;
610
611         Limits.Finalise();
612 }
613
614 // WARNING: it is not safe to use most of the codebase in this function, as it
615 // will run in the config reader thread
616 void ServerConfig::Read()
617 {
618         /* Load and parse the config file, if there are any errors then explode */
619
620         ParseStack stack(this);
621         try
622         {
623                 valid = stack.ParseFile(ServerInstance->ConfigFileName, 0);
624         }
625         catch (CoreException& err)
626         {
627                 valid = false;
628                 errstr << err.GetReason();
629         }
630         if (valid)
631         {
632                 DNSServer = ConfValue("dns")->getString("server");
633                 FindDNS(DNSServer);
634         }
635 }
636
637 void ServerConfig::Apply(ServerConfig* old, const std::string &useruid)
638 {
639         valid = true;
640         if (old)
641         {
642                 /*
643                  * These values can only be set on boot. Keep their old values. Do it before we send messages so we actually have a servername.
644                  */
645                 this->ServerName = old->ServerName;
646                 this->sid = old->sid;
647                 this->cmdline = old->cmdline;
648         }
649
650         /* The stuff in here may throw CoreException, be sure we're in a position to catch it. */
651         try
652         {
653                 for (int Index = 0; Index * sizeof(Deprecated) < sizeof(ChangedConfig); Index++)
654                 {
655                         std::string dummy;
656                         if (ConfValue(ChangedConfig[Index].tag)->readString(ChangedConfig[Index].value, dummy, true))
657                                 errstr << "Your configuration contains a deprecated value: <"
658                                         << ChangedConfig[Index].tag << ":" << ChangedConfig[Index].value << "> - " << ChangedConfig[Index].reason
659                                         << " (at " << ConfValue(ChangedConfig[Index].tag)->getTagLocation() << ")\n";
660                 }
661
662                 Fill();
663
664                 // Handle special items
665                 CrossCheckOperClassType();
666                 CrossCheckConnectBlocks(old);
667         }
668         catch (CoreException &ce)
669         {
670                 errstr << ce.GetReason();
671         }
672
673         // Check errors before dealing with failed binds, since continuing on failed bind is wanted in some circumstances.
674         valid = errstr.str().empty();
675
676         // write once here, to try it out and make sure its ok
677         if (valid)
678                 ServerInstance->WritePID(this->PID);
679
680         if (old)
681         {
682                 // On first run, ports are bound later on
683                 FailedPortList pl;
684                 ServerInstance->BindPorts(pl);
685                 if (pl.size())
686                 {
687                         errstr << "Not all your client ports could be bound.\nThe following port(s) failed to bind:\n";
688
689                         int j = 1;
690                         for (FailedPortList::iterator i = pl.begin(); i != pl.end(); i++, j++)
691                         {
692                                 char buf[MAXBUF];
693                                 snprintf(buf, MAXBUF, "%d.   Address: %s   Reason: %s\n", j, i->first.empty() ? "<all>" : i->first.c_str(), i->second.c_str());
694                                 errstr << buf;
695                         }
696                 }
697         }
698
699         User* user = useruid.empty() ? NULL : ServerInstance->FindNick(useruid);
700
701         if (!valid)
702                 ServerInstance->Logs->Log("CONFIG",DEFAULT, "There were errors in your configuration file:");
703
704         while (errstr.good())
705         {
706                 std::string line;
707                 getline(errstr, line, '\n');
708                 if (line.empty())
709                         continue;
710                 // On startup, print out to console (still attached at this point)
711                 if (!old)
712                         printf("%s\n", line.c_str());
713                 // If a user is rehashing, tell them directly
714                 if (user)
715                         user->SendText(":%s NOTICE %s :*** %s", ServerInstance->Config->ServerName.c_str(), user->nick.c_str(), line.c_str());
716                 // Also tell opers
717                 ServerInstance->SNO->WriteGlobalSno('a', line);
718         }
719
720         errstr.clear();
721         errstr.str(std::string());
722
723         /* No old configuration -> initial boot, nothing more to do here */
724         if (!old)
725         {
726                 if (!valid)
727                 {
728                         ServerInstance->Exit(EXIT_STATUS_CONFIG);
729                 }
730
731                 return;
732         }
733
734         // If there were errors processing configuration, don't touch modules.
735         if (!valid)
736                 return;
737
738         ApplyModules(user);
739
740         if (user)
741                 user->SendText(":%s NOTICE %s :*** Successfully rehashed server.",
742                         ServerInstance->Config->ServerName.c_str(), user->nick.c_str());
743         ServerInstance->SNO->WriteGlobalSno('a', "*** Successfully rehashed server.");
744 }
745
746 void ServerConfig::ApplyModules(User* user)
747 {
748         Module* whowas = ServerInstance->Modules->Find("cmd_whowas.so");
749         if (whowas)
750                 WhowasRequest(NULL, whowas, WhowasRequest::WHOWAS_PRUNE).Send();
751
752         const std::vector<std::string> v = ServerInstance->Modules->GetAllModuleNames(0);
753         std::vector<std::string> added_modules;
754         std::set<std::string> removed_modules(v.begin(), v.end());
755
756         ConfigTagList tags = ConfTags("module");
757         for(ConfigIter i = tags.first; i != tags.second; ++i)
758         {
759                 ConfigTag* tag = i->second;
760                 std::string name;
761                 if (tag->readString("name", name))
762                 {
763                         // if this module is already loaded, the erase will succeed, so we need do nothing
764                         // otherwise, we need to add the module (which will be done later)
765                         if (removed_modules.erase(name) == 0)
766                                 added_modules.push_back(name);
767                 }
768         }
769
770         if (ConfValue("options")->getBool("allowhalfop") && removed_modules.erase("m_halfop.so") == 0)
771                 added_modules.push_back("m_halfop.so");
772
773         for (std::set<std::string>::iterator removing = removed_modules.begin(); removing != removed_modules.end(); removing++)
774         {
775                 // Don't remove cmd_*.so, just remove m_*.so
776                 if (removing->c_str()[0] == 'c')
777                         continue;
778                 Module* m = ServerInstance->Modules->Find(*removing);
779                 if (m && ServerInstance->Modules->Unload(m))
780                 {
781                         ServerInstance->SNO->WriteGlobalSno('a', "*** REHASH UNLOADED MODULE: %s",removing->c_str());
782
783                         if (user)
784                                 user->WriteNumeric(RPL_UNLOADEDMODULE, "%s %s :Module %s successfully unloaded.",user->nick.c_str(), removing->c_str(), removing->c_str());
785                         else
786                                 ServerInstance->SNO->WriteGlobalSno('a', "Module %s successfully unloaded.", removing->c_str());
787                 }
788                 else
789                 {
790                         if (user)
791                                 user->WriteNumeric(ERR_CANTUNLOADMODULE, "%s %s :Failed to unload module %s: %s",user->nick.c_str(), removing->c_str(), removing->c_str(), ServerInstance->Modules->LastError().c_str());
792                         else
793                                  ServerInstance->SNO->WriteGlobalSno('a', "Failed to unload module %s: %s", removing->c_str(), ServerInstance->Modules->LastError().c_str());
794                 }
795         }
796
797         for (std::vector<std::string>::iterator adding = added_modules.begin(); adding != added_modules.end(); adding++)
798         {
799                 if (ServerInstance->Modules->Load(adding->c_str()))
800                 {
801                         ServerInstance->SNO->WriteGlobalSno('a', "*** REHASH LOADED MODULE: %s",adding->c_str());
802                         if (user)
803                                 user->WriteNumeric(RPL_LOADEDMODULE, "%s %s :Module %s successfully loaded.",user->nick.c_str(), adding->c_str(), adding->c_str());
804                         else
805                                 ServerInstance->SNO->WriteGlobalSno('a', "Module %s successfully loaded.", adding->c_str());
806                 }
807                 else
808                 {
809                         if (user)
810                                 user->WriteNumeric(ERR_CANTLOADMODULE, "%s %s :Failed to load module %s: %s",user->nick.c_str(), adding->c_str(), adding->c_str(), ServerInstance->Modules->LastError().c_str());
811                         else
812                                 ServerInstance->SNO->WriteGlobalSno('a', "Failed to load module %s: %s", adding->c_str(), ServerInstance->Modules->LastError().c_str());
813                 }
814         }
815 }
816
817 bool ServerConfig::StartsWithWindowsDriveLetter(const std::string &path)
818 {
819         return (path.length() > 2 && isalpha(path[0]) && path[1] == ':');
820 }
821
822 ConfigTag* ServerConfig::ConfValue(const std::string &tag)
823 {
824         ConfigTagList found = config_data.equal_range(tag);
825         if (found.first == found.second)
826                 return NULL;
827         ConfigTag* rv = found.first->second;
828         found.first++;
829         if (found.first != found.second)
830                 ServerInstance->Logs->Log("CONFIG",DEFAULT, "Multiple <" + tag + "> tags found; only first will be used "
831                         "(first at " + rv->getTagLocation() + "; second at " + found.first->second->getTagLocation() + ")");
832         return rv;
833 }
834
835 ConfigTagList ServerConfig::ConfTags(const std::string& tag)
836 {
837         return config_data.equal_range(tag);
838 }
839
840 bool ServerConfig::FileExists(const char* file)
841 {
842         struct stat sb;
843         if (stat(file, &sb) == -1)
844                 return false;
845
846         if ((sb.st_mode & S_IFDIR) > 0)
847                 return false;
848
849         FILE *input = fopen(file, "r");
850         if (input == NULL)
851                 return false;
852         else
853         {
854                 fclose(input);
855                 return true;
856         }
857 }
858
859 const char* ServerConfig::CleanFilename(const char* name)
860 {
861         const char* p = name + strlen(name);
862         while ((p != name) && (*p != '/') && (*p != '\\')) p--;
863         return (p != name ? ++p : p);
864 }
865
866 std::string ServerConfig::GetSID()
867 {
868         return sid;
869 }
870
871 void ConfigReaderThread::Run()
872 {
873         Config->Read();
874         done = true;
875 }
876
877 void ConfigReaderThread::Finish()
878 {
879         ServerConfig* old = ServerInstance->Config;
880         ServerInstance->Logs->Log("CONFIG",DEBUG,"Switching to new configuration...");
881         ServerInstance->Config = this->Config;
882         Config->Apply(old, TheUserUID);
883
884         if (Config->valid)
885         {
886                 /*
887                  * Apply the changed configuration from the rehash.
888                  *
889                  * XXX: The order of these is IMPORTANT, do not reorder them without testing
890                  * thoroughly!!!
891                  */
892                 ServerInstance->XLines->CheckELines();
893                 ServerInstance->XLines->ApplyLines();
894                 ServerInstance->Res->Rehash();
895                 ServerInstance->ResetMaxBans();
896                 Config->ApplyDisabledCommands(Config->DisabledCommands);
897                 User* user = ServerInstance->FindNick(TheUserUID);
898                 FOREACH_MOD(I_OnRehash, OnRehash(user));
899                 ServerInstance->BuildISupport();
900
901                 ServerInstance->Logs->CloseLogs();
902                 ServerInstance->Logs->OpenFileLogs();
903
904                 if (Config->RawLog && !old->RawLog)
905                         ServerInstance->Users->ServerNoticeAll("*** Raw I/O logging is enabled on this server. All messages, passwords, and commands are being recorded.");
906
907                 Config = old;
908         }
909         else
910         {
911                 // whoops, abort!
912                 ServerInstance->Config = old;
913         }
914 }