Deduplicate media stream ordering code (#9014)

This commit is contained in:
Bond-009 2023-01-07 19:30:55 +01:00 committed by GitHub
parent 770c8c8902
commit 769c48c629
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 78 additions and 42 deletions

View File

@ -89,17 +89,7 @@ namespace Emby.Server.Implementations.Library
// Give some preference to external text subs for better performance // Give some preference to external text subs for better performance
return streams return streams
.Where(i => i.Type == type) .Where(i => i.Type == type)
.OrderBy(i => .OrderByDescending(i => GetStreamScore(i, languagePreferences));
{
var index = languagePreferences.FindIndex(x => string.Equals(x, i.Language, StringComparison.OrdinalIgnoreCase));
return index == -1 ? 100 : index;
})
.ThenBy(i => GetBooleanOrderBy(i.IsDefault))
.ThenBy(i => GetBooleanOrderBy(i.SupportsExternalStream))
.ThenBy(i => GetBooleanOrderBy(i.IsTextSubtitleStream))
.ThenBy(i => GetBooleanOrderBy(i.IsExternal))
.ThenBy(i => i.Index);
} }
public static void SetSubtitleStreamScores( public static void SetSubtitleStreamScores(
@ -113,9 +103,9 @@ namespace Emby.Server.Implementations.Library
return; return;
} }
var sortedStreams = GetSortedStreams(streams, MediaStreamType.Subtitle, preferredLanguages); var sortedStreams = GetSortedStreams(streams, MediaStreamType.Subtitle, preferredLanguages).ToList();
var filteredStreams = new List<MediaStream>(); List<MediaStream>? filteredStreams = null;
if (mode == SubtitlePlaybackMode.Default) if (mode == SubtitlePlaybackMode.Default)
{ {
@ -144,46 +134,26 @@ namespace Emby.Server.Implementations.Library
} }
// load forced subs if we have found no suitable full subtitles // load forced subs if we have found no suitable full subtitles
var iterStreams = filteredStreams.Count == 0 var iterStreams = filteredStreams is null || filteredStreams.Count == 0
? sortedStreams.Where(s => s.IsForced && string.Equals(s.Language, audioTrackLanguage, StringComparison.OrdinalIgnoreCase)) ? sortedStreams.Where(s => s.IsForced && string.Equals(s.Language, audioTrackLanguage, StringComparison.OrdinalIgnoreCase))
: filteredStreams; : filteredStreams;
foreach (var stream in iterStreams) foreach (var stream in iterStreams)
{ {
stream.Score = GetSubtitleScore(stream, preferredLanguages); stream.Score = GetStreamScore(stream, preferredLanguages);
} }
} }
private static int GetSubtitleScore(MediaStream stream, IReadOnlyList<string> languagePreferences) internal static int GetStreamScore(MediaStream stream, IReadOnlyList<string> languagePreferences)
{ {
var values = new List<int>();
var index = languagePreferences.FindIndex(x => string.Equals(x, stream.Language, StringComparison.OrdinalIgnoreCase)); var index = languagePreferences.FindIndex(x => string.Equals(x, stream.Language, StringComparison.OrdinalIgnoreCase));
var score = index == -1 ? 1 : 101 - index;
values.Add(index == -1 ? 0 : 100 - index); score = (score * 10) + (stream.IsForced ? 2 : 1);
score = (score * 10) + (stream.IsDefault ? 2 : 1);
values.Add(stream.IsForced ? 1 : 0); score = (score * 10) + (stream.SupportsExternalStream ? 2 : 1);
values.Add(stream.IsDefault ? 1 : 0); score = (score * 10) + (stream.IsTextSubtitleStream ? 2 : 1);
values.Add(stream.SupportsExternalStream ? 1 : 0); score = (score * 10) + (stream.IsExternal ? 2 : 1);
values.Add(stream.IsTextSubtitleStream ? 1 : 0);
values.Add(stream.IsExternal ? 1 : 0);
values.Reverse();
var scale = 1;
var score = 0;
foreach (var value in values)
{
score += scale * (value + 1);
scale *= 10;
}
return score; return score;
} }
private static int GetBooleanOrderBy(bool value)
{
return value ? 0 : 1;
}
} }
} }

View File

@ -93,6 +93,8 @@
<Rule Id="CA1845" Action="Error" /> <Rule Id="CA1845" Action="Error" />
<!-- error on CA1849: Call async methods when in an async method --> <!-- error on CA1849: Call async methods when in an async method -->
<Rule Id="CA1849" Action="Error" /> <Rule Id="CA1849" Action="Error" />
<!-- error on CA1851: Possible multiple enumerations of IEnumerable collection -->
<Rule Id="CA1851" Action="Error" />
<!-- error on CA2016: Forward the CancellationToken parameter to methods that take one <!-- error on CA2016: Forward the CancellationToken parameter to methods that take one
or pass in 'CancellationToken.None' explicitly to indicate intentionally not propagating the token --> or pass in 'CancellationToken.None' explicitly to indicate intentionally not propagating the token -->
<Rule Id="CA2016" Action="Error" /> <Rule Id="CA2016" Action="Error" />

View File

@ -51,4 +51,68 @@ public class MediaStreamSelectorTests
Assert.Equal(expectedIndex, MediaStreamSelector.GetDefaultAudioStreamIndex(streams, preferredLanguages, preferDefaultTrack)); Assert.Equal(expectedIndex, MediaStreamSelector.GetDefaultAudioStreamIndex(streams, preferredLanguages, preferDefaultTrack));
} }
public static TheoryData<MediaStream, int> GetStreamScore_MediaStream_TestData()
{
var data = new TheoryData<MediaStream, int>();
data.Add(new MediaStream(), 111111);
data.Add(
new MediaStream()
{
Language = "eng"
},
10111111);
data.Add(
new MediaStream()
{
Language = "fre"
},
10011111);
data.Add(
new MediaStream()
{
IsForced = true
},
121111);
data.Add(
new MediaStream()
{
IsDefault = true
},
112111);
data.Add(
new MediaStream()
{
SupportsExternalStream = true
},
111211);
data.Add(
new MediaStream()
{
IsExternal = true
},
111112);
data.Add(
new MediaStream()
{
Language = "eng",
IsForced = true,
IsDefault = true,
SupportsExternalStream = true,
IsExternal = true
},
10122212);
return data;
}
[Theory]
[MemberData(nameof(GetStreamScore_MediaStream_TestData))]
public void GetStreamScore_MediaStream_CorrectScore(MediaStream stream, int expectedScore)
{
var languagePref = new[] { "eng", "fre" };
Assert.Equal(expectedScore, MediaStreamSelector.GetStreamScore(stream, languagePref));
}
} }