using System.Net.MQTT;

// Create client
var options = new MqttClientOptions
{
    Host = "localhost",
    Port = 1883,
    ClientId = "my-client",
    CleanSession = true
};

using var client = new MqttClient(options);

// Event handlers
client.MessageReceived += (s, e) =>
{
    Console.WriteLine($"Received: {e.Message.Topic} = {e.Message.PayloadAsString}");
};

// Connect
await client.ConnectAsync();

// Subscribe
await client.SubscribeAsync("sensors/#", MqttQualityOfService.AtLeastOnce);

// Publish
await client.PublishAsync("sensors/temperature", "25.5");

// Disconnect
await client.DisconnectAsync();

using System.Net.MQTT.Broker;

// Create broker
var options = new MqttBrokerOptions
{
    Port = 1883,
    AllowAnonymous = true
};

using var broker = new MqttBroker(options);

// Event handlers
broker.ClientConnected += (s, e) =>
{
    Console.WriteLine($"Client connected: {e.Session.ClientId}");
};

broker.MessagePublished += (s, e) =>
{
    Console.WriteLine($"Message: {e.Message.Topic} = {e.Message.PayloadAsString}");
};

// Start broker
await broker.StartAsync();

// Wait for shutdown signal
await Task.Delay(Timeout.Infinite);

// Stop broker
await broker.StopAsync();

// Simple username/password authentication
var authenticator = new SimpleAuthenticator()
    .AddUser("admin", "password")
    .AddUser("user1", "pass123");

broker.Authenticator = authenticator;

public class MyAuthenticator : IMqttAuthenticator
{
    public async Task<bool> AuthenticateAsync(
        string clientId,
        string? username,
        string? password,
        CancellationToken cancellationToken)
    {
        // Your authentication logic
        return await ValidateCredentialsAsync(username, password);
    }
}

var options = new MqttClientOptions
{
    Host = "broker.example.com",
    Port = 8883,
    UseTls = true,
    ClientCertificate = new X509Certificate2("client.pfx", "password"),
    SkipCertificateValidation = false // Set true for self-signed certs
};

var options = new MqttBrokerOptions
{
    UseTls = true,
    TlsPort = 8883,
    ServerCertificate = new X509Certificate2("server.pfx", "password"),
    RequireClientCertificate = false
};

// QoS 0 - Fire and forget
await client.PublishAsync("topic", "message", MqttQualityOfService.AtMostOnce);

// QoS 1 - At least once
await client.PublishAsync("topic", "message", MqttQualityOfService.AtLeastOnce);

// QoS 2 - Exactly once
await client.PublishAsync("topic", "message", MqttQualityOfService.ExactlyOnce);

// Match: sensors/living-room/temperature, sensors/bedroom/temperature
await client.SubscribeAsync("sensors/+/temperature");

// Match: sensors/*, sensors/room1/*, sensors/room1/temp, etc.
await client.SubscribeAsync("sensors/#");

var options = new MqttClientOptions
{
    Host = "localhost",
    WillMessage = MqttApplicationMessage.Create(
        topic: "clients/my-client/status",
        payload: "offline",
        qos: MqttQualityOfService.AtLeastOnce,
        retain: true
    )
};