@ -106,8 +106,7 @@ namespace Emby.Server.Implementations.LiveTv.Listings
options . Content = JsonContent . Create ( requestList , options : _jsonOptions ) ;
options . Headers . TryAddWithoutValidation ( "token" , token ) ;
using var response = await Send ( options , true , info , cancellationToken ) . ConfigureAwait ( false ) ;
await using var responseStream = await response . Content . ReadAsStreamAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
var dailySchedules = await JsonSerializer . DeserializeAsync < IReadOnlyList < DayDto > > ( responseStream , _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
var dailySchedules = await response . Content . ReadFromJsonAsync < IReadOnlyList < DayDto > > ( _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
if ( dailySchedules is null )
{
return Array . Empty < ProgramInfo > ( ) ;
@ -122,8 +121,7 @@ namespace Emby.Server.Implementations.LiveTv.Listings
programRequestOptions . Content = JsonContent . Create ( programIds , options : _jsonOptions ) ;
using var innerResponse = await Send ( programRequestOptions , true , info , cancellationToken ) . ConfigureAwait ( false ) ;
await using var innerResponseStream = await innerResponse . Content . ReadAsStreamAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
var programDetails = await JsonSerializer . DeserializeAsync < IReadOnlyList < ProgramDetailsDto > > ( innerResponseStream , _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
var programDetails = await innerResponse . Content . ReadFromJsonAsync < IReadOnlyList < ProgramDetailsDto > > ( _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
if ( programDetails is null )
{
return Array . Empty < ProgramInfo > ( ) ;
@ -482,8 +480,7 @@ namespace Emby.Server.Implementations.LiveTv.Listings
try
{
using var innerResponse2 = await Send ( message , true , info , cancellationToken ) . ConfigureAwait ( false ) ;
await using var response = await innerResponse2 . Content . ReadAsStreamAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
return await JsonSerializer . DeserializeAsync < IReadOnlyList < ShowImagesDto > > ( response , _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
return await innerResponse2 . Content . ReadFromJsonAsync < IReadOnlyList < ShowImagesDto > > ( _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
}
catch ( Exception ex )
{
@ -510,10 +507,7 @@ namespace Emby.Server.Implementations.LiveTv.Listings
try
{
using var httpResponse = await Send ( options , false , info , cancellationToken ) . ConfigureAwait ( false ) ;
await using var response = await httpResponse . Content . ReadAsStreamAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
var root = await JsonSerializer . DeserializeAsync < IReadOnlyList < HeadendsDto > > ( response , _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
var root = await httpResponse . Content . ReadFromJsonAsync < IReadOnlyList < HeadendsDto > > ( _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
if ( root is not null )
{
foreach ( HeadendsDto headend in root )
@ -649,8 +643,7 @@ namespace Emby.Server.Implementations.LiveTv.Listings
using var response = await Send ( options , false , null , cancellationToken ) . ConfigureAwait ( false ) ;
response . EnsureSuccessStatusCode ( ) ;
await using var stream = await response . Content . ReadAsStreamAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
var root = await JsonSerializer . DeserializeAsync < TokenDto > ( stream , _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
var root = await response . Content . ReadFromJsonAsync < TokenDto > ( _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
if ( string . Equals ( root ? . Message , "OK" , StringComparison . Ordinal ) )
{
_logger . LogInformation ( "Authenticated with Schedules Direct token: {Token}" , root . Token ) ;
@ -691,10 +684,7 @@ namespace Emby.Server.Implementations.LiveTv.Listings
{
using var httpResponse = await Send ( options , false , null , cancellationToken ) . ConfigureAwait ( false ) ;
httpResponse . EnsureSuccessStatusCode ( ) ;
await using var stream = await httpResponse . Content . ReadAsStreamAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
using var response = httpResponse . Content ;
var root = await JsonSerializer . DeserializeAsync < LineupsDto > ( stream , _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
var root = await httpResponse . Content . ReadFromJsonAsync < LineupsDto > ( _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
return root ? . Lineups . Any ( i = > string . Equals ( info . ListingsId , i . Lineup , StringComparison . OrdinalIgnoreCase ) ) ? ? false ;
}
catch ( HttpRequestException ex )
@ -748,8 +738,7 @@ namespace Emby.Server.Implementations.LiveTv.Listings
options . Headers . TryAddWithoutValidation ( "token" , token ) ;
using var httpResponse = await Send ( options , true , info , cancellationToken ) . ConfigureAwait ( false ) ;
await using var stream = await httpResponse . Content . ReadAsStreamAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
var root = await JsonSerializer . DeserializeAsync < ChannelDto > ( stream , _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
var root = await httpResponse . Content . ReadFromJsonAsync < ChannelDto > ( _jsonOptions , cancellationToken ) . ConfigureAwait ( false ) ;
if ( root is null )
{
return new List < ChannelInfo > ( ) ;