postgres/typesense
1
0
Fork 0
mirror of https://github.com/typesense/typesense.git synced 2025-05-22 06:40:30 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Fix ``clear_expired_conversations``

Browse Source
This commit is contained in:
ozanarmagan 2023-11-12 13:14:59 +03:00
parent b01e7b8d73
commit 9bd1bc00a1
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/conversation_manager.cpp
View File

@ -163,15 +163,15 @@ void ConversationManager::clear_expired_conversations() {
int cleared_conversations = 0;
for(auto& conversation : conversations) {
const std::string& conversation_id = conversation.first;
nlohmann::json conversation_json = conversation.second;
for(auto it = conversations.begin(); it != conversations.end();) {
const std::string& conversation_id = it->first;
nlohmann::json conversation_json = it->second;
if(conversation_json.count("last_updated") == 0 || conversation_json.count("ttl") == 0) {
bool delete_op = store->remove(get_conversation_key(conversation_id));
if(!delete_op) {
LOG(ERROR) << "Error while deleting conversation from the store";
}
conversations.erase(conversation_id);
it = conversations.erase(it);
cleared_conversations++;
continue;
}
@ -182,8 +182,10 @@ void ConversationManager::clear_expired_conversations() {
if(!delete_op) {
LOG(ERROR) << "Error while deleting conversation from the store";
}
conversations.erase(conversation_id);
it = conversations.erase(it);
cleared_conversations++;
} else {
it++;
}
}