/
Hubitat.cs
82 lines (69 loc) · 2.99 KB
/
Hubitat.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
using System;
using System.Net;
using System.Net.Http;
using System.Net.Http.Json;
using System.Text.Json;
using System.Text.Json.Serialization;
using System.Threading.Tasks;
using hubitat2prom.HubitatDevice;
using hubitat2prom.JsonConverters;
namespace hubitat2prom;
public class Hubitat
{
private Uri _baseUri;
private string _authToken;
private IHttpClientFactory _httpClientFactory;
private HttpClient _httpClient => _httpClientFactory.CreateClient();
public Hubitat(Uri baseUri, Guid authToken, IHttpClientFactory httpClientFactory)
{
_baseUri = baseUri;
_authToken = authToken.ToString("D");
_httpClientFactory = httpClientFactory;
}
private UriBuilder _authenticatedUriBuilder()
{
var uriBuilder = new UriBuilder(_baseUri);
uriBuilder.Query = $"access_token={_authToken}";
return uriBuilder;
}
public async Task<HttpStatusCode> StatusCheck()
{
var uriBuilder = _authenticatedUriBuilder();
var response = await _httpClient.GetAsync(uriBuilder.ToString());
return response.StatusCode;
}
public async Task<DeviceSummary[]> Devices()
{
var uriBuilder = _authenticatedUriBuilder();
var result = await _httpClient.GetFromJsonAsync<DeviceSummary[]>(uriBuilder.ToString());
return result;
}
public Task<DeviceDetails> DeviceDetails(DeviceSummary device) => DeviceDetails(int.Parse(device.id));
public async Task<DeviceDetails> DeviceDetails(int deviceId)
{
var uriBuilder = _authenticatedUriBuilder();
uriBuilder.PathAppend(deviceId.ToString());
var jsonSerializerOptions = new JsonSerializerOptions();
jsonSerializerOptions.Converters.Add(new DynamicJsonConverter());
jsonSerializerOptions.Converters.Add(new DeviceSummaryAttributesDynamicJsonConverter());
jsonSerializerOptions.Converters.Add(new OneOfDoubleStringNullableJsonConverter());
jsonSerializerOptions.Converters.Add(new OneOfStringHubitatDeviceCapabilitiesJsonConverter());
var result = await _httpClient.GetFromJsonAsync<DeviceDetails>(uriBuilder.ToString(), jsonSerializerOptions);
return result;
}
public async Task<DeviceDetailSummary[]> DeviceDetails()
{
var uriBuilder = _authenticatedUriBuilder();
uriBuilder.PathAppend("all");
var jsonSerializerOptions = new JsonSerializerOptions
{
NumberHandling = JsonNumberHandling.AllowReadingFromString,
};
jsonSerializerOptions.Converters.Add(new DynamicJsonConverter());
jsonSerializerOptions.Converters.Add(new DeviceSummaryAttributesDynamicJsonConverter());
jsonSerializerOptions.Converters.Add(new OneOfDoubleStringNullableJsonConverter());
jsonSerializerOptions.Converters.Add(new OneOfStringHubitatDeviceCapabilitiesJsonConverter());
var result = await _httpClient.GetFromJsonAsync<DeviceDetailSummary[]>(uriBuilder.ToString(), jsonSerializerOptions);
return result;
}
}