Add SmartHomeMonitorWatcherTask

Author: thomasneuberger

TgHomeBot.Scheduling/README.md

@@ -172,6 +172,25 @@ The task generates a summary of EV charging sessions from the last two months, g
 - Formatted in German with month names
 - Sent to all registered Telegram chats (respects the MonthlyChargingReport feature flag)
 
+### SmartHomeMonitorWatcherTask
+
+A scheduled task that ensures the Smart Home Monitor is running by periodically checking and restarting it if needed:
+
+Configuration file (`SmartHomeMonitorWatcherTask.json`):
+```json
+{
+  "taskType": "SmartHomeMonitorWatcherTask",
+  "cronExpression": "*/5 * * * *",
+  "enabled": true
+}
+```
+
+The task runs every 5 minutes and:
+- Checks if the Smart Home Monitor is running
+- Automatically restarts the monitor if it has stopped
+- Logs the current status of the monitor
+- Ensures continuous monitoring of smart home devices for state changes
+
 ## Integration
 
 To integrate the scheduler into your application:

TgHomeBot.Scheduling/Tasks/SmartHomeMonitorWatcherTask.cs

@@ -0,0 +1,20 @@
+using Microsoft.Extensions.Logging;
+using TgHomeBot.SmartHome.Contract;
+
+namespace TgHomeBot.Scheduling.Tasks;
+
+/// <summary>
+/// Scheduled task to ensure the Smart Home Monitor is running
+/// Periodically checks and restarts the monitor if needed
+/// </summary>
+public class SmartHomeMonitorWatcherTask(ILogger<SmartHomeMonitorWatcherTask> logger, ISmartHomeConnector smartHomeConnector)
+    : IScheduledTask
+{
+    public string TaskName => "SmartHomeMonitorWatcherTask";
+
+    public async Task ExecuteAsync(CancellationToken cancellationToken)
+    {
+        var isRunning = await smartHomeConnector.EnsureMonitorIsRunning();
+        logger.LogInformation("Smart Home Monitor is running: {IsRunning}", isRunning);
+    }
+}

TgHomeBot.Scheduling/Tasks/SmartHomeMonitorWatcherTask.json.example

@@ -0,0 +1,5 @@
+{
+  "taskType": "SmartHomeMonitorWatcherTask",
+  "cronExpression": "*/5 * * * *",
+  "enabled": true
+}

TgHomeBot.SmartHome.Contract/ISmartHomeConnector.cs

@@ -8,4 +8,5 @@ public interface ISmartHomeConnector
     Task<IReadOnlyList<SmartDevice>> GetDevices(IReadOnlyList<MonitoredDevice> requestedDevices);
     Task<ISmartHomeMonitor> CreateMonitorAsync(IReadOnlyList<MonitoredDevice> devices,
         CancellationToken cancellationToken);
+    Task<bool> EnsureMonitorIsRunning();
 }

TgHomeBot.SmartHome.HomeAssistant/HomeAssistantConnector.cs

@@ -8,7 +8,12 @@
 
 namespace TgHomeBot.SmartHome.HomeAssistant;
 
-internal class HomeAssistantConnector(IOptions<HomeAssistantOptions> options, IHttpClientFactory httpClientFactory, IServiceProvider serviceProvider, ILogger<HomeAssistantMonitor> monitorLogger)
+internal class HomeAssistantConnector(
+    IOptions<HomeAssistantOptions> options,
+    IHttpClientFactory httpClientFactory,
+    IServiceProvider serviceProvider,
+    ILogger<HomeAssistantMonitor> monitorLogger,
+    ILogger<HomeAssistantConnector> logger)
     : ISmartHomeConnector
 {
     internal const string HttpClientName = "HomeAssistant";
@@ -62,6 +67,28 @@ public async Task<ISmartHomeMonitor> CreateMonitorAsync(IReadOnlyList<MonitoredD
         }
     }
 
+    public async Task<bool> EnsureMonitorIsRunning()
+    {
+        try
+        {
+            switch (_smartHomeMonitor?.State)
+            {
+                case MonitorState.Idle:
+                    await _smartHomeMonitor.StartMonitoringAsync(CancellationToken.None);
+                    return true;
+                case MonitorState.Listening:
+                    return true;
+                default:
+                    return false;
+            }
+        }
+        catch (Exception e)
+        {
+            logger.LogError(e, "Error ensuring Home Assistant monitor is running");
+            return false;
+        }
+    }
+
     private async Task<string> CallApi(string endpoint, HttpMethod method)
     {
         var url = options.Value.BaseUrl.TrimEnd('/') + "/api/" + endpoint;

TgHomeBot.SmartHome.HomeAssistant/HomeAssistantMonitor.cs

@@ -152,7 +152,7 @@ private async Task WaitForMessages()
                 logger.LogError(ex, "Error receiving message from Home Assistant web socket: {Exception}", ex.Message);
             }
         }
-        logger.LogWarning("Home Assistant Web socket has been closed.");
+        logger.LogWarning("Home Assistant Web socket has been closed. Reconnect: {Reconnect}", _reconnect);
         if (_reconnect)
         {
             while (_webSocket is null || _webSocket.State == WebSocketState.Closed)