SERVER-70658 Prepare pre-image purging job to operate in serverless and non-serverless modes

1 files changed, 14 insertions, 0 deletions

diff --git a/src/mongo/db/change_stream_serverless_helpers.cpp b/src/mongo/db/change_stream_serverless_helpers.cpp
index aa1b12181df..2fcab33e474 100644
--- a/src/mongo/db/change_stream_serverless_helpers.cpp
+++ b/src/mongo/db/change_stream_serverless_helpers.cpp
@@ -32,6 +32,7 @@
 #include "mongo/db/change_stream_serverless_helpers.h"
 
 #include "mongo/db/catalog_raii.h"
+#include "mongo/db/change_streams_cluster_parameter_gen.h"
 #include "mongo/db/dbdirectclient.h"
 #include "mongo/db/global_settings.h"
 #include "mongo/db/multitenancy_gen.h"
@@ -109,5 +110,18 @@ TenantSet getConfigDbTenants(OperationContext* opCtx) {
     return tenantIds;
 }
 
+
+int64_t getExpireAfterSeconds(const TenantId& tenantId) {
+    auto* clusterParameters = ServerParameterSet::getClusterParameterSet();
+    auto* changeStreamsParam =
+        clusterParameters->get<ClusterParameterWithStorage<ChangeStreamsClusterParameterStorage>>(
+            "changeStreams");
+
+    // TODO SERVER-69511 Pass 'tenantId' instead of 'boost::none'.
+    auto expireAfterSeconds = changeStreamsParam->getValue(boost::none).getExpireAfterSeconds();
+    invariant(expireAfterSeconds > 0);
+    return expireAfterSeconds;
+}
+
 }  // namespace change_stream_serverless_helpers
 }  // namespace mongo