diff --git a/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoCamera.cs b/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoCamera.cs
index 67312df8..9e8b0554 100644
--- a/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoCamera.cs
+++ b/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoCamera.cs
@@ -41,12 +41,12 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
public void PanLeft()
{
- ParentCodec.SendText(string.Format("xCommand Call FarEndControl Camera Move Value: Left CallId: {0}", CallId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Call FarEndControl Camera Move Value: Left CallId: {0}", CallId));
}
public void PanRight()
{
- ParentCodec.SendText(string.Format("xCommand Call FarEndControl Camera Move Value: Right CallId: {0}", CallId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Call FarEndControl Camera Move Value: Right CallId: {0}", CallId));
}
public void PanStop()
@@ -60,12 +60,12 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
public void TiltDown()
{
- ParentCodec.SendText(string.Format("xCommand Call FarEndControl Camera Move Value: Down CallId: {0}", CallId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Call FarEndControl Camera Move Value: Down CallId: {0}", CallId));
}
public void TiltUp()
{
- ParentCodec.SendText(string.Format("xCommand Call FarEndControl Camera Move Value: Up CallId: {0}", CallId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Call FarEndControl Camera Move Value: Up CallId: {0}", CallId));
}
public void TiltStop()
@@ -79,12 +79,12 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
public void ZoomIn()
{
- ParentCodec.SendText(string.Format("xCommand Call FarEndControl Camera Move Value: ZoomIn CallId: {0}", CallId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Call FarEndControl Camera Move Value: ZoomIn CallId: {0}", CallId));
}
public void ZoomOut()
{
- ParentCodec.SendText(string.Format("xCommand Call FarEndControl Camera Move Value: ZoomOut CallId: {0}", CallId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Call FarEndControl Camera Move Value: ZoomOut CallId: {0}", CallId));
}
public void ZoomStop()
@@ -97,7 +97,7 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
void Stop()
{
- ParentCodec.SendText(string.Format("xCommand Call FarEndControl Camera Stop CallId: {0}", CallId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Call FarEndControl Camera Stop CallId: {0}", CallId));
}
public void LinkToApi(BasicTriList trilist, uint joinStart, string joinMapKey, EiscApiAdvanced bridge)
@@ -202,7 +202,7 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
if (!isMoving)
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Pan: Left PanSpeed: {1}", CameraId, PanSpeed));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Pan: Left PanSpeed: {1}", CameraId, PanSpeed));
isPanning = true;
}
}
@@ -211,14 +211,14 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
if (!isMoving)
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Pan: Right PanSpeed: {1}", CameraId, PanSpeed));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Pan: Right PanSpeed: {1}", CameraId, PanSpeed));
isPanning = true;
}
}
public void PanStop()
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Pan: Stop", CameraId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Pan: Stop", CameraId));
isPanning = false;
}
@@ -232,7 +232,7 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
if (!isMoving)
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Tilt: Down TiltSpeed: {1}", CameraId, TiltSpeed));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Tilt: Down TiltSpeed: {1}", CameraId, TiltSpeed));
isTilting = true;
}
}
@@ -241,14 +241,14 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
if (!isMoving)
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Tilt: Up TiltSpeed: {1}", CameraId, TiltSpeed));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Tilt: Up TiltSpeed: {1}", CameraId, TiltSpeed));
isTilting = true;
}
}
public void TiltStop()
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Tilt: Stop", CameraId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Tilt: Stop", CameraId));
isTilting = false;
}
@@ -260,7 +260,7 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
if (!isMoving)
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Zoom: In ZoomSpeed: {1}", CameraId, ZoomSpeed));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Zoom: In ZoomSpeed: {1}", CameraId, ZoomSpeed));
isZooming = true;
}
}
@@ -269,14 +269,14 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
if (!isMoving)
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Zoom: Out ZoomSpeed: {1}", CameraId, ZoomSpeed));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Zoom: Out ZoomSpeed: {1}", CameraId, ZoomSpeed));
isZooming = true;
}
}
public void ZoomStop()
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Zoom: Stop", CameraId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Zoom: Stop", CameraId));
isZooming = false;
}
@@ -288,7 +288,7 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
if (!isMoving)
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Focus: Near", CameraId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Focus: Near", CameraId));
isFocusing = true;
}
}
@@ -297,20 +297,20 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
if (!isMoving)
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Focus: Far", CameraId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Focus: Far", CameraId));
isFocusing = true;
}
}
public void FocusStop()
{
- ParentCodec.SendText(string.Format("xCommand Camera Ramp CameraId: {0} Focus: Stop", CameraId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera Ramp CameraId: {0} Focus: Stop", CameraId));
isFocusing = false;
}
public void TriggerAutoFocus()
{
- ParentCodec.SendText(string.Format("xCommand Camera TriggerAutofocus CameraId: {0}", CameraId));
+ ParentCodec.EnqueueCommand(string.Format("xCommand Camera TriggerAutofocus CameraId: {0}", CameraId));
}
#endregion
diff --git a/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoSparkCodec.cs b/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoSparkCodec.cs
index e42386c8..b6f59dac 100644
--- a/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoSparkCodec.cs
+++ b/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/CiscoCodec/CiscoSparkCodec.cs
@@ -371,7 +371,7 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
_phonebookMode = props.PhonebookMode;
- _syncState = new CodecSyncState(Key + "--Sync");
+ _syncState = new CodecSyncState(Key + "--Sync", this);
PhonebookSyncState = new CodecPhonebookSyncState(Key + "--PhonebookSync");
@@ -547,7 +547,7 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
/// Mobile Control user code
private void DisplayUserCode(string code)
{
- SendText(string.Format("xcommand userinterface message alert display title:\"Mobile Control User Code:\" text:\"{0}\" duration: 30", code));
+ EnqueueCommand(string.Format("xcommand userinterface message alert display title:\"Mobile Control User Code:\" text:\"{0}\" duration: 30", code));
}
private void SendMcBrandingUrl(IMobileControlRoomBridge mcBridge)
@@ -559,17 +559,17 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
Debug.Console(1, this, "Sending url: {0}", mcBridge.QrCodeUrl);
- SendText("xconfiguration userinterface custommessage: \"Scan the QR code with a mobile phone to get started\"");
- SendText("xconfiguration userinterface osd halfwakemessage: \"Tap the touch panel or scan the QR code with a mobile phone to get started\"");
+ EnqueueCommand("xconfiguration userinterface custommessage: \"Scan the QR code with a mobile phone to get started\"");
+ EnqueueCommand("xconfiguration userinterface osd halfwakemessage: \"Tap the touch panel or scan the QR code with a mobile phone to get started\"");
var checksum = !String.IsNullOrEmpty(mcBridge.QrCodeChecksum)
? String.Format("checksum: {0} ", mcBridge.QrCodeChecksum)
: String.Empty;
- SendText(String.Format(
+ EnqueueCommand(String.Format(
"xcommand userinterface branding fetch {1}type: branding url: {0}",
mcBridge.QrCodeUrl, checksum));
- SendText(String.Format(
+ EnqueueCommand(String.Format(
"xcommand userinterface branding fetch {1}type: halfwakebranding url: {0}",
mcBridge.QrCodeUrl, checksum));
}
@@ -578,9 +578,9 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.Cisco
{
Debug.Console(1, this, "Sending url: {0}", _brandingUrl);
- SendText(String.Format("xcommand userinterface branding fetch type: branding url: {0}",
+ EnqueueCommand(String.Format("xcommand userinterface branding fetch type: branding url: {0}",
_brandingUrl));
- SendText(String.Format("xcommand userinterface branding fetch type: halfwakebranding url: {0}",
+ EnqueueCommand(String.Format("xcommand userinterface branding fetch type: halfwakebranding url: {0}",
_brandingUrl));
}
///
@@ -769,6 +769,12 @@ ConnectorID: {2}"
Debug.Console(1, this, "RX: '{0}'", args.Text);
}
+ if(args.Text.Contains("xCommand"))
+ {
+ Debug.Console(2, this, "Received command echo response. Ignoring");
+ return;
+ }
+
if (args.Text == "{" + Delimiter) // Check for the beginning of a new JSON message
{
_jsonFeedbackMessageIsIncoming = true;
@@ -813,6 +819,7 @@ ConnectorID: {2}"
if(_loginMessageReceivedTimer != null)
_loginMessageReceivedTimer.Stop();
+ SendText("echo off");
SendText("xPreferences outputmode json");
break;
}
@@ -829,12 +836,21 @@ ConnectorID: {2}"
}
}
}
-
-
}
///
- /// Appends the delimiter and send the command to the codec
+ /// Enqueues a command to be sent to the codec.
+ ///
+ ///
+ public void EnqueueCommand(string command)
+ {
+ _syncState.AddCommandToQueue(command + Delimiter);
+ }
+
+ ///
+ /// Appends the delimiter and send the command to the codec.
+ /// Should not be used for sending general commands to the codec. Use EnqueueCommand instead.
+ /// Should be used to get initial Status and Configuration as well as set up Feedback Registration
///
///
public void SendText(string command)
@@ -1062,7 +1078,9 @@ ConnectorID: {2}"
_syncState.InitialStatusMessageReceived();
if (!_syncState.InitialConfigurationMessageWasReceived)
+ {
SendText("xConfiguration");
+ }
}
}
else if (response.IndexOf("\"Configuration\":{") > -1 || response.IndexOf("\"Configuration\": {") > -1)
@@ -1296,7 +1314,7 @@ ConnectorID: {2}"
public void GetCallHistory()
{
- SendText("xCommand CallHistory Recents Limit: 20 Order: OccurrenceTime");
+ EnqueueCommand("xCommand CallHistory Recents Limit: 20 Order: OccurrenceTime");
}
///
@@ -1315,7 +1333,7 @@ ConnectorID: {2}"
{
Debug.Console(1, this, "Retrieving Booking Info from Codec. Current Time: {0}", DateTime.Now.ToLocalTime());
- SendText("xCommand Bookings List Days: 1 DayOffset: 0");
+ EnqueueCommand("xCommand Bookings List Days: 1 DayOffset: 0");
}
///
@@ -1349,13 +1367,13 @@ ConnectorID: {2}"
private void GetPhonebookFolders()
{
// Get Phonebook Folders (determine local/corporate from config, and set results limit)
- SendText(string.Format("xCommand Phonebook Search PhonebookType: {0} ContactType: Folder", _phonebookMode));
+ EnqueueCommand(string.Format("xCommand Phonebook Search PhonebookType: {0} ContactType: Folder", _phonebookMode));
}
private void GetPhonebookContacts()
{
// Get Phonebook Folders (determine local/corporate from config, and set results limit)
- SendText(string.Format("xCommand Phonebook Search PhonebookType: {0} ContactType: Contact Limit: {1}", _phonebookMode, _phonebookResultsLimit));
+ EnqueueCommand(string.Format("xCommand Phonebook Search PhonebookType: {0} ContactType: Contact Limit: {1}", _phonebookMode, _phonebookResultsLimit));
}
///
@@ -1364,7 +1382,7 @@ ConnectorID: {2}"
///
public void SearchDirectory(string searchString)
{
- SendText(string.Format("xCommand Phonebook Search SearchString: \"{0}\" PhonebookType: {1} ContactType: Contact Limit: {2}", searchString, _phonebookMode, _phonebookResultsLimit));
+ EnqueueCommand(string.Format("xCommand Phonebook Search SearchString: \"{0}\" PhonebookType: {1} ContactType: Contact Limit: {2}", searchString, _phonebookMode, _phonebookResultsLimit));
}
///
@@ -1373,7 +1391,7 @@ ConnectorID: {2}"
///
public void GetDirectoryFolderContents(string folderId)
{
- SendText(string.Format("xCommand Phonebook Search FolderId: {0} PhonebookType: {1} ContactType: Any Limit: {2}", folderId, _phonebookMode, _phonebookResultsLimit));
+ EnqueueCommand(string.Format("xCommand Phonebook Search FolderId: {0} PhonebookType: {1} ContactType: Any Limit: {2}", folderId, _phonebookMode, _phonebookResultsLimit));
}
///
@@ -1444,7 +1462,7 @@ ConnectorID: {2}"
///
public override void Dial(string number)
{
- SendText(string.Format("xCommand Dial Number: \"{0}\"", number));
+ EnqueueCommand(string.Format("xCommand Dial Number: \"{0}\"", number));
}
///
@@ -1469,43 +1487,43 @@ ConnectorID: {2}"
///
public void Dial(string number, string protocol, string callRate, string callType, string meetingId)
{
- SendText(string.Format("xCommand Dial Number: \"{0}\" Protocol: {1} CallRate: {2} CallType: {3} BookingId: {4}", number, protocol, callRate, callType, meetingId));
+ EnqueueCommand(string.Format("xCommand Dial Number: \"{0}\" Protocol: {1} CallRate: {2} CallType: {3} BookingId: {4}", number, protocol, callRate, callType, meetingId));
}
public override void EndCall(CodecActiveCallItem activeCall)
{
- SendText(string.Format("xCommand Call Disconnect CallId: {0}", activeCall.Id));
+ EnqueueCommand(string.Format("xCommand Call Disconnect CallId: {0}", activeCall.Id));
}
public override void EndAllCalls()
{
foreach (CodecActiveCallItem activeCall in ActiveCalls)
{
- SendText(string.Format("xCommand Call Disconnect CallId: {0}", activeCall.Id));
+ EnqueueCommand(string.Format("xCommand Call Disconnect CallId: {0}", activeCall.Id));
}
}
public override void AcceptCall(CodecActiveCallItem item)
{
- SendText("xCommand Call Accept");
+ EnqueueCommand("xCommand Call Accept");
}
public override void RejectCall(CodecActiveCallItem item)
{
- SendText("xCommand Call Reject");
+ EnqueueCommand("xCommand Call Reject");
}
#region IHasCallHold Members
public void HoldCall(CodecActiveCallItem activeCall)
{
- SendText(string.Format("xCommand Call Hold CallId: {0}", activeCall.Id));
+ EnqueueCommand(string.Format("xCommand Call Hold CallId: {0}", activeCall.Id));
}
public void ResumeCall(CodecActiveCallItem activeCall)
{
- SendText(string.Format("xCommand Call Resume CallId: {0}", activeCall.Id));
+ EnqueueCommand(string.Format("xCommand Call Resume CallId: {0}", activeCall.Id));
}
#endregion
@@ -1514,7 +1532,7 @@ ConnectorID: {2}"
public void JoinCall(CodecActiveCallItem activeCall)
{
- SendText(string.Format("xCommand Call Join CallId: {0}", activeCall.Id));
+ EnqueueCommand(string.Format("xCommand Call Join CallId: {0}", activeCall.Id));
}
public void JoinAllCalls()
@@ -1531,7 +1549,7 @@ ConnectorID: {2}"
if (ids.Length > 0)
{
- SendText(string.Format("xCommand Call Join {0}", ids.ToString()));
+ EnqueueCommand(string.Format("xCommand Call Join {0}", ids.ToString()));
}
}
@@ -1543,7 +1561,7 @@ ConnectorID: {2}"
///
public override void SendDtmf(string s)
{
- SendText(string.Format("xCommand Call DTMFSend CallId: {0} DTMFString: \"{1}\"", GetCallId(), s));
+ EnqueueCommand(string.Format("xCommand Call DTMFSend CallId: {0} DTMFString: \"{1}\"", GetCallId(), s));
}
///
@@ -1553,7 +1571,7 @@ ConnectorID: {2}"
///
public override void SendDtmf(string s, CodecActiveCallItem activeCall)
{
- SendText(string.Format("xCommand Call DTMFSend CallId: {0} DTMFString: \"{1}\"", activeCall.Id, s));
+ EnqueueCommand(string.Format("xCommand Call DTMFSend CallId: {0} DTMFString: \"{1}\"", activeCall.Id, s));
}
public void SelectPresentationSource(int source)
@@ -1581,7 +1599,7 @@ ConnectorID: {2}"
return;
}
- SendText(string.Format("xConfiguration Audio SoundsAndAlerts RingVolume: {0}", volume));
+ EnqueueCommand(string.Format("xConfiguration Audio SoundsAndAlerts RingVolume: {0}", volume));
}
///
@@ -1615,7 +1633,7 @@ ConnectorID: {2}"
sendingMode = "LocalOnly";
if (_desiredPresentationSource > 0)
- SendText(string.Format("xCommand Presentation Start PresentationSource: {0} SendingMode: {1}", _desiredPresentationSource, sendingMode));
+ EnqueueCommand(string.Format("xCommand Presentation Start PresentationSource: {0} SendingMode: {1}", _desiredPresentationSource, sendingMode));
}
///
@@ -1625,39 +1643,39 @@ ConnectorID: {2}"
{
_desiredPresentationSource = 0;
- SendText("xCommand Presentation Stop");
+ EnqueueCommand("xCommand Presentation Stop");
}
public override void PrivacyModeOn()
{
- SendText("xCommand Audio Microphones Mute");
+ EnqueueCommand("xCommand Audio Microphones Mute");
}
public override void PrivacyModeOff()
{
- SendText("xCommand Audio Microphones Unmute");
+ EnqueueCommand("xCommand Audio Microphones Unmute");
}
public override void PrivacyModeToggle()
{
- SendText("xCommand Audio Microphones ToggleMute");
+ EnqueueCommand("xCommand Audio Microphones ToggleMute");
}
public override void MuteOff()
{
- SendText("xCommand Audio Volume Unmute");
+ EnqueueCommand("xCommand Audio Volume Unmute");
}
public override void MuteOn()
{
- SendText("xCommand Audio Volume Mute");
+ EnqueueCommand("xCommand Audio Volume Mute");
}
public override void MuteToggle()
{
- SendText("xCommand Audio Volume ToggleMute");
+ EnqueueCommand("xCommand Audio Volume ToggleMute");
}
///
@@ -1666,7 +1684,7 @@ ConnectorID: {2}"
///
public override void VolumeUp(bool pressRelease)
{
- SendText("xCommand Audio Volume Increase");
+ EnqueueCommand("xCommand Audio Volume Increase");
}
///
@@ -1675,7 +1693,7 @@ ConnectorID: {2}"
///
public override void VolumeDown(bool pressRelease)
{
- SendText("xCommand Audio Volume Decrease");
+ EnqueueCommand("xCommand Audio Volume Decrease");
}
///
@@ -1685,7 +1703,7 @@ ConnectorID: {2}"
public override void SetVolume(ushort level)
{
var scaledLevel = CrestronEnvironment.ScaleWithLimits(level, 65535, 0, 100, 0);
- SendText(string.Format("xCommand Audio Volume Set Level: {0}", scaledLevel));
+ EnqueueCommand(string.Format("xCommand Audio Volume Set Level: {0}", scaledLevel));
}
///
@@ -1693,7 +1711,7 @@ ConnectorID: {2}"
///
public void VolumeSetToDefault()
{
- SendText("xCommand Audio Volume SetToDefault");
+ EnqueueCommand("xCommand Audio Volume SetToDefault");
}
///
@@ -1701,7 +1719,7 @@ ConnectorID: {2}"
///
public override void StandbyActivate()
{
- SendText("xCommand Standby Activate");
+ EnqueueCommand("xCommand Standby Activate");
}
///
@@ -1709,7 +1727,7 @@ ConnectorID: {2}"
///
public override void StandbyDeactivate()
{
- SendText("xCommand Standby Deactivate");
+ EnqueueCommand("xCommand Standby Deactivate");
}
public override void LinkToApi(BasicTriList trilist, uint joinStart, string joinMapKey, EiscApiAdvanced bridge)
@@ -1736,7 +1754,7 @@ ConnectorID: {2}"
public void LinkCiscoCodecToApi(BasicTriList trilist, CiscoCodecJoinMap joinMap)
{
// Custom commands to codec
- trilist.SetStringSigAction(joinMap.CommandToDevice.JoinNumber, (s) => this.SendText(s));
+ trilist.SetStringSigAction(joinMap.CommandToDevice.JoinNumber, (s) => this.EnqueueCommand(s));
var dndCodec = this as IHasDoNotDisturbMode;
@@ -1780,7 +1798,7 @@ ConnectorID: {2}"
///
public void Reboot()
{
- SendText("xCommand SystemUnit Boot Action: Restart");
+ EnqueueCommand("xCommand SystemUnit Boot Action: Restart");
}
///
@@ -1806,7 +1824,7 @@ ConnectorID: {2}"
///
public void SelfViewModeOn()
{
- SendText("xCommand Video Selfview Set Mode: On");
+ EnqueueCommand("xCommand Video Selfview Set Mode: On");
}
///
@@ -1814,7 +1832,7 @@ ConnectorID: {2}"
///
public void SelfViewModeOff()
{
- SendText("xCommand Video Selfview Set Mode: Off");
+ EnqueueCommand("xCommand Video Selfview Set Mode: Off");
}
///
@@ -1829,7 +1847,7 @@ ConnectorID: {2}"
else
mode = "On";
- SendText(string.Format("xCommand Video Selfview Set Mode: {0}", mode));
+ EnqueueCommand(string.Format("xCommand Video Selfview Set Mode: {0}", mode));
}
///
@@ -1838,7 +1856,7 @@ ConnectorID: {2}"
///
public void SelfviewPipPositionSet(CodecCommandWithLabel position)
{
- SendText(string.Format("xCommand Video Selfview Set Mode: On PIPPosition: {0}", position.Command));
+ EnqueueCommand(string.Format("xCommand Video Selfview Set Mode: On PIPPosition: {0}", position.Command));
}
///
@@ -1863,7 +1881,7 @@ ConnectorID: {2}"
///
public void LocalLayoutSet(CodecCommandWithLabel layout)
{
- SendText(string.Format("xCommand Video Layout LayoutFamily Set Target: local LayoutFamily: {0}", layout.Command));
+ EnqueueCommand(string.Format("xCommand Video Layout LayoutFamily Set Target: local LayoutFamily: {0}", layout.Command));
}
///
@@ -1907,7 +1925,7 @@ ConnectorID: {2}"
else
_currentPresentationView = "Maximized";
- SendText(string.Format("xCommand Video PresentationView Set View: {0}", _currentPresentationView));
+ EnqueueCommand(string.Format("xCommand Video PresentationView Set View: {0}", _currentPresentationView));
PresentationViewMaximizedFeedback.FireUpdate();
}
@@ -1935,7 +1953,7 @@ ConnectorID: {2}"
public void RemoveCallHistoryEntry(CodecCallHistory.CallHistoryEntry entry)
{
- SendText(string.Format("xCommand CallHistory DeleteEntry CallHistoryId: {0} AcknowledgeConsecutiveDuplicates: True", entry.OccurrenceHistoryId));
+ EnqueueCommand(string.Format("xCommand CallHistory DeleteEntry CallHistoryId: {0} AcknowledgeConsecutiveDuplicates: True", entry.OccurrenceHistoryId));
}
#region IHasCameraSpeakerTrack
@@ -1944,11 +1962,11 @@ ConnectorID: {2}"
{
if (!CameraAutoModeIsOnFeedback.BoolValue)
{
- SendText("xCommand Cameras SpeakerTrack Activate");
+ EnqueueCommand("xCommand Cameras SpeakerTrack Activate");
}
else
{
- SendText("xCommand Cameras SpeakerTrack Deactivate");
+ EnqueueCommand("xCommand Cameras SpeakerTrack Deactivate");
}
}
@@ -1959,7 +1977,7 @@ ConnectorID: {2}"
CameraMuteOff();
}
- SendText("xCommand Cameras SpeakerTrack Activate");
+ EnqueueCommand("xCommand Cameras SpeakerTrack Activate");
}
public void CameraAutoModeOff()
@@ -1969,7 +1987,7 @@ ConnectorID: {2}"
CameraMuteOff();
}
- SendText("xCommand Cameras SpeakerTrack Deactivate");
+ EnqueueCommand("xCommand Cameras SpeakerTrack Deactivate");
}
#endregion
@@ -2106,7 +2124,7 @@ ConnectorID: {2}"
var ciscoCam = camera as CiscoSparkCamera;
if (ciscoCam != null)
{
- SendText(string.Format("xCommand Video Input SetMainVideoSource SourceId: {0}", ciscoCam.CameraId));
+ EnqueueCommand(string.Format("xCommand Video Input SetMainVideoSource SourceId: {0}", ciscoCam.CameraId));
}
}
@@ -2259,19 +2277,19 @@ ConnectorID: {2}"
if (SelectedCamera is IAmFarEndCamera)
SelectFarEndPreset(preset);
else
- SendText(string.Format("xCommand RoomPreset Activate PresetId: {0}", preset));
+ EnqueueCommand(string.Format("xCommand RoomPreset Activate PresetId: {0}", preset));
}
public void CodecRoomPresetStore(int preset, string description)
{
- SendText(string.Format("xCommand RoomPreset Store PresetId: {0} Description: \"{1}\" Type: All", preset, description));
+ EnqueueCommand(string.Format("xCommand RoomPreset Store PresetId: {0} Description: \"{1}\" Type: All", preset, description));
}
#endregion
public void SelectFarEndPreset(int preset)
{
- SendText(string.Format("xCommand Call FarEndControl RoomPreset Activate CallId: {0} PresetId: {1}", GetCallId(), preset));
+ EnqueueCommand(string.Format("xCommand Call FarEndControl RoomPreset Activate CallId: {0} PresetId: {1}", GetCallId(), preset));
}
@@ -2308,7 +2326,7 @@ ConnectorID: {2}"
{
id = 3;
}
- SendText(string.Format("xCommand UserInterface Presentation ExternalSource Add ConnectorId: {0} SourceIdentifier: \"{1}\" Name: \"{2}\" Type: {3}", id, key, name, type.ToString()));
+ EnqueueCommand(string.Format("xCommand UserInterface Presentation ExternalSource Add ConnectorId: {0} SourceIdentifier: \"{1}\" Name: \"{2}\" Type: {3}", id, key, name, type.ToString()));
// SendText(string.Format("xCommand UserInterface Presentation ExternalSource State Set SourceIdentifier: \"{0}\" State: Ready", key));
Debug.Console(2, this, "Adding ExternalSource {0} {1}", connectorId, name);
@@ -2322,14 +2340,14 @@ ConnectorID: {2}"
///
public void SetExternalSourceState(string key, eExternalSourceMode mode)
{
- SendText(string.Format("xCommand UserInterface Presentation ExternalSource State Set SourceIdentifier: \"{0}\" State: {1}", key, mode.ToString()));
+ EnqueueCommand(string.Format("xCommand UserInterface Presentation ExternalSource State Set SourceIdentifier: \"{0}\" State: {1}", key, mode.ToString()));
}
///
/// Clears all external sources on the codec
///
public void ClearExternalSources()
{
- SendText("xCommand UserInterface Presentation ExternalSource RemoveAll");
+ EnqueueCommand("xCommand UserInterface Presentation ExternalSource RemoveAll");
}
@@ -2338,7 +2356,7 @@ ConnectorID: {2}"
///
public void SetSelectedSource(string key)
{
- SendText(string.Format("xCommand UserInterface Presentation ExternalSource Select SourceIdentifier: {0}", key));
+ EnqueueCommand(string.Format("xCommand UserInterface Presentation ExternalSource Select SourceIdentifier: {0}", key));
_externalSourceChangeRequested = true;
}
@@ -2377,7 +2395,7 @@ ConnectorID: {2}"
///
public void CameraMuteOn()
{
- SendText("xCommand Video Input MainVideo Mute");
+ EnqueueCommand("xCommand Video Input MainVideo Mute");
}
///
@@ -2385,7 +2403,7 @@ ConnectorID: {2}"
///
public void CameraMuteOff()
{
- SendText("xCommand Video Input MainVideo Unmute");
+ EnqueueCommand("xCommand Video Input MainVideo Unmute");
}
///
@@ -2405,12 +2423,12 @@ ConnectorID: {2}"
public void ActivateDoNotDisturbMode()
{
- SendText("xCommand Conference DoNotDisturb Activate");
+ EnqueueCommand("xCommand Conference DoNotDisturb Activate");
}
public void DeactivateDoNotDisturbMode()
{
- SendText("xCommand Conference DoNotDisturb Deactivate");
+ EnqueueCommand("xCommand Conference DoNotDisturb Deactivate");
}
public void ToggleDoNotDisturbMode()
@@ -2435,7 +2453,7 @@ ConnectorID: {2}"
public void HalfwakeActivate()
{
- SendText("xCommand Standby Halfwake");
+ EnqueueCommand("xCommand Standby Halfwake");
}
#endregion
@@ -2463,8 +2481,10 @@ ConnectorID: {2}"
public class CodecSyncState : IKeyed
{
bool _InitialSyncComplete;
+ private readonly CiscoSparkCodec _parent;
public event EventHandler InitialSyncCompleted;
+ private readonly CrestronQueue _commandQueue;
public string Key { get; private set; }
@@ -2491,10 +2511,43 @@ ConnectorID: {2}"
public bool FeedbackWasRegistered { get; private set; }
- public CodecSyncState(string key)
+ public CodecSyncState(string key, CiscoSparkCodec parent)
{
Key = key;
+ _parent = parent;
+ _commandQueue = new CrestronQueue(25);
CodecDisconnected();
+
+
+ while (InitialSyncComplete && !_commandQueue.IsEmpty)
+ {
+ var query = _commandQueue.Dequeue();
+
+ _parent.SendText(query);
+ }
+ }
+
+ //public void StartSync()
+ //{
+ // DequeueQueries();
+ //}
+
+ //private void DequeueQueries()
+ //{
+
+ // while (!_commandQueue.IsEmpty)
+ // {
+ // var query = _commandQueue.Dequeue();
+
+ // _parent.SendText(query);
+ // }
+
+ // InitialQueryMessagesSent();
+ //}
+
+ public void AddCommandToQueue(string query)
+ {
+ _commandQueue.Enqueue(query);
}
public void LoginMessageReceived()
@@ -2527,6 +2580,7 @@ ConnectorID: {2}"
public void CodecDisconnected()
{
+ _commandQueue.Clear();
LoginMessageWasReceived = false;
InitialConfigurationMessageWasReceived = false;
InitialStatusMessageWasReceived = false;
@@ -2536,7 +2590,7 @@ ConnectorID: {2}"
void CheckSyncStatus()
{
- if (LoginMessageWasReceived && InitialConfigurationMessageWasReceived && InitialStatusMessageWasReceived && FeedbackWasRegistered)
+ if (LoginMessageWasReceived && InitialConfigurationMessageWasReceived && InitialStatusMessageWasReceived && FeedbackWasRegistered)
{
InitialSyncComplete = true;
Debug.Console(1, this, "Initial Codec Sync Complete!");
diff --git a/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/ZoomRoom/ZoomRoom.cs b/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/ZoomRoom/ZoomRoom.cs
index a43ea79c..1fa58ffb 100644
--- a/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/ZoomRoom/ZoomRoom.cs
+++ b/essentials-framework/Essentials Devices Common/Essentials Devices Common/VideoCodec/ZoomRoom/ZoomRoom.cs
@@ -3200,7 +3200,7 @@ namespace PepperDash.Essentials.Devices.Common.VideoCodec.ZoomRoom
CheckSyncStatus();
}
- public void InitialQueryMessagesSent()
+ private void InitialQueryMessagesSent()
{
InitialQueryMessagesWereSent = true;
Debug.Console(1, this, "Query Messages Sent.");