30 lines
720 B
C#
30 lines
720 B
C#
|
using Microsoft.AspNetCore.Http;
|
|||
|
|
using Microsoft.AspNetCore.Mvc;
|
|||
|
|
using MQTTnet.Server;
|
|||
|
|
namespace iotweb.Controllers
|
|||
|
|
{
|
|||
|
|
[Route("api/[controller]/[action]")]
|
|||
|
|
[ApiController]
|
|||
|
|
public class ValuesController : ControllerBase
|
|||
|
|
{
|
|||
|
|
private readonly MqttServer _mqttServer;
|
|||
|
|
|
|||
|
|
public ValuesController(MqttServer mqttServer)
|
|||
|
|
{
|
|||
|
|
_mqttServer = mqttServer;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
[HttpGet()]
|
|||
|
|
public async Task<IActionResult> GetConnectedClients()
|
|||
|
|
{
|
|||
|
|
var clients = await _mqttServer.GetClientsAsync();
|
|||
|
|
return Ok(clients.Select(c => new
|
|||
|
|
{
|
|||
|
|
Id = c.Id,
|
|||
|
|
Endpoint = c.Endpoint
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|