Added in support for live updating MySQL databases and the ability to execute commands to Anope through MySQL. Currently database support only applies to NickServ, ChanServ and BotServ but will be expanded soon.

git-svn-id: http://anope.svn.sourceforge.net/svnroot/anope/trunk@2798 5417fbe8-f217-4b02-8779-1006273d7864

1 files changed, 740 insertions, 0 deletions

diff --git a/src/modules/mysql/db_mysql_write.cpp b/src/modules/mysql/db_mysql_write.cpp
new file mode 100644
index 000000000..21f2513d1
--- /dev/null
+++ b/src/modules/mysql/db_mysql_write.cpp
@@ -0,0 +1,740 @@
+/* RequiredLibraries: mysqlpp */
+
+#include "db_mysql.h"
+
+static std::string BuildFlagsList(ChannelInfo *ci)
+{
+	std::string ret;
+
+	for (int i = 0; ChannelFlags[i].Flag != -1; ++i)
+	{
+		if (ci->HasFlag(ChannelFlags[i].Flag))
+		{
+			ret += " " + ChannelFlags[i].Name;
+		}
+	}
+
+	if (!ret.empty())
+		ret.erase(ret.begin());
+
+	return ret;
+}
+
+static std::string BuildFlagsList(NickAlias *na)
+{
+	std::string ret;
+
+	for (int i = 0; NickAliasFlags[i].Flag != -1; ++i)
+	{
+		if (na->HasFlag(NickAliasFlags[i].Flag))
+		{
+			ret += " " + NickAliasFlags[i].Name;
+		}
+	}
+
+	if (!ret.empty())
+		ret.erase(ret.begin());
+
+	return ret;
+}
+
+static std::string BuildFlagsList(NickCore *nc)
+{
+	std::string ret;
+
+	for (int i = 0; NickCoreFlags[i].Flag != -1; ++i)
+	{
+		if (nc->HasFlag(NickCoreFlags[i].Flag))
+		{
+			ret += " " + NickCoreFlags[i].Name;
+		}
+	}
+
+	if (!ret.empty())
+		ret.erase(ret.begin());
+
+	return ret;
+}
+
+static std::string MakeMLock(ChannelInfo *ci, bool status)
+{
+	std::string ret;
+
+	for (int i = 0; ChannelModes[i].Mode != -1; ++i)
+	{
+		if (ci->HasMLock(ChannelModes[i].Mode, status))
+		{
+			ret += " " + ChannelModes[i].Name;
+		}
+	}
+
+	if (!ret.empty())
+		ret.erase(ret.begin());
+
+	return ret;
+}
+
+static inline std::string GetMLockOn(ChannelInfo *ci)
+{
+	return MakeMLock(ci, true);
+}
+
+static inline std::string GetMLockOff(ChannelInfo *ci)
+{
+	return MakeMLock(ci, false);
+}
+
+static std::string GetMLockParams(ChannelInfo *ci)
+{
+	std::string ret;
+
+	for (int i = 0; ChannelModes[i].Mode != -1; ++i)
+	{
+		std::string param;
+		if (ci->GetParam(ChannelModes[i].Mode, &param))
+		{
+			ret += " " + param;
+		}
+	}
+
+	if (!ret.empty())
+		ret.erase(ret.begin());
+
+	return ret;
+}
+
+static std::string GetBotFlags(Flags<BotServFlag>& Flags)
+{
+	std::string buf;
+
+	for (int i = 0; BotFlags[i].Flag != -1; ++i)
+	{
+		if (Flags.HasFlag(BotFlags[i].Flag))
+		{
+			buf += " " + BotFlags[i].Name;
+		}
+	}
+
+	if (!buf.empty())
+		buf.erase(buf.begin());
+
+	return buf;
+}
+
+static std::string GetBotServFlags(BotInfo *bi)
+{
+	std::string buf;
+
+	for (int i = 0; BotServFlags[i].Flag != -1; ++i)
+	{
+		if (bi->HasFlag(BotServFlags[i].Flag))
+		{
+			buf += " " + BotServFlags[i].Name;
+		}
+	}
+
+	if (!buf.empty())
+		buf.erase(buf.begin());;
+	
+	return buf;
+}
+
+static NickAlias *CurNick = NULL;
+static NickCore *CurCore = NULL;
+static ChannelInfo *CurChannel = NULL;
+
+void Write(const std::string &data)
+{
+	mysqlpp::Query query(Me->Con);
+	query << "INSERT DELAYED INTO `anope_extra` (data) VALUES(" << mysqlpp::quote << data << ")";
+	ExecuteQuery(query);
+}
+
+void WriteMetadata(const std::string &key, const std::string &data)
+{
+	mysqlpp::Query query(Me->Con);
+	query << "INSERT DELAYED INTO `anope_metadata` (name, value) VALUES(" << mysqlpp::quote << key << ", " << mysqlpp::quote << data << ")";
+	ExecuteQuery(query);
+}
+
+void WriteNickMetadata(const std::string &key, const std::string &data)
+{
+	if (!CurNick)
+		throw CoreException("WriteNickMetadata without a nick to write");
+
+	mysqlpp::Query query(Me->Con);
+	query << "INSERT DELAYED INTO `anope_ns_alias_metadata` (nick, name, value) VALUES(" << mysqlpp::quote << CurNick->nick << ", " << mysqlpp::quote << key << ", " << mysqlpp::quote << data << ")";
+	ExecuteQuery(query);
+}
+
+void WriteCoreMetadata(const std::string &key, const std::string &data)
+{
+	if (!CurCore)
+		throw CoreException("WritCoreMetadata without a core to write");
+	
+	mysqlpp::Query query(Me->Con);
+	query << "INSERT DELAYED INTO `anope_ns_core_metadata` (nick, name, value) VALUES(" << mysqlpp::quote << CurCore->display << ", " << mysqlpp::quote << key << ", " << mysqlpp::quote << data << ")";
+	ExecuteQuery(query);
+}
+
+void WriteChannelMetadata(const std::string &key, const std::string &data)
+{
+	if (!CurChannel)
+		throw CoreException("WriteChannelMetadata without a channel to write");
+
+	mysqlpp::Query query(Me->Con);
+	query << "INSERT DELAYED INTO `anope_cs_info_metadata` (channel, name, value) VALUES(" << mysqlpp::quote << CurChannel->name << ", " << mysqlpp::quote << key << ", " << mysqlpp::quote << data << ")";
+	ExecuteQuery(query);
+}
+
+static void SaveDatabases()
+{
+	int i;
+	mysqlpp::Query query(Me->Con);
+
+	query << "TRUNCATE TABLE `anope_ns_access`";
+	ExecuteQuery(query);
+	query << "TRUNCATE TABLE `anope_ns_core`";
+	ExecuteQuery(query);
+	for (i = 0; i < 1024; ++i)
+	{
+		for (NickCore *nc = nclists[i]; nc; nc = nc->next)
+		{
+			std::string flags = BuildFlagsList(nc);
+			query << "INSERT DELAYED INTO `anope_ns_core` (display, pass, email, greet, icq, url, flags, language, channelcount, memomax) VALUES(";
+			query << mysqlpp::quote << nc->display << ", " << mysqlpp::quote << nc->pass << ", ";
+			query << mysqlpp::quote << (nc->email ? nc->email : "") << ", " << mysqlpp::quote << (nc->greet ? nc->greet : "");
+			query << ", " << nc->icq << ", " << mysqlpp::quote << (nc->url ? nc->url : "");
+			query << ", '" << (!flags.empty() ? flags : "") << "', " << nc->language << ", " << nc->channelcount << ", ";
+			query << nc->memos.memomax << ") ";
+			query << "ON DUPLICATE KEY UPDATE pass=VALUES(pass), email=VALUES(email), greet=VALUES(greet), icq=VALUES(icq), flags=VALUES(flags), language=VALUES(language), ";
+			query << "channelcount=VALUES(channelcount), memomax=VALUES(memomax)";
+			ExecuteQuery(query);
+
+			for (std::vector<std::string>::iterator it = nc->access.begin(); it != nc->access.end(); ++it)
+			{
+				query << "INSERT DELAYED INTO `anope_ns_access` (display, access) VALUES(" << mysqlpp::quote << nc->display << ", " << mysqlpp::quote << *it << ")";
+				ExecuteQuery(query);
+			}
+		}
+	}
+
+	query << "TRUNCATE TABLE `anope_ns_alias`";
+	ExecuteQuery(query);
+	for (i = 0; i < 1024; ++i)
+	{
+		for (NickAlias *na = nalists[i]; na; na = na->next)
+		{
+			std::string flags = BuildFlagsList(na);
+			query << "INSERT DELAYED INTO `anope_ns_alias` (nick, last_quit, last_realname, last_usermask, time_registered, last_seen, flags, display) VALUES(";
+			query << mysqlpp::quote << na->nick << ", " << mysqlpp::quote << (na->last_quit ? na->last_quit : "") << ", ";
+			query << mysqlpp::quote << (na->last_realname ? na->last_realname : "") << ", ";
+			query << mysqlpp::quote << (na->last_usermask ? na->last_usermask : "") << ", " << na->time_registered << ", " << na->last_seen;
+			query << ", '" << (!flags.empty() ? flags : "") << "', " << mysqlpp::quote << na->nc->display << ") ";
+			query << "ON DUPLICATE KEY UPDATE last_quit=VALUES(last_quit), last_realname=VALUES(last_realname), last_usermask=VALUES(last_usermask), time_registered=VALUES(time_registered), last_seen=VALUES(last_seen), flags=VALUES(flags), display=VALUES(display)";
+			ExecuteQuery(query);
+		}
+	}
+
+	query << "TRUNCATE TABLE `anope_bs_core`";
+	ExecuteQuery(query);
+	for (i = 0; i < 256; ++i)
+	{
+		for (BotInfo *bi = botlists[i]; bi; bi = bi->next)
+		{
+			query << "INSERT DELAYED INTO `anope_bs_core` (nick, user, host, rname, flags, created, chancount) VALUES(";
+			query << mysqlpp::quote << bi->nick << ", " << mysqlpp::quote << bi->user << ", " << mysqlpp::quote << bi->host << ", ";
+			query << mysqlpp::quote << bi->real << ", '" << GetBotServFlags(bi) << "', " << bi->created << ", " << bi->chancount << ") ";
+			query << "ON DUPLICATE KEY UPDATE nick=VALUES(nick), user=VALUES(user), host=VALUES(host), rname=VALUES(rname), flags=VALUES(flags), created=VALUES(created), chancount=VALUES(chancount)";
+			ExecuteQuery(query);
+		}
+	}
+
+	query << "TRUNCATE TABLE `anope_cs_info`";
+	ExecuteQuery(query);
+	query << "TRUNCATE TABLE `anope_cs_access`";
+	ExecuteQuery(query);
+
+	for (i = 0; i < 256; ++i)
+	{
+		for (ChannelInfo *ci = chanlists[i]; ci; ci = ci->next)
+		{
+			std::string flags = BuildFlagsList(ci), mlockon = GetMLockOn(ci), mlockoff = GetMLockOff(ci), mlockparams = GetMLockParams(ci);
+			query << "INSERT DELAYED INTO `anope_cs_info` (name, founder, successor, descr, url, email, time_registered, last_used, last_topic, last_topic_setter, last_topic_time, flags, forbidby, forbidreason, bantype, mlock_on, mlock_off, mlock_params, entry_message, memomax, botnick, botflags, capsmin, capspercent, floodlines, floodsecs, repeattimes) VALUES(";
+			query << mysqlpp::quote << ci->name << ", " << mysqlpp::quote << (ci->founder ? ci->founder->display : "") << ", ";
+			query << mysqlpp::quote << (ci->successor ? ci->successor->display : "") << ", " << mysqlpp::quote << ci->desc << ", ";
+			query << mysqlpp::quote << (ci->url ? ci->url : "") << ", " << mysqlpp::quote << (ci->email ? ci->email : "") << ", ";
+			query << ci->time_registered << ", " << ci->last_used << ", " << mysqlpp::quote << (ci->last_topic ? ci->last_topic : "");
+			query << ", " << mysqlpp::quote << (!ci->last_topic_setter.empty() ? ci->last_topic_setter : "");
+			query << ", " << ci->last_topic_time << ", '" << (!flags.empty() ? flags : "") << "', ";
+			query << mysqlpp::quote << (ci->forbidby ? ci->forbidby : "") << ", " << mysqlpp::quote << (ci->forbidreason ? ci->forbidreason : "") << ", " << ci->bantype << ", '";
+			query << mlockon << "', '" << mlockoff << "', '";
+			query << mlockparams << "', " << mysqlpp::quote << (ci->entry_message ? ci->entry_message : "") << ", ";
+			query << ci->memos.memomax << ", " << mysqlpp::quote << (ci->bi ? ci->bi->nick : "") << ", '" << GetBotFlags(ci->botflags);
+			query << "', " << ci->capsmin << ", " << ci->capspercent << ", " << ci->floodlines;
+			query << ", " << ci->floodsecs << ", " << ci->repeattimes << ") ";
+			query << "ON DUPLICATE KEY UPDATE founder=VALUES(founder), successor=VALUES(successor), descr=VALUES(descr), url=VALUES(url),  email=VALUES(email), time_registered=VALUES(time_registered), last_used=VALUES(last_used), last_topic=VALUES(last_topic), last_topic_setter=VALUES(last_topic_setter), last_topic_time=VALUES(last_topic_time), flags=VALUES(flags), forbidby=VALUES(forbidby), forbidreason=VALUES(forbidreason), bantype=VALUES(bantype), mlock_on=VALUES(mlock_on), mlock_off=VALUES(mlock_off), mlock_params=VALUES(mlock_params), entry_message=VALUES(entry_message), memomax=VALUES(memomax), botnick=VALUES(botnick), botflags=VALUES(botflags), capsmin=VALUES(capsmin), capspercent=VALUES(capspercent), floodlines=VALUES(floodlines), floodsecs=VALUES(floodsecs), repeattimes=VALUES(repeattimes)";
+			ExecuteQuery(query);
+
+			for (unsigned j = 0; j < ci->GetAccessCount(); ++j)
+			{
+				ChanAccess *access = ci->GetAccess(j);
+
+				if (access->in_use)
+				{
+					query << "INSERT DELAYED INTO `anope_cs_access` (level, display, channel, last_seen, creator) VALUES('" << access->level << "', " << mysqlpp::quote << access->nc->display << ", " << mysqlpp::quote << ci->name << ", " << access->last_seen << ", " << mysqlpp::quote << access->creator << ") ON DUPLICATE KEY UPDATE level=VALUES(level), last_seen=VALUES(last_seen), creator=VALUES(creator)";
+					ExecuteQuery(query);
+				}
+			}
+
+			query << "TRUNCATE TABLE `anope_cs_levels`";
+			ExecuteQuery(query);
+			for (int k = 0; k < CA_SIZE; ++k)
+			{
+				query << "INSERT DELAYED INTO `anope_cs_levels` (channel, position, level) VALUES(" << mysqlpp::quote << ci->name << ", '" << k << "', '" << ci->levels[k] << "') ON DUPLICATE KEY UPDATE position=VALUES(position), level=VALUES(level)";
+				ExecuteQuery(query);
+			}
+		}
+	}
+
+	query << "TRUNCATE TABLE `anope_ns_request`";
+	ExecuteQuery(query);
+
+	for (i = 0; i < 1024; i++)
+	{
+		for (NickRequest *nr = nrlists[i]; nr; nr = nr->next)
+		{
+			query << "INSERT DELAYED INTO `anope_ns_request` (nick, passcode, password, email, requested) VALUES(" << mysqlpp::quote << nr->nick << ", '" << nr->passcode << "', '" << nr->password << "', " << mysqlpp::quote << nr->email << ", '" << nr->requested << "') ON DUPLICATE KEY UPDATE passcode=VALUES(passcode), pasword=VALUES(password), email=VALUES(email), requests=VALUES(requested)";
+			ExecuteQuery(query);
+		}
+	}
+}
+
+class CommandSyncSQL : public Command
+{
+ public:
+	CommandSyncSQL(const std::string &cname) : Command(cname, 0, 0)
+	{
+	}
+
+	CommandReturn Execute(User *u, const std::vector<ci::string> &params)
+	{
+		notice_lang(Config.s_OperServ, u, MYSQL_SYNC_UPDATING);
+		SaveDatabases();
+		notice_lang(Config.s_OperServ, u, MYSQL_SYNC_UPDATED);
+		return MOD_CONT;
+	}
+};
+
+class DBMySQLWrite : public DBMySQL
+{
+ public:
+	DBMySQLWrite(const std::string &modname, const std::string &creator) : DBMySQL(modname, creator)
+	{
+		ModuleManager::Attach(I_OnServerConnect, this);
+
+		this->AddCommand(OPERSERV, new CommandSyncSQL("SQLSYNC"));
+	}
+
+	~DBMySQLWrite()
+	{
+	}
+
+	void OnServerConnect()
+	{
+		Implementation i[] = {
+			/* Misc */
+			I_OnSaveDatabase, I_OnPostCommand,
+			/* NickServ */
+			I_OnNickAddAccess, I_OnNickEraseAccess, I_OnNickClearAccess,
+			I_OnDelCore, I_OnNickForbidden, I_OnNickGroup, I_OnMakeNickRequest,
+			I_OnDelNickRequest, I_OnNickRegister, I_OnChangeCoreDisplay,
+			I_OnNickSuspended,
+			/* Chanserv */
+			I_OnAccessAdd, I_OnAccessDel, I_OnAccessChange, I_OnAccessClear,
+			I_OnChanForbidden, I_OnDelChan, I_OnChanRegistered, I_OnChanSuspend,
+			/* BotServ */
+			I_OnBotCreate, I_OnBotChange, I_OnBotDelete,
+			I_OnBotAssign, I_OnBotUnAssign
+		};
+		ModuleManager::Attach(i, this, 26);
+	}
+
+	EventReturn OnSaveDatabase()
+	{
+		for (int i = 0; i < 1024; ++i)
+		{
+			for (NickCore *nc = nclists[i]; nc; nc = nc->next)
+			{
+				CurCore = nc;
+				FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteCoreMetadata, nc));
+			}
+		}
+
+		for (int i = 0; i < 1024; ++i)
+		{
+			for (NickAlias *na = nalists[i]; na; na = na->next)
+			{
+				CurNick = na;
+				FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteNickMetadata, na));
+			}
+		}
+
+		for (int i = 0; i < 256; ++i)
+		{
+			for (ChannelInfo *ci = chanlists[i]; ci; ci = ci->next)
+			{
+				CurChannel = ci;
+				FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteChannelMetadata, ci));
+			}
+		}
+
+		FOREACH_MOD(I_OnDatabaseWrite, OnDatabaseWrite(Write));
+
+		return EVENT_CONTINUE;
+	}
+
+	void OnPostCommand(User *u, const std::string &service, const ci::string &command, const std::vector<ci::string> &params)
+	{
+		mysqlpp::Query query(Me->Con);
+
+		if (service == Config.s_NickServ)
+		{
+			if (u->Account() && ((command == "SET" && !params.empty()) || (command == "SASET" && u->Account()->HasCommand("nickserv/saset") && params.size() > 1)))
+			{
+				ci::string cmd = (command == "SET" ? params[0] : params[1]);
+				NickCore *nc = (command == "SET" ? u->Account() : findcore(params[0].c_str()));
+				if (!nc)
+					return;
+				if (cmd == "PASSWORD" && params.size() > 1)
+				{
+					query << "UPDATE `anope_ns_core` SET `password` = " << mysqlpp::quote << nc->pass << " WHERE `display` = " << mysqlpp::quote << nc->display;
+					ExecuteQuery(query);
+				}
+				else if (cmd == "LANGUAGE" && params.size() > 1)
+				{
+					query << "UPDATE `anope_ns_core` SET `language` = " << nc->language << " WHERE `display` = " << mysqlpp::quote << nc->display;
+					ExecuteQuery(query);
+				}
+				else if (cmd == "URL")
+				{
+					query << "UPDATE `anope_ns_core` SET `url` = " << mysqlpp::quote << nc->url << " WHERE `display` = " << mysqlpp::quote << nc->display;
+					ExecuteQuery(query);
+				}
+				else if (cmd == "EMAIL")
+				{
+					query << "UPDATE `anope_ns_core` SET `email` = " << mysqlpp::quote << nc->email << " WHERE `display` = " << mysqlpp::quote << nc->display;
+					ExecuteQuery(query);
+				}
+				else if (cmd == "ICQ")
+				{
+					query << "UPDATE `anope_ns_core` SET `icq` = " << nc->icq << " WHERE `display` = " << mysqlpp::quote << nc->display;
+					ExecuteQuery(query);
+				}
+				else if (cmd == "GREET")
+				{
+					query << "UPDATE `anope_ns_core` SET `greet` = " << mysqlpp::quote << nc->greet << " WHERE `display` = " << mysqlpp::quote << nc->display;
+					ExecuteQuery(query);
+				}
+				else if (cmd == "KILL" || cmd == "SECURE" || cmd == "PRIVATE" || cmd == "MSG" || cmd == "HIDE" || cmd == "AUTOOP")
+				{
+					query << "UPDATE `anope_ns_core` SET `flags` = " << BuildFlagsList(nc) << " WHERE `display` = " << mysqlpp::quote << nc->display;
+					ExecuteQuery(query);
+				}
+			}
+		}
+		else if (service == Config.s_ChanServ)
+		{
+			if (command == "SET" && u->Account() && params.size() > 1)
+			{
+				ChannelInfo *ci = cs_findchan(params[0].c_str());
+				if (!ci)
+					return;
+				if (!u->Account()->HasPriv("chanserv/set") && check_access(u, ci, CA_SET))
+					return;
+				if (params[1] == "FOUNDER" && ci->founder)
+				{
+					query << "UPDATE `anope_cs_info` SET `founder` = " << mysqlpp::quote << ci->founder->display << " WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+				else if (params[1] == "SUCCESSOR")
+				{
+					query << "UPDATE `anope_cs_info` SET `successor` = " << mysqlpp::quote << (ci->successor ? ci->successor->display : "") << " WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+				else if (params[1] == "DESC")
+				{
+					query << "UPDATE `anope_cs_info` SET `descr` = " << mysqlpp::quote << ci->desc << " WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+				else if (params[1] == "URL")
+				{
+					query << "UPDATE `anope_cs_info` SET `url` = " << mysqlpp::quote << ci->url << " WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+				else if (params[1] == "EMAIL")
+				{
+					query << "UPDATE `anope_cs_info` SET `email` = " << mysqlpp::quote << ci->email << " WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+				else if (params[1] == "ENTRYMSG")
+				{
+					query << "UPDATE `anope_cs_info` SET `entry_message` = " << mysqlpp::quote << ci->entry_message << " WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+				else if (params[1] == "MLOCK")
+				{
+					query << "UPDATE `anope_cs_info` SET `mlock_on` = '" << GetMLockOn(ci) << "' WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+					query << "UPDATE `anope_cs_info` SET `mlock_off` = '" << GetMLockOff(ci) << "' WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+					query << "UPDATE `anope_cs_info` SET `mlock_params` = '" << GetMLockParams(ci) << "' WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+				else if (params[1] == "BANTYPE")
+				{
+					query << "UPDATE `anope_cs_info` SET `bantype` = " << ci->bantype << " WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+				else if (params[1] == "KEEPTOPIC" || params[1] == "TOPICLOCK" || params[1] == "PRIVATE" || params[1] == "SECUREOPS" || params[1] == "SECUREFOUNDER" || params[1] == "RESTRICTED" || params[1] == "SECURE" || params[1] == "SIGNKICK" || params[1] == "OPNOTICE" || params[1] == "XOP" || params[1] == "PEACE" || params[1] == "PERSIST" || params[1] == "NOEXPIRE")
+				{
+					query << "UPDATE `anope_cs_info` SET `flags` = '" << BuildFlagsList(ci) << "' WHERE `name` = " << mysqlpp::quote << ci->name;
+					ExecuteQuery(query);
+				}
+			}
+		}
+	}
+
+	void OnNickAddAccess(NickCore *nc, const std::string &entry)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "INSERT DELAYED INTO `anope_ns_access` (display, access) VALUES(" << mysqlpp::quote << nc->display << ", " << mysqlpp::quote << entry << ")";
+		ExecuteQuery(query);
+	}
+
+	void OnNickEraseAccess(NickCore *nc, const std::string &entry)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "DELETE FROM `anope_ns_access` WHERE `display` = " << mysqlpp::quote << nc->display << " AND `access` = " << mysqlpp::quote << entry;
+		ExecuteQuery(query);
+	}
+
+	void OnNickClearAccess(NickCore *nc)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "DELETE FROM `anope_ns_access` WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+	}
+
+	void OnDelCore(NickCore *nc)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "DELETE FROM `anope_cs_access` WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+		query << "DELETE FROM `anope_ns_access` WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+		query << "DELETE FROM `anope_ns_alias` WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+		query << "DELETE FROM `anope_ns_core` WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+	}
+
+	void OnNickForbidden(NickAlias *na)
+	{
+		std::string flags = BuildFlagsList(na);
+		mysqlpp::Query query(Me->Con);
+		query << "UPDATE `anope_ns_alias` SET `flags` = '" << (!flags.empty() ? flags : "") << "' WHERE `nick` = " << mysqlpp::quote << na->nick;
+		ExecuteQuery(query);
+	}
+
+	void OnNickGroup(User *u, NickAlias *)
+	{
+		OnNickRegister(findnick(u->nick));
+	}
+	
+	void OnMakeNickRequest(NickRequest *nr)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "INSERT DELAYED INTO `anope_ns_request` (nick, passcode, password, email, requested) VALUES(" << mysqlpp::quote << nr->nick << ", ";
+		query << mysqlpp::quote << nr->passcode << ", " << mysqlpp::quote << nr->password << ", " << mysqlpp::quote << nr->email << ", '";
+		query << nr->requested << "')";
+		ExecuteQuery(query);
+	}
+
+	void OnDelNickRequest(NickRequest *nr)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "DELETE FROM `anope_ns_request` WHERE `nick` = " << mysqlpp::quote << nr->nick;
+		ExecuteQuery(query);
+	}
+
+	void OnNickRegister(NickAlias *na)
+	{
+		std::string flags = BuildFlagsList(na);
+		mysqlpp::Query query(Me->Con);
+		query << "INSERT DELAYED INTO `anope_ns_alias` (nick, last_quit, last_realname, last_usermask, time_registered, last_seen, flags, display) VALUES(";
+		query << mysqlpp::quote << na->nick << ", " << mysqlpp::quote << (na->last_quit ? na->last_quit : "") << ", ";
+		query << mysqlpp::quote << (na->last_realname ? na->last_realname : "") << ", ";
+		query << mysqlpp::quote << (na->last_usermask ? na->last_usermask : "") << ", " << na->time_registered << ", " << na->last_seen;
+		query << ", '" << (!flags.empty() ? flags : "") << "', " << mysqlpp::quote << na->nc->display << ") ";
+		query << "ON DUPLICATE KEY UPDATE last_quit=VALUES(last_quit), last_realname=VALUES(last_realname), last_usermask=VALUES(last_usermask), time_registered=VALUES(time_registered), last_seen=VALUES(last_seen), flags=VALUES(flags), display=VALUES(display)";
+		ExecuteQuery(query);
+
+		flags = BuildFlagsList(na->nc);
+		query << "INSERT DELAYED INTO `anope_ns_core` (display, pass, email, greet, icq, url, flags, language, channelcount, memomax) VALUES(";
+		query << mysqlpp::quote << na->nc->display << ", " << mysqlpp::quote << na->nc->pass << ", ";
+		query << mysqlpp::quote << (na->nc->email ? na->nc->email : "") << ", " << mysqlpp::quote << (na->nc->greet ? na->nc->greet : "");
+		query << ", " << na->nc->icq << ", " << mysqlpp::quote << (na->nc->url ? na->nc->url : "");
+		query << ", '" << (!flags.empty() ? flags : "") << "', " << na->nc->language << ", " << na->nc->channelcount << ", ";
+		query << na->nc->memos.memomax << ") ";
+		query << "ON DUPLICATE KEY UPDATE pass=VALUES(pass), email=VALUES(email), greet=VALUES(greet), icq=VALUES(icq), flags=VALUES(flags), language=VALUES(language), ";
+		query << "channelcount=VALUES(channelcount), memomax=VALUES(memomax)";
+		ExecuteQuery(query);
+	}
+
+	void OnChangeCoreDisplay(NickCore *nc, const std::string &newdisplay)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "UPDATE `anope_ns_core` SET `display` = " << mysqlpp::quote << newdisplay << " WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+		query << "UPDATE `anope_ns_alias` SET `display` = " << mysqlpp::quote << newdisplay << " WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+		query << "UPDATE `anope_ns_access` SET `display` = " << mysqlpp::quote << newdisplay << " WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+		query << "UPDATE `anope_cs_access` SET `display` = " << mysqlpp::quote << newdisplay << " WHERE `display` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+		query << "UPDATE `anope_cs_info` SET `founder` = " << mysqlpp::quote << newdisplay << " WHERE `founder` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+		query << "UPDATE `anope_cs_info` SET `successor` = " << mysqlpp::quote << newdisplay << " WHERE `successor` = " << mysqlpp::quote << nc->display;
+		ExecuteQuery(query);
+	}
+
+	void OnNickSuspend(NickAlias *na)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "UPDATE `anope_ns_core` SET `flags` = '" << BuildFlagsList(na->nc) << "' WHERE `display` = " << mysqlpp::quote << na->nc->display;
+		ExecuteQuery(query);
+	}
+
+	void OnAccessAdd(ChannelInfo *ci, User *u, NickAlias *na, int level)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "INSERT DELAYED INTO `anope_cs_access` (level, display, channel, last_seen, creator) VALUES (" << level << ", " << mysqlpp::quote << na->nc->display << ", " << mysqlpp::quote << ci->name << ", " << time(NULL) << ", " << mysqlpp::quote << u->nick << ")"; 
+		ExecuteQuery(query);
+	}
+
+	void OnAccessDel(ChannelInfo *ci, User *u, NickCore *nc)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "DELETE FROM `anope_cs_access` WHERE `display` = " << mysqlpp::quote << nc->display << " AND `channel` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+	}
+
+	void OnAccessChange(ChannelInfo *ci, User *u, NickAlias *na, int level)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "INSERT DELAYED INTO `anope_cs_access` (level, display, channel, last_seen, creator) VALUES (" << level << ", " << mysqlpp::quote << na->nc->display << ", " << mysqlpp::quote << ci->name << ", " << time(NULL) << ", " << mysqlpp::quote << u->nick << ") ON DUPLICATE KEY UPDATE level=VALUES(level), display=VALUES(display), channel=VALUES(channel), last_seen=VALUES(last_seen), creator=VALUES(creator)";
+		ExecuteQuery(query);
+	}
+
+	void OnAccessClear(ChannelInfo *ci, User *u)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "DELETE FROM `anope_cs_access` WHERE `channel` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+	}
+
+	void OnChanForbidden(ChannelInfo *ci)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "INSERT DELAYED INTO `anope_cs_info` (name, time_registered, last_used, flags, forbidby, forbidreason) VALUES (";
+		query << mysqlpp::quote << ci->name << ", " << ci->time_registered << ", " << ci->last_used << ", '" << BuildFlagsList(ci) << "', " << mysqlpp::quote << ci->forbidby << ", " << mysqlpp::quote << ci->forbidreason << ")";
+		ExecuteQuery(query);
+	}
+
+	void OnDelChan(ChannelInfo *ci)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "DELETE FROM `anope_cs_access` WHERE `channel` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+		query << "DELETE FROM `anope_cs_info` WHERE `name` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+		query << "DELETE FROM `anope_cs_levels` WHERE `channel` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+	}
+	
+	void OnChanRegistered(ChannelInfo *ci)
+	{
+		mysqlpp::Query query(Me->Con);
+		std::string flags = BuildFlagsList(ci), mlockon = GetMLockOn(ci), mlockoff = GetMLockOff(ci), mlockparams = GetMLockParams(ci);
+		query << "INSERT DELAYED INTO `anope_cs_info` (name, founder, successor, descr, url, email, time_registered, last_used, last_topic,  last_topic_setter, last_topic_time, flags, forbidby, forbidreason, bantype, mlock_on, mlock_off, mlock_params, entry_message, memomax, botnick, botflags, capsmin, capspercent, floodlines, floodsecs, repeattimes) VALUES(";
+		query << mysqlpp::quote << ci->name << ", " << mysqlpp::quote << (ci->founder ? ci->founder->display : "") << ", ";
+		query << mysqlpp::quote << (ci->successor ? ci->successor->display : "") << ", " << mysqlpp::quote << ci->desc << ", ";
+		query << mysqlpp::quote << (ci->url ? ci->url : "") << ", " << mysqlpp::quote << (ci->email ? ci->email : "") << ", ";
+		query << ci->time_registered << ", " << ci->last_used << ", " << mysqlpp::quote << (ci->last_topic ? ci->last_topic : "");
+		query << ", " << mysqlpp::quote << (!ci->last_topic_setter.empty() ? ci->last_topic_setter : "");
+		query << ", " << ci->last_topic_time << ", '" << (!flags.empty() ? flags : "") << "', ";
+		query << mysqlpp::quote << (ci->forbidby ? ci->forbidby : "") << ", " << mysqlpp::quote << (ci->forbidreason ? ci->forbidreason : "") << ", " <<  ci->bantype << ", '";
+		query << mlockon << "', '" << mlockoff << "', '";
+		query << mlockparams << "', " << mysqlpp::quote << (ci->entry_message ? ci->entry_message : "") << ", ";
+		query << ci->memos.memomax << ", " << mysqlpp::quote << (ci->bi ? ci->bi->nick : "") << ", '" << GetBotFlags(ci->botflags);
+		query << "', " << ci->capsmin << ", " << ci->capspercent << ", " << ci->floodlines;
+		query << ", " << ci->floodsecs << ", " << ci->repeattimes << ") ";
+		query << "ON DUPLICATE KEY UPDATE founder=VALUES(founder), successor=VALUES(successor), descr=VALUES(descr), url=VALUES(url),  email=VALUES(email), time_registered=VALUES(time_registered), last_used=VALUES(last_used), last_topic=VALUES(last_topic), last_topic_setter=VALUES(last_topic_setter),  last_topic_time=VALUES(last_topic_time), flags=VALUES(flags), forbidby=VALUES(forbidby), forbidreason=VALUES(forbidreason), bantype=VALUES(bantype), mlock_on=VALUES(mlock_on), mlock_off=VALUES(mlock_off), mlock_params=VALUES(mlock_params), entry_message=VALUES(entry_message), memomax=VALUES(memomax), botnick=VALUES(botnick), botflags=VALUES(botflags), capsmin=VALUES(capsmin), capspercent=VALUES(capspercent), floodlines=VALUES(floodlines), floodsecs=VALUES(floodsecs), repeattimes=VALUES(repeattimes)";
+		ExecuteQuery(query);
+	}
+
+	void OnChanSuspend(ChannelInfo *ci)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "UPDATE `anope_cs_info` SET `flags` = '" << BuildFlagsList(ci) << "' WHERE `name` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+		query << "UPDATE `anope_cs_info` SET `forbidby` = " << mysqlpp::quote << ci->forbidby << " WHERE `name` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+		query << "UPDATE `anope_cs_info` SET `forbidreason` = " << mysqlpp::quote << ci->forbidreason << " WHERE `name` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+	}
+
+	void OnBotCreate(BotInfo *bi)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "INSERT DELAYED INTO `anope_bs_core` (nick, user, host, rname, flags, created, chancount) VALUES(";
+		query << mysqlpp::quote << bi->nick << ", " << mysqlpp::quote << bi->user << ", " << mysqlpp::quote << bi->host << ", ";
+		query << mysqlpp::quote << bi->real << ", '" << GetBotServFlags(bi) << "', " << bi->created << ", " << bi->chancount << ") ";
+		query << "ON DUPLICATE KEY UPDATE nick=VALUES(nick), user=VALUES(user), host=VALUES(host), rname=VALUES(rname), flags=VALUES(flags), created=VALUES(created), chancount=VALUES(chancount)";
+		ExecuteQuery(query);
+	}
+
+	void OnBotChange(BotInfo *bi)
+	{
+		OnBotCreate(bi);
+	}
+
+	void OnBotDelete(BotInfo *bi)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "DELETE FROM `anope_bs_core` WHERE `nick` = " << mysqlpp::quote << bi->nick;
+		ExecuteQuery(query);
+		query << "UPDATE `anope_cs_info` SET `botnick` = '' WHERE `botnick` = " << mysqlpp::quote << bi->nick;
+		ExecuteQuery(query);
+	}
+
+	EventReturn OnBotAssign(User *sender, ChannelInfo *ci, BotInfo *bi)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "UPDATE `anope_cs_info` SET `botnick` = " << mysqlpp::quote << bi->nick << " WHERE `name` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+		return EVENT_CONTINUE;
+	}
+
+	EventReturn OnBotUnAssign(User *sender, ChannelInfo *ci)
+	{
+		mysqlpp::Query query(Me->Con);
+		query << "UPDATE `anope_cs_info` SET `botnick` = '' WHERE `name` = " << mysqlpp::quote << ci->name;
+		ExecuteQuery(query);
+		return EVENT_CONTINUE;
+	}
+};
+
+MODULE_INIT(DBMySQLWrite)
+