zleao

public enum DbLocation
{
    Unknown,
    Local,
    Azure
}
    
public interface IMongoDbConfiguration
{
    string DatabaseName { get; }

zleao

 public IMongoDatabase GetDatabaseInstance()
{
    var settings = MongoClientSettings.FromUrl(new MongoUrl(Configuration.ConnectionString));
    
    settings.SslSettings = new SslSettings() { EnabledSslProtocols = SslProtocols.Tls12 };

    var client = new MongoClient(settings);

    return client.GetDatabase(Configuration.DatabaseName);
}

zleao

public async Task EnsureDatabaseIsCreatedAsync()
{
    using (var client = GetDocumentClient())
    {
        //set the throughput for the database
        var options = new RequestOptions { OfferThroughput = Configuration.AzureDatabaseInitialThroughput };

        //create the database without overriding any existing one
        await client.CreateDatabaseIfNotExistsAsync(new Microsoft.Azure.Documents.Database { Id = Configuration.DatabaseName }, options);
    }

zleao

var partitionKey = "_id";
var partition = new BsonDocument {
    {"shardCollection", $"{Database.DatabaseNamespace.DatabaseName}.{collectionName}"},
    {"key", new BsonDocument {{partitionKey, "hashed"}}}
};
var command = new BsonDocumentCommand<BsonDocument>(partition);
await Database.RunCommandAsync(command);

zleao

...
//Get CollectionCount
...
var offer = documentClient.CreateOfferQuery().Where(r => r.ResourceLink == database.SelfLink).ToList().FirstOrDefault();
if(offer != null)
{
    offer = new OfferV2(offer, Math.Max(400, (collectionCount * 100)));
    await documentClient.ReplaceOfferAsync(offer);
}

zleao

var localEnv = new MongoDbConfiguration(
        databaseName: "LocalDatabaseName",
        databaseLocation: DbLocation.Local,
        connectionString: "mongodb://localhost:27017");
        
var cloudEnv = new MongoDbConfiguration(
        databaseName: "CloudDatabaseName",
        databaseLocation: DbLocation.Azure,
        connectionString: "mongodb://{AzureCosmosAccount}:{AzureCosmosAccountPrimaryKey}==@{AzureCosmosAccount}.documents.azure.com:10255/?ssl=true&replicaSet=globaldb"
        azureDatabaseInitialThroughput: 2000,

zleao

try { /*TryCreateShardedCollection*/ }
catch
{
  await Database.CreateCollectionAsync(collectionName);
}

zleao

var database = client.CreateDatabaseQuery().Where(db => db.Id == Configuration.DatabaseName).ToList().FirstOrDefault();
var feedResult = await client.ReadDocumentCollectionFeedAsync(UriFactory.CreateDatabaseUri(database.Id));
var collectionCount = feedResult.Count;

zleao

// OneWay Subscription Examples

// Subscribe OneWay message with default context, using a weak reference
var token = NotificationService.Subscribe<MyMessage>(HandleOneWaySubscriptionAsync);
var token = NotificationService.Subscribe(typeof(MyMessage), HandleOneWaySubscriptionAsync);

// Subscribe OneWay message with specified context, using a weak reference
var token = NotificationService.Subscribe<MyMessage>(HandleOneWaySubscriptionAsync, "myContext");
var token = NotificationService.Subscribe(typeof(MyMessage), HandleOneWaySubscriptionAsync, "myContext");

zleao

// Unsubscribe message with specified token
NotificationService.Unsubscribe(token);

// Unsubscribe all messages from a particular message type
NotificationService.Unsubscribe<MyMessage>();
NotificationService.Unsubscribe(typeof(MyMessage));