Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| ff998f9603 | |||
| 39bc20bc25 |
@ -1,42 +1,17 @@
|
||||
using System.Collections.ObjectModel;
|
||||
using System.Net.Http.Headers;
|
||||
|
||||
using Gatus.To.MonA.Infineon.Monitoring.MonA;
|
||||
using Gatus.To.MonA.Models;
|
||||
|
||||
namespace Gatus.To.MonA.Helpers;
|
||||
|
||||
internal static partial class HelperGatusToMona {
|
||||
|
||||
private static IMonIn? _MonIn;
|
||||
private static HttpClient? _HttpClient;
|
||||
|
||||
private static string GetFile(AppSettings appSettings) =>
|
||||
Path.Combine(appSettings.GatusToMonaConfiguration.Directory, appSettings.GatusConfiguration.FileName);
|
||||
|
||||
internal static void Heartbeat(AppSettings appSettings, IHttpClientFactory httpClientFactory, ILogger<Worker> logger, State state, CancellationToken cancellationToken) {
|
||||
_MonIn ??= MonIn.GetInstance(httpClientFactory);
|
||||
CreateEmptyFile(appSettings);
|
||||
Task<HttpResponseMessage> httpResponseMessage = _MonIn.SendStatus(appSettings.MonAConfiguration.Site,
|
||||
appSettings.MonAConfiguration.Resource,
|
||||
appSettings.MonAConfiguration.StateName,
|
||||
state);
|
||||
httpResponseMessage.Wait(cancellationToken);
|
||||
logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {StateName} ; {state}",
|
||||
99,
|
||||
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
|
||||
appSettings.MonAConfiguration.Resource,
|
||||
appSettings.MonAConfiguration.StateName,
|
||||
state);
|
||||
if (httpResponseMessage.Result.StatusCode != System.Net.HttpStatusCode.OK)
|
||||
throw new Exception(httpResponseMessage.Result.StatusCode.ToString());
|
||||
Task<string> body = httpResponseMessage.Result.Content.ReadAsStringAsync(cancellationToken);
|
||||
body.Wait(cancellationToken);
|
||||
logger.LogInformation("Line {line}: {Result}",
|
||||
10,
|
||||
body.Result);
|
||||
}
|
||||
|
||||
private static void CreateEmptyFile(AppSettings appSettings) {
|
||||
if (!Directory.Exists(appSettings.GatusToMonaConfiguration.Directory))
|
||||
_ = Directory.CreateDirectory(appSettings.GatusToMonaConfiguration.Directory);
|
||||
@ -45,18 +20,10 @@ internal static partial class HelperGatusToMona {
|
||||
}
|
||||
|
||||
internal static bool UpdateCount(AppSettings appSettings, IHttpClientFactory httpClientFactory, ILogger<Worker> logger, CancellationToken cancellationToken) {
|
||||
_MonIn ??= MonIn.GetInstance(httpClientFactory);
|
||||
if (_HttpClient is null) {
|
||||
_HttpClient = httpClientFactory.CreateClient();
|
||||
_HttpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", appSettings.GatusConfiguration.Token);
|
||||
}
|
||||
Task<HttpResponseMessage> httpResponseMessage = _HttpClient.PostAsync($"{appSettings.GatusConfiguration.BaseUniformResourceLocator}/api/v1/endpoints/{appSettings.GatusConfiguration.Key}/external?success=true&error=", null, cancellationToken);
|
||||
httpResponseMessage.Wait(cancellationToken);
|
||||
if (httpResponseMessage.Result.StatusCode != System.Net.HttpStatusCode.OK)
|
||||
logger.LogWarning("Result is {statusCode}", httpResponseMessage.Result.StatusCode);
|
||||
Heartbeat(appSettings, httpClientFactory, logger, State.Up, cancellationToken);
|
||||
_HttpClient ??= httpClientFactory.CreateClient();
|
||||
ReadOnlyCollection<string> successMatches = GetSuccessMatches(appSettings, logger, cancellationToken);
|
||||
SendPerformanceMessage(appSettings, logger, successMatches, cancellationToken);
|
||||
decimal value = GetValue(appSettings, successMatches);
|
||||
SendPerformanceMessage(appSettings, logger, _HttpClient, value, cancellationToken);
|
||||
return true;
|
||||
}
|
||||
|
||||
@ -78,13 +45,13 @@ internal static partial class HelperGatusToMona {
|
||||
if (value[^1] is not '0' and not '1')
|
||||
continue;
|
||||
logger.LogInformation("Line {line}: {value}",
|
||||
39,
|
||||
76,
|
||||
value);
|
||||
if (line.EndsWith('1'))
|
||||
results.Add(string.Concat('{', value));
|
||||
}
|
||||
logger.LogInformation("Line {line}: {results}",
|
||||
45,
|
||||
82,
|
||||
string.Join(Environment.NewLine, results));
|
||||
return results.AsReadOnly();
|
||||
}
|
||||
@ -104,29 +71,41 @@ internal static partial class HelperGatusToMona {
|
||||
return results.AsReadOnly();
|
||||
}
|
||||
|
||||
private static void SendPerformanceMessage(AppSettings appSettings, ILogger<Worker> logger, ReadOnlyCollection<string> successMatches, CancellationToken cancellationToken) {
|
||||
string performanceName = string.Concat(appSettings.MonAConfiguration.Resource, appSettings.MonAConfiguration.Suffix);
|
||||
double v = successMatches.Count / appSettings.MonAConfiguration.Expected;
|
||||
double value = Math.Round(v, 3) * 100;
|
||||
Task<HttpResponseMessage> httpResponseMessage = _MonIn.SendPerformanceMessage(appSettings.MonAConfiguration.Site,
|
||||
appSettings.MonAConfiguration.Resource,
|
||||
performanceName,
|
||||
value,
|
||||
description: string.Empty);
|
||||
private static decimal GetValue(AppSettings appSettings, ReadOnlyCollection<string> successMatches) {
|
||||
decimal result;
|
||||
decimal v = successMatches.Count / appSettings.MonAConfiguration.Expected;
|
||||
result = Math.Round(v, 3) * 100;
|
||||
return result;
|
||||
}
|
||||
|
||||
private static void SendPerformanceMessage(AppSettings appSettings, ILogger<Worker> logger, HttpClient httpClient, decimal value, CancellationToken cancellationToken) {
|
||||
string success = value == 100 ? "true" : "false";
|
||||
string error = value == 100 ? string.Empty : $"value: {value}%;";
|
||||
// httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", appSettings.GatusConfiguration.Token);
|
||||
// httpResponseMessage = httpClient.PostAsync($"{appSettings.GatusConfiguration.BaseUniformResourceLocator}/api/v1/endpoints/{appSettings.GatusConfiguration.Key}/external?success={success}&error={error}", null, cancellationToken);
|
||||
// httpResponseMessage.Wait(cancellationToken);
|
||||
// logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {Key} ; {value}",
|
||||
// 140,
|
||||
// httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
|
||||
// appSettings.MonAConfiguration.Resource,
|
||||
// appSettings.GatusConfiguration.Key,
|
||||
// value);
|
||||
// if (httpResponseMessage.Result.StatusCode != System.Net.HttpStatusCode.OK)
|
||||
// throw new Exception(httpResponseMessage.Result.StatusCode.ToString());
|
||||
// if (!string.IsNullOrEmpty(appSettings.GatusToGatusConfiguration.BaseUniformResourceLocator)
|
||||
// && !string.IsNullOrEmpty(appSettings.GatusToGatusConfiguration.Key)
|
||||
// && !string.IsNullOrEmpty(appSettings.GatusToGatusConfiguration.Token)) { }
|
||||
httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", appSettings.GatusToGatusConfiguration.Token);
|
||||
Task<HttpResponseMessage> httpResponseMessage = httpClient.PostAsync($"{appSettings.GatusToGatusConfiguration.BaseUniformResourceLocator}/api/v1/endpoints/{appSettings.GatusToGatusConfiguration.Key}/external?success={success}&error={error}", null, cancellationToken);
|
||||
httpResponseMessage.Wait(cancellationToken);
|
||||
logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {performanceName} ; {value}",
|
||||
76,
|
||||
logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {Key} ; {value}",
|
||||
154,
|
||||
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
|
||||
appSettings.MonAConfiguration.Resource,
|
||||
performanceName,
|
||||
appSettings.GatusToGatusConfiguration.Key,
|
||||
value);
|
||||
if (httpResponseMessage.Result.StatusCode != System.Net.HttpStatusCode.OK)
|
||||
throw new Exception(httpResponseMessage.Result.StatusCode.ToString());
|
||||
Task<string> body = httpResponseMessage.Result.Content.ReadAsStringAsync(cancellationToken);
|
||||
body.Wait(cancellationToken);
|
||||
logger.LogInformation("Line {line}: {Result}",
|
||||
86,
|
||||
body.Result);
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,144 +0,0 @@
|
||||
namespace Gatus.To.MonA.Infineon.Monitoring.MonA;
|
||||
|
||||
public interface IMonIn {
|
||||
Task<HttpResponseMessage> SendStatus(string site, string resource, string stateName, State state);
|
||||
|
||||
Task<HttpResponseMessage> SendStatus(string site,
|
||||
DateTime timeStamp,
|
||||
string resource,
|
||||
string stateName,
|
||||
State state);
|
||||
|
||||
Task<HttpResponseMessage> SendStatus(string site,
|
||||
string resource,
|
||||
string stateName,
|
||||
State state,
|
||||
string description);
|
||||
|
||||
Task<HttpResponseMessage> SendStatus(string site,
|
||||
DateTime timeStamp,
|
||||
string resource,
|
||||
string stateName,
|
||||
State state,
|
||||
string description);
|
||||
|
||||
Task<HttpResponseMessage> SendStatus(string site,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
State state);
|
||||
|
||||
Task<HttpResponseMessage> SendStatus(string site,
|
||||
DateTime timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
State state);
|
||||
|
||||
Task<HttpResponseMessage> SendStatus(string site,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
State state,
|
||||
string description);
|
||||
|
||||
Task<HttpResponseMessage> SendStatus(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
State state,
|
||||
string description);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value,
|
||||
int? interval);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
DateTime? timeStamp,
|
||||
string performanceName,
|
||||
double value,
|
||||
string unit);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string unit,
|
||||
int? interval);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
int? interval);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string unit);
|
||||
|
||||
Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description,
|
||||
string unit,
|
||||
int? interval);
|
||||
}
|
||||
@ -1,250 +0,0 @@
|
||||
using System.Globalization;
|
||||
using System.Text;
|
||||
|
||||
namespace Gatus.To.MonA.Infineon.Monitoring.MonA;
|
||||
|
||||
public class MonIn : IMonIn {
|
||||
private readonly string _MonInUrl;
|
||||
private readonly HttpClient _HttpClient;
|
||||
private static CultureInfo? _CultureInfo;
|
||||
private static readonly Dictionary<string, MonIn> _Instances = [];
|
||||
public const string MonInUrl = "http://moninhttp.{0}.infineon.com/input/text";
|
||||
private static readonly DateTime _Utc1970DateTime = new(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
|
||||
|
||||
public Task<HttpResponseMessage> SendStatus(string site, string resource, string stateName, State state) =>
|
||||
SendStatus(site, new DateTime?(), resource, string.Empty, stateName, state, string.Empty);
|
||||
|
||||
public Task<HttpResponseMessage> SendStatus(string site,
|
||||
DateTime timeStamp,
|
||||
string resource,
|
||||
string stateName,
|
||||
State state) =>
|
||||
SendStatus(site, new DateTime?(timeStamp), resource, string.Empty, stateName, state, string.Empty);
|
||||
|
||||
public Task<HttpResponseMessage> SendStatus(string site,
|
||||
string resource,
|
||||
string stateName,
|
||||
State state,
|
||||
string description) =>
|
||||
SendStatus(site, new DateTime?(), resource, string.Empty, stateName, state, description);
|
||||
|
||||
public Task<HttpResponseMessage> SendStatus(string site,
|
||||
DateTime timeStamp,
|
||||
string resource,
|
||||
string stateName,
|
||||
State state,
|
||||
string description) =>
|
||||
SendStatus(site, new DateTime?(timeStamp), resource, string.Empty, stateName, state, description);
|
||||
|
||||
public Task<HttpResponseMessage> SendStatus(string site,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
State state) =>
|
||||
SendStatus(site, new DateTime?(), resource, subResource, stateName, state, string.Empty);
|
||||
|
||||
public Task<HttpResponseMessage> SendStatus(string site,
|
||||
DateTime timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
State state) =>
|
||||
SendStatus(site, new DateTime?(timeStamp), resource, subResource, stateName, state, string.Empty);
|
||||
|
||||
public Task<HttpResponseMessage> SendStatus(string site,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
State state,
|
||||
string description) =>
|
||||
SendStatus(site, new DateTime?(), resource, subResource, stateName, state, description);
|
||||
|
||||
public Task<HttpResponseMessage> SendStatus(
|
||||
string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
State state,
|
||||
string description) {
|
||||
string statusMessage = CreateStatusMessage(site, timeStamp, resource, subResource, stateName, state.ToString(), description);
|
||||
StringContent stringContent = new(statusMessage, Encoding.UTF8, "application/text");
|
||||
lock (_HttpClient)
|
||||
return _HttpClient.PostAsync(string.Format(_MonInUrl, site), stringContent);
|
||||
}
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value) =>
|
||||
SendPerformanceMessage(site, new DateTime?(), resource, string.Empty, performanceName, value, string.Empty, string.Empty, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value) =>
|
||||
SendPerformanceMessage(site, timeStamp, resource, string.Empty, performanceName, value, string.Empty, string.Empty, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description) =>
|
||||
SendPerformanceMessage(site, new DateTime?(), resource, string.Empty, performanceName, value, description, string.Empty, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description) =>
|
||||
SendPerformanceMessage(site, timeStamp, resource, string.Empty, performanceName, value, description, string.Empty, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value,
|
||||
int? interval) =>
|
||||
SendPerformanceMessage(site, timeStamp, resource, string.Empty, performanceName, value, string.Empty, string.Empty, interval);
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
DateTime? timeStamp,
|
||||
string performanceName,
|
||||
double value,
|
||||
string unit) =>
|
||||
SendPerformanceMessage(site, timeStamp, resource, string.Empty, performanceName, value, string.Empty, unit, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string unit,
|
||||
int? interval) =>
|
||||
SendPerformanceMessage(site, timeStamp, resource, string.Empty, performanceName, value, string.Empty, unit, interval);
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value) =>
|
||||
SendPerformanceMessage(site, new DateTime?(), resource, subResource, performanceName, value, string.Empty, string.Empty, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value) =>
|
||||
SendPerformanceMessage(site, timeStamp, resource, subResource, performanceName, value, string.Empty, string.Empty, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description) =>
|
||||
SendPerformanceMessage(site, new DateTime?(), resource, subResource, performanceName, value, description, string.Empty, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
int? interval) =>
|
||||
SendPerformanceMessage(site, timeStamp, resource, subResource, performanceName, value, string.Empty, string.Empty, interval);
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string unit) =>
|
||||
SendPerformanceMessage(site, timeStamp, resource, subResource, performanceName, value, string.Empty, unit, new int?());
|
||||
|
||||
public Task<HttpResponseMessage> SendPerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description,
|
||||
string unit,
|
||||
int? interval) {
|
||||
string performanceMessage = CreatePerformanceMessage(site, timeStamp, resource, subResource, performanceName, value, description, unit, interval);
|
||||
StringContent stringContent = new(performanceMessage, Encoding.UTF8, "application/text");
|
||||
lock (_HttpClient)
|
||||
return _HttpClient.PostAsync(string.Format(_MonInUrl, site), stringContent);
|
||||
}
|
||||
|
||||
private static string CreateStatusMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string stateName,
|
||||
string state,
|
||||
string description) {
|
||||
StringBuilder stringBuilder = new();
|
||||
if (string.IsNullOrEmpty(subResource))
|
||||
_ = stringBuilder.AppendFormat(_CultureInfo, "> {0} {1} \"{2}\" \"{3}\" {4} \n{5}", site.Trim(), timeStamp.HasValue ? GetDateTimeNowAsPosix(timeStamp.Value) : (object)"now", resource.Trim(), stateName.Trim(), state.Trim(), description.Trim());
|
||||
else
|
||||
_ = stringBuilder.AppendFormat(_CultureInfo, "> {0} {1} \"{2}\" \"{3}\" \"{4}\" {5} \n{6}", site.Trim(), timeStamp.HasValue ? GetDateTimeNowAsPosix(timeStamp.Value) : (object)"now", resource.Trim(), subResource.Trim(), stateName.Trim(), state.Trim(), description.Trim());
|
||||
return stringBuilder.ToString();
|
||||
}
|
||||
|
||||
private static string CreatePerformanceMessage(string site,
|
||||
DateTime? timeStamp,
|
||||
string resource,
|
||||
string subResource,
|
||||
string performanceName,
|
||||
double value,
|
||||
string description,
|
||||
string unit,
|
||||
int? interval) {
|
||||
StringBuilder stringBuilder = new();
|
||||
if (string.IsNullOrEmpty(subResource)) {
|
||||
if (unit.Equals(string.Empty) && !interval.HasValue)
|
||||
_ = stringBuilder.AppendFormat(_CultureInfo, "> {0} {1} \"{2}\" \"{3}\" {4} \n{5}", site.Trim(), timeStamp.HasValue ? GetDateTimeNowAsPosix(timeStamp.Value) : (object)"now", resource.Trim(), performanceName.Trim(), value, description.Trim());
|
||||
else
|
||||
_ = stringBuilder.AppendFormat(_CultureInfo, "> {0} {1} \"{2}\" \"{3}\" {4} {5} {{interval={6}, unit={7}}}\n", site.Trim(), timeStamp.HasValue ? GetDateTimeNowAsPosix(timeStamp.Value) : (object)"now", resource.Trim(), performanceName.Trim(), value, description.Trim(), interval.HasValue ? interval.Value.ToString() : (object)string.Empty, unit.Trim());
|
||||
} else if (unit.Equals(string.Empty) && !interval.HasValue)
|
||||
_ = stringBuilder.AppendFormat(_CultureInfo, "> {0} {1} \"{2}\" \"{3}\" \"{4}\" {5} \n{6}", site.Trim(), timeStamp.HasValue ? GetDateTimeNowAsPosix(timeStamp.Value) : (object)"now", resource.Trim(), subResource.Trim(), performanceName.Trim(), value, description.Trim());
|
||||
else
|
||||
_ = stringBuilder.AppendFormat(_CultureInfo, "> {0} {1} \"{2}\" \"{3}\" \"{4}\" {5} {6} {{interval={7}, unit={8}}}\n", site.Trim(), timeStamp.HasValue ? GetDateTimeNowAsPosix(timeStamp.Value) : (object)"now", resource.Trim(), subResource.Trim(), performanceName.Trim(), value, description.Trim(), interval.HasValue ? interval.Value.ToString() : (object)string.Empty, unit.Trim());
|
||||
return stringBuilder.ToString();
|
||||
}
|
||||
|
||||
public static MonIn GetInstance(IHttpClientFactory httpClientFactory, string url = MonInUrl) {
|
||||
MonIn instance;
|
||||
if (_Instances.ContainsKey(url)) {
|
||||
instance = _Instances[url];
|
||||
} else {
|
||||
lock (_Instances) {
|
||||
if (!_Instances.ContainsKey(url)) {
|
||||
instance = new MonIn(httpClientFactory, url);
|
||||
_Instances.Add(url, instance);
|
||||
} else
|
||||
instance = _Instances[url];
|
||||
}
|
||||
}
|
||||
return instance;
|
||||
}
|
||||
|
||||
private MonIn(IHttpClientFactory httpClientFactory, string url) {
|
||||
_MonInUrl = url;
|
||||
_CultureInfo = new CultureInfo("en-US");
|
||||
_HttpClient = httpClientFactory.CreateClient();
|
||||
}
|
||||
|
||||
private static string GetDateTimeNowAsPosix(DateTime timeStamp) {
|
||||
if (timeStamp > DateTime.Now)
|
||||
timeStamp = DateTime.Now;
|
||||
return ((int)timeStamp.ToUniversalTime().Subtract(_Utc1970DateTime).TotalSeconds).ToString(CultureInfo.InvariantCulture);
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,10 +0,0 @@
|
||||
namespace Gatus.To.MonA.Infineon.Monitoring.MonA;
|
||||
|
||||
public enum State {
|
||||
Up,
|
||||
Ok,
|
||||
Warning,
|
||||
Critical,
|
||||
Down,
|
||||
Unknown,
|
||||
}
|
||||
@ -4,6 +4,7 @@ using System.Text.Json.Serialization;
|
||||
namespace Gatus.To.MonA.Models;
|
||||
|
||||
public record AppSettings(GatusConfiguration GatusConfiguration,
|
||||
GatusToGatusConfiguration GatusToGatusConfiguration,
|
||||
GatusToMonaConfiguration GatusToMonaConfiguration,
|
||||
MonAConfiguration MonAConfiguration) {
|
||||
|
||||
@ -11,10 +12,12 @@ public record AppSettings(GatusConfiguration GatusConfiguration,
|
||||
AppSettings result;
|
||||
#pragma warning disable IL3050, IL2026
|
||||
GatusConfiguration? gatusConfiguration = configurationRoot.GetSection(nameof(GatusConfiguration)).Get<GatusConfiguration>();
|
||||
GatusToGatusConfiguration? gatusToGatusConfiguration = configurationRoot.GetSection(nameof(GatusToGatusConfiguration)).Get<GatusToGatusConfiguration>();
|
||||
GatusToMonaConfiguration? gatusToMonaConfiguration = configurationRoot.GetSection(nameof(GatusToMonaConfiguration)).Get<GatusToMonaConfiguration>();
|
||||
MonAConfiguration? monAConfiguration = configurationRoot.GetSection(nameof(MonAConfiguration)).Get<MonAConfiguration>();
|
||||
#pragma warning restore IL3050, IL2026
|
||||
if (gatusConfiguration is null
|
||||
|| gatusToGatusConfiguration is null
|
||||
|| gatusToMonaConfiguration is null
|
||||
|| monAConfiguration is null
|
||||
|| gatusToMonaConfiguration?.Company is null) {
|
||||
@ -29,6 +32,7 @@ public record AppSettings(GatusConfiguration GatusConfiguration,
|
||||
throw new NotSupportedException($"Not found!{Environment.NewLine}{string.Join(Environment.NewLine, paths.Distinct())}");
|
||||
}
|
||||
result = new(gatusConfiguration,
|
||||
gatusToGatusConfiguration,
|
||||
gatusToMonaConfiguration,
|
||||
monAConfiguration);
|
||||
Verify(result);
|
||||
|
||||
@ -5,9 +5,7 @@ namespace Gatus.To.MonA.Models;
|
||||
|
||||
public record GatusConfiguration(string BaseUniformResourceLocator,
|
||||
string FileName,
|
||||
string Key,
|
||||
string Metric,
|
||||
string Token) {
|
||||
string Metric) {
|
||||
|
||||
public override string ToString() {
|
||||
string result = JsonSerializer.Serialize(this, GatusConfigurationSourceGenerationContext.Default.GatusConfiguration);
|
||||
|
||||
20
Models/GatusToGatusConfiguration.cs
Normal file
20
Models/GatusToGatusConfiguration.cs
Normal file
@ -0,0 +1,20 @@
|
||||
using System.Text.Json;
|
||||
using System.Text.Json.Serialization;
|
||||
|
||||
namespace Gatus.To.MonA.Models;
|
||||
|
||||
public record GatusToGatusConfiguration(string? BaseUniformResourceLocator,
|
||||
string? Key,
|
||||
string? Token) {
|
||||
|
||||
public override string ToString() {
|
||||
string result = JsonSerializer.Serialize(this, GatusToGatusConfigurationSourceGenerationContext.Default.GatusToGatusConfiguration);
|
||||
return result;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
[JsonSourceGenerationOptions(WriteIndented = true)]
|
||||
[JsonSerializable(typeof(GatusToGatusConfiguration))]
|
||||
internal partial class GatusToGatusConfigurationSourceGenerationContext : JsonSerializerContext {
|
||||
}
|
||||
@ -3,7 +3,7 @@ using System.Text.Json.Serialization;
|
||||
|
||||
namespace Gatus.To.MonA.Models;
|
||||
|
||||
public record MonAConfiguration(int Expected,
|
||||
public record MonAConfiguration(decimal Expected,
|
||||
int Minutes,
|
||||
string Resource,
|
||||
string Site,
|
||||
|
||||
@ -22,15 +22,13 @@ public partial class Worker : BackgroundService {
|
||||
_IsWindowsService = collection.Contains(nameof(WindowsServiceLifetime));
|
||||
}
|
||||
|
||||
public override Task StopAsync(CancellationToken cancellationToken) {
|
||||
if (_AppSettings.GatusToMonaConfiguration.Helper == nameof(Helpers.HelperGatusToMona))
|
||||
Helpers.HelperGatusToMona.Heartbeat(_AppSettings, _HttpClientFactory, _Logger, Infineon.Monitoring.MonA.State.Down, cancellationToken);
|
||||
return base.StopAsync(cancellationToken);
|
||||
}
|
||||
public override Task StopAsync(CancellationToken cancellationToken) =>
|
||||
base.StopAsync(cancellationToken);
|
||||
|
||||
private async Task Body(CancellationToken cancellationToken) {
|
||||
if (!_IsWindowsService) {
|
||||
_Logger.LogInformation("Set break point and skip to run {_AppSettings.GatusToMonaConfiguration.Helper}!", _AppSettings.GatusToMonaConfiguration.Helper);
|
||||
BodyInner(cancellationToken);
|
||||
throw new EvaluateException($"Set break point and skip to run {_AppSettings.GatusToMonaConfiguration.Helper}!");
|
||||
}
|
||||
if (!_IsWindowsService) {
|
||||
|
||||
Reference in New Issue
Block a user