renamed variables in twitchserver

This commit is contained in:
fourtf 2018-06-24 13:06:11 +02:00
parent 47198a5489
commit 8111946858
2 changed files with 12 additions and 11 deletions

View file

@ -184,10 +184,11 @@ void TwitchServer::onMessageSendRequested(TwitchChannel *channel, const QString
sent = false; sent = false;
{ {
std::lock_guard<std::mutex> guard(this->lastMessageMutex); std::lock_guard<std::mutex> guard(this->lastMessageMutex_);
// std::queue<std::chrono::steady_clock::time_point> // std::queue<std::chrono::steady_clock::time_point>
auto &lastMessage = channel->hasModRights() ? this->lastMessageMod : this->lastMessagePleb; auto &lastMessage =
channel->hasModRights() ? this->lastMessageMod_ : this->lastMessagePleb_;
size_t maxMessageCount = channel->hasModRights() ? 99 : 19; size_t maxMessageCount = channel->hasModRights() ? 99 : 19;
auto minMessageOffset = (channel->hasModRights() ? 100ms : 1100ms); auto minMessageOffset = (channel->hasModRights() ? 100ms : 1100ms);
@ -195,13 +196,13 @@ void TwitchServer::onMessageSendRequested(TwitchChannel *channel, const QString
// check if you are sending messages too fast // check if you are sending messages too fast
if (!lastMessage.empty() && lastMessage.back() + minMessageOffset > now) { if (!lastMessage.empty() && lastMessage.back() + minMessageOffset > now) {
if (lastErrorTimeSpeed + 30s < now) { if (lastErrorTimeSpeed_ + 30s < now) {
auto errorMessage = auto errorMessage =
messages::Message::createSystemMessage("sending messages too fast"); messages::Message::createSystemMessage("sending messages too fast");
channel->addMessage(errorMessage); channel->addMessage(errorMessage);
lastErrorTimeSpeed = now; lastErrorTimeSpeed_ = now;
} }
return; return;
} }
@ -213,13 +214,13 @@ void TwitchServer::onMessageSendRequested(TwitchChannel *channel, const QString
// check if you are sending too many messages // check if you are sending too many messages
if (lastMessage.size() >= maxMessageCount) { if (lastMessage.size() >= maxMessageCount) {
if (lastErrorTimeAmount + 30s < now) { if (lastErrorTimeAmount_ + 30s < now) {
auto errorMessage = auto errorMessage =
messages::Message::createSystemMessage("sending too many messages"); messages::Message::createSystemMessage("sending too many messages");
channel->addMessage(errorMessage); channel->addMessage(errorMessage);
lastErrorTimeAmount = now; lastErrorTimeAmount_ = now;
} }
return; return;
} }

View file

@ -45,11 +45,11 @@ protected:
QString cleanChannelName(const QString &dirtyChannelName) override; QString cleanChannelName(const QString &dirtyChannelName) override;
private: private:
std::mutex lastMessageMutex; std::mutex lastMessageMutex_;
std::queue<std::chrono::steady_clock::time_point> lastMessagePleb; std::queue<std::chrono::steady_clock::time_point> lastMessagePleb_;
std::queue<std::chrono::steady_clock::time_point> lastMessageMod; std::queue<std::chrono::steady_clock::time_point> lastMessageMod_;
std::chrono::steady_clock::time_point lastErrorTimeSpeed; std::chrono::steady_clock::time_point lastErrorTimeSpeed_;
std::chrono::steady_clock::time_point lastErrorTimeAmount; std::chrono::steady_clock::time_point lastErrorTimeAmount_;
void onMessageSendRequested(TwitchChannel *channel, const QString &message, bool &sent); void onMessageSendRequested(TwitchChannel *channel, const QString &message, bool &sent);
}; };