pegasus/anope
1
0
Fork 0
mirror of https://github.com/anope/anope.git synced 2026-06-23 12:16:37 +02:00
Code Activity
Files
fde42899e76009db978e2007a0a8a1ffc5f0f83d
anope/modules/protocol/inspircd20.cpp
T

813 lines
26 KiB
C++
Raw Blame History

/* Inspircd 2.0 functions
*
* (C) 2003-2012 Anope Team
* Contact us at team@anope.org
*
* Please read COPYING and README for further details.
*
* Based on the original code of Epona by Lara.
* Based on the original code of Services by Andy Church.
*/
/*************************************************************************/
#include "module.h"
/* inspircd-ts6.h uses these */
static bool has_chghostmod = false;
static bool has_chgidentmod = false;
static bool has_globopsmod = true; // Not a typo
static bool has_rlinemod = false;
#include "inspircd-ts6.h"
IRCDVar myIrcd = {
"InspIRCd 2.0", /* ircd name */
"+I", /* Modes used by pseudoclients */
1, /* SVSNICK */
1, /* Vhost */
0, /* Supports SNlines */
1, /* Supports SQlines */
1, /* Supports SZlines */
0, /* Join 2 Message */
0, /* Chan SQlines */
0, /* Quit on Kill */
1, /* vidents */
1, /* svshold */
0, /* time stamp on mode */
0, /* O:LINE */
1, /* UMODE */
1, /* No Knock requires +i */
0, /* Can remove User Channel Modes with SVSMODE */
0, /* Sglines are not enforced until user reconnects */
1, /* ts6 */
"$", /* TLD Prefix for Global */
20, /* Max number of modes we can send per line */
1, /* IRCd sends a SSL users certificate fingerprint */
};
static bool has_servicesmod = false;
static bool has_svsholdmod = false;
class InspIRCdProto : public InspIRCdTS6Proto
{
void SendConnect() anope_override
{
UplinkSocket::Message() << "CAPAB START 1202";
UplinkSocket::Message() << "CAPAB CAPABILITIES :PROTOCOL=1202";
UplinkSocket::Message() << "CAPAB END";
SendServer(Me);
UplinkSocket::Message(Me) << "BURST";
Module *enc = ModuleManager::FindFirstOf(ENCRYPTION);
UplinkSocket::Message(Me) << "VERSION :Anope-" << Anope::Version() << " " << Me->GetName() << " :" << ircd->name <<" - (" << (enc ? enc->name : "unknown") << ") -- " << Anope::VersionBuildString();
}
};
bool event_ftopic(const Anope::string &source, const std::vector<Anope::string> &params)
{
/* :source FTOPIC channel ts setby :topic */
if (params.size() < 4)
return true;
Channel *c = findchan(params[0]);
if (!c)
{
Log(LOG_DEBUG) << "TOPIC " << params[3] << " for nonexistent channel " << params[0];
return true;
}
c->ChangeTopicInternal(params[2], params[3], Anope::string(params[1]).is_pos_number_only() ? convertTo<time_t>(params[1]) : Anope::CurTime);
return true;
}
bool event_opertype(const Anope::string &source, const std::vector<Anope::string> &params)
{
/* opertype is equivalent to mode +o because servers
dont do this directly */
User *u = finduser(source);
if (u && !u->HasMode(UMODE_OPER))
{
std::vector<Anope::string> newparams;
newparams.push_back(source);
newparams.push_back("+o");
return ircdmessage->OnMode(source, newparams);
}
return true;
}
bool event_fmode(const Anope::string &source, const std::vector<Anope::string> &params)
{
/* :source FMODE #test 12345678 +nto foo */
if (params.size() < 3)
return true;
Channel *c = findchan(params[0]);
if (!c)
return true;
/* Checking the TS for validity to avoid desyncs */
time_t ts = Anope::string(params[1]).is_pos_number_only() ? convertTo<time_t>(params[1]) : 0;
if (c->creation_time > ts)
{
/* Our TS is bigger, we should lower it */
c->creation_time = ts;
c->Reset();
}
else if (c->creation_time < ts)
/* The TS we got is bigger, we should ignore this message. */
return true;
/* TS's are equal now, so we can proceed with parsing */
std::vector<Anope::string> newparams;
newparams.push_back(params[0]);
newparams.push_back(params[1]);
Anope::string modes = params[2];
for (unsigned n = 3; n < params.size(); ++n)
modes += " " + params[n];
newparams.push_back(modes);
return ircdmessage->OnMode(source, newparams);
}
bool event_chgname(const Anope::string &source, const std::vector<Anope::string> &params)
{
User *u = finduser(source);
if (!u)
{
Log(LOG_DEBUG) << "FNAME for nonexistent user " << source;
return true;
}
else if (params.empty())
return true;
u->SetRealname(params[0]);
return true;
}
bool event_chgident(const Anope::string &source, const std::vector<Anope::string> &params)
{
User *u = finduser(source);
if (!u)
{
Log(LOG_DEBUG) << "FIDENT for nonexistent user " << source;
return true;
}
u->SetIdent(params[0]);
return true;
}
bool event_chghost(const Anope::string &source, const std::vector<Anope::string> &params)
{
User *u = finduser(source);
if (!u)
{
Log(LOG_DEBUG) << "FHOST for nonexistent user " << source;
return true;
}
u->SetDisplayedHost(params[0]);
return true;
}
/*
* source = numeric of the sending server
* params[0] = uuid
* params[1] = metadata name
* params[2] = data
*/
bool event_metadata(const Anope::string &source, const std::vector<Anope::string> &params)
{
if (params.size() < 3)
return true;
else if (params[1].equals_cs("accountname"))
{
User *u = finduser(params[0]);
NickCore *nc = findcore(params[2]);
if (u && nc)
{
u->Login(nc);
const NickAlias *user_na = findnick(u->nick);
if (!Config->NoNicknameOwnership && nickserv && user_na && user_na->nc == nc && user_na->nc->HasFlag(NI_UNCONFIRMED) == false)
u->SetMode(findbot(Config->NickServ), UMODE_REGISTERED);
}
}
/*
* possible incoming ssl_cert messages:
* Received: :409 METADATA 409AAAAAA ssl_cert :vTrSe c38070ce96e41cc144ed6590a68d45a6 <...> <...>
* Received: :409 METADATA 409AAAAAC ssl_cert :vTrSE Could not get peer certificate: error:00000000:lib(0):func(0):reason(0)
*/
else if (params[1].equals_cs("ssl_cert"))
{
User *u = finduser(params[0]);
if (!u)
return true;
std::string data = params[2].c_str();
size_t pos1 = data.find(' ') + 1;
size_t pos2 = data.find(' ', pos1);
if ((pos2 - pos1) >= 32) // inspircd supports md5 and sha1 fingerprint hashes -> size 32 or 40 bytes.
{
u->fingerprint = data.substr(pos1, pos2 - pos1);
FOREACH_MOD(I_OnFingerprint, OnFingerprint(u));
}
}
return true;
}
bool event_encap(const Anope::string &source, const std::vector<Anope::string> &params)
{
if (params.size() < 2 || Server::Find(params[0]) != Me)
return true;
if (params[1] == "CHGIDENT" && params.size() > 3)
{
User *u = finduser(params[2]);
if (!u || u->server != Me)
return true;
u->SetIdent(params[3]);
UplinkSocket::Message(u) << "FIDENT " << params[3];
}
else if (params[1] == "CHGHOST" && params.size() > 3)
{
User *u = finduser(params[2]);
if (!u || u->server != Me)
return true;
u->SetDisplayedHost(params[3]);
UplinkSocket::Message(u) << "FHOST " << params[3];
}
else if (params[1] == "CHGNAME" && params.size() > 3)
{
User *u = finduser(params[2]);
if (!u || u->server != Me)
return true;
u->SetRealname(params[3]);
UplinkSocket::Message(u) << "FNAME " << params[3];
}
return true;
}
bool event_endburst(const Anope::string &source, const std::vector<Anope::string> &params)
{
Server *s = Server::Find(source);
if (!s)
throw CoreException("Got ENDBURST without a source");
Log(LOG_DEBUG) << "Processed ENDBURST for " << s->GetName();
s->Sync(true);
return true;
}
class InspIRCdExtBan : public ChannelModeList
{
public:
InspIRCdExtBan(ChannelModeName mName, char modeChar) : ChannelModeList(mName, modeChar) { }
bool Matches(const User *u, const Entry *e) anope_override
{
const Anope::string &mask = e->mask;
if (mask.find("m:") == 0 || mask.find("N:") == 0)
{
Anope::string real_mask = mask.substr(3);
Entry en(this->Name, real_mask);
if (en.Matches(u))
return true;
}
else if (mask.find("j:") == 0)
{
Anope::string channel = mask.substr(3);
ChannelMode *cm = NULL;
if (channel[0] != '#')
{
char modeChar = ModeManager::GetStatusChar(channel[0]);
channel.erase(channel.begin());
cm = ModeManager::FindChannelModeByChar(modeChar);
if (cm != NULL && cm->Type != MODE_STATUS)
cm = NULL;
}
Channel *c = findchan(channel);
if (c != NULL)
{
UserContainer *uc = c->FindUser(u);
if (uc != NULL)
if (cm == NULL || uc->Status->HasFlag(cm->Name))
return true;
}
}
else if (mask.find("R:") == 0)
{
Anope::string real_mask = mask.substr(2);
if (u->IsIdentified() && real_mask.equals_ci(u->Account()->display))
return true;
}
else if (mask.find("r:") == 0)
{
Anope::string real_mask = mask.substr(2);
if (Anope::Match(u->realname, real_mask))
return true;
}
else if (mask.find("s:") == 0)
{
Anope::string real_mask = mask.substr(2);
if (Anope::Match(u->server->GetName(), real_mask))
return true;
}
else if (mask.find("z:") == 0)
{
Anope::string real_mask = mask.substr(2);
if (Anope::Match(u->fingerprint, real_mask))
return true;
}
return false;
}
};
class Inspircd20IRCdMessage : public InspircdIRCdMessage
{
public:
/*
* [Nov 03 22:09:58.176252 2009] debug: Received: :964 UID 964AAAAAC 1225746297 w00t2 localhost testnet.user w00t 127.0.0.1 1225746302 +iosw +ACGJKLNOQcdfgjklnoqtx :Robin Burchell <w00t@inspircd.org>
* 0: uid
* 1: ts
* 2: nick
* 3: host
* 4: dhost
* 5: ident
* 6: ip
* 7: signon
* 8+: modes and params -- IMPORTANT, some modes (e.g. +s) may have parameters. So don't assume a fixed position of realname!
* last: realname
*/
bool OnUID(const Anope::string &source, const std::vector<Anope::string> &params) anope_override
{
time_t ts = Anope::string(params[1]).is_pos_number_only() ? convertTo<time_t>(params[1]) : 0;
Anope::string modes = params[8];
for (unsigned i = 9; i < params.size() - 1; ++i)
modes += Anope::string(" ") + params[i];
User *user = do_nick("", params[2], params[5], params[3], source, params[params.size() - 1], ts, params[6], params[4], params[0], modes);
if (user && user->server->IsSynced() && nickserv)
nickserv->Validate(user);
return true;
}
bool OnCapab(const Anope::string &source, const std::vector<Anope::string> &params) anope_override
{
if (params[0].equals_cs("START"))
{
if (params.size() < 2 || (Anope::string(params[1]).is_pos_number_only() ? convertTo<unsigned>(params[1]) : 0) < 1202)
{
UplinkSocket::Message() << "ERROR :Protocol mismatch, no or invalid protocol version given in CAPAB START";
quitmsg = "Protocol mismatch, no or invalid protocol version given in CAPAB START";
quitting = true;
return false;
}
/* reset CAPAB */
has_servicesmod = false;
has_svsholdmod = false;
has_chghostmod = false;
has_chgidentmod = false;
}
else if (params[0].equals_cs("CHANMODES"))
{
spacesepstream ssep(params[1]);
Anope::string capab;
while (ssep.GetToken(capab))
{
Anope::string modename = capab.substr(0, capab.find('='));
Anope::string modechar = capab.substr(capab.find('=') + 1);
ChannelMode *cm = NULL;
if (modename.equals_cs("admin"))
cm = new ChannelModeStatus(CMODE_PROTECT, modechar.length() > 1 ? modechar[1] : modechar[0], modechar.length() > 1 ? modechar[0] : 0);
else if (modename.equals_cs("allowinvite"))
cm = new ChannelMode(CMODE_ALLINVITE, modechar[0]);
else if (modename.equals_cs("auditorium"))
cm = new ChannelMode(CMODE_AUDITORIUM, modechar[0]);
else if (modename.equals_cs("ban"))
cm = new InspIRCdExtBan(CMODE_BAN, modechar[0]);
else if (modename.equals_cs("banexception"))
cm = new InspIRCdExtBan(CMODE_EXCEPT, 'e');
else if (modename.equals_cs("blockcaps"))
cm = new ChannelMode(CMODE_BLOCKCAPS, modechar[0]);
else if (modename.equals_cs("blockcolor"))
cm = new ChannelMode(CMODE_BLOCKCOLOR, modechar[0]);
else if (modename.equals_cs("c_registered"))
cm = new ChannelModeRegistered(modechar[0]);
else if (modename.equals_cs("censor"))
cm = new ChannelMode(CMODE_FILTER, modechar[0]);
else if (modename.equals_cs("delayjoin"))
cm = new ChannelMode(CMODE_DELAYEDJOIN, modechar[0]);
else if (modename.equals_cs("flood"))
cm = new ChannelModeFlood(modechar[0], true);
else if (modename.equals_cs("founder"))
cm = new ChannelModeStatus(CMODE_OWNER, modechar.length() > 1 ? modechar[1] : modechar[0], modechar.length() > 1 ? modechar[0] : 0);
else if (modename.equals_cs("halfop"))
cm = new ChannelModeStatus(CMODE_HALFOP, modechar.length() > 1 ? modechar[1] : modechar[0], modechar.length() > 1 ? modechar[0] : 0);
else if (modename.equals_cs("invex"))
cm = new InspIRCdExtBan(CMODE_INVITEOVERRIDE, 'I');
else if (modename.equals_cs("inviteonly"))
cm = new ChannelMode(CMODE_INVITE, modechar[0]);
else if (modename.equals_cs("joinflood"))
cm = new ChannelModeParam(CMODE_JOINFLOOD, modechar[0], true);
else if (modename.equals_cs("key"))
cm = new ChannelModeKey(modechar[0]);
else if (modename.equals_cs("kicknorejoin"))
cm = new ChannelModeParam(CMODE_NOREJOIN, modechar[0], true);
else if (modename.equals_cs("limit"))
cm = new ChannelModeParam(CMODE_LIMIT, modechar[0], true);
else if (modename.equals_cs("moderated"))
cm = new ChannelMode(CMODE_MODERATED, modechar[0]);
else if (modename.equals_cs("nickflood"))
cm = new ChannelModeParam(CMODE_NICKFLOOD, modechar[0], true);
else if (modename.equals_cs("noctcp"))
cm = new ChannelMode(CMODE_NOCTCP, modechar[0]);
else if (modename.equals_cs("noextmsg"))
cm = new ChannelMode(CMODE_NOEXTERNAL, modechar[0]);
else if (modename.equals_cs("nokick"))
cm = new ChannelMode(CMODE_NOKICK, modechar[0]);
else if (modename.equals_cs("noknock"))
cm = new ChannelMode(CMODE_NOKNOCK, modechar[0]);
else if (modename.equals_cs("nonick"))
cm = new ChannelMode(CMODE_NONICK, modechar[0]);
else if (modename.equals_cs("nonotice"))
cm = new ChannelMode(CMODE_NONOTICE, modechar[0]);
else if (modename.equals_cs("op"))
cm = new ChannelModeStatus(CMODE_OP, modechar.length() > 1 ? modechar[1] : modechar[0], modechar.length() > 1 ? modechar[0] : 0);
else if (modename.equals_cs("operonly"))
cm = new ChannelModeOper(modechar[0]);
else if (modename.equals_cs("permanent"))
cm = new ChannelMode(CMODE_PERM, modechar[0]);
else if (modename.equals_cs("private"))
cm = new ChannelMode(CMODE_PRIVATE, modechar[0]);
else if (modename.equals_cs("redirect"))
cm = new ChannelModeParam(CMODE_REDIRECT, modechar[0], true);
else if (modename.equals_cs("reginvite"))
cm = new ChannelMode(CMODE_REGISTEREDONLY, modechar[0]);
else if (modename.equals_cs("regmoderated"))
cm = new ChannelMode(CMODE_REGMODERATED, modechar[0]);
else if (modename.equals_cs("secret"))
cm = new ChannelMode(CMODE_SECRET, modechar[0]);
else if (modename.equals_cs("sslonly"))
cm = new ChannelMode(CMODE_SSL, modechar[0]);
else if (modename.equals_cs("stripcolor"))
cm = new ChannelMode(CMODE_STRIPCOLOR, modechar[0]);
else if (modename.equals_cs("topiclock"))
cm = new ChannelMode(CMODE_TOPIC, modechar[0]);
else if (modename.equals_cs("voice"))
cm = new ChannelModeStatus(CMODE_VOICE, modechar.length() > 1 ? modechar[1] : modechar[0], modechar.length() > 1 ? modechar[0] : 0);
/* Unknown status mode, (customprefix) - add it */
else if (modechar.length() == 2)
cm = new ChannelModeStatus(CMODE_END, modechar[1], modechar[0]);
/* else don't do anything here, we will get it in CAPAB CAPABILITIES */
if (cm)
ModeManager::AddChannelMode(cm);
else
Log() << "Unrecognized mode string in CAPAB CHANMODES: " << capab;
}
}
if (params[0].equals_cs("USERMODES"))
{
spacesepstream ssep(params[1]);
Anope::string capab;
while (ssep.GetToken(capab))
{
Anope::string modename = capab.substr(0, capab.find('='));
Anope::string modechar = capab.substr(capab.find('=') + 1);
UserMode *um = NULL;
if (modename.equals_cs("bot"))
um = new UserMode(UMODE_BOT, modechar[0]);
else if (modename.equals_cs("callerid"))
um = new UserMode(UMODE_CALLERID, modechar[0]);
else if (modename.equals_cs("cloak"))
um = new UserMode(UMODE_CLOAK, modechar[0]);
else if (modename.equals_cs("deaf"))
um = new UserMode(UMODE_DEAF, modechar[0]);
else if (modename.equals_cs("deaf_commonchan"))
um = new UserMode(UMODE_COMMONCHANS, modechar[0]);
else if (modename.equals_cs("helpop"))
um = new UserMode(UMODE_HELPOP, modechar[0]);
else if (modename.equals_cs("hidechans"))
um = new UserMode(UMODE_PRIV, modechar[0]);
else if (modename.equals_cs("hideoper"))
um = new UserMode(UMODE_HIDEOPER, modechar[0]);
else if (modename.equals_cs("invisible"))
um = new UserMode(UMODE_INVIS, modechar[0]);
else if (modename.equals_cs("invis-oper"))
um = new UserMode(UMODE_INVISIBLE_OPER, modechar[0]);
else if (modename.equals_cs("oper"))
um = new UserMode(UMODE_OPER, modechar[0]);
else if (modename.equals_cs("regdeaf"))
um = new UserMode(UMODE_REGPRIV, modechar[0]);
else if (modename.equals_cs("servprotect"))
{
um = new UserMode(UMODE_PROTECTED, modechar[0]);
ircd->pseudoclient_mode = "+Ik"; // XXX
}
else if (modename.equals_cs("showwhois"))
um = new UserMode(UMODE_WHOIS, modechar[0]);
else if (modename.equals_cs("u_censor"))
um = new UserMode(UMODE_FILTER, modechar[0]);
else if (modename.equals_cs("u_registered"))
um = new UserMode(UMODE_REGISTERED, modechar[0]);
else if (modename.equals_cs("u_stripcolor"))
um = new UserMode(UMODE_STRIPCOLOR, modechar[0]);
else if (modename.equals_cs("wallops"))
um = new UserMode(UMODE_WALLOPS, modechar[0]);
if (um)
ModeManager::AddUserMode(um);
else
Log() << "Unrecognized mode string in CAPAB USERMODES: " << capab;
}
}
else if (params[0].equals_cs("MODULES"))
{
spacesepstream ssep(params[1]);
Anope::string module;
while (ssep.GetToken(module))
{
if (module.equals_cs("m_svshold.so"))
has_svsholdmod = true;
else if (module.find("m_rline.so") == 0)
{
has_rlinemod = true;
if (!Config->RegexEngine.empty() && Config->RegexEngine != module.substr(11))
Log() << "Warning: InspIRCd is using regex engine " << module.substr(11) << ", but we have " << Config->RegexEngine << ". This may cause inconsistencies.";
}
}
}
else if (params[0].equals_cs("MODSUPPORT"))
{
spacesepstream ssep(params[1]);
Anope::string module;
while (ssep.GetToken(module))
{
if (module.equals_cs("m_services_account.so"))
has_servicesmod = true;
else if (module.equals_cs("m_chghost.so"))
has_chghostmod = true;
else if (module.equals_cs("m_chgident.so"))
has_chgidentmod = true;
}
}
else if (params[0].equals_cs("CAPABILITIES"))
{
spacesepstream ssep(params[1]);
Anope::string capab;
while (ssep.GetToken(capab))
{
if (capab.find("CHANMODES") != Anope::string::npos)
{
Anope::string modes(capab.begin() + 10, capab.end());
commasepstream sep(modes);
Anope::string modebuf;
sep.GetToken(modebuf);
for (size_t t = 0, end = modebuf.length(); t < end; ++t)
{
if (ModeManager::FindChannelModeByChar(modebuf[t]))
continue;
ModeManager::AddChannelMode(new ChannelModeList(CMODE_END, modebuf[t]));
}
sep.GetToken(modebuf);
for (size_t t = 0, end = modebuf.length(); t < end; ++t)
{
if (ModeManager::FindChannelModeByChar(modebuf[t]))
continue;
ModeManager::AddChannelMode(new ChannelModeParam(CMODE_END, modebuf[t]));
}
sep.GetToken(modebuf);
for (size_t t = 0, end = modebuf.length(); t < end; ++t)
{
if (ModeManager::FindChannelModeByChar(modebuf[t]))
continue;
ModeManager::AddChannelMode(new ChannelModeParam(CMODE_END, true));
}
sep.GetToken(modebuf);
for (size_t t = 0, end = modebuf.length(); t < end; ++t)
{
if (ModeManager::FindChannelModeByChar(modebuf[t]))
continue;
ModeManager::AddChannelMode(new ChannelMode(CMODE_END, modebuf[t]));
}
}
else if (capab.find("USERMODES") != Anope::string::npos)
{
Anope::string modes(capab.begin() + 10, capab.end());
commasepstream sep(modes);
Anope::string modebuf;
sep.GetToken(modebuf);
sep.GetToken(modebuf);
if (sep.GetToken(modebuf))
for (size_t t = 0, end = modebuf.length(); t < end; ++t)
ModeManager::AddUserMode(new UserModeParam(UMODE_END, modebuf[t]));
if (sep.GetToken(modebuf))
for (size_t t = 0, end = modebuf.length(); t < end; ++t)
ModeManager::AddUserMode(new UserMode(UMODE_END, modebuf[t]));
}
else if (capab.find("MAXMODES=") != Anope::string::npos)
{
Anope::string maxmodes(capab.begin() + 9, capab.end());
ircd->maxmodes = maxmodes.is_pos_number_only() ? convertTo<unsigned>(maxmodes) : 3;
}
else if (capab.find("PREFIX=") != Anope::string::npos)
{
Anope::string modes(capab.begin() + 8, capab.begin() + capab.find(')'));
Anope::string chars(capab.begin() + capab.find(')') + 1, capab.end());
unsigned short level = modes.length() - 1;
for (size_t t = 0, end = modes.length(); t < end; ++t)
{
ChannelMode *cm = ModeManager::FindChannelModeByChar(modes[t]);
if (cm == NULL || cm->Type != MODE_STATUS)
{
Log() << "CAPAB PREFIX gave unknown channel status mode " << modes[t];
continue;
}
ChannelModeStatus *cms = anope_dynamic_static_cast<ChannelModeStatus *>(cm);
cms->Level = level--;
}
}
}
}
else if (params[0].equals_cs("END"))
{
if (!has_servicesmod)
{
UplinkSocket::Message() << "ERROR :m_services_account.so is not loaded. This is required by Anope";
quitmsg = "ERROR: Remote server does not have the m_services_account module loaded, and this is required.";
quitting = true;
return false;
}
if (!ModeManager::FindUserModeByName(UMODE_PRIV))
{
UplinkSocket::Message() << "ERROR :m_hidechans.so is not loaded. This is required by Anope";
quitmsg = "ERROR: Remote server does not have the m_hidechans module loaded, and this is required.";
quitting = true;
return false;
}
if (!has_svsholdmod)
Log() << "SVSHOLD missing, Usage disabled until module is loaded.";
if (!has_chghostmod)
Log() << "CHGHOST missing, Usage disabled until module is loaded.";
if (!has_chgidentmod)
Log() << "CHGIDENT missing, Usage disabled until module is loaded.";
ircd->svshold = has_svsholdmod;
}
IRCdMessage::OnCapab(source, params);
return true;
}
};
class ProtoInspIRCd : public Module
{
Message message_endburst, message_time,
message_rsquit, message_svsmode, message_fhost,
message_chgident, message_fname, message_fjoin, message_fmode,
message_ftopic, message_opertype, message_idle, message_metadata,
message_encap;
InspIRCdProto ircd_proto;
Inspircd20IRCdMessage ircd_message;
public:
ProtoInspIRCd(const Anope::string &modname, const Anope::string &creator) : Module(modname, creator, PROTOCOL),
message_endburst("ENDBURST", event_endburst),
message_time("TIME", event_time), message_rsquit("RSQUIT", event_rsquit),
message_svsmode("SVSMODE", OnMode), message_fhost("FHOST", event_chghost),
message_chgident("FIDENT", event_chgident), message_fname("FNAME", event_chgname),
message_fjoin("FJOIN", OnSJoin),
message_fmode("FMODE", event_fmode), message_ftopic("FTOPIC", event_ftopic),
message_opertype("OPERTYPE", event_opertype), message_idle("IDLE", event_idle),
message_metadata("METADATA", event_metadata), message_encap("ENCAP", event_encap)
{
this->SetAuthor("Anope");
pmodule_ircd_var(&myIrcd);
pmodule_ircd_proto(&this->ircd_proto);
pmodule_ircd_message(&this->ircd_message);
Capab.insert("NOQUIT");
Implementation i[] = { I_OnUserNickChange, I_OnServerSync, I_OnChannelCreate, I_OnChanRegistered, I_OnDelChan, I_OnMLock, I_OnUnMLock };
ModuleManager::Attach(i, this, sizeof(i) / sizeof(Implementation));
if (Config->Numeric.empty())
{
Anope::string numeric = ts6_sid_retrieve();
Me->SetSID(numeric);
Config->Numeric = numeric;
}
for (botinfo_map::iterator it = BotListByNick->begin(), it_end = BotListByNick->end(); it != it_end; ++it)
it->second->GenerateUID();
}
~ProtoInspIRCd()
{
pmodule_ircd_var(NULL);
pmodule_ircd_proto(NULL);
pmodule_ircd_message(NULL);
}
void OnUserNickChange(User *u, const Anope::string &) anope_override
{
u->RemoveModeInternal(ModeManager::FindUserModeByName(UMODE_REGISTERED));
}
void OnServerSync(Server *s) anope_override
{
if (nickserv)
for (Anope::insensitive_map<User *>::iterator it = UserListByNick.begin(); it != UserListByNick.end(); ++it)
{
User *u = it->second;
if (u->server == s && !u->IsIdentified())
nickserv->Validate(u);
}
}
void OnChannelCreate(Channel *c) anope_override
{
if (c->ci && Config->UseServerSideMLock)
this->OnChanRegistered(c->ci);
}
void OnChanRegistered(ChannelInfo *ci) anope_override
{
if (!Config->UseServerSideMLock)
return;
Anope::string modes = ci->GetMLockAsString(false).replace_all_cs("+", "").replace_all_cs("-", "");
UplinkSocket::Message(Me) << "METADATA " << ci->name << " mlock :" << modes;
}
void OnDelChan(ChannelInfo *ci) anope_override
{
if (!Config->UseServerSideMLock)
return;
UplinkSocket::Message(Me) << "METADATA " << ci->name << " mlock :";
}
EventReturn OnMLock(ChannelInfo *ci, ModeLock *lock) anope_override
{
ChannelMode *cm = ModeManager::FindChannelModeByName(lock->name);
if (cm && ci->c && (cm->Type == MODE_REGULAR || cm->Type == MODE_PARAM) && Config->UseServerSideMLock)
{
Anope::string modes = ci->GetMLockAsString(false).replace_all_cs("+", "").replace_all_cs("-", "") + cm->ModeChar;
UplinkSocket::Message(Me) << "METADATA " << ci->name << " mlock :" << modes;
}
return EVENT_CONTINUE;
}
EventReturn OnUnMLock(ChannelInfo *ci, ModeLock *lock) anope_override
{
ChannelMode *cm = ModeManager::FindChannelModeByName(lock->name);
if (cm && ci->c && (cm->Type == MODE_REGULAR || cm->Type == MODE_PARAM) && Config->UseServerSideMLock)
{
Anope::string modes = ci->GetMLockAsString(false).replace_all_cs("+", "").replace_all_cs("-", "").replace_all_cs(cm->ModeChar, "");
UplinkSocket::Message(Me) << "METADATA " << ci->name << " mlock :" << modes;
}
return EVENT_CONTINUE;
}
};
MODULE_INIT(ProtoInspIRCd)
View Git Blame Copy Permalink