Merge pull request #4 from camargo2019/fix/expire-cache

🩹 fix: expire cache

TODO.md

@@ -1,7 +1,7 @@
 ## 📌 Tarefas Pendentes
 
 ### Funcionalidades
-- [ ] Implementar expiração dos valores ao utilizar o comando `SET key value expire`.
+- [x] Implementar expiração dos valores ao utilizar o comando `SET key value expire`.
 
 ### Melhorias
 - [ ] Melhorar o método de salvamento dos dados no arquivo `.dat`.

core/cache/cache.cpp

@@ -128,4 +128,21 @@ void Cache::save(){
             cachedata.serialize(file);
         }
     }
+}
+
+void Cache::expire(){
+    std::thread([this]() {
+        while (true) {
+            std::this_thread::sleep_for(std::chrono::seconds(1));
+            for (auto& row: cache_) {
+                for (auto& item: row.second) {
+                    if (item.second.expire == 0){
+                        del(row.first, item.first);
+                    }else if(item.second.expire > 0){
+                        --item.second.expire;
+                    }
+                }
+            }
+        }
+    }).detach();
 }

core/cache/cache.h

@@ -24,6 +24,8 @@
 
     #include <string>
     #include <vector>
+    #include <thread>
+    #include <chrono>
     #include <fstream>
     #include <unordered_map>
 
@@ -55,6 +57,7 @@
             bool del(std::string db, std::string key);
             std::vector<std::string> keys (std::string db);
             void save();
+            void expire();
 
         private:
             std::unordered_map<std::string, std::unordered_map<std::string, CacheStruct>> cache_;

core/manager/manager.h

@@ -22,7 +22,6 @@
 #ifndef CORE_MANAGER_H
     #define CORE_MANAGER_H
 
-    #include <string>
     #include <string>
     #include <vector>
     #include <memory>

main.cpp

@@ -23,6 +23,7 @@
 
 int main(){
     Cache cache_;
+    cache_.expire();
 
     try {
         boost::asio::io_context io_context;