gatus external-endpoints push main server

gatus external-endpoints push
2025-05-02 14:23:48 -07:00 · 2025-04-30 12:01:41 -07:00
5 changed files with 134 additions and 24 deletions
--- a/Helpers/HelperGatusToMona.cs
+++ b/Helpers/HelperGatusToMona.cs
@ -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,6 +9,7 @@ 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);
@ -21,7 +23,7 @@ internal static partial class HelperGatusToMona {
                                                                          state);
        httpResponseMessage.Wait(cancellationToken);
        logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {StateName} ; {state}",
-                              99,
+                              26,
                              httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
                              appSettings.MonAConfiguration.Resource,
                              appSettings.MonAConfiguration.StateName,
@ -31,7 +33,7 @@ internal static partial class HelperGatusToMona {
        Task<string> body = httpResponseMessage.Result.Content.ReadAsStringAsync(cancellationToken);
        body.Wait(cancellationToken);
        logger.LogInformation("Line {line}: {Result}",
-                              10,
+                              36,
                              body.Result);
    }

@ -44,9 +46,12 @@ 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);
-        SendPerformanceMessage(appSettings, logger, successMatches, cancellationToken);
+        double value = GetValue(appSettings, successMatches);
+        SendPerformanceMessage(appSettings, logger, value, cancellationToken);
+        SendPerformanceMessage(appSettings, logger, _HttpClient, value, cancellationToken);
        return true;
    }

@ -68,13 +73,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();
    }
@ -83,7 +88,7 @@ internal static partial class HelperGatusToMona {
        string[] results;
        FileStream fileStream = new(file, FileMode.Truncate);
        HttpClient httpClient = new();
-        Task<Stream> streamTask = httpClient.GetStreamAsync(appSettings.GatusConfiguration.URL, cancellationToken);
+        Task<Stream> streamTask = httpClient.GetStreamAsync($"{appSettings.GatusConfiguration.BaseUniformResourceLocator}/metrics", cancellationToken);
        streamTask.Wait(cancellationToken);
        Task task = streamTask.Result.CopyToAsync(fileStream, cancellationToken);
        task.Wait(cancellationToken);
@ -94,10 +99,15 @@ 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);
+    private static double GetValue(AppSettings appSettings, ReadOnlyCollection<string> successMatches) {
+        double result;
        double v = successMatches.Count / appSettings.MonAConfiguration.Expected;
-        double value = Math.Round(v, 3) * 100;
+        result = Math.Round(v, 3) * 100;
+        return result;
+    }
+
+    private static void SendPerformanceMessage(AppSettings appSettings, ILogger<Worker> logger, double value, CancellationToken cancellationToken) {
+        string performanceName = string.Concat(appSettings.MonAConfiguration.Resource, appSettings.MonAConfiguration.Suffix);
        Task<HttpResponseMessage> httpResponseMessage = _MonIn.SendPerformanceMessage(appSettings.MonAConfiguration.Site,
                                                                                      appSettings.MonAConfiguration.Resource,
                                                                                      performanceName,
@ -105,7 +115,7 @@ internal static partial class HelperGatusToMona {
                                                                                      description: string.Empty);
        httpResponseMessage.Wait(cancellationToken);
        logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {performanceName} ; {value}",
-                              76,
+                              118,
                              httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
                              appSettings.MonAConfiguration.Resource,
                              performanceName,
@ -115,8 +125,40 @@ internal static partial class HelperGatusToMona {
        Task<string> body = httpResponseMessage.Result.Content.ReadAsStringAsync(cancellationToken);
        body.Wait(cancellationToken);
        logger.LogInformation("Line {line}: {Result}",
-                              86,
+                              128,
                              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}",
+                              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);
+            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,
+                                  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());
+        }
+    }
+
 }
--- a/Models/AppSettings.cs
+++ b/Models/AppSettings.cs
@ -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);
--- a/Models/GatusConfiguration.cs
+++ b/Models/GatusConfiguration.cs
@ -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);
--- a/Models/GatusToGatusConfiguration.cs
+++ b/Models/GatusToGatusConfiguration.cs
@ -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 {
+}
--- a/README.md
+++ b/README.md
@ -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
Author	SHA1	Message	Date
Mike Phares	39bc20bc25	gatus external-endpoints push main server	2025-05-02 14:23:48 -07:00
Mike Phares	8cae455a50	gatus external-endpoints push	2025-04-30 12:01:41 -07:00