]> git.netwichtig.de Git - user/henk/code/inspircd.git/blob - src/configreader.cpp
59a9f0d9787304f6210dff90a1391479b3b03b84
[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 "xline.h"
27 #include "listmode.h"
28 #include "exitcodes.h"
29 #include "configparser.h"
30 #include <iostream>
31
32 ServerConfig::ServerConfig()
33 {
34         RawLog = HideBans = HideSplits = UndernetMsgPrefix = false;
35         WildcardIPv6 = InvBypassModes = true;
36         dns_timeout = 5;
37         MaxTargets = 20;
38         NetBufferSize = 10240;
39         SoftLimit = ServerInstance->SE->GetMaxFds();
40         MaxConn = SOMAXCONN;
41         MaxChans = 20;
42         OperMaxChans = 30;
43         c_ipv4_range = 32;
44         c_ipv6_range = 128;
45 }
46
47 static void ValidHost(const std::string& p, const std::string& msg)
48 {
49         int num_dots = 0;
50         if (p.empty() || p[0] == '.')
51                 throw CoreException("The value of "+msg+" is not a valid hostname");
52         for (unsigned int i=0;i < p.length();i++)
53         {
54                 switch (p[i])
55                 {
56                         case ' ':
57                                 throw CoreException("The value of "+msg+" is not a valid hostname");
58                         case '.':
59                                 num_dots++;
60                         break;
61                 }
62         }
63         if (num_dots == 0)
64                 throw CoreException("The value of "+msg+" is not a valid hostname");
65 }
66
67 bool ServerConfig::ApplyDisabledCommands(const std::string& data)
68 {
69         std::stringstream dcmds(data);
70         std::string thiscmd;
71
72         /* Enable everything first */
73         for (Commandtable::iterator x = ServerInstance->Parser->cmdlist.begin(); x != ServerInstance->Parser->cmdlist.end(); x++)
74                 x->second->Disable(false);
75
76         /* Now disable all the ones which the user wants disabled */
77         while (dcmds >> thiscmd)
78         {
79                 Commandtable::iterator cm = ServerInstance->Parser->cmdlist.find(thiscmd);
80                 if (cm != ServerInstance->Parser->cmdlist.end())
81                 {
82                         cm->second->Disable(true);
83                 }
84         }
85         return true;
86 }
87
88 static void ReadXLine(ServerConfig* conf, const std::string& tag, const std::string& key, XLineFactory* make)
89 {
90         ConfigTagList tags = conf->ConfTags(tag);
91         for(ConfigIter i = tags.first; i != tags.second; ++i)
92         {
93                 ConfigTag* ctag = i->second;
94                 std::string mask;
95                 if (!ctag->readString(key, mask))
96                         throw CoreException("<"+tag+":"+key+"> missing at " + ctag->getTagLocation());
97                 std::string reason = ctag->getString("reason", "<Config>");
98                 XLine* xl = make->Generate(ServerInstance->Time(), 0, "<Config>", reason, mask);
99                 if (!ServerInstance->XLines->AddLine(xl, NULL))
100                         delete xl;
101         }
102 }
103
104 typedef std::map<std::string, ConfigTag*> LocalIndex;
105 void ServerConfig::CrossCheckOperClassType()
106 {
107         LocalIndex operclass;
108         ConfigTagList tags = ConfTags("class");
109         for(ConfigIter i = tags.first; i != tags.second; ++i)
110         {
111                 ConfigTag* tag = i->second;
112                 std::string name = tag->getString("name");
113                 if (name.empty())
114                         throw CoreException("<class:name> missing from tag at " + tag->getTagLocation());
115                 if (operclass.find(name) != operclass.end())
116                         throw CoreException("Duplicate class block with name " + name + " at " + tag->getTagLocation());
117                 operclass[name] = tag;
118         }
119         tags = ConfTags("type");
120         for(ConfigIter i = tags.first; i != tags.second; ++i)
121         {
122                 ConfigTag* tag = i->second;
123                 std::string name = tag->getString("name");
124                 if (name.empty())
125                         throw CoreException("<type:name> is missing from tag at " + tag->getTagLocation());
126                 if (OperTypes.find(name) != OperTypes.end())
127                         throw CoreException("Duplicate type block with name " + name + " at " + tag->getTagLocation());
128
129                 OperInfo* ifo = new OperInfo;
130                 OperTypes[name] = ifo;
131                 ifo->name = name;
132                 ifo->type_block = tag;
133
134                 std::string classname;
135                 irc::spacesepstream str(tag->getString("classes"));
136                 while (str.GetToken(classname))
137                 {
138                         LocalIndex::iterator cls = operclass.find(classname);
139                         if (cls == operclass.end())
140                                 throw CoreException("Oper type " + name + " has missing class " + classname);
141                         ifo->class_blocks.push_back(cls->second);
142                 }
143         }
144
145         tags = ConfTags("oper");
146         for(ConfigIter i = tags.first; i != tags.second; ++i)
147         {
148                 ConfigTag* tag = i->second;
149
150                 std::string name = tag->getString("name");
151                 if (name.empty())
152                         throw CoreException("<oper:name> missing from tag at " + tag->getTagLocation());
153
154                 std::string type = tag->getString("type");
155                 OperIndex::iterator tblk = OperTypes.find(type);
156                 if (tblk == OperTypes.end())
157                         throw CoreException("Oper block " + name + " has missing type " + type);
158                 if (oper_blocks.find(name) != oper_blocks.end())
159                         throw CoreException("Duplicate oper block with name " + name + " at " + tag->getTagLocation());
160
161                 OperInfo* ifo = new OperInfo;
162                 ifo->name = type;
163                 ifo->oper_block = tag;
164                 ifo->type_block = tblk->second->type_block;
165                 ifo->class_blocks.assign(tblk->second->class_blocks.begin(), tblk->second->class_blocks.end());
166                 oper_blocks[name] = ifo;
167         }
168 }
169
170 void ServerConfig::CrossCheckConnectBlocks(ServerConfig* current)
171 {
172         typedef std::map<std::string, ConnectClass*> ClassMap;
173         ClassMap oldBlocksByMask;
174         if (current)
175         {
176                 for(ClassVector::iterator i = current->Classes.begin(); i != current->Classes.end(); ++i)
177                 {
178                         ConnectClass* c = *i;
179                         if (c->name.substr(0, 8) != "unnamed-")
180                         {
181                                 oldBlocksByMask["n" + c->name] = c;
182                         }
183                         else if (c->type == CC_ALLOW || c->type == CC_DENY)
184                         {
185                                 std::string typeMask = (c->type == CC_ALLOW) ? "a" : "d";
186                                 typeMask += c->host;
187                                 oldBlocksByMask[typeMask] = c;
188                         }
189                 }
190         }
191
192         int blk_count = config_data.count("connect");
193         if (blk_count == 0)
194         {
195                 // No connect blocks found; make a trivial default block
196                 std::vector<KeyVal>* items;
197                 ConfigTag* tag = ConfigTag::create("connect", "<auto>", 0, items);
198                 items->push_back(std::make_pair("allow", "*"));
199                 config_data.insert(std::make_pair("connect", tag));
200                 blk_count = 1;
201         }
202
203         Classes.resize(blk_count);
204         std::map<std::string, int> names;
205
206         bool try_again = true;
207         for(int tries=0; try_again; tries++)
208         {
209                 try_again = false;
210                 ConfigTagList tags = ConfTags("connect");
211                 int i=0;
212                 for(ConfigIter it = tags.first; it != tags.second; ++it, ++i)
213                 {
214                         ConfigTag* tag = it->second;
215                         if (Classes[i])
216                                 continue;
217
218                         ConnectClass* parent = NULL;
219                         std::string parentName = tag->getString("parent");
220                         if (!parentName.empty())
221                         {
222                                 std::map<std::string,int>::iterator parentIter = names.find(parentName);
223                                 if (parentIter == names.end())
224                                 {
225                                         try_again = true;
226                                         // couldn't find parent this time. If it's the last time, we'll never find it.
227                                         if (tries >= blk_count)
228                                                 throw CoreException("Could not find parent connect class \"" + parentName + "\" for connect block at " + tag->getTagLocation());
229                                         continue;
230                                 }
231                                 parent = Classes[parentIter->second];
232                         }
233
234                         std::string name = tag->getString("name");
235                         std::string mask, typeMask;
236                         char type;
237
238                         if (tag->readString("allow", mask, false))
239                         {
240                                 type = CC_ALLOW;
241                                 typeMask = 'a' + mask;
242                         }
243                         else if (tag->readString("deny", mask, false))
244                         {
245                                 type = CC_DENY;
246                                 typeMask = 'd' + mask;
247                         }
248                         else if (!name.empty())
249                         {
250                                 type = CC_NAMED;
251                                 mask = name;
252                                 typeMask = 'n' + mask;
253                         }
254                         else
255                         {
256                                 throw CoreException("Connect class must have allow, deny, or name specified at " + tag->getTagLocation());
257                         }
258
259                         if (name.empty())
260                         {
261                                 name = "unnamed-" + ConvToStr(i);
262                         }
263                         else
264                         {
265                                 typeMask = 'n' + name;
266                         }
267
268                         if (names.find(name) != names.end())
269                                 throw CoreException("Two connect classes with name \"" + name + "\" defined!");
270                         names[name] = i;
271
272                         ConnectClass* me = parent ?
273                                 new ConnectClass(tag, type, mask, *parent) :
274                                 new ConnectClass(tag, type, mask);
275
276                         me->name = name;
277
278                         me->registration_timeout = tag->getInt("timeout", me->registration_timeout);
279                         me->pingtime = tag->getInt("pingfreq", me->pingtime);
280                         std::string sendq;
281                         if (tag->readString("sendq", sendq))
282                         {
283                                 // attempt to guess a good hard/soft sendq from a single value
284                                 long value = atol(sendq.c_str());
285                                 if (value > 16384)
286                                         me->softsendqmax = value / 16;
287                                 else
288                                         me->softsendqmax = value;
289                                 me->hardsendqmax = value * 8;
290                         }
291                         me->softsendqmax = tag->getInt("softsendq", me->softsendqmax);
292                         me->hardsendqmax = tag->getInt("hardsendq", me->hardsendqmax);
293                         me->recvqmax = tag->getInt("recvq", me->recvqmax);
294                         me->penaltythreshold = tag->getInt("threshold", me->penaltythreshold);
295                         me->commandrate = tag->getInt("commandrate", me->commandrate);
296                         me->fakelag = tag->getBool("fakelag", me->fakelag);
297                         me->maxlocal = tag->getInt("localmax", me->maxlocal);
298                         me->maxglobal = tag->getInt("globalmax", me->maxglobal);
299                         me->maxchans = tag->getInt("maxchans", me->maxchans);
300                         me->maxconnwarn = tag->getBool("maxconnwarn", me->maxconnwarn);
301                         me->limit = tag->getInt("limit", me->limit);
302                         me->resolvehostnames = tag->getBool("resolvehostnames", me->resolvehostnames);
303
304                         ClassMap::iterator oldMask = oldBlocksByMask.find(typeMask);
305                         if (oldMask != oldBlocksByMask.end())
306                         {
307                                 ConnectClass* old = oldMask->second;
308                                 oldBlocksByMask.erase(oldMask);
309                                 old->Update(me);
310                                 delete me;
311                                 me = old;
312                         }
313                         Classes[i] = me;
314                 }
315         }
316 }
317
318 /** Represents a deprecated configuration tag.
319  */
320 struct DeprecatedConfig
321 {
322         /** Tag name. */
323         std::string tag;
324
325         /** Attribute key. */
326         std::string key;
327
328         /** Attribute value. */
329         std::string value;
330
331         /** Reason for deprecation. */
332         std::string reason;
333 };
334
335 static const DeprecatedConfig ChangedConfig[] = {
336         { "bind",        "transport",   "",                 "has been moved to <bind:ssl> as of 2.0" },
337         { "die",         "value",       "",                 "you need to reread your config" },
338         { "gnutls",      "starttls",    "",                 "has been replaced with m_starttls as of 2.2" },
339         { "link",        "autoconnect", "",                 "2.0+ does not use this attribute - define <autoconnect> tags instead" },
340         { "link",        "transport",   "",                 "has been moved to <link:ssl> as of 2.0" },
341         { "module",      "name",        "m_chanprotect.so", "has been replaced with m_customprefix as of 2.2" },
342         { "module",      "name",        "m_halfop.so",      "has been replaced with m_customprefix as of 2.2" },
343         { "options",     "cyclehosts",  "",                 "has been replaced with m_hostcycle as of 2.2" },
344         { "performance", "nouserdns",   "",                 "has been moved to <connect:resolvehostnames> as of 2.2" }
345 };
346
347 void ServerConfig::Fill()
348 {
349         ConfigTag* options = ConfValue("options");
350         ConfigTag* security = ConfValue("security");
351         if (sid.empty())
352         {
353                 ServerName = ConfValue("server")->getString("name", "irc.example.com");
354                 ValidHost(ServerName, "<server:name>");
355
356                 sid = ConfValue("server")->getString("id");
357                 if (!sid.empty() && !InspIRCd::IsSID(sid))
358                         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.");
359         }
360         else
361         {
362                 if (ServerName != ConfValue("server")->getString("name"))
363                         throw CoreException("You must restart to change the server name");
364
365                 std::string nsid = ConfValue("server")->getString("id");
366                 if (!nsid.empty() && nsid != sid)
367                         throw CoreException("You must restart to change the server id");
368         }
369         diepass = ConfValue("power")->getString("diepass");
370         restartpass = ConfValue("power")->getString("restartpass");
371         powerhash = ConfValue("power")->getString("hash");
372         PrefixQuit = options->getString("prefixquit");
373         SuffixQuit = options->getString("suffixquit");
374         FixedQuit = options->getString("fixedquit");
375         PrefixPart = options->getString("prefixpart");
376         SuffixPart = options->getString("suffixpart");
377         FixedPart = options->getString("fixedpart");
378         SoftLimit = ConfValue("performance")->getInt("softlimit", ServerInstance->SE->GetMaxFds(), 10, ServerInstance->SE->GetMaxFds());
379         CCOnConnect = ConfValue("performance")->getBool("clonesonconnect", true);
380         MaxConn = ConfValue("performance")->getInt("somaxconn", SOMAXCONN);
381         XLineMessage = options->getString("xlinemessage", options->getString("moronbanner", "You're banned!"));
382         ServerDesc = ConfValue("server")->getString("description", "Configure Me");
383         Network = ConfValue("server")->getString("network", "Network");
384         AdminName = ConfValue("admin")->getString("name", "");
385         AdminEmail = ConfValue("admin")->getString("email", "null@example.com");
386         AdminNick = ConfValue("admin")->getString("nick", "admin");
387         NetBufferSize = ConfValue("performance")->getInt("netbuffersize", 10240, 1024, 65534);
388         dns_timeout = ConfValue("dns")->getInt("timeout", 5);
389         DisabledCommands = ConfValue("disabled")->getString("commands", "");
390         DisabledDontExist = ConfValue("disabled")->getBool("fakenonexistant");
391         UserStats = security->getString("userstats");
392         CustomVersion = security->getString("customversion");
393         HideSplits = security->getBool("hidesplits");
394         HideBans = security->getBool("hidebans");
395         HideWhoisServer = security->getString("hidewhois");
396         HideKillsServer = security->getString("hidekills");
397         RestrictBannedUsers = security->getBool("restrictbannedusers", true);
398         GenericOper = security->getBool("genericoper");
399         SyntaxHints = options->getBool("syntaxhints");
400         CycleHostsFromUser = options->getBool("cyclehostsfromuser");
401         UndernetMsgPrefix = options->getBool("ircumsgprefix");
402         FullHostInTopic = options->getBool("hostintopic");
403         MaxTargets = security->getInt("maxtargets", 20, 1, 31);
404         DefaultModes = options->getString("defaultmodes", "not");
405         PID = ConfValue("pid")->getString("file");
406         MaxChans = ConfValue("channels")->getInt("users", 20);
407         OperMaxChans = ConfValue("channels")->getInt("opers", 60);
408         c_ipv4_range = ConfValue("cidr")->getInt("ipv4clone", 32);
409         c_ipv6_range = ConfValue("cidr")->getInt("ipv6clone", 128);
410         Limits.NickMax = ConfValue("limits")->getInt("maxnick", 32);
411         Limits.ChanMax = ConfValue("limits")->getInt("maxchan", 64);
412         Limits.MaxModes = ConfValue("limits")->getInt("maxmodes", 20);
413         Limits.IdentMax = ConfValue("limits")->getInt("maxident", 11);
414         Limits.MaxQuit = ConfValue("limits")->getInt("maxquit", 255);
415         Limits.MaxTopic = ConfValue("limits")->getInt("maxtopic", 307);
416         Limits.MaxKick = ConfValue("limits")->getInt("maxkick", 255);
417         Limits.MaxGecos = ConfValue("limits")->getInt("maxgecos", 128);
418         Limits.MaxAway = ConfValue("limits")->getInt("maxaway", 200);
419         Limits.MaxLine = ConfValue("limits")->getInt("maxline", 512);
420         Paths.Config = ConfValue("path")->getString("configdir", CONFIG_PATH);
421         Paths.Data = ConfValue("path")->getString("datadir", DATA_PATH);
422         Paths.Log = ConfValue("path")->getString("logdir", LOG_PATH);
423         Paths.Module = ConfValue("path")->getString("moduledir", MOD_PATH);
424         InvBypassModes = options->getBool("invitebypassmodes", true);
425         NoSnoticeStack = options->getBool("nosnoticestack", false);
426
427         if (Network.find(' ') != std::string::npos)
428                 throw CoreException(Network + " is not a valid network name. A network name must not contain spaces.");
429
430         std::string defbind = options->getString("defaultbind");
431         if (assign(defbind) == "ipv4")
432         {
433                 WildcardIPv6 = false;
434         }
435         else if (assign(defbind) == "ipv6")
436         {
437                 WildcardIPv6 = true;
438         }
439         else
440         {
441                 WildcardIPv6 = true;
442                 int socktest = socket(AF_INET6, SOCK_STREAM, 0);
443                 if (socktest < 0)
444                         WildcardIPv6 = false;
445                 else
446                         SocketEngine::Close(socktest);
447         }
448
449         ReadXLine(this, "badip", "ipmask", ServerInstance->XLines->GetFactory("Z"));
450         ReadXLine(this, "badnick", "nick", ServerInstance->XLines->GetFactory("Q"));
451         ReadXLine(this, "badhost", "host", ServerInstance->XLines->GetFactory("K"));
452         ReadXLine(this, "exception", "host", ServerInstance->XLines->GetFactory("E"));
453
454         memset(DisabledUModes, 0, sizeof(DisabledUModes));
455         std::string modes = ConfValue("disabled")->getString("usermodes");
456         for (std::string::const_iterator p = modes.begin(); p != modes.end(); ++p)
457         {
458                 // Complain when the character is not a-z or A-Z
459                 if ((*p < 'A') || (*p > 'z') || ((*p < 'a') && (*p > 'Z')))
460                         throw CoreException("Invalid usermode " + std::string(1, *p) + " was found.");
461                 DisabledUModes[*p - 'A'] = 1;
462         }
463
464         memset(DisabledCModes, 0, sizeof(DisabledCModes));
465         modes = ConfValue("disabled")->getString("chanmodes");
466         for (std::string::const_iterator p = modes.begin(); p != modes.end(); ++p)
467         {
468                 if ((*p < 'A') || (*p > 'z') || ((*p < 'a') && (*p > 'Z')))
469                         throw CoreException("Invalid chanmode " + std::string(1, *p) + " was found.");
470                 DisabledCModes[*p - 'A'] = 1;
471         }
472
473         memset(HideModeLists, 0, sizeof(HideModeLists));
474         modes = ConfValue("security")->getString("hidemodes");
475         for (std::string::const_iterator p = modes.begin(); p != modes.end(); ++p)
476                 HideModeLists[(unsigned char) *p] = true;
477
478         std::string v = security->getString("announceinvites");
479
480         if (v == "ops")
481                 AnnounceInvites = ServerConfig::INVITE_ANNOUNCE_OPS;
482         else if (v == "all")
483                 AnnounceInvites = ServerConfig::INVITE_ANNOUNCE_ALL;
484         else if (v == "dynamic")
485                 AnnounceInvites = ServerConfig::INVITE_ANNOUNCE_DYNAMIC;
486         else
487                 AnnounceInvites = ServerConfig::INVITE_ANNOUNCE_NONE;
488
489         v = security->getString("operspywhois");
490         if (v == "splitmsg")
491                 OperSpyWhois = SPYWHOIS_SPLITMSG;
492         else if (v == "on" || v == "yes")
493                 OperSpyWhois = SPYWHOIS_SINGLEMSG;
494         else
495                 OperSpyWhois = SPYWHOIS_NONE;
496 }
497
498 // WARNING: it is not safe to use most of the codebase in this function, as it
499 // will run in the config reader thread
500 void ServerConfig::Read()
501 {
502         /* Load and parse the config file, if there are any errors then explode */
503
504         ParseStack stack(this);
505         try
506         {
507                 valid = stack.ParseFile(ServerInstance->ConfigFileName, 0);
508         }
509         catch (CoreException& err)
510         {
511                 valid = false;
512                 errstr << err.GetReason() << std::endl;
513         }
514 }
515
516 void ServerConfig::Apply(ServerConfig* old, const std::string &useruid)
517 {
518         valid = true;
519         if (old)
520         {
521                 /*
522                  * These values can only be set on boot. Keep their old values. Do it before we send messages so we actually have a servername.
523                  */
524                 this->ServerName = old->ServerName;
525                 this->sid = old->sid;
526                 this->cmdline = old->cmdline;
527         }
528
529         /* The stuff in here may throw CoreException, be sure we're in a position to catch it. */
530         try
531         {
532                 for (int index = 0; index * sizeof(DeprecatedConfig) < sizeof(ChangedConfig); index++)
533                 {
534                         std::string value;
535                         ConfigTagList tags = ConfTags(ChangedConfig[index].tag);
536                         for(ConfigIter i = tags.first; i != tags.second; ++i)
537                         {
538                                 if (i->second->readString(ChangedConfig[index].key, value, true)
539                                         && (ChangedConfig[index].value.empty() || value == ChangedConfig[index].value))
540                                 {
541                                         errstr << "Your configuration contains a deprecated value: <"  << ChangedConfig[index].tag;
542                                         if (ChangedConfig[index].value.empty())
543                                         {
544                                                 errstr << ':' << ChangedConfig[index].key;
545                                         }
546                                         else
547                                         {
548                                                 errstr << ' ' << ChangedConfig[index].key << "=\"" << ChangedConfig[index].value << "\"";
549                                         }
550                                         errstr << "> - " << ChangedConfig[index].reason << " (at " << i->second->getTagLocation() << ")" << std::endl;
551                                 }
552                         }
553                 }
554
555                 Fill();
556
557                 // Handle special items
558                 CrossCheckOperClassType();
559                 CrossCheckConnectBlocks(old);
560         }
561         catch (CoreException &ce)
562         {
563                 errstr << ce.GetReason();
564         }
565
566         // Check errors before dealing with failed binds, since continuing on failed bind is wanted in some circumstances.
567         valid = errstr.str().empty();
568
569         // write once here, to try it out and make sure its ok
570         if (valid)
571                 ServerInstance->WritePID(this->PID);
572
573         ConfigTagList binds = ConfTags("bind");
574         if (binds.first == binds.second)
575                  errstr << "Possible configuration error: you have not defined any <bind> blocks." << std::endl
576                          << "You will need to do this if you want clients to be able to connect!" << std::endl;
577
578         if (old)
579         {
580                 // On first run, ports are bound later on
581                 FailedPortList pl;
582                 ServerInstance->BindPorts(pl);
583                 if (pl.size())
584                 {
585                         errstr << "Not all your client ports could be bound." << std::endl
586                                 << "The following port(s) failed to bind:" << std::endl;
587
588                         int j = 1;
589                         for (FailedPortList::iterator i = pl.begin(); i != pl.end(); i++, j++)
590                         {
591                                 errstr << j << ".\tAddress: " << (i->first.empty() ? "<all>" : i->first.c_str()) << "\tReason: "
592                                         << i->second << std::endl;
593                         }
594                 }
595         }
596
597         User* user = useruid.empty() ? NULL : ServerInstance->FindNick(useruid);
598
599         if (!valid)
600                 ServerInstance->Logs->Log("CONFIG", LOG_DEFAULT, "There were errors in your configuration file:");
601
602         while (errstr.good())
603         {
604                 std::string line;
605                 getline(errstr, line, '\n');
606                 if (line.empty())
607                         continue;
608                 // On startup, print out to console (still attached at this point)
609                 if (!old)
610                         std::cout << line << std::endl;
611                 // If a user is rehashing, tell them directly
612                 if (user)
613                         user->SendText(":%s NOTICE %s :*** %s", ServerInstance->Config->ServerName.c_str(), user->nick.c_str(), line.c_str());
614                 // Also tell opers
615                 ServerInstance->SNO->WriteGlobalSno('a', line);
616         }
617
618         errstr.clear();
619         errstr.str(std::string());
620
621         // Re-parse our MOTD and RULES files for colors -- Justasic
622         for (ClassVector::const_iterator it = this->Classes.begin(), it_end = this->Classes.end(); it != it_end; ++it)
623         {
624                 ConfigTag *tag = (*it)->config;
625                 // Make sure our connection class allows motd colors
626                 if(!tag->getBool("allowmotdcolors"))
627                       continue;
628
629                 ConfigFileCache::iterator file = this->Files.find(tag->getString("motd", "motd"));
630                 if (file != this->Files.end())
631                       InspIRCd::ProcessColors(file->second);
632         }
633
634         /* No old configuration -> initial boot, nothing more to do here */
635         if (!old)
636         {
637                 if (!valid)
638                 {
639                         ServerInstance->Exit(EXIT_STATUS_CONFIG);
640                 }
641
642                 return;
643         }
644
645
646         // If there were errors processing configuration, don't touch modules.
647         if (!valid)
648                 return;
649
650         ApplyModules(user);
651
652         if (user)
653                 user->SendText(":%s NOTICE %s :*** Successfully rehashed server.",
654                         ServerInstance->Config->ServerName.c_str(), user->nick.c_str());
655         ServerInstance->SNO->WriteGlobalSno('a', "*** Successfully rehashed server.");
656 }
657
658 void ServerConfig::ApplyModules(User* user)
659 {
660         std::vector<std::string> added_modules;
661         ModuleManager::ModuleMap removed_modules = ServerInstance->Modules->GetModules();
662
663         ConfigTagList tags = ConfTags("module");
664         for(ConfigIter i = tags.first; i != tags.second; ++i)
665         {
666                 ConfigTag* tag = i->second;
667                 std::string name;
668                 if (tag->readString("name", name))
669                 {
670                         // if this module is already loaded, the erase will succeed, so we need do nothing
671                         // otherwise, we need to add the module (which will be done later)
672                         if (removed_modules.erase(name) == 0)
673                                 added_modules.push_back(name);
674                 }
675         }
676
677         for (ModuleManager::ModuleMap::iterator i = removed_modules.begin(); i != removed_modules.end(); ++i)
678         {
679                 const std::string& modname = i->first;
680                 // Don't remove cmd_*.so, just remove m_*.so
681                 if (modname.c_str()[0] == 'c')
682                         continue;
683                 if (ServerInstance->Modules->Unload(i->second))
684                 {
685                         ServerInstance->SNO->WriteGlobalSno('a', "*** REHASH UNLOADED MODULE: %s", modname.c_str());
686
687                         if (user)
688                                 user->WriteNumeric(RPL_UNLOADEDMODULE, "%s :Module %s successfully unloaded.", modname.c_str(), modname.c_str());
689                         else
690                                 ServerInstance->SNO->WriteGlobalSno('a', "Module %s successfully unloaded.", modname.c_str());
691                 }
692                 else
693                 {
694                         if (user)
695                                 user->WriteNumeric(ERR_CANTUNLOADMODULE, "%s :Failed to unload module %s: %s", modname.c_str(), modname.c_str(), ServerInstance->Modules->LastError().c_str());
696                         else
697                                  ServerInstance->SNO->WriteGlobalSno('a', "Failed to unload module %s: %s", modname.c_str(), ServerInstance->Modules->LastError().c_str());
698                 }
699         }
700
701         for (std::vector<std::string>::iterator adding = added_modules.begin(); adding != added_modules.end(); adding++)
702         {
703                 if (ServerInstance->Modules->Load(adding->c_str()))
704                 {
705                         ServerInstance->SNO->WriteGlobalSno('a', "*** REHASH LOADED MODULE: %s",adding->c_str());
706                         if (user)
707                                 user->WriteNumeric(RPL_LOADEDMODULE, "%s :Module %s successfully loaded.", adding->c_str(), adding->c_str());
708                         else
709                                 ServerInstance->SNO->WriteGlobalSno('a', "Module %s successfully loaded.", adding->c_str());
710                 }
711                 else
712                 {
713                         if (user)
714                                 user->WriteNumeric(ERR_CANTLOADMODULE, "%s :Failed to load module %s: %s", adding->c_str(), adding->c_str(), ServerInstance->Modules->LastError().c_str());
715                         else
716                                 ServerInstance->SNO->WriteGlobalSno('a', "Failed to load module %s: %s", adding->c_str(), ServerInstance->Modules->LastError().c_str());
717                 }
718         }
719 }
720
721 ConfigTag* ServerConfig::ConfValue(const std::string &tag)
722 {
723         ConfigTagList found = config_data.equal_range(tag);
724         if (found.first == found.second)
725                 return NULL;
726         ConfigTag* rv = found.first->second;
727         found.first++;
728         if (found.first != found.second)
729                 ServerInstance->Logs->Log("CONFIG", LOG_DEFAULT, "Multiple <" + tag + "> tags found; only first will be used "
730                         "(first at " + rv->getTagLocation() + "; second at " + found.first->second->getTagLocation() + ")");
731         return rv;
732 }
733
734 ConfigTagList ServerConfig::ConfTags(const std::string& tag)
735 {
736         return config_data.equal_range(tag);
737 }
738
739 std::string ServerConfig::Escape(const std::string& str, bool xml)
740 {
741         std::string escaped;
742         for (std::string::const_iterator it = str.begin(); it != str.end(); ++it)
743         {
744                 switch (*it)
745                 {
746                         case '"':
747                                 escaped += xml ? "&quot;" : "\"";
748                                 break;
749                         case '&':
750                                 escaped += xml ? "&amp;" : "&";
751                                 break;
752                         case '\\':
753                                 escaped += xml ? "\\" : "\\\\";
754                                 break;
755                         default:
756                                 escaped += *it;
757                                 break;
758                 }
759         }
760         return escaped;
761 }
762
763 void ConfigReaderThread::Run()
764 {
765         Config->Read();
766         done = true;
767 }
768
769 void ConfigReaderThread::Finish()
770 {
771         ServerConfig* old = ServerInstance->Config;
772         ServerInstance->Logs->Log("CONFIG", LOG_DEBUG, "Switching to new configuration...");
773         ServerInstance->Config = this->Config;
774         Config->Apply(old, TheUserUID);
775
776         if (Config->valid)
777         {
778                 /*
779                  * Apply the changed configuration from the rehash.
780                  *
781                  * XXX: The order of these is IMPORTANT, do not reorder them without testing
782                  * thoroughly!!!
783                  */
784                 ServerInstance->XLines->CheckELines();
785                 ServerInstance->XLines->ApplyLines();
786                 ChanModeReference ban(NULL, "ban");
787                 static_cast<ListModeBase*>(*ban)->DoRehash();
788                 Config->ApplyDisabledCommands(Config->DisabledCommands);
789                 User* user = ServerInstance->FindNick(TheUserUID);
790
791                 ConfigStatus status(user);
792                 const ModuleManager::ModuleMap& mods = ServerInstance->Modules->GetModules();
793                 for (ModuleManager::ModuleMap::const_iterator i = mods.begin(); i != mods.end(); ++i)
794                         i->second->ReadConfig(status);
795
796                 ServerInstance->ISupport.Build();
797
798                 ServerInstance->Logs->CloseLogs();
799                 ServerInstance->Logs->OpenFileLogs();
800
801                 if (Config->RawLog && !old->RawLog)
802                         ServerInstance->Users->ServerNoticeAll("*** Raw I/O logging is enabled on this server. All messages, passwords, and commands are being recorded.");
803
804                 Config = old;
805         }
806         else
807         {
808                 // whoops, abort!
809                 ServerInstance->Config = old;
810         }
811 }