/** * Copyright (C) 2018-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/catalog/collection.h" #include "mongo/db/catalog/index_catalog.h" #include "mongo/platform/atomic_word.h" #include "mongo/util/assert_util.h" namespace mongo { /** * This class comprises a mock Collection for use by CollectionCatalog unit tests. */ class CollectionMock : public Collection { public: explicit CollectionMock(const NamespaceString& nss) : CollectionMock(UUID::gen(), nss, std::unique_ptr()) {} CollectionMock(const UUID& uuid, const NamespaceString& nss) : CollectionMock(uuid, nss, std::unique_ptr()) {} CollectionMock(const UUID& uuid, const NamespaceString& nss, std::unique_ptr indexCatalog) : _uuid(uuid), _nss(nss), _indexCatalog(std::move(indexCatalog)) {} CollectionMock(const NamespaceString& nss, RecordId catalogId) : _nss(nss), _catalogId(std::move(catalogId)) {} ~CollectionMock() = default; std::shared_ptr clone() const { return std::make_shared(*this); } SharedCollectionDecorations* getSharedDecorations() const { return nullptr; } void init(OperationContext* opCtx) { MONGO_UNREACHABLE; } Status initFromExisting(OperationContext* opCtx, const std::shared_ptr& collection, const DurableCatalogEntry& catalogEntry, boost::optional readTimestamp) { MONGO_UNREACHABLE; } RecordId getCatalogId() const { return _catalogId; } void setCatalogId(RecordId catalogId) { _catalogId = std::move(catalogId); } const NamespaceString& ns() const { return _nss; } Status rename(OperationContext* opCtx, const NamespaceString& nss, bool stayTemp) final { _nss = std::move(nss); return Status::OK(); } const IndexCatalog* getIndexCatalog() const { return _indexCatalog.get(); } IndexCatalog* getIndexCatalog() { return _indexCatalog.get(); } RecordStore* getRecordStore() const { MONGO_UNREACHABLE; } std::shared_ptr getSharedIdent() const { return std::make_shared(_nss.toString()); } void setIdent(std::shared_ptr newIdent) { MONGO_UNREACHABLE; } BSONObj getValidatorDoc() const { MONGO_UNREACHABLE; } std::pair checkValidation(OperationContext* opCtx, const BSONObj& document) const { MONGO_UNREACHABLE; } virtual Status checkValidationAndParseResult(OperationContext* opCtx, const BSONObj& document) const { MONGO_UNREACHABLE; } bool requiresIdIndex() const { MONGO_UNREACHABLE; } Snapshotted docFor(OperationContext* opCtx, const RecordId& loc) const { MONGO_UNREACHABLE; } bool findDoc(OperationContext* opCtx, const RecordId& loc, Snapshotted* out) const { MONGO_UNREACHABLE; } std::unique_ptr getCursor(OperationContext* opCtx, bool forward) const { MONGO_UNREACHABLE; } bool updateWithDamagesSupported() const { MONGO_UNREACHABLE; } Status truncate(OperationContext* opCtx) { MONGO_UNREACHABLE; } void cappedTruncateAfter(OperationContext* opCtx, const RecordId& end, bool inclusive) const { MONGO_UNREACHABLE; } Validator parseValidator(OperationContext* opCtx, const BSONObj& validator, MatchExpressionParser::AllowedFeatureSet allowedFeatures, boost::optional maxFeatureCompatibilityVersion) const { MONGO_UNREACHABLE; } void setValidator(OperationContext* opCtx, Validator validator) { MONGO_UNREACHABLE; } Status setValidationLevel(OperationContext* opCtx, ValidationLevelEnum newLevel) { MONGO_UNREACHABLE; } Status setValidationAction(OperationContext* opCtx, ValidationActionEnum newAction) { MONGO_UNREACHABLE; } boost::optional getValidationLevel() const { MONGO_UNREACHABLE; } boost::optional getValidationAction() const { MONGO_UNREACHABLE; } Status updateValidator(OperationContext* opCtx, BSONObj newValidator, boost::optional newLevel, boost::optional newAction) { MONGO_UNREACHABLE; } Status checkValidatorAPIVersionCompatability(OperationContext* opCtx) const final { MONGO_UNREACHABLE; } bool isTemporary() const { MONGO_UNREACHABLE; } boost::optional getTimeseriesBucketsMayHaveMixedSchemaData() const { MONGO_UNREACHABLE; } void setTimeseriesBucketsMayHaveMixedSchemaData(OperationContext* opCtx, boost::optional setting) { MONGO_UNREACHABLE; } bool doesTimeseriesBucketsDocContainMixedSchemaData(const BSONObj& bucketsDoc) const { MONGO_UNREACHABLE; } bool getRequiresTimeseriesExtendedRangeSupport() const { MONGO_UNREACHABLE; } void setRequiresTimeseriesExtendedRangeSupport(OperationContext* opCtx) const { MONGO_UNREACHABLE; } bool isClustered() const { return false; } boost::optional getClusteredInfo() const { MONGO_UNREACHABLE; } void updateClusteredIndexTTLSetting(OperationContext* opCtx, boost::optional expireAfterSeconds) { MONGO_UNREACHABLE; } Status updateCappedSize(OperationContext* opCtx, boost::optional newCappedSize, boost::optional newCappedMax) { MONGO_UNREACHABLE; } bool isChangeStreamPreAndPostImagesEnabled() const { MONGO_UNREACHABLE; } void setChangeStreamPreAndPostImages(OperationContext* opCtx, ChangeStreamPreAndPostImagesOptions val) { MONGO_UNREACHABLE; } bool isCapped() const { return false; } long long getCappedMaxDocs() const { MONGO_UNREACHABLE; } long long getCappedMaxSize() const { MONGO_UNREACHABLE; } bool usesCappedSnapshots() const { return false; } std::vector reserveCappedRecordIds(OperationContext* opCtx, size_t nIds) const final { MONGO_UNREACHABLE; } void registerCappedInserts(OperationContext* opCtx, const RecordId& minRecord, const RecordId& maxRecord) const { std::abort(); } CappedVisibilityObserver* getCappedVisibilityObserver() const { std::abort(); } CappedVisibilitySnapshot takeCappedVisibilitySnapshot() const { std::abort(); } long long numRecords(OperationContext* opCtx) const { MONGO_UNREACHABLE; } long long dataSize(OperationContext* opCtx) const { MONGO_UNREACHABLE; } bool isEmpty(OperationContext* opCtx) const { MONGO_UNREACHABLE; } int averageObjectSize(OperationContext* const opCtx) const { MONGO_UNREACHABLE; } uint64_t getIndexSize(OperationContext* opCtx, BSONObjBuilder* details, int scale) const { MONGO_UNREACHABLE; } uint64_t getIndexFreeStorageBytes(OperationContext* const opCtx) const { MONGO_UNREACHABLE; } boost::optional getMinimumValidSnapshot() const { MONGO_UNREACHABLE; } void setMinimumValidSnapshot(Timestamp name) override { // no-op, called by unittests } boost::optional getTimeseriesOptions() const { MONGO_UNREACHABLE; } void setTimeseriesOptions(OperationContext* opCtx, const TimeseriesOptions& tsOptions) { MONGO_UNREACHABLE; } const CollatorInterface* getDefaultCollator() const { MONGO_UNREACHABLE; } const CollectionOptions& getCollectionOptions() const { MONGO_UNREACHABLE; } StatusWith> addCollationDefaultsToIndexSpecsForCreate( OperationContext* opCtx, const std::vector& indexSpecs) const { MONGO_UNREACHABLE; } std::unique_ptr makePlanExecutor( OperationContext* opCtx, const CollectionPtr& yieldableCollection, PlanYieldPolicy::YieldPolicy yieldPolicy, ScanDirection scanDirection, const boost::optional& resumeAfterRecordId) const { MONGO_UNREACHABLE; } void onDeregisterFromCatalog(OperationContext* opCtx) {} UUID uuid() const { return _uuid; } bool isCommitted() const final { return _committed; } void setCommitted(bool val) final { _committed = val; } void indexBuildSuccess(OperationContext* opCtx, IndexCatalogEntry* index) { MONGO_UNREACHABLE; } StatusWith checkMetaDataForIndex(const std::string& indexName, const BSONObj& spec) const { MONGO_UNREACHABLE; } void updateTTLSetting(OperationContext* opCtx, StringData idxName, long long newExpireSeconds) { MONGO_UNREACHABLE; } void updateHiddenSetting(OperationContext* opCtx, StringData idxName, bool hidden) { MONGO_UNREACHABLE; } void updateUniqueSetting(OperationContext* opCtx, StringData idxName, bool unique) { MONGO_UNREACHABLE; } void updatePrepareUniqueSetting(OperationContext* opCtx, StringData idxName, bool prepareUnique) { MONGO_UNREACHABLE; } std::vector repairInvalidIndexOptions(OperationContext* opCtx) { MONGO_UNREACHABLE; } void setIsTemp(OperationContext* opCtx, bool isTemp) { MONGO_UNREACHABLE; } void removeIndex(OperationContext* opCtx, StringData indexName) { MONGO_UNREACHABLE; } Status prepareForIndexBuild(OperationContext* opCtx, const IndexDescriptor* spec, boost::optional buildUUID, bool isBackgroundSecondaryBuild) { MONGO_UNREACHABLE; } boost::optional getIndexBuildUUID(StringData indexName) const { MONGO_UNREACHABLE; } bool isIndexMultikey(OperationContext* opCtx, StringData indexName, MultikeyPaths* multikeyPaths, int indexOffset) const { MONGO_UNREACHABLE; } bool setIndexIsMultikey(OperationContext* opCtx, StringData indexName, const MultikeyPaths& multikeyPaths, int indexOffset) const { MONGO_UNREACHABLE; } void forceSetIndexIsMultikey(OperationContext* opCtx, const IndexDescriptor* desc, bool isMultikey, const MultikeyPaths& multikeyPaths) const final { MONGO_UNREACHABLE; } int getTotalIndexCount() const { MONGO_UNREACHABLE; } int getCompletedIndexCount() const { MONGO_UNREACHABLE; } BSONObj getIndexSpec(StringData indexName) const { MONGO_UNREACHABLE; } void getAllIndexes(std::vector* names) const { MONGO_UNREACHABLE; } void getReadyIndexes(std::vector* names) const { MONGO_UNREACHABLE; } bool isIndexPresent(StringData indexName) const { MONGO_UNREACHABLE; } bool isIndexReady(StringData indexName) const { MONGO_UNREACHABLE; } void replaceMetadata(OperationContext* opCtx, std::shared_ptr md) { MONGO_UNREACHABLE; } bool isMetadataEqual(const BSONObj& otherMetadata) const { MONGO_UNREACHABLE; } bool needsCappedLock() const { MONGO_UNREACHABLE; } bool isCappedAndNeedsDelete(OperationContext* opCtx) const { MONGO_UNREACHABLE; } private: UUID _uuid = UUID::gen(); NamespaceString _nss; RecordId _catalogId{0}; clonable_ptr _indexCatalog; bool _committed = true; }; } // namespace mongo