feat: support cmd persist

src/base_cmd.h

@@ -27,6 +27,7 @@ const std::string kCmdNameExists = "exists";
 const std::string kCmdNamePExpire = "pexpire";
 const std::string kCmdNameExpireat = "expireat";
 const std::string kCmdNamePExpireat = "pexpireat";
+const std::string kCmdNamePersist = "persist";
 
 // string cmd
 const std::string kCmdNameSet = "set";

src/cmd_keys.cc

@@ -121,4 +121,29 @@ void PExpireatCmd::DoCmd(PClient* client) {
   }
 }
 
+PersistCmd::PersistCmd(const std::string& name, int16_t arity)
+    : BaseCmd(name, arity, kCmdFlagsWrite, kAclCategoryWrite | kAclCategoryKeyspace) {}
+
+bool PersistCmd::DoInitial(PClient* client) {
+  client->SetKey(client->argv_[1]);
+  return true;
+}
+
+void PersistCmd::DoCmd(PClient* client) {
+  std::map<storage::DataType, storage::Status> type_status;
+  auto res = PSTORE.GetBackend(client->GetCurrentDB())->Persist(client->Key(), &type_status);
+  if (res != -1) {
+    client->AppendInteger(res);
+  } else {
+    std::string cnt;
+    for (auto const& s : type_status) {
+      cnt.append(storage::DataTypeToString[s.first]);
+      cnt.append(" - ");
+      cnt.append(s.second.ToString());
+      cnt.append(";");
+    }
+    client->SetRes(CmdRes::kErrOther, cnt);
+  }
+}
+
 }  // namespace pikiwidb

src/cmd_keys.h

@@ -66,4 +66,14 @@ class PExpireatCmd : public BaseCmd {
   void DoCmd(PClient* client) override;
 };
 
+class PersistCmd : public BaseCmd {
+ public:
+  PersistCmd(const std::string& name, int16_t arity);
+
+ protected:
+  bool DoInitial(PClient* client) override;
+
+ private:
+  void DoCmd(PClient* client) override;
+};
 }  // namespace pikiwidb

src/cmd_table_manager.cc

@@ -49,6 +49,7 @@ void CmdTableManager::InitCmdTable() {
   ADD_COMMAND(PExpire, 3);
   ADD_COMMAND(Expireat, 3);
   ADD_COMMAND(PExpireat, 3);
+  ADD_COMMAND(Persist, 2);
   // kv
   ADD_COMMAND(Get, 2);
   ADD_COMMAND(Set, -3);

src/storage/include/storage/storage.h

@@ -121,6 +121,7 @@ enum BeforeOrAfter { Before, After };
 
 enum DataType { kAll, kStrings, kHashes, kSets, kLists, kZSets };
 
+const std::string DataTypeToString[] = {"all", "string", "hash", "set", "list", "zset"};
 const char DataTypeTag[] = {'a', 'k', 'h', 's', 'l', 'z'};
 
 enum class OptionType {

tests/key_test.go

@@ -189,4 +189,27 @@ var _ = Describe("Keyspace", Ordered, func() {
 
 	})
 
+	It("persist", func() {
+		// return 0 if key does not exist
+		Expect(client.Persist(ctx, DefaultKey).Val()).To(Equal(false))
+
+		// return 0 if key does not have an associated timeout
+		Expect(client.Set(ctx, DefaultKey, DefaultValue, 0).Val()).To(Equal(OK))
+		Expect(client.Persist(ctx, DefaultKey).Val()).To(Equal(false))
+
+		// return 1 if the timueout was set
+		Expect(client.PExpireAt(ctx, DefaultKey, time.Now().Add(time.Second*3)).Val()).To(Equal(true))
+		Expect(client.Persist(ctx, DefaultKey).Val()).To(Equal(true))
+		time.Sleep(5 * time.Second)
+		Expect(client.Exists(ctx, DefaultKey).Val()).To(Equal(int64(1)))
+
+		// multi data type
+		Expect(client.LPush(ctx, DefaultKey, "l").Err()).NotTo(HaveOccurred())
+		Expect(client.HSet(ctx, DefaultKey, "h", "h").Err()).NotTo(HaveOccurred())
+		Expect(client.SAdd(ctx, DefaultKey, "s").Err()).NotTo(HaveOccurred())
+		Expect(client.ZAdd(ctx, DefaultKey, redis.Z{Score: 1, Member: "z"}).Err()).NotTo(HaveOccurred())
+		Expect(client.Set(ctx, DefaultKey, DefaultValue, 0).Val()).To(Equal(OK))
+		Expect(client.PExpireAt(ctx, DefaultKey, time.Now().Add(time.Second*1000)).Err()).NotTo(HaveOccurred())
+		Expect(client.Persist(ctx, DefaultKey).Err()).NotTo(HaveOccurred())
+	})
 })