diff options
Diffstat (limited to 'Software/Visual_Studio/Tango.Telemetry/Sources')
3 files changed, 146 insertions, 16 deletions
diff --git a/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryEventsHistorySource.cs b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryEventsHistorySource.cs new file mode 100644 index 000000000..57abee66b --- /dev/null +++ b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryEventsHistorySource.cs @@ -0,0 +1,79 @@ +using System; +using System.Collections.Generic; +using System.Data.Entity; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using Tango.BL; +using Tango.Telemetry.Mappers; +using Tango.Telemetry.Telemetries; + +namespace Tango.Telemetry.Sources +{ + public class TelemetryEventsHistorySource : ITelemetryHistorySource + { + private bool _isBusy; + + public TelemetryHistorySourceDirection Direction { get; } = TelemetryHistorySourceDirection.Descending; + public string Name { get; } = "Events History"; + public bool RequiresTelemetryDuplicationTracking { get; } = true; + + public async Task<bool> CanRequestHistory(DateTime from) + { + if (_isBusy) + { + return false; + } + else + { + try + { + using (ObservablesContext db = ObservablesContext.CreateDefault()) + { + return await db.MachinesEvents.CountAsync(x => x.LastUpdated < from) > 0; + } + } + catch + { + return false; + } + } + } + + public async Task<IEnumerable<ITelemetry>> RequestHistory(DateTime from) + { + try + { + _isBusy = true; + + using (ObservablesContext db = ObservablesContext.CreateDefault()) + { + var events = await db.MachinesEvents + .OrderByDescending(x => x.LastUpdated) + .Where(x => x.LastUpdated < from) + .Take(10) + .ToListAsync(); + + List<TelemetryEvent> tRuns = new List<TelemetryEvent>(); + + foreach (var ev in events) + { + var tEvent = EventMapper.MapEvent(ev); + tRuns.Add(tEvent); + } + + return tRuns; + } + } + finally + { + _isBusy = false; + } + } + + public void Dispose() + { + + } + } +} diff --git a/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryEventsStreamingSource.cs b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryEventsStreamingSource.cs new file mode 100644 index 000000000..4b00c49ce --- /dev/null +++ b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryEventsStreamingSource.cs @@ -0,0 +1,64 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; +using Tango.BL.Entities; +using Tango.Integration.Operation; +using Tango.Telemetry.Mappers; +using Tango.Telemetry.Telemetries; + +namespace Tango.Telemetry.Sources +{ + public class TelemetryEventsStreamingSource : ITelemetryStreamingSource + { + private IMachineOperator _machineOperator; + + public bool IsStarted { get; private set; } + public string Name { get; } = "Events Streaming"; + public bool RequiresTelemetryDuplicationTracking { get; } = true; + + public event EventHandler<TelemetryAvailableEventArgs> TelemetryAvailable; + + public TelemetryEventsStreamingSource(IMachineOperator machineOperator) + { + _machineOperator = machineOperator; + } + + private void MachineEventsStateProvider_NewEvents(object sender, IEnumerable<MachinesEvent> events) + { + if (IsStarted) + { + foreach (var ev in events) + { + TelemetryEvent t = EventMapper.MapEvent(ev); + + TelemetryAvailable?.Invoke(this, new TelemetryAvailableEventArgs() { TelemetryObject = t }); + } + } + } + + public void Start() + { + if (!IsStarted) + { + IsStarted = true; + _machineOperator.MachineEventsStateProvider.NewEvents += MachineEventsStateProvider_NewEvents; + } + } + + public void Stop() + { + if (IsStarted) + { + IsStarted = false; + _machineOperator.MachineEventsStateProvider.NewEvents -= MachineEventsStateProvider_NewEvents; + } + } + + public void Dispose() + { + Stop(); + } + } +} diff --git a/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryLogsStreamingSource.cs b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryLogsStreamingSource.cs index 9deb93132..2c8020f7c 100644 --- a/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryLogsStreamingSource.cs +++ b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryLogsStreamingSource.cs @@ -5,6 +5,7 @@ using System.Text; using System.Threading.Tasks; using Tango.Integration.Operation; using Tango.Logging; +using Tango.Telemetry.Mappers; using Tango.Telemetry.Telemetries; namespace Tango.Telemetry.Sources @@ -53,14 +54,7 @@ namespace Tango.Telemetry.Sources _lastFirmwareMessage = new KeyValuePair<DateTime, string>(DateTime.UtcNow, log.Message); - TelemetryLog tLog = new TelemetryLog(); - tLog.Source = "Firmware"; - tLog.Time = DateTime.UtcNow; - tLog.Category = log.Category.ToString(); - tLog.Class = log.FileName; - tLog.Method = $"[{log.ModuleId}] [{log.Filter}] [{log.Parameter}]"; - tLog.Line = log.LineNumber; - tLog.Message = log.Message; + TelemetryLog tLog = LogMapper.MapLog(log); TelemetryAvailable?.Invoke(this, new TelemetryAvailableEventArgs() { TelemetryObject = tLog }); } } @@ -71,14 +65,7 @@ namespace Tango.Telemetry.Sources { if (!Config.Categories.Contains(log.Category)) return; - TelemetryLog tLog = new TelemetryLog(); - tLog.Source = "Application"; - tLog.Time = log.TimeStamp.ToUniversalTime(); - tLog.Category = log.Category.ToString(); - tLog.Class = log.ClassName; - tLog.Method = log.CallerMethodName; - tLog.Line = log.CallerLineNumber; - tLog.Message = log.Message; + TelemetryLog tLog = LogMapper.MapLog(log); TelemetryAvailable?.Invoke(this, new TelemetryAvailableEventArgs() { TelemetryObject = tLog }); } } |