feat:add Rpop cmd & go ut

src/base_cmd.h

@@ -80,8 +80,11 @@ const std::string kCmdNameSUnionStore = "sunionstore";
 const std::string kCmdNameSInter = "sinter";
 const std::string kCmdNameSRem = "srem";
 const std::string kCmdNameSUnion = "sunion";
+
+// list cmd
 const std::string kCmdNameLPush = "lpush";
 const std::string kCmdNameRPush = "rpush";
+const std::string kCmdNameRPop = "rpop";
 
 enum CmdFlags {
  kCmdFlagsWrite = (1 << 0), // May modify the dataset

src/cmd_list.cc

@@ -48,4 +48,24 @@ void RPushCmd::DoCmd(PClient* client) {
  }
 }
 
+RPopCmd::RPopCmd(const std::string& name, int16_t arity)
+ : BaseCmd(name, arity, kCmdFlagsWrite, kAclCategoryWrite | kAclCategoryList) {}
+
+bool RPopCmd::DoInitial(PClient* client) {
+ client->SetKey(client->argv_[1]);
+ return true;
+}
+
+void RPopCmd::DoCmd(PClient* client) {
+ std::vector<std::string> elements;
+ storage::Status s = PSTORE.GetBackend()->RPop(client->Key(), 1, &elements);
+ if (s.ok()) {
+ client->AppendString(elements[0]);
+ } else if (s.IsNotFound()) {
+ client->AppendStringLen(-1);
+ } else {
+ client->SetRes(CmdRes::kSyntaxErr, "rpop cmd error");
+ }
+}
+
 } // namespace pikiwidb

src/cmd_list.h

@@ -30,4 +30,16 @@ class RPushCmd : public BaseCmd {
  private:
  void DoCmd(PClient* client) override;
 };
+
+class RPopCmd : public BaseCmd {
+ public:
+ RPopCmd(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

@@ -89,6 +89,7 @@ void CmdTableManager::InitCmdTable() {
  // list
  ADD_COMMAND(LPush, -3);
  ADD_COMMAND(RPush, -3);
+ ADD_COMMAND(RPop, 2);
 }
 
 std::pair<BaseCmd*, CmdRes::CmdRet> CmdTableManager::GetCommand(const std::string& cmdName, PClient* client) {

tests/list_test.go

@@ -79,4 +79,24 @@ var _ = Describe("List", Ordered, func() {
 
  // Expect(client.LRange(ctx,"mylistRPUSH",0,-1).Val()).To(Equal([]string{"hello", "world"})) //After the LRange command is developed, uncomment it to test LRange command.
  })
+
+ It("should RPop", func() {
+ rPush := client.RPush(ctx, "list", "one")
+ Expect(rPush.Err()).NotTo(HaveOccurred())
+ rPush = client.RPush(ctx, "list", "two")
+ Expect(rPush.Err()).NotTo(HaveOccurred())
+ rPush = client.RPush(ctx, "list", "three")
+ Expect(rPush.Err()).NotTo(HaveOccurred())
+
+ rPop := client.RPop(ctx, "list")
+ Expect(rPop.Err()).NotTo(HaveOccurred())
+ Expect(rPop.Val()).To(Equal("three"))
+
+ //lRange := client.LRange(ctx, "list", 0, -1)
+ //Expect(lRange.Err()).NotTo(HaveOccurred())
+ //Expect(lRange.Val()).To(Equal([]string{"one", "two"}))
+
+ err := client.Do(ctx, "RPOP", "list", 1, 2).Err()
+ Expect(err).To(MatchError(ContainSubstring("ERR wrong number of arguments for 'rpop' command")))
+ })
 })