using System.Text;
using System.Text.Json;
using MQTTnet;
using MQTTnet.Client;

var factory = new MqttFactory();
var client = factory.CreateMqttClient();

var options = new MqttClientOptionsBuilder()
    .WithClientId("SenderClient")
    .WithTcpServer("localhost", 1883) 
    .Build();

await client.ConnectAsync(options, CancellationToken.None);

var dto = new LargeDto
{
    Id = 1,
    Name = "Sample",
    Data = new byte[1024 * 50]
};

var jsonData = JsonSerializer.Serialize(dto);
var message = new MqttApplicationMessageBuilder()
    .WithTopic("large/dto")
    .WithPayload(Encoding.UTF8.GetBytes(jsonData))
    .WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce)
    .Build();

while (true)
{
    await client.PublishAsync(message, CancellationToken.None);
    await Task.Delay(1); 
}


await client.DisconnectAsync();

public class LargeDto
{
    public int Id { get; set; }
    public string Name { get; set; }
    public byte[] Data { get; set; }
}

using WebApplication1;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddHostedService<MqttHostedService>();
var app = builder.Build();

app.MapGet("/", () => "Hello World!");

app.Run();

using MQTTnet;
using MQTTnet.Client;

namespace WebApplication1;

public class MqttHostedService : IHostedService
{
    private readonly IMqttClient _client;
    private readonly MqttClientOptions _options;

    public MqttHostedService()
    {
        var factory = new MqttFactory();
        _client = factory.CreateMqttClient();

        _options = new MqttClientOptionsBuilder()
            .WithClientId("ListenerClientAsp6")
            .WithTcpServer("localhost", 1883) 
            .Build();

        _client.ApplicationMessageReceivedAsync += e =>
        {
            return Task.CompletedTask;
        };
    }

    public async Task StartAsync(CancellationToken cancellationToken)
    {
        await _client.ConnectAsync(_options, cancellationToken);
        await _client.SubscribeAsync(new MqttTopicFilterBuilder()
            .WithTopic("large/dto")
            .Build());
    }

    public async Task StopAsync(CancellationToken cancellationToken)
    {
        var disconnectOptions = new MqttClientDisconnectOptions
        {
            Reason = MqttClientDisconnectOptionsReason.NormalDisconnection,
            ReasonString = "Service stopping"
        };

        await _client.DisconnectAsync(disconnectOptions, cancellationToken);
    }
}