3 Commits

10 changed files with 205 additions and 76 deletions

16
.vscode/tasks.json vendored
View File

@ -50,9 +50,7 @@
"build",
"-r",
"win-x64",
"${workspaceFolder}/Gatus-to-MonA.csproj",
"/property:GenerateFullPaths=true",
"/consoleloggerparameters:NoSummary"
"${workspaceFolder}/Gatus-to-MonA.csproj"
],
"problemMatcher": "$msCompile"
},
@ -64,9 +62,7 @@
"build",
"-r",
"linux-x64",
"${workspaceFolder}/Gatus-to-MonA.csproj",
"/property:GenerateFullPaths=true",
"/consoleloggerparameters:NoSummary"
"${workspaceFolder}/Gatus-to-MonA.csproj"
],
"problemMatcher": "$msCompile"
},
@ -91,9 +87,7 @@
"-c",
"Release",
"-p:PublishAot=true",
"${workspaceFolder}/Gatus-to-MonA.csproj",
"/property:GenerateFullPaths=true",
"/consoleloggerparameters:NoSummary"
"${workspaceFolder}/Gatus-to-MonA.csproj"
],
"problemMatcher": "$msCompile"
},
@ -108,9 +102,7 @@
"-c",
"Release",
"-p:PublishAot=true",
"${workspaceFolder}/Gatus-to-MonA.csproj",
"/property:GenerateFullPaths=true",
"/consoleloggerparameters:NoSummary"
"${workspaceFolder}/Gatus-to-MonA.csproj"
],
"problemMatcher": "$msCompile"
},

View File

@ -16,7 +16,7 @@
<PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.1" />
<PackageReference Include="Microsoft.Extensions.Logging.Console" Version="8.0.1" />
<PackageReference Include="Microsoft.Extensions.Logging.EventLog" Version="8.0.1" />
<PackageReference Include="runtime.win-x64.Microsoft.DotNet.ILCompiler" Version="8.0.15" />
<PackageReference Include="runtime.win-x64.Microsoft.DotNet.ILCompiler" Version="8.0.21" />
<PackageReference Include="System.Text.Json" Version="9.0.2" />
</ItemGroup>
</Project>

View File

@ -1,4 +1,5 @@
using System.Collections.ObjectModel;
using System.Net.Http.Headers;
using Gatus.To.MonA.Infineon.Monitoring.MonA;
using Gatus.To.MonA.Models;
@ -8,31 +9,34 @@ 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);
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) {
@ -43,19 +47,59 @@ internal static partial class HelperGatusToMona {
}
internal static bool UpdateCount(AppSettings appSettings, IHttpClientFactory httpClientFactory, ILogger<Worker> logger, CancellationToken cancellationToken) {
_MonIn ??= MonIn.GetInstance(httpClientFactory);
Heartbeat(appSettings, httpClientFactory, logger, State.Up, cancellationToken);
ReadOnlyCollection<string> successMatches = GetSuccessMatches(appSettings, logger, cancellationToken);
SendPerformanceMessage(appSettings, logger, successMatches, cancellationToken);
_HttpClient ??= httpClientFactory.CreateClient();
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;
@ -68,36 +112,26 @@ internal static partial class HelperGatusToMona {
if (value[^1] is not '0' and not '1')
continue;
logger.LogInformation("Line {line}: {value}",
39,
115,
value);
if (line.EndsWith('1'))
results.Add(string.Concat('{', value));
}
logger.LogInformation("Line {line}: {results}",
45,
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.URL, 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 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, ReadOnlyCollection<string> successMatches, CancellationToken cancellationToken) {
private static void SendPerformanceMessage(AppSettings appSettings, ILogger<Worker> logger, double value, 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,
@ -105,7 +139,7 @@ internal static partial class HelperGatusToMona {
description: string.Empty);
httpResponseMessage.Wait(cancellationToken);
logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {performanceName} ; {value}",
76,
142,
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
appSettings.MonAConfiguration.Resource,
performanceName,
@ -115,8 +149,40 @@ internal static partial class HelperGatusToMona {
Task<string> body = httpResponseMessage.Result.Content.ReadAsStringAsync(cancellationToken);
body.Wait(cancellationToken);
logger.LogInformation("Line {line}: {Result}",
86,
152,
body.Result);
}
private static void SendPerformanceMessage(AppSettings appSettings, ILogger<Worker> logger, HttpClient httpClient, double value, CancellationToken cancellationToken) {
Task<HttpResponseMessage> httpResponseMessage;
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}",
164,
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);
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}",
178,
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
appSettings.MonAConfiguration.Resource,
appSettings.GatusToGatusConfiguration.Key,
value);
if (httpResponseMessage.Result.StatusCode != System.Net.HttpStatusCode.OK)
throw new Exception(httpResponseMessage.Result.StatusCode.ToString());
}
}
}

View File

@ -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);

View File

@ -3,9 +3,11 @@ using System.Text.Json.Serialization;
namespace Gatus.To.MonA.Models;
public record GatusConfiguration(string FileName,
public record GatusConfiguration(string BaseUniformResourceLocator,
string FileName,
string Key,
string Metric,
string URL) {
string Token) {
public override string ToString() {
string result = JsonSerializer.Serialize(this, GatusConfigurationSourceGenerationContext.Default.GatusConfiguration);

View 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 {
}

View File

@ -6,7 +6,8 @@ namespace Gatus.To.MonA.Models;
public record GatusToMonaConfiguration(string Company,
string Directory,
string Helper,
int MillisecondsDelay) {
int MillisecondsDelay,
string? SyncDirectory) {
public override string ToString() {
string result = JsonSerializer.Serialize(this, GatusToMonaConfigurationSourceGenerationContext.Default.GatusToMonaConfiguration);

View File

@ -3,12 +3,13 @@ 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,
string StateName,
string Suffix) {
string Suffix,
bool Use) {
public override string ToString() {
string result = JsonSerializer.Serialize(this, MonAConfigurationSourceGenerationContext.Default.MonAConfiguration);

View File

@ -113,21 +113,21 @@ sc.exe create "Gatus-to-MonA" binpath="C:\Windows\System32\config\systemprofile\
## MonA Instances
- [MES_APC_GATUS](https://mona.auc.infineon.com/auc/systems/563556/dependencies?config=true)
- messa013ec.infineon.com
- [messa013ec.infineon.com](http://messa013ec.infineon.com:8082)
- [MES_EAF_GATUS](https://mona.auc.infineon.com/auc/systems/563493/dependencies?config=true)
- messa08ec.infineon.com
- [messa08ec.infineon.com](http://messa08ec.infineon.com:8082)
- [MES_EAF_STAGE_GATUS](https://mona.auc.infineon.com/auc/systems/563516/dependencies?config=true)
- mestsa07ec.infineon.com
- [mestsa07ec.infineon.com](http://mestsa07ec.infineon.com:8082)
- [MES_FAB_APPROVAL_SYSTEM_GATUS](https://mona.auc.infineon.com/auc/systems/563517/dependencies?config=true)
- messa016ec.infineon.com
- [messa016ec.infineon.com](http://messa016ec.infineon.com:8082)
- https://messa016ec.infineon.com
- [MES_FAB_TIME_GATUS](https://mona.auc.infineon.com/auc/systems/563518/dependencies?config=true)
- messa004.infineon.com
- [messa004.infineon.com](http://messa004.infineon.com:8082)
- [MES_INFINITY_QS_SI_GATUS](https://mona.auc.infineon.com/auc/systems/563519/dependencies?config=true)
- messa04ec.infineon.com
- [messa04ec.infineon.com](http://messa04ec.infineon.com:8082)
- [MES_OPEN_INSIGHT_GATUS](https://mona.auc.infineon.com/auc/systems/563520/dependencies?config=true)
- GATUS_CONFIG_PATH=./oi.yaml
- messa01ec.infineon.com
- [messa01ec.infineon.com](http://messa01ec.infineon.com:8082)
- http://messa014.infineon.com/api/heartbeat
- http://messa014.infineon.com/API/RemoteHealthCheck/Mona/MonaEngines/DB-EN1
- http://messa014.infineon.com/api/RemoteHealthCheck/Mona/MonaEngines/DB-EN10
@ -141,14 +141,56 @@ sc.exe create "Gatus-to-MonA" binpath="C:\Windows\System32\config\systemprofile\
- http://messa014.infineon.com/api/RemoteHealthCheck/Mona/MonaEngines/DB-EN7
- http://messa014.infineon.com/api/RemoteHealthCheck/Mona/MonaEngines/DB-EN9
- [MES_OPEN_INSIGHT_DEV_GATUS](https://mona.auc.infineon.com/auc/systems/563521/dependencies?config=true)
- mestsa01ec.infineon.com
- [mestsa01ec.infineon.com](http://mestsa01ec.infineon.com:8082)
- [MES_OI_METROLOGY_VIEWER_GATUS](https://mona.auc.infineon.com/auc/systems/557090/dependencies?config=true)
- messa010ec.infineon.com
- [messa010ec.infineon.com](http://messa010ec.infineon.com:8082)
- [MES_OI_WEB_SERVICES_GATUS](https://mona.auc.infineon.com/auc/systems/563522/dependencies?config=true)
- messa020ec.infineon.com
- [messa020ec.infineon.com](http://messa020ec.infineon.com:8082)
- ~~messa014.infineon.com~~
- https://messa014.infineon.com/scan
- https://messa014.infineon.com:50184
- https://messa014.infineon.com:5022
- [LEO_EAF_GATUS](https://mona.auc.infineon.com/auc/systems/563522/dependencies?config=true)
- leosaec17.infineon.com
- [leosaec17.infineon.com](http://leosaec17.infineon.com:8082)
## Prometheus config to consume Gatus metrics
- [prometheus](https://github.com/TwiN/gatus/blob/master/.examples/docker-compose-grafana-prometheus/README.md)
## Outline
### Goal
- Monitor TLS Cert
### Options
- Uptime Kuma
- Configuration is GUI driven
- Prometheus
- Not as easy to get started
- Grafana
- Too many features
- Open source but still have to login to use
### Benefits
- [x] Open Source
- [x] Written in GoLang
- [x] Doesn't need WAN connectivity
- [x] Keeps history with simple graph
- [x] Metrics output built for Prometheus
- [x] Sends e-mail alerts and has other alerting
- [x] Check status more often than five minute intervals
- [x] Single Config file that can be put in source control
- [x] Can wait for pushed data as well as default pull data
- [x] Simple GUI (website) that can be accessed outside server
- [x] Badge api that can be embedded in website (see oi server?)
- [x] Easy deployment [one binary, one config, runs via Non-Sucking Service Manager (nssm) and outputs sqlite files]
### Drawbacks
- [x] Another item to manage
- [x] Not part of the target solution
- [x] Haven't figured out how to push to MonIn directly with both heartbeat and performance

View File

@ -23,7 +23,7 @@ public partial class Worker : BackgroundService {
}
public override Task StopAsync(CancellationToken cancellationToken) {
if (_AppSettings.GatusToMonaConfiguration.Helper == nameof(Helpers.HelperGatusToMona))
if (_AppSettings.GatusToMonaConfiguration.Helper is nameof(Helpers.HelperGatusToMona))
Helpers.HelperGatusToMona.Heartbeat(_AppSettings, _HttpClientFactory, _Logger, Infineon.Monitoring.MonA.State.Down, cancellationToken);
return base.StopAsync(cancellationToken);
}
@ -31,6 +31,7 @@ public partial class Worker : BackgroundService {
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) {