phares3757/gatus-to-mona
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor HelperGatusToMona to conditionally execute heartbeat and update performance message logic; update project dependencies and configuration models

Browse Source
This commit is contained in:
Mike Phares
2025-10-20 13:25:14 -07:00
parent 39bc20bc25
commit 3a307bb488
6 changed files with 88 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files

128
Helpers/HelperGatusToMona.cs
View File

@ -15,26 +15,28 @@ internal static partial class HelperGatusToMona {
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}",
26,
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}",
36,
body.Result);
if (appSettings.MonAConfiguration.Use) {
_MonIn ??= MonIn.GetInstance(httpClientFactory);
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}",
27,
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}",
37,
body.Result);
}
}
private static void CreateEmptyFile(AppSettings appSettings) {
@ -45,22 +47,59 @@ internal static partial class HelperGatusToMona {
}
internal static bool UpdateCount(AppSettings appSettings, IHttpClientFactory httpClientFactory, ILogger<Worker> logger, CancellationToken cancellationToken) {
_MonIn ??= MonIn.GetInstance(httpClientFactory);
_HttpClient ??= httpClientFactory.CreateClient();
Heartbeat(appSettings, httpClientFactory, logger, State.Up, cancellationToken);
ReadOnlyCollection<string> successMatches = GetSuccessMatches(appSettings, logger, cancellationToken);
double value = GetValue(appSettings, successMatches);
SendPerformanceMessage(appSettings, logger, value, cancellationToken);
if (appSettings.MonAConfiguration.Use) {
_MonIn ??= MonIn.GetInstance(httpClientFactory);
Heartbeat(appSettings, httpClientFactory, logger, State.Up, cancellationToken);
}
ReadOnlyCollection<string> lines = DownloadThenReadAllLinesMaybeSync(appSettings, logger, cancellationToken);
ReadOnlyCollection<string> successMatches = GetSuccessMatches(appSettings, logger, lines);
double value = (double)GetValue(appSettings, successMatches);
if (appSettings.MonAConfiguration.Use) {
SendPerformanceMessage(appSettings, logger, value, cancellationToken);
}
SendPerformanceMessage(appSettings, logger, _HttpClient, value, cancellationToken);
return true;
}
private static ReadOnlyCollection<string> GetSuccessMatches(AppSettings appSettings, ILogger<Worker> logger, CancellationToken cancellationToken) {
private static ReadOnlyCollection<string> DownloadThenReadAllLinesMaybeSync(AppSettings appSettings, ILogger<Worker> logger, CancellationToken cancellationToken) {
string[] results;
string file = GetFile(appSettings);
DownloadLines(appSettings, file, cancellationToken);
results = File.ReadAllLines(file);
if (!string.IsNullOrEmpty(appSettings.GatusToMonaConfiguration.SyncDirectory)) {
string text = string.Join(Environment.NewLine, results);
string path = Path.Combine(appSettings.GatusToMonaConfiguration.SyncDirectory, appSettings.GatusConfiguration.FileName);
try {
if (!Directory.Exists(appSettings.GatusToMonaConfiguration.SyncDirectory))
_ = Directory.CreateDirectory(appSettings.GatusToMonaConfiguration.SyncDirectory);
File.WriteAllText(path, text);
Directory.SetLastWriteTime(appSettings.GatusToMonaConfiguration.SyncDirectory, DateTime.Now);
} catch (Exception ex) {
logger.LogInformation("Exception {ex}: {ex}",
80,
$"{ex.Message}{Environment.NewLine}{ex.StackTrace}");
}
}
return results.AsReadOnly();
}
private static void DownloadLines(AppSettings appSettings, string file, CancellationToken cancellationToken) {
FileStream fileStream = new(file, FileMode.Truncate);
HttpClient httpClient = new();
Task<Stream> streamTask = httpClient.GetStreamAsync($"{appSettings.GatusConfiguration.BaseUniformResourceLocator}/metrics", cancellationToken);
streamTask.Wait(cancellationToken);
Task task = streamTask.Result.CopyToAsync(fileStream, cancellationToken);
task.Wait(cancellationToken);
fileStream.Dispose();
streamTask.Dispose();
httpClient.Dispose();
}
private static ReadOnlyCollection<string> GetSuccessMatches(AppSettings appSettings, ILogger<Worker> logger, ReadOnlyCollection<string> lines) {
List<string> results = [];
string value;
string[] segments;
string file = GetFile(appSettings);
ReadOnlyCollection<string> lines = GetLines(appSettings, file, cancellationToken);
foreach (string line in lines) {
if (!line.StartsWith(appSettings.GatusConfiguration.Metric))
continue;
@ -73,35 +112,20 @@ internal static partial class HelperGatusToMona {
if (value[^1] is not '0' and not '1')
continue;
logger.LogInformation("Line {line}: {value}",
76,
115,
value);
if (line.EndsWith('1'))
results.Add(string.Concat('{', value));
}
logger.LogInformation("Line {line}: {results}",
82,
121,
string.Join(Environment.NewLine, results));
return results.AsReadOnly();
}
private static ReadOnlyCollection<string> GetLines(AppSettings appSettings, string file, CancellationToken cancellationToken) {
string[] results;
FileStream fileStream = new(file, FileMode.Truncate);
HttpClient httpClient = new();
Task<Stream> streamTask = httpClient.GetStreamAsync($"{appSettings.GatusConfiguration.BaseUniformResourceLocator}/metrics", cancellationToken);
streamTask.Wait(cancellationToken);
Task task = streamTask.Result.CopyToAsync(fileStream, cancellationToken);
task.Wait(cancellationToken);
fileStream.Dispose();
streamTask.Dispose();
httpClient.Dispose();
results = File.ReadAllLines(file);
return results.AsReadOnly();
}
private static double GetValue(AppSettings appSettings, ReadOnlyCollection<string> successMatches) {
double result;
double v = successMatches.Count / appSettings.MonAConfiguration.Expected;
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;
}
@ -115,7 +139,7 @@ internal static partial class HelperGatusToMona {
description: string.Empty);
httpResponseMessage.Wait(cancellationToken);
logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {performanceName} ; {value}",
118,
142,
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
appSettings.MonAConfiguration.Resource,
performanceName,
@ -125,7 +149,7 @@ internal static partial class HelperGatusToMona {
Task<string> body = httpResponseMessage.Result.Content.ReadAsStringAsync(cancellationToken);
body.Wait(cancellationToken);
logger.LogInformation("Line {line}: {Result}",
128,
152,
body.Result);
}
@ -137,7 +161,7 @@ internal static partial class HelperGatusToMona {
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,
164,
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
appSettings.MonAConfiguration.Resource,
appSettings.GatusConfiguration.Key,
@ -151,10 +175,10 @@ internal static partial class HelperGatusToMona {
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} : {Key} ; {value}",
154,
178,
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
appSettings.MonAConfiguration.Resource,
appSettings.GatusConfiguration.Key,
appSettings.GatusToGatusConfiguration.Key,
value);
if (httpResponseMessage.Result.StatusCode != System.Net.HttpStatusCode.OK)
throw new Exception(httpResponseMessage.Result.StatusCode.ToString());