mirror of https://github.com/ErsatzTV/ErsatzTV.git
Jason Dove
3 years ago
committed by
GitHub
11 changed files with 385 additions and 42 deletions
@ -0,0 +1,3 @@
@@ -0,0 +1,3 @@
|
||||
namespace ErsatzTV.Application.Troubleshooting; |
||||
|
||||
public record HealthCheckResultSummary(string Title, string Message); |
||||
@ -0,0 +1,3 @@
@@ -0,0 +1,3 @@
|
||||
namespace ErsatzTV.Application.Troubleshooting.Queries; |
||||
|
||||
public record GetTroubleshootingInfo : IRequest<TroubleshootingInfo>; |
||||
@ -0,0 +1,193 @@
@@ -0,0 +1,193 @@
|
||||
using System.Collections.Immutable; |
||||
using System.Reflection; |
||||
using System.Runtime.InteropServices; |
||||
using ErsatzTV.Application.FFmpegProfiles; |
||||
using ErsatzTV.Core.Domain; |
||||
using ErsatzTV.Core.FFmpeg; |
||||
using ErsatzTV.Core.Health; |
||||
using ErsatzTV.Core.Interfaces.Repositories; |
||||
using ErsatzTV.FFmpeg.Capabilities; |
||||
using ErsatzTV.FFmpeg.Runtime; |
||||
using ErsatzTV.Infrastructure.Data; |
||||
using ErsatzTV.Infrastructure.Runtime; |
||||
using Microsoft.EntityFrameworkCore; |
||||
using Microsoft.Extensions.Caching.Memory; |
||||
|
||||
namespace ErsatzTV.Application.Troubleshooting.Queries; |
||||
|
||||
public class GetTroubleshootingInfoHandler : IRequestHandler<GetTroubleshootingInfo, TroubleshootingInfo> |
||||
{ |
||||
private readonly IDbContextFactory<TvContext> _dbContextFactory; |
||||
private readonly IHealthCheckService _healthCheckService; |
||||
private readonly IHardwareCapabilitiesFactory _hardwareCapabilitiesFactory; |
||||
private readonly IConfigElementRepository _configElementRepository; |
||||
private readonly IRuntimeInfo _runtimeInfo; |
||||
private readonly IMemoryCache _memoryCache; |
||||
|
||||
public GetTroubleshootingInfoHandler( |
||||
IDbContextFactory<TvContext> dbContextFactory, |
||||
IHealthCheckService healthCheckService, |
||||
IHardwareCapabilitiesFactory hardwareCapabilitiesFactory, |
||||
IConfigElementRepository configElementRepository, |
||||
IRuntimeInfo runtimeInfo, |
||||
IMemoryCache memoryCache) |
||||
{ |
||||
_dbContextFactory = dbContextFactory; |
||||
_healthCheckService = healthCheckService; |
||||
_hardwareCapabilitiesFactory = hardwareCapabilitiesFactory; |
||||
_configElementRepository = configElementRepository; |
||||
_runtimeInfo = runtimeInfo; |
||||
_memoryCache = memoryCache; |
||||
} |
||||
|
||||
public async Task<TroubleshootingInfo> Handle(GetTroubleshootingInfo request, CancellationToken cancellationToken) |
||||
{ |
||||
List<HealthCheckResult> healthCheckResults = await _healthCheckService.PerformHealthChecks(cancellationToken); |
||||
|
||||
string version = Assembly.GetEntryAssembly()? |
||||
.GetCustomAttribute<AssemblyInformationalVersionAttribute>()? |
||||
.InformationalVersion ?? "unknown"; |
||||
|
||||
var healthCheckSummaries = healthCheckResults |
||||
.Filter(r => r.Status is HealthCheckStatus.Warning or HealthCheckStatus.Fail) |
||||
.Map(r => new HealthCheckResultSummary(r.Title, r.Message)) |
||||
.ToList(); |
||||
|
||||
FFmpegSettingsViewModel ffmpegSettings = await GetFFmpegSettings(); |
||||
|
||||
await using TvContext dbContext = await _dbContextFactory.CreateDbContextAsync(cancellationToken); |
||||
|
||||
List<Channel> channels = await dbContext.Channels |
||||
.AsNoTracking() |
||||
.ToListAsync(cancellationToken); |
||||
|
||||
var channelFFmpegProfiles = channels |
||||
.Map(c => c.FFmpegProfileId) |
||||
.ToImmutableHashSet(); |
||||
|
||||
List<FFmpegProfile> ffmpegProfiles = await dbContext.FFmpegProfiles |
||||
.AsNoTracking() |
||||
.Include(p => p.Resolution) |
||||
.ToListAsync(cancellationToken); |
||||
|
||||
var activeFFmpegProfiles = ffmpegProfiles |
||||
.Filter(f => channelFFmpegProfiles.Contains(f.Id)) |
||||
.ToList(); |
||||
|
||||
string nvidiaCapabilities = null; |
||||
string vaapiCapabilities = null; |
||||
Option<ConfigElement> maybeFFmpegPath = await _configElementRepository.Get(ConfigElementKey.FFmpegPath); |
||||
if (maybeFFmpegPath.IsNone) |
||||
{ |
||||
nvidiaCapabilities = "Unable to locate ffmpeg"; |
||||
} |
||||
else |
||||
{ |
||||
foreach (ConfigElement ffmpegPath in maybeFFmpegPath) |
||||
{ |
||||
nvidiaCapabilities = await _hardwareCapabilitiesFactory.GetNvidiaOutput(ffmpegPath.Value); |
||||
|
||||
if (_runtimeInfo.IsOSPlatform(OSPlatform.Linux)) |
||||
{ |
||||
var allDrivers = new List<VaapiDriver> |
||||
{ VaapiDriver.iHD, VaapiDriver.i965, VaapiDriver.RadeonSI, VaapiDriver.Nouveau }; |
||||
|
||||
foreach (VaapiDriver activeDriver in allDrivers) |
||||
{ |
||||
if (!_memoryCache.TryGetValue("ffmpeg.render_devices", out List<string> vaapiDevices)) |
||||
{ |
||||
vaapiDevices = new List<string> { "/dev/dri/renderD128" }; |
||||
} |
||||
|
||||
foreach (string vaapiDevice in vaapiDevices) |
||||
{ |
||||
foreach (string output in await _hardwareCapabilitiesFactory.GetVaapiOutput( |
||||
Optional(GetDriverName(activeDriver)), |
||||
vaapiDevice)) |
||||
{ |
||||
vaapiCapabilities += $"Checking driver {activeDriver} device {vaapiDevice} {Environment.NewLine} {Environment.NewLine}"; |
||||
vaapiCapabilities += $@"```shell
|
||||
{output} |
||||
```";
|
||||
vaapiCapabilities += " " + Environment.NewLine + " " + Environment.NewLine; |
||||
} |
||||
} |
||||
} |
||||
} |
||||
} |
||||
} |
||||
|
||||
return new TroubleshootingInfo( |
||||
version, |
||||
healthCheckSummaries, |
||||
ffmpegSettings, |
||||
activeFFmpegProfiles, |
||||
channels, |
||||
nvidiaCapabilities, |
||||
vaapiCapabilities); |
||||
} |
||||
|
||||
// lifted from GetFFmpegSettingsHandler
|
||||
private async Task<FFmpegSettingsViewModel> GetFFmpegSettings() |
||||
{ |
||||
Option<string> ffmpegPath = await _configElementRepository.GetValue<string>(ConfigElementKey.FFmpegPath); |
||||
Option<string> ffprobePath = await _configElementRepository.GetValue<string>(ConfigElementKey.FFprobePath); |
||||
Option<int> defaultFFmpegProfileId = |
||||
await _configElementRepository.GetValue<int>(ConfigElementKey.FFmpegDefaultProfileId); |
||||
Option<bool> saveReports = |
||||
await _configElementRepository.GetValue<bool>(ConfigElementKey.FFmpegSaveReports); |
||||
Option<string> preferredAudioLanguageCode = |
||||
await _configElementRepository.GetValue<string>(ConfigElementKey.FFmpegPreferredLanguageCode); |
||||
Option<int> watermark = |
||||
await _configElementRepository.GetValue<int>(ConfigElementKey.FFmpegGlobalWatermarkId); |
||||
Option<int> fallbackFiller = |
||||
await _configElementRepository.GetValue<int>(ConfigElementKey.FFmpegGlobalFallbackFillerId); |
||||
Option<int> hlsSegmenterIdleTimeout = |
||||
await _configElementRepository.GetValue<int>(ConfigElementKey.FFmpegSegmenterTimeout); |
||||
Option<int> workAheadSegmenterLimit = |
||||
await _configElementRepository.GetValue<int>(ConfigElementKey.FFmpegWorkAheadSegmenters); |
||||
Option<int> initialSegmentCount = |
||||
await _configElementRepository.GetValue<int>(ConfigElementKey.FFmpegInitialSegmentCount); |
||||
|
||||
var result = new FFmpegSettingsViewModel |
||||
{ |
||||
FFmpegPath = await ffmpegPath.IfNoneAsync(string.Empty), |
||||
FFprobePath = await ffprobePath.IfNoneAsync(string.Empty), |
||||
DefaultFFmpegProfileId = await defaultFFmpegProfileId.IfNoneAsync(0), |
||||
SaveReports = await saveReports.IfNoneAsync(false), |
||||
PreferredAudioLanguageCode = await preferredAudioLanguageCode.IfNoneAsync("eng"), |
||||
HlsSegmenterIdleTimeout = await hlsSegmenterIdleTimeout.IfNoneAsync(60), |
||||
WorkAheadSegmenterLimit = await workAheadSegmenterLimit.IfNoneAsync(1), |
||||
InitialSegmentCount = await initialSegmentCount.IfNoneAsync(1) |
||||
}; |
||||
|
||||
foreach (int watermarkId in watermark) |
||||
{ |
||||
result.GlobalWatermarkId = watermarkId; |
||||
} |
||||
|
||||
foreach (int fallbackFillerId in fallbackFiller) |
||||
{ |
||||
result.GlobalFallbackFillerId = fallbackFillerId; |
||||
} |
||||
|
||||
return result; |
||||
} |
||||
|
||||
private string GetDriverName(VaapiDriver driver) |
||||
{ |
||||
switch (driver) |
||||
{ |
||||
case VaapiDriver.i965: |
||||
return "i965"; |
||||
case VaapiDriver.iHD: |
||||
return "iHD"; |
||||
case VaapiDriver.RadeonSI: |
||||
return "radeonsi"; |
||||
case VaapiDriver.Nouveau: |
||||
return "nouveau"; |
||||
} |
||||
|
||||
return null; |
||||
} |
||||
} |
||||
@ -0,0 +1,13 @@
@@ -0,0 +1,13 @@
|
||||
using ErsatzTV.Application.FFmpegProfiles; |
||||
using ErsatzTV.Core.Domain; |
||||
|
||||
namespace ErsatzTV.Application.Troubleshooting; |
||||
|
||||
public record TroubleshootingInfo( |
||||
string Version, |
||||
IEnumerable<HealthCheckResultSummary> Health, |
||||
FFmpegSettingsViewModel FFmpegSettings, |
||||
IEnumerable<FFmpegProfile> FFmpegProfiles, |
||||
IEnumerable<Channel> Channels, |
||||
string NvidiaCapabilities, |
||||
string VaapiCapabilities); |
||||
@ -0,0 +1,87 @@
@@ -0,0 +1,87 @@
|
||||
@page "/system/troubleshooting" |
||||
@using ErsatzTV.Application.Troubleshooting.Queries |
||||
@using System.Text.Json |
||||
@using System.Text.Json.Serialization |
||||
@using ErsatzTV.Application.Troubleshooting |
||||
@implements IDisposable |
||||
@inject IMediator Mediator |
||||
|
||||
<MudContainer MaxWidth="MaxWidth.ExtraLarge" Class="pt-8"> |
||||
<MudCard Class="mb-6"> |
||||
<MudCardHeader> |
||||
<CardHeaderContent> |
||||
<MudText Typo="Typo.h5">General</MudText> |
||||
</CardHeaderContent> |
||||
</MudCardHeader> |
||||
<MudCardContent> |
||||
<MarkdownView Content="@_troubleshootingInfo"/> |
||||
</MudCardContent> |
||||
</MudCard> |
||||
<MudCard Class="mb-6"> |
||||
<MudCardHeader> |
||||
<CardHeaderContent> |
||||
<MudText Typo="Typo.h5">Nvidia Capabilities</MudText> |
||||
</CardHeaderContent> |
||||
</MudCardHeader> |
||||
<MudCardContent> |
||||
<MarkdownView Content="@_nvidiaCapabilities"/> |
||||
</MudCardContent> |
||||
</MudCard> |
||||
<MudCard> |
||||
<MudCardHeader> |
||||
<CardHeaderContent> |
||||
<MudText Typo="Typo.h5">Vaapi Capabilities</MudText> |
||||
</CardHeaderContent> |
||||
</MudCardHeader> |
||||
<MudCardContent> |
||||
<MarkdownView Content="@_vaapiCapabilities"/> |
||||
</MudCardContent> |
||||
</MudCard> |
||||
</MudContainer> |
||||
|
||||
@code { |
||||
private readonly CancellationTokenSource _cts = new(); |
||||
private string _troubleshootingInfo; |
||||
private string _nvidiaCapabilities; |
||||
private string _vaapiCapabilities; |
||||
|
||||
public void Dispose() |
||||
{ |
||||
_cts.Cancel(); |
||||
_cts.Dispose(); |
||||
} |
||||
|
||||
protected override async Task OnParametersSetAsync() |
||||
{ |
||||
try |
||||
{ |
||||
TroubleshootingInfo info = await Mediator.Send(new GetTroubleshootingInfo(), _cts.Token); |
||||
|
||||
string json = JsonSerializer.Serialize( |
||||
new { info.Version, info.Health, info.FFmpegSettings, info.Channels, info.FFmpegProfiles }, |
||||
new JsonSerializerOptions |
||||
{ |
||||
Converters = { new JsonStringEnumConverter() }, |
||||
DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull, |
||||
WriteIndented = true |
||||
}); |
||||
|
||||
_troubleshootingInfo = $@"```json |
||||
{json} |
||||
```"; |
||||
string formattedCapabilities = info.NvidiaCapabilities.Replace("\n", $" {Environment.NewLine}"); |
||||
|
||||
_nvidiaCapabilities = $@"```shell |
||||
{formattedCapabilities} |
||||
```"; |
||||
|
||||
_vaapiCapabilities = info.VaapiCapabilities; |
||||
} |
||||
catch (Exception ex) |
||||
{ |
||||
_troubleshootingInfo = $@"``` |
||||
{ex} |
||||
```"; |
||||
} |
||||
} |
||||
} |
||||
Loading…
Reference in new issue