mirror of
https://github.com/PepperDash/Essentials.git
synced 2026-01-11 19:44:52 +00:00
514 lines
19 KiB
C#
514 lines
19 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using Crestron.SimplSharp;
|
|
using Crestron.SimplSharp.CrestronIO;
|
|
using Crestron.SimplSharpPro;
|
|
using Crestron.SimplSharpPro.CrestronThread;
|
|
using Crestron.SimplSharpPro.Diagnostics;
|
|
using Crestron.SimplSharp.Reflection;
|
|
|
|
using PepperDash.Core;
|
|
using PepperDash.Essentials.Core;
|
|
using PepperDash.Essentials.Core.Config;
|
|
using PepperDash.Essentials.Devices.Common;
|
|
using PepperDash.Essentials.DM;
|
|
using PepperDash.Essentials.Fusion;
|
|
using PepperDash.Essentials.Room.Config;
|
|
using PepperDash.Essentials.Room.Cotija;
|
|
|
|
namespace PepperDash.Essentials
|
|
{
|
|
public class ControlSystem : CrestronControlSystem
|
|
{
|
|
HttpLogoServer LogoServer;
|
|
|
|
List<object> FactoryObjects = new List<object>();
|
|
|
|
public ControlSystem()
|
|
: base()
|
|
{
|
|
Thread.MaxNumberOfUserThreads = 400;
|
|
Global.ControlSystem = this;
|
|
DeviceManager.Initialize(this);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Git 'er goin'
|
|
/// </summary>
|
|
public override void InitializeSystem()
|
|
{
|
|
DeterminePlatform();
|
|
|
|
//CrestronConsole.AddNewConsoleCommand(s => GoWithLoad(), "go", "Loads configuration file",
|
|
// ConsoleAccessLevelEnum.AccessOperator);
|
|
|
|
// CrestronConsole.AddNewConsoleCommand(S => { ConfigWriter.WriteConfigFile(null); }, "writeconfig", "writes the current config to a file", ConsoleAccessLevelEnum.AccessOperator);
|
|
CrestronConsole.AddNewConsoleCommand(s =>
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "CONSOLE MESSAGE: {0}", s);
|
|
}, "appdebugmessage", "Writes message to log", ConsoleAccessLevelEnum.AccessOperator);
|
|
|
|
CrestronConsole.AddNewConsoleCommand(s =>
|
|
{
|
|
foreach (var tl in TieLineCollection.Default)
|
|
CrestronConsole.ConsoleCommandResponse(" {0}\r", tl);
|
|
},
|
|
"listtielines", "Prints out all tie lines", ConsoleAccessLevelEnum.AccessOperator);
|
|
|
|
CrestronConsole.AddNewConsoleCommand(s =>
|
|
{
|
|
CrestronConsole.ConsoleCommandResponse
|
|
("Current running configuration. This is the merged system and template configuration");
|
|
CrestronConsole.ConsoleCommandResponse(Newtonsoft.Json.JsonConvert.SerializeObject
|
|
(ConfigReader.ConfigObject, Newtonsoft.Json.Formatting.Indented));
|
|
}, "showconfig", "Shows the current running merged config", ConsoleAccessLevelEnum.AccessOperator);
|
|
|
|
CrestronConsole.AddNewConsoleCommand(s =>
|
|
{
|
|
CrestronConsole.ConsoleCommandResponse("This system can be found at the following URLs:\r" +
|
|
"System URL: {0}\r" +
|
|
"Template URL: {1}", ConfigReader.ConfigObject.SystemUrl, ConfigReader.ConfigObject.TemplateUrl);
|
|
}, "portalinfo", "Shows portal URLS from configuration", ConsoleAccessLevelEnum.AccessOperator);
|
|
|
|
GoWithLoad();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Determines if the program is running on a processor (appliance) or server (VC-4).
|
|
///
|
|
/// Sets Global.FilePathPrefix based on platform
|
|
/// </summary>
|
|
public void DeterminePlatform()
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Determining Platform....");
|
|
|
|
string filePathPrefix;
|
|
|
|
var dirSeparator = Global.DirectorySeparator;
|
|
|
|
var version = Crestron.SimplSharp.Reflection.Assembly.GetExecutingAssembly().GetName().Version;
|
|
|
|
var versionString = string.Format("{0}.{1}.{2}", version.Major, version.Minor, version.Build);
|
|
|
|
string directoryPrefix;
|
|
|
|
directoryPrefix = Crestron.SimplSharp.CrestronIO.Directory.GetApplicationRootDirectory();
|
|
|
|
if (CrestronEnvironment.DevicePlatform != eDevicePlatform.Server) // Handles 3-series running Windows OS
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Starting Essentials v{0} on 3-series Appliance", versionString);
|
|
|
|
// Check if User/ProgramX exists
|
|
if(Directory.Exists(directoryPrefix + dirSeparator + "User"
|
|
+ dirSeparator + string.Format("program{0}", InitialParametersClass.ApplicationNumber)))
|
|
{
|
|
Debug.Console(0, @"User/program{0} directory found", InitialParametersClass.ApplicationNumber);
|
|
filePathPrefix = directoryPrefix + dirSeparator + "User"
|
|
+ dirSeparator + string.Format("program{0}", InitialParametersClass.ApplicationNumber) + dirSeparator;
|
|
}
|
|
// Check if Nvram/Programx exists
|
|
else if (Directory.Exists(directoryPrefix + dirSeparator + "Nvram"
|
|
+ dirSeparator + string.Format("program{0}", InitialParametersClass.ApplicationNumber)))
|
|
{
|
|
Debug.Console(0, @"Nvram/program{0} directory found", InitialParametersClass.ApplicationNumber);
|
|
filePathPrefix = directoryPrefix + dirSeparator + "Nvram"
|
|
+ dirSeparator + string.Format("program{0}", InitialParametersClass.ApplicationNumber) + dirSeparator;
|
|
}
|
|
// If neither exists, set path to User/ProgramX
|
|
else
|
|
{
|
|
Debug.Console(0, @"No previous directory found. Using User/program{0}", InitialParametersClass.ApplicationNumber);
|
|
filePathPrefix = directoryPrefix + dirSeparator + "User"
|
|
+ dirSeparator + string.Format("program{0}", InitialParametersClass.ApplicationNumber) + dirSeparator;
|
|
}
|
|
}
|
|
else // Handles Linux OS (Virtual Control)
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Starting Essentials v{0} on Virtual Control Server", versionString);
|
|
|
|
// Set path to User/
|
|
filePathPrefix = directoryPrefix + dirSeparator + "User" + dirSeparator;
|
|
}
|
|
|
|
Global.SetFilePathPrefix(filePathPrefix);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Do it, yo
|
|
/// </summary>
|
|
public void GoWithLoad()
|
|
{
|
|
try
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Starting Essentials load from configuration");
|
|
|
|
var filesReady = SetupFilesystem();
|
|
if (filesReady)
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Checking for plugins");
|
|
LoadPlugins();
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Folder structure verified. Loading config...");
|
|
if (!ConfigReader.LoadConfig2())
|
|
return;
|
|
|
|
Load();
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Essentials load complete\r" +
|
|
"-------------------------------------------------------------");
|
|
}
|
|
else
|
|
{
|
|
Debug.Console(0,
|
|
"------------------------------------------------\r" +
|
|
"------------------------------------------------\r" +
|
|
"------------------------------------------------\r" +
|
|
"Essentials file structure setup completed.\r" +
|
|
"Please load config, sgd and ir files and\r" +
|
|
"restart program.\r" +
|
|
"------------------------------------------------\r" +
|
|
"------------------------------------------------\r" +
|
|
"------------------------------------------------");
|
|
}
|
|
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
Debug.Console(0, "FATAL INITIALIZE ERROR. System is in an inconsistent state:\r{0}", e);
|
|
|
|
|
|
}
|
|
|
|
// Notify the OS that the program intitialization has completed
|
|
SystemMonitor.ProgramInitialization.ProgramInitializationComplete = true;
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Initial simple implementation. Reads user/programN/plugins folder and
|
|
/// use
|
|
/// </summary>
|
|
void LoadPlugins()
|
|
{
|
|
var dir = Global.FilePathPrefix + "plugins";
|
|
if (Directory.Exists(dir))
|
|
{
|
|
// TODO Clear out or create localPlugins folder (maybe in program slot folder)
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Plugins directory found, checking for factory plugins");
|
|
var di = new DirectoryInfo(dir);
|
|
var files = di.GetFiles("*.dll");
|
|
foreach (FileInfo fi in files)
|
|
{
|
|
// TODO COPY plugin to loadedPlugins folder
|
|
|
|
// TODO LOAD that loadedPlugins dll file
|
|
|
|
var assy = Assembly.LoadFrom(fi.FullName);
|
|
var ver = assy.GetName().Version;
|
|
var verStr = string.Format("{0}.{1}.{2}.{3}", ver.Major, ver.Minor, ver.Build, ver.Revision);
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Loaded plugin file '{0}', version {1}", fi.FullName, verStr);
|
|
|
|
// iteratate this assembly's classes, looking for "LoadPlugin()" methods
|
|
var types = assy.GetTypes();
|
|
foreach (var type in types)
|
|
{
|
|
var methods = type.GetMethods(BindingFlags.Public | BindingFlags.Static);
|
|
var loadPlugin = methods.FirstOrDefault(m => m.Name.Equals("LoadPlugin"));
|
|
if (loadPlugin != null)
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Adding type {0}", fi.FullName, type.FullName);
|
|
loadPlugin.Invoke(null, null);
|
|
}
|
|
|
|
}
|
|
|
|
// plugin dll will be loaded. Any classes in plugin should have a static constructor
|
|
// that registers that class with the Core.DeviceFactory
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Verifies filesystem is set up. IR, SGD, and programX folders
|
|
/// </summary>
|
|
bool SetupFilesystem()
|
|
{
|
|
Debug.Console(0, "Verifying and/or creating folder structure");
|
|
var configDir = Global.FilePathPrefix;
|
|
var configExists = Directory.Exists(configDir);
|
|
if (!configExists)
|
|
Directory.Create(configDir);
|
|
|
|
var irDir = Global.FilePathPrefix + "ir";
|
|
if (!Directory.Exists(irDir))
|
|
Directory.Create(irDir);
|
|
|
|
var sgdDir = Global.FilePathPrefix + "sgd";
|
|
if (!Directory.Exists(sgdDir))
|
|
Directory.Create(sgdDir);
|
|
|
|
var pluginDir = Global.FilePathPrefix + "plugins";
|
|
if (!Directory.Exists(pluginDir))
|
|
Directory.Create(pluginDir);
|
|
|
|
return configExists;
|
|
}
|
|
|
|
///// <summary>
|
|
/////
|
|
///// </summary>
|
|
///// <param name="s"></param>
|
|
//public void EnablePortalSync(string s)
|
|
//{
|
|
// if (s.ToLower() == "enable")
|
|
// {
|
|
// CrestronConsole.ConsoleCommandResponse("Portal Sync features enabled");
|
|
// }
|
|
//}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
public void TearDown()
|
|
{
|
|
Debug.Console(0, "Tearing down existing system");
|
|
DeviceManager.DeactivateAll();
|
|
|
|
TieLineCollection.Default.Clear();
|
|
|
|
foreach (var key in DeviceManager.GetDevices())
|
|
DeviceManager.RemoveDevice(key);
|
|
|
|
Debug.Console(0, "Tear down COMPLETE");
|
|
}
|
|
|
|
/// <summary>
|
|
///
|
|
/// </summary>
|
|
void Load()
|
|
{
|
|
LoadDevices();
|
|
LoadTieLines();
|
|
LoadRooms();
|
|
LoadLogoServer();
|
|
|
|
DeviceManager.ActivateAll();
|
|
|
|
LinkSystemMonitorToAppServer();
|
|
}
|
|
|
|
void LinkSystemMonitorToAppServer()
|
|
{
|
|
var sysMon = DeviceManager.GetDeviceForKey("systemMonitor") as PepperDash.Essentials.Core.Monitoring.SystemMonitorController;
|
|
|
|
var appServer = DeviceManager.GetDeviceForKey("appServer") as CotijaSystemController;
|
|
|
|
|
|
if (sysMon != null && appServer != null)
|
|
{
|
|
var key = sysMon.Key + "-" + appServer.Key;
|
|
var messenger = new PepperDash.Essentials.AppServer.Messengers.SystemMonitorMessenger
|
|
(key, sysMon, "/device/systemMonitor");
|
|
|
|
messenger.RegisterWithAppServer(appServer);
|
|
|
|
DeviceManager.AddDevice(messenger);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Reads all devices from config and adds them to DeviceManager
|
|
/// </summary>
|
|
public void LoadDevices()
|
|
{
|
|
// Build the processor wrapper class
|
|
DeviceManager.AddDevice(new PepperDash.Essentials.Core.Devices.CrestronProcessor("processor"));
|
|
|
|
// Add global System Monitor device
|
|
DeviceManager.AddDevice(new PepperDash.Essentials.Core.Monitoring.SystemMonitorController("systemMonitor"));
|
|
|
|
foreach (var devConf in ConfigReader.ConfigObject.Devices)
|
|
{
|
|
|
|
try
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Creating device '{0}', type '{1}'", devConf.Key, devConf.Type);
|
|
// Skip this to prevent unnecessary warnings
|
|
if (devConf.Key == "processor")
|
|
{
|
|
if (devConf.Type.ToLower() != Global.ControlSystem.ControllerPrompt.ToLower())
|
|
Debug.Console(0,
|
|
"WARNING: Config file defines processor type as '{0}' but actual processor is '{1}'! Some ports may not be available",
|
|
devConf.Type.ToUpper(), Global.ControlSystem.ControllerPrompt.ToUpper());
|
|
|
|
continue;
|
|
}
|
|
|
|
// Try local factories first
|
|
var newDev = DeviceFactory.GetDevice(devConf);
|
|
|
|
if (newDev == null)
|
|
newDev = BridgeFactory.GetDevice(devConf);
|
|
|
|
// Then associated library factories
|
|
if (newDev == null)
|
|
newDev = PepperDash.Essentials.Core.DeviceFactory.GetDevice(devConf);
|
|
if (newDev == null)
|
|
newDev = PepperDash.Essentials.Devices.Common.DeviceFactory.GetDevice(devConf);
|
|
if (newDev == null)
|
|
newDev = PepperDash.Essentials.DM.DeviceFactory.GetDevice(devConf);
|
|
if (newDev == null)
|
|
newDev = PepperDash.Essentials.Devices.Displays.DisplayDeviceFactory.GetDevice(devConf);
|
|
|
|
//if (newDev == null) // might want to consider the ability to override an essentials "type"
|
|
//{
|
|
// // iterate plugin factories
|
|
// foreach (var f in FactoryObjects)
|
|
// {
|
|
// var cresFactory = f as IGetCrestronDevice;
|
|
// if (cresFactory != null)
|
|
// {
|
|
// newDev = cresFactory.GetDevice(devConf, this);
|
|
// }
|
|
// }
|
|
//}
|
|
|
|
if (newDev != null)
|
|
DeviceManager.AddDevice(newDev);
|
|
else
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "ERROR: Cannot load unknown device type '{0}', key '{1}'.", devConf.Type, devConf.Key);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "ERROR: Creating device {0}. Skipping device. \r{1}", devConf.Key, e);
|
|
}
|
|
}
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "All Devices Loaded.");
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// Helper method to load tie lines. This should run after devices have loaded
|
|
/// </summary>
|
|
public void LoadTieLines()
|
|
{
|
|
// In the future, we can't necessarily just clear here because devices
|
|
// might be making their own internal sources/tie lines
|
|
|
|
var tlc = TieLineCollection.Default;
|
|
//tlc.Clear();
|
|
if (ConfigReader.ConfigObject.TieLines == null)
|
|
{
|
|
return;
|
|
}
|
|
|
|
foreach (var tieLineConfig in ConfigReader.ConfigObject.TieLines)
|
|
{
|
|
var newTL = tieLineConfig.GetTieLine();
|
|
if (newTL != null)
|
|
tlc.Add(newTL);
|
|
}
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "All Tie Lines Loaded.");
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Reads all rooms from config and adds them to DeviceManager
|
|
/// </summary>
|
|
public void LoadRooms()
|
|
{
|
|
if (ConfigReader.ConfigObject.Rooms == null)
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Warning, "WARNING: Configuration contains no rooms");
|
|
return;
|
|
}
|
|
|
|
foreach (var roomConfig in ConfigReader.ConfigObject.Rooms)
|
|
{
|
|
var room = EssentialsRoomConfigHelper.GetRoomObject(roomConfig) as EssentialsRoomBase;
|
|
if (room != null)
|
|
{
|
|
if (room is EssentialsHuddleSpaceRoom)
|
|
{
|
|
DeviceManager.AddDevice(room);
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Room is EssentialsHuddleSpaceRoom, attempting to add to DeviceManager with Fusion");
|
|
DeviceManager.AddDevice(new EssentialsHuddleSpaceFusionSystemControllerBase((EssentialsHuddleSpaceRoom)room, 0xf1));
|
|
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Attempting to build Cotija Bridge...");
|
|
// Cotija bridge
|
|
var bridge = new CotijaEssentialsHuddleSpaceRoomBridge(room as EssentialsHuddleSpaceRoom);
|
|
AddBridgePostActivationHelper(bridge); // Lets things happen later when all devices are present
|
|
DeviceManager.AddDevice(bridge);
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Cotija Bridge Added...");
|
|
}
|
|
else if (room is EssentialsHuddleVtc1Room)
|
|
{
|
|
DeviceManager.AddDevice(room);
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Room is EssentialsHuddleVtc1Room, attempting to add to DeviceManager with Fusion");
|
|
DeviceManager.AddDevice(new EssentialsHuddleVtc1FusionController((EssentialsHuddleVtc1Room)room, 0xf1));
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Attempting to build Cotija Bridge...");
|
|
// Cotija bridge
|
|
var bridge = new CotijaEssentialsHuddleSpaceRoomBridge(room);
|
|
AddBridgePostActivationHelper(bridge); // Lets things happen later when all devices are present
|
|
DeviceManager.AddDevice(bridge);
|
|
}
|
|
else
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "Room is NOT EssentialsRoom, attempting to add to DeviceManager w/o Fusion");
|
|
DeviceManager.AddDevice(room);
|
|
}
|
|
|
|
}
|
|
else
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "WARNING: Cannot create room from config, key '{0}'", roomConfig.Key);
|
|
}
|
|
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "All Rooms Loaded.");
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Helps add the post activation steps that link bridges to main controller
|
|
/// </summary>
|
|
/// <param name="bridge"></param>
|
|
void AddBridgePostActivationHelper(CotijaBridgeBase bridge)
|
|
{
|
|
bridge.AddPostActivationAction(() =>
|
|
{
|
|
var parent = DeviceManager.AllDevices.FirstOrDefault(d => d.Key == "appServer") as CotijaSystemController;
|
|
if (parent == null)
|
|
{
|
|
Debug.Console(0, bridge, "ERROR: Cannot connect app server room bridge. System controller not present");
|
|
return;
|
|
}
|
|
Debug.Console(0, bridge, "Linking to parent controller");
|
|
bridge.AddParent(parent);
|
|
parent.AddBridge(bridge);
|
|
});
|
|
}
|
|
|
|
/// <summary>
|
|
/// Fires up a logo server if not already running
|
|
/// </summary>
|
|
void LoadLogoServer()
|
|
{
|
|
try
|
|
{
|
|
LogoServer = new HttpLogoServer(8080, Global.DirectorySeparator + "html" + Global.DirectorySeparator + "logo");
|
|
}
|
|
catch (Exception)
|
|
{
|
|
Debug.Console(0, Debug.ErrorLogLevel.Notice, "NOTICE: Logo server cannot be started. Likely already running in another program");
|
|
}
|
|
}
|
|
}
|
|
}
|