/* +------------------------------------+
* | Inspire Internet Relay Chat Daemon |
* +------------------------------------+
*
* InspIRCd: (C) 2002-2011 InspIRCd Development Team
* See: http://wiki.inspircd.org/Credits
*
* This program is free but copyrighted software; see
* the file COPYING for details.
*
* ---------------------------------------------------
*/
#include "inspircd.h"
#include "xline.h"
#include "treesocket.h"
#include "treeserver.h"
#include "utils.h"
#include "main.h"
/** This function is called when we want to send a netburst to a local
* server. There is a set order we must do this, because for example
* users require their servers to exist, and channels require their
* users to exist. You get the idea.
*/
void TreeSocket::DoBurst(TreeServer* s)
{
std::string name = s->GetName();
std::string burst = ":" + ServerInstance->Config->GetSID() + " BURST " +ConvToStr(ServerInstance->Time());
std::string endburst = ":" + ServerInstance->Config->GetSID() + " ENDBURST";
ServerInstance->SNO->WriteToSnoMask('l',"Bursting to \2%s\2 (Authentication: %s%s).",
name.c_str(),
capab->auth_fingerprint ? "SSL Fingerprint and " : "",
capab->auth_challenge ? "challenge-response" : "plaintext password");
this->CleanNegotiationInfo();
this->WriteLine(burst);
/* send our version string */
this->WriteLine(std::string(":")+ServerInstance->Config->GetSID()+" VERSION :"+ServerInstance->GetVersionString());
/* Send server tree */
this->SendServers(Utils->TreeRoot,s,1);
/* Send users and their oper status */
this->SendUsers(s);
/* Send everything else (channel modes, xlines etc) */
this->SendChannelModes(s);
this->SendXLines(s);
FOREACH_MOD(I_OnSyncNetwork,OnSyncNetwork(&sync));
this->WriteLine(endburst);
ServerInstance->SNO->WriteToSnoMask('l',"Finished bursting to \2"+name+"\2.");
}
/** Recursively send the server tree with distances as hops.
* This is used during network burst to inform the other server
* (and any of ITS servers too) of what servers we know about.
* If at any point any of these servers already exist on the other
* end, our connection may be terminated. The hopcounts given
* by this function are relative, this doesn't matter so long as
* they are all >1, as all the remote servers re-calculate them
* to be relative too, with themselves as hop 0.
*/
void TreeSocket::SendServers(TreeServer* Current, TreeServer* s, int hops)
{
char command[1024];
for (unsigned int q = 0; q < Current->ChildCount(); q++)
{
TreeServer* recursive_server = Current->GetChild(q);
if (recursive_server != s)
{
snprintf(command,1024,":%s SERVER %s * %d %s :%s",Current->GetName().c_str(),recursive_server->GetName().c_str(),hops,
recursive_server->GetID().c_str(),
recursive_server->GetDesc().c_str());
this->WriteLine(command);
this->WriteLine(":"+recursive_server->GetName()+" VERSION :"+recursive_server->GetVersion());
/* down to next level */
this->SendServers(recursive_server, s, hops+1);
}
}
}
/** Send one or more FJOINs for a channel of users.
* If the length of a single line is more than 480-NICKMAX
* in length, it is split over multiple lines.
*/
void TreeSocket::SendFJoins(Channel* c)
{
char list[MAXBUF];
size_t curlen, headlen;
// the blank mode is fine here, as we send an FMODE right afterwards that will fix it.
curlen = headlen = snprintf(list,MAXBUF,":%s FJOIN %s %lu + :",
ServerInstance->Config->GetSID().c_str(), c->name.c_str(), (unsigned long)c->age);
int numusers = 0;
char* ptr = list + curlen;
bool looped_once = false;
const UserMembList *ulist = c->GetUsers();
std::string params;
for (UserMembCIter i = ulist->begin(); i != ulist->end(); i++)
{
size_t ptrlen = 0;
std::string modestr = i->second->modes;
if ((curlen + modestr.length() + i->first->uuid.length() + 4) > 480)
{
// remove the final space
if (ptr[-1] == ' ')
ptr[-1] = '\0';
WriteLine(list);
curlen = headlen;
ptr = list + headlen;
numusers = 0;
}
ptrlen = snprintf(ptr, MAXBUF-curlen, "%s,%s ", modestr.c_str(), i->first->uuid.c_str());
looped_once = true;
curlen += ptrlen;
ptr += ptrlen;
numusers++;
}
// Okay, permanent channels will (of course) need this \r\n anyway, numusers check is if there
// actually were people in the channel (looped_once == true)
if (!looped_once || numusers > 0)
{
// remove the final space
if (ptr[-1] == ' ')
ptr[-1] = '\0';
WriteLine(list);
}
irc::modestacker fmodes;
c->ChanModes(fmodes, MODELIST_FULL);
snprintf(list, MAXBUF, ":%s FMODE %s %ld ", ServerInstance->Config->GetSID().c_str(), c->name.c_str(), (unsigned long)c->age);
while (!fmodes.empty())
{
std::string line = fmodes.popModeLine(FORMAT_NETWORK);
if (line.empty())
continue;
// request a mode merge, not a forced application of our modes
line[0] = '=';
WriteLine(list + line);
}
if (!c->topic.empty())
{
snprintf(list,MAXBUF,":%s FTOPIC %s %lu %s :%s", ServerInstance->Config->GetSID().c_str(), c->name.c_str(), (unsigned long)c->topicset, c->setby.c_str(), c->topic.c_str());
WriteLine(list);
}
for(Extensible::ExtensibleStore::const_iterator i = c->GetExtList().begin(); i != c->GetExtList().end(); i++)
{
ExtensionItem* item = i->first;
std::string value = item->serialize(FORMAT_NETWORK, c, i->second);
if (!value.empty())
sync.SendMetaData(c, item->name, value);
}
FOREACH_MOD(I_OnSyncChannel,OnSyncChannel(c, &sync));
}
/** Send G, Q, Z and E lines */
void TreeSocket::SendXLines(TreeServer* Current)
{
char data[MAXBUF];
std::string n = ServerInstance->Config->GetSID();
const char* sn = n.c_str();
std::vector<std::string> types = ServerInstance->XLines->GetAllTypes();
time_t current = ServerInstance->Time();
for (std::vector<std::string>::iterator it = types.begin(); it != types.end(); ++it)
{
XLineLookup* lookup = ServerInstance->XLines->GetAll(*it);
if (lookup)
{
for (LookupIter i = lookup->begin(); i != lookup->end(); ++i)
{
/* Is it burstable? this is better than an explicit check for type 'K'.
* We break the loop as NONE of the items in this group are worth iterating.
*/
if (!i->second->IsBurstable())
break;
/* If it's expired, don't bother to burst it
*/
if (i->second->duration && current > i->second->expiry)
continue;
snprintf(data,MAXBUF,":%s ADDLINE %s %s %s %lu %lu :%s",sn, it->c_str(), i->second->Displayable(),
i->second->source.c_str(),
(unsigned long)i->second->set_time,
(unsigned long)i->second->duration,
i->second->reason.c_str());
this->WriteLine(data);
}
}
}
}
/** Send channel modes and topics */
void TreeSocket::SendChannelModes(TreeServer* Current)
{
for (chan_hash::iterator c = ServerInstance->chanlist->begin(); c != ServerInstance->chanlist->end(); c++)
{
SendFJoins(c->second);
}
}
/** send all users and their oper state/modes */
void TreeSocket::SendUsers(TreeServer* Current)
{
char data[MAXBUF];
std::string dataline;
for (user_hash::iterator u = ServerInstance->Users->clientlist->begin(); u != ServerInstance->Users->clientlist->end(); u++)
{
if (u->second->registered == REG_ALL)
{
TreeServer* theirserver = Utils->FindServer(u->second->server);
if (theirserver)
{
snprintf(data,MAXBUF,":%s UID %s %lu %s %s %s %s %s %lu +%s :%s",
theirserver->GetID().c_str(), /* Prefix: SID */
u->second->uuid.c_str(), /* 0: UUID */
(unsigned long)u->second->age, /* 1: TS */
u->second->nick.c_str(), /* 2: Nick */
u->second->host.c_str(), /* 3: Displayed Host */
u->second->dhost.c_str(), /* 4: Real host */
u->second->ident.c_str(), /* 5: Ident */
u->second->GetIPString(), /* 6: IP string */
(unsigned long)u->second->signon, /* 7: Signon time for WHOWAS */
u->second->FormatModes(true), /* 8...n: Modes and params */
u->second->fullname.c_str()); /* size-1: GECOS */
this->WriteLine(data);
if (IS_OPER(u->second))
{
snprintf(data,MAXBUF,":%s OPERTYPE %s", u->second->uuid.c_str(), u->second->oper->name.c_str());
this->WriteLine(data);
}
if (IS_AWAY(u->second))
{
snprintf(data,MAXBUF,":%s AWAY %ld :%s", u->second->uuid.c_str(), (long)u->second->awaytime, u->second->awaymsg.c_str());
this->WriteLine(data);
}
}
for(Extensible::ExtensibleStore::const_iterator i = u->second->GetExtList().begin(); i != u->second->GetExtList().end(); i++)
{
ExtensionItem* item = i->first;
std::string value = item->serialize(FORMAT_NETWORK, u->second, i->second);
if (!value.empty())
sync.SendMetaData(u->second, item->name, value);
}
FOREACH_MOD(I_OnSyncUser,OnSyncUser(u->second,&sync));
}
}
}
