mirror of
https://github.com/PepperDash/Essentials.git
synced 2026-08-31 19:08:29 +00:00
Compare commits
No commits in common. "main" and "v2.37.0" have entirely different histories.
20 changed files with 68 additions and 383 deletions
|
|
@ -1,6 +1,6 @@
|
|||
<Project>
|
||||
<PropertyGroup>
|
||||
<Version>2.42.1-local</Version>
|
||||
<Version>2.36.6-local</Version>
|
||||
<InformationalVersion>$(Version)</InformationalVersion>
|
||||
<Authors>PepperDash Technology</Authors>
|
||||
<Company>PepperDash Technology</Company>
|
||||
|
|
|
|||
|
|
@ -151,8 +151,6 @@ namespace PepperDash.Core
|
|||
// Thread-safety lock for state changes
|
||||
private readonly object _stateLock = new object();
|
||||
|
||||
private volatile bool _isProgramStopping;
|
||||
|
||||
private bool disconnectLogged = false;
|
||||
|
||||
/// <summary>
|
||||
|
|
@ -209,9 +207,11 @@ namespace PepperDash.Core
|
|||
{
|
||||
if (programEventType == eProgramStatusEventType.Stopping)
|
||||
{
|
||||
_isProgramStopping = true;
|
||||
this.LogDebug("Program stopping. Closing connection");
|
||||
Disconnect();
|
||||
if (client != null)
|
||||
{
|
||||
this.LogDebug("Program stopping. Closing connection");
|
||||
Disconnect();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -228,12 +228,6 @@ namespace PepperDash.Core
|
|||
return;
|
||||
}
|
||||
|
||||
if (_isProgramStopping)
|
||||
{
|
||||
this.LogDebug("Skipping connect because program is stopping");
|
||||
return;
|
||||
}
|
||||
|
||||
ConnectEnabled = true;
|
||||
|
||||
try
|
||||
|
|
@ -293,7 +287,13 @@ namespace PepperDash.Core
|
|||
}
|
||||
catch (SshConnectionException e)
|
||||
{
|
||||
var ie = e.InnerException; // The details are inside, when present - remote can close the connection with no inner exception at all
|
||||
var ie = e.InnerException; // The details are inside!!
|
||||
|
||||
if (ie is SocketException)
|
||||
{
|
||||
this.LogError("CONNECTION failure: Cannot reach host");
|
||||
this.LogVerbose(ie, "Exception details: ");
|
||||
}
|
||||
|
||||
if (ie is System.Net.Sockets.SocketException socketException)
|
||||
{
|
||||
|
|
@ -301,20 +301,20 @@ namespace PepperDash.Core
|
|||
Hostname, Port);
|
||||
this.LogVerbose(socketException, "SocketException details: ");
|
||||
}
|
||||
else if (ie is SshAuthenticationException)
|
||||
if (ie is SshAuthenticationException)
|
||||
{
|
||||
this.LogError("Authentication failure for username {userName}", Username);
|
||||
this.LogVerbose(ie, "AuthenticationException details: ");
|
||||
}
|
||||
else
|
||||
{
|
||||
this.LogError("Error on connect: {error}", ie?.Message ?? e.Message);
|
||||
this.LogVerbose(ie ?? e, "Exception details: ");
|
||||
this.LogError("Error on connect: {error}", ie.Message);
|
||||
this.LogVerbose(ie, "Exception details: ");
|
||||
}
|
||||
|
||||
disconnectLogged = true;
|
||||
KillClient(SocketStatus.SOCKET_STATUS_CONNECT_FAILED);
|
||||
if (AutoReconnect && ConnectEnabled && !_isProgramStopping)
|
||||
if (AutoReconnect)
|
||||
{
|
||||
this.LogDebug("Checking autoreconnect: {autoReconnect}, {autoReconnectInterval}ms", AutoReconnect, AutoReconnectIntervalMs);
|
||||
StartReconnectTimer();
|
||||
|
|
@ -326,7 +326,7 @@ namespace PepperDash.Core
|
|||
|
||||
disconnectLogged = true;
|
||||
KillClient(SocketStatus.SOCKET_STATUS_CONNECT_FAILED);
|
||||
if (AutoReconnect && ConnectEnabled && !_isProgramStopping)
|
||||
if (AutoReconnect)
|
||||
{
|
||||
this.LogDebug("Checking autoreconnect: {0}, {1}ms", AutoReconnect, AutoReconnectIntervalMs);
|
||||
StartReconnectTimer();
|
||||
|
|
@ -338,7 +338,7 @@ namespace PepperDash.Core
|
|||
this.LogVerbose(e, "Exception details: ");
|
||||
disconnectLogged = true;
|
||||
KillClient(SocketStatus.SOCKET_STATUS_CONNECT_FAILED);
|
||||
if (AutoReconnect && ConnectEnabled && !_isProgramStopping)
|
||||
if (AutoReconnect)
|
||||
{
|
||||
this.LogDebug("Checking autoreconnect: {0}, {1}ms", AutoReconnect, AutoReconnectIntervalMs);
|
||||
StartReconnectTimer();
|
||||
|
|
@ -473,7 +473,7 @@ namespace PepperDash.Core
|
|||
{
|
||||
connectLock.Release();
|
||||
}
|
||||
if (AutoReconnect && ConnectEnabled && !_isProgramStopping)
|
||||
if (AutoReconnect && ConnectEnabled)
|
||||
{
|
||||
this.LogDebug("Checking autoreconnect: {0}, {1}ms", AutoReconnect, AutoReconnectIntervalMs);
|
||||
StartReconnectTimer();
|
||||
|
|
@ -516,10 +516,7 @@ namespace PepperDash.Core
|
|||
this.LogError("ObjectDisposedException sending '{message}'. Restarting connection...", text.Trim());
|
||||
|
||||
KillClient(SocketStatus.SOCKET_STATUS_CONNECT_FAILED);
|
||||
if (AutoReconnect && ConnectEnabled && !_isProgramStopping)
|
||||
{
|
||||
StartReconnectTimer();
|
||||
}
|
||||
StartReconnectTimer();
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
|
@ -552,10 +549,7 @@ namespace PepperDash.Core
|
|||
this.LogException(ex, "ObjectDisposedException sending {message}", ComTextHelper.GetEscapedText(bytes));
|
||||
|
||||
KillClient(SocketStatus.SOCKET_STATUS_CONNECT_FAILED);
|
||||
if (AutoReconnect && ConnectEnabled && !_isProgramStopping)
|
||||
{
|
||||
StartReconnectTimer();
|
||||
}
|
||||
StartReconnectTimer();
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
|
|
|||
|
|
@ -43,7 +43,7 @@
|
|||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<PackageReference Include="BouncyCastle.Cryptography" Version="2.4.0" />
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.Library" Version="2.21.274" />
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.Library" Version="2.21.90" />
|
||||
<PackageReference Include="Serilog" Version="3.1.1" />
|
||||
<PackageReference Include="Serilog.Expressions" Version="4.0.0" />
|
||||
<PackageReference Include="Serilog.Formatting.Compact" Version="2.0.0" />
|
||||
|
|
|
|||
|
|
@ -39,8 +39,6 @@ namespace PepperDash.Essentials.Core
|
|||
|
||||
ICec Port;
|
||||
|
||||
bool _cecSubscribed;
|
||||
|
||||
/// <summary>
|
||||
/// Constructor
|
||||
/// </summary>
|
||||
|
|
@ -56,7 +54,7 @@ namespace PepperDash.Essentials.Core
|
|||
{
|
||||
Port = postActivationFunc(config);
|
||||
|
||||
TryEnsureCecSubscription();
|
||||
Port.StreamCec.CecChange += StreamCec_CecChange;
|
||||
});
|
||||
}
|
||||
|
||||
|
|
@ -70,29 +68,7 @@ namespace PepperDash.Essentials.Core
|
|||
{
|
||||
Port = port;
|
||||
|
||||
TryEnsureCecSubscription();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Subscribes to the CEC change event once <see cref="ICec.StreamCec"/> is available.
|
||||
/// Safe to call repeatedly; the subscription is only wired a single time.
|
||||
/// If StreamCec is null during construction, this is retried when send methods invoke
|
||||
/// this method later.
|
||||
/// </summary>
|
||||
void TryEnsureCecSubscription()
|
||||
{
|
||||
if (_cecSubscribed)
|
||||
return;
|
||||
|
||||
if (Port?.StreamCec == null)
|
||||
{
|
||||
Debug.LogMessage(LogEventLevel.Warning, this, "StreamCec is not available; CEC feedback is deferred until the device is ready");
|
||||
return;
|
||||
}
|
||||
|
||||
Port.StreamCec.CecChange += new CecChangeEventHandler(StreamCec_CecChange);
|
||||
_cecSubscribed = true;
|
||||
Debug.LogMessage(LogEventLevel.Information, this, "Subscribed to CEC feedback");
|
||||
}
|
||||
|
||||
void StreamCec_CecChange(Cec cecDevice, CecEventArgs args)
|
||||
|
|
@ -128,9 +104,8 @@ namespace PepperDash.Essentials.Core
|
|||
/// </summary>
|
||||
public void SendText(string text)
|
||||
{
|
||||
if (Port?.StreamCec == null)
|
||||
if (Port == null)
|
||||
return;
|
||||
TryEnsureCecSubscription();
|
||||
this.PrintSentText(text);
|
||||
Port.StreamCec.Send.StringValue = text;
|
||||
}
|
||||
|
|
@ -140,9 +115,8 @@ namespace PepperDash.Essentials.Core
|
|||
/// </summary>
|
||||
public void SendBytes(byte[] bytes)
|
||||
{
|
||||
if (Port?.StreamCec == null)
|
||||
if (Port == null)
|
||||
return;
|
||||
TryEnsureCecSubscription();
|
||||
var text = Encoding.GetEncoding(28591).GetString(bytes, 0, bytes.Length);
|
||||
this.PrintSentBytes(bytes);
|
||||
Debug.LogMessage(LogEventLevel.Information, this, "Sending {0} bytes: '{1}'", bytes.Length, ComTextHelper.GetEscapedText(bytes));
|
||||
|
|
|
|||
|
|
@ -1,48 +0,0 @@
|
|||
using System;
|
||||
|
||||
namespace PepperDash.Essentials.Core.DeviceTypeInterfaces
|
||||
{
|
||||
/// <summary>
|
||||
/// Defines the contract for a wireless presentation endpoint that reports whether a wireless
|
||||
/// sharing session is currently active. Implemented by platforms such as Crestron AirMedia,
|
||||
/// Mersive Solstice, Barco ClickShare, Miracast/Teams receivers, etc. Allows consumers (e.g.
|
||||
/// room plugins) to react to wireless sharing activity without taking a dependency on any
|
||||
/// concrete device implementation.
|
||||
/// </summary>
|
||||
/// <remarks>
|
||||
/// This refers specifically to wireless screen/device mirroring, as distinct from in-call
|
||||
/// content sharing on a video conference.
|
||||
/// </remarks>
|
||||
public interface IHasWirelessSharing
|
||||
{
|
||||
/// <summary>
|
||||
/// Reports whether a wireless sharing session is currently active (content is being presented).
|
||||
/// </summary>
|
||||
BoolFeedback IsSharingFeedback { get; }
|
||||
|
||||
/// <summary>
|
||||
/// Raised when wireless sharing starts or stops. The event args carry the new sharing state.
|
||||
/// </summary>
|
||||
event EventHandler<WirelessSharingEventArgs> SharingChanged;
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Event arguments describing a change in wireless sharing state.
|
||||
/// </summary>
|
||||
public class WirelessSharingEventArgs : EventArgs
|
||||
{
|
||||
/// <summary>
|
||||
/// True if a wireless sharing session is active (content is being presented), false otherwise.
|
||||
/// </summary>
|
||||
public bool IsSharing { get; private set; }
|
||||
|
||||
/// <summary>
|
||||
/// Creates a new <see cref="WirelessSharingEventArgs"/>.
|
||||
/// </summary>
|
||||
/// <param name="isSharing">True if a wireless sharing session is active, false otherwise.</param>
|
||||
public WirelessSharingEventArgs(bool isSharing)
|
||||
{
|
||||
IsSharing = isSharing;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,122 +0,0 @@
|
|||
using System;
|
||||
|
||||
namespace PepperDash.Essentials.Core.DeviceTypeInterfaces
|
||||
{
|
||||
/// <summary>
|
||||
/// Interface for network switches that support VLAN assignment on individual ports.
|
||||
/// </summary>
|
||||
public interface INetworkSwitchVlanManager
|
||||
{
|
||||
/// <summary>
|
||||
/// Returns the current access VLAN ID configured on the port.
|
||||
/// Return -1 when the value is unavailable (e.g. the switch has not been polled yet
|
||||
/// or the implementation does not support VLAN queries).
|
||||
/// </summary>
|
||||
/// <param name="port">Switch port identifier</param>
|
||||
/// <returns>VLAN ID or -1 when unavailable</returns>
|
||||
int GetPortCurrentVlan(string port);
|
||||
|
||||
/// <summary>
|
||||
/// Changes the access VLAN of a single switch port.
|
||||
/// The implementation is responsible for entering/exiting privileged/config mode.
|
||||
/// </summary>
|
||||
/// <param name="port">Switch port identifier (e.g. "1/0/3" for Netgear, "gi1/0/3" for Cisco)</param>
|
||||
/// <param name="vlanId">Target VLAN ID (1-4093)</param>
|
||||
void SetPortVlan(string port, uint vlanId);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Interface for network switches that support Power over Ethernet (PoE) control on individual ports.
|
||||
/// </summary>
|
||||
public interface INetworkSwitchPoeManager
|
||||
{
|
||||
/// <summary>
|
||||
/// Enables or disables PoE power delivery on a single switch port.
|
||||
/// The implementation is responsible for entering/exiting privileged/config mode.
|
||||
/// </summary>
|
||||
/// <param name="port">Switch port identifier</param>
|
||||
/// <param name="enabled">True to enable PoE; false to disable PoE</param>
|
||||
void SetPortPoeState(string port, bool enabled);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Standardized interface for network switch devices that support per-port PoE control
|
||||
/// and VLAN assignment.
|
||||
/// </summary>
|
||||
public interface INetworkSwitchPoeVlanManager : INetworkSwitchVlanManager, INetworkSwitchPoeManager
|
||||
{
|
||||
/// <summary>
|
||||
/// Event that is raised when the state of a switch port changes, such as a VLAN change or PoE state change.
|
||||
/// </summary>
|
||||
event EventHandler<NetworkSwitchPortEventArgs> PortStateChanged;
|
||||
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Event arguments for port state changes on a network switch, such as VLAN changes or PoE state changes.
|
||||
/// </summary>
|
||||
public class NetworkSwitchPortEventArgs : EventArgs
|
||||
{
|
||||
/// <summary>
|
||||
/// The identifier of the port that changed state (e.g. "1/0/3" for Netgear, "gi1/0/3" for Cisco).
|
||||
/// </summary>
|
||||
public string Port { get; private set; }
|
||||
|
||||
/// <summary>
|
||||
/// The type of event that occurred on the port (e.g. VLAN change, PoE enabled/disabled).
|
||||
/// </summary>
|
||||
public NetworkSwitchPortEventType EventType { get; private set; }
|
||||
|
||||
/// <summary>
|
||||
/// Constructor for NetworkSwitchPortEventArgs
|
||||
/// </summary>
|
||||
/// <param name="port">The identifier of the port that changed state</param>
|
||||
/// <param name="eventType">The type of event that occurred on the port</param>
|
||||
public NetworkSwitchPortEventArgs(string port, NetworkSwitchPortEventType eventType)
|
||||
{
|
||||
Port = port;
|
||||
EventType = eventType;
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Enumeration of network switch port state change event types (e.g. VLAN changes or PoE state changes).
|
||||
/// </summary>
|
||||
public enum NetworkSwitchPortEventType
|
||||
{
|
||||
/// <summary>
|
||||
/// Indicates that the type of event is unknown or cannot be determined.
|
||||
/// </summary>
|
||||
Unknown,
|
||||
|
||||
/// <summary>
|
||||
/// Indicates that a VLAN change is in progress on the port, either through a call to SetPortVlan or an external change detected by polling.
|
||||
/// </summary>
|
||||
VlanChangeInProgress,
|
||||
|
||||
/// <summary>
|
||||
/// Indicates that the access VLAN on a port has changed, either through a successful call to SetPortVlan or an external change detected by polling.
|
||||
/// </summary>
|
||||
VlanChanged,
|
||||
|
||||
/// <summary>
|
||||
/// Indicates that PoE is being disabled on the port, either through a call to SetPortPoeState or an external change detected by polling.
|
||||
/// </summary>
|
||||
PoeDisableInProgress,
|
||||
|
||||
/// <summary>
|
||||
/// Indicates that PoE has been disabled on the port, either through a successful call to SetPortPoeState or an external change detected by polling.
|
||||
/// </summary>
|
||||
PoEDisabled,
|
||||
|
||||
/// <summary>
|
||||
/// Indicates that PoE is being enabled on the port, either through a call to SetPortPoeState or an external change detected by polling.
|
||||
/// </summary>
|
||||
PoeEnableInProgress,
|
||||
|
||||
/// <summary>
|
||||
/// Indicates that PoE has been enabled on the port, either through a successful call to SetPortPoeState or an external change detected by polling.
|
||||
/// </summary>
|
||||
PoEEnabled
|
||||
}
|
||||
}
|
||||
|
|
@ -1,14 +0,0 @@
|
|||
namespace PepperDash.Essentials.Core
|
||||
{
|
||||
/// <summary>
|
||||
/// Defines the contract for IHasDspPresetSave
|
||||
/// </summary>
|
||||
public interface IHasDspPresetSave : IDspPresets
|
||||
{
|
||||
/// <summary>
|
||||
/// Saves the preset by key
|
||||
/// </summary>
|
||||
/// <param name="key">key of preset to save</param>
|
||||
void SavePreset(string key);
|
||||
}
|
||||
}
|
||||
|
|
@ -25,7 +25,7 @@
|
|||
<DocumentationFile>bin\$(Configuration)\PepperDash_Essentials_Core.xml</DocumentationFile>
|
||||
</PropertyGroup>
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.ProgramLibrary" Version="2.21.274" />
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.ProgramLibrary" Version="2.21.90" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<None Include="Crestron\CrestronGenericBaseDevice.cs.orig" />
|
||||
|
|
|
|||
|
|
@ -343,14 +343,12 @@ namespace PepperDash.Essentials.Core
|
|||
IndexTieLines();
|
||||
}
|
||||
|
||||
var sinks = DeviceManager.AllDevices.OfType<IRoutingInputs>()
|
||||
.Where(d => !(d is IRoutingInputsOutputs)).ToList();
|
||||
var sources = DeviceManager.AllDevices.OfType<IRoutingOutputs>()
|
||||
.Where(d => !(d is IRoutingInputsOutputs)).ToList();
|
||||
var sinks = DeviceManager.AllDevices.OfType<IRoutingInputs>();
|
||||
var sources = DeviceManager.AllDevices.OfType<IRoutingOutputs>();
|
||||
|
||||
foreach (var sink in sinks)
|
||||
foreach (var sink in sinks.Where(d => !(d is IRoutingInputsOutputs)))
|
||||
{
|
||||
foreach (var source in sources)
|
||||
foreach (var source in sources.Where(d => !(d is IRoutingInputsOutputs)))
|
||||
{
|
||||
foreach (var inputPort in sink.InputPorts)
|
||||
{
|
||||
|
|
@ -375,10 +373,6 @@ namespace PepperDash.Essentials.Core
|
|||
continue;
|
||||
}
|
||||
|
||||
Debug.LogVerbose("Route mapped: {source} -> {sink} via {input}/{output}, type {type}",
|
||||
source.Key, sink.Key,
|
||||
inputPort.Key, outputPort.Key, audioOrSingleRoute.SignalType);
|
||||
|
||||
// Add to the appropriate collection(s) based on signal type
|
||||
// Note: A single route descriptor with combined flags (e.g., AudioVideo) will be added once per matching signal type
|
||||
if (audioOrSingleRoute.SignalType.HasFlag(eRoutingSignalType.Audio))
|
||||
|
|
@ -410,10 +404,6 @@ namespace PepperDash.Essentials.Core
|
|||
continue;
|
||||
}
|
||||
|
||||
Debug.LogVerbose("Video route mapped: {source} -> {sink} via {input}/{output}",
|
||||
source.Key, sink.Key,
|
||||
inputPort.Key, outputPort.Key);
|
||||
|
||||
RouteDescriptors[eRoutingSignalType.Video].AddRouteDescriptor(videoRoute);
|
||||
}
|
||||
}
|
||||
|
|
@ -619,12 +609,10 @@ namespace PepperDash.Essentials.Core
|
|||
|
||||
// No direct tie? Run back out on the inputs' attached devices...
|
||||
// Only the ones that are routing devices
|
||||
var midpointTieLines = destinationTieLines
|
||||
.Where(t => t.SourcePort.ParentDevice is IRoutingInputsOutputs)
|
||||
.ToList();
|
||||
var midpointTieLines = destinationTieLines.Where(t => t.SourcePort.ParentDevice is IRoutingInputsOutputs);
|
||||
|
||||
Debug.LogVerbose(destination, "Found {tieLineCount} tie lines to walk for {destinationKey}", midpointTieLines.Count(), destination.Key);
|
||||
|
||||
Debug.LogVerbose(destination, "Found {tieLineCount} tie lines to walk for {destinationKey}", midpointTieLines.Count, destination.Key);
|
||||
|
||||
//Create a list for tracking already checked devices to avoid loops, if it doesn't already exist from previous iteration
|
||||
if (alreadyCheckedDevices == null)
|
||||
alreadyCheckedDevices = new List<IRoutingInputsOutputs>();
|
||||
|
|
|
|||
|
|
@ -1,14 +1,13 @@
|
|||
using System;
|
||||
using System.Linq;
|
||||
using System.Linq;
|
||||
using Crestron.SimplSharp.WebScripting;
|
||||
using Newtonsoft.Json;
|
||||
using PepperDash.Core.Web.RequestHandlers;
|
||||
|
||||
namespace PepperDash.Essentials.Core.Web.RequestHandlers
|
||||
{
|
||||
/// <summary>
|
||||
/// Represents a GetFeedbacksForDeviceRequestHandler
|
||||
/// </summary>
|
||||
/// <summary>
|
||||
/// Represents a GetFeedbacksForDeviceRequestHandler
|
||||
/// </summary>
|
||||
public class GetFeedbacksForDeviceRequestHandler : WebApiBaseRequestHandler
|
||||
{
|
||||
/// <summary>
|
||||
|
|
@ -77,7 +76,7 @@ namespace PepperDash.Essentials.Core.Web.RequestHandlers
|
|||
Value = feedback.IntValue
|
||||
};
|
||||
|
||||
var stringFeedback =
|
||||
var stringFeedback =
|
||||
from feedback in device.Feedbacks.OfType<StringFeedback>()
|
||||
where !string.IsNullOrEmpty(feedback.Key)
|
||||
select new
|
||||
|
|
|
|||
|
|
@ -152,15 +152,6 @@ namespace PepperDash.Essentials.Devices.Common.Shades
|
|||
|
||||
private void IsCoolingDownFeedback_OutputChange(object sender, FeedbackEventArgs e)
|
||||
{
|
||||
if (Config.DisableAutoRaiseOnPowerOff)
|
||||
{
|
||||
this.LogDebug(
|
||||
"Auto-raise on power-off disabled for {type}; leaving position unchanged (manual control only)",
|
||||
Type
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
if (
|
||||
!DisplayDevice.IsCoolingDownFeedback.BoolValue
|
||||
&& Type == eScreenLiftControlType.lift
|
||||
|
|
@ -183,15 +174,6 @@ namespace PepperDash.Essentials.Devices.Common.Shades
|
|||
{
|
||||
if (DisplayDevice.IsWarmingUpFeedback.BoolValue)
|
||||
{
|
||||
if (Config.DisableAutoLowerOnPowerOn)
|
||||
{
|
||||
this.LogDebug(
|
||||
"Auto-lower on power-on disabled for {type}; leaving position unchanged (manual control only)",
|
||||
Type
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
Lower();
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -41,23 +41,5 @@ namespace PepperDash.Essentials.Devices.Common.Shades
|
|||
/// </summary>
|
||||
[JsonProperty("muteOnScreenUp")]
|
||||
public bool MuteOnScreenUp { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// When true, this controller does NOT automatically lower when its assigned display powers on
|
||||
/// (warms up). Manual Raise/Lower still work, and the power-off auto-raise is unaffected. Intended
|
||||
/// for a projector screen that must not auto-drop in a public space for safety, while the projector
|
||||
/// lift (a separate controller) can still drop automatically.
|
||||
/// </summary>
|
||||
[JsonProperty("disableAutoLowerOnPowerOn")]
|
||||
public bool DisableAutoLowerOnPowerOn { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// When true, this controller does NOT automatically raise when its assigned display powers off
|
||||
/// (cools down). Manual Raise/Lower still work, and the power-on auto-lower is unaffected. The
|
||||
/// companion to <see cref="DisableAutoLowerOnPowerOn"/>; together they make a controller fully
|
||||
/// manual while leaving other controllers (e.g. the lift) on their default automatic behavior.
|
||||
/// </summary>
|
||||
[JsonProperty("disableAutoRaiseOnPowerOff")]
|
||||
public bool DisableAutoRaiseOnPowerOff { get; set; }
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -29,6 +29,6 @@
|
|||
<ProjectReference Include="..\PepperDash.Essentials.Core\PepperDash.Essentials.Core.csproj" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.ProgramLibrary" Version="2.21.274" />
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.ProgramLibrary" Version="2.21.90" />
|
||||
</ItemGroup>
|
||||
</Project>
|
||||
|
|
@ -10,7 +10,7 @@ namespace PepperDash.Essentials.AppServer.Messengers
|
|||
/// <summary>
|
||||
/// The device key
|
||||
/// </summary>
|
||||
[JsonProperty("key", NullValueHandling = NullValueHandling.Ignore)]
|
||||
[JsonProperty("key")]
|
||||
/// <summary>
|
||||
/// Gets or sets the Key
|
||||
/// </summary>
|
||||
|
|
@ -19,19 +19,19 @@ namespace PepperDash.Essentials.AppServer.Messengers
|
|||
/// <summary>
|
||||
/// The device name
|
||||
/// </summary>
|
||||
[JsonProperty("name", NullValueHandling = NullValueHandling.Ignore)]
|
||||
[JsonProperty("name")]
|
||||
public string Name { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// The type of the message class
|
||||
/// </summary>
|
||||
[JsonProperty("messageType", NullValueHandling = NullValueHandling.Ignore)]
|
||||
[JsonProperty("messageType")]
|
||||
public string MessageType => GetType().Name;
|
||||
|
||||
/// <summary>
|
||||
/// Gets or sets the MessageBasePath
|
||||
/// </summary>
|
||||
[JsonProperty("messageBasePath", NullValueHandling = NullValueHandling.Ignore)]
|
||||
[JsonProperty("messageBasePath")]
|
||||
|
||||
public string MessageBasePath { get; set; }
|
||||
}
|
||||
|
|
|
|||
|
|
@ -12,8 +12,7 @@ namespace PepperDash.Essentials.AppServer.Messengers
|
|||
/// <summary>
|
||||
/// The interfaces implmented by the device sending the messsage
|
||||
/// </summary>
|
||||
[JsonProperty("interfaces", NullValueHandling = NullValueHandling.Ignore)]
|
||||
[Obsolete("Interfaces are no longer supported and will be removed in a future release. Interfaces for all devices are now retrieved via the /joinroom endpoint in the MobileControlWebsocketServer")]
|
||||
[JsonProperty("interfaces")]
|
||||
public List<string> Interfaces { get; private set; }
|
||||
|
||||
/// <summary>
|
||||
|
|
|
|||
|
|
@ -33,7 +33,7 @@
|
|||
<Compile Remove="Messengers\SIMPLVtcMessenger.cs" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.ProgramLibrary" Version="2.21.274" />
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.ProgramLibrary" Version="2.21.90" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<ProjectReference Include="..\PepperDash.Core\PepperDash.Core.csproj" />
|
||||
|
|
|
|||
|
|
@ -38,7 +38,7 @@
|
|||
<Compile Remove="RoomBridges\SourceDeviceMapDictionary.cs" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.ProgramLibrary" Version="2.21.274" />
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.ProgramLibrary" Version="2.21.90" />
|
||||
<PackageReference Include="WebSocketSharp-netstandard" Version="1.0.1" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
|
|
|
|||
|
|
@ -25,28 +25,11 @@ namespace PepperDash.Essentials.Touchpanel
|
|||
/// Mobile Control touchpanel controller that provides app control, Zoom integration,
|
||||
/// and mobile control functionality for Crestron touchpanels.
|
||||
/// </summary>
|
||||
public class MobileControlTouchpanelController : TouchpanelBase, IHasFeedback, ITswAppControl, ITswZoomControl, IDeviceInfoProvider, IMobileControlCrestronTouchpanelController, ITheme, ICommunicationMonitor
|
||||
public class MobileControlTouchpanelController : TouchpanelBase, IHasFeedback, ITswAppControl, ITswZoomControl, IDeviceInfoProvider, IMobileControlCrestronTouchpanelController, ITheme
|
||||
{
|
||||
private readonly MobileControlTouchpanelProperties localConfig;
|
||||
private IMobileControlRoomMessenger _bridge;
|
||||
|
||||
/// <summary>
|
||||
/// Gets the CommunicationMonitor tracking the panel's online/offline state
|
||||
/// </summary>
|
||||
public StatusMonitorBase CommunicationMonitor { get; private set; }
|
||||
|
||||
private sealed class NullCommunicationMonitor : StatusMonitorBase
|
||||
{
|
||||
public NullCommunicationMonitor(IKeyed parent) : base(parent, 120000, 300000)
|
||||
{
|
||||
Status = MonitorStatus.InError;
|
||||
Message = "Panel is not initialized";
|
||||
}
|
||||
|
||||
public override void Start() { }
|
||||
public override void Stop() { }
|
||||
}
|
||||
|
||||
private string _appUrl;
|
||||
|
||||
/// <summary>
|
||||
|
|
@ -145,11 +128,6 @@ namespace PepperDash.Essentials.Touchpanel
|
|||
{
|
||||
localConfig = config;
|
||||
|
||||
if (panel != null)
|
||||
{
|
||||
CommunicationMonitor = new CrestronGenericBaseCommunicationMonitor(this, panel, 120000, 300000);
|
||||
}
|
||||
|
||||
AddPostActivationAction(SubscribeForMobileControlUpdates);
|
||||
|
||||
ThemeFeedback = new StringFeedback($"{Key}-theme", () => Theme);
|
||||
|
|
@ -388,8 +366,6 @@ namespace PepperDash.Essentials.Touchpanel
|
|||
/// </summary>
|
||||
public override bool CustomActivate()
|
||||
{
|
||||
CommunicationMonitor?.Start();
|
||||
|
||||
var appMessenger = new ITswAppControlMessenger($"appControlMessenger-{Key}", $"/device/{Key}", this);
|
||||
|
||||
var zoomMessenger = new ITswZoomControlMessenger($"zoomControlMessenger-{Key}", $"/device/{Key}", this);
|
||||
|
|
@ -417,17 +393,6 @@ namespace PepperDash.Essentials.Touchpanel
|
|||
return base.CustomActivate();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Stops the CommunicationMonitor on deactivation.
|
||||
/// </summary>
|
||||
/// <returns>True if deactivation was successful; otherwise, false.</returns>
|
||||
public override bool Deactivate()
|
||||
{
|
||||
CommunicationMonitor?.Stop();
|
||||
|
||||
return base.Deactivate();
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// Handles device extender signal changes for system reserved signals.
|
||||
/// </summary>
|
||||
|
|
@ -554,8 +519,15 @@ namespace PepperDash.Essentials.Touchpanel
|
|||
return false;
|
||||
}) ? csIpAddress.ToString() : processorIp;
|
||||
|
||||
// replace the host but preserve whatever scheme (http/https) is already present in the URL
|
||||
var updatedUrl = Regex.Replace(url, @"^(https?)://[^:/]+", $"$1://{ip}");
|
||||
var match = Regex.Match(url, @"^http://([^:/]+):\d+/mc/app\?token=.+$");
|
||||
if (match.Success)
|
||||
{
|
||||
string ipa = match.Groups[1].Value;
|
||||
// ip will be "192.168.1.100"
|
||||
}
|
||||
|
||||
// replace ipa with ip but leave the rest of the string intact
|
||||
var updatedUrl = Regex.Replace(url, @"^http://[^:/]+", $"http://{ip}");
|
||||
|
||||
this.LogVerbose("Updated URL: {updatedUrl}", updatedUrl);
|
||||
|
||||
|
|
@ -768,7 +740,7 @@ namespace PepperDash.Essentials.Touchpanel
|
|||
/// </summary>
|
||||
public MobileControlTouchpanelControllerFactory()
|
||||
{
|
||||
TypeNames = new List<string>() { "mccrestronapp", "mctsw550", "mctsw750", "mctsw1050", "mctsw560", "mctsw760", "mctsw1060", "mctsw570", "mctsw770", "mcts770", "mctsw1070", "mcts1070", "mctsw1080", "mcts1080", "mcxpanel", "mcdge1000" };
|
||||
TypeNames = new List<string>() { "mccrestronapp", "mctsw550", "mctsw750", "mctsw1050", "mctsw560", "mctsw760", "mctsw1060", "mctsw570", "mctsw770", "mcts770", "mctsw1070", "mcts1070", "mcxpanel", "mcdge1000" };
|
||||
MinimumEssentialsFrameworkVersion = "2.0.0";
|
||||
|
||||
factories = new Dictionary<string, Func<uint, CrestronControlSystem, string, BasicTriListWithSmartObject>>
|
||||
|
|
@ -793,8 +765,6 @@ namespace PepperDash.Essentials.Touchpanel
|
|||
{"ts770", (id, controlSystem, projectName) => new Ts770(id, controlSystem)},
|
||||
{"tsw1070", (id, controlSystem, projectName) => new Tsw1070(id, controlSystem)},
|
||||
{"ts1070", (id, controlSystem, projectName) => new Ts1070(id, controlSystem)},
|
||||
{"tsw1080", (id, controlSystem, projectName) => new Tsw1080(id, controlSystem)},
|
||||
{"ts1080", (id, controlSystem, projectName) => new Ts1080(id, controlSystem)},
|
||||
{"dge1000", (id, controlSystem, projectName) => new Dge1000(id, controlSystem)}
|
||||
};
|
||||
}
|
||||
|
|
|
|||
|
|
@ -127,16 +127,6 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
/// </summary>
|
||||
public int Port { get; private set; }
|
||||
|
||||
/// <summary>
|
||||
/// Gets the HTTP scheme to use for generated URLs, based on whether the direct server is configured as secure
|
||||
/// </summary>
|
||||
private string HttpScheme => _parent.Config.DirectServer.Secure ? "https" : "http";
|
||||
|
||||
/// <summary>
|
||||
/// Gets the WebSocket scheme to use for generated URLs, based on whether the direct server is configured as secure
|
||||
/// </summary>
|
||||
private string WsScheme => _parent.Config.DirectServer.Secure ? "wss" : "ws";
|
||||
|
||||
/// <summary>
|
||||
/// Gets the user app URL prefix
|
||||
/// </summary>
|
||||
|
|
@ -144,8 +134,7 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
{
|
||||
get
|
||||
{
|
||||
return string.Format("{0}://{1}:{2}{3}?token=",
|
||||
HttpScheme,
|
||||
return string.Format("http://{0}:{1}{2}?token=",
|
||||
CrestronEthernetHelper.GetEthernetParameter(CrestronEthernetHelper.ETHERNET_PARAMETER_TO_GET.GET_CURRENT_IP_ADDRESS, 0),
|
||||
Port,
|
||||
_userAppBaseHref);
|
||||
|
|
@ -284,7 +273,7 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
{
|
||||
base.Initialize();
|
||||
|
||||
_server = new HttpServer(Port, _parent.Config.DirectServer.Secure);
|
||||
_server = new HttpServer(Port, false);
|
||||
|
||||
_server.OnGet += Server_OnGet;
|
||||
|
||||
|
|
@ -302,7 +291,7 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
{
|
||||
ClientCertificateRequired = false,
|
||||
CheckCertificateRevocation = false,
|
||||
EnabledSslProtocols = SslProtocols.Tls12
|
||||
EnabledSslProtocols = SslProtocols.Tls12 | SslProtocols.Tls11
|
||||
};
|
||||
}
|
||||
|
||||
|
|
@ -414,11 +403,11 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
ip = csIpAddress.ToString();
|
||||
}
|
||||
|
||||
var appUrl = $"{HttpScheme}://{ip}:{Port}/mc/app?token={touchpanel.Key}";
|
||||
var appUrl = $"http://{ip}:{_parent.Config.DirectServer.Port}/mc/app?token={touchpanel.Key}";
|
||||
|
||||
this.LogVerbose("Sending URL {appUrl} to touchpanel {touchpanelKey}", appUrl, touchpanel.Touchpanel.Key);
|
||||
|
||||
touchpanel.Touchpanel.SetAppUrl(appUrl);
|
||||
touchpanel.Touchpanel.SetAppUrl($"http://{ip}:{_parent.Config.DirectServer.Port}/mc/app?token={touchpanel.Key}");
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -498,7 +487,7 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
{
|
||||
var config = new MobileControlApplicationConfig
|
||||
{
|
||||
ApiPath = string.Format("{0}://{1}:{2}/mc/api", HttpScheme, processorIp, Port),
|
||||
ApiPath = string.Format("http://{0}:{1}/mc/api", processorIp, _parent.Config.DirectServer.Port),
|
||||
GatewayAppPath = "",
|
||||
LogoPath = _parent.Config.ApplicationConfig?.LogoPath ?? "logo/logo.png",
|
||||
EnableDev = _parent.Config.ApplicationConfig?.EnableDev ?? false,
|
||||
|
|
@ -1109,7 +1098,6 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
res.StatusCode = 200;
|
||||
res.Close();
|
||||
|
||||
// remote log collector has no dedicated secure flag; keep it on http regardless of DirectServer.Secure
|
||||
var logRequest = new HttpRequestMessage(HttpMethod.Post, $"http://{_parent.Config.DirectServer.Logging.Host}:{_parent.Config.DirectServer.Logging.Port}/logs")
|
||||
{
|
||||
Content = new StringContent(body, Encoding.UTF8, "application/json"),
|
||||
|
|
@ -1162,11 +1150,6 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
var qp = req.QueryString;
|
||||
var token = qp["token"];
|
||||
|
||||
// Each join mints a single-use clientId; the panel webview must never replay a cached
|
||||
// response, or it reconnects forever with an already-consumed id (1008 loop).
|
||||
res.Headers.Add("Cache-Control", "no-store");
|
||||
res.Headers.Add("Pragma", "no-cache");
|
||||
|
||||
this.LogVerbose("Join Room Request with token: {token}", token);
|
||||
|
||||
byte[] body;
|
||||
|
|
@ -1230,7 +1213,8 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
this.LogVerbose("Assigning ClientId: {clientId} for token: {token} at {timestamp}", clientId, token, now);
|
||||
|
||||
// Construct WebSocket URL with clientId query parameter
|
||||
var wsUrl = $"{WsScheme}://{CrestronEthernetHelper.GetEthernetParameter(CrestronEthernetHelper.ETHERNET_PARAMETER_TO_GET.GET_CURRENT_IP_ADDRESS, 0)}:{Port}{_wsPath}{token}?clientId={clientId}";
|
||||
var wsProtocol = "ws";
|
||||
var wsUrl = $"{wsProtocol}://{CrestronEthernetHelper.GetEthernetParameter(CrestronEthernetHelper.ETHERNET_PARAMETER_TO_GET.GET_CURRENT_IP_ADDRESS, 0)}:{Port}{_wsPath}{token}?clientId={clientId}";
|
||||
|
||||
// Construct the response object
|
||||
JoinResponse jRes = new JoinResponse
|
||||
|
|
@ -1242,8 +1226,7 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
Config = _parent.GetConfigWithPluginVersion(),
|
||||
CodeExpires = new DateTime().AddYears(1),
|
||||
UserCode = bridge.UserCode,
|
||||
UserAppUrl = string.Format("{0}://{1}:{2}/mc/app",
|
||||
HttpScheme,
|
||||
UserAppUrl = string.Format("http://{0}:{1}/mc/app",
|
||||
CrestronEthernetHelper.GetEthernetParameter(CrestronEthernetHelper.ETHERNET_PARAMETER_TO_GET.GET_CURRENT_IP_ADDRESS, 0),
|
||||
Port),
|
||||
WebSocketUrl = wsUrl,
|
||||
|
|
@ -1268,8 +1251,6 @@ namespace PepperDash.Essentials.WebSocketServer
|
|||
{
|
||||
res.StatusCode = 200;
|
||||
res.ContentType = "application/json";
|
||||
res.Headers.Add("Cache-Control", "no-store");
|
||||
res.Headers.Add("Pragma", "no-cache");
|
||||
var version = new Version() { ServerVersion = _parent.GetConfigWithPluginVersion().RuntimeInfo.PluginVersion };
|
||||
var message = JsonConvert.SerializeObject(version);
|
||||
this.LogVerbose("{message}", message);
|
||||
|
|
|
|||
|
|
@ -48,7 +48,7 @@
|
|||
</None>
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.Program" Version="2.21.274" />
|
||||
<PackageReference Include="Crestron.SimplSharp.SDK.Program" Version="2.21.90" />
|
||||
<PackageReference Include="System.IO.Compression" Version="4.0.0" />
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue