SERVER-45590 Allow building a LiteParsedPipeline without first building an AggregationRequest

1 files changed, 12 insertions, 7 deletions

diff --git a/src/mongo/db/pipeline/document_source_graph_lookup.h b/src/mongo/db/pipeline/document_source_graph_lookup.h
index 77512232c36..85afcb9cf69 100644
--- a/src/mongo/db/pipeline/document_source_graph_lookup.h
+++ b/src/mongo/db/pipeline/document_source_graph_lookup.h
@@ -41,18 +41,23 @@ class DocumentSourceGraphLookUp final : public DocumentSource {
 public:
     static constexpr StringData kStageName = "$graphLookup"_sd;
 
-    class LiteParsed : public LiteParsedDocumentSourceForeignCollections {
+    class LiteParsed : public LiteParsedDocumentSourceForeignCollection {
     public:
-        LiteParsed(NamespaceString foreignNss, PrivilegeVector privileges)
-            : LiteParsedDocumentSourceForeignCollections(std::move(foreignNss),
-                                                         std::move(privileges)) {}
+        LiteParsed(NamespaceString foreignNss)
+            : LiteParsedDocumentSourceForeignCollection(std::move(foreignNss)) {}
+
+        static std::unique_ptr<LiteParsed> parse(const NamespaceString& nss,
+                                                 const BSONElement& spec);
+
 
         bool allowShardedForeignCollection(NamespaceString nss) const override {
-            return (_foreignNssSet.find(nss) == _foreignNssSet.end());
+            return _foreignNss != nss;
+        }
+
+        PrivilegeVector requiredPrivileges(bool isMongos, bool bypassDocumentValidation) const {
+            return {Privilege(ResourcePattern::forExactNamespace(_foreignNss), ActionType::find)};
         }
     };
-    static std::unique_ptr<LiteParsed> liteParse(const AggregationRequest& request,
-                                                 const BSONElement& spec);
 
     const char* getSourceName() const final;