/* 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)