yt handler checks just need to be issued, and events unsubscribed

HumanCommunication.cs

@@ -41,6 +41,9 @@ namespace Director
         {
             Console.WriteLine($"[{DateTime.Now.ToLongTimeString()}] [{logLevel.ToString()}] {message}");
 
+            //if(logLevel >= LogLevel.Warning && false)
+            if(false) //TODO: re-enable
+            {
                 var httpWebRequest = (HttpWebRequest)WebRequest.Create(call_for_humans_discord_webhook);
                 httpWebRequest.ContentType = "application/json";
                 httpWebRequest.Method = "POST";
@@ -50,6 +53,7 @@ namespace Director
                 }
                 httpWebRequest.GetResponse();
             }
+        }
         public enum LogLevel { Trace, Verbose, Info, Warning, Error, Showstopper }
     }
     public class NotInitializedException : Exception

schedulable/Show.cs

@@ -29,9 +29,12 @@ namespace Schedulable.Show
         {
             public string cmd { get; set; }
             public string args { get; set; }
+            public TimeSpan leadTime { get; set; }
         }
-        public class CommandLineCheck : CommandLine
+        public class CommandLineCheck
         {
+            public string cmd { get; set; }
+            public string args { get; set; }
             public string target { get; set; }
         }
         #endregion

showHandlers/ShowHandler.cs

@@ -5,7 +5,6 @@ namespace ShowHandlers
 {
     public abstract class ShowHandler
     {
-        protected abstract TimeSpan AgentsRespondingBuffer { get; }
         public abstract void Handle(iCalHoopJumping.CalendarOccurrence evt);
     }
 }

showHandlers/TwitchStreamHandler.cs

@@ -5,7 +5,6 @@ namespace ShowHandlers
 {
     public class TwitchStreamHandler : ShowHandler
     {
-        protected override TimeSpan AgentsRespondingBuffer { get { return TimeSpan.FromHours(1); } }
         public override void Handle(iCalHoopJumping.CalendarOccurrence evt)
         {
             Console.WriteLine("I am a twitch stream handler, it falls to me to...");

showHandlers/YoutubeHandler.cs

@@ -19,15 +19,12 @@ namespace ShowHandlers
         private Dictionary<string, bool> checksProgress = new Dictionary<string, bool>();
         private readonly AutoResetEvent checkSignal = new AutoResetEvent(false);
 
-        protected override TimeSpan AgentsRespondingBuffer { get { return TimeSpan.FromHours(1); } }
-
         public override void Handle(iCalHoopJumping.CalendarOccurrence evt)
         {
             Console.WriteLine($"begin youtube handler. current time {DateTime.Now.ToLongTimeString()}");
             Console.WriteLine(JsonConvert.SerializeObject(evt));
             var ytConfig = File.ReadAllText(Program.conf.show_template_yt_release);
             config = JsonConvert.DeserializeObject<YoutubeRelease>(ytConfig);
-            config.PreShow.AgentsNeeded = config.PreShow.AgentsNeeded.Select(s => s.ToLower()).ToList();
             Task.Run(() => PreShow(evt));
             Console.WriteLine("kicked off the pre-show");
             if (evt.OccurrenceStart > DateTime.Now)
@@ -44,12 +41,21 @@ namespace ShowHandlers
         protected void PreShow(iCalHoopJumping.CalendarOccurrence evt)
         {
             Console.WriteLine($"it's the pre-show, showtime at: {evt.OccurrenceStart}");
+            config.PreShow.AgentsNeeded = config.PreShow.AgentsNeeded.Select(s => s.ToLower()).ToList();
 
-            preShow_GetAgents(evt);
+            var commandLeadNeeded = TimeSpan.FromMinutes(15);
-            preShow_RunChecks(evt);
+            foreach(var cl in config.PreShow.Commands)
+            {
+                if(cl.leadTime > commandLeadNeeded){
+                    commandLeadNeeded = cl.leadTime;
+                }
+            }
+
+            preShow_GetAgents(evt, commandLeadNeeded + TimeSpan.FromMinutes(10));
+            preShow_RunChecks(evt, commandLeadNeeded);
             preShow_RunCommands(evt);
         }
-        protected void preShow_GetAgents(iCalHoopJumping.CalendarOccurrence evt)
+        protected void preShow_GetAgents(iCalHoopJumping.CalendarOccurrence evt, TimeSpan leadNeeded)
         {
             Console.WriteLine($"preshow agents needed: {string.Join(", ", config.PreShow.AgentsNeeded)}");
             agentsPresent.Clear();
@@ -59,8 +65,8 @@ namespace ShowHandlers
             //Telefranz.Instance.ProduceMessage(new silver_messages.global.sound_off());
             while (config.PreShow.AgentsNeeded.Where(ap => !agentsPresent.Contains(ap))?.Count() > 0)
             {
-                checkSignal.WaitOne(TimeSpan.FromMinutes(1));
+                checkSignal.WaitOne(TimeSpan.FromSeconds(15));
-                if(DateTime.Now > evt.OccurrenceStart - AgentsRespondingBuffer)
+                if(DateTime.Now > evt.OccurrenceStart - leadNeeded)
                 {
                     var miaAgents = string.Join(", ", config.PreShow.AgentsNeeded.Where(ap => !agentsPresent.Contains(ap)));
                     HumanCommunication.Instance.Say($"Youtube handler getting antsy and going forward. mia agents: {miaAgents}",
@@ -70,27 +76,41 @@ namespace ShowHandlers
             }
             Console.WriteLine("going forward");
         }
-        protected void preShow_RunChecks(iCalHoopJumping.CalendarOccurrence evt)
+        protected void preShow_RunChecks(iCalHoopJumping.CalendarOccurrence evt, TimeSpan leadNeeded)
         {
             Console.WriteLine("pre show: run checks:");
-            //TODO
             checksProgress.Clear();
             var argsList = new List<string>() { JsonConvert.SerializeObject(evt) };
             //Telefranz.Instance.addHandler()
             foreach (var c in config.PreShow.Checks)
             {
                 checksProgress.Add(c.cmd, false);
-                Telefranz.Instance.ProduceMessage(new silver_messages.directorial.execute_check()
-                {
-                    check = c.cmd,
-                    args = argsList.Append(c.args).ToList()
-                });
             }
-            while (true)
+            Action issueChecks = () => {
+                foreach (var checkCmd in checksProgress.Where(cp => cp.Value == false).Select(kvp => kvp.Key))
                 {
-                checkSignal.WaitOne(TimeSpan.FromSeconds(45));
+                    var check = config.PreShow.Checks.First(clc => clc.cmd == checkCmd);
-
+                    // Telefranz.Instance.ProduceMessage(new silver_messages.directorial.execute_check()
+                    // {
+                    //     check = check.cmd,
+                    //     args = argsList.Append(check.args).ToList()
+                    // });
                 }
+            };
+            issueChecks();
+            while (checksProgress.ContainsValue(false))
+            {
+                checkSignal.WaitOne(TimeSpan.FromSeconds(15));
+                if(DateTime.Now > evt.OccurrenceStart - leadNeeded)
+                {
+                    var stillFailing = string.Join(", ", checksProgress.Where(cp => cp.Value == false).Select(cp => cp.Key));
+                    HumanCommunication.Instance.Say($"Youtube handler getting antsy and going forward. checks still failing: {stillFailing}",
+                        HumanCommunication.LogLevel.Error);
+                    break;
+                }
+                issueChecks();
+            }
+            Console.WriteLine("going forward");
         }
         protected void preShow_RunCommands(iCalHoopJumping.CalendarOccurrence evt)
         {