PoC: Add MQL translation skeleton

src/realm/CMakeLists.txt

@@ -101,6 +101,8 @@ set(UTIL_SOURCES
     util/random.cpp
     util/resource_limits.cpp
     util/uri.cpp
+    util/bson/bson.cpp
+    util/bson/regular_expression.cpp
 )
 
 set(REALM_INSTALL_HEADERS
@@ -272,6 +274,12 @@ set(REALM_NOINST_HEADERS
     util/timestamp_formatter.hpp
     util/timestamp_logger.hpp
     util/value_reset_guard.hpp
+    util/bson/bson.hpp
+    util/bson/min_key.hpp
+    util/bson/max_key.hpp
+    util/bson/regular_expression.hpp
+    util/bson/indexed_map.hpp
+    util/bson/mongo_timestamp.hpp
 ) # REALM_NOINST_HEADERS
 
 if(NOT MSVC)

src/realm/object-store/CMakeLists.txt

@@ -110,14 +110,7 @@ if(REALM_ENABLE_SYNC)
         sync/impl/sync_client.hpp
         sync/impl/sync_file.hpp
         sync/impl/sync_metadata.hpp
-        sync/impl/network_reachability.hpp
-
-        util/bson/bson.hpp
-        util/bson/min_key.hpp
-        util/bson/max_key.hpp
-        util/bson/regular_expression.hpp
-        util/bson/indexed_map.hpp
-        util/bson/mongo_timestamp.hpp)
+        sync/impl/network_reachability.hpp)
 
     list(APPEND SOURCES
         sync/app.cpp
@@ -133,9 +126,7 @@ if(REALM_ENABLE_SYNC)
         sync/mongo_database.cpp
         sync/push_client.cpp
         sync/impl/sync_file.cpp
-        sync/impl/sync_metadata.cpp
-        util/bson/bson.cpp
-        util/bson/regular_expression.cpp)
+        sync/impl/sync_metadata.cpp)
     if(APPLE)
         list(APPEND HEADERS
             sync/impl/apple/network_reachability_observer.hpp

src/realm/object-store/results.cpp

@@ -26,7 +26,7 @@
 #include <realm/object-store/schema.hpp>
 #include <realm/object-store/class.hpp>
 #include <realm/object-store/sectioned_results.hpp>
-
+#include <realm/util/bson/bson.hpp>
 #include <realm/set.hpp>
 
 #include <stdexcept>
@@ -56,6 +56,16 @@ Results::Results(SharedRealm r, Query q, DescriptorOrdering o)
 {
 }
 
+Results::Results(SharedRealm r, ConstTableRef table, const bson::BsonDocument& document)
+    : Results(r, table->query(document))
+{
+}
+
+Results::Results(SharedRealm r, ConstTableRef table, const std::string& document)
+    : Results(r, table->query(static_cast<bson::BsonDocument>(bson::parse(document))))
+{
+}
+
 Results::Results(const Class& cls)
     : Results(cls.get_realm(), cls.get_table())
 {

src/realm/object-store/results.hpp

@@ -51,6 +51,8 @@ class Results {
     Results();
     Results(const Class&);
     Results(std::shared_ptr<Realm> r, ConstTableRef table);
+    Results(std::shared_ptr<Realm> r, ConstTableRef, const bson::BsonDocument& document);
+    Results(std::shared_ptr<Realm> r, ConstTableRef, const std::string& document);
     Results(std::shared_ptr<Realm> r, Query q, DescriptorOrdering o = {});
     Results(std::shared_ptr<Realm> r, TableView tv, DescriptorOrdering o = {});
     Results(std::shared_ptr<Realm> r, const Obj& obj, TableKey src_table, ColKey src_col_key)
@@ -152,6 +154,9 @@ class Results {
 
     // Create a new Results by further filtering or sorting this Results
     Results filter(Query&& q) const REQUIRES(!m_mutex);
+    Results find(const bson::BsonDocument& document) const REQUIRES(!m_mutex);
+    Results find(const std::string& document) const REQUIRES(!m_mutex);
+
     // Create a new Results by sorting this Result.
     Results sort(SortDescriptor&& sort) const REQUIRES(!m_mutex);
     // Create a new Results by sorting this Result based on the specified key paths.

src/realm/object-store/sync/app_credentials.cpp

@@ -17,7 +17,7 @@
 ////////////////////////////////////////////////////////////////////////////
 
 #include <realm/object-store/sync/app_credentials.hpp>
-#include <realm/object-store/util/bson/bson.hpp>
+#include <realm/util/bson/bson.hpp>
 
 namespace realm::app {
 

src/realm/object-store/sync/app_service_client.hpp

@@ -19,7 +19,7 @@
 #ifndef APP_SERVICE_CLIENT_HPP
 #define APP_SERVICE_CLIENT_HPP
 
-#include <realm/object-store/util/bson/bson.hpp>
+#include <realm/util/bson/bson.hpp>
 #include <realm/util/functional.hpp>
 #include <realm/util/optional.hpp>
 

src/realm/object-store/sync/mongo_collection.hpp

@@ -19,7 +19,7 @@
 #ifndef MONGO_COLLECTION_HPP
 #define MONGO_COLLECTION_HPP
 
-#include <realm/object-store/util/bson/bson.hpp>
+#include <realm/util/bson/bson.hpp>
 #include <realm/util/functional.hpp>
 #include <realm/util/optional.hpp>
 

src/realm/object-store/sync/push_client.cpp

@@ -21,7 +21,7 @@
 #include <realm/object-store/sync/app_utils.hpp>
 #include <realm/object-store/sync/auth_request_client.hpp>
 #include <realm/object-store/sync/generic_network_transport.hpp>
-#include <realm/object-store/util/bson/bson.hpp>
+#include <realm/util/bson/bson.hpp>
 
 namespace realm::app {
 

src/realm/object-store/sync/sync_user.hpp

@@ -20,7 +20,7 @@
 #define REALM_OS_SYNC_USER_HPP
 
 #include <realm/object-store/util/atomic_shared_ptr.hpp>
-#include <realm/object-store/util/bson/bson.hpp>
+#include <realm/util/bson/bson.hpp>
 #include <realm/object-store/sync/subscribable.hpp>
 
 #include <realm/util/checked_mutex.hpp>

src/realm/parser/CMakeLists.txt

@@ -31,7 +31,8 @@ if(NOT REALM_CORE_SUBMODULE_BUILD)
 endif()
 
 set(REALM_PARSER_SOURCES
-    driver.cpp
+    query_ast.cpp
+    query_bson.cpp
     keypath_mapping.cpp
 ) # REALM_PARSER_SOURCES
 
@@ -41,7 +42,7 @@ set(REALM_PARSER_GENERATED
 ) # REALM_PARSER_SOURCES
 
 set(REALM_PARSER_HEADERS
-    driver.hpp
+    query_ast.hpp
     keypath_mapping.hpp
     query_parser.hpp
     generated/query_bison.hpp