using System; using System.Collections; using System.Xml; using System.Threading; using GrassValley.Mseries.AppServer; using GrassValley.Mseries.AppServerLog; using GrassValley.Mseries.ChanStatus; using GrassValley.Mseries.ConfigMgr; using GrassValley.Mseries.Control; using GrassValley.Mseries.DVCapture; using GrassValley.Mseries.Editor; using GrassValley.Mseries.MediaMgr; using GrassValley.Mseries.Security; using GrassValley.Mseries.Status; using GrassValley.Mseries.TransferQueue; // Leave the following "css_reference" lines in when running with CS-Script. They're // more than just comments - they tell CS-Script which DLLs to load if the DLL // name does not match the namespace that it implements. //css_reference Credentials.dll; //css_reference ServerUtil.dll; /// /// This is a sample CS-Script app for controlling the Grass Valley K2 server. /// The code is regular C# code, but it's written for CS-Script which can /// run it as a script from a DOS command prompt. /// /// Go to the K2 AppServer Developer's Guide for more information: /// http://www.gvgdevelopers.com/K2DevGuide/K2DevGuide.html#%5B%5BCS-Script%20Sample%20Scripts%5D%5D /// /// For more information about CS-Script go to: /// http://www.members.optusnet.com.au/~olegshilo/ /// namespace K2Script { class Test { static int Main(string[] args) { try { // get the application's name & create a unique suite name string appName = Environment.GetCommandLineArgs()[0]; string suiteName = appName + "_" + System.Guid.NewGuid().ToString("N"); // fill in these values for your connection (i.e. hardcode them, pass in cmdline arguments, read from file, read from console, etc.) string host = ""; string username = ""; string password = ""; string domain = ""; // Connect to host & pass in credentials. The "using" block disposes connection when done. using ( Connection connection = new Connection(appName, suiteName, host, username, password, domain) ) { // do work only if we have a valid connection if ( connection.IsConnected ) { ////////////////////////// // DO WORK HERE ////////////////////////// // create a transfer queue connection using ( IXfrQueue ixfrQueue = connection.AppServer.CreateXfrQueue(appName) ) { string xmlData = ""; int transferItemCount = 0; XmlDocument xmlDoc = new XmlDocument(); Console.WriteLine("------------------------------------------------------"); while(true) { ixfrQueue.EnumerateXfrItems(out xmlData, out transferItemCount); if (transferItemCount > 0) { xmlDoc.LoadXml(xmlData); // need a namespace manager to parse the xml doc XmlNamespaceManager namespaceManager = new XmlNamespaceManager(xmlDoc.NameTable); namespaceManager.AddNamespace("ns", "x-schema:#Schema1"); XmlNodeList transferItems = xmlDoc.SelectNodes(("./TransferItems/ns:Data/ns:TransferItem"), namespaceManager); IEnumerator transferItemEnum = transferItems.GetEnumerator(); bool bMoreTransfers = transferItemEnum.MoveNext(); do { XmlNode transferItem = (XmlNode)transferItemEnum.Current; string source = transferItem.Attributes.GetNamedItem("SrcUml").Value; string dest = transferItem.Attributes.GetNamedItem("DestUml").Value; string token = transferItem.Attributes.GetNamedItem("Token").Value; string state = transferItem.Attributes.GetNamedItem("State").Value; string percent = transferItem.Attributes.GetNamedItem("Percent").Value; string averagerate = transferItem.Attributes.GetNamedItem("AverageRate").Value; string currentrate = transferItem.Attributes.GetNamedItem("CurrentRate").Value; string errorcode = transferItem.Attributes.GetNamedItem("ErrorCode").Value; string type = transferItem.Attributes.GetNamedItem("Type").Value; string starttimestamp = transferItem.Attributes.GetNamedItem("StartTimestamp").Value; Console.WriteLine("token : " + token + " state: " + state + " percent: " + percent); Console.WriteLine("source: " + source); Console.WriteLine("dest : " + dest); Console.WriteLine("type : " + type); Console.WriteLine("currentrate: " + currentrate + " averagerate: " + averagerate); Console.WriteLine("errorcode : " + errorcode); Console.WriteLine(""); bMoreTransfers = transferItemEnum.MoveNext(); } while (bMoreTransfers); Console.WriteLine("------------------------------------------------------"); Console.WriteLine(""); } Thread.Sleep(100); } } } } } catch (Exception e) { Console.WriteLine(e); } return 0; } } // Connection helper class: sets up credentials & hostname, connects to K2 public class Connection: IDisposable { private bool _connected = false; private AppServerMgrProxy _appServerMgrProxy = null; private IAppServer _appServer = null; /// /// Object that connects to the specified K2 credentials /// /// The application's name. /// The suite's name. /// The K2's host name. /// The username. /// The password. /// The domain. public Connection(string appname, string suitename, string host, string username, string password, string domain) { try { ////////////////////////// // SETUP ////////////////////////// if ( null == host || host.Length == 0) { Console.WriteLine("Empty host name passed to Connection object."); return; } ////////////////////////// // CONNECT TO K2 ////////////////////////// // create an AppServerMgr proxy object _appServerMgrProxy = new AppServerMgrProxy(); // tell it which K2 we're connecting to _appServerMgrProxy.SetHost(host); // give it the user credentials we want to use if ( username.Length > 0 ) _appServerMgrProxy.SetUserCredentials(username, password, domain, false); // connect to the K2's AppServerMgr if ( !_appServerMgrProxy.Connect() ) { // if the connection failed, report an error and exit Console.WriteLine("ERROR: Could not connect to AppService on host '" + host + "'. Check the host name."); _appServerMgrProxy = null; return; } // if we got here we're connected to K2 AppService ////////////////////////// // CREATE AN APPSERVER ////////////////////////// // now create an AppServer bool newConnection = false; _appServer = _appServerMgrProxy.CreateAppServer(suitename, appname, out newConnection); _connected = true; } catch (Exception e) { Console.WriteLine(e); } } /// /// Gets a value indicating whether this instance is connected. /// /// /// true if this instance is connected; otherwise, false. /// public bool IsConnected { get { return _connected; } } /// /// Gets the AppServerMgr. /// /// The AppServerMgr public AppServerMgrProxy AppServerMgr { get { if ( _appServerMgrProxy == null ) Console.WriteLine("WARNING: AppServerMgrProxy object == null!"); return _appServerMgrProxy; } } /// /// Gets the AppServer /// /// The AppServer public IAppServer AppServer { get { if ( _appServerMgrProxy == null ) Console.WriteLine("WARNING: AppServerProxy object == null!"); return _appServer; } } /// /// Disposes this instance. /// public void Dispose() { if ( _appServer != null ) _appServer.CloseConnection(); } } }