X-Git-Url: https://git.stg.codes/stg.git/blobdiff_plain/a79cfb92e093d9c9c78e3ccbabcd45de1a283e56..43ac308ea20014761481bc40525496a0bb1d9740:/projects/stargazer/plugins/configuration/sgconfig/parser_users.cpp diff --git a/projects/stargazer/plugins/configuration/sgconfig/parser_users.cpp b/projects/stargazer/plugins/configuration/sgconfig/parser_users.cpp index 67e2c699..68a597c8 100644 --- a/projects/stargazer/plugins/configuration/sgconfig/parser_users.cpp +++ b/projects/stargazer/plugins/configuration/sgconfig/parser_users.cpp @@ -22,10 +22,12 @@ #include "parser_users.h" #include "stg/users.h" -#include "stg/tariffs.h" -#include "stg/user_property.h" +#include "stg/user.h" #include "stg/user_conf.h" #include "stg/user_stat.h" +#include "stg/tariffs.h" +#include "stg/tariff.h" +#include "stg/user_property.h" #include #include @@ -44,118 +46,121 @@ const char * CHG_USER::tag = "SetUser"; const char * DEL_USER::tag = "DelUser"; const char * CHECK_USER::tag = "CheckUser"; +using UserPtr = STG::User*; +using ConstUserPtr = const STG::User*; + namespace { -std::string UserToXML(const USER & user, bool loginInStart, bool showPass, time_t lastTime = 0) +std::string UserToXML(const STG::User & user, bool loginInStart, bool showPass, time_t lastTime = 0) { std::string answer; if (loginInStart) - answer += ""; + answer += ""; else - answer += ""; + answer += ""; answer += ""; - if (user.GetProperty().password.ModificationTime() > lastTime) + if (user.GetProperties().password.ModificationTime() > lastTime) { if (showPass) - answer += ""; + answer += ""; else answer += ""; } - if (user.GetProperty().cash.ModificationTime() > lastTime) - answer += ""; - if (user.GetProperty().freeMb.ModificationTime() > lastTime) - answer += ""; - if (user.GetProperty().credit.ModificationTime() > lastTime) - answer += ""; + if (user.GetProperties().cash.ModificationTime() > lastTime) + answer += ""; + if (user.GetProperties().freeMb.ModificationTime() > lastTime) + answer += ""; + if (user.GetProperties().credit.ModificationTime() > lastTime) + answer += ""; - if (user.GetProperty().nextTariff.Get() != "") + if (user.GetProperties().nextTariff.Get() != "") { - if (user.GetProperty().tariffName.ModificationTime() > lastTime || - user.GetProperty().nextTariff.ModificationTime() > lastTime) - answer += ""; + if (user.GetProperties().tariffName.ModificationTime() > lastTime || + user.GetProperties().nextTariff.ModificationTime() > lastTime) + answer += ""; } else { - if (user.GetProperty().tariffName.ModificationTime() > lastTime) - answer += ""; + if (user.GetProperties().tariffName.ModificationTime() > lastTime) + answer += ""; } - if (user.GetProperty().note.ModificationTime() > lastTime) - answer += ""; - if (user.GetProperty().phone.ModificationTime() > lastTime) - answer += ""; - if (user.GetProperty().address.ModificationTime() > lastTime) - answer += "
"; - if (user.GetProperty().email.ModificationTime() > lastTime) - answer += ""; - - std::vector *> userdata; - userdata.push_back(user.GetProperty().userdata0.GetPointer()); - userdata.push_back(user.GetProperty().userdata1.GetPointer()); - userdata.push_back(user.GetProperty().userdata2.GetPointer()); - userdata.push_back(user.GetProperty().userdata3.GetPointer()); - userdata.push_back(user.GetProperty().userdata4.GetPointer()); - userdata.push_back(user.GetProperty().userdata5.GetPointer()); - userdata.push_back(user.GetProperty().userdata6.GetPointer()); - userdata.push_back(user.GetProperty().userdata7.GetPointer()); - userdata.push_back(user.GetProperty().userdata8.GetPointer()); - userdata.push_back(user.GetProperty().userdata9.GetPointer()); + if (user.GetProperties().note.ModificationTime() > lastTime) + answer += ""; + if (user.GetProperties().phone.ModificationTime() > lastTime) + answer += ""; + if (user.GetProperties().address.ModificationTime() > lastTime) + answer += "
"; + if (user.GetProperties().email.ModificationTime() > lastTime) + answer += ""; + + std::vector *> userdata; + userdata.push_back(user.GetProperties().userdata0.GetPointer()); + userdata.push_back(user.GetProperties().userdata1.GetPointer()); + userdata.push_back(user.GetProperties().userdata2.GetPointer()); + userdata.push_back(user.GetProperties().userdata3.GetPointer()); + userdata.push_back(user.GetProperties().userdata4.GetPointer()); + userdata.push_back(user.GetProperties().userdata5.GetPointer()); + userdata.push_back(user.GetProperties().userdata6.GetPointer()); + userdata.push_back(user.GetProperties().userdata7.GetPointer()); + userdata.push_back(user.GetProperties().userdata8.GetPointer()); + userdata.push_back(user.GetProperties().userdata9.GetPointer()); for (size_t i = 0; i < userdata.size(); i++) if (userdata[i]->ModificationTime() > lastTime) - answer += "Get()) + "\" />"; + answer += "Get()) + "\" />"; - if (user.GetProperty().realName.ModificationTime() > lastTime) - answer += ""; - if (user.GetProperty().group.ModificationTime() > lastTime) - answer += ""; + if (user.GetProperties().realName.ModificationTime() > lastTime) + answer += ""; + if (user.GetProperties().group.ModificationTime() > lastTime) + answer += ""; if (user.GetConnectedModificationTime() > lastTime) answer += std::string(""; - if (user.GetProperty().alwaysOnline.ModificationTime() > lastTime) - answer += std::string(""; + if (user.GetProperties().alwaysOnline.ModificationTime() > lastTime) + answer += std::string(""; if (user.GetCurrIPModificationTime() > lastTime) answer += ""; if (user.GetPingTime() > lastTime) - answer += ""; - if (user.GetProperty().ips.ModificationTime() > lastTime) - answer += ""; + answer += ""; + if (user.GetProperties().ips.ModificationTime() > lastTime) + answer += ""; answer += " lastTime) + const auto & upload(user.GetProperties().up.Get()); + const auto & download(user.GetProperties().down.Get()); + if (user.GetProperties().up.ModificationTime() > lastTime) for (size_t j = 0; j < DIR_NUM; j++) - answer += " MU" + x2str(j) + "=\"" + x2str(upload[j]) + "\""; - if (user.GetProperty().down.ModificationTime() > lastTime) + answer += " MU" + std::to_string(j) + "=\"" + std::to_string(upload[j]) + "\""; + if (user.GetProperties().down.ModificationTime() > lastTime) for (size_t j = 0; j < DIR_NUM; j++) - answer += " MD" + x2str(j) + "=\"" + x2str(download[j]) + "\""; + answer += " MD" + std::to_string(j) + "=\"" + std::to_string(download[j]) + "\""; if (user.GetSessionUploadModificationTime() > lastTime) for (size_t j = 0; j < DIR_NUM; j++) - answer += " SU" + x2str(j) + "=\"" + x2str(user.GetSessionUpload()[j]) + "\""; + answer += " SU" + std::to_string(j) + "=\"" + std::to_string(user.GetSessionUpload()[j]) + "\""; if (user.GetSessionDownloadModificationTime() > lastTime) for (size_t j = 0; j < DIR_NUM; j++) - answer += " SD" + x2str(j) + "=\"" + x2str(user.GetSessionDownload()[j]) + "\""; + answer += " SD" + std::to_string(j) + "=\"" + std::to_string(user.GetSessionDownload()[j]) + "\""; answer += "/>"; - if (user.GetProperty().disabled.ModificationTime() > lastTime) - answer += std::string(""; - if (user.GetProperty().disabledDetailStat.ModificationTime() > lastTime) - answer += std::string(""; - if (user.GetProperty().passive.ModificationTime() > lastTime) - answer += std::string(""; - if (user.GetProperty().lastCashAdd.ModificationTime() > lastTime) - answer += ""; - if (user.GetProperty().lastCashAddTime.ModificationTime() > lastTime) - answer += ""; - if (user.GetProperty().lastActivityTime.ModificationTime() > lastTime) - answer += ""; - if (user.GetProperty().creditExpire.ModificationTime() > lastTime) - answer += ""; + if (user.GetProperties().disabled.ModificationTime() > lastTime) + answer += std::string(""; + if (user.GetProperties().disabledDetailStat.ModificationTime() > lastTime) + answer += std::string(""; + if (user.GetProperties().passive.ModificationTime() > lastTime) + answer += std::string(""; + if (user.GetProperties().lastCashAdd.ModificationTime() > lastTime) + answer += ""; + if (user.GetProperties().lastCashAddTime.ModificationTime() > lastTime) + answer += ""; + if (user.GetProperties().lastActivityTime.ModificationTime() > lastTime) + answer += ""; + if (user.GetProperties().creditExpire.ModificationTime() > lastTime) + answer += ""; if (lastTime == 0) { @@ -197,14 +202,14 @@ void GET_USERS::CreateAnswer() assert(h); if (m_lastUserUpdateTime > 0) - m_answer = ""; + m_answer = ""; else m_answer = ""; - USER_PTR u; + UserPtr u; while (m_users.SearchNext(h, &u) == 0) - m_answer += UserToXML(*u, true, m_currAdmin.GetPriv()->userConf || m_currAdmin.GetPriv()->userPasswd, m_lastUserUpdateTime); + m_answer += UserToXML(*u, true, m_currAdmin.priv().userConf || m_currAdmin.priv().userPasswd, m_lastUserUpdateTime); m_users.CloseSearch(h); @@ -225,12 +230,12 @@ int GET_USER::Start(void *, const char * el, const char ** attr) void GET_USER::CreateAnswer() { - CONST_USER_PTR u; + ConstUserPtr u; if (m_users.FindByName(m_login, &u)) m_answer = ""; else - m_answer = UserToXML(*u, false, m_currAdmin.GetPriv()->userConf || m_currAdmin.GetPriv()->userPasswd); + m_answer = UserToXML(*u, false, m_currAdmin.priv().userConf || m_currAdmin.priv().userPasswd); } int ADD_USER::Start(void *, const char * el, const char ** attr) @@ -282,7 +287,7 @@ int CHG_USER::Start(void *, const char * el, const char ** attr) if (strcasecmp(el, "ip") == 0) { - m_ucr.ips = StrToIPS(attr[1]); + m_ucr.ips = UserIPs::parse(attr[1]); return 0; } @@ -322,7 +327,7 @@ int CHG_USER::Start(void *, const char * el, const char ** attr) { long int creditExpire = 0; if (str2x(attr[1], creditExpire) == 0) - m_ucr.creditExpire = (time_t)creditExpire; + m_ucr.creditExpire = creditExpire; return 0; } @@ -457,146 +462,158 @@ void CHG_USER::CreateAnswer() int CHG_USER::ApplyChanges() { printfd(__FILE__, "PARSER_CHG_USER::ApplyChanges()\n"); - USER_PTR u; + UserPtr u; if (m_users.FindByName(m_login, &u)) return -1; bool check = false; - bool alwaysOnline = u->GetProperty().alwaysOnline; - if (!m_ucr.alwaysOnline.empty()) + bool alwaysOnline = u->GetProperties().alwaysOnline; + if (m_ucr.alwaysOnline) { check = true; - alwaysOnline = m_ucr.alwaysOnline.const_data(); + alwaysOnline = m_ucr.alwaysOnline.value(); } - bool onlyOneIP = u->GetProperty().ips.ConstData().OnlyOneIP(); - if (!m_ucr.ips.empty()) + bool onlyOneIP = u->GetProperties().ips.ConstData().onlyOneIP(); + if (m_ucr.ips) { check = true; - onlyOneIP = m_ucr.ips.const_data().OnlyOneIP(); + onlyOneIP = m_ucr.ips.value().onlyOneIP(); } if (check && alwaysOnline && !onlyOneIP) { printfd(__FILE__, "Requested change leads to a forbidden state: AlwaysOnline with multiple IP's\n"); - GetStgLogger()("%s Requested change leads to a forbidden state: AlwaysOnline with multiple IP's", m_currAdmin.GetLogStr().c_str()); + PluginLogger::get("conf_sg")("%s Requested change leads to a forbidden state: AlwaysOnline with multiple IP's", m_currAdmin.logStr().c_str()); return -1; } - for (size_t i = 0; i < m_ucr.ips.const_data().Count(); ++i) + for (size_t i = 0; i < m_ucr.ips.value().count(); ++i) { - CONST_USER_PTR user; - uint32_t ip = m_ucr.ips.const_data().operator[](i).ip; + ConstUserPtr user; + uint32_t ip = m_ucr.ips.value().operator[](i).ip; if (m_users.IsIPInUse(ip, m_login, &user)) { printfd(__FILE__, "Trying to assign an IP %s to '%s' that is already in use by '%s'\n", inet_ntostring(ip).c_str(), m_login.c_str(), user->GetLogin().c_str()); - GetStgLogger()("%s trying to assign an IP %s to '%s' that is currently in use by '%s'", m_currAdmin.GetLogStr().c_str(), inet_ntostring(ip).c_str(), m_login.c_str(), user->GetLogin().c_str()); + PluginLogger::get("conf_sg")("%s trying to assign an IP %s to '%s' that is currently in use by '%s'", m_currAdmin.logStr().c_str(), inet_ntostring(ip).c_str(), m_login.c_str(), user->GetLogin().c_str()); return -1; } } - if (!m_ucr.ips.empty()) - if (!u->GetProperty().ips.Set(m_ucr.ips.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.ips) + if (!u->GetProperties().ips.Set(m_ucr.ips.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.alwaysOnline.empty()) - if (!u->GetProperty().alwaysOnline.Set(m_ucr.alwaysOnline.const_data(), - &m_currAdmin, m_login, &m_store)) + if (m_ucr.alwaysOnline) + if (!u->GetProperties().alwaysOnline.Set(m_ucr.alwaysOnline.value(), + m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.address.empty()) - if (!u->GetProperty().address.Set(m_ucr.address.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.address) + if (!u->GetProperties().address.Set(m_ucr.address.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.creditExpire.empty()) - if (!u->GetProperty().creditExpire.Set(m_ucr.creditExpire.const_data(), - &m_currAdmin, m_login, &m_store)) + if (m_ucr.creditExpire) + if (!u->GetProperties().creditExpire.Set(m_ucr.creditExpire.value(), + m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.credit.empty()) - if (!u->GetProperty().credit.Set(m_ucr.credit.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.credit) + if (!u->GetProperties().credit.Set(m_ucr.credit.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_usr.freeMb.empty()) - if (!u->GetProperty().freeMb.Set(m_usr.freeMb.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_usr.freeMb) + if (!u->GetProperties().freeMb.Set(m_usr.freeMb.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.disabled.empty()) - if (!u->GetProperty().disabled.Set(m_ucr.disabled.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.disabled) + if (!u->GetProperties().disabled.Set(m_ucr.disabled.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.disabledDetailStat.empty()) - if (!u->GetProperty().disabledDetailStat.Set(m_ucr.disabledDetailStat.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.disabledDetailStat) + if (!u->GetProperties().disabledDetailStat.Set(m_ucr.disabledDetailStat.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.email.empty()) - if (!u->GetProperty().email.Set(m_ucr.email.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.email) + if (!u->GetProperties().email.Set(m_ucr.email.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.group.empty()) - if (!u->GetProperty().group.Set(m_ucr.group.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.group) + if (!u->GetProperties().group.Set(m_ucr.group.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.note.empty()) - if (!u->GetProperty().note.Set(m_ucr.note.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.note) + if (!u->GetProperties().note.Set(m_ucr.note.value(), m_currAdmin, m_login, m_store)) return -1; - std::vector *> userdata; - userdata.push_back(u->GetProperty().userdata0.GetPointer()); - userdata.push_back(u->GetProperty().userdata1.GetPointer()); - userdata.push_back(u->GetProperty().userdata2.GetPointer()); - userdata.push_back(u->GetProperty().userdata3.GetPointer()); - userdata.push_back(u->GetProperty().userdata4.GetPointer()); - userdata.push_back(u->GetProperty().userdata5.GetPointer()); - userdata.push_back(u->GetProperty().userdata6.GetPointer()); - userdata.push_back(u->GetProperty().userdata7.GetPointer()); - userdata.push_back(u->GetProperty().userdata8.GetPointer()); - userdata.push_back(u->GetProperty().userdata9.GetPointer()); - - for (int i = 0; i < (int)userdata.size(); i++) - if (!m_ucr.userdata[i].empty()) - if(!userdata[i]->Set(m_ucr.userdata[i].const_data(), &m_currAdmin, m_login, &m_store)) + std::vector *> userdata; + userdata.push_back(u->GetProperties().userdata0.GetPointer()); + userdata.push_back(u->GetProperties().userdata1.GetPointer()); + userdata.push_back(u->GetProperties().userdata2.GetPointer()); + userdata.push_back(u->GetProperties().userdata3.GetPointer()); + userdata.push_back(u->GetProperties().userdata4.GetPointer()); + userdata.push_back(u->GetProperties().userdata5.GetPointer()); + userdata.push_back(u->GetProperties().userdata6.GetPointer()); + userdata.push_back(u->GetProperties().userdata7.GetPointer()); + userdata.push_back(u->GetProperties().userdata8.GetPointer()); + userdata.push_back(u->GetProperties().userdata9.GetPointer()); + + for (size_t i = 0; i < userdata.size(); i++) + if (m_ucr.userdata[i]) + if(!userdata[i]->Set(m_ucr.userdata[i].value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.passive.empty()) - if (!u->GetProperty().passive.Set(m_ucr.passive.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.passive) + if (!u->GetProperties().passive.Set(m_ucr.passive.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.password.empty()) - if (!u->GetProperty().password.Set(m_ucr.password.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.password) + if (!u->GetProperties().password.Set(m_ucr.password.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.phone.empty()) - if (!u->GetProperty().phone.Set(m_ucr.phone.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.phone) + if (!u->GetProperties().phone.Set(m_ucr.phone.value(), m_currAdmin, m_login, m_store)) return -1; - if (!m_ucr.realName.empty()) - if (!u->GetProperty().realName.Set(m_ucr.realName.const_data(), &m_currAdmin, m_login, &m_store)) + if (m_ucr.realName) + if (!u->GetProperties().realName.Set(m_ucr.realName.value(), m_currAdmin, m_login, m_store)) return -1; - - if (!m_usr.cash.empty()) + if (m_usr.cash) + { if (m_cashMustBeAdded) { - if (!u->GetProperty().cash.Set(m_usr.cash.const_data() + u->GetProperty().cash, - &m_currAdmin, - m_login, - &m_store, - m_cashMsg)) + if (!u->GetProperties().cash.Set(m_usr.cash.value() + u->GetProperties().cash, + m_currAdmin, + m_login, + m_store, + m_cashMsg)) return -1; - else - if (!u->GetProperty().cash.Set(m_usr.cash.const_data(), &m_currAdmin, m_login, &m_store, m_cashMsg)) - return -1; } + else + { + if (!u->GetProperties().cash.Set(m_usr.cash.value(), m_currAdmin, m_login, m_store, m_cashMsg)) + return -1; + } + } - - if (!m_ucr.tariffName.empty()) + if (m_ucr.tariffName) { - if (m_tariffs.FindByName(m_ucr.tariffName.const_data())) + const auto newTariff = m_tariffs.FindByName(m_ucr.tariffName.value()); + if (newTariff) { - if (!u->GetProperty().tariffName.Set(m_ucr.tariffName.const_data(), &m_currAdmin, m_login, &m_store)) - return -1; - u->ResetNextTariff(); + const auto tariff = u->GetTariff(); + std::string message = tariff->TariffChangeIsAllowed(*newTariff, time(NULL)); + if (message.empty()) + { + if (!u->GetProperties().tariffName.Set(m_ucr.tariffName.value(), m_currAdmin, m_login, m_store)) + return -1; + u->ResetNextTariff(); + } + else + { + PluginLogger::get("conf_sg")("Tariff change is prohibited for user %s. %s", u->GetLogin().c_str(), message.c_str()); + } } else { @@ -605,11 +622,11 @@ int CHG_USER::ApplyChanges() } } - if (!m_ucr.nextTariff.empty()) + if (m_ucr.nextTariff) { - if (m_tariffs.FindByName(m_ucr.nextTariff.const_data())) + if (m_tariffs.FindByName(m_ucr.nextTariff.value())) { - if (!u->GetProperty().nextTariff.Set(m_ucr.nextTariff.const_data(), &m_currAdmin, m_login, &m_store)) + if (!u->GetProperties().nextTariff.Set(m_ucr.nextTariff.value(), m_currAdmin, m_login, m_store)) return -1; } else @@ -619,30 +636,30 @@ int CHG_USER::ApplyChanges() } } - DIR_TRAFF up = u->GetProperty().up; - DIR_TRAFF down = u->GetProperty().down; + auto up = u->GetProperties().up.get(); + auto down = u->GetProperties().down.get(); int upCount = 0; int downCount = 0; for (int i = 0; i < DIR_NUM; i++) { - if (!m_upr[i].empty()) + if (m_upr[i]) { - up[i] = m_upr[i].data(); + up[i] = m_upr[i].value(); upCount++; } - if (!m_downr[i].empty()) + if (m_downr[i]) { - down[i] = m_downr[i].data(); + down[i] = m_downr[i].value(); downCount++; } } if (upCount) - if (!u->GetProperty().up.Set(up, &m_currAdmin, m_login, &m_store)) + if (!u->GetProperties().up.Set(up, m_currAdmin, m_login, m_store)) return -1; if (downCount) - if (!u->GetProperty().down.Set(down, &m_currAdmin, m_login, &m_store)) + if (!u->GetProperties().down.Set(down, m_currAdmin, m_login, m_store)) return -1; u->WriteConf(); @@ -682,8 +699,6 @@ int DEL_USER::End(void *, const char *el) if (!res) m_users.Del(u->GetLogin(), &m_currAdmin); - m_done = true; - return 0; } return -1; @@ -709,7 +724,7 @@ int CHECK_USER::Start(void *, const char *el, const char **attr) return 0; } - CONST_USER_PTR user; + ConstUserPtr user; if (m_users.FindByName(attr[1], &user)) { CreateAnswer("User not found."); @@ -717,7 +732,7 @@ int CHECK_USER::Start(void *, const char *el, const char **attr) return 0; } - if (strcmp(user->GetProperty().password.Get().c_str(), attr[3])) + if (strcmp(user->GetProperties().password.Get().c_str(), attr[3])) { CreateAnswer("Wrong password."); printfd(__FILE__, "PARSER_CHECK_USER - passwd err\n"); @@ -733,10 +748,7 @@ int CHECK_USER::Start(void *, const char *el, const char **attr) int CHECK_USER::End(void *, const char *el) { if (strcasecmp(el, m_tag.c_str()) == 0) - { - m_done = true; return 0; - } return -1; }