Telemetry JobRuns.

1 files changed, 28 insertions, 22 deletions

diff --git a/Software/Visual_Studio/Utilities/Tango.Telemetry.Tester.IOT.CLI/Program.cs b/Software/Visual_Studio/Utilities/Tango.Telemetry.Tester.IOT.CLI/Program.cs
index cb8a79288..0565ab00d 100644
--- a/Software/Visual_Studio/Utilities/Tango.Telemetry.Tester.IOT.CLI/Program.cs
+++ b/Software/Visual_Studio/Utilities/Tango.Telemetry.Tester.IOT.CLI/Program.cs
@@ -3,8 +3,11 @@ using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
+using Tango.BL;
 using Tango.BL.Enumerations;
+using Tango.Logging;
 using Tango.Telemetry.Destinations;
+using Tango.Telemetry.Mappers;
 using Tango.Telemetry.Sources;
 
 namespace Tango.Telemetry.Tester.IOT.CLI
@@ -13,10 +16,13 @@ namespace Tango.Telemetry.Tester.IOT.CLI
     {
         static void Main(string[] args)
         {
+            LogManager.Default.RegisterLogger(new Tango.Logging.VSOutputLogger("IOT TESTER"));
+
             TelemetryPublisher publisher = new TelemetryPublisher(new TelemetryPublisherConfiguration()
             {
                 Environment = "DEV",
                 SerialNumber = "dev-machine",
+                Organization = "Twine",
                 MachineType = MachineTypes.TS1800,
                 HistorySourcesRequestInterval = TimeSpan.FromSeconds(1),
                 EnableBackoff = false,
@@ -64,24 +70,17 @@ namespace Tango.Telemetry.Tester.IOT.CLI
         }
     }
 
-    [TelemetryName("JobRun")]
-    public class JobRunTestTelemetry : TelemetryBase
-    {
-        public String JobName { get; set; }
-        public String Thread { get; set; }
-        public double Length { get; set; }
-    }
-
     public class JobRunsTestSource : ITelemetryHistorySource
     {
-        private int counter = 1;
+        private bool _busy;
 
-        public string Name { get; } = "Persons Source";
+        public string Name { get; } = "JobRuns Source";
         public bool RequiresTelemetryDuplicationTracking { get; } = false;
+        public TelemetryHistorySourceDirection Direction { get => TelemetryHistorySourceDirection.Descending; }
 
         public Task<bool> CanRequestHistory(DateTime from)
         {
-            return Task.FromResult(true);
+            return Task.FromResult(!_busy);
         }
 
         public void Dispose()
@@ -91,17 +90,24 @@ namespace Tango.Telemetry.Tester.IOT.CLI
 
         public Task<IEnumerable<ITelemetry>> RequestHistory(DateTime from)
         {
-            return Task.
-                FromResult<IEnumerable<ITelemetry>>(new List<JobRunTestTelemetry>()
-                {
-                    new JobRunTestTelemetry()
-                    {
-                        Time = DateTime.UtcNow,
-                        JobName = $"Job For Materialized {counter++}",
-                        Length = 1000 + counter,
-                        Thread = $"Coats Thread {counter}"
-                    }
-                });
+            _busy = true;
+            
+            ObservablesContext.OverrideSettingsDataSource(new Core.DataSource()
+            {
+                Address = "localhost\\SQLPPC",
+                IntegratedSecurity = true,
+                Catalog = "Tango",
+                Type = Core.DataSourceType.SQLServer,
+            });
+
+            using (ObservablesContext db = ObservablesContext.CreateDefault())
+            {
+                var runs = db.JobRuns.OrderByDescending(x => x.LastUpdated).Where(x => x.LastUpdated < from).Take(1).ToList();
+                var runsT = runs.Select(x => JobRunMapper.MapJobRun(x)).ToList();
+
+                _busy = false;
+                return Task.FromResult<IEnumerable<ITelemetry>>(runsT);
+            }
         }
     }
 }