feature: MQTT client and server

src/Namotion.Interceptor.Mqtt.SampleClient/Namotion.Interceptor.Mqtt.SampleClient.csproj

@@ -0,0 +1,22 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net9.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+        <IsPackable>false</IsPackable>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Microsoft.Extensions.Hosting" Version="9.0.10" />
+    </ItemGroup>
+
+    <ItemGroup>
+        <ProjectReference Include="..\Namotion.Interceptor.Mqtt\Namotion.Interceptor.Mqtt.csproj" />
+        <ProjectReference Include="..\Namotion.Interceptor.SamplesModel\Namotion.Interceptor.SamplesModel.csproj" />
+        <ProjectReference Include="..\Namotion.Interceptor.Hosting\Namotion.Interceptor.Hosting.csproj" />
+        <ProjectReference Include="..\Namotion.Interceptor.Validation\Namotion.Interceptor.Validation.csproj" />
+    </ItemGroup>
+
+</Project>

src/Namotion.Interceptor.Mqtt.SampleClient/Program.cs

@@ -0,0 +1,41 @@
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Namotion.Interceptor;
+using Namotion.Interceptor.Hosting;
+using Namotion.Interceptor.Mqtt;
+using Namotion.Interceptor.Mqtt.Client;
+using Namotion.Interceptor.Registry;
+using Namotion.Interceptor.SamplesModel;
+using Namotion.Interceptor.SamplesModel.Workers;
+using Namotion.Interceptor.Sources.Paths;
+using Namotion.Interceptor.Tracking;
+using Namotion.Interceptor.Validation;
+
+var builder = Host.CreateApplicationBuilder(args);
+
+var context = InterceptorSubjectContext
+    .Create()
+    .WithFullPropertyTracking()
+    .WithRegistry()
+    .WithParents()
+    .WithLifecycle()
+    .WithDataAnnotationValidation()
+    .WithHostedServices(builder.Services);
+
+var root = Root.CreateWithPersons(context);
+context.AddService(root);
+
+builder.Services.AddSingleton(root);
+builder.Services.AddHostedService<ClientWorker>();
+builder.Services.AddMqttSubjectClient(
+    _ => root,
+    _ => new MqttClientConfiguration
+    {
+        BrokerHost = "localhost",
+        BrokerPort = 1883,
+        PathProvider = new AttributeBasedSourcePathProvider("mqtt", "/", null)
+    });
+
+using var performanceProfiler = new PerformanceProfiler(context, "Client");
+var host = builder.Build();
+host.Run();

src/Namotion.Interceptor.Mqtt.SampleServer/Namotion.Interceptor.Mqtt.SampleServer.csproj

@@ -0,0 +1,22 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net9.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+        <IsPackable>false</IsPackable>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Microsoft.Extensions.Hosting" Version="9.0.10" />
+    </ItemGroup>
+
+    <ItemGroup>
+        <ProjectReference Include="..\Namotion.Interceptor.Mqtt\Namotion.Interceptor.Mqtt.csproj" />
+        <ProjectReference Include="..\Namotion.Interceptor.SamplesModel\Namotion.Interceptor.SamplesModel.csproj" />
+        <ProjectReference Include="..\Namotion.Interceptor.Hosting\Namotion.Interceptor.Hosting.csproj" />
+        <ProjectReference Include="..\Namotion.Interceptor.Validation\Namotion.Interceptor.Validation.csproj" />
+    </ItemGroup>
+
+</Project>

src/Namotion.Interceptor.Mqtt.SampleServer/Program.cs

@@ -0,0 +1,40 @@
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Namotion.Interceptor;
+using Namotion.Interceptor.Hosting;
+using Namotion.Interceptor.Mqtt.Server;
+using Namotion.Interceptor.Registry;
+using Namotion.Interceptor.SamplesModel;
+using Namotion.Interceptor.SamplesModel.Workers;
+using Namotion.Interceptor.Sources.Paths;
+using Namotion.Interceptor.Tracking;
+using Namotion.Interceptor.Validation;
+
+var builder = Host.CreateApplicationBuilder(args);
+
+var context = InterceptorSubjectContext
+    .Create()
+    .WithFullPropertyTracking()
+    .WithRegistry()
+    .WithParents()
+    .WithLifecycle()
+    .WithDataAnnotationValidation()
+    .WithHostedServices(builder.Services);
+
+var root = Root.CreateWithPersons(context);
+context.AddService(root);
+
+builder.Services.AddSingleton(root);
+builder.Services.AddHostedService<ServerWorker>();
+builder.Services.AddMqttSubjectServer(
+    _ => root,
+    _ => new MqttServerConfiguration
+    {
+        BrokerHost = "localhost",
+        BrokerPort = 1883,
+        PathProvider = new AttributeBasedSourcePathProvider("mqtt", "/")
+    });
+
+using var performanceProfiler = new PerformanceProfiler(context, "Server");
+var host = builder.Build();
+host.Run();

src/Namotion.Interceptor.Mqtt.Tests/JsonMqttValueConverterTests.cs

@@ -0,0 +1,144 @@
+using System.Buffers;
+using System.Text;
+using System.Text.Json;
+using Xunit;
+
+namespace Namotion.Interceptor.Mqtt.Tests;
+
+public class JsonMqttValueConverterTests
+{
+    private readonly JsonMqttValueConverter _converter = new();
+
+    [Fact]
+    public void Serialize_NullValue_ReturnsJsonNull()
+    {
+        // Act
+        var result = _converter.Serialize(null, typeof(object));
+
+        // Assert
+        Assert.Equal("null", Encoding.UTF8.GetString(result));
+    }
+
+    [Theory]
+    [InlineData(42, typeof(int), "42")]
+    [InlineData(3.14, typeof(double), "3.14")]
+    [InlineData(true, typeof(bool), "true")]
+    [InlineData(false, typeof(bool), "false")]
+    [InlineData("test", typeof(string), "\"test\"")]
+    public void Serialize_PrimitiveTypes_ReturnsCorrectJson(object value, Type type, string expected)
+    {
+        // Act
+        var result = _converter.Serialize(value, type);
+
+        // Assert
+        Assert.Equal(expected, Encoding.UTF8.GetString(result));
+    }
+
+    [Fact]
+    public void Serialize_ComplexObject_ReturnsCorrectJson()
+    {
+        // Arrange
+        var obj = new TestObject { Name = "Test", Value = 123 };
+
+        // Act
+        var result = _converter.Serialize(obj, typeof(TestObject));
+
+        // Assert
+        var json = Encoding.UTF8.GetString(result);
+        Assert.Contains("\"name\":", json); // camelCase
+        Assert.Contains("\"Test\"", json);
+        Assert.Contains("\"value\":", json);
+        Assert.Contains("123", json);
+    }
+
+    [Fact]
+    public void Deserialize_EmptyPayload_ReturnsNull()
+    {
+        // Arrange
+        var payload = new ReadOnlySequence<byte>(Array.Empty<byte>());
+
+        // Act
+        var result = _converter.Deserialize(payload, typeof(string));
+
+        // Assert
+        Assert.Null(result);
+    }
+
+    [Fact]
+    public void Deserialize_JsonNull_ReturnsNull()
+    {
+        // Arrange
+        var payload = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("null"));
+
+        // Act
+        var result = _converter.Deserialize(payload, typeof(string));
+
+        // Assert
+        Assert.Null(result);
+    }
+
+    [Theory]
+    [InlineData("42", typeof(int), 42)]
+    [InlineData("3.14", typeof(double), 3.14)]
+    [InlineData("true", typeof(bool), true)]
+    [InlineData("\"test\"", typeof(string), "test")]
+    public void Deserialize_PrimitiveTypes_ReturnsCorrectValue(string json, Type type, object expected)
+    {
+        // Arrange
+        var payload = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json));
+
+        // Act
+        var result = _converter.Deserialize(payload, type);
+
+        // Assert
+        Assert.Equal(expected, result);
+    }
+
+    [Fact]
+    public void Deserialize_ComplexObject_ReturnsCorrectObject()
+    {
+        // Arrange
+        var json = "{\"name\":\"Test\",\"value\":123}";
+        var payload = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json));
+
+        // Act
+        var result = _converter.Deserialize(payload, typeof(TestObject)) as TestObject;
+
+        // Assert
+        Assert.NotNull(result);
+        Assert.Equal("Test", result.Name);
+        Assert.Equal(123, result.Value);
+    }
+
+    [Fact]
+    public void Deserialize_InvalidJson_ThrowsJsonException()
+    {
+        // Arrange
+        var payload = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("invalid json"));
+
+        // Act & Assert
+        Assert.Throws<JsonException>(() => _converter.Deserialize(payload, typeof(int)));
+    }
+
+    [Fact]
+    public void RoundTrip_PreservesValue()
+    {
+        // Arrange
+        var original = new TestObject { Name = "RoundTrip", Value = 456 };
+
+        // Act
+        var serialized = _converter.Serialize(original, typeof(TestObject));
+        var deserialized = _converter.Deserialize(new ReadOnlySequence<byte>(serialized), typeof(TestObject)) as TestObject;
+
+        // Assert
+        Assert.NotNull(deserialized);
+        Assert.Equal(original.Name, deserialized.Name);
+        Assert.Equal(original.Value, deserialized.Value);
+    }
+
+    private class TestObject
+    {
+        public string Name { get; set; } = string.Empty;
+        public int Value { get; set; }
+    }
+}