using System; using System.Collections.Generic; using System.Globalization; using System.Linq; using MediaBrowser.Model.Diagnostics; using Microsoft.Extensions.Logging; namespace MediaBrowser.MediaEncoding.Encoder { public class EncoderValidator { private readonly ILogger _logger; private readonly IProcessFactory _processFactory; public EncoderValidator(ILogger logger, IProcessFactory processFactory) { _logger = logger; _processFactory = processFactory; } public (IEnumerable decoders, IEnumerable encoders) Validate(string encoderPath) { _logger.LogInformation("Validating media encoder at {EncoderPath}", encoderPath); var decoders = GetDecoders(encoderPath); var encoders = GetEncoders(encoderPath); _logger.LogInformation("Encoder validation complete"); return (decoders, encoders); } public bool ValidateVersion(string encoderAppPath, bool logOutput) { string output = null; try { output = GetProcessOutput(encoderAppPath, "-version"); } catch (Exception ex) { if (logOutput) { _logger.LogError(ex, "Error validating encoder"); } } if (string.IsNullOrWhiteSpace(output)) { return false; } _logger.LogInformation("ffmpeg info: {0}", output); if (output.IndexOf("Libav developers", StringComparison.OrdinalIgnoreCase) != -1) { return false; } output = " " + output + " "; for (var i = 2013; i <= 2015; i++) { var yearString = i.ToString(CultureInfo.InvariantCulture); if (output.IndexOf(" " + yearString + " ", StringComparison.OrdinalIgnoreCase) != -1) { return false; } } return true; } private IEnumerable GetDecoders(string encoderAppPath) { string output = null; try { output = GetProcessOutput(encoderAppPath, "-decoders"); } catch (Exception ex) { _logger.LogError(ex, "Error detecting available decoders"); } if (string.IsNullOrWhiteSpace(output)) { return Enumerable.Empty(); } var required = new[] { "mpeg2video", "h264_qsv", "hevc_qsv", "mpeg2_qsv", "vc1_qsv", "h264_cuvid", "hevc_cuvid", "dts", "ac3", "aac", "mp3", "h264", "hevc" }; var found = required.Where(x => output.IndexOf(x, StringComparison.OrdinalIgnoreCase) != -1); _logger.LogInformation("Available decoders: {Codecs}", found); return found; } private IEnumerable GetEncoders(string encoderAppPath) { string output = null; try { output = GetProcessOutput(encoderAppPath, "-encoders"); } catch (Exception ex) { _logger.LogError(ex, "Error getting encoders"); } if (string.IsNullOrWhiteSpace(output)) { return Enumerable.Empty(); } var required = new[] { "libx264", "libx265", "mpeg4", "msmpeg4", "libvpx", "libvpx-vp9", "aac", "libmp3lame", "libopus", "libvorbis", "srt", "h264_nvenc", "hevc_nvenc", "h264_qsv", "hevc_qsv", "h264_omx", "hevc_omx", "h264_vaapi", "hevc_vaapi", "ac3" }; var found = required.Where(x => output.IndexOf(x, StringComparison.OrdinalIgnoreCase) != -1); _logger.LogInformation("Available encoders: {Codecs}", found); return found; } private string GetProcessOutput(string path, string arguments) { IProcess process = _processFactory.Create(new ProcessOptions { CreateNoWindow = true, UseShellExecute = false, FileName = path, Arguments = arguments, IsHidden = true, ErrorDialog = false, RedirectStandardOutput = true }); _logger.LogInformation("Running {Path} {Arguments}", path, arguments); using (process) { process.Start(); try { return process.StandardOutput.ReadToEnd(); } catch { _logger.LogInformation("Killing process {path} {arguments}", path, arguments); // Hate having to do this try { process.Kill(); } catch (Exception ex) { _logger.LogError(ex, "Error killing process"); } throw; } } } } }