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