/** * Copyright (C) 2021-present MongoDB, Inc. * * This program is free software: you can redistribute it and/or modify * it under the terms of the Server Side Public License, version 1, * as published by MongoDB, Inc. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * Server Side Public License for more details. * * You should have received a copy of the Server Side Public License * along with this program. If not, see * . * * As a special exception, the copyright holders give permission to link the * code of portions of this program with the OpenSSL library under certain * conditions as described in each individual source file and distribute * linked combinations including the program with the OpenSSL library. You * must comply with the Server Side Public License in all respects for * all of the code used other than as permitted herein. If you modify file(s) * with this exception, you may extend this exception to your version of the * file(s), but you are not obligated to do so. If you do not wish to do so, * delete this exception statement from your version. If you delete this * exception statement from all source files in the program, then also delete * it in the license file. */ #pragma once #include "mongo/db/geo/geometry_container.h" #include "mongo/db/geo/geoparser.h" #include "mongo/db/matcher/expression.h" namespace mongo { /** * An internal $geoWithin Match expression that has the same semantics as $geoWithin but is only * used against timeseries collections. * * For example, consider the match expression * * {$_internalBucketGeoWithin: { * withinRegion: { * $geometry: { * type : "Polygon" , * coordinates: [ [ [ 0, 0 ], [ 3, 6 ], [ 6, 1 ], [ 0, 0 ] ] ] * } * }, * field: "location" * }} * * The document to match should be a bucket document in an underlying system.buckets.collection * collection. Note that the 'field' value, "location", does not reflect the path in the matching * document but the path in the document in the corresponding timeseries collection, because the * document schma between the timeseries collection and the underlying bucket collection is * different. * */ class InternalBucketGeoWithinMatchExpression final : public MatchExpression { public: static constexpr StringData kName = "$_internalBucketGeoWithin"_sd; static constexpr StringData kWithinRegion = "withinRegion"_sd; static constexpr StringData kField = "field"_sd; InternalBucketGeoWithinMatchExpression(std::shared_ptr container, std::string field, clonable_ptr annotation = nullptr) : MatchExpression(MatchExpression::INTERNAL_BUCKET_GEO_WITHIN, std::move(annotation)), _geoContainer(container), _indexField("data." + field), _field(std::move(field)) {} void debugString(StringBuilder& debug, int indentationLevel) const final; bool equivalent(const MatchExpression* expr) const final; MatchCategory getCategory() const final { return MatchCategory::kLeaf; } /** * The input matches if the bucket document, 'doc', may contain any geo field that is within * 'withinRegion'. * - If false, the bucket must not contain any point that is within 'withinRegion'. * - If true, the bucket may or may not contain points that are within the region. The bucket * will go through the subsequent "unpack" stage so as to check each point in the bucket in an * equivalent $geoWithin operator individually. Always returns true for any bucket containing * objects not of type Point. */ bool matches(const MatchableDocument* doc, MatchDetails* details) const final; bool matchesSingleElement(const BSONElement& element, MatchDetails* details) const final { return false; } void serialize(BSONObjBuilder* builder, bool includePath) const final; std::unique_ptr shallowClone() const final; std::vector>* getChildVector() final { return nullptr; } size_t numChildren() const final { return 0; } MatchExpression* getChild(size_t i) const final { MONGO_UNREACHABLE; } void resetChild(size_t, MatchExpression*) { MONGO_UNREACHABLE; }; const std::string getField() const { return _field; } const std::shared_ptr getGeoContainer() const { return _geoContainer; } const StringData path() const final { return _indexField; } const FieldRef* fieldRef() const final { MONGO_UNREACHABLE_TASSERT(5837104); return nullptr; } void acceptVisitor(MatchExpressionMutableVisitor* visitor) final { visitor->visit(this); } void acceptVisitor(MatchExpressionConstVisitor* visitor) const final { visitor->visit(this); } private: ExpressionOptimizerFunc getOptimizer() const final { return [](std::unique_ptr expression) { return expression; }; } /** * Helper function for matches() and matchesSingleElement(). */ bool _matchesBSONObj(const BSONObj& obj) const; void _doAddDependencies(DepsTracker* deps) const final { deps->needWholeDocument = true; } std::shared_ptr _geoContainer; std::string _indexField; std::string _field; }; } // namespace mongo