Feature.cs

/* Copyright 2010-present MongoDB Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

using System;
using System.Threading;
using System.Threading.Tasks;
using MongoDB.Driver.Core.Bindings;

namespace MongoDB.Driver.Core.Misc
{
    /// <summary>
    /// Represents a feature that is not supported by all versions of the server.
    /// </summary>
    public class Feature
    {
        #region static
        private static readonly Feature __aggregateAccumulator = new Feature("AggregateAccumulator", WireVersion.Server44);
        private static readonly Feature __aggregateFunction = new Feature("AggregateFunction", WireVersion.Server44);
        private static readonly Feature __aggregateOptionsLet = new Feature("AggregateOptionsLet", WireVersion.Server50);
        private static readonly Feature __aggregateMerge = new Feature("AggregateMerge", WireVersion.Server42);
        private static readonly Feature __aggregateOutOnSecondary = new Feature("AggregateOutOnSecondary", WireVersion.Server50);
        private static readonly Feature __aggregateOutTimeSeries = new Feature("AggregateOutTimeSeries", WireVersion.Server70);
        private static readonly Feature __aggregateOutToDifferentDatabase = new Feature("AggregateOutToDifferentDatabase", WireVersion.Server44);
        private static readonly Feature __aggregateToString = new Feature("AggregateToString", WireVersion.Server40);
        private static readonly Feature __aggregateUnionWith = new Feature("AggregateUnionWith", WireVersion.Server44);
        private static readonly Feature __bitwiseOperators = new Feature("BitwiseOperators", WireVersion.Server63);
        private static readonly Feature __changeStreamAllChangesForCluster = new Feature("ChangeStreamAllChangesForCluster", WireVersion.Server40);
        private static readonly Feature __changeStreamForDatabase = new Feature("ChangeStreamForDatabase", WireVersion.Server40);
        private static readonly Feature __changeStreamPostBatchResumeToken = new Feature("ChangeStreamPostBatchResumeToken", WireVersion.Server40);
        private static readonly Feature __changeStreamPrePostImages = new Feature("ChangeStreamPrePostImages", WireVersion.Server60);
        private static readonly Feature __changeStreamSplitEventStage = new Feature("ChangeStreamSplitEventStage", WireVersion.Server70);
        private static readonly Feature __clientBulkWrite = new Feature("ClientBulkWrite", WireVersion.Server80);
        private static readonly Feature __clientSideEncryption = new Feature("ClientSideEncryption", WireVersion.Server42);
        private static readonly Feature __clusteredIndexes = new Feature("ClusteredIndexes", WireVersion.Server53);
        private static readonly Feature __convertOperatorBinDataToFromNumeric = new Feature("ConvertOperatorBinDataToFromNumeric", WireVersion.Server81);
        private static readonly Feature __convertOperatorBinDataToFromString= new Feature("ConvertOperatorBinDataToFromString", WireVersion.Server80);
        private static readonly Feature __createIndexCommitQuorum = new Feature("CreateIndexCommitQuorum", WireVersion.Server44);
        private static readonly Feature __createIndexesUsingInsertOperations = new Feature("CreateIndexesUsingInsertOperations", WireVersion.Zero, WireVersion.Server42);
        private static readonly Feature __csfleRangeAlgorithm = new Feature("CsfleRangeAlgorithm", WireVersion.Server62);
        private static readonly Feature __csfle2Qev2Lookup = new Feature("csfle2Qev2Lookup", WireVersion.Server81);
        private static readonly Feature __csfle2Qev2RangeAlgorithm = new Feature("csfle2Qev2RangeAlgorithm", WireVersion.Server80);
        private static readonly Feature __csfle2 = new Feature("Csfle2", WireVersion.Server60);
        private static readonly Feature __csfle2Qev2 = new Feature("Csfle2Qev2", WireVersion.Server70, notSupportedMessage: "Driver support of Queryable Encryption is incompatible with server. Upgrade server to use Queryable Encryption.");
        private static readonly Feature __dateFromStringFormatArgument = new Feature("DateFromStringFormatArgument", WireVersion.Server40);
        private static readonly Feature __dateOperatorsNewIn50 = new Feature("DateOperatorsNewIn50", WireVersion.Server50);
        private static readonly Feature __densifyStage = new Feature("DensifyStage", WireVersion.Server51);
        private static readonly Feature __documentsStage = new Feature("DocumentsStage", WireVersion.Server51);
        private static readonly Feature __directConnectionSetting = new Feature("DirectConnectionSetting", WireVersion.Server44);
        private static readonly Feature __electionIdPriorityInSDAM = new Feature("ElectionIdPriorityInSDAM ", WireVersion.Server60);
        private static readonly Feature __eval = new Feature("Eval", WireVersion.Zero, WireVersion.Server42);
        private static readonly Feature __failPointsBlockConnection = new Feature("FailPointsBlockConnection", WireVersion.Server42);
        private static readonly Feature __failPointsFailCommand = new Feature("FailPointsFailCommand", WireVersion.Server40);
        private static readonly Feature __failPointsFailCommandForSharded = new Feature("FailPointsFailCommandForSharded", WireVersion.Server42);
        private static readonly Feature __filterLimit = new Feature("FilterLimit", WireVersion.Server60);
        private static readonly Feature __findAllowDiskUse = new Feature("FindAllowDiskUse", WireVersion.Server44);
        private static readonly Feature __findProjectionExpressions = new Feature("FindProjectionExpressions", WireVersion.Server44);
        private static readonly Feature __geoNearCommand = new Feature("GeoNearCommand", WireVersion.Zero, WireVersion.Server42);
        private static readonly Feature __getField = new Feature("GetField", WireVersion.Server50);
        private static readonly Feature __getMoreComment = new Feature("GetMoreComment", WireVersion.Server44);
        private static readonly Feature __groupCommand = new Feature("GroupCommand", WireVersion.Zero, WireVersion.Server42);
        private static readonly Feature __hedgedReads = new Feature("HedgedReads", WireVersion.Server44);
        private static readonly Feature __hiddenIndex = new Feature("HiddenIndex", WireVersion.Server44);
        private static readonly Feature __hintForDeleteOperations = new Feature("HintForDeleteOperations", WireVersion.Server44);
        private static readonly HintForFindAndModifyFeature __hintForFindAndModifyFeature = new HintForFindAndModifyFeature("HintForFindAndModify", WireVersion.Server44);
        private static readonly Feature __hintForUpdateAndReplaceOperations = new Feature("HintForUpdateAndReplaceOperations", WireVersion.Server42);
        private static readonly Feature __keepConnectionPoolWhenNotPrimaryConnectionException = new Feature("KeepConnectionPoolWhenNotWritablePrimaryConnectionException", WireVersion.Server42);
        private static readonly Feature __keepConnectionPoolWhenReplSetStepDown = new Feature("KeepConnectionPoolWhenReplSetStepDown", WireVersion.Server42);
        private static readonly Feature __legacyWireProtocol = new Feature("LegacyWireProtocol", WireVersion.Zero, WireVersion.Server51);
        private static readonly Feature __listDatabasesAuthorizedDatabases = new Feature("ListDatabasesAuthorizedDatabases", WireVersion.Server40);
        private static readonly Feature __loadBalancedMode = new Feature("LoadBalancedMode", WireVersion.Server50);
        private static readonly Feature __loookupConciseSyntax = new Feature("LoookupConciseSyntax", WireVersion.Server50);
        private static readonly Feature __loookupDocuments= new Feature("LoookupDocuments", WireVersion.Server60);
        private static readonly Feature __mmapV1StorageEngine = new Feature("MmapV1StorageEngine", WireVersion.Zero, WireVersion.Server42);
        private static readonly Feature __pickAccumulatorsNewIn52 = new Feature("PickAccumulatorsNewIn52", WireVersion.Server52);
        private static readonly Feature __regexMatch = new Feature("RegexMatch", WireVersion.Server42);
        private static readonly Feature __round = new Feature("Round", WireVersion.Server42);
        private static readonly Feature __scramSha256Authentication = new Feature("ScramSha256Authentication", WireVersion.Server40);
        private static readonly Feature __serverReturnsResumableChangeStreamErrorLabel = new Feature("ServerReturnsResumableChangeStreamErrorLabel", WireVersion.Server44);
        private static readonly Feature __serverReturnsRetryableWriteErrorLabel = new Feature("ServerReturnsRetryableWriteErrorLabel", WireVersion.Server44);
        private static readonly Feature __setStage = new Feature("SetStage", WireVersion.Server42);
        private static readonly Feature __setWindowFields = new Feature("SetWindowFields", WireVersion.Server50);
        private static readonly Feature __setWindowFieldsLocf = new Feature("SetWindowFieldsLocf", WireVersion.Server52);
        private static readonly Feature __shardedTransactions = new Feature("ShardedTransactions", WireVersion.Server42);
        private static readonly Feature __snapshotReads = new Feature("SnapshotReads", WireVersion.Server50, notSupportedMessage: "Snapshot reads require MongoDB 5.0 or later");
        private static readonly Feature __sortArrayOperator = new Feature("SortArrayOperator", WireVersion.Server52);
        private static readonly Feature __speculativeAuthentication = new Feature("SpeculativeAuthentication", WireVersion.Server44);
        private static readonly Feature __stableApi = new Feature("StableAPI", WireVersion.Server50);
        private static readonly Feature __streamingHello = new Feature("StreamingHello", WireVersion.Server44);
        private static readonly Feature __toConversionOperators = new Feature("ToConversionOperators", WireVersion.Server40);
        private static readonly Feature __trigOperators = new Feature("TrigOperators", WireVersion.Server42);
        private static readonly Feature __trimOperator = new Feature("TrimOperator", WireVersion.Server40);
        private static readonly Feature __transactions = new Feature("Transactions", WireVersion.Server40);
        private static readonly Feature __updateWithAggregationPipeline = new Feature("UpdateWithAggregationPipeline", WireVersion.Server42);
        private static readonly Feature __wildcardIndexes = new Feature("WildcardIndexes", WireVersion.Server42);

        /// <summary>
        /// Gets the aggregate accumulator feature.
        /// </summary>
        public static Feature AggregateAccumulator => __aggregateAccumulator;

        /// <summary>
        /// Gets the aggregate $function stage feature.
        /// </summary>
        public static Feature AggregateFunction => __aggregateFunction;

        /// <summary>
        /// Gets the aggregate let feature.
        /// </summary>
        public static Feature AggregateOptionsLet => __aggregateOptionsLet;

        /// <summary>
        /// Gets the aggregate merge feature.
        /// </summary>
        public static Feature AggregateMerge => __aggregateMerge;

        /// <summary>
        /// Gets the aggregate out on secondary feature.
        /// </summary>
        public static Feature AggregateOutOnSecondary => __aggregateOutOnSecondary;

        /// <summary>
        /// Gets the aggregate out to time series feature.
        /// </summary>
        public static Feature AggregateOutTimeSeries => __aggregateOutTimeSeries;

        /// <summary>
        /// Gets the aggregate out to a different database feature.
        /// </summary>
        public static Feature AggregateOutToDifferentDatabase => __aggregateOutToDifferentDatabase;

        /// <summary>
        /// Gets the aggregate toString feature.
        /// </summary>
        public static Feature AggregateToString => __aggregateToString;

        /// <summary>
        /// Gets the aggregate unionWith feature.
        /// </summary>
        public static Feature AggregateUnionWith => __aggregateUnionWith;

        /// <summary>
        /// Gets the bitwise operators feature.
        /// </summary>
        public static Feature BitwiseOperators => __bitwiseOperators;

        /// <summary>
        /// Gets the change stream all changes for cluster feature.
        /// </summary>
        public static Feature ChangeStreamAllChangesForCluster => __changeStreamAllChangesForCluster;

        /// <summary>
        /// Gets the change stream for database feature.
        /// </summary>
        public static Feature ChangeStreamForDatabase => __changeStreamForDatabase;

        /// <summary>
        /// Gets the change stream post batch resume token feature.
        /// </summary>
        public static Feature ChangeStreamPostBatchResumeToken => __changeStreamPostBatchResumeToken;

        /// <summary>
        /// Gets the change stream pre post images feature.
        /// </summary>
        public static Feature ChangeStreamPrePostImages => __changeStreamPrePostImages;

        /// <summary>
        /// Gets the change stream splitEvent stage feature.
        /// </summary>
        public static Feature ChangeStreamSplitEventStage => __changeStreamSplitEventStage;

        /// <summary>
        /// Gets the client bulk write feature.
        /// </summary>
        public static Feature ClientBulkWrite => __clientBulkWrite;

        /// <summary>
        /// Gets the client side encryption feature.
        /// </summary>
        public static Feature ClientSideEncryption => __clientSideEncryption;

        /// <summary>
        /// Gets the clustered indexes feature.
        /// </summary>
        public static Feature ClusteredIndexes => __clusteredIndexes;

        /// <summary>
        /// Gets the conversion of binary data to/from numeric types feature.
        /// </summary>
        public static Feature ConvertOperatorBinDataToFromNumeric => __convertOperatorBinDataToFromNumeric;

        /// <summary>
        /// Gets the conversion of binary data to/from string feature.
        /// </summary>
        public static Feature ConvertOperatorBinDataToFromString => __convertOperatorBinDataToFromString;

        /// <summary>
        /// Gets the create index commit quorum feature.
        /// </summary>
        public static Feature CreateIndexCommitQuorum => __createIndexCommitQuorum;

        /// <summary>
        /// Gets the create indexes using insert operations feature.
        /// </summary>
        public static Feature CreateIndexesUsingInsertOperations => __createIndexesUsingInsertOperations;

        /// <summary>
        /// Gets the csfle range algorithm feature.
        /// </summary>
        public static Feature CsfleRangeAlgorithm => __csfleRangeAlgorithm;

        /// <summary>
        /// Gets the client side field level encryption 2 feature.
        /// </summary>
        public static Feature Csfle2 => __csfle2;

        /// <summary>
        /// Gets the client side field level encryption 2 queryable encryption v2 feature.
        /// </summary>
        public static Feature Csfle2QEv2 => __csfle2Qev2;

        /// <summary>
        /// Gets the csfle2 $lookup support feature.
        /// </summary>
        public static Feature Csfle2QEv2Lookup => __csfle2Qev2Lookup;

        /// <summary>
        /// Gets the csfle2 range algorithm feature.
        /// </summary>
        public static Feature Csfle2QEv2RangeAlgorithm => __csfle2Qev2RangeAlgorithm;

        /// <summary>
        /// Gets the $dateFromString format argument feature.
        /// </summary>
        public static Feature DateFromStringFormatArgument => __dateFromStringFormatArgument;

        /// <summary>
        /// Gets the date operators added in 5.0 feature.
        /// </summary>
        public static Feature DateOperatorsNewIn50 => __dateOperatorsNewIn50;

        /// <summary>
        /// Gets the aggregate $densify stage feature.
        /// </summary>
        public static Feature DensifyStage => __densifyStage;

        /// <summary>
        /// Gets the documents stage feature.
        /// </summary>
        public static Feature DocumentsStage => __documentsStage;

        /// <summary>
        /// Gets the directConnection setting feature.
        /// </summary>
        public static Feature DirectConnectionSetting => __directConnectionSetting;

        /// <summary>
        /// Gets the electionIdPriorityInSDAM feature.
        /// </summary>
        public static Feature ElectionIdPriorityInSDAM => __electionIdPriorityInSDAM;

        /// <summary>
        /// Gets the eval feature.
        /// </summary>
        public static Feature Eval => __eval;

        /// <summary>
        /// Gets the fail points block connection feature.
        /// </summary>
        public static Feature FailPointsBlockConnection => __failPointsBlockConnection;

        /// <summary>
        /// Gets the fail points fail command feature.
        /// </summary>
        public static Feature FailPointsFailCommand => __failPointsFailCommand;

        /// <summary>
        /// Gets the fail points fail command for sharded feature.
        /// </summary>
        public static Feature FailPointsFailCommandForSharded => __failPointsFailCommandForSharded;

        /// <summary>
        /// Gets filter limit feature.
        /// </summary>
        public static Feature FilterLimit => __filterLimit;

        /// <summary>
        /// Gets the find allowDiskUse feature.
        /// </summary>
        [Obsolete("This property will be removed in a later release.")]
        public static Feature FindAllowDiskUse => __findAllowDiskUse;

        /// <summary>
        /// Gets the find projection expressions feature.
        /// </summary>
        public static Feature FindProjectionExpressions => __findProjectionExpressions;

        /// <summary>
        /// Gets the geoNear command feature.
        /// </summary>
        public static Feature GeoNearCommand => __geoNearCommand;

        /// <summary>
        /// Gets the getField feature.
        /// </summary>
        public static Feature GetField => __getField;

        /// <summary>
        /// Gets the getMore comment feature.
        /// </summary>
        public static Feature GetMoreComment => __getMoreComment;

        /// <summary>
        /// Gets the group command feature.
        /// </summary>
        public static Feature GroupCommand => __groupCommand;

        /// <summary>
        /// Gets the hedged reads feature.
        /// </summary>
        public static Feature HedgedReads => __hedgedReads;

        /// <summary>
        /// Gets the hidden index feature.
        /// </summary>
        public static Feature HiddenIndex => __hiddenIndex;

        /// <summary>
        /// Gets the hint for delete operations feature.
        /// </summary>
        [Obsolete("This property will be removed in a later release.")]
        public static Feature HintForDeleteOperations => __hintForDeleteOperations;

        /// <summary>
        /// Gets the hint for find and modify operations feature.
        /// </summary>
        public static HintForFindAndModifyFeature HintForFindAndModifyFeature => __hintForFindAndModifyFeature;

        /// <summary>
        /// Gets the hint for update and replace operations feature.
        /// </summary>
        [Obsolete("This property will be removed in a later release.")]
        public static Feature HintForUpdateAndReplaceOperations => __hintForUpdateAndReplaceOperations;

        /// <summary>
        /// Gets the keep connection pool when NotPrimary connection exception feature.
        /// </summary>
        public static Feature KeepConnectionPoolWhenNotPrimaryConnectionException => __keepConnectionPoolWhenNotPrimaryConnectionException;

        /// <summary>
        /// Gets the keep connection pool when replSetStepDown feature.
        /// </summary>
        public static Feature KeepConnectionPoolWhenReplSetStepDown => __keepConnectionPoolWhenReplSetStepDown;

        /// <summary>
        /// Gets the legacy wire protocol feature.
        /// </summary>
        public static Feature LegacyWireProtocol => __legacyWireProtocol;

        /// <summary>
        /// Get the list databases authorizedDatabases feature.
        /// </summary>
        public static Feature ListDatabasesAuthorizedDatabases => __listDatabasesAuthorizedDatabases;

        /// <summary>
        /// Gets the load balanced mode feature.
        /// </summary>
        public static Feature LoadBalancedMode => __loadBalancedMode;

        /// <summary>
        /// Gets the lookup concise syntax feature.
        /// </summary>
        public static Feature LookupConciseSyntax => __loookupConciseSyntax;

        /// <summary>
        /// Gets the lookup documents feature.
        /// </summary>
        public static Feature LookupDocuments => __loookupDocuments;

        /// <summary>
        /// Gets the mmapv1 storage engine feature.
        /// </summary>
        public static Feature MmapV1StorageEngine => __mmapV1StorageEngine;

        /// <summary>
        /// Gets the pick accumulators new in 5.2 feature.
        /// </summary>
        public static Feature PickAccumulatorsNewIn52 => __pickAccumulatorsNewIn52;

        /// <summary>
        /// Gets the regex match feature.
        /// </summary>
        public static Feature RegexMatch => __regexMatch;

        /// <summary>
        /// Gets the $round feature.
        /// </summary>
        public static Feature Round => __round;

        /// <summary>
        /// Gets the scram sha256 authentication feature.
        /// </summary>
        public static Feature ScramSha256Authentication => __scramSha256Authentication;

        /// <summary>
        /// Gets the server returns resumableChangeStream label feature.
        /// </summary>
        public static Feature ServerReturnsResumableChangeStreamErrorLabel => __serverReturnsResumableChangeStreamErrorLabel;

        /// <summary>
        /// Gets the server returns retryable writeError label feature.
        /// </summary>
        public static Feature ServerReturnsRetryableWriteErrorLabel => __serverReturnsRetryableWriteErrorLabel;

        /// <summary>
        /// Gets the $set stage feature.
        /// </summary>
        public static Feature SetStage => __setStage;

        /// <summary>
        /// Gets the set window fields feature.
        /// </summary>
        public static Feature SetWindowFields => __setWindowFields;

        /// <summary>
        /// Gets the set window fields $locf feature.
        /// </summary>
        public static Feature SetWindowFieldsLocf => __setWindowFieldsLocf;

        /// <summary>
        /// Gets the sharded transactions feature.
        /// </summary>
        public static Feature ShardedTransactions => __shardedTransactions;

        /// <summary>
        /// Gets the snapshot reads feature.
        /// </summary>
        public static Feature SnapshotReads => __snapshotReads;

        /// <summary>
        /// Gets the $sortArray operator feature.
        /// </summary>
        public static Feature SortArrayOperator => __sortArrayOperator;

        /// <summary>
        /// Gets the speculative authentication feature.
        /// </summary>
        public static Feature SpeculativeAuthentication => __speculativeAuthentication;

        /// <summary>
        /// Gets the speculative authentication feature.
        /// </summary>
        public static Feature StableApi => __stableApi;

        /// <summary>
        /// Gets the streaming hello feature.
        /// </summary>
        public static Feature StreamingHello => __streamingHello;

        /// <summary>
        /// Gets the $toXyz conversion operators feature ($toDouble etc.).
        /// </summary>
        public static Feature ToConversionOperators => __toConversionOperators;

        /// <summary>
        /// Gets the transactions feature.
        /// </summary>
        public static Feature Transactions => __transactions;

        /// <summary>
        /// Gets the trig operators feature.
        /// </summary>
        public static Feature TrigOperators => __trigOperators;

        /// <summary>
        /// Gets the trim operator feature.
        /// </summary>
        public static Feature TrimOperator => __trimOperator;

        /// <summary>
        /// Gets the update with aggregation pipeline feature.
        /// </summary>
        public static Feature UpdateWithAggregationPipeline => __updateWithAggregationPipeline;

        /// <summary>
        /// Gets the wildcard indexes feature.
        /// </summary>
        public static Feature WildcardIndexes => __wildcardIndexes;

        #endregion

        private readonly string _name;
        private readonly int _firstSupportedWireVersion;
        private readonly int? _supportRemovedWireVersion;
        private readonly string _notSupportedMessage;

        /// <summary>
        /// Initializes a new instance of the <see cref="Feature" /> class.
        /// </summary>
        /// <param name="name">The name of the feature.</param>
        /// <param name="firstSupportedWireVersion">The first wire version that supports the feature.</param>
        /// <param name="supportRemovedWireVersion">The wire version that stops support the feature.</param>
        /// <param name="notSupportedMessage">The not supported error message.</param>
        public Feature(string name,
            int firstSupportedWireVersion,
            int? supportRemovedWireVersion = null,
            string notSupportedMessage = null)
        {
            _name = name;
            _firstSupportedWireVersion = Ensure.IsGreaterThanOrEqualToZero(firstSupportedWireVersion, nameof(firstSupportedWireVersion));
            _supportRemovedWireVersion = Ensure.IsNullOrGreaterThanOrEqualToZero(supportRemovedWireVersion, nameof(supportRemovedWireVersion));
            _notSupportedMessage = notSupportedMessage;
        }

        /// <summary>
        /// Gets the name of the feature.
        /// </summary>
        public string Name => _name;

        internal int FirstSupportedWireVersion => _firstSupportedWireVersion;

        internal int LastNotSupportedWireVersion
        {
            get
            {
                return _firstSupportedWireVersion > 0 ? _firstSupportedWireVersion - 1 : throw new InvalidOperationException("There is no wire version before 0.");
            }
        }

        /// <summary>
        /// Gets the error message to be used by the feature support checks.
        /// </summary>
        public string NotSupportedMessage => _notSupportedMessage;

        /// <summary>
        /// Throws an exception if the feature is not supported in the server used by the client.
        /// </summary>
        /// <param name="client">The client.</param>
        /// <param name="cancellationToken">The cancellation token.</param>
        public void ThrowIfNotSupported(IMongoClient client, CancellationToken cancellationToken = default)
        {
            var cluster = client.GetClusterInternal();
            using (var binding = new ReadWriteBindingHandle(new WritableServerBinding(cluster, NoCoreSession.NewHandle())))
            using (var channelSource = binding.GetWriteChannelSource(cancellationToken))
            using (var channel = channelSource.GetChannel(cancellationToken))
            {
                // Use WireVersion from a connection since server level value may be null
                ThrowIfNotSupported(channel.ConnectionDescription.MaxWireVersion);
            }
        }

        /// <summary>
        /// Throws an exception if the feature is not supported in the server used by the client.
        /// </summary>
        /// <param name="client">The client.</param>
        /// <param name="cancellationToken">The cancellation token.</param>
        public async Task ThrowIfNotSupportedAsync(IMongoClient client, CancellationToken cancellationToken = default)
        {
            var cluster = client.GetClusterInternal();
            using (var binding = new ReadWriteBindingHandle(new WritableServerBinding(cluster, NoCoreSession.NewHandle())))
            using (var channelSource = await binding.GetWriteChannelSourceAsync(cancellationToken).ConfigureAwait(false))
            using (var channel = await channelSource.GetChannelAsync(cancellationToken).ConfigureAwait(false))
            {
                // Use WireVersion from a connection since server level value may be null
                ThrowIfNotSupported(channel.ConnectionDescription.MaxWireVersion);
            }
        }

        internal bool IsSupported(int wireVersion)
        {
            return _supportRemovedWireVersion.HasValue
                ? _firstSupportedWireVersion <= wireVersion && _supportRemovedWireVersion > wireVersion
                : _firstSupportedWireVersion <= wireVersion;
        }

        internal void ThrowIfNotSupported(int wireVersion)
        {
            if (!IsSupported(wireVersion))
            {
                string errorMessage;
                if (_notSupportedMessage != null)
                {
                    errorMessage = _notSupportedMessage;
                }
                else
                {
                    errorMessage = $"Server version {WireVersion.GetServerVersionForErrorMessage(wireVersion)} does not support the {_name} feature.";
                }
                throw new NotSupportedException(errorMessage);
            }
        }

        /// <inheritdoc/>
        public override string ToString()
        {
            var message = $"{_name} feature added in {_firstSupportedWireVersion} wire protocol";
            if (_supportRemovedWireVersion != null)
            {
                message += $" and removed in {_supportRemovedWireVersion} wire protocol";
            }
            return $"{message}.";
        }
    }
}