summaryrefslogtreecommitdiff
path: root/modules/database/db_plain.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'modules/database/db_plain.cpp')
-rw-r--r--modules/database/db_plain.cpp706
1 files changed, 333 insertions, 373 deletions
diff --git a/modules/database/db_plain.cpp b/modules/database/db_plain.cpp
index bf0b05e3d..711434336 100644
--- a/modules/database/db_plain.cpp
+++ b/modules/database/db_plain.cpp
@@ -15,7 +15,14 @@
Anope::string DatabaseFile;
std::stringstream db_buffer;
-service_reference<SessionService, Base> SessionInterface("session");
+
+class DatabaseException : public CoreException
+{
+ public:
+ DatabaseException(const Anope::string &reason = "") : CoreException(reason) { }
+
+ virtual ~DatabaseException() throw() { }
+};
/** Enum used for what METADATA type we are reading
*/
@@ -28,6 +35,300 @@ enum MDType
MD_CH
};
+static void LoadNickCore(const std::vector<Anope::string> &params);
+static void LoadNickAlias(const std::vector<Anope::string> &params);
+static void LoadBotInfo(const std::vector<Anope::string> &params);
+static void LoadChanInfo(const std::vector<Anope::string> &params);
+static void LoadOperInfo(const std::vector<Anope::string> &params);
+
+EventReturn OnDatabaseRead(const std::vector<Anope::string> &params)
+{
+ Anope::string key = params[0];
+ std::vector<Anope::string> otherparams = params;
+ otherparams.erase(otherparams.begin());
+
+ if (key.equals_ci("NC"))
+ LoadNickCore(otherparams);
+ else if (key.equals_ci("NA"))
+ LoadNickAlias(otherparams);
+ else if (key.equals_ci("BI"))
+ LoadBotInfo(otherparams);
+ else if (key.equals_ci("CH"))
+ LoadChanInfo(otherparams);
+ else if (key.equals_ci("OS"))
+ LoadOperInfo(otherparams);
+
+ return EVENT_CONTINUE;
+ }
+
+EventReturn OnDatabaseReadMetadata(NickCore *nc, const Anope::string &key, const std::vector<Anope::string> &params)
+{
+ try
+ {
+ if (key.equals_ci("LANGUAGE"))
+ nc->language = params[0];
+ else if (key.equals_ci("MEMOMAX"))
+ nc->memos.memomax = params[0].is_pos_number_only() ? convertTo<int16>(params[0]) : -1;
+ else if (key.equals_ci("EMAIL"))
+ nc->email = params[0];
+ else if (key.equals_ci("GREET"))
+ nc->greet = params[0];
+ else if (key.equals_ci("ACCESS"))
+ nc->AddAccess(params[0]);
+ else if (key.equals_ci("CERT"))
+ nc->AddCert(params[0]);
+ else if (key.equals_ci("FLAGS"))
+ nc->FromVector(params);
+ else if (key.equals_ci("MI"))
+ {
+ Memo *m = new Memo;
+ m->time = params[0].is_pos_number_only() ? convertTo<time_t>(params[0]) : 0;
+ m->sender = params[1];
+ for (unsigned j = 2; params[j].equals_ci("UNREAD") || params[j].equals_ci("RECEIPT"); ++j)
+ {
+ if (params[j].equals_ci("UNREAD"))
+ m->SetFlag(MF_UNREAD);
+ else if (params[j].equals_ci("RECEIPT"))
+ m->SetFlag(MF_RECEIPT);
+ }
+ m->text = params[params.size() - 1];
+ nc->memos.memos.push_back(m);
+ }
+ else if (key.equals_ci("MIG"))
+ nc->memos.ignores.push_back(params[0].ci_str());
+ }
+ catch (const ConvertException &ex)
+ {
+ throw DatabaseException(ex.GetReason());
+ }
+ return EVENT_CONTINUE;
+}
+
+EventReturn OnDatabaseReadMetadata(NickAlias *na, const Anope::string &key, const std::vector<Anope::string> &params)
+{
+ if (key.equals_ci("LAST_USERMASK"))
+ na->last_usermask = params[0];
+ else if (key.equals_ci("LAST_REALHOST"))
+ na->last_realhost = params[0];
+ else if (key.equals_ci("LAST_REALNAME"))
+ na->last_realname = params[0];
+ else if (key.equals_ci("LAST_QUIT"))
+ na->last_quit = params[0];
+ else if (key.equals_ci("FLAGS"))
+ na->FromVector(params);
+ else if (key.equals_ci("VHOST"))
+ na->hostinfo.SetVhost(params.size() > 3 ? params[3] : "", params[2], params[0], params[1].is_pos_number_only() ? convertTo<time_t>(params[1]) : 0);
+ return EVENT_CONTINUE;
+}
+
+EventReturn OnDatabaseReadMetadata(BotInfo *bi, const Anope::string &key, const std::vector<Anope::string> &params)
+{
+ if (key.equals_ci("FLAGS"))
+ bi->FromVector(params);
+
+ return EVENT_CONTINUE;
+}
+
+EventReturn OnDatabaseReadMetadata(ChannelInfo *ci, const Anope::string &key, const std::vector<Anope::string> &params)
+{
+ try
+ {
+ if (key.equals_ci("BANTYPE"))
+ ci->bantype = params[0].is_pos_number_only() ? convertTo<int16>(params[0]) : Config->CSDefBantype;
+ else if (key.equals_ci("MEMOMAX"))
+ ci->memos.memomax = params[0].is_pos_number_only() ? convertTo<int16>(params[0]) : -1;
+ else if (key.equals_ci("FOUNDER"))
+ ci->SetFounder(findcore(params[0]));
+ else if (key.equals_ci("SUCCESSOR"))
+ ci->successor = findcore(params[0]);
+ else if (key.equals_ci("LEVELS"))
+ {
+ for (unsigned j = 0, end = params.size(); j < end; j += 2)
+ {
+ Privilege *p = PrivilegeManager::FindPrivilege(params[j]);
+ if (p == NULL)
+ continue;
+ ci->SetLevel(p->name, params[j + 1].is_number_only() ? convertTo<int16>(params[j + 1]) : 0);
+ }
+ }
+ else if (key.equals_ci("FLAGS"))
+ ci->FromVector(params);
+ else if (key.equals_ci("DESC"))
+ ci->desc = params[0];
+ else if (key.equals_ci("TOPIC"))
+ {
+ ci->last_topic_setter = params[0];
+ ci->last_topic_time = params[1].is_pos_number_only() ? convertTo<time_t>(params[1]) : 0;
+ ci->last_topic = params[2];
+ }
+ else if (key.equals_ci("SUSPEND"))
+ {
+ ci->Extend("suspend_by", new ExtensibleString(params[0]));
+ ci->Extend("suspend_reason", new ExtensibleString(params[1]));
+ }
+ else if (key.equals_ci("ACCESS")) // Older access system, from Anope 1.9.4.
+ {
+ service_reference<AccessProvider> provider("access/access");
+ if (!provider)
+ throw DatabaseException("Old access entry for nonexistant provider");
+
+ ChanAccess *access = provider->Create();
+ access->ci = ci;
+ access->mask = params[0];
+ access->Unserialize(params[1]);
+ access->last_seen = params[2].is_pos_number_only() ? convertTo<time_t>(params[2]) : 0;
+ access->creator = params[3];
+ access->created = Anope::CurTime;
+
+ ci->AddAccess(access);
+ }
+ else if (key.equals_ci("ACCESS2"))
+ {
+ service_reference<AccessProvider> provider(params[0]);
+ if (!provider)
+ throw DatabaseException("Access entry for nonexistant provider " + params[0]);
+
+ ChanAccess *access = provider->Create();
+ access->ci = ci;
+ access->mask = params[1];
+ access->Unserialize(params[2]);
+ access->last_seen = params[3].is_pos_number_only() ? convertTo<time_t>(params[3]) : 0;
+ access->creator = params[4];
+ access->created = params.size() > 5 && params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : Anope::CurTime;
+
+ ci->AddAccess(access);
+ }
+ else if (key.equals_ci("AKICK"))
+ {
+ // 0 is the old stuck
+ bool Nick = params[1].equals_ci("NICK");
+ NickCore *nc = NULL;
+ if (Nick)
+ {
+ nc = findcore(params[2]);
+ if (!nc)
+ throw DatabaseException("Akick for nonexistant core " + params[2] + " on " + ci->name);
+ }
+
+ AutoKick *ak;
+ if (Nick)
+ ak = ci->AddAkick(params[3], nc, params.size() > 6 ? params[6] : "", params[4].is_pos_number_only() ? convertTo<time_t>(params[4]) : 0, params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : 0);
+ else
+ ak = ci->AddAkick(params[3], params[2], params.size() > 6 ? params[6] : "", params[4].is_pos_number_only() ? convertTo<time_t>(params[4]) : 0, params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : 0);
+ if (Nick)
+ ak->SetFlag(AK_ISNICK);
+
+ }
+ else if (key.equals_ci("LOG"))
+ {
+ LogSetting l;
+
+ l.service_name = params[0];
+ l.command_service = params[1];
+ l.command_name = params[2];
+ l.method = params[3];
+ l.creator = params[4];
+ l.created = params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : Anope::CurTime;
+ l.extra = params.size() > 6 ? params[6] : "";
+
+ ci->log_settings.push_back(l);
+ }
+ else if (key.equals_ci("MLOCK"))
+ {
+ bool set = params[0] == "1" ? true : false;
+ Anope::string mode_name = params[1];
+ Anope::string setter = params[2];
+ time_t mcreated = params[3].is_pos_number_only() ? convertTo<time_t>(params[3]) : Anope::CurTime;
+ Anope::string param = params.size() > 4 ? params[4] : "";
+ for (size_t i = CMODE_BEGIN + 1; i < CMODE_END; ++i)
+ if (ChannelModeNameStrings[i] == mode_name)
+ {
+ ChannelModeName n = static_cast<ChannelModeName>(i);
+ ci->mode_locks.insert(std::make_pair(n, ModeLock(ci, set, n, param, setter, mcreated)));
+ break;
+ }
+ }
+ else if (key.equals_ci("MI"))
+ {
+ Memo *m = new Memo;
+ m->time = params[0].is_pos_number_only() ? convertTo<time_t>(params[0]) : 0;
+ m->sender = params[1];
+ for (unsigned j = 2; params[j].equals_ci("UNREAD") || params[j].equals_ci("RECEIPT"); ++j)
+ {
+ if (params[j].equals_ci("UNREAD"))
+ m->SetFlag(MF_UNREAD);
+ else if (params[j].equals_ci("RECEIPT"))
+ m->SetFlag(MF_RECEIPT);
+ }
+ m->text = params[params.size() - 1];
+ ci->memos.memos.push_back(m);
+ }
+ else if (key.equals_ci("MIG"))
+ ci->memos.ignores.push_back(params[0].ci_str());
+ else if (key.equals_ci("BI"))
+ {
+ if (params[0].equals_ci("NAME"))
+ ci->bi = findbot(params[1]);
+ else if (params[0].equals_ci("FLAGS"))
+ ci->botflags.FromVector(params);
+ else if (params[0].equals_ci("TTB"))
+ {
+ for (unsigned j = 1, end = params.size(); j < end; j += 2)
+ {
+ if (params[j].equals_ci("BOLDS"))
+ ci->ttb[0] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("COLORS"))
+ ci->ttb[1] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("REVERSES"))
+ ci->ttb[2] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("UNDERLINES"))
+ ci->ttb[3] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("BADWORDS"))
+ ci->ttb[4] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("CAPS"))
+ ci->ttb[5] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("FLOOD"))
+ ci->ttb[6] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("REPEAT"))
+ ci->ttb[7] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("ITALICS"))
+ ci->ttb[8] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ else if (params[j].equals_ci("AMSGS"))
+ ci->ttb[9] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
+ }
+ }
+ else if (params[0].equals_ci("CAPSMIN"))
+ ci->capsmin = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
+ else if (params[0].equals_ci("CAPSPERCENT"))
+ ci->capspercent = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
+ else if (params[0].equals_ci("FLOODLINES"))
+ ci->floodlines = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
+ else if (params[0].equals_ci("FLOODSECS"))
+ ci->floodsecs = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
+ else if (params[0].equals_ci("REPEATTIMES"))
+ ci->repeattimes = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
+ else if (params[0].equals_ci("BADWORD"))
+ {
+ BadWordType Type;
+ if (params[1].equals_ci("SINGLE"))
+ Type = BW_SINGLE;
+ else if (params[1].equals_ci("START"))
+ Type = BW_START;
+ else if (params[1].equals_ci("END"))
+ Type = BW_END;
+ else
+ Type = BW_ANY;
+ ci->AddBadWord(params[2], Type);
+ }
+ }
+ }
+ catch (const ConvertException &ex)
+ {
+ throw DatabaseException(ex.GetReason());
+ }
+ return EVENT_CONTINUE;
+}
+
/* Character for newlines, in my research I have concluded it is significantly faster
* to use \n instead of std::endl because std::endl also flushes the buffer, which
* is not necessary here
@@ -39,7 +340,7 @@ static const char endl = '\n';
*/
static void ReadDatabase(Module *m = NULL)
{
- EventReturn MOD_RESULT;
+ //EventReturn MOD_RESULT;
MDType Type = MD_NONE;
std::fstream db;
@@ -81,12 +382,13 @@ static void ReadDatabase(Module *m = NULL)
params.push_back(buf);
}
- if (m)
+ /*if (m)
MOD_RESULT = m->OnDatabaseRead(params);
else
FOREACH_RESULT(I_OnDatabaseRead, OnDatabaseRead(params));
if (MOD_RESULT == EVENT_STOP)
- continue;
+ continue;*/
+ OnDatabaseRead(params);
if (!params.empty())
{
@@ -120,10 +422,7 @@ static void ReadDatabase(Module *m = NULL)
{
try
{
- if (m)
- m->OnDatabaseReadMetadata(nc, key, params);
- else
- FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(nc, key, params));
+ OnDatabaseReadMetadata(nc, key, params);
}
catch (const DatabaseException &ex)
{
@@ -134,10 +433,7 @@ static void ReadDatabase(Module *m = NULL)
{
try
{
- if (m)
- m->OnDatabaseReadMetadata(na, key, params);
- else
- FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(na, key, params));
+ OnDatabaseReadMetadata(na, key, params);
}
catch (const DatabaseException &ex)
{
@@ -148,10 +444,7 @@ static void ReadDatabase(Module *m = NULL)
{
try
{
- if (m)
- m->OnDatabaseReadMetadata(bi, key, params);
- else
- FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(bi, key, params));
+ OnDatabaseReadMetadata(bi, key, params);
}
catch (const DatabaseException &ex)
{
@@ -162,10 +455,7 @@ static void ReadDatabase(Module *m = NULL)
{
try
{
- if (m)
- m->OnDatabaseReadMetadata(ci, key, params);
- else
- FOREACH_RESULT(I_OnDatabaseReadMetadata, OnDatabaseReadMetadata(ci, key, params));
+ OnDatabaseReadMetadata(ci, key, params);
}
catch (const DatabaseException &ex)
{
@@ -179,19 +469,6 @@ static void ReadDatabase(Module *m = NULL)
db.close();
}
-static Anope::string ToString(const std::vector<Anope::string> &strings)
-{
- Anope::string ret;
-
- for (unsigned i = 0; i < strings.size(); ++i)
- ret += " " + strings[i];
-
- if (!ret.empty())
- ret.erase(ret.begin());
-
- return ret;
-}
-
static void LoadNickCore(const std::vector<Anope::string> &params)
{
NickCore *nc = new NickCore(params[0]);
@@ -278,7 +555,7 @@ static void LoadOperInfo(const std::vector<Anope::string> &params)
}
}
}
- else if (params[0].equals_ci("EXCEPTION") && SessionInterface)
+ else if (params[0].equals_ci("EXCEPTION") && session_service)
{
Exception *exception = new Exception();
exception->mask = params[1];
@@ -287,7 +564,7 @@ static void LoadOperInfo(const std::vector<Anope::string> &params)
exception->time = params[4].is_pos_number_only() ? convertTo<time_t>(params[4]) : 0;
exception->expires = params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : 0;
exception->reason = params[6];
- SessionInterface->AddException(exception);
+ session_service->AddException(exception);
}
}
@@ -312,7 +589,7 @@ class DBPlain : public Module
{
this->SetAuthor("Anope");
- Implementation i[] = { I_OnReload, I_OnDatabaseRead, I_OnLoadDatabase, I_OnDatabaseReadMetadata, I_OnSaveDatabase, I_OnModuleLoad };
+ Implementation i[] = { I_OnReload, I_OnLoadDatabase, I_OnSaveDatabase };
ModuleManager::Attach(i, this, sizeof(i) / sizeof(Implementation));
OnReload();
@@ -370,308 +647,17 @@ class DBPlain : public Module
DatabaseFile = config.ReadValue("db_plain", "database", "anope.db", 0);
}
- EventReturn OnDatabaseRead(const std::vector<Anope::string> &params)
- {
- Anope::string key = params[0];
- std::vector<Anope::string> otherparams = params;
- otherparams.erase(otherparams.begin());
-
- if (key.equals_ci("NC"))
- LoadNickCore(otherparams);
- else if (key.equals_ci("NA"))
- LoadNickAlias(otherparams);
- else if (key.equals_ci("BI"))
- LoadBotInfo(otherparams);
- else if (key.equals_ci("CH"))
- LoadChanInfo(otherparams);
- else if (key.equals_ci("OS"))
- LoadOperInfo(otherparams);
-
- return EVENT_CONTINUE;
- }
-
EventReturn OnLoadDatabase()
{
ReadDatabase();
/* No need to ever reload this again, although this should never be trigged again */
ModuleManager::Detach(I_OnLoadDatabase, this);
- ModuleManager::Detach(I_OnDatabaseReadMetadata, this);
+ //ModuleManager::Detach(I_OnDatabaseReadMetadata, this);
return EVENT_STOP;
}
- EventReturn OnDatabaseReadMetadata(NickCore *nc, const Anope::string &key, const std::vector<Anope::string> &params)
- {
- try
- {
- if (key.equals_ci("LANGUAGE"))
- nc->language = params[0];
- else if (key.equals_ci("MEMOMAX"))
- nc->memos.memomax = params[0].is_pos_number_only() ? convertTo<int16>(params[0]) : -1;
- else if (key.equals_ci("EMAIL"))
- nc->email = params[0];
- else if (key.equals_ci("GREET"))
- nc->greet = params[0];
- else if (key.equals_ci("ACCESS"))
- nc->AddAccess(params[0]);
- else if (key.equals_ci("CERT"))
- nc->AddCert(params[0]);
- else if (key.equals_ci("FLAGS"))
- nc->FromString(params);
- else if (key.equals_ci("MI"))
- {
- Memo *m = new Memo;
- m->time = params[0].is_pos_number_only() ? convertTo<time_t>(params[0]) : 0;
- m->sender = params[1];
- for (unsigned j = 2; params[j].equals_ci("UNREAD") || params[j].equals_ci("RECEIPT"); ++j)
- {
- if (params[j].equals_ci("UNREAD"))
- m->SetFlag(MF_UNREAD);
- else if (params[j].equals_ci("RECEIPT"))
- m->SetFlag(MF_RECEIPT);
- }
- m->text = params[params.size() - 1];
- nc->memos.memos.push_back(m);
- }
- else if (key.equals_ci("MIG"))
- nc->memos.ignores.push_back(params[0].ci_str());
- }
- catch (const ConvertException &ex)
- {
- throw DatabaseException(ex.GetReason());
- }
-
- return EVENT_CONTINUE;
- }
-
- EventReturn OnDatabaseReadMetadata(NickAlias *na, const Anope::string &key, const std::vector<Anope::string> &params)
- {
- if (key.equals_ci("LAST_USERMASK"))
- na->last_usermask = params[0];
- else if (key.equals_ci("LAST_REALHOST"))
- na->last_realhost = params[0];
- else if (key.equals_ci("LAST_REALNAME"))
- na->last_realname = params[0];
- else if (key.equals_ci("LAST_QUIT"))
- na->last_quit = params[0];
- else if (key.equals_ci("FLAGS"))
- na->FromString(params);
- else if (key.equals_ci("VHOST"))
- na->hostinfo.SetVhost(params.size() > 3 ? params[3] : "", params[2], params[0], params[1].is_pos_number_only() ? convertTo<time_t>(params[1]) : 0);
-
- return EVENT_CONTINUE;
- }
-
- EventReturn OnDatabaseReadMetadata(BotInfo *bi, const Anope::string &key, const std::vector<Anope::string> &params)
- {
- if (key.equals_ci("FLAGS"))
- bi->FromString(params);
-
- return EVENT_CONTINUE;
- }
-
- EventReturn OnDatabaseReadMetadata(ChannelInfo *ci, const Anope::string &key, const std::vector<Anope::string> &params)
- {
- try
- {
- if (key.equals_ci("BANTYPE"))
- ci->bantype = params[0].is_pos_number_only() ? convertTo<int16>(params[0]) : Config->CSDefBantype;
- else if (key.equals_ci("MEMOMAX"))
- ci->memos.memomax = params[0].is_pos_number_only() ? convertTo<int16>(params[0]) : -1;
- else if (key.equals_ci("FOUNDER"))
- ci->SetFounder(findcore(params[0]));
- else if (key.equals_ci("SUCCESSOR"))
- ci->successor = findcore(params[0]);
- else if (key.equals_ci("LEVELS"))
- {
- for (unsigned j = 0, end = params.size(); j < end; j += 2)
- {
- Privilege *p = PrivilegeManager::FindPrivilege(params[j]);
- if (p == NULL)
- continue;
- ci->SetLevel(p->name, params[j + 1].is_number_only() ? convertTo<int16>(params[j + 1]) : 0);
- }
- }
- else if (key.equals_ci("FLAGS"))
- ci->FromString(params);
- else if (key.equals_ci("DESC"))
- ci->desc = params[0];
- else if (key.equals_ci("TOPIC"))
- {
- ci->last_topic_setter = params[0];
- ci->last_topic_time = params[1].is_pos_number_only() ? convertTo<time_t>(params[1]) : 0;
- ci->last_topic = params[2];
- }
- else if (key.equals_ci("SUSPEND"))
- {
- ci->Extend("suspend_by", new ExtensibleItemRegular<Anope::string>(params[0]));
- ci->Extend("suspend_reason", new ExtensibleItemRegular<Anope::string>(params[1]));
- }
- else if (key.equals_ci("ACCESS")) // Older access system, from Anope 1.9.4.
- {
- service_reference<AccessProvider> provider("access/access");
- if (!provider)
- throw DatabaseException("Old access entry for nonexistant provider");
-
- ChanAccess *access = provider->Create();
- access->ci = ci;
- access->mask = params[0];
- access->Unserialize(params[1]);
- access->last_seen = params[2].is_pos_number_only() ? convertTo<time_t>(params[2]) : 0;
- access->creator = params[3];
- access->created = Anope::CurTime;
-
- ci->AddAccess(access);
- }
- else if (key.equals_ci("ACCESS2"))
- {
- service_reference<AccessProvider> provider(params[0]);
- if (!provider)
- throw DatabaseException("Access entry for nonexistant provider " + params[0]);
-
- ChanAccess *access = provider->Create();
- access->ci = ci;
- access->mask = params[1];
- access->Unserialize(params[2]);
- access->last_seen = params[3].is_pos_number_only() ? convertTo<time_t>(params[3]) : 0;
- access->creator = params[4];
- access->created = params.size() > 5 && params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : Anope::CurTime;
-
- ci->AddAccess(access);
- }
- else if (key.equals_ci("AKICK"))
- {
- // 0 is the old stuck
- bool Nick = params[1].equals_ci("NICK");
- NickCore *nc = NULL;
- if (Nick)
- {
- nc = findcore(params[2]);
- if (!nc)
- throw DatabaseException("Akick for nonexistant core " + params[2] + " on " + ci->name);
- }
-
- AutoKick *ak;
- if (Nick)
- ak = ci->AddAkick(params[3], nc, params.size() > 6 ? params[6] : "", params[4].is_pos_number_only() ? convertTo<time_t>(params[4]) : 0, params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : 0);
- else
- ak = ci->AddAkick(params[3], params[2], params.size() > 6 ? params[6] : "", params[4].is_pos_number_only() ? convertTo<time_t>(params[4]) : 0, params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : 0);
- if (Nick)
- ak->SetFlag(AK_ISNICK);
-
- }
- else if (key.equals_ci("LOG"))
- {
- LogSetting l;
-
- l.service_name = params[0];
- l.command_service = params[1];
- l.command_name = params[2];
- l.method = params[3];
- l.creator = params[4];
- l.created = params[5].is_pos_number_only() ? convertTo<time_t>(params[5]) : Anope::CurTime;
- l.extra = params.size() > 6 ? params[6] : "";
-
- ci->log_settings.push_back(l);
- }
- else if (key.equals_ci("MLOCK"))
- {
- bool set = params[0] == "1" ? true : false;
- Anope::string mode_name = params[1];
- Anope::string setter = params[2];
- time_t mcreated = params[3].is_pos_number_only() ? convertTo<time_t>(params[3]) : Anope::CurTime;
- Anope::string param = params.size() > 4 ? params[4] : "";
-
- for (size_t i = CMODE_BEGIN + 1; i < CMODE_END; ++i)
- if (ChannelModeNameStrings[i] == mode_name)
- {
- ChannelModeName n = static_cast<ChannelModeName>(i);
- ci->mode_locks.insert(std::make_pair(n, ModeLock(set, n, param, setter, mcreated)));
- break;
- }
- }
- else if (key.equals_ci("MI"))
- {
- Memo *m = new Memo;
- m->time = params[0].is_pos_number_only() ? convertTo<time_t>(params[0]) : 0;
- m->sender = params[1];
- for (unsigned j = 2; params[j].equals_ci("UNREAD") || params[j].equals_ci("RECEIPT"); ++j)
- {
- if (params[j].equals_ci("UNREAD"))
- m->SetFlag(MF_UNREAD);
- else if (params[j].equals_ci("RECEIPT"))
- m->SetFlag(MF_RECEIPT);
- }
- m->text = params[params.size() - 1];
- ci->memos.memos.push_back(m);
- }
- else if (key.equals_ci("MIG"))
- ci->memos.ignores.push_back(params[0].ci_str());
- else if (key.equals_ci("BI"))
- {
- if (params[0].equals_ci("NAME"))
- ci->bi = findbot(params[1]);
- else if (params[0].equals_ci("FLAGS"))
- ci->botflags.FromString(params);
- else if (params[0].equals_ci("TTB"))
- {
- for (unsigned j = 1, end = params.size(); j < end; j += 2)
- {
- if (params[j].equals_ci("BOLDS"))
- ci->ttb[0] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("COLORS"))
- ci->ttb[1] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("REVERSES"))
- ci->ttb[2] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("UNDERLINES"))
- ci->ttb[3] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("BADWORDS"))
- ci->ttb[4] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("CAPS"))
- ci->ttb[5] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("FLOOD"))
- ci->ttb[6] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("REPEAT"))
- ci->ttb[7] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("ITALICS"))
- ci->ttb[8] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- else if (params[j].equals_ci("AMSGS"))
- ci->ttb[9] = params[j + 1].is_pos_number_only() ? convertTo<int16>(params[j + 1]) : 0;
- }
- }
- else if (params[0].equals_ci("CAPSMIN"))
- ci->capsmin = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
- else if (params[0].equals_ci("CAPSPERCENT"))
- ci->capspercent = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
- else if (params[0].equals_ci("FLOODLINES"))
- ci->floodlines = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
- else if (params[0].equals_ci("FLOODSECS"))
- ci->floodsecs = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
- else if (params[0].equals_ci("REPEATTIMES"))
- ci->repeattimes = params[1].is_pos_number_only() ? convertTo<int16>(params[1]) : 0;
- else if (params[0].equals_ci("BADWORD"))
- {
- BadWordType Type;
- if (params[1].equals_ci("SINGLE"))
- Type = BW_SINGLE;
- else if (params[1].equals_ci("START"))
- Type = BW_START;
- else if (params[1].equals_ci("END"))
- Type = BW_END;
- else
- Type = BW_ANY;
- ci->AddBadWord(params[2], Type);
- }
- }
- }
- catch (const ConvertException &ex)
- {
- throw DatabaseException(ex.GetReason());
- }
-
- return EVENT_CONTINUE;
- }
EventReturn OnSaveDatabase()
{
@@ -705,7 +691,7 @@ class DBPlain : public Module
db_buffer << "MD CERT " << *it << endl;
}
if (nc->FlagCount())
- db_buffer << "MD FLAGS " << ToString(nc->ToString()) << endl;
+ db_buffer << "MD FLAGS " << nc->ToString() << endl;
MemoInfo *mi = &nc->memos;
for (unsigned k = 0, end = mi->memos.size(); k < end; ++k)
{
@@ -718,7 +704,7 @@ class DBPlain : public Module
}
for (unsigned k = 0, end = mi->ignores.size(); k < end; ++k)
db_buffer << "MD MIG " << Anope::string(mi->ignores[k]) << endl;
- FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteMetadata, nc));
+ //FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteMetadata, nc));
}
for (nickalias_map::const_iterator it = NickAliasList.begin(), it_end = NickAliasList.end(); it != it_end; ++it)
@@ -735,11 +721,11 @@ class DBPlain : public Module
if (!na->last_quit.empty())
db_buffer << "MD LAST_QUIT :" << na->last_quit << endl;
if (na->FlagCount())
- db_buffer << "MD FLAGS " << ToString(na->ToString()) << endl;
+ db_buffer << "MD FLAGS " << na->ToString() << endl;
if (na->hostinfo.HasVhost())
db_buffer << "MD VHOST " << na->hostinfo.GetCreator() << " " << na->hostinfo.GetTime() << " " << na->hostinfo.GetHost() << " :" << na->hostinfo.GetIdent() << endl;
- FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteMetadata, na));
+ //FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteMetadata, na));
}
for (Anope::insensitive_map<BotInfo *>::const_iterator it = BotListByNick.begin(), it_end = BotListByNick.end(); it != it_end; ++it)
@@ -751,7 +737,7 @@ class DBPlain : public Module
db_buffer << "BI " << bi->nick << " " << bi->GetIdent() << " " << bi->host << " " << bi->created << " " << bi->chancount << " :" << bi->realname << endl;
if (bi->FlagCount())
- db_buffer << "MD FLAGS " << ToString(bi->ToString()) << endl;
+ db_buffer << "MD FLAGS " << bi->ToString() << endl;
}
for (registered_channel_map::const_iterator cit = RegisteredChannelList.begin(), cit_end = RegisteredChannelList.end(); cit != cit_end; ++cit)
@@ -778,13 +764,12 @@ class DBPlain : public Module
}
db_buffer << endl;
if (ci->FlagCount())
- db_buffer << "MD FLAGS " << ToString(ci->ToString()) << endl;
+ db_buffer << "MD FLAGS " << ci->ToString() << endl;
if (ci->HasFlag(CI_SUSPENDED))
{
- Anope::string by, reason;
- ci->GetExtRegular("suspend_by", by);
- ci->GetExtRegular("suspend_reason", reason);
- db_buffer << "MD SUSPEND " << by << " :" << reason << endl;
+ Anope::string *by = ci->GetExt<Anope::string *>("suspend_by"), *reason = ci->GetExt<Anope::string *>("suspend_reason");
+ if (by && reason)
+ db_buffer << "MD SUSPEND " << *by << " :" << *reason << endl;
}
for (unsigned k = 0, end = ci->GetAccessCount(); k < end; ++k)
{
@@ -805,21 +790,12 @@ class DBPlain : public Module
db_buffer << "MD LOG " << l.service_name << " " << l.command_service << " " << l.command_name << " " << l.method << " " << l.creator << " " << l.created << " " << l.extra << endl;
}
+ for (std::multimap<ChannelModeName, ModeLock>::const_iterator it = ci->GetMLock().begin(), it_end = ci->GetMLock().end(); it != it_end; ++it)
{
- std::vector<Anope::string> mlocks;
- if (ci->GetExtRegular("db_mlock", mlocks))
- for (unsigned i = 0; i < mlocks.size(); ++i)
- db_buffer << mlocks[i] << endl;
- else
- {
- for (std::multimap<ChannelModeName, ModeLock>::const_iterator it = ci->GetMLock().begin(), it_end = ci->GetMLock().end(); it != it_end; ++it)
- {
- const ModeLock &ml = it->second;
- ChannelMode *cm = ModeManager::FindChannelModeByName(ml.name);
- if (cm != NULL)
- db_buffer << "MD MLOCK " << (ml.set ? 1 : 0) << " " << cm->NameAsString() << " " << ml.setter << " " << ml.created << " " << ml.param << endl;
- }
- }
+ const ModeLock &ml = it->second;
+ ChannelMode *cm = ModeManager::FindChannelModeByName(ml.name);
+ if (cm != NULL)
+ db_buffer << "MD MLOCK " << (ml.set ? 1 : 0) << " " << cm->NameAsString() << " " << ml.setter << " " << ml.created << " " << ml.param << endl;
}
MemoInfo *memos = &ci->memos;
for (unsigned k = 0, end = memos->memos.size(); k < end; ++k)
@@ -836,7 +812,7 @@ class DBPlain : public Module
if (ci->bi)
db_buffer << "MD BI NAME " << ci->bi->nick << endl;
if (ci->botflags.FlagCount())
- db_buffer << "MD BI FLAGS " << ToString(ci->botflags.ToString()) << endl;
+ db_buffer << "MD BI FLAGS " << ci->botflags.ToString() << endl;
db_buffer << "MD BI TTB BOLDS " << ci->ttb[0] << " COLORS " << ci->ttb[1] << " REVERSES " << ci->ttb[2] << " UNDERLINES " << ci->ttb[3] << " BADWORDS " << ci->ttb[4] << " CAPS " << ci->ttb[5] << " FLOOD " << ci->ttb[6] << " REPEAT " << ci->ttb[7] << " ITALICS " << ci->ttb[8] << " AMSGS " << ci->ttb[9] << endl;
if (ci->capsmin)
db_buffer << "MD BI CAPSMIN " << ci->capsmin << endl;
@@ -852,7 +828,7 @@ class DBPlain : public Module
db_buffer << "MD BI BADWORD " << (ci->GetBadWord(k)->type == BW_ANY ? "ANY " : "") << (ci->GetBadWord(k)->type == BW_SINGLE ? "SINGLE " : "") << (ci->GetBadWord(k)->type == BW_START ? "START " : "") <<
(ci->GetBadWord(k)->type == BW_END ? "END " : "") << ":" << ci->GetBadWord(k)->word << endl;
- FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteMetadata, ci));
+ //FOREACH_MOD(I_OnDatabaseWriteMetadata, OnDatabaseWriteMetadata(WriteMetadata, ci));
}
db_buffer << "OS STATS " << maxusercnt << " " << maxusertime << endl;
@@ -867,14 +843,14 @@ class DBPlain : public Module
}
}
- if (SessionInterface)
- for (SessionService::ExceptionVector::iterator it = SessionInterface->GetExceptions().begin(); it != SessionInterface->GetExceptions().end(); ++it)
+ if (session_service)
+ for (SessionService::ExceptionVector::iterator it = session_service->GetExceptions().begin(); it != session_service->GetExceptions().end(); ++it)
{
Exception *e = *it;
db_buffer << "OS EXCEPTION " << e->mask << " " << e->limit << " " << e->who << " " << e->time << " " << e->expires << " " << e->reason << endl;
}
- FOREACH_MOD(I_OnDatabaseWrite, OnDatabaseWrite(Write));
+ //FOREACH_MOD(I_OnDatabaseWrite, OnDatabaseWrite(Write));
std::fstream db;
db.open(DatabaseFile.c_str(), std::ios_base::out | std::ios_base::trunc);
@@ -892,22 +868,6 @@ class DBPlain : public Module
return EVENT_CONTINUE;
}
-
- void OnModuleLoad(User *u, Module *m)
- {
- if (!u)
- return;
-
- Implementation events[] = {I_OnDatabaseRead, I_OnDatabaseReadMetadata};
- for (int i = 0; i < 2; ++i)
- {
- std::vector<Module *>::iterator it = std::find(ModuleManager::EventHandlers[events[i]].begin(), ModuleManager::EventHandlers[events[i]].end(), m);
- /* This module wants to read from the database */
- if (it != ModuleManager::EventHandlers[events[i]].end())
- /* Loop over the database and call the events it would on a normal startup */
- ReadDatabase(m);
- }
- }
};
MODULE_INIT(DBPlain)
generated by cgit (git 2.34.1) at 2025-06-17 15:35:39 +0000