namespace ClearAllActiveAlarms
{
using System;
using System.Linq;
using System.Threading.Tasks;
using Skyline.DataMiner.Automation;
using Skyline.DataMiner.Net.Messages;

public class Script
{
public void Run(IEngine engine)
{
try
{
engine.GenerateInformation("Script starting.");
ClearAllAlarms(engine);
engine.GenerateInformation("Script ending.");
}
catch (Exception e)
{
engine.ExitFail("Run|Something went wrong: " + e);
}
}

private void ClearAllAlarms(IEngine engine)
{
try
{
engine.GenerateInformation("Fetching all active alarms to clear.");
var messages = GetActiveAlarms(engine);

if (messages == null || messages.Length == 0)
{
engine.GenerateInformation("No active alarms were retrieved.");
return;
}

engine.GenerateInformation($"Received {messages.Length} messages from the DataMiner system.");
ProcessActiveAlarms(messages, engine);
}
catch (Exception ex)
{
engine.GenerateInformation($"ClearAllAlarms|Something went wrong: {ex.Message}\n{ex.StackTrace}");
engine.ExitFail("ClearAllAlarms|Something went wrong.");
}
}

private DMSMessage[] GetActiveAlarms(IEngine engine)
{
try
{
var getActiveAlarmsMessage = new GetActiveAlarmsMessage();
return engine.SendSLNetMessage(getActiveAlarmsMessage);
}
catch (Exception ex)
{
engine.GenerateInformation($"Failed to retrieve active alarms: {ex.Message}");
return null;
}
}

private void ProcessActiveAlarms(DMSMessage[] messages, IEngine engine)
{
var oneWeekAgo = DateTime.UtcNow.AddDays(-7);

foreach (var message in messages)
{
if (message is ActiveAlarmsResponseMessage alarmMessage)
{
Parallel.ForEach(alarmMessage.ActiveAlarms, alarm =>
{
if ((alarm.Severity == "Notice" || alarm.Severity == "Warning") && alarm.RootCreationTime > oneWeekAgo)
{
ClearSingleAlarm(alarm, engine);
}
else
{
engine.GenerateInformation($"Skipping Alarm {alarm.RootAlarmID} with Severity '{alarm.Severity}' or CreationTime '{alarm.RootCreationTime}' not matching criteria.");
}
});
}
else
{
engine.GenerateInformation("Received a message that is not an ActiveAlarmsResponseMessage. Skipping...");
}
}
}

private void ClearSingleAlarm(AlarmEventMessage alarm, IEngine engine) // Updated type
{
try
{
engine.GenerateInformation($"Clearing Alarm {alarm.RootAlarmID} with Severity '{alarm.Severity}' and Source '{alarm.Source}'.");

var clearingMessage = $"Cleared the alarm with DataMinerID '{alarm.DataMinerID}' and RootAlarmID '{alarm.RootAlarmID}' from Automation.";
var setAlarmStateMessage = new SetAlarmStateMessage(
alarm.DataMinerID,
alarm.RootAlarmID,
7,
clearingMessage
);
engine.SendSLNetMessage(setAlarmStateMessage);
engine.GenerateInformation($"Alarm with RootAlarmID '{alarm.RootAlarmID}' cleared.");
}
catch (Exception ex)
{
engine.GenerateInformation($"Failed to clear Alarm {alarm.RootAlarmID}: {ex.Message}\n{ex.StackTrace}");
}
}
}
}