Disabled pipeline resolving

Author: andrey-serdyuk

Directory.Build.props

@@ -4,7 +4,7 @@
 		<ImplicitUsings>enable</ImplicitUsings>
 		<Nullable>enable</Nullable>
 		<IsPackable>true</IsPackable>
-		<Version>2.3.19</Version>
+		<Version>2.3.24</Version>
 		<Authors>Andrey Serdyuk</Authors>
 		<Company>TaskHub</Company>
 		<Title>TaskHub.Shared - Reusable Primitives for .NET Microservices</Title>

TaskHub.Observability.OpenTelemetry/Bootstrap/OpenTelemetryBootstrap.cs

@@ -22,7 +22,7 @@ public static void AddAppOpenTelemetry(this IServiceCollection services, Action<
             t.AddAttributes([new("deployment.environment", options.Environment)]);
         }).WithTracing(t =>
         {
-            t.AddSource("CommandsBus", "NominatimClient", "NominatimService");
+            t.AddSource("CommandsBus", "NominatimClient", "NominatimService", "Networking");
             t.AddSource([.. options.Sources]);
 
             if (options.Sampling.IsEnabled)

TaskHub.Shared.Commands.Implementation/Bootstrap/BusBootstrap.cs

@@ -8,7 +8,7 @@ public static class BusBootstrap
 {
     public static void AddAppCommandsBus(this IServiceCollection services, Type[] types)
     {
-        services.AddAppPipeline(types);
+        //services.AddAppPipeline(types);
         services.AddScoped<ICommandsBus>(sp => new CommandsBus(
             sp.GetRequiredService<IServiceScopeFactory>(),
             sp.GetRequiredService<IHistogramMetricFactory>().Get("CommandBus")

TaskHub.Shared.Commands.Implementation/Bootstrap/PipelineBootstrap.cs

@@ -6,6 +6,9 @@
 
 namespace TaskHub.Shared.Commands.Implementation.Bootstrap;
 
+/// <summary>
+/// Candidate for deprecation
+/// </summary>
 public static class PipelineBootstrap
 {
     public static void AddAppPipeline(this IServiceCollection services, IEnumerable<Type> types)
@@ -15,20 +18,19 @@ public static void AddAppPipeline(this IServiceCollection services, IEnumerable<
         var closedTypes = src.Where(t => !t.IsGenericTypeDefinition).ToArray();
 
         var openPre = openTypes
-            .Where(i => i.GetCustomAttribute<SharedBehaviorAttribute>() != null)
             .Where(i => i.GetInterfaces().Any(j => j.IsGenericType && j.GetGenericTypeDefinition() == typeof(IPreBehavior<,>)))
             .Select(i => new
             {
                 Type = i,
                 Order = i.GetCustomAttribute<OrderAttribute>()?.Order ?? int.MinValue
             }).OrderBy(i => i.Order).Select(i => i.Type).ToArray();
+
         foreach (var type in openPre)
         {
             services.AddScoped(typeof(IPreBehavior<,>), type);
         }
 
         var openPost = openTypes
-            .Where(i => i.GetCustomAttribute<SharedBehaviorAttribute>() != null)
             .Where(i => i.GetInterfaces().Any(j => j.IsGenericType && j.GetGenericTypeDefinition() == typeof(IPostBehavior<,>)))
             .Select(i => new
             {

TaskHub.Shared.Commands.Implementation/CommandsBus.cs

@@ -42,7 +42,7 @@ private async Task<TResult> InvokeScoped<TCommand, TResult>(
         return await invoker(scope.ServiceProvider, command, ct).ConfigureAwait(false);
     }
 
-    private Func<IServiceProvider, TCommand, CancellationToken, Task<TResult>> BuildInvoker<TCommand, TResult>()
+    private static Func<IServiceProvider, TCommand, CancellationToken, Task<TResult>> BuildInvoker<TCommand, TResult>()
         where TCommand : ICommand
         where TResult : Result
     {

TaskHub.Shared.Networking.Abstractions/ClientBase.cs

@@ -4,5 +4,5 @@ namespace TaskHub.Shared.Networking.Abstractions;
 
 public abstract class ClientBase
 {
-    protected static readonly ActivitySource ActivitySource = new("JobClient");
+    protected static readonly ActivitySource ActivitySource = new("Networking");
 }

TaskHub.Shared.Networking.Implementation/Bootstrap/AppHttpClient.cs

@@ -16,6 +16,7 @@ public static void AddAppNetworkingSettings(this IServiceCollection services, Ac
     {
         var settings = new NetworkOptions();
         action(settings);
+        services.AddTransient<BearerTokenHandler>();
         foreach (var (name, node) in settings.Services)
         {
             services.AddAppHttpClient(name, settings.Defaults, new OptionsResolver(settings.Defaults, node).Resolve());

TaskHub.Shared.Response/Result.cs

@@ -1,5 +1,4 @@
 using System.Diagnostics;
-using System.Text.Json.Serialization;
 
 namespace TaskHub.Shared.Response;
 
@@ -10,7 +9,6 @@ public class Result
     public string Message { get; init; }
     public static implicit operator Result(OpResult op) => new(op.ResultCode, op.Message);
 
-    [JsonConstructor]
     public Result(int code, string message)
     {
         ResultCode = code;

TaskHub.Shared.Response/ValueResult.cs

@@ -1,5 +1,4 @@
 using System.Diagnostics;
-using System.Text.Json.Serialization;
 
 namespace TaskHub.Shared.Response;
 
@@ -8,7 +7,6 @@ public sealed class ValueResult<T> : Result
     public T? Data { get; init; }
     public static implicit operator ValueResult<T>(OpResult op) => new(op.ResultCode, op.Message, default);
 
-    [JsonConstructor]
     public ValueResult(int code, string message, T? data) : base(code, message)
     {
         Data = data;