SERVER-45179 Add the FCV 4.4 behavior to the MigrationDestinationManager

1 files changed, 29 insertions, 1 deletions

diff --git a/src/mongo/db/s/start_chunk_clone_request.cpp b/src/mongo/db/s/start_chunk_clone_request.cpp
index ad350452346..30d2813a428 100644
--- a/src/mongo/db/s/start_chunk_clone_request.cpp
+++ b/src/mongo/db/s/start_chunk_clone_request.cpp
@@ -77,7 +77,8 @@ StatusWith<StartChunkCloneRequest> StartChunkCloneRequest::createFromCommand(Nam
     // TODO (SERVER-44787): Remove this FCV check after 4.4 is released.
     if (serverGlobalParams.featureCompatibility.getVersion() ==
         ServerGlobalParams::FeatureCompatibility::Version::kFullyUpgradedTo44) {
-        request._migrationId = UUID::parse(obj);
+        if (obj.getField("uuid"))
+            request._migrationId = UUID::parse(obj);
     }
 
     {
@@ -187,4 +188,31 @@ void StartChunkCloneRequest::appendAsCommand(
     secondaryThrottle.append(builder);
 }
 
+// TODO (SERVER-44787): Remove this overload after 4.4 is released.
+void StartChunkCloneRequest::appendAsCommand(
+    BSONObjBuilder* builder,
+    const NamespaceString& nss,
+    const MigrationSessionId& sessionId,
+    const ConnectionString& fromShardConnectionString,
+    const ShardId& fromShardId,
+    const ShardId& toShardId,
+    const BSONObj& chunkMinKey,
+    const BSONObj& chunkMaxKey,
+    const BSONObj& shardKeyPattern,
+    const MigrationSecondaryThrottleOptions& secondaryThrottle) {
+    invariant(builder->asTempObj().isEmpty());
+    invariant(nss.isValid());
+    invariant(fromShardConnectionString.isValid());
+
+    builder->append(kRecvChunkStart, nss.ns());
+    sessionId.append(builder);
+    builder->append(kFromShardConnectionString, fromShardConnectionString.toString());
+    builder->append(kFromShardId, fromShardId.toString());
+    builder->append(kToShardId, toShardId.toString());
+    builder->append(kChunkMinKey, chunkMinKey);
+    builder->append(kChunkMaxKey, chunkMaxKey);
+    builder->append(kShardKeyPattern, shardKeyPattern);
+    secondaryThrottle.append(builder);
+}
+
 }  // namespace mongo