Add SmartHomeMonitorWatcherTask (#59)

* Add SmartHomeMonitorWatcherTask

* Improve SmartHomeMonitorWatcherTask: CancellationToken propagation, sync, and logging (#60)

* Initial plan

* Apply PR review feedback: CancellationToken, Unknown state, semaphore, logging improvements

Co-authored-by: thomasneuberger <23504477+thomasneuberger@users.noreply.github.com>
Agent-Logs-Url: https://github.com/thomasneuberger/TgHomeBot/sessions/02041d09-0799-491d-ac3a-ccd36acdea63

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: thomasneuberger <23504477+thomasneuberger@users.noreply.github.com>

---------

Co-authored-by: Copilot <198982749+Copilot@users.noreply.github.com>

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,30 @@
+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)
+    {
+        cancellationToken.ThrowIfCancellationRequested();
+
+        var isRunning = await smartHomeConnector.EnsureMonitorIsRunning(cancellationToken).ConfigureAwait(false);
+
+        if (!isRunning)
+        {
+            logger.LogWarning("Smart Home Monitor is not running and could not be started.");
+        }
+        else
+        {
+            logger.LogDebug("Smart Home Monitor is running.");
+        }
+    }
+}

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(CancellationToken cancellationToken);
 }

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,37 @@ public async Task<ISmartHomeMonitor> CreateMonitorAsync(IReadOnlyList<MonitoredD
         }
     }
 
+    public async Task<bool> EnsureMonitorIsRunning(CancellationToken cancellationToken)
+    {
+        try
+        {
+            await _semaphore.WaitAsync(cancellationToken);
+            try
+            {
+                switch (_smartHomeMonitor?.State)
+                {
+                    case MonitorState.Idle:
+                    case MonitorState.Unknown:
+                        await _smartHomeMonitor!.StartMonitoringAsync(cancellationToken);
+                        return true;
+                    case MonitorState.Listening:
+                        return true;
+                    default:
+                        return false;
+                }
+            }
+            finally
+            {
+                _semaphore.Release();
+            }
+        }
+        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)