Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| ff998f9603 |
16
.vscode/tasks.json
vendored
16
.vscode/tasks.json
vendored
@ -50,7 +50,9 @@
|
|||||||
"build",
|
"build",
|
||||||
"-r",
|
"-r",
|
||||||
"win-x64",
|
"win-x64",
|
||||||
"${workspaceFolder}/Gatus-to-MonA.csproj"
|
"${workspaceFolder}/Gatus-to-MonA.csproj",
|
||||||
|
"/property:GenerateFullPaths=true",
|
||||||
|
"/consoleloggerparameters:NoSummary"
|
||||||
],
|
],
|
||||||
"problemMatcher": "$msCompile"
|
"problemMatcher": "$msCompile"
|
||||||
},
|
},
|
||||||
@ -62,7 +64,9 @@
|
|||||||
"build",
|
"build",
|
||||||
"-r",
|
"-r",
|
||||||
"linux-x64",
|
"linux-x64",
|
||||||
"${workspaceFolder}/Gatus-to-MonA.csproj"
|
"${workspaceFolder}/Gatus-to-MonA.csproj",
|
||||||
|
"/property:GenerateFullPaths=true",
|
||||||
|
"/consoleloggerparameters:NoSummary"
|
||||||
],
|
],
|
||||||
"problemMatcher": "$msCompile"
|
"problemMatcher": "$msCompile"
|
||||||
},
|
},
|
||||||
@ -87,7 +91,9 @@
|
|||||||
"-c",
|
"-c",
|
||||||
"Release",
|
"Release",
|
||||||
"-p:PublishAot=true",
|
"-p:PublishAot=true",
|
||||||
"${workspaceFolder}/Gatus-to-MonA.csproj"
|
"${workspaceFolder}/Gatus-to-MonA.csproj",
|
||||||
|
"/property:GenerateFullPaths=true",
|
||||||
|
"/consoleloggerparameters:NoSummary"
|
||||||
],
|
],
|
||||||
"problemMatcher": "$msCompile"
|
"problemMatcher": "$msCompile"
|
||||||
},
|
},
|
||||||
@ -102,7 +108,9 @@
|
|||||||
"-c",
|
"-c",
|
||||||
"Release",
|
"Release",
|
||||||
"-p:PublishAot=true",
|
"-p:PublishAot=true",
|
||||||
"${workspaceFolder}/Gatus-to-MonA.csproj"
|
"${workspaceFolder}/Gatus-to-MonA.csproj",
|
||||||
|
"/property:GenerateFullPaths=true",
|
||||||
|
"/consoleloggerparameters:NoSummary"
|
||||||
],
|
],
|
||||||
"problemMatcher": "$msCompile"
|
"problemMatcher": "$msCompile"
|
||||||
},
|
},
|
||||||
|
|||||||
@ -16,7 +16,7 @@
|
|||||||
<PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.1" />
|
<PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.1" />
|
||||||
<PackageReference Include="Microsoft.Extensions.Logging.Console" 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="Microsoft.Extensions.Logging.EventLog" Version="8.0.1" />
|
||||||
<PackageReference Include="runtime.win-x64.Microsoft.DotNet.ILCompiler" Version="8.0.21" />
|
<PackageReference Include="runtime.win-x64.Microsoft.DotNet.ILCompiler" Version="8.0.15" />
|
||||||
<PackageReference Include="System.Text.Json" Version="9.0.2" />
|
<PackageReference Include="System.Text.Json" Version="9.0.2" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
</Project>
|
</Project>
|
||||||
@ -1,44 +1,17 @@
|
|||||||
using System.Collections.ObjectModel;
|
using System.Collections.ObjectModel;
|
||||||
using System.Net.Http.Headers;
|
using System.Net.Http.Headers;
|
||||||
|
|
||||||
using Gatus.To.MonA.Infineon.Monitoring.MonA;
|
|
||||||
using Gatus.To.MonA.Models;
|
using Gatus.To.MonA.Models;
|
||||||
|
|
||||||
namespace Gatus.To.MonA.Helpers;
|
namespace Gatus.To.MonA.Helpers;
|
||||||
|
|
||||||
internal static partial class HelperGatusToMona {
|
internal static partial class HelperGatusToMona {
|
||||||
|
|
||||||
private static IMonIn? _MonIn;
|
|
||||||
private static HttpClient? _HttpClient;
|
private static HttpClient? _HttpClient;
|
||||||
|
|
||||||
private static string GetFile(AppSettings appSettings) =>
|
private static string GetFile(AppSettings appSettings) =>
|
||||||
Path.Combine(appSettings.GatusToMonaConfiguration.Directory, appSettings.GatusConfiguration.FileName);
|
Path.Combine(appSettings.GatusToMonaConfiguration.Directory, appSettings.GatusConfiguration.FileName);
|
||||||
|
|
||||||
internal static void Heartbeat(AppSettings appSettings, IHttpClientFactory httpClientFactory, ILogger<Worker> logger, State state, CancellationToken cancellationToken) {
|
|
||||||
CreateEmptyFile(appSettings);
|
|
||||||
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) {
|
private static void CreateEmptyFile(AppSettings appSettings) {
|
||||||
if (!Directory.Exists(appSettings.GatusToMonaConfiguration.Directory))
|
if (!Directory.Exists(appSettings.GatusToMonaConfiguration.Directory))
|
||||||
_ = Directory.CreateDirectory(appSettings.GatusToMonaConfiguration.Directory);
|
_ = Directory.CreateDirectory(appSettings.GatusToMonaConfiguration.Directory);
|
||||||
@ -48,58 +21,18 @@ internal static partial class HelperGatusToMona {
|
|||||||
|
|
||||||
internal static bool UpdateCount(AppSettings appSettings, IHttpClientFactory httpClientFactory, ILogger<Worker> logger, CancellationToken cancellationToken) {
|
internal static bool UpdateCount(AppSettings appSettings, IHttpClientFactory httpClientFactory, ILogger<Worker> logger, CancellationToken cancellationToken) {
|
||||||
_HttpClient ??= httpClientFactory.CreateClient();
|
_HttpClient ??= httpClientFactory.CreateClient();
|
||||||
if (appSettings.MonAConfiguration.Use) {
|
ReadOnlyCollection<string> successMatches = GetSuccessMatches(appSettings, logger, cancellationToken);
|
||||||
_MonIn ??= MonIn.GetInstance(httpClientFactory);
|
decimal value = GetValue(appSettings, successMatches);
|
||||||
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);
|
SendPerformanceMessage(appSettings, logger, _HttpClient, value, cancellationToken);
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static ReadOnlyCollection<string> DownloadThenReadAllLinesMaybeSync(AppSettings appSettings, ILogger<Worker> logger, CancellationToken cancellationToken) {
|
private static ReadOnlyCollection<string> GetSuccessMatches(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 = [];
|
List<string> results = [];
|
||||||
string value;
|
string value;
|
||||||
string[] segments;
|
string[] segments;
|
||||||
|
string file = GetFile(appSettings);
|
||||||
|
ReadOnlyCollection<string> lines = GetLines(appSettings, file, cancellationToken);
|
||||||
foreach (string line in lines) {
|
foreach (string line in lines) {
|
||||||
if (!line.StartsWith(appSettings.GatusConfiguration.Metric))
|
if (!line.StartsWith(appSettings.GatusConfiguration.Metric))
|
||||||
continue;
|
continue;
|
||||||
@ -112,17 +45,32 @@ internal static partial class HelperGatusToMona {
|
|||||||
if (value[^1] is not '0' and not '1')
|
if (value[^1] is not '0' and not '1')
|
||||||
continue;
|
continue;
|
||||||
logger.LogInformation("Line {line}: {value}",
|
logger.LogInformation("Line {line}: {value}",
|
||||||
115,
|
76,
|
||||||
value);
|
value);
|
||||||
if (line.EndsWith('1'))
|
if (line.EndsWith('1'))
|
||||||
results.Add(string.Concat('{', value));
|
results.Add(string.Concat('{', value));
|
||||||
}
|
}
|
||||||
logger.LogInformation("Line {line}: {results}",
|
logger.LogInformation("Line {line}: {results}",
|
||||||
121,
|
82,
|
||||||
string.Join(Environment.NewLine, results));
|
string.Join(Environment.NewLine, results));
|
||||||
return results.AsReadOnly();
|
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 decimal GetValue(AppSettings appSettings, ReadOnlyCollection<string> successMatches) {
|
private static decimal GetValue(AppSettings appSettings, ReadOnlyCollection<string> successMatches) {
|
||||||
decimal result;
|
decimal result;
|
||||||
decimal v = successMatches.Count / appSettings.MonAConfiguration.Expected;
|
decimal v = successMatches.Count / appSettings.MonAConfiguration.Expected;
|
||||||
@ -130,59 +78,34 @@ internal static partial class HelperGatusToMona {
|
|||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void SendPerformanceMessage(AppSettings appSettings, ILogger<Worker> logger, double value, CancellationToken cancellationToken) {
|
private static void SendPerformanceMessage(AppSettings appSettings, ILogger<Worker> logger, HttpClient httpClient, decimal 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,
|
|
||||||
value,
|
|
||||||
description: string.Empty);
|
|
||||||
httpResponseMessage.Wait(cancellationToken);
|
|
||||||
logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {performanceName} ; {value}",
|
|
||||||
142,
|
|
||||||
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
|
|
||||||
appSettings.MonAConfiguration.Resource,
|
|
||||||
performanceName,
|
|
||||||
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}",
|
|
||||||
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 success = value == 100 ? "true" : "false";
|
||||||
string error = value == 100 ? string.Empty : $"value: {value}%;";
|
string error = value == 100 ? string.Empty : $"value: {value}%;";
|
||||||
httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", appSettings.GatusConfiguration.Token);
|
// 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 = 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);
|
httpResponseMessage.Wait(cancellationToken);
|
||||||
logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {Key} ; {value}",
|
logger.LogInformation("Line {line}: {OriginalString} => {Resource} : {Key} ; {value}",
|
||||||
164,
|
154,
|
||||||
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
|
httpResponseMessage.Result.RequestMessage.RequestUri.OriginalString,
|
||||||
appSettings.MonAConfiguration.Resource,
|
appSettings.MonAConfiguration.Resource,
|
||||||
appSettings.GatusConfiguration.Key,
|
appSettings.GatusToGatusConfiguration.Key,
|
||||||
value);
|
value);
|
||||||
if (httpResponseMessage.Result.StatusCode != System.Net.HttpStatusCode.OK)
|
if (httpResponseMessage.Result.StatusCode != System.Net.HttpStatusCode.OK)
|
||||||
throw new Exception(httpResponseMessage.Result.StatusCode.ToString());
|
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());
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@ -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,
|
|
||||||
}
|
|
||||||
@ -5,9 +5,7 @@ namespace Gatus.To.MonA.Models;
|
|||||||
|
|
||||||
public record GatusConfiguration(string BaseUniformResourceLocator,
|
public record GatusConfiguration(string BaseUniformResourceLocator,
|
||||||
string FileName,
|
string FileName,
|
||||||
string Key,
|
string Metric) {
|
||||||
string Metric,
|
|
||||||
string Token) {
|
|
||||||
|
|
||||||
public override string ToString() {
|
public override string ToString() {
|
||||||
string result = JsonSerializer.Serialize(this, GatusConfigurationSourceGenerationContext.Default.GatusConfiguration);
|
string result = JsonSerializer.Serialize(this, GatusConfigurationSourceGenerationContext.Default.GatusConfiguration);
|
||||||
|
|||||||
@ -6,8 +6,7 @@ namespace Gatus.To.MonA.Models;
|
|||||||
public record GatusToMonaConfiguration(string Company,
|
public record GatusToMonaConfiguration(string Company,
|
||||||
string Directory,
|
string Directory,
|
||||||
string Helper,
|
string Helper,
|
||||||
int MillisecondsDelay,
|
int MillisecondsDelay) {
|
||||||
string? SyncDirectory) {
|
|
||||||
|
|
||||||
public override string ToString() {
|
public override string ToString() {
|
||||||
string result = JsonSerializer.Serialize(this, GatusToMonaConfigurationSourceGenerationContext.Default.GatusToMonaConfiguration);
|
string result = JsonSerializer.Serialize(this, GatusToMonaConfigurationSourceGenerationContext.Default.GatusToMonaConfiguration);
|
||||||
|
|||||||
@ -8,8 +8,7 @@ public record MonAConfiguration(decimal Expected,
|
|||||||
string Resource,
|
string Resource,
|
||||||
string Site,
|
string Site,
|
||||||
string StateName,
|
string StateName,
|
||||||
string Suffix,
|
string Suffix) {
|
||||||
bool Use) {
|
|
||||||
|
|
||||||
public override string ToString() {
|
public override string ToString() {
|
||||||
string result = JsonSerializer.Serialize(this, MonAConfigurationSourceGenerationContext.Default.MonAConfiguration);
|
string result = JsonSerializer.Serialize(this, MonAConfigurationSourceGenerationContext.Default.MonAConfiguration);
|
||||||
|
|||||||
@ -22,11 +22,8 @@ public partial class Worker : BackgroundService {
|
|||||||
_IsWindowsService = collection.Contains(nameof(WindowsServiceLifetime));
|
_IsWindowsService = collection.Contains(nameof(WindowsServiceLifetime));
|
||||||
}
|
}
|
||||||
|
|
||||||
public override Task StopAsync(CancellationToken cancellationToken) {
|
public override Task StopAsync(CancellationToken cancellationToken) =>
|
||||||
if (_AppSettings.GatusToMonaConfiguration.Helper is nameof(Helpers.HelperGatusToMona))
|
base.StopAsync(cancellationToken);
|
||||||
Helpers.HelperGatusToMona.Heartbeat(_AppSettings, _HttpClientFactory, _Logger, Infineon.Monitoring.MonA.State.Down, cancellationToken);
|
|
||||||
return base.StopAsync(cancellationToken);
|
|
||||||
}
|
|
||||||
|
|
||||||
private async Task Body(CancellationToken cancellationToken) {
|
private async Task Body(CancellationToken cancellationToken) {
|
||||||
if (!_IsWindowsService) {
|
if (!_IsWindowsService) {
|
||||||
|
|||||||
Reference in New Issue
Block a user