fix: add messenger and event to ICurrentSources

src/PepperDash.Essentials.Core/Routing/ICurrentSources.cs

@@ -1,5 +1,5 @@
+using System;
 using System.Collections.Generic;
-using PepperDash.Essentials.Core;
 
 namespace PepperDash.Essentials.Core.Routing
 {
@@ -25,5 +25,19 @@ namespace PepperDash.Essentials.Core.Routing
     /// </summary>
     Dictionary<eRoutingSignalType, string> CurrentSourceKeys { get; }
 
+    /// <summary>
+    /// Event raised when the current sources change.
+    /// </summary>
+    event EventHandler CurrentSourcesChanged;
+
+    /// <summary>
+    /// Sets the current source for a specific signal type.
+    /// This method updates the current source for the specified signal type and notifies any subscribers of the change.
+    /// </summary>
+    /// <param name="signalType">The signal type to update.</param>
+    /// <param name="sourceListKey">The key for the source list.</param>
+    /// <param name="sourceListItem">The source list item to set as the current source.</param>
+    void SetCurrentSource(eRoutingSignalType signalType, string sourceListKey, SourceListItem sourceListItem);
+
   }
 }

src/PepperDash.Essentials.Devices.Common/Displays/DisplayBase.cs

@@ -52,9 +52,9 @@ namespace PepperDash.Essentials.Devices.Common.Displays
 		/// </summary>
 		public event SourceInfoChangeHandler CurrentSourceChange;
 
-  /// <summary>
+		/// <summary>
-  /// Gets or sets the CurrentSourceInfoKey
+		/// Gets or sets the CurrentSourceInfoKey
-  /// </summary>
+		/// </summary>
 		public string CurrentSourceInfoKey { get; set; }
 
 		/// <summary>
@@ -89,29 +89,32 @@ namespace PepperDash.Essentials.Devices.Common.Displays
 		/// <inheritdoc/>
 		public Dictionary<eRoutingSignalType, string> CurrentSourceKeys { get; private set; }
 
+		/// <inheritdoc />
+		public event EventHandler CurrentSourcesChanged;
+
 		/// <summary>
 		/// Gets feedback indicating whether the display is currently cooling down after being powered off.
 		/// </summary>
 		public BoolFeedback IsCoolingDownFeedback { get; protected set; }
 
-  /// <summary>
+		/// <summary>
-  /// Gets or sets the IsWarmingUpFeedback
+		/// Gets or sets the IsWarmingUpFeedback
-  /// </summary>
+		/// </summary>
 		public BoolFeedback IsWarmingUpFeedback { get; private set; }
 
-  /// <summary>
+		/// <summary>
-  /// Gets or sets the UsageTracker
+		/// Gets or sets the UsageTracker
-  /// </summary>
+		/// </summary>
 		public UsageTracking UsageTracker { get; set; }
 
-  /// <summary>
+		/// <summary>
-  /// Gets or sets the WarmupTime
+		/// Gets or sets the WarmupTime
-  /// </summary>
+		/// </summary>
 		public uint WarmupTime { get; set; }
 
-  /// <summary>
+		/// <summary>
-  /// Gets or sets the CooldownTime
+		/// Gets or sets the CooldownTime
-  /// </summary>
+		/// </summary>
 		public uint CooldownTime { get; set; }
 
 		/// <summary>
@@ -189,7 +192,7 @@ namespace PepperDash.Essentials.Devices.Common.Displays
 		/// <summary>
 		/// Gets the collection of feedback objects for this display device.
 		/// </summary>
-  /// <inheritdoc />
+		/// <inheritdoc />
 		public virtual FeedbackCollection<Feedback> Feedbacks
 		{
 			get
@@ -378,6 +381,33 @@ namespace PepperDash.Essentials.Devices.Common.Displays
 			volumeDisplayWithFeedback.MuteFeedback.LinkComplementInputSig(trilist.BooleanInput[joinMap.VolumeMuteOff.JoinNumber]);
 		}
 
+		/// <inheritdoc />
+		public virtual void SetCurrentSource(eRoutingSignalType signalType, string sourceListKey, SourceListItem sourceListItem)
+		{
+			// Update the current source for the specified signal type
+			if (CurrentSources.ContainsKey(signalType))
+			{
+				CurrentSources[signalType] = sourceListItem;
+			}
+			else
+			{
+				CurrentSources.Add(signalType, sourceListItem);
+			}
+
+			// Update the current source key for the specified signal type
+			if (CurrentSourceKeys.ContainsKey(signalType))
+			{
+				CurrentSourceKeys[signalType] = sourceListKey;
+			}
+			else
+			{
+				CurrentSourceKeys.Add(signalType, sourceListKey);
+			}
+
+			// Raise the CurrentSourcesChanged event
+			CurrentSourcesChanged?.Invoke(this, EventArgs.Empty);
+		}
+
 	}
 
 	/// <summary>

src/PepperDash.Essentials.MobileControl.Messengers/Messengers/CurrentSourcesMessenger.cs

@@ -0,0 +1,68 @@
+using System.Collections.Generic;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Converters;
+using Newtonsoft.Json.Linq;
+using PepperDash.Core;
+using PepperDash.Essentials.Core;
+using PepperDash.Essentials.Core.Routing;
+
+namespace PepperDash.Essentials.AppServer.Messengers
+{
+  /// <summary>
+  /// Represents a IHasCurrentSourceInfoMessenger
+  /// </summary>
+  public class CurrentSourcesMessenger : MessengerBase
+  {
+    private readonly ICurrentSources sourceDevice;
+    public CurrentSourcesMessenger(string key, string messagePath, ICurrentSources device) : base(key, messagePath, device as IKeyName)
+    {
+      sourceDevice = device;
+    }
+
+    protected override void RegisterActions()
+    {
+      base.RegisterActions();
+
+      AddAction("/fullStatus", (id, content) =>
+      {
+        var message = new CurrentSourcesStateMessage
+        {
+          CurrentSourceKeys = sourceDevice.CurrentSourceKeys,
+          CurrentSources = sourceDevice.CurrentSources
+        };
+
+        PostStatusMessage(message);
+      });
+
+      sourceDevice.CurrentSourcesChanged += (sender, e) =>
+      {
+        PostStatusMessage(JToken.FromObject(new
+        {
+          currentSourceKeys = sourceDevice.CurrentSourceKeys,
+          currentSources = sourceDevice.CurrentSources
+        }));
+      };
+    }
+  }
+
+  /// <summary>
+  /// Represents a CurrentSourcesStateMessage
+  /// </summary>
+  public class CurrentSourcesStateMessage : DeviceStateMessageBase
+  {
+
+    /// <summary>
+    /// Gets or sets the CurrentSourceKey
+    /// </summary>
+    [JsonProperty("currentSourceKey", NullValueHandling = NullValueHandling.Ignore)]
+    [JsonConverter(typeof(StringEnumConverter))]
+    public Dictionary<eRoutingSignalType, string> CurrentSourceKeys { get; set; }
+
+
+    /// <summary>
+    /// Gets or sets the CurrentSource
+    /// </summary>
+    [JsonProperty("currentSource")]
+    public Dictionary<eRoutingSignalType, SourceListItem> CurrentSources { get; set; }
+  }
+}

src/PepperDash.Essentials.MobileControl.Messengers/Messengers/IHasCurrentSourceInfoMessenger.cs

@@ -54,16 +54,18 @@ namespace PepperDash.Essentials.AppServer.Messengers
     /// </summary>
     public class CurrentSourceStateMessage : DeviceStateMessageBase
     {
-        [JsonProperty("currentSourceKey", NullValueHandling = NullValueHandling.Ignore)]
+
         /// <summary>
         /// Gets or sets the CurrentSourceKey
         /// </summary>
+        [JsonProperty("currentSourceKey", NullValueHandling = NullValueHandling.Ignore)]
         public string CurrentSourceKey { get; set; }
 
-        [JsonProperty("currentSource")]
+
         /// <summary>
         /// Gets or sets the CurrentSource
         /// </summary>
+        [JsonProperty("currentSource")]
         public SourceListItem CurrentSource { get; set; }
     }
 }

src/PepperDash.Essentials.MobileControl/MobileControlSystemController.cs

@@ -1,4 +1,10 @@
-using Crestron.SimplSharp;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Reflection;
+using System.Text.RegularExpressions;
+using System.Threading.Tasks;
+using Crestron.SimplSharp;
 using Crestron.SimplSharp.CrestronIO;
 using Crestron.SimplSharp.Net.Http;
 using Crestron.SimplSharp.WebScripting;
@@ -30,12 +36,6 @@ using PepperDash.Essentials.RoomBridges;
 using PepperDash.Essentials.Services;
 using PepperDash.Essentials.WebApiHandlers;
 using PepperDash.Essentials.WebSocketServer;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Reflection;
-using System.Text.RegularExpressions;
-using System.Threading.Tasks;
 using WebSocketSharp;
 
 namespace PepperDash.Essentials
@@ -721,6 +721,15 @@ namespace PepperDash.Essentials
                         messengerAdded = true;
                     }
 
+                    if (device is ICurrentSources currentSources)
+                    {
+                        this.LogVerbose("Adding CurrentSourcesMessenger for {deviceKey}", device.Key);
+
+                        var messenger = new CurrentSourcesMessenger($"{device.Key}-currentSources-{Key}", $"/device/{device.Key}", currentSources);
+
+                        AddDefaultDeviceMessenger(messenger);
+                    }
+
                     if (device is ISwitchedOutput switchedDevice)
                     {
                         this.LogVerbose(