From c3459e34d46ca752e1f2994035c2c0359f02697e Mon Sep 17 00:00:00 2001 From: Jicheng Lu <103353@smsassist.com> Date: Wed, 19 Feb 2025 11:16:51 -0600 Subject: [PATCH] minor change --- .../BotSharp.Plugin.MongoStorage/MongoDbContext.cs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/Plugins/BotSharp.Plugin.MongoStorage/MongoDbContext.cs b/src/Plugins/BotSharp.Plugin.MongoStorage/MongoDbContext.cs index 91e668f3..4d7f76a4 100644 --- a/src/Plugins/BotSharp.Plugin.MongoStorage/MongoDbContext.cs +++ b/src/Plugins/BotSharp.Plugin.MongoStorage/MongoDbContext.cs @@ -48,10 +48,11 @@ public class MongoDbContext private IMongoDatabase Database => _mongoClient.GetDatabase(_mongoDbDatabaseName); + #region Private methods private bool CollectionExists(IMongoDatabase database, string collectionName) { var filter = Builders.Filter.Eq("name", collectionName); - var collections = database.ListCollections(new ListCollectionsOptions { Filter = filter }); + var collections = database.ListCollectionNames(new ListCollectionNamesOptions { Filter = filter }).ToList(); return collections.Any(); } @@ -60,9 +61,11 @@ public class MongoDbContext if (string.IsNullOrWhiteSpace(name)) throw new ArgumentException($"The collection {name} cannot be empty."); - string collectionName = $"{_collectionPrefix}_{name}"; + var collectionName = $"{_collectionPrefix}_{name}"; if (!CollectionExists(Database, collectionName)) + { Database.CreateCollection(collectionName); + } var collection = Database.GetCollection(collectionName); return collection; @@ -134,6 +137,7 @@ public class MongoDbContext return collection; } #endregion + #endregion public IMongoCollection Agents => GetCollectionOrCreate("Agents");