1 files changed, 334 insertions, 0 deletions
diff --git a/modules/operserv/main/operserv.cpp b/modules/operserv/main/operserv.cpp
new file mode 100644
index 000000000..b439653f9
--- /dev/null
+++ b/modules/operserv/main/operserv.cpp
@@ -0,0 +1,334 @@
+/*
+ * Anope IRC Services
+ *
+ * Copyright (C) 2011-2017 Anope Team <team@anope.org>
+ *
+ * This file is part of Anope. Anope is free software; you can
+ * redistribute it and/or modify it under the terms of the GNU
+ * General Public License as published by the Free Software
+ * Foundation, version 2.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, see see <http://www.gnu.org/licenses/>.
+ */
+
+#include "module.h"
+#include "modules/help.h"
+#include "modules/nickserv.h"
+
+class SGLineManager : public XLineManager
+{
+ public:
+	SGLineManager(Module *creator) : XLineManager(creator, "xlinemanager/sgline", 'G') { }
+
+	void OnMatch(User *u, XLine *x) override
+	{
+		this->Send(u, x);
+	}
+
+	void OnExpire(XLine *x) override
+	{
+		Anope::Logger.Bot("OperServ").Category("expire/akill").Log(_("AKILL on \002{0}\002 has expired"),
+			x->GetMask());
+	}
+
+	void Send(User *u, XLine *x) override
+	{
+		IRCD->Send<messages::Akill>(u, x);
+	}
+
+	void SendDel(XLine *x) override
+	{
+		IRCD->Send<messages::AkillDel>(x);
+	}
+
+	bool Check(User *u, XLine *x) override
+	{
+		if (x->regex)
+		{
+			Anope::string uh = u->GetIdent() + "@" + u->host, nuhr = u->nick + "!" + uh + "#" + u->realname;
+			return std::regex_match(uh.str(), *x->regex) || std::regex_match(nuhr.str(), *x->regex);
+		}
+
+		if (!x->GetNick().empty() && !Anope::Match(u->nick, x->GetNick()))
+			return false;
+
+		if (!x->GetUser().empty() && !Anope::Match(u->GetIdent(), x->GetUser()))
+			return false;
+
+		if (!x->GetReal().empty() && !Anope::Match(u->realname, x->GetReal()))
+			return false;
+
+		if (x->c && x->c->match(u->ip))
+			return true;
+
+		if (x->GetHost().empty() || Anope::Match(u->host, x->GetHost()) || Anope::Match(u->ip.addr(), x->GetHost()))
+			return true;
+
+		return false;
+	}
+};
+
+class SQLineManager : public XLineManager
+{
+ public:
+	SQLineManager(Module *creator) : XLineManager(creator, "xlinemanager/sqline", 'Q') { }
+
+	void OnMatch(User *u, XLine *x) override
+	{
+		this->Send(u, x);
+	}
+
+	void OnExpire(XLine *x) override
+	{
+		Anope::Logger.Bot("OperServ").Category("expire/sqline").Log(_("SQLINE on \002{0}\002 has expired"), x->GetMask());
+	}
+
+	void Send(User *u, XLine *x) override
+	{
+		if (!IRCD->CanSQLine)
+		{
+			if (!u)
+				;
+			else if (NickServ::service)
+				NickServ::service->Collide(u, NULL);
+			else
+				u->Kill(Config->GetClient("OperServ"), "Q-Lined: " + x->GetReason());
+		}
+		else if (x->IsRegex())
+		{
+			if (u)
+				u->Kill(Config->GetClient("OperServ"), "Q-Lined: " + x->GetReason());
+		}
+		else if (x->GetMask()[0] != '#' || IRCD->CanSQLineChannel)
+		{
+			IRCD->Send<messages::SQLine>(u, x);
+			/* If it is an oper, assume they're walking it, otherwise kill for good measure */
+			if (u && !u->HasMode("OPER"))
+				u->Kill(Config->GetClient("OperServ"), "Q-Lined: " + x->GetReason());
+		}
+	}
+
+	void SendDel(XLine *x) override
+	{
+		if (!IRCD->CanSQLine || x->IsRegex())
+			;
+		else if (x->GetMask()[0] != '#' || IRCD->CanSQLineChannel)
+			IRCD->Send<messages::SQLineDel>(x);
+	}
+
+	bool Check(User *u, XLine *x) override
+	{
+		if (x->regex)
+			return std::regex_match(u->nick.c_str(), *x->regex);
+		return Anope::Match(u->nick, x->GetMask());
+	}
+
+	XLine *CheckChannel(Channel *c)
+	{
+		for (XLine *x : this->GetXLines())
+		{
+			if (x->regex)
+			{
+				if (std::regex_match(c->name.str(), *x->regex))
+					return x;
+			}
+			else
+			{
+				if (x->GetMask().empty() || x->GetMask()[0] != '#')
+					continue;
+
+				if (Anope::Match(c->name, x->GetMask(), false, true))
+					return x;
+			}
+		}
+		return nullptr;
+	}
+};
+
+class SNLineManager : public XLineManager
+{
+ public:
+	SNLineManager(Module *creator) : XLineManager(creator, "xlinemanager/snline", 'N') { }
+
+	void OnMatch(User *u, XLine *x) override
+	{
+		this->Send(u, x);
+	}
+
+	void OnExpire(XLine *x) override
+	{
+		Anope::Logger.Bot("OperServ").Category("expire/snline").Log(_("SNLINE on \002{0}\002 has expired"), x->GetMask());
+	}
+
+	void Send(User *u, XLine *x) override
+	{
+		if (IRCD->CanSNLine && !x->IsRegex())
+			IRCD->Send<messages::SGLine>(u, x);
+
+		if (u)
+			u->Kill(Config->GetClient("OperServ"), "SNLined: " + x->GetReason());
+	}
+
+	void SendDel(XLine *x) override
+	{
+		if (IRCD->CanSNLine && !x->IsRegex())
+			IRCD->Send<messages::SGLineDel>(x);
+	}
+
+	bool Check(User *u, XLine *x) override
+	{
+		if (x->regex)
+			return std::regex_match(u->realname.str(), *x->regex);
+		return Anope::Match(u->realname, x->GetMask(), false, true);
+	}
+};
+
+class OperServCore : public Module
+	, public EventHook<Event::BotPrivmsg>
+	, public EventHook<Event::ServerQuit>
+	, public EventHook<Event::UserModeSet>
+	, public EventHook<Event::UserModeUnset>
+	, public EventHook<Event::UserConnect>
+	, public EventHook<Event::UserNickChange>
+	, public EventHook<Event::CheckKick>
+	, public EventHook<Event::Help>
+	, public EventHook<Event::Log>
+{
+	Reference<ServiceBot> OperServ;
+	SGLineManager sglines;
+	SQLineManager sqlines;
+	SNLineManager snlines;
+
+ public:
+	OperServCore(const Anope::string &modname, const Anope::string &creator) : Module(modname, creator, PSEUDOCLIENT | VENDOR)
+		, EventHook<Event::BotPrivmsg>(this)
+		, EventHook<Event::ServerQuit>(this)
+		, EventHook<Event::UserModeSet>(this)
+		, EventHook<Event::UserModeUnset>(this)
+		, EventHook<Event::UserConnect>(this)
+		, EventHook<Event::UserNickChange>(this)
+		, EventHook<Event::CheckKick>(this)
+		, EventHook<Event::Help>(this)
+		, EventHook<Event::Log>(this)
+		, sglines(this)
+		, sqlines(this)
+		, snlines(this)
+	{
+
+		/* Yes, these are in this order for a reason. Most violent->least violent. */
+		XLineManager::RegisterXLineManager(&sglines);
+		XLineManager::RegisterXLineManager(&sqlines);
+		XLineManager::RegisterXLineManager(&snlines);
+	}
+
+	~OperServCore()
+	{
+		this->sglines.Clear();
+		this->sqlines.Clear();
+		this->snlines.Clear();
+
+		XLineManager::UnregisterXLineManager(&sglines);
+		XLineManager::UnregisterXLineManager(&sqlines);
+		XLineManager::UnregisterXLineManager(&snlines);
+	}
+
+	void OnReload(Configuration::Conf *conf) override
+	{
+		const Anope::string &osnick = conf->GetModule(this)->Get<Anope::string>("client");
+
+		if (osnick.empty())
+			throw ConfigException(Module::name + ": <client> must be defined");
+
+		ServiceBot *bi = ServiceBot::Find(osnick, true);
+		if (!bi)
+			throw ConfigException(Module::name + ": no bot named " + osnick);
+
+		OperServ = bi;
+	}
+
+	EventReturn OnBotPrivmsg(User *u, ServiceBot *bi, Anope::string &message) override
+	{
+		if (bi == OperServ && !u->HasMode("OPER") && Config->GetModule(this)->Get<bool>("opersonly"))
+		{
+			u->SendMessage(bi, _("Access denied."));
+			logger.Bot(bi).Category("bados").Log(_("Denied access to {0} from {1} (non-oper)"), bi->nick, u->GetMask());
+			return EVENT_STOP;
+		}
+
+		return EVENT_CONTINUE;
+	}
+
+	void OnServerQuit(Server *server) override
+	{
+		if (server->IsJuped())
+			server->logger.Bot(OperServ).Category("squit").Log(_("Received SQUIT for juped server {0}"), server->GetName());
+	}
+
+	void OnUserModeSet(const MessageSource &setter, User *u, const Anope::string &mname) override
+	{
+		if (mname == "OPER")
+			u->logger.Bot(OperServ).Category("oper").Log(_("{0} is now an IRC operator."), u->GetMask());
+	}
+
+	void OnUserModeUnset(const MessageSource &setter, User *u, const Anope::string &mname) override
+	{
+		if (mname == "OPER")
+			u->logger.Bot(OperServ).Category("oper").Log(_("{0} is no longer an IRC operator"), u->GetMask());
+	}
+
+	void OnUserConnect(User *u, bool &exempt) override
+	{
+		if (!u->Quitting() && !exempt)
+			XLineManager::CheckAll(u);
+	}
+
+	void OnUserNickChange(User *u, const Anope::string &oldnick) override
+	{
+		if (!u->HasMode("OPER"))
+			this->sqlines.CheckAllXLines(u);
+	}
+
+	EventReturn OnCheckKick(User *u, Channel *c, Anope::string &mask, Anope::string &reason) override
+	{
+		XLine *x = this->sqlines.CheckChannel(c);
+		if (x)
+		{
+			this->sqlines.OnMatch(u, x);
+			reason = x->GetReason();
+			return EVENT_STOP;
+		}
+
+		return EVENT_CONTINUE;
+	}
+
+	EventReturn OnPreHelp(CommandSource &source, const std::vector<Anope::string> &params) override
+	{
+		if (!params.empty() || source.c || source.service != *OperServ)
+			return EVENT_CONTINUE;
+
+		source.Reply(_("{0} commands:"), OperServ->nick);
+		return EVENT_CONTINUE;
+	}
+
+	void OnPostHelp(CommandSource &source, const std::vector<Anope::string> &params) override
+	{
+	}
+
+	void OnLog(Logger *l) override
+	{
+#warning ""
+#if 0
+		if (l->type == LogType::SERVER)
+			l->bi = OperServ;
+#endif
+	}
+};
+
+MODULE_INIT(OperServCore)
+