diff --git a/Adaptation/FileHandlers/CellInstanceConnectionName.cs b/Adaptation/FileHandlers/CellInstanceConnectionName.cs index 5c17383..18d1665 100644 --- a/Adaptation/FileHandlers/CellInstanceConnectionName.cs +++ b/Adaptation/FileHandlers/CellInstanceConnectionName.cs @@ -27,6 +27,7 @@ public class CellInstanceConnectionName nameof(R6) => new R6.FileRead(smtp, fileParameter, cellInstanceName, connectionCount, cellInstanceConnectionName, fileConnectorConfiguration, equipmentTypeName, parameterizedModelObjectDefinitionType, modelObjectParameters, equipmentDictionaryName, dummyRuns, staticRuns, useCyclicalForDescription, isEAFHosted: connectionCount is null), nameof(R7) => new R7.FileRead(smtp, fileParameter, cellInstanceName, connectionCount, cellInstanceConnectionName, fileConnectorConfiguration, equipmentTypeName, parameterizedModelObjectDefinitionType, modelObjectParameters, equipmentDictionaryName, dummyRuns, staticRuns, useCyclicalForDescription, isEAFHosted: connectionCount is null), nameof(Source) => new Source.FileRead(smtp, fileParameter, cellInstanceName, connectionCount, cellInstanceConnectionName, fileConnectorConfiguration, equipmentTypeName, parameterizedModelObjectDefinitionType, modelObjectParameters, equipmentDictionaryName, dummyRuns, staticRuns, useCyclicalForDescription, isEAFHosted: connectionCount is null), + nameof(StatusQueryV2InstanceStatuses) => new StatusQueryV2InstanceStatuses.FileRead(smtp, fileParameter, cellInstanceName, connectionCount, cellInstanceConnectionName, fileConnectorConfiguration, equipmentTypeName, parameterizedModelObjectDefinitionType, modelObjectParameters, equipmentDictionaryName, dummyRuns, staticRuns, useCyclicalForDescription, isEAFHosted: connectionCount is null), _ => throw new Exception($"\"{cellInstanceConnectionName}\" not mapped") }; return result; diff --git a/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/ArrayOfRuntimeInstanceStatusReport.cs b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/ArrayOfRuntimeInstanceStatusReport.cs new file mode 100644 index 0000000..2fd67ee --- /dev/null +++ b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/ArrayOfRuntimeInstanceStatusReport.cs @@ -0,0 +1,18 @@ +using System; +using System.Xml; +using System.Xml.Serialization; + +namespace Adaptation.FileHandlers.StatusQueryV2InstanceStatuses; + +#nullable enable +#pragma warning disable IDE0027 + +[Serializable()] +[XmlType(Namespace = "http://schemas.datacontract.org/2004/07/EafManagement.Monitoring")] +[XmlRoot(Namespace = "http://schemas.datacontract.org/2004/07/EafManagement.Monitoring", IsNullable = false)] +public partial class ArrayOfRuntimeInstanceStatusReport { + + [XmlElement("RuntimeInstanceStatusReport", Order = 0)] + public RuntimeInstanceStatusReport[]? RuntimeInstanceStatusReport { get; set; } + +} \ No newline at end of file diff --git a/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/EquipmentState.cs b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/EquipmentState.cs new file mode 100644 index 0000000..a4c73bd --- /dev/null +++ b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/EquipmentState.cs @@ -0,0 +1,19 @@ +using System; +using System.Xml.Serialization; + +namespace Adaptation.FileHandlers.StatusQueryV2InstanceStatuses; + +#nullable enable +#pragma warning disable IDE0027 + +[Serializable()] +[XmlType(Namespace = "http://schemas.datacontract.org/2004/07/EafManagement.Monitoring")] +[XmlRoot(Namespace = "http://schemas.datacontract.org/2004/07/EafManagement.Monitoring", IsNullable = false)] +public partial class EquipmentState { + + public bool? IsCommunicating { get; set; } + public bool? IsConnected { get; set; } + public string? CommunicationState { get; set; } + public string? Name { get; set; } + +} \ No newline at end of file diff --git a/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/FileRead.cs b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/FileRead.cs new file mode 100644 index 0000000..5cd23b5 --- /dev/null +++ b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/FileRead.cs @@ -0,0 +1,248 @@ +using Adaptation.Eaf.Management.ConfigurationData.CellAutomation; +using Adaptation.Ifx.Eaf.EquipmentConnector.File.Configuration; +using Adaptation.Shared; +using Adaptation.Shared.Duplicator; +using Adaptation.Shared.Methods; +using log4net; +using System; +using System.Collections.Generic; +using System.Diagnostics; +using System.IO; +using System.Net.Http; +using System.Text.Json; +using System.Threading; +using System.Xml; +using System.Xml.Serialization; + +namespace Adaptation.FileHandlers.StatusQueryV2InstanceStatuses; + +#nullable enable + +public class FileRead : Shared.FileRead, IFileRead +{ + + private readonly Timer _Timer; + private readonly HttpClient _HttpClient; + + public FileRead(ISMTP smtp, Dictionary fileParameter, string cellInstanceName, int? connectionCount, string cellInstanceConnectionName, FileConnectorConfiguration fileConnectorConfiguration, string equipmentTypeName, string parameterizedModelObjectDefinitionType, IList modelObjectParameters, string equipmentDictionaryName, Dictionary> dummyRuns, Dictionary> staticRuns, bool useCyclicalForDescription, bool isEAFHosted) : + base(new Description(), false, smtp, fileParameter, cellInstanceName, connectionCount, cellInstanceConnectionName, fileConnectorConfiguration, equipmentTypeName, parameterizedModelObjectDefinitionType, modelObjectParameters, equipmentDictionaryName, dummyRuns, staticRuns, useCyclicalForDescription, isEAFHosted: connectionCount is null) + { + _MinFileLength = 10; + _NullData = string.Empty; + _Logistics = new(this); + if (_FileParameter is null) + throw new Exception(cellInstanceConnectionName); + if (_ModelObjectParameterDefinitions is null) + throw new Exception(cellInstanceConnectionName); + string statusQueryV2URL = GetPropertyValue(cellInstanceConnectionName, modelObjectParameters, "Status.Query.V2.URL"); + _HttpClient = new(new HttpClientHandler() { UseDefaultCredentials = true }) { BaseAddress = new(statusQueryV2URL) }; + if (!Debugger.IsAttached && fileConnectorConfiguration.PreProcessingMode != FileConnectorConfiguration.PreProcessingModeEnum.Process && fileConnectorConfiguration.FileScanningIntervalInSeconds is not null) + _Timer = new Timer(Callback, null, (int)(fileConnectorConfiguration.FileScanningIntervalInSeconds.Value * 1000), Timeout.Infinite); + else + { + _Timer = new Timer(Callback, null, Timeout.Infinite, Timeout.Infinite); + Callback(null); + } + } + + void IFileRead.Move(Tuple> extractResults, Exception exception) + { + bool isErrorFile = exception is not null; + if (!isErrorFile && !string.IsNullOrEmpty(_Logistics.ReportFullPath)) + { + FileInfo fileInfo = new(_Logistics.ReportFullPath); + if (fileInfo.Exists && fileInfo.LastWriteTime < fileInfo.CreationTime) + File.SetLastWriteTime(_Logistics.ReportFullPath, fileInfo.CreationTime); + } + Move(extractResults); + } + + void IFileRead.WaitForThread() => + WaitForThread(thread: null, threadExceptions: null); + + string IFileRead.GetEventDescription() + { + string result = _Description.GetEventDescription(); + return result; + } + + List IFileRead.GetHeaderNames() + { + List results = _Description.GetHeaderNames(); + return results; + } + + string[] IFileRead.Move(Tuple> extractResults, string to, string from, string resolvedFileLocation, Exception exception) + { + string[] results = Move(extractResults, to, from, resolvedFileLocation, exception); + return results; + } + + JsonProperty[] IFileRead.GetDefault() + { + JsonProperty[] results = _Description.GetDefault(this, _Logistics); + return results; + } + + Dictionary IFileRead.GetDisplayNamesJsonElement() + { + Dictionary results = _Description.GetDisplayNamesJsonElement(this); + return results; + } + + List IFileRead.GetDescriptions(IFileRead fileRead, List tests, IProcessData processData) + { + List results = _Description.GetDescriptions(fileRead, _Logistics, tests, processData); + return results; + } + + Tuple> IFileRead.GetExtractResult(string reportFullPath, string eventName) + { + Tuple> results; + if (string.IsNullOrEmpty(eventName)) + throw new Exception(); + _ReportFullPath = reportFullPath; + DateTime dateTime = DateTime.Now; + results = GetExtractResult(reportFullPath, dateTime); + if (results.Item3 is null) + results = new Tuple>(results.Item1, Array.Empty(), Array.Empty(), results.Item4); + if (results.Item3.Length > 0 && _IsEAFHosted) + WritePDSF(this, results.Item3); + UpdateLastTicksDuration(DateTime.Now.Ticks - dateTime.Ticks); + return results; + } + + Tuple> IFileRead.ReExtract() + { + Tuple> results; + List headerNames = _Description.GetHeaderNames(); + Dictionary keyValuePairs = _Description.GetDisplayNamesJsonElement(this); + results = ReExtract(this, headerNames, keyValuePairs); + return results; + } + + private Tuple> GetExtractResult(string reportFullPath, DateTime dateTime) => + throw new Exception(string.Concat("See ", nameof(Callback))); + + private void ExportXmlToJson() + { + string xml; + string sourceDirectory = Path.GetFullPath(_FileConnectorConfiguration.SourceFileLocation); + string fileName = Path.Combine(sourceDirectory, $"{_FileConnectorConfiguration.SourceFileFilter}.xml"); + if (!Directory.Exists(sourceDirectory)) + _ = Directory.CreateDirectory(sourceDirectory); + _Log.Info($"Downloading from URL: {_HttpClient.BaseAddress}"); + HttpResponseMessage httpResponseMessage = _HttpClient.GetAsync(_HttpClient.BaseAddress).Result; + xml = httpResponseMessage.Content.ReadAsStringAsync().Result; + File.WriteAllText(fileName, xml); + _Log.Info($"File saved: {fileName}"); + Parse(_Log, sourceDirectory, _FileConnectorConfiguration.SourceFileFilter, xml); + } + + private static void Parse(ILog log, string sourceDirectory, string name, string xml) + { + ArrayOfRuntimeInstanceStatusReport? arrayOfRuntimeInstanceStatusReport = ParseXML(xml, throwExceptions: true); + if (arrayOfRuntimeInstanceStatusReport is not null) + WriteAllText(log, sourceDirectory, name, arrayOfRuntimeInstanceStatusReport); + } + + private static T? ParseXML(string value, bool throwExceptions) where T : class + { + object? result; + try + { + Stream stream = ToStream(value.Trim()); + XmlReader xmlReader = XmlReader.Create(stream, new XmlReaderSettings() { ConformanceLevel = ConformanceLevel.Document }); +#pragma warning disable IL2026, IL2090 + XmlSerializer xmlSerializer = new(typeof(T), typeof(T).GetNestedTypes()); + result = xmlSerializer.Deserialize(xmlReader); +#pragma warning restore IL2026, IL2090 + stream.Dispose(); + } + catch (Exception) + { + result = null; + if (throwExceptions) + throw; + } + return result as T; + } + + private static MemoryStream ToStream(string value) + { + MemoryStream memoryStream = new(); + StreamWriter streamWriter = new(memoryStream); + streamWriter.Write(value); + streamWriter.Flush(); + memoryStream.Position = 0; + return memoryStream; + } + + private static void WriteAllText(ILog log, string sourceDirectory, string name, ArrayOfRuntimeInstanceStatusReport arrayOfRuntimeInstanceStatusReport) + { + string json; + string fileName = Path.Combine(sourceDirectory, $"{name}.json"); + JsonSerializerOptions jsonSerializerOptions = new() { WriteIndented = true }; + json = Serialize(jsonSerializerOptions, arrayOfRuntimeInstanceStatusReport) + .Replace("\"\"", "null") + .Replace("\"true\"", "true") + .Replace("\"True\"", "true") + .Replace("\"false\"", "false") + .Replace("\"False\"", "false"); + File.WriteAllText(fileName, json); + log.Info($"File saved: {fileName}"); + Record[]? records = JsonSerializer.Deserialize(json, RecordSourceGenerationContext.Default.RecordArray); + if (records is not null) + { + string key; + Dictionary keyValuePairs = new(); + foreach (Record record in records) + { + key = $"{record.CellInstanceName}"; + if (!keyValuePairs.ContainsKey(key)) + keyValuePairs.Add(key, record); + if (record.Startable is null || !record.Startable.Value) + continue; + log.Info($"CellInstanceName: {record.CellInstanceName}, MachineName: {record.MachineName}, State: {record.State}, ErrorDescription: {record.ErrorDescription}"); + } + json = JsonSerializer.Serialize(keyValuePairs, DictionaryStringRecordSourceGenerationContext.Default.DictionaryStringRecord); + File.WriteAllText($"{fileName}.json", json); + } + + } + + private static string Serialize(JsonSerializerOptions jsonSerializerOptions, ArrayOfRuntimeInstanceStatusReport arrayOfRuntimeInstanceStatusReport) => +#pragma warning disable IL3050, IL2026 + JsonSerializer.Serialize(arrayOfRuntimeInstanceStatusReport.RuntimeInstanceStatusReport, jsonSerializerOptions); +#pragma warning restore IL3050, IL2026 + + private void Callback(object? state) + { + try + { ExportXmlToJson(); } + catch (Exception exception) + { + string subject = string.Concat("Exception:", _CellInstanceConnectionName); + string body = string.Concat(exception.Message, Environment.NewLine, Environment.NewLine, exception.StackTrace); + try + { _SMTP.SendHighPriorityEmailMessage(subject, body); } + catch (Exception) { } + } + try + { + if (_FileConnectorConfiguration.FileScanningIntervalInSeconds is null) + throw new NotImplementedException(); + TimeSpan timeSpan = new(DateTime.Now.AddSeconds(_FileConnectorConfiguration.FileScanningIntervalInSeconds.Value).Ticks - DateTime.Now.Ticks); + _ = _Timer.Change((long)timeSpan.TotalMilliseconds, Timeout.Infinite); + } + catch (Exception exception) + { + string subject = string.Concat("Exception:", _CellInstanceConnectionName); + string body = string.Concat(exception.Message, Environment.NewLine, Environment.NewLine, exception.StackTrace); + try + { _SMTP.SendHighPriorityEmailMessage(subject, body); } + catch (Exception) { } + } + } + +} \ No newline at end of file diff --git a/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/Record.cs b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/Record.cs new file mode 100644 index 0000000..3ce5605 --- /dev/null +++ b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/Record.cs @@ -0,0 +1,109 @@ +using System.Collections.Generic; +using System.Text.Json.Serialization; + +namespace Adaptation.FileHandlers.StatusQueryV2InstanceStatuses; + +#nullable enable + +internal class Record +{ + + [JsonConstructor] + public Record(string? cellInstanceName, + string? currentActiveVersion, + string? currentHost, + string? currentLoggingConfigurationName, + string? currentLoggingConfigurationVersion, + EquipmentState[]? equipmentStates, + string? errorDescription, + string? info, + bool? isAutomatedRestartActive, + bool? isAutomatedRestartRequested, + bool? isPilot, + bool? isReadyForRestart, + string? lastKnownCurrentActiveVersion, + string? machineName, + object pilotVersion, + string? runtimeInstanceName, + bool? startable, + string? startTime, + string? state, + string? stopTime, + string? targetActiveVersion, + string? targetHost, + string? targetLoggingConfigurationName, + string? targetLoggingConfigurationVersion, + string? timestamp, + int? updatePeriod, + string? windowsName) + { + CellInstanceName = cellInstanceName; + CurrentActiveVersion = currentActiveVersion; + CurrentHost = currentHost; + CurrentLoggingConfigurationName = currentLoggingConfigurationName; + CurrentLoggingConfigurationVersion = currentLoggingConfigurationVersion; + EquipmentStates = equipmentStates; + ErrorDescription = errorDescription; + Info = info; + IsAutomatedRestartActive = isAutomatedRestartActive; + IsAutomatedRestartRequested = isAutomatedRestartRequested; + IsPilot = isPilot; + IsReadyForRestart = isReadyForRestart; + LastKnownCurrentActiveVersion = lastKnownCurrentActiveVersion; + MachineName = machineName; + PilotVersion = pilotVersion; + RuntimeInstanceName = runtimeInstanceName; + Startable = startable; + StartTime = startTime; + State = state; + StopTime = stopTime; + TargetActiveVersion = targetActiveVersion; + TargetHost = targetHost; + TargetLoggingConfigurationName = targetLoggingConfigurationName; + TargetLoggingConfigurationVersion = targetLoggingConfigurationVersion; + Timestamp = timestamp; + UpdatePeriod = updatePeriod; + WindowsName = windowsName; + } + + [JsonPropertyName("CellInstanceName")] public string? CellInstanceName { get; } + [JsonPropertyName("CurrentActiveVersion")] public string? CurrentActiveVersion { get; } + [JsonPropertyName("CurrentHost")] public string? CurrentHost { get; } + [JsonPropertyName("CurrentLoggingConfigurationName")] public string? CurrentLoggingConfigurationName { get; } + [JsonPropertyName("CurrentLoggingConfigurationVersion")] public string? CurrentLoggingConfigurationVersion { get; } + [JsonPropertyName("EquipmentStates")] public EquipmentState[]? EquipmentStates { get; } + [JsonPropertyName("ErrorDescription")] public string? ErrorDescription { get; } + [JsonPropertyName("Info")] public string? Info { get; } + [JsonPropertyName("IsAutomatedRestartActive")] public bool? IsAutomatedRestartActive { get; } + [JsonPropertyName("IsAutomatedRestartRequested")] public bool? IsAutomatedRestartRequested { get; } + [JsonPropertyName("IsPilot")] public bool? IsPilot { get; } + [JsonPropertyName("IsReadyForRestart")] public bool? IsReadyForRestart { get; } + [JsonPropertyName("LastKnownCurrentActiveVersion")] public string? LastKnownCurrentActiveVersion { get; } + [JsonPropertyName("MachineName")] public string? MachineName { get; } + [JsonPropertyName("PilotVersion")] public object PilotVersion { get; } + [JsonPropertyName("RuntimeInstanceName")] public string? RuntimeInstanceName { get; } + [JsonPropertyName("Startable")] public bool? Startable { get; } + [JsonPropertyName("StartTime")] public string? StartTime { get; } + [JsonPropertyName("State")] public string? State { get; } + [JsonPropertyName("StopTime")] public string? StopTime { get; } + [JsonPropertyName("TargetActiveVersion")] public string? TargetActiveVersion { get; } + [JsonPropertyName("TargetHost")] public string? TargetHost { get; } + [JsonPropertyName("TargetLoggingConfigurationName")] public string? TargetLoggingConfigurationName { get; } + [JsonPropertyName("TargetLoggingConfigurationVersion")] public string? TargetLoggingConfigurationVersion { get; } + [JsonPropertyName("Timestamp")] public string? Timestamp { get; } + [JsonPropertyName("UpdatePeriod")] public int? UpdatePeriod { get; } + [JsonPropertyName("WindowsName")] public string? WindowsName { get; } + +} + +[JsonSourceGenerationOptions(WriteIndented = true)] +[JsonSerializable(typeof(Record[]))] +internal partial class RecordSourceGenerationContext : JsonSerializerContext +{ +} + +[JsonSourceGenerationOptions(WriteIndented = true)] +[JsonSerializable(typeof(Dictionary))] +internal partial class DictionaryStringRecordSourceGenerationContext : JsonSerializerContext +{ +} \ No newline at end of file diff --git a/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/RuntimeInstanceStatusReport.cs b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/RuntimeInstanceStatusReport.cs new file mode 100644 index 0000000..e8507b9 --- /dev/null +++ b/Adaptation/FileHandlers/StatusQueryV2InstanceStatuses/RuntimeInstanceStatusReport.cs @@ -0,0 +1,41 @@ +using System; +using System.Xml.Serialization; + +namespace Adaptation.FileHandlers.StatusQueryV2InstanceStatuses; + +#nullable enable +#pragma warning disable IDE0027 + +[Serializable()] +[XmlType(Namespace = "http://schemas.datacontract.org/2004/07/EafManagement.Monitoring")] +[XmlRoot(Namespace = "http://schemas.datacontract.org/2004/07/EafManagement.Monitoring", IsNullable = false)] +public partial class RuntimeInstanceStatusReport { + + public string? CellInstanceName { get; set; } + public string? CurrentActiveVersion { get; set; } + public string? CurrentHost { get; set; } + public string? CurrentLoggingConfigurationName { get; set; } + public string? CurrentLoggingConfigurationVersion { get; set; } + public EquipmentState[]? EquipmentStates { get; set; } + public string? ErrorDescription { get; set; } + public string? Info { get; set; } + public string? IsAutomatedRestartActive { get; set; } + public string? IsAutomatedRestartRequested { get; set; } + public string? IsPilot { get; set; } + public string? IsReadyForRestart { get; set; } + public string? LastKnownCurrentActiveVersion { get; set; } + public string? MachineName { get; set; } + public string? PilotVersion { get; set; } + public string? RuntimeInstanceName { get; set; } + public string? Startable { get; set; } + public string? StartTime { get; set; } + public string? State { get; set; } + public string? StopTime { get; set; } + public string? TargetActiveVersion { get; set; } + public string? TargetHost { get; set; } + public string? TargetLoggingConfigurationName { get; set; } + public string? TargetLoggingConfigurationVersion { get; set; } + public string? Timestamp { get; set; } + public string? WindowsName { get; set; } + +} \ No newline at end of file diff --git a/DEP08CEPIEPSILON.csproj b/DEP08CEPIEPSILON.csproj index 2b10472..2a11ad7 100644 --- a/DEP08CEPIEPSILON.csproj +++ b/DEP08CEPIEPSILON.csproj @@ -119,6 +119,11 @@ + + + + +