Add extention AddLibStoredProtocolLayers and use in example

Author: guuskuiper

examples/LibStored.Net.Example.Console/Program.cs

@@ -21,10 +21,12 @@
 builder.AddServiceDefaults();
 builder.Logging.SetMinimumLevel(LogLevel.Debug);
 
-builder.Services.AddTransient<Debugger>();
-builder.Services.AddTransient<LoggerLayer>();
-builder.Services.AddTransient<BufferLayer>();
+builder.Services.AddLibStoredProtocolLayers();
 
+builder.Services.AddOpenTelemetry()
+    .WithTracing(x => x.AddSource(OpenTelemetryLayer.ActivitySourceName))
+    .WithMetrics(x => x.AddMeter(OpenTelemetryLayer.MeterName))
+    ;
 
 builder.Services.AddHostedService<App>();
 
@@ -209,6 +211,7 @@ private ProtocolBuilder.ProtocolStack CreateDebugStack(ResponseSocket debugSocke
                     })
                     .Add<BufferLayer>()
                     .Add<LoggerLayer>()
+                    .Add<OpenTelemetryLayer>()
                     .Add<DebugZeroMQLayer>(new DebugZeroMQLayer(debugSocket))
                     .Build();
             }
@@ -223,8 +226,11 @@ private ProtocolBuilder.ProtocolStack CreateDebugStack(ResponseSocket debugSocke
                 LoggerLayer debugLogging = new(_loggerFactory.CreateLogger<LoggerLayer>());
                 debugLogging.Wrap(buffer);
 
+                OpenTelemetryLayer telemetry = new();
+                telemetry.Wrap(debugLogging);
+
                 DebugZeroMQLayer debugLayer = new DebugZeroMQLayer(debugSocket);
-                debugLayer.Wrap(debugLogging);
+                debugLayer.Wrap(telemetry);
 
                 stack = ProtocolBuilder.ProtocolStack.Traverse(debugger);
             }
@@ -237,9 +243,10 @@ private ProtocolBuilder.ProtocolStack CreateSyncStack(DealerSocket socket, Synch
             if (useBuilder)
             {
                 syncStack = ProtocolBuilder.Create(_services)
-                    .Add<SyncConnection>(synchronizer.CreateConnectionLayer())
+                    .Add(synchronizer)
                     .Add<BufferLayer>()
                     .Add<LoggerLayer>()
+                    .Add<OpenTelemetryLayer>()
                     .Add<SyncZeroMQLayer>(new SyncZeroMQLayer(socket))
                     .Build();
             }
@@ -250,8 +257,11 @@ private ProtocolBuilder.ProtocolStack CreateSyncStack(DealerSocket socket, Synch
                 LoggerLayer logging = new(_loggerFactory.CreateLogger<LoggerLayer>());
                 logging.Wrap(buffer);
 
+                OpenTelemetryLayer telemetry = new();
+                telemetry.Wrap(logging);
+
                 SyncZeroMQLayer sync = new(socket);
-                sync.Wrap(logging);
+                sync.Wrap(telemetry);
 
                 synchronizer.Connect(buffer);
 
@@ -261,4 +271,4 @@ private ProtocolBuilder.ProtocolStack CreateSyncStack(DealerSocket socket, Synch
             return syncStack;
         }
     }
-}
+}

src/LibStored.Net/ProtocolBuilder.cs

@@ -3,6 +3,7 @@
 // SPDX-License-Identifier: MIT
 
 using System.Text;
+using LibStored.Net.Synchronization;
 using Microsoft.Extensions.DependencyInjection;
 
 namespace LibStored.Net;
@@ -114,6 +115,17 @@ public ProtocolBuilder Add<T>(T layer) where T : Protocol.ProtocolLayer
         return this;
     }
 
+    /// <summary>
+    /// Creates and adds a <see cref="SyncConnection"/> from a <see cref="Synchronizer"/>.
+    /// </summary>
+    /// <param name="synchronizer">The synchronizer used to create the connection layer.</param>
+    /// <returns>The current <see cref="ProtocolBuilder"/> instance.</returns>
+    public ProtocolBuilder Add(Synchronizer synchronizer)
+    {
+        _layers.Add(synchronizer.CreateConnectionLayer());
+        return this;
+    }
+
     /// <summary>
     /// Adds a protocol layer of type <typeparamref name="T"/> resolved from the service provider.
     /// </summary>

src/LibStored.Net/ServiceCollectionExtensions.cs

@@ -0,0 +1,45 @@
+// SPDX-FileCopyrightText: 2025 Guus Kuiper
+// 
+// SPDX-License-Identifier: MIT
+
+using Microsoft.Extensions.DependencyInjection;
+using LibStored.Net.Protocol;
+
+namespace LibStored.Net;
+
+/// <summary>
+/// Registers all built‑in protocol layers as transient services.
+/// No reflection; each layer is explicitly added.
+/// </summary>
+public static class ServiceCollectionExtensions
+{
+    /// <summary>
+    /// Registers all protocol layers with a simple transient lifetime so multiple stacks
+    /// can be composed independently. Layers that need constructor params have defaults.
+    /// </summary>
+    public static IServiceCollection AddLibStoredProtocolLayers(this IServiceCollection services)
+    {
+        // Application layers
+        services.AddTransient<Debugger>();
+        // The SynchronizationConnection needs to be created from a Synchronizer; not auto-registered.
+
+        // Stateless / simple
+        services.AddTransient<AsciiEscapeLayer>();
+        services.AddTransient<BufferLayer>();
+        services.AddTransient<LoggingLayer>();
+        services.AddTransient<OpenTelemetryLayer>();
+        services.AddTransient<TerminalLayer>();
+
+        services.AddTransient<LoggerLayer>();
+        services.AddTransient<Crc8Layer>();
+        services.AddTransient<Crc16Layer>();
+
+        // Parameterized layers (use default ctor values)
+        services.AddTransient<SegmentationLayer>();     // default mtu
+        services.AddTransient<ArqLayer>();              // default maxEncodeBufferSize
+
+        // LoopbackLayer requires two peer layers; not auto-registered (needs runtime pair wiring).
+
+        return services;
+    }
+}