using MQTTnet.AspNetCore;
using MQTTnet.AspNetCore.Routing;

var builder = WebApplication.CreateBuilder(args);
builder.WebHost.ConfigureKestrel(o =>
    {
        o.ListenAnyIP(iotaboardMqttSettings.Port, l => l.UseMqtt());
        o.ListenAnyIP(iotaboardHttpSettings.Port);
    }
);

//配置MQTT服务
builder.Services
    .AddHostedMqttServerWithServices(o =>
    {
        // other configurations
        o.WithoutDefaultEndpoint();
    })
    .AddMqttConnectionHandler()
    .AddConnections()
    .AddMqttControllers( // <== NOTICE THIS PART
    /*
       默认情况下，所有控制类在这里都会被自动发现， 那么这里就是空的， 但是这里也提供了加入其他程序集的方法。
    */); 
    
var app = builder.Build();

app.MapControllers();
app.UseMqttServer(server => {  
    // other MqttServer configurations, for example client connect intercepts
    server.WithAttributeRouting(app.Services, allowUnmatchedRoutes: false);
});
app.Run();

[MqttController]
[MqttRoute("[controller]")] // 指定控制类topic 。
public class MqttWeatherForecastController : MqttBaseController 
{
    private readonly ILogger<MqttWeatherForecastController> _logger;

    // Controllers支持完整的注入依赖， 就像AspNetCore 控制器一样。
    public MqttWeatherForecastController(ILogger<MqttWeatherForecastController> logger)
    {
        _logger = logger;
    }

    //支持模板路由和类型定义就像AspNetCore一样。
    // Action 路由与控制器级别的路由前缀一起组成
    [MqttRoute("{zipCode:int}/temperature")]
    public Task WeatherReport(int zipCode)
    {
        // 我们这里可以直接访问MqttContext
        if (zipCode != 90210) { MqttContext.CloseConnection = true; }

        // 我们可以直接访问原始数据
        var temperature = BitConverter.ToDouble(Message.Payload);

        _logger.LogInformation($"It's {temperature} degrees in Hollywood");

        // 规则判断
        if (temperature <= 0 || temperature >= 130)
        {
            return BadMessage();
        }

        return Ok();
}

        //我们也支持 FromPayload ， 就像 AspNetCore中的FromBody 一样。

        [MqttRoute("viewmodel/{sender}")]

        public Task DeserializeViewModel(string sender, [FromPayload] SamplePayload payload)

        {

           

            _logger.LogInformation("{Sender} says {Message}", sender, payload.Message);
            return Accepted();

        }

}

public class SamplePayload

{

    public string Message { get; set; }

}