Add BinprotCompactDbCommand

Change-Id: Ied21fa9501a7bc2486fe47b0a3f7e5a6832635f7
Reviewed-on: http://review.couchbase.org/c/kv_engine/+/138033
Tested-by: Build Bot <[email protected]>
Reviewed-by: Dave Rigby <[email protected]>

Author: trondn

protocol/connection/client_mcbp_commands.cc

@@ -1893,3 +1893,13 @@ void BinprotEWBCommand::encode(std::vector<uint8_t>& buf) const {
     buf.insert(buf.end(), extraBuf.begin(), extraBuf.end());
     buf.insert(buf.end(), key.begin(), key.end());
 }
+
+BinprotCompactDbCommand::BinprotCompactDbCommand()
+    : BinprotGenericCommand(cb::mcbp::ClientOpcode::CompactDb) {
+}
+
+void BinprotCompactDbCommand::encode(std::vector<uint8_t>& buf) const {
+    writeHeader(buf, 0, sizeof(extras));
+    auto extraBuf = extras.getBuffer();
+    buf.insert(buf.end(), extraBuf.begin(), extraBuf.end());
+}

protocol/connection/client_mcbp_commands.h

@@ -1116,3 +1116,38 @@ class BinprotEWBCommand : public BinprotGenericCommand {
     ENGINE_ERROR_CODE err_code;
     uint32_t value;
 };
+
+class BinprotCompactDbCommand : public BinprotGenericCommand {
+public:
+    BinprotCompactDbCommand();
+
+    void encode(std::vector<uint8_t>& buf) const override;
+
+    uint64_t getPurgeBeforeTs() const {
+        return extras.getPurgeBeforeTs();
+    }
+    void setPurgeBeforeTs(uint64_t purge_before_ts) {
+        extras.setPurgeBeforeTs(purge_before_ts);
+    }
+    uint64_t getPurgeBeforeSeq() const {
+        return extras.getPurgeBeforeSeq();
+    }
+    void setPurgeBeforeSeq(uint64_t purge_before_seq) {
+        extras.setPurgeBeforeSeq(purge_before_seq);
+    }
+    uint8_t getDropDeletes() const {
+        return extras.getDropDeletes();
+    }
+    void setDropDeletes(uint8_t drop_deletes) {
+        extras.setDropDeletes(drop_deletes);
+    }
+    const Vbid getDbFileId() const {
+        return extras.getDbFileId();
+    }
+    void setDbFileId(Vbid db_file_id) {
+        extras.setDbFileId(db_file_id);
+    }
+
+protected:
+    cb::mcbp::request::CompactDbPayload extras;
+};