SERVER-40209 Implement $$NOW and $$CLUSTER_TIME

1 files changed, 9 insertions, 0 deletions

diff --git a/src/mongo/db/pipeline/aggregation_request.cpp b/src/mongo/db/pipeline/aggregation_request.cpp
index ce2dc95da88..2357693d4f0 100644
--- a/src/mongo/db/pipeline/aggregation_request.cpp
+++ b/src/mongo/db/pipeline/aggregation_request.cpp
@@ -239,6 +239,13 @@ StatusWith<AggregationRequest> AggregationRequest::parseFromBSON(
             WriteConcernOptions writeConcern;
             uassertStatusOK(writeConcern.parse(elem.embeddedObject()));
             request.setWriteConcern(writeConcern);
+        } else if (kRuntimeConstants == fieldName) {
+            try {
+                IDLParserErrorContext ctx("internalRuntimeConstants");
+                request.setRuntimeConstants(RuntimeConstants::parse(ctx, elem.Obj()));
+            } catch (const DBException& ex) {
+                return ex.toStatus();
+            }
         } else if (!isGenericArgument(fieldName)) {
             return {ErrorCodes::FailedToParse,
                     str::stream() << "unrecognized field '" << elem.fieldName() << "'"};
@@ -342,6 +349,8 @@ Document AggregationRequest::serializeToCommandObj() const {
         {kExchangeName, _exchangeSpec ? Value(_exchangeSpec->toBSON()) : Value()},
         {WriteConcernOptions::kWriteConcernField,
          _writeConcern ? Value(_writeConcern->toBSON()) : Value()},
+        // Only serialize runtime constants if any were specified.
+        {kRuntimeConstants, _runtimeConstants ? Value(_runtimeConstants->toBSON()) : Value()},
     };
 }
 }  // namespace mongo