Add local nuget push to remaining projects

Add where clause rewriter to TSqlLinguist

nuget.config

@@ -10,8 +10,8 @@
     </packageRestore>
     <packageSources>
         <add key="NuGet official package source" value="https://api.nuget.org/v3/index.json" />
-		<add key="Local repository" value="%LOCAL_NUGET%" />
+        <add key="LocalNugetServer" value="%LOCAL_NUGET_SERVER%" />
+        <add key="Local file repository" value="%LOCAL_NUGET%" />
     </packageSources>
-
     <disabledPackageSources />
 </configuration>

src/Connected.Caching/Connected.Caching.csproj

@@ -59,4 +59,9 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Collections/Connected.Collections.csproj

@@ -58,4 +58,9 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
 
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
+
 </Project>

src/Connected.Configuration/ConfigurationService.cs

@@ -1,14 +1,16 @@
 using Connected.Configuration.Authentication;
 using Connected.Configuration.Endpoints;
+using Microsoft.Extensions.Configuration;
 
 namespace Connected.Configuration;
 
 internal class ConfigurationService : IConfigurationService
 {
-	public ConfigurationService()
+	public ConfigurationService(IConfiguration configuration)
 	{
-		Endpoint = new EndpointConfiguration();
+		Endpoint = new EndpointConfiguration(configuration.GetSection("endpoint"));
-		Storage = new StorageConfiguration();
+		
+		Storage = new StorageConfiguration(configuration.GetSection("storage"));
 	}
 
 	public IEndpointConfiguration Endpoint { get; }

src/Connected.Configuration/Connected.Configuration.csproj

@@ -40,4 +40,9 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Configuration/DatabaseConfiguration.cs

@@ -1,19 +1,18 @@
 using System.Collections.Immutable;
+using Microsoft.Extensions.Configuration;
 
 namespace Connected.Configuration
 {
 	internal class DatabaseConfiguration : IDatabaseConfiguration
 	{
-		private List<string> _shards;
+		private readonly List<string> _shards;
 
-		public DatabaseConfiguration()
+		public DatabaseConfiguration(IConfiguration configuration)
 		{
-			/*
+			DefaultConnectionString = "";
-			 * TODO: read from config
-			 */
-			DefaultConnectionString = "server=PIT-ZBOOK\\sqlexpress; database=connected; trusted_connection=true;TrustServerCertificate=True;multiple active result sets=true";
-
 			_shards = new();
+			configuration.Bind(this);
+			configuration.Bind("shards", _shards);
 		}
 
 		public string? DefaultConnectionString { get; init; }

src/Connected.Configuration/Endpoints/EndpointConfiguration.cs

@@ -1,7 +1,14 @@
-namespace Connected.Configuration.Endpoints
+using Microsoft.Extensions.Configuration;
+
+namespace Connected.Configuration.Endpoints
 {
 	internal sealed class EndpointConfiguration : IEndpointConfiguration
 	{
+		public EndpointConfiguration(IConfiguration configuration) 
+		{
+			configuration.Bind(this);
+		}
+
 		public string? Address { get; set; }
 	}
 }

src/Connected.Configuration/IDatabaseConfiguration.cs

@@ -4,7 +4,7 @@ namespace Connected.Configuration
 {
 	public interface IDatabaseConfiguration
 	{
-		string DefaultConnectionString { get; }
+		string? DefaultConnectionString { get; }
 
 		ImmutableList<string> Shards { get; }
 	}

src/Connected.Configuration/StorageConfiguration.cs

@@ -1,10 +1,12 @@
-namespace Connected.Configuration
+using Microsoft.Extensions.Configuration;
+
+namespace Connected.Configuration
 {
 	internal class StorageConfiguration : IStorageConfiguration
 	{
-		public StorageConfiguration()
+		public StorageConfiguration(IConfiguration configuration)
 		{
-			Databases = new DatabaseConfiguration();
+			Databases = new DatabaseConfiguration(configuration.GetSection("databases"));
 		}
 
 		public IDatabaseConfiguration Databases { get; }

src/Connected.Data/Connected.Data.csproj

@@ -62,4 +62,9 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Data/Storage/EntityStorage.cs

@@ -152,7 +152,11 @@ internal class EntityStorage<TEntity> : IAsyncEnumerable<TEntity>, IStorage<TEnt
 
 		await Execute(new StorageContextArgs(operation));
 
-		return entity;
+		var clone = entity.Clone();
+
+		ReturnValueBinder.Bind(operation, clone);
+
+		return clone;
 	}
 	/// <summary>
 	/// Performs the update on the specified entity with optional concurrency callback support.
@@ -271,10 +275,6 @@ internal class EntityStorage<TEntity> : IAsyncEnumerable<TEntity>, IStorage<TEnt
 		 */
 		if (recordsAffected == 0 && args.Operation.Concurrency == DataConcurrencyMode.Enabled)
 			throw new DBConcurrencyException($"{SR.ErrDataConcurrency} ({typeof(Entity).Name})");
-		/*
-		 * Bind storage parameters with operation parameters.
-		 */
-		ReturnValueBinder.Bind(writer, args.Operation);
 
 		return recordsAffected;
 	}

src/Connected.Data/Storage/ReturnValueBinder.cs

@@ -6,47 +6,36 @@ using Connected.Interop;
 
 namespace Connected.Data.Storage
 {
-    internal static class ReturnValueBinder
+	internal static class ReturnValueBinder
 	{
-		public static void Bind(IStorageWriter w, IStorageOperation operation)
+		public static void Bind(IStorageOperation operation, object entity)
 		{
-			List<PropertyInfo> properties = null;
+			if (operation is null || operation.Parameters is null)
-
-			if (w.Operation.Parameters is null)
 				return;
 
-			foreach (var parameter in w.Operation.Parameters)
+			foreach (var parameter in operation.Parameters)
 			{
-				if (parameter.Direction != ParameterDirection.ReturnValue && parameter.Direction != ParameterDirection.Output)
-					continue;
-
 				if (parameter.Value == DBNull.Value)
 					continue;
 
-				if (properties is null)
+				var properties = new List<PropertyInfo>();
+
+				var all = entity.GetType().GetProperties(BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance);
+
+				foreach (var prop in all)
 				{
-					properties = new List<PropertyInfo>();
+					if (prop.FindAttribute<ReturnValueAttribute>() is not null)
-
+						properties.Add(prop);
-					var all = operation.GetType().GetProperties(BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance);
-
-					foreach (var prop in all)
-					{
-						if (prop.FindAttribute<ReturnValueAttribute>() is not null)
-							properties.Add(prop);
-					}
 				}
 
-				PropertyInfo property = null;
+				PropertyInfo? property = null;
 
-				if (property is null)
+				foreach (var prop in properties)
 				{
-					foreach (var prop in properties)
+					if (string.Equals(prop.Name, parameter.Name, StringComparison.Ordinal))
 					{
-						if (string.Equals(prop.Name, parameter.Name, StringComparison.Ordinal))
+						property = prop;
-						{
+						break;
-							property = prop;
-							break;
-						}
 					}
 				}
 
@@ -65,9 +54,9 @@ namespace Connected.Data.Storage
 				if (property is null)
 				{
 					var candidates = new List<string>
-			{
+					{
-			  parameter.Name.Replace("@", string.Empty)
+					  parameter.Name.Replace("@", string.Empty)
-			};
+					};
 
 					foreach (var prop in properties)
 					{
@@ -85,26 +74,28 @@ namespace Connected.Data.Storage
 					}
 				}
 
-				if (property is not null)
+				if (property is null)
+					continue;
+
+				var existingValue = property.GetValue(entity);
+				var overwriteAtt = property.FindAttribute<ReturnValueAttribute>();
+
+				if (overwriteAtt is null)
+					continue;
+
+				switch (overwriteAtt.ValueBehavior)
 				{
-					var existingValue = property.GetValue(operation);
+					case PropertyValueBehavior.OverwriteDefault:
-					var overwriteAtt = property.FindAttribute<ReturnValueAttribute>();
+						var defaultValue = property.PropertyType.GetDefault();
 
-					switch (overwriteAtt.ValueBehavior)
+						if (Equals(existingValue, defaultValue))
-					{
+							property.SetValue(entity, TypeConversion.Convert(parameter.Value, property.PropertyType));
-						case PropertyValueBehavior.OverwriteDefault:
+						break;
-							var defaultValue = property.PropertyType.GetDefault();
+					case PropertyValueBehavior.AlwaysOverwrite:
-
+						property.SetValue(entity, TypeConversion.Convert(parameter.Value, property.PropertyType));
-							if (Equals(existingValue, defaultValue))
+						break;
-								property.SetValue(operation, parameter.Value);
-							break;
-						case PropertyValueBehavior.AlwaysOverwrite:
-							property.SetValue(operation, parameter.Value);
-							break;
-					}
 				}
 			}
 		}
-
 	}
 }

src/Connected.Data/Update/CommandBuilder.cs

@@ -28,10 +28,12 @@ internal abstract class CommandBuilder
 
 		if (TryGetExisting(out StorageOperation? existing))
 		{
+			if (existing is null)
+				return null;
 			/*
-             * We need to rebuild an instance since StorageOperation
+          * We need to rebuild an instance since StorageOperation
-             * is immutable
+          * is immutable
-             */
+          */
 			var result = new StorageOperation
 			{
 				CommandText = existing.CommandText,
@@ -43,20 +45,21 @@ internal abstract class CommandBuilder
 			if (result.Parameters is null)
 				return result;
 
-			foreach (var parameter in result.Parameters)
+			foreach (var parameter in existing.Parameters)
 			{
-				if (parameter.Direction == ParameterDirection.Input)
+				if (ResolveProperty(parameter.Name) is PropertyInfo property)
 				{
-					if (ResolveProperty(parameter.Name) is PropertyInfo property)
+					result.AddParameter(new StorageParameter
 					{
-						result.AddParameter(new StorageParameter
+						Value = parameter.Direction switch
 						{
-							Value = GetValue(property),
+							ParameterDirection.Input => GetValue(property),
-							Name = parameter.Name,
+							_ => default
-							Type = parameter.Type,
+						},
-							Direction = parameter.Direction
+						Name = parameter.Name,
-						});
+						Type = parameter.Type,
-					}
+						Direction = parameter.Direction
+					});
 				}
 			}
 

src/Connected.Entities/Caching/EntityCacheClient.cs

@@ -10,118 +10,122 @@ using System.Collections.Immutable;
 namespace Connected.Entities.Caching;
 
 public abstract class EntityCacheClient<TEntity, TPrimaryKey> : StatefulCacheClient<TEntity, TPrimaryKey>, IEntityCacheClient<TEntity, TPrimaryKey>
-    where TEntity : class, IPrimaryKey<TPrimaryKey>, IEntity
+	 where TEntity : class, IPrimaryKey<TPrimaryKey>, IEntity
-    where TPrimaryKey : notnull
+	 where TPrimaryKey : notnull
 {
-    protected EntityCacheClient(IEntityCacheContext context, string key) : base(context.Cache, key)
+	protected EntityCacheClient(IEntityCacheContext context, string key) : base(context.Cache, key)
-    {
+	{
-        Context = context;
+		Context = context;
-    }
+	}
 
-    private IEntityCacheContext Context { get; }
+	private IEntityCacheContext Context { get; }
 
-    protected override sealed async Task OnInitializing()
+	protected override sealed async Task OnInitializing()
-    {
+	{
-        using var ctx = Context.ContextProvider.Create();
+		using var ctx = Context.ContextProvider.Create();
 
-        var transaction = ctx.GetService<ITransactionContext?>();
+		var transaction = ctx.GetService<ITransactionContext?>();
 
-        try
+		try
-        {
+		{
-            if (await OnInitializing(ctx) is ImmutableList<TEntity> ds)
+			if (await OnInitializing(ctx) is ImmutableList<TEntity> ds)
-            {
+			{
-                foreach (var r in ds)
+				foreach (var r in ds)
-                    Set(r.Id, r, TimeSpan.Zero);
+					Set(r.Id, r, TimeSpan.Zero);
-            }
+			}
 
-            if (transaction is not null)
+			if (transaction is not null)
-                await transaction.Commit();
+				await transaction.Commit();
-        }
+		}
-        catch
+		catch
-        {
+		{
-            if (transaction is not null)
+			if (transaction is not null)
-                await transaction.Rollback();
+				await transaction.Rollback();
 
-            throw;
+			throw;
-        }
+		}
-    }
+	}
 
-    protected virtual async Task<ImmutableList<TEntity>?> OnInitializing(IContext context)
+	protected virtual async Task<ImmutableList<TEntity>?> OnInitializing(IContext context)
-    {
+	{
-        if (context.GetService<IStorageProvider>() is not IStorageProvider db)
+		if (context.GetService<IStorageProvider>() is not IStorageProvider db)
-            return default;
+			return default;
 
-        return await (from dc in db.Open<TEntity>()
+		return await (from dc in db.Open<TEntity>()
-                      select dc).AsEntities();
+						  select dc).AsEntities();
-    }
+	}
 
-    protected override async Task OnInvalidate(TPrimaryKey id)
+	protected override async Task OnInvalidate(TPrimaryKey id)
-    {
+	{
-        using var ctx = Context.ContextProvider.Create();
+		using var ctx = Context.ContextProvider.Create();
-        var transaction = ctx.GetService<ITransactionContext>();
+		var transaction = ctx.GetService<ITransactionContext>();
 
-        try
+		try
-        {
+		{
-            if (OnInvalidating(ctx, id) is TEntity entity && entity is IPrimaryKey<TPrimaryKey> pk)
+			if (OnInvalidating(ctx, id) is TEntity entity && entity is IPrimaryKey<TPrimaryKey> pk)
-                Set(pk.Id, entity, TimeSpan.Zero);
+				Set(pk.Id, entity, TimeSpan.Zero);
 
-            if (transaction is not null)
+			if (transaction is not null)
-                await transaction.Commit();
+				await transaction.Commit();
-        }
+		}
-        catch
+		catch
-        {
+		{
-            if (transaction is not null)
+			if (transaction is not null)
-                await transaction.Rollback();
+				await transaction.Rollback();
 
-            throw;
+			throw;
-        }
+		}
-    }
+	}
 
-    protected virtual async Task<TEntity?> OnInvalidating(IContext context, TPrimaryKey id)
+	protected virtual async Task<TEntity?> OnInvalidating(IContext context, TPrimaryKey id)
-    {
+	{
-        if (context.GetService<IStorageProvider>() is not IStorageProvider provider)
+		if (context.GetService<IStorageProvider>() is not IStorageProvider provider)
-            return default;
+			return default;
 
-        return await (from dc in provider.Open<TEntity>()
+		var entities = await provider.Open<TEntity>().AsEntities();
-                      where TypeComparer.Compare(dc.Id, id)
-                      select dc).AsEntity();
-    }
 
-    async Task IEntityCacheClient<TEntity, TPrimaryKey>.Refresh(TPrimaryKey id)
+		var entity = entities.FirstOrDefault(e => e.Id.Equals(id));
-    {
-        await Refresh(id);
-    }
 
-    async Task IEntityCacheClient<TEntity, TPrimaryKey>.Remove(TPrimaryKey id)
+		return await (from dc in provider.Open<TEntity>()
-    {
+						  where TypeComparer.Compare(dc.Id, id)
-        await Remove(id);
+						  select dc).AsEntity();
-    }
+	}
 
-    protected override void Set(TPrimaryKey id, TEntity instance)
+	async Task IEntityCacheClient<TEntity, TPrimaryKey>.Refresh(TPrimaryKey id)
-    {
+	{
-        Set(id, instance, TimeSpan.Zero);
+		await Refresh(id);
-    }
+	}
 
-    protected override void Set(TPrimaryKey id, TEntity instance, TimeSpan duration)
+	async Task IEntityCacheClient<TEntity, TPrimaryKey>.Remove(TPrimaryKey id)
-    {
+	{
-        if (instance is IConcurrentEntity<TPrimaryKey> concurrent)
+		await Remove(id);
-        {
+	}
-            if (Get(id) is TEntity existing && existing is IConcurrentEntity<TPrimaryKey> existingConcurrent)
-            {
-                lock (existingConcurrent)
-                {
-                    if (existingConcurrent.Sync != concurrent.Sync)
-                        throw new InvalidOperationException(SR.ErrConcurrent);
 
-                    concurrent.GetType().GetProperty(nameof(IConcurrentEntity<TPrimaryKey>.Sync))?.SetValue(concurrent, concurrent.Sync + 1);
+	protected override void Set(TPrimaryKey id, TEntity instance)
+	{
+		Set(id, instance, TimeSpan.Zero);
+	}
 
-                    Set(id, instance, duration);
+	protected override void Set(TPrimaryKey id, TEntity instance, TimeSpan duration)
+	{
+		if (instance is IConcurrentEntity<TPrimaryKey> concurrent)
+		{
+			if (Get(id) is TEntity existing && existing is IConcurrentEntity<TPrimaryKey> existingConcurrent)
+			{
+				lock (existingConcurrent)
+				{
+					if (existingConcurrent.Sync != concurrent.Sync)
+						throw new InvalidOperationException(SR.ErrConcurrent);
 
-                    return;
+					concurrent.GetType().GetProperty(nameof(IConcurrentEntity<TPrimaryKey>.Sync))?.SetValue(concurrent, concurrent.Sync + 1);
-                }
-            }
-        }
 
-        base.Set(id, instance, duration);
+					Set(id, instance, duration);
-    }
+
+					return;
+				}
+			}
+		}
+
+		base.Set(id, instance, duration);
+	}
 }

src/Connected.Entities/Connected.Entities.csproj

@@ -56,4 +56,9 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Entities/EntitiesExtensions.cs

@@ -85,6 +85,14 @@ public static class EntitiesExtensions
 		return Serializer.Merge(newEntity, existing, modifier, new StateModifier { State = state }, sources);
 	}
 
+	public static TEntity Clone<TEntity>(this TEntity existing)
+		where TEntity : IEntity
+	{
+		var newEntity = Activator.CreateInstance<TEntity>();
+
+		return Serializer.Merge(newEntity, existing);
+	}
+
 	public static async Task<ImmutableList<TSource>> AsEntities<TSource>(this IQueryable<TSource> source, CancellationToken cancellationToken = default)
 	{
 		if (source is null)

src/Connected.Expressions/Connected.Expressions.csproj

@@ -42,4 +42,9 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Globalization/Connected.Globalization.csproj

@@ -40,4 +40,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Hosting/Connected.Hosting.csproj

@@ -56,4 +56,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Instance/Connected.Instance.csproj

@@ -71,4 +71,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Instance/Instance.cs

@@ -13,7 +13,10 @@ namespace Connected.Instance
 			var options = new WebApplicationOptions();
 			config.Bind(options);
 
-			var builder = WebApplication.CreateBuilder(options);
+			var builder = WebApplication
+				.CreateBuilder(options);
+
+			builder.Configuration.AddConfiguration(config);
 
 			var startups = Assemblies.QueryImplementations<IStartup>();
 

src/Connected.Interop/Connected.Interop.csproj

@@ -55,4 +55,13 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Middleware/Connected.Middleware.csproj

@@ -41,4 +41,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Net/Connected.Net.csproj

@@ -61,4 +61,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Notifications/Connected.Notifications.csproj

@@ -41,5 +41,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
-
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Rest/Connected.Rest.csproj

@@ -61,4 +61,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Runtime/Connected.Runtime.csproj

@@ -43,4 +43,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Security/Connected.Security.csproj

@@ -58,5 +58,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
-
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Services/Connected.Services.csproj

@@ -61,4 +61,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Threading/Connected.Threading.csproj

@@ -55,4 +55,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>

src/Connected.Validation/Connected.Validation.csproj

@@ -56,4 +56,8 @@
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).nupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 		<Copy SourceFiles="$(OutputPath)..\$(PackageId).$(PackageVersion).snupkg" DestinationFolder="$([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET'))" />
 	</Target>
+	<Target Name="UploadLocalPackages" AfterTargets="CopyPackages" >
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).nupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+		<Exec Command="dotnet nuget push -s LocalNugetServer $(OutputPath)..\$(PackageId).$(PackageVersion).snupkg --api-key $([System.Environment]::GetEnvironmentVariable('LOCAL_NUGET_SERVER_TOKEN'))" IgnoreExitCode="true"></Exec>
+	</Target>
 </Project>