Essentials/essentials-framework/Essentials Core/PepperDashEssentialsBase/Devices/GenericIRController.cs

using System.Collections.Generic;
using System.Linq;
using Crestron.SimplSharpPro.DeviceSupport;
using Newtonsoft.Json;
using PepperDash.Core;
using PepperDash.Essentials.Core.Bridges;
using PepperDash.Essentials.Core.Config;
using PepperDash_Essentials_Core.Bridges.JoinMaps;

namespace PepperDash.Essentials.Core.Devices
{
    public class GenericIrController: EssentialsBridgeableDevice
    {
        //data storage for bridging
        private BasicTriList _trilist;
        private uint _joinStart;
        private string _joinMapKey;
        private EiscApiAdvanced _bridge;

        private readonly IrOutputPortController _port; 

        public string[] IrCommands {get { return _port.IrFileCommands; }}	    

        public GenericIrController(string key, string name, IrOutputPortController irPort) : base(key, name)
        {
            _port = irPort;
            if (_port == null)
            {
                Debug.Console(0, this, Debug.ErrorLogLevel.Error, "IR Port is null, device will not function");
                return;
            }
            DeviceManager.AddDevice(_port);

            _port.DriverLoaded.OutputChange += DriverLoadedOnOutputChange;
        }

        private void DriverLoadedOnOutputChange(object sender, FeedbackEventArgs args)
        {
            if (!args.BoolValue)
            {
                return;
            }

            if (_trilist == null || _bridge == null)
            {
                return;
            }

            LinkToApi(_trilist, _joinStart, _joinMapKey, _bridge);
        }

        #region Overrides of EssentialsBridgeableDevice

        public override void LinkToApi(BasicTriList trilist, uint joinStart, string joinMapKey, EiscApiAdvanced bridge)
        {
            //if driver isn't loaded yet, store the variables until it is loaded, then call the LinkToApi method again
            if (!_port.DriverIsLoaded)
            {
                _trilist = trilist;
                _joinStart = joinStart;
                _joinMapKey = joinMapKey;
                _bridge = bridge;
                return;
            }

            var joinMap = new GenericIrControllerJoinMap(joinStart);

            var joinMapSerialized = JoinMapHelper.GetSerializedJoinMapForDevice(joinMapKey);

            if (!string.IsNullOrEmpty(joinMapSerialized))
                joinMap = JsonConvert.DeserializeObject<GenericIrControllerJoinMap>(joinMapSerialized);

	        if (_port.UseBridgeJoinMap)
	        {
				Debug.Console(0, this, "Using new IR bridge join map");

		        var bridgeJoins = joinMap.Joins.Where((kv) => _port.IrFileCommands.Any(cmd => cmd == kv.Key)).ToDictionary(kv => kv.Key);
		        if (bridgeJoins == null)
		        {
					Debug.Console(0, this, Debug.ErrorLogLevel.Error, "Failed to link new IR bridge join map");
			        return;
		        }
		        foreach (var bridgeJoin in bridgeJoins)
		        {
					Debug.Console(0, this, @"bridgeJoin: Key-'{0}'
Value.Key-'{1}'
Value.JoinNumber-'{2}'
Value.Metadata.Description-'{3}'", 
						bridgeJoin.Key, 
						bridgeJoin.Value.Key, 
						bridgeJoin.Value.Value.JoinNumber, 
						bridgeJoin.Value.Value.Metadata.Description);

			        var joinNumber = bridgeJoin.Value.Value.JoinNumber;
			        var joinCmd = bridgeJoin.Key;

			        trilist.SetBoolSigAction(joinNumber, (b) => Press(joinCmd, b));
		        }		        

		        //foreach (var irFileCommand in _port.IrFileCommands)
		        //{
		        //    var cmd = irFileCommand;
		        //    JoinDataComplete joinDataComplete;
		        //    if (joinMap.Joins.TryGetValue(cmd, out joinDataComplete))
		        //    {
		        //        Debug.Console(0, this, "joinDataComplete: attributeName-'{0}', joinNumber-'{1}', joinSpan-'{2}', metadata.description-'{3}'",
		        //            joinDataComplete.AttributeName, joinDataComplete.JoinNumber, joinDataComplete.JoinSpan, joinDataComplete.Metadata.Description);				        

		        //        trilist.SetBoolSigAction(joinDataComplete.JoinNumber, (b) => Press(cmd, b));
		        //    }
		        //    else
		        //    {
		        //        Debug.Console(0, this, "GenericIrController join map does not contain support for IR command '{0}', verify IR file.", cmd);
		        //    }




		        //    //if (joinMap.Joins.ContainsKey(cmd))
		        //    //{
		        //    //    Debug.Console(0, this, "joinData: key-'{0}', joinNumber-'{1}', joinSpan-'{2}', description-'{3}'",
		        //    //        joinData.Key, joinData.Value.JoinNumber, joinData.Value.JoinSpan, joinData.Value.Metadata.Description);
		        //    //}

		        //    //Debug.Console(0, this, "_port.IrFileCommand: {0}", irFileCommand);
		        //    //var joinData = joinMap.Joins.FirstOrDefault(j => j.Key == cmd);			        

		        //    //if (joinData.Value == null) continue;

		        //    //joinData.Value.SetJoinOffset(joinStart);

		        //    //Debug.Console(0, this, "joinData: key-'{0}', joinNumber-'{1}', joinSpan-'{2}', description-'{3}'",
		        //    //    joinData.Key, joinData.Value.JoinNumber, joinData.Value.JoinSpan, joinData.Value.Metadata.Description);

		        //    //joinMap.Joins.Add(joinData.Key, joinData.Value);

		        //    //trilist.SetBoolSigAction(joinData.Value.JoinNumber, (b) => Press(joinData.Key, b));
		        //}
	        }
	        else
	        {
				Debug.Console(0, this, "Using legacy IR join mapping based on available IR commands");

				joinMap.Joins.Clear();

				for (uint i = 0; i < _port.IrFileCommands.Length; i++)
				{
					var cmd = _port.IrFileCommands[i];
					var joinData = new JoinDataComplete(new JoinData { JoinNumber = i, JoinSpan = 1 },
						new JoinMetadata
						{
							Description = cmd,
							JoinCapabilities = eJoinCapabilities.FromSIMPL,
							JoinType = eJoinType.Digital
						});

					joinData.SetJoinOffset(joinStart);

					joinMap.Joins.Add(cmd, joinData);

					trilist.SetBoolSigAction(joinData.JoinNumber, (b) => Press(cmd, b));
				}   
	        }            

            joinMap.PrintJoinMapInfo();

            if (bridge != null)
            {
                bridge.AddJoinMap(Key, joinMap);
            }
            else
            {
                Debug.Console(0, this, "Please update config to use 'eiscapiadvanced' to get all join map features for this device.");
            }
        }

        #endregion

        public void Press(string command, bool pressRelease)
        {
            _port.PressRelease(command, pressRelease);
        }
    }

    public class GenericIrControllerFactory : EssentialsDeviceFactory<GenericIrController>
    {
        public GenericIrControllerFactory()
        {
            TypeNames = new List<string> {"genericIrController"};
        }
        #region Overrides of EssentialsDeviceFactory<GenericIRController>

        public override EssentialsDevice BuildDevice(DeviceConfig dc)
        {
            Debug.Console(1, "Factory Attempting to create new Generic IR Controller Device");

            var irPort = IRPortHelper.GetIrOutputPortController(dc);

            return new GenericIrController(dc.Key, dc.Name, irPort);
        }

        #endregion
    }
}