src/modules/m_spanningtree/main.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 Craig Edwards <craigedwards@brainbox.cc>
   6  *   Copyright (C) 2007-2008 Robin Burchell <robin+git@viroteck.net>
   7  *   Copyright (C) 2008 Thomas Stagner <aquanight@inspircd.org>
   8  *   Copyright (C) 2007 Dennis Friis <peavey@inspircd.org>
   9  *
  10  * This file is part of InspIRCd.  InspIRCd is free software: you can
  11  * redistribute it and/or modify it under the terms of the GNU General Public
  12  * License as published by the Free Software Foundation, version 2.
  13  *
  14  * This program is distributed in the hope that it will be useful, but WITHOUT
  15  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  16  * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
  17  * details.
  18  *
  19  * You should have received a copy of the GNU General Public License
  20  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  21  */
  22
  23
  24 #include "inspircd.h"
  25 #include "socket.h"
  26 #include "xline.h"
  27 #include "iohook.h"
  28
  29 #include "resolvers.h"
  30 #include "main.h"
  31 #include "utils.h"
  32 #include "treeserver.h"
  33 #include "link.h"
  34 #include "treesocket.h"
  35 #include "commands.h"
  36 #include "protocolinterface.h"
  37
  38 ModuleSpanningTree::ModuleSpanningTree()
  39         : commands(NULL), DNS(this, "DNS")
  40 {
  41 }
  42
  43 SpanningTreeCommands::SpanningTreeCommands(ModuleSpanningTree* module)
  44         : rconnect(module), rsquit(module),
  45         svsjoin(module), svspart(module), svsnick(module), metadata(module),
  46         uid(module), opertype(module), fjoin(module), ijoin(module), resync(module),
  47         fmode(module), ftopic(module), fhost(module), fident(module), fname(module),
  48         away(module), addline(module), delline(module), encap(module), idle(module),
  49         nick(module), ping(module), pong(module), push(module), save(module),
  50         server(module), squit(module), snonotice(module), version(module),
  51         burst(module), endburst(module)
  52 {
  53 }
  54
  55 void ModuleSpanningTree::init()
  56 {
  57         ServerInstance->SNO->EnableSnomask('l', "LINK");
  58
  59         Utils = new SpanningTreeUtilities(this);
  60         Utils->TreeRoot = new TreeServer;
  61         commands = new SpanningTreeCommands(this);
  62         ServerInstance->Modules->AddService(commands->rconnect);
  63         ServerInstance->Modules->AddService(commands->rsquit);
  64
  65         delete ServerInstance->PI;
  66         ServerInstance->PI = new SpanningTreeProtocolInterface(Utils);
  67         loopCall = false;
  68
  69         // update our local user count
  70         Utils->TreeRoot->UserCount = ServerInstance->Users->local_users.size();
  71 }
  72
  73 void ModuleSpanningTree::ShowLinks(TreeServer* Current, User* user, int hops)
  74 {
  75         std::string Parent = Utils->TreeRoot->GetName();
  76         if (Current->GetParent())
  77         {
  78                 Parent = Current->GetParent()->GetName();
  79         }
  80         for (unsigned int q = 0; q < Current->ChildCount(); q++)
  81         {
  82                 if ((Current->GetChild(q)->Hidden) || ((Utils->HideULines) && (ServerInstance->ULine(Current->GetChild(q)->GetName()))))
  83                 {
  84                         if (user->IsOper())
  85                         {
  86                                  ShowLinks(Current->GetChild(q),user,hops+1);
  87                         }
  88                 }
  89                 else
  90                 {
  91                         ShowLinks(Current->GetChild(q),user,hops+1);
  92                 }
  93         }
  94         /* Don't display the line if its a uline, hide ulines is on, and the user isnt an oper */
  95         if ((Utils->HideULines) && (ServerInstance->ULine(Current->GetName())) && (!user->IsOper()))
  96                 return;
  97         /* Or if the server is hidden and they're not an oper */
  98         else if ((Current->Hidden) && (!user->IsOper()))
  99                 return;
 100
 101         user->WriteNumeric(364, "%s %s %s :%d %s",      user->nick.c_str(), Current->GetName().c_str(),
 102                         (Utils->FlatLinks && (!user->IsOper())) ? ServerInstance->Config->ServerName.c_str() : Parent.c_str(),
 103                         (Utils->FlatLinks && (!user->IsOper())) ? 0 : hops,
 104                         Current->GetDesc().c_str());
 105 }
 106
 107 int ModuleSpanningTree::CountServs()
 108 {
 109         return Utils->serverlist.size();
 110 }
 111
 112 void ModuleSpanningTree::HandleLinks(const std::vector<std::string>& parameters, User* user)
 113 {
 114         ShowLinks(Utils->TreeRoot,user,0);
 115         user->WriteNumeric(365, "%s * :End of /LINKS list.",user->nick.c_str());
 116         return;
 117 }
 118
 119 std::string ModuleSpanningTree::TimeToStr(time_t secs)
 120 {
 121         time_t mins_up = secs / 60;
 122         time_t hours_up = mins_up / 60;
 123         time_t days_up = hours_up / 24;
 124         secs = secs % 60;
 125         mins_up = mins_up % 60;
 126         hours_up = hours_up % 24;
 127         return ((days_up ? (ConvToStr(days_up) + "d") : "")
 128                         + (hours_up ? (ConvToStr(hours_up) + "h") : "")
 129                         + (mins_up ? (ConvToStr(mins_up) + "m") : "")
 130                         + ConvToStr(secs) + "s");
 131 }
 132
 133 void ModuleSpanningTree::DoPingChecks(time_t curtime)
 134 {
 135         /*
 136          * Cancel remote burst mode on any servers which still have it enabled due to latency/lack of data.
 137          * This prevents lost REMOTECONNECT notices
 138          */
 139         long ts = ServerInstance->Time() * 1000 + (ServerInstance->Time_ns() / 1000000);
 140
 141 restart:
 142         for (server_hash::iterator i = Utils->serverlist.begin(); i != Utils->serverlist.end(); i++)
 143         {
 144                 TreeServer *s = i->second;
 145
 146                 if (s->GetSocket() && s->GetSocket()->GetLinkState() == DYING)
 147                 {
 148                         s->GetSocket()->Close();
 149                         goto restart;
 150                 }
 151
 152                 // Fix for bug #792, do not ping servers that are not connected yet!
 153                 // Remote servers have Socket == NULL and local connected servers have
 154                 // Socket->LinkState == CONNECTED
 155                 if (s->GetSocket() && s->GetSocket()->GetLinkState() != CONNECTED)
 156                         continue;
 157
 158                 // Now do PING checks on all servers
 159                 TreeServer *mts = Utils->BestRouteTo(s->GetID());
 160
 161                 if (mts)
 162                 {
 163                         // Only ping if this server needs one
 164                         if (curtime >= s->NextPingTime())
 165                         {
 166                                 // And if they answered the last
 167                                 if (s->AnsweredLastPing())
 168                                 {
 169                                         // They did, send a ping to them
 170                                         s->SetNextPingTime(curtime + Utils->PingFreq);
 171                                         TreeSocket *tsock = mts->GetSocket();
 172
 173                                         // ... if we can find a proper route to them
 174                                         if (tsock)
 175                                         {
 176                                                 tsock->WriteLine(":" + ServerInstance->Config->GetSID() + " PING " + s->GetID());
 177                                                 s->LastPingMsec = ts;
 178                                         }
 179                                 }
 180                                 else
 181                                 {
 182                                         // They didn't answer the last ping, if they are locally connected, get rid of them.
 183                                         TreeSocket *sock = s->GetSocket();
 184                                         if (sock)
 185                                         {
 186                                                 sock->SendError("Ping timeout");
 187                                                 sock->Close();
 188                                                 goto restart;
 189                                         }
 190                                 }
 191                         }
 192
 193                         // If warn on ping enabled and not warned and the difference is sufficient and they didn't answer the last ping...
 194                         if ((Utils->PingWarnTime) && (!s->Warned) && (curtime >= s->NextPingTime() - (Utils->PingFreq - Utils->PingWarnTime)) && (!s->AnsweredLastPing()))
 195                         {
 196                                 /* The server hasnt responded, send a warning to opers */
 197                                 ServerInstance->SNO->WriteToSnoMask('l',"Server \002%s\002 has not responded to PING for %d seconds, high latency.", s->GetName().c_str(), Utils->PingWarnTime);
 198                                 s->Warned = true;
 199                         }
 200                 }
 201         }
 202 }
 203
 204 void ModuleSpanningTree::ConnectServer(Autoconnect* a, bool on_timer)
 205 {
 206         if (!a)
 207                 return;
 208         for(unsigned int j=0; j < a->servers.size(); j++)
 209         {
 210                 if (Utils->FindServer(a->servers[j]))
 211                 {
 212                         // found something in this block. Should the server fail,
 213                         // we want to start at the start of the list, not in the
 214                         // middle where we left off
 215                         a->position = -1;
 216                         return;
 217                 }
 218         }
 219         if (on_timer && a->position >= 0)
 220                 return;
 221         if (!on_timer && a->position < 0)
 222                 return;
 223
 224         a->position++;
 225         while (a->position < (int)a->servers.size())
 226         {
 227                 Link* x = Utils->FindLink(a->servers[a->position]);
 228                 if (x)
 229                 {
 230                         ServerInstance->SNO->WriteToSnoMask('l', "AUTOCONNECT: Auto-connecting server \002%s\002", x->Name.c_str());
 231                         ConnectServer(x, a);
 232                         return;
 233                 }
 234                 a->position++;
 235         }
 236         // Autoconnect chain has been fully iterated; start at the beginning on the
 237         // next AutoConnectServers run
 238         a->position = -1;
 239 }
 240
 241 void ModuleSpanningTree::ConnectServer(Link* x, Autoconnect* y)
 242 {
 243         bool ipvalid = true;
 244
 245         if (InspIRCd::Match(ServerInstance->Config->ServerName, assign(x->Name)))
 246         {
 247                 ServerInstance->SNO->WriteToSnoMask('l', "CONNECT: Not connecting to myself.");
 248                 return;
 249         }
 250
 251         DNS::QueryType start_type = DNS::QUERY_AAAA;
 252         if (strchr(x->IPAddr.c_str(),':'))
 253         {
 254                 in6_addr n;
 255                 if (inet_pton(AF_INET6, x->IPAddr.c_str(), &n) < 1)
 256                         ipvalid = false;
 257         }
 258         else
 259         {
 260                 in_addr n;
 261                 if (inet_aton(x->IPAddr.c_str(),&n) < 1)
 262                         ipvalid = false;
 263         }
 264
 265         /* Do we already have an IP? If so, no need to resolve it. */
 266         if (ipvalid)
 267         {
 268                 /* Gave a hook, but it wasnt one we know */
 269                 TreeSocket* newsocket = new TreeSocket(x, y, x->IPAddr);
 270                 if (newsocket->GetFd() > -1)
 271                 {
 272                         /* Handled automatically on success */
 273                 }
 274                 else
 275                 {
 276                         ServerInstance->SNO->WriteToSnoMask('l', "CONNECT: Error connecting \002%s\002: %s.",
 277                                 x->Name.c_str(), newsocket->getError().c_str());
 278                         ServerInstance->GlobalCulls.AddItem(newsocket);
 279                 }
 280         }
 281         else if (!DNS)
 282         {
 283                 ServerInstance->SNO->WriteToSnoMask('l', "CONNECT: Error connecting \002%s\002: Hostname given and m_dns.so is not loaded, unable to resolve.", x->Name.c_str());
 284         }
 285         else
 286         {
 287                 ServernameResolver* snr = new ServernameResolver(*DNS, x->IPAddr, x, start_type, y);
 288                 try
 289                 {
 290                         DNS->Process(snr);
 291                 }
 292                 catch (DNS::Exception& e)
 293                 {
 294                         delete snr;
 295                         ServerInstance->SNO->WriteToSnoMask('l', "CONNECT: Error connecting \002%s\002: %s.",x->Name.c_str(), e.GetReason());
 296                         ConnectServer(y, false);
 297                 }
 298         }
 299 }
 300
 301 void ModuleSpanningTree::AutoConnectServers(time_t curtime)
 302 {
 303         for (std::vector<reference<Autoconnect> >::iterator i = Utils->AutoconnectBlocks.begin(); i < Utils->AutoconnectBlocks.end(); ++i)
 304         {
 305                 Autoconnect* x = *i;
 306                 if (curtime >= x->NextConnectTime)
 307                 {
 308                         x->NextConnectTime = curtime + x->Period;
 309                         ConnectServer(x, true);
 310                 }
 311         }
 312 }
 313
 314 void ModuleSpanningTree::DoConnectTimeout(time_t curtime)
 315 {
 316         std::map<TreeSocket*, std::pair<std::string, int> >::iterator i = Utils->timeoutlist.begin();
 317         while (i != Utils->timeoutlist.end())
 318         {
 319                 TreeSocket* s = i->first;
 320                 std::pair<std::string, int> p = i->second;
 321                 std::map<TreeSocket*, std::pair<std::string, int> >::iterator me = i;
 322                 i++;
 323                 if (s->GetLinkState() == DYING)
 324                 {
 325                         Utils->timeoutlist.erase(me);
 326                         s->Close();
 327                 }
 328                 else if (curtime > s->age + p.second)
 329                 {
 330                         ServerInstance->SNO->WriteToSnoMask('l',"CONNECT: Error connecting \002%s\002 (timeout of %d seconds)",p.first.c_str(),p.second);
 331                         Utils->timeoutlist.erase(me);
 332                         s->Close();
 333                 }
 334         }
 335 }
 336
 337 ModResult ModuleSpanningTree::HandleVersion(const std::vector<std::string>& parameters, User* user)
 338 {
 339         // we've already checked if pcnt > 0, so this is safe
 340         TreeServer* found = Utils->FindServerMask(parameters[0]);
 341         if (found)
 342         {
 343                 if (found == Utils->TreeRoot)
 344                 {
 345                         // Pass to default VERSION handler.
 346                         return MOD_RES_PASSTHRU;
 347                 }
 348                 std::string Version = found->GetVersion();
 349                 user->WriteNumeric(351, "%s :%s",user->nick.c_str(),Version.c_str());
 350         }
 351         else
 352         {
 353                 user->WriteNumeric(402, "%s %s :No such server",user->nick.c_str(),parameters[0].c_str());
 354         }
 355         return MOD_RES_DENY;
 356 }
 357
 358 /* This method will attempt to get a message to a remote user.
 359  */
 360 void ModuleSpanningTree::RemoteMessage(User* user, const char* format, ...)
 361 {
 362         std::string text;
 363         VAFORMAT(text, format, format);
 364
 365         if (IS_LOCAL(user))
 366                 user->WriteNotice(text);
 367         else
 368                 ServerInstance->PI->SendUserNotice(user, text);
 369 }
 370
 371 ModResult ModuleSpanningTree::HandleConnect(const std::vector<std::string>& parameters, User* user)
 372 {
 373         for (std::vector<reference<Link> >::iterator i = Utils->LinkBlocks.begin(); i < Utils->LinkBlocks.end(); i++)
 374         {
 375                 Link* x = *i;
 376                 if (InspIRCd::Match(x->Name.c_str(),parameters[0]))
 377                 {
 378                         if (InspIRCd::Match(ServerInstance->Config->ServerName, assign(x->Name)))
 379                         {
 380                                 RemoteMessage(user, "*** CONNECT: Server \002%s\002 is ME, not connecting.",x->Name.c_str());
 381                                 return MOD_RES_DENY;
 382                         }
 383
 384                         TreeServer* CheckDupe = Utils->FindServer(x->Name.c_str());
 385                         if (!CheckDupe)
 386                         {
 387                                 RemoteMessage(user, "*** CONNECT: Connecting to server: \002%s\002 (%s:%d)",x->Name.c_str(),(x->HiddenFromStats ? "<hidden>" : x->IPAddr.c_str()),x->Port);
 388                                 ConnectServer(x);
 389                                 return MOD_RES_DENY;
 390                         }
 391                         else
 392                         {
 393                                 RemoteMessage(user, "*** CONNECT: Server \002%s\002 already exists on the network and is connected via \002%s\002", x->Name.c_str(), CheckDupe->GetParent()->GetName().c_str());
 394                                 return MOD_RES_DENY;
 395                         }
 396                 }
 397         }
 398         RemoteMessage(user, "*** CONNECT: No server matching \002%s\002 could be found in the config file.",parameters[0].c_str());
 399         return MOD_RES_DENY;
 400 }
 401
 402 void ModuleSpanningTree::OnGetServerDescription(const std::string &servername,std::string &description)
 403 {
 404         TreeServer* s = Utils->FindServer(servername);
 405         if (s)
 406         {
 407                 description = s->GetDesc();
 408         }
 409 }
 410
 411 void ModuleSpanningTree::OnUserInvite(User* source,User* dest,Channel* channel, time_t expiry)
 412 {
 413         if (IS_LOCAL(source))
 414         {
 415                 parameterlist params;
 416                 params.push_back(dest->uuid);
 417                 params.push_back(channel->name);
 418                 params.push_back(ConvToStr(expiry));
 419                 Utils->DoOneToMany(source->uuid,"INVITE",params);
 420         }
 421 }
 422
 423 void ModuleSpanningTree::OnPostTopicChange(User* user, Channel* chan, const std::string &topic)
 424 {
 425         // Drop remote events on the floor.
 426         if (!IS_LOCAL(user))
 427                 return;
 428
 429         parameterlist params;
 430         params.push_back(chan->name);
 431         params.push_back(":"+topic);
 432         Utils->DoOneToMany(user->uuid,"TOPIC",params);
 433 }
 434
 435 void ModuleSpanningTree::LocalMessage(User* user, void* dest, int target_type, const std::string &text, char status, const CUList &exempt_list, const char* message_type)
 436 {
 437         /* Server or remote origin, dest should always be non-null */
 438         if ((!user) || (!IS_LOCAL(user)) || (!dest))
 439                 return;
 440
 441         if (target_type == TYPE_USER)
 442         {
 443                 User* d = (User*) dest;
 444                 if (!IS_LOCAL(d))
 445                 {
 446                         parameterlist params;
 447                         params.push_back(d->uuid);
 448                         params.push_back(":"+text);
 449                         Utils->DoOneToOne(user->uuid, message_type, params, d->server);
 450                 }
 451         }
 452         else if (target_type == TYPE_CHANNEL)
 453         {
 454                 Utils->SendChannelMessage(user->uuid, (Channel*)dest, text, status, exempt_list, message_type);
 455         }
 456         else if (target_type == TYPE_SERVER)
 457         {
 458                 char* target = (char*) dest;
 459                 parameterlist par;
 460                 par.push_back(target);
 461                 par.push_back(":"+text);
 462                 Utils->DoOneToMany(user->uuid, message_type, par);
 463         }
 464 }
 465
 466 void ModuleSpanningTree::OnUserMessage(User* user, void* dest, int target_type, const std::string& text, char status, const CUList& exempt_list, MessageType msgtype)
 467 {
 468         LocalMessage(user, dest, target_type, text, status, exempt_list, (msgtype == MSG_PRIVMSG ? "PRIVMSG" : "NOTICE"));
 469 }
 470
 471 void ModuleSpanningTree::OnBackgroundTimer(time_t curtime)
 472 {
 473         AutoConnectServers(curtime);
 474         DoPingChecks(curtime);
 475         DoConnectTimeout(curtime);
 476 }
 477
 478 void ModuleSpanningTree::OnUserConnect(LocalUser* user)
 479 {
 480         if (user->quitting)
 481                 return;
 482
 483         parameterlist params;
 484         params.push_back(user->uuid);
 485         params.push_back(ConvToStr(user->age));
 486         params.push_back(user->nick);
 487         params.push_back(user->host);
 488         params.push_back(user->dhost);
 489         params.push_back(user->ident);
 490         params.push_back(user->GetIPString());
 491         params.push_back(ConvToStr(user->signon));
 492         params.push_back("+"+std::string(user->FormatModes(true)));
 493         params.push_back(":"+user->fullname);
 494         Utils->DoOneToMany(ServerInstance->Config->GetSID(), "UID", params);
 495
 496         if (user->IsOper())
 497         {
 498                 params.clear();
 499                 params.push_back(":");
 500                 params[0].append(user->oper->name);
 501                 Utils->DoOneToMany(user->uuid,"OPERTYPE",params);
 502         }
 503
 504         for(Extensible::ExtensibleStore::const_iterator i = user->GetExtList().begin(); i != user->GetExtList().end(); i++)
 505         {
 506                 ExtensionItem* item = i->first;
 507                 std::string value = item->serialize(FORMAT_NETWORK, user, i->second);
 508                 if (!value.empty())
 509                         ServerInstance->PI->SendMetaData(user, item->name, value);
 510         }
 511
 512         Utils->TreeRoot->UserCount++;
 513 }
 514
 515 void ModuleSpanningTree::OnUserJoin(Membership* memb, bool sync, bool created_by_local, CUList& excepts)
 516 {
 517         // Only do this for local users
 518         if (IS_LOCAL(memb->user))
 519         {
 520                 parameterlist params;
 521                 params.push_back(memb->chan->name);
 522                 if (created_by_local)
 523                 {
 524                         params.push_back(ConvToStr(memb->chan->age));
 525                         params.push_back(std::string("+") + memb->chan->ChanModes(true));
 526                         params.push_back(memb->modes+","+memb->user->uuid);
 527                         Utils->DoOneToMany(ServerInstance->Config->GetSID(),"FJOIN",params);
 528                 }
 529                 else
 530                 {
 531                         if (!memb->modes.empty())
 532                         {
 533                                 params.push_back(ConvToStr(memb->chan->age));
 534                                 params.push_back(memb->modes);
 535                         }
 536                         Utils->DoOneToMany(memb->user->uuid, "IJOIN", params);
 537                 }
 538         }
 539 }
 540
 541 void ModuleSpanningTree::OnChangeHost(User* user, const std::string &newhost)
 542 {
 543         if (user->registered != REG_ALL || !IS_LOCAL(user))
 544                 return;
 545
 546         parameterlist params;
 547         params.push_back(newhost);
 548         Utils->DoOneToMany(user->uuid,"FHOST",params);
 549 }
 550
 551 void ModuleSpanningTree::OnChangeName(User* user, const std::string &gecos)
 552 {
 553         if (user->registered != REG_ALL || !IS_LOCAL(user))
 554                 return;
 555
 556         parameterlist params;
 557         params.push_back(gecos);
 558         Utils->DoOneToMany(user->uuid,"FNAME",params);
 559 }
 560
 561 void ModuleSpanningTree::OnChangeIdent(User* user, const std::string &ident)
 562 {
 563         if ((user->registered != REG_ALL) || (!IS_LOCAL(user)))
 564                 return;
 565
 566         parameterlist params;
 567         params.push_back(ident);
 568         Utils->DoOneToMany(user->uuid,"FIDENT",params);
 569 }
 570
 571 void ModuleSpanningTree::OnUserPart(Membership* memb, std::string &partmessage, CUList& excepts)
 572 {
 573         if (IS_LOCAL(memb->user))
 574         {
 575                 parameterlist params;
 576                 params.push_back(memb->chan->name);
 577                 if (!partmessage.empty())
 578                         params.push_back(":"+partmessage);
 579                 Utils->DoOneToMany(memb->user->uuid,"PART",params);
 580         }
 581 }
 582
 583 void ModuleSpanningTree::OnUserQuit(User* user, const std::string &reason, const std::string &oper_message)
 584 {
 585         if ((IS_LOCAL(user)) && (user->registered == REG_ALL))
 586         {
 587                 parameterlist params;
 588
 589                 if (oper_message != reason)
 590                         ServerInstance->PI->SendMetaData(user, "operquit", oper_message);
 591
 592                 params.push_back(":"+reason);
 593                 Utils->DoOneToMany(user->uuid,"QUIT",params);
 594         }
 595
 596         // Regardless, We need to modify the user Counts..
 597         TreeServer* SourceServer = Utils->FindServer(user->server);
 598         if (SourceServer)
 599         {
 600                 SourceServer->UserCount--;
 601         }
 602 }
 603
 604 void ModuleSpanningTree::OnUserPostNick(User* user, const std::string &oldnick)
 605 {
 606         if (IS_LOCAL(user))
 607         {
 608                 parameterlist params;
 609                 params.push_back(user->nick);
 610
 611                 /** IMPORTANT: We don't update the TS if the oldnick is just a case change of the newnick!
 612                  */
 613                 if (irc::string(user->nick.c_str()) != assign(oldnick))
 614                         user->age = ServerInstance->Time();
 615
 616                 params.push_back(ConvToStr(user->age));
 617                 Utils->DoOneToMany(user->uuid,"NICK",params);
 618         }
 619         else if (!loopCall && user->nick == user->uuid)
 620         {
 621                 parameterlist params;
 622                 params.push_back(user->uuid);
 623                 params.push_back(ConvToStr(user->age));
 624                 Utils->DoOneToMany(ServerInstance->Config->GetSID(),"SAVE",params);
 625         }
 626 }
 627
 628 void ModuleSpanningTree::OnUserKick(User* source, Membership* memb, const std::string &reason, CUList& excepts)
 629 {
 630         parameterlist params;
 631         params.push_back(memb->chan->name);
 632         params.push_back(memb->user->uuid);
 633         params.push_back(":"+reason);
 634         if (IS_LOCAL(source))
 635         {
 636                 Utils->DoOneToMany(source->uuid,"KICK",params);
 637         }
 638         else if (source == ServerInstance->FakeClient)
 639         {
 640                 Utils->DoOneToMany(ServerInstance->Config->GetSID(),"KICK",params);
 641         }
 642 }
 643
 644 void ModuleSpanningTree::OnPreRehash(User* user, const std::string &parameter)
 645 {
 646         if (loopCall)
 647                 return; // Don't generate a REHASH here if we're in the middle of processing a message that generated this one
 648
 649         ServerInstance->Logs->Log(MODNAME, LOG_DEBUG, "OnPreRehash called with param %s", parameter.c_str());
 650
 651         // Send out to other servers
 652         if (!parameter.empty() && parameter[0] != '-')
 653         {
 654                 parameterlist params;
 655                 params.push_back(parameter);
 656                 Utils->DoOneToAllButSender(user ? user->uuid : ServerInstance->Config->GetSID(), "REHASH", params, user ? user->server : ServerInstance->Config->ServerName);
 657         }
 658 }
 659
 660 void ModuleSpanningTree::OnRehash(User* user)
 661 {
 662         // Re-read config stuff
 663         try
 664         {
 665                 Utils->ReadConfiguration();
 666         }
 667         catch (ModuleException& e)
 668         {
 669                 // Refresh the IP cache anyway, so servers read before the error will be allowed to connect
 670                 Utils->RefreshIPCache();
 671                 // Always warn local opers with snomask +l, also warn globally (snomask +L) if the rehash was issued by a remote user
 672                 std::string msg = "Error in configuration: ";
 673                 msg.append(e.GetReason());
 674                 ServerInstance->SNO->WriteToSnoMask('l', msg);
 675                 if (user && !IS_LOCAL(user))
 676                         ServerInstance->PI->SendSNONotice("L", msg);
 677         }
 678 }
 679
 680 void ModuleSpanningTree::OnLoadModule(Module* mod)
 681 {
 682         std::string data;
 683         data.push_back('+');
 684         data.append(mod->ModuleSourceFile);
 685         Version v = mod->GetVersion();
 686         if (!v.link_data.empty())
 687         {
 688                 data.push_back('=');
 689                 data.append(v.link_data);
 690         }
 691         ServerInstance->PI->SendMetaData(NULL, "modules", data);
 692 }
 693
 694 void ModuleSpanningTree::OnUnloadModule(Module* mod)
 695 {
 696         ServerInstance->PI->SendMetaData(NULL, "modules", "-" + mod->ModuleSourceFile);
 697
 698         unsigned int items = Utils->TreeRoot->ChildCount();
 699         for(unsigned int x = 0; x < items; x++)
 700         {
 701                 TreeServer* srv = Utils->TreeRoot->GetChild(x);
 702                 TreeSocket* sock = srv->GetSocket();
 703                 if (sock && sock->GetIOHook() && sock->GetIOHook()->creator == mod)
 704                 {
 705                         sock->SendError("SSL module unloaded");
 706                         sock->Close();
 707                 }
 708         }
 709 }
 710
 711 // note: the protocol does not allow direct umode +o except
 712 // via NICK with 8 params. sending OPERTYPE infers +o modechange
 713 // locally.
 714 void ModuleSpanningTree::OnOper(User* user, const std::string &opertype)
 715 {
 716         if (user->registered != REG_ALL || !IS_LOCAL(user))
 717                 return;
 718         parameterlist params;
 719         params.push_back(":");
 720         params[0].append(opertype);
 721         Utils->DoOneToMany(user->uuid,"OPERTYPE",params);
 722 }
 723
 724 void ModuleSpanningTree::OnAddLine(User* user, XLine *x)
 725 {
 726         if (!x->IsBurstable() || loopCall)
 727                 return;
 728
 729         parameterlist params;
 730         params.push_back(x->type);
 731         params.push_back(x->Displayable());
 732         params.push_back(ServerInstance->Config->ServerName);
 733         params.push_back(ConvToStr(x->set_time));
 734         params.push_back(ConvToStr(x->duration));
 735         params.push_back(":" + x->reason);
 736
 737         if (!user)
 738         {
 739                 /* Server-set lines */
 740                 Utils->DoOneToMany(ServerInstance->Config->GetSID(), "ADDLINE", params);
 741         }
 742         else if (IS_LOCAL(user))
 743         {
 744                 /* User-set lines */
 745                 Utils->DoOneToMany(user->uuid, "ADDLINE", params);
 746         }
 747 }
 748
 749 void ModuleSpanningTree::OnDelLine(User* user, XLine *x)
 750 {
 751         if (!x->IsBurstable() || loopCall)
 752                 return;
 753
 754         parameterlist params;
 755         params.push_back(x->type);
 756         params.push_back(x->Displayable());
 757
 758         if (!user)
 759         {
 760                 /* Server-unset lines */
 761                 Utils->DoOneToMany(ServerInstance->Config->GetSID(), "DELLINE", params);
 762         }
 763         else if (IS_LOCAL(user))
 764         {
 765                 /* User-unset lines */
 766                 Utils->DoOneToMany(user->uuid, "DELLINE", params);
 767         }
 768 }
 769
 770 ModResult ModuleSpanningTree::OnSetAway(User* user, const std::string &awaymsg)
 771 {
 772         if (IS_LOCAL(user))
 773         {
 774                 parameterlist params;
 775                 if (!awaymsg.empty())
 776                 {
 777                         params.push_back(ConvToStr(user->awaytime));
 778                         params.push_back(":" + awaymsg);
 779                 }
 780                 Utils->DoOneToMany(user->uuid, "AWAY", params);
 781         }
 782
 783         return MOD_RES_PASSTHRU;
 784 }
 785
 786 void ModuleSpanningTree::ProtoSendMode(void* opaque, TargetTypeFlags target_type, void* target, const parameterlist &modeline, const std::vector<TranslateType> &translate)
 787 {
 788         TreeSocket* s = (TreeSocket*)opaque;
 789         std::string output_text = CommandParser::TranslateUIDs(translate, modeline);
 790
 791         if (target)
 792         {
 793                 if (target_type == TYPE_USER)
 794                 {
 795                         User* u = (User*)target;
 796                         s->WriteLine(":"+ServerInstance->Config->GetSID()+" MODE "+u->uuid+" "+output_text);
 797                 }
 798                 else if (target_type == TYPE_CHANNEL)
 799                 {
 800                         Channel* c = (Channel*)target;
 801                         s->WriteLine(":"+ServerInstance->Config->GetSID()+" FMODE "+c->name+" "+ConvToStr(c->age)+" "+output_text);
 802                 }
 803         }
 804 }
 805
 806 void ModuleSpanningTree::ProtoSendMetaData(void* opaque, Extensible* target, const std::string &extname, const std::string &extdata)
 807 {
 808         TreeSocket* s = static_cast<TreeSocket*>(opaque);
 809         User* u = dynamic_cast<User*>(target);
 810         Channel* c = dynamic_cast<Channel*>(target);
 811         if (u)
 812                 s->WriteLine(":"+ServerInstance->Config->GetSID()+" METADATA "+u->uuid+" "+extname+" :"+extdata);
 813         else if (c)
 814                 s->WriteLine(":"+ServerInstance->Config->GetSID()+" METADATA "+c->name+" "+ConvToStr(c->age)+" "+extname+" :"+extdata);
 815         else if (!target)
 816                 s->WriteLine(":"+ServerInstance->Config->GetSID()+" METADATA * "+extname+" :"+extdata);
 817 }
 818
 819 CullResult ModuleSpanningTree::cull()
 820 {
 821         if (Utils)
 822                 Utils->cull();
 823         return this->Module::cull();
 824 }
 825
 826 ModuleSpanningTree::~ModuleSpanningTree()
 827 {
 828         delete ServerInstance->PI;
 829         ServerInstance->PI = new ProtocolInterface;
 830
 831         /* This will also free the listeners */
 832         delete Utils;
 833
 834         delete commands;
 835 }
 836
 837 Version ModuleSpanningTree::GetVersion()
 838 {
 839         return Version("Allows servers to be linked", VF_VENDOR);
 840 }
 841
 842 /* It is IMPORTANT that m_spanningtree is the last module in the chain
 843  * so that any activity it sees is FINAL, e.g. we arent going to send out
 844  * a NICK message before m_cloaking has finished putting the +x on the user,
 845  * etc etc.
 846  * Therefore, we return PRIORITY_LAST to make sure we end up at the END of
 847  * the module call queue.
 848  */
 849 void ModuleSpanningTree::Prioritize()
 850 {
 851         ServerInstance->Modules->SetPriority(this, PRIORITY_LAST);
 852 }
 853
 854 MODULE_INIT(ModuleSpanningTree)