SERVER-30147 Move Command::appendOperationTime to LogicalTime

1 files changed, 22 insertions, 2 deletions

diff --git a/src/mongo/db/logical_time.cpp b/src/mongo/db/logical_time.cpp
index c26d542ec3d..1bb5ce5b62f 100644
--- a/src/mongo/db/logical_time.cpp
+++ b/src/mongo/db/logical_time.cpp
@@ -26,19 +26,39 @@
  *    it in the license file.
  */
 
+#include "mongo/platform/basic.h"
+
 #include "mongo/db/logical_time.h"
 
 #include "mongo/base/data_type_endian.h"
 #include "mongo/base/data_view.h"
-#include "mongo/platform/basic.h"
-#include "mongo/util/mongoutils/str.h"
+#include "mongo/bson/bsonobj.h"
+#include "mongo/bson/bsonobjbuilder.h"
 
 namespace mongo {
+namespace {
+
+constexpr auto kOperationTime = "operationTime"_sd;
+
+}  // namespace
 
 const LogicalTime LogicalTime::kUninitialized = LogicalTime();
 
 LogicalTime::LogicalTime(Timestamp ts) : _time(ts.asULL()) {}
 
+LogicalTime LogicalTime::fromOperationTime(const BSONObj& obj) {
+    const auto opTimeElem(obj[kOperationTime]);
+    uassert(ErrorCodes::FailedToParse, "No operationTime found", !opTimeElem.eoo());
+    uassert(ErrorCodes::BadValue,
+            "Operation time is of the wrong value",
+            opTimeElem.type() == bsonTimestamp);
+    return LogicalTime(opTimeElem.timestamp());
+}
+
+void LogicalTime::appendAsOperationTime(BSONObjBuilder* builder) const {
+    builder->append(kOperationTime, asTimestamp());
+}
+
 void LogicalTime::addTicks(uint64_t ticks) {
     _time += ticks;
 }