SERVER-53483 Map predicates on time and regular fields to predicates on control's min/max

1 files changed, 10 insertions, 8 deletions

diff --git a/src/mongo/s/query/cluster_aggregate.cpp b/src/mongo/s/query/cluster_aggregate.cpp
index 7bd56463058..067a31ab52d 100644
--- a/src/mongo/s/query/cluster_aggregate.cpp
+++ b/src/mongo/s/query/cluster_aggregate.cpp
@@ -189,15 +189,16 @@ void updateHostsTargetedMetrics(OperationContext* opCtx,
 }
 
 /**
- * Performs validations related to API versioning before running the aggregation command.
- * Throws uassert if any of the validations fails
- *     - validation on each stage on the pipeline
- *     - validation on 'AggregateCommand' request
+ * Performs validations related to API versioning and time-series stages.
+ * Throws UserAssertion if any of the validations fails
+ *     - validation of API versioning on each stage on the pipeline
+ *     - validation of API versioning on 'AggregateCommand' request
+ *     - validation of time-series related stages
  */
-void performAPIVersionChecks(const OperationContext* opCtx,
+void performValidationChecks(const OperationContext* opCtx,
                              const AggregateCommand& request,
                              const LiteParsedPipeline& liteParsedPipeline) {
-    liteParsedPipeline.validatePipelineStagesforAPIVersion(opCtx);
+    liteParsedPipeline.validate(opCtx);
     aggregation_request_helper::validateRequestForAPIVersion(opCtx, request);
 }
 
@@ -217,8 +218,9 @@ Status ClusterAggregate::runAggregate(OperationContext* opCtx,
                                       const LiteParsedPipeline& liteParsedPipeline,
                                       const PrivilegeVector& privileges,
                                       BSONObjBuilder* result) {
-    // Perform API versioning validation checks.
-    performAPIVersionChecks(opCtx, request, liteParsedPipeline);
+    // Perform some validations on the LiteParsedPipeline and request before continuing with the
+    // aggregation command.
+    performValidationChecks(opCtx, request, liteParsedPipeline);
 
     uassert(51028, "Cannot specify exchange option to a mongos", !request.getExchange());
     uassert(51143,