Naming to CosmosClientFactory

Author: brucezlata

src/providers/WorkflowCore.Providers.Azure/Interface/ICosmosDbClient.cs renamed to src/providers/WorkflowCore.Providers.Azure/Interface/ICosmosClientFactory.cs

@@ -2,7 +2,7 @@
 
 namespace WorkflowCore.Providers.Azure.Interface
 {
-    public interface ICosmosDbClient
+    public interface ICosmosClientFactory
     {
         CosmosClient GetCosmosClient();
     }

src/providers/WorkflowCore.Providers.Azure/ServiceCollectionExtensions.cs

@@ -28,9 +28,9 @@ public static WorkflowOptions UseAzureServiceBusEventHub(
 
         public static WorkflowOptions UseCosmosDbPersistence(this WorkflowOptions options, string connectionString, string databaseId)
         {
-            options.Services.AddSingleton<ICosmosDbClient>(sp => new CosmosDbClient(connectionString));
-            options.Services.AddTransient<ICosmosDbProvisioner>(sp => new CosmosDbProvisioner(sp.GetService<ICosmosDbClient>(), sp.GetService<ILoggerFactory>()));
-            options.UsePersistence(sp => new CosmosDbPersistenceProvider(sp.GetService<ICosmosDbClient>(), databaseId, sp.GetService<ICosmosDbProvisioner>()));
+            options.Services.AddSingleton<ICosmosClientFactory>(sp => new CosmosClientFactory(connectionString));
+            options.Services.AddTransient<ICosmosDbProvisioner>(sp => new CosmosDbProvisioner(sp.GetService<ICosmosClientFactory>(), sp.GetService<ILoggerFactory>()));
+            options.UsePersistence(sp => new CosmosDbPersistenceProvider(sp.GetService<ICosmosClientFactory>(), databaseId, sp.GetService<ICosmosDbProvisioner>()));
             return options;
         }
     }

src/providers/WorkflowCore.Providers.Azure/Services/CosmosDbClient.cs renamed to src/providers/WorkflowCore.Providers.Azure/Services/CosmosClientFactory.cs

@@ -4,13 +4,13 @@
 
 namespace WorkflowCore.Providers.Azure.Services
 {
-    public class CosmosDbClient : ICosmosDbClient, IDisposable
+    public class CosmosClientFactory : ICosmosClientFactory, IDisposable
     {
         private bool isDisposed = false;
 
         private CosmosClient _client;
 
-        public CosmosDbClient(string connectionString)
+        public CosmosClientFactory(string connectionString)
         {
             _client = new CosmosClient(connectionString);
         }

src/providers/WorkflowCore.Providers.Azure/Services/CosmosDbPersistenceProvider.cs

@@ -19,19 +19,19 @@ public class CosmosDbPersistenceProvider : IPersistenceProvider
 
         private ICosmosDbProvisioner _provisioner;
         private string _dbId;
-        private ICosmosDbClient _client;
+        private ICosmosClientFactory _clientFactory;
         private Lazy<Container> _workflowContainer;
         private Lazy<Container> _eventContainer;
         private Lazy<Container> _subscriptionContainer;
 
-        public CosmosDbPersistenceProvider(ICosmosDbClient client, string dbId, ICosmosDbProvisioner provisioner)
+        public CosmosDbPersistenceProvider(ICosmosClientFactory clientFactory, string dbId, ICosmosDbProvisioner provisioner)
         {
             _provisioner = provisioner;
             _dbId = dbId;
-            _client = client;
-            _workflowContainer = new Lazy<Container>(() => _client.GetCosmosClient().GetDatabase(_dbId).GetContainer(WorkflowContainerName));
-            _eventContainer = new Lazy<Container>(() => _client.GetCosmosClient().GetDatabase(_dbId).GetContainer(EventContainerName));
-            _subscriptionContainer = new Lazy<Container>(() => _client.GetCosmosClient().GetDatabase(_dbId).GetContainer(SubscriptionContainerName));
+            _clientFactory = clientFactory;
+            _workflowContainer = new Lazy<Container>(() => _clientFactory.GetCosmosClient().GetDatabase(_dbId).GetContainer(WorkflowContainerName));
+            _eventContainer = new Lazy<Container>(() => _clientFactory.GetCosmosClient().GetDatabase(_dbId).GetContainer(EventContainerName));
+            _subscriptionContainer = new Lazy<Container>(() => _clientFactory.GetCosmosClient().GetDatabase(_dbId).GetContainer(SubscriptionContainerName));
         }
 
         public async Task ClearSubscriptionToken(string eventSubscriptionId, string token)

src/providers/WorkflowCore.Providers.Azure/Services/CosmosDbProvisioner.cs

@@ -9,9 +9,9 @@ namespace WorkflowCore.Providers.Azure.Services
     public class CosmosDbProvisioner : ICosmosDbProvisioner
     {
 
-        private ICosmosDbClient _client;
+        private ICosmosClientFactory _client;
 
-        public CosmosDbProvisioner(ICosmosDbClient client, ILoggerFactory loggerFactory)
+        public CosmosDbProvisioner(ICosmosClientFactory client, ILoggerFactory loggerFactory)
         {
             _client = client;
         }