add connection string overloads for di extensions

EventStore · Oct 27, 2020 · bab84a4 · bab84a4
1 parent 2730403
commit bab84a4
Show file tree

Hide file tree

Showing 5 changed files with 101 additions and 14 deletions.
diff --git a/src/EventStore.Client.Operations/EventStoreOperationsClientServiceCollectionExtensions.cs b/src/EventStore.Client.Operations/EventStoreOperationsClientServiceCollectionExtensions.cs
@@ -22,6 +22,7 @@ public static class EventStoreOperationsClientServiceCollectionExtensions {
 		/// <param name="address"></param>
 		/// <param name="createHttpMessageHandler"></param>
 		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStoreOperationsClient(this IServiceCollection services, Uri address,
 			Func<HttpMessageHandler>? createHttpMessageHandler = null)
 			=> services.AddEventStoreOperationsClient(options => {
@@ -37,12 +38,27 @@ public static IServiceCollection AddEventStoreOperationsClient(this IServiceColl
 		/// <returns></returns>
 		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStoreOperationsClient(this IServiceCollection services,
-			Action<EventStoreClientSettings>? configureOptions = null) {
+			Action<EventStoreClientSettings>? configureOptions = null) =>
+			services.AddEventStoreOperationsClient(new EventStoreClientSettings(), configureOptions);
+
+		/// <summary>
+		/// Adds an <see cref="EventStoreOperationsClient"/> to the <see cref="IServiceCollection"/>.
+		/// </summary>
+		/// <param name="services"></param>
+		/// <param name="connectionString"></param>
+		/// <param name="configureOptions"></param>
+		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
+		public static IServiceCollection AddEventStoreOperationsClient(this IServiceCollection services,
+			string connectionString, Action<EventStoreClientSettings>? configureOptions = null) =>
+			services.AddEventStoreOperationsClient(EventStoreClientSettings.Create(connectionString), configureOptions);
+
+		private static IServiceCollection AddEventStoreOperationsClient(this IServiceCollection services,
+			EventStoreClientSettings options, Action<EventStoreClientSettings>? configureOptions) {
 			if (services == null) {
 				throw new ArgumentNullException(nameof(services));
 			}
 
-			var options = new EventStoreClientSettings();
 			configureOptions?.Invoke(options);
 
 			services.TryAddSingleton(provider => {

diff --git a/...nt.PersistentSubscriptions/EventStorePersistentSubscriptionsClientCollectionExtensions.cs b/...nt.PersistentSubscriptions/EventStorePersistentSubscriptionsClientCollectionExtensions.cs
@@ -20,6 +20,7 @@ public static class EventStorePersistentSubscriptionsClientCollectionExtensions
 		/// <param name="address"></param>
 		/// <param name="createHttpMessageHandler"></param>
 		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStorePersistentSubscriptionsClient(this IServiceCollection services,
 			Uri address,
 			Func<HttpMessageHandler>? createHttpMessageHandler = null)
@@ -36,12 +37,29 @@ public static IServiceCollection AddEventStorePersistentSubscriptionsClient(this
 		/// <returns></returns>
 		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStorePersistentSubscriptionsClient(this IServiceCollection services,
-			Action<EventStoreClientSettings>? configureSettings = null) {
+			Action<EventStoreClientSettings>? configureSettings = null) =>
+			services.AddEventStorePersistentSubscriptionsClient(new EventStoreClientSettings(),
+				configureSettings);
+
+		/// <summary>
+		/// Adds an <see cref="EventStorePersistentSubscriptionsClient"/> to the <see cref="IServiceCollection"/>.
+		/// </summary>
+		/// <param name="services"></param>
+		/// <param name="connectionString"></param>
+		/// <param name="configureSettings"></param>
+		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
+		public static IServiceCollection AddEventStorePersistentSubscriptionsClient(this IServiceCollection services,
+			string connectionString, Action<EventStoreClientSettings>? configureSettings = null) =>
+			services.AddEventStorePersistentSubscriptionsClient(EventStoreClientSettings.Create(connectionString),
+				configureSettings);
+
+		private static IServiceCollection AddEventStorePersistentSubscriptionsClient(this IServiceCollection services,
+			EventStoreClientSettings settings, Action<EventStoreClientSettings>? configureSettings) {
 			if (services == null) {
 				throw new ArgumentNullException(nameof(services));
 			}
 
-			var settings = new EventStoreClientSettings();
 			configureSettings?.Invoke(settings);
 
 			services.TryAddSingleton(provider => {

diff --git a/...e.Client.ProjectionManagement/EventStoreProjectionManagementClientCollectionExtensions.cs b/...e.Client.ProjectionManagement/EventStoreProjectionManagementClientCollectionExtensions.cs
@@ -20,6 +20,7 @@ public static class EventStoreProjectionManagementClientCollectionExtensions {
 		/// <param name="address"></param>
 		/// <param name="createHttpMessageHandler"></param>
 		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStoreProjectionManagementClient(this IServiceCollection services,
 			Uri address,
 			Func<HttpMessageHandler>? createHttpMessageHandler = null)
@@ -36,12 +37,28 @@ public static IServiceCollection AddEventStoreProjectionManagementClient(this IS
 		/// <returns></returns>
 		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStoreProjectionManagementClient(this IServiceCollection services,
-			Action<EventStoreClientSettings>? configureSettings = null) {
+			Action<EventStoreClientSettings>? configureSettings = null) =>
+			services.AddEventStoreProjectionManagementClient(new EventStoreClientSettings(), configureSettings);
+
+		/// <summary>
+		/// Adds an <see cref="EventStoreProjectionManagementClient"/> to the <see cref="IServiceCollection"/>.
+		/// </summary>
+		/// <param name="services"></param>
+		/// <param name="connectionString"></param>
+		/// <param name="configureSettings"></param>
+		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
+		public static IServiceCollection AddEventStoreProjectionManagementClient(this IServiceCollection services,
+			string connectionString, Action<EventStoreClientSettings>? configureSettings = null) =>
+			services.AddEventStoreProjectionManagementClient(EventStoreClientSettings.Create(connectionString),
+				configureSettings);
+
+		private static IServiceCollection AddEventStoreProjectionManagementClient(this IServiceCollection services,
+			EventStoreClientSettings settings, Action<EventStoreClientSettings>? configureSettings) {
 			if (services == null) {
 				throw new ArgumentNullException(nameof(services));
 			}
 
-			var settings = new EventStoreClientSettings();
 			configureSettings?.Invoke(settings);
 
 			services.TryAddSingleton(provider => {

diff --git a/src/EventStore.Client.Streams/EventStoreClientServiceCollectionExtensions.cs b/src/EventStore.Client.Streams/EventStoreClientServiceCollectionExtensions.cs
@@ -20,6 +20,7 @@ public static class EventStoreClientServiceCollectionExtensions {
 		/// <param name="address"></param>
 		/// <param name="createHttpMessageHandler"></param>
 		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStoreClient(this IServiceCollection services, Uri address,
 			Func<HttpMessageHandler>? createHttpMessageHandler = null)
 			=> services.AddEventStoreClient(options => {
@@ -36,12 +37,31 @@ public static IServiceCollection AddEventStoreClient(this IServiceCollection ser
 		/// <returns></returns>
 		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStoreClient(this IServiceCollection services,
-			Action<EventStoreClientSettings>? configureSettings = null) {
+			Action<EventStoreClientSettings>? configureSettings = null) =>
+			services.AddEventStoreClient(new EventStoreClientSettings(), configureSettings);
+
+
+		/// <summary>
+		/// Adds an <see cref="EventStoreClient"/> to the <see cref="IServiceCollection"/>.
+		/// </summary>
+		/// <param name="services"></param>
+		/// <param name="connectionString"></param>
+		/// <param name="configureSettings"></param>
+		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
+		public static IServiceCollection AddEventStoreClient(this IServiceCollection services,
+			string connectionString, Action<EventStoreClientSettings>? configureSettings = null) {
 			if (services == null) {
 				throw new ArgumentNullException(nameof(services));
 			}
 
-			var settings = new EventStoreClientSettings();
+			return services.AddEventStoreClient(EventStoreClientSettings.Create(connectionString), configureSettings);
+		}
+
+
+		private static IServiceCollection AddEventStoreClient(this IServiceCollection services,
+			EventStoreClientSettings settings,
+			Action<EventStoreClientSettings>? configureSettings) {
 			configureSettings?.Invoke(settings);
 
 			services.TryAddSingleton(provider => {

diff --git a/src/EventStore.Client.UserManagement/EventStoreUserManagementClientCollectionExtensions.cs b/src/EventStore.Client.UserManagement/EventStoreUserManagementClientCollectionExtensions.cs
@@ -20,9 +20,9 @@ public static class EventStoreUserManagementClientCollectionExtensions {
 		/// <param name="address"></param>
 		/// <param name="createHttpMessageHandler"></param>
 		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStoreUserManagementClient(this IServiceCollection services,
-			Uri address,
-			Func<HttpMessageHandler>? createHttpMessageHandler = null)
+			Uri address, Func<HttpMessageHandler>? createHttpMessageHandler = null)
 			=> services.AddEventStoreUserManagementClient(options => {
 				options.ConnectivitySettings.Address = address;
 				options.CreateHttpMessageHandler = createHttpMessageHandler;
@@ -32,18 +32,34 @@ public static IServiceCollection AddEventStoreUserManagementClient(this IService
 		/// Adds an <see cref="EventStoreUserManagementClient"/> to the <see cref="IServiceCollection"/>.
 		/// </summary>
 		/// <param name="services"></param>
+		/// <param name="connectionString"></param>
 		/// <param name="configureSettings"></param>
 		/// <returns></returns>
 		/// <exception cref="ArgumentNullException"></exception>
 		public static IServiceCollection AddEventStoreUserManagementClient(this IServiceCollection services,
-			Action<EventStoreClientSettings>? configureSettings = null) {
+			string connectionString, Action<EventStoreClientSettings>? configureSettings = null)
+			=> services.AddEventStoreUserManagementClient(EventStoreClientSettings.Create(connectionString),
+				configureSettings);
+
+
+		/// <summary>
+		/// Adds an <see cref="EventStoreUserManagementClient"/> to the <see cref="IServiceCollection"/>.
+		/// </summary>
+		/// <param name="services"></param>
+		/// <param name="configureSettings"></param>
+		/// <returns></returns>
+		/// <exception cref="ArgumentNullException"></exception>
+		public static IServiceCollection AddEventStoreUserManagementClient(this IServiceCollection services,
+			Action<EventStoreClientSettings>? configureSettings = null) =>
+			services.AddEventStoreUserManagementClient(new EventStoreClientSettings(), configureSettings);
+
+		private static IServiceCollection AddEventStoreUserManagementClient(this IServiceCollection services,
+			EventStoreClientSettings settings, Action<EventStoreClientSettings>? configureSettings = null) {
+			configureSettings?.Invoke(settings);
 			if (services == null) {
 				throw new ArgumentNullException(nameof(services));
 			}
 
-			var settings = new EventStoreClientSettings();
-			configureSettings?.Invoke(settings);
-
 			services.TryAddSingleton(provider => {
 				settings.LoggerFactory ??= provider.GetService<ILoggerFactory>();
 				settings.Interceptors ??= provider.GetServices<Interceptor>();