1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
using Microsoft.Extensions.Caching.Memory;
namespace I2R.LightNews.Services;
public class NrkRadioService
{
private readonly IMemoryCache _cache;
private readonly HttpClient _http;
private const string CATEGORY_SEARCH_CACHE_KEY = "category_search";
private readonly ILogger<NrkRadioService> _logger;
public NrkRadioService(IMemoryCache cache, HttpClient http, ILogger<NrkRadioService> logger) {
_cache = cache;
http.BaseAddress = new Uri("https://psapi.nrk.no");
_http = http;
_logger = logger;
}
public async Task CreateIndexAsync(CancellationToken cancellationToken = default) {
var letters = "#ABCDEFGHIJKLMNOPQRSTUVWXYZÆØÅ".ToCharArray();
var skip = 0;
foreach (var letter in letters) {
var path = "/radio/search/categories/alt-innhold?letter=" + (letter == '#' ? "%23" : letter) + "&skip=0&take=50";
while (path.HasValue()) {
var response = await _http.GetFromJsonAsync<RadioCategorySearchResult>(path, cancellationToken);
if (response == null) break;
await Task.Delay(2000, cancellationToken);
foreach (var series in response.Series) {
var dbSeries = RadioIndexDb.GetSeriesByNrkId(series.Id) ?? new RadioSeries {
Name = series.Title,
NrkId = series.Id,
Type = series.Type,
};
var seriesId = dbSeries.Id > 0 ? dbSeries.Id : RadioIndexDb.AddSeries(dbSeries);
_logger.LogInformation("Added series {0} with id {1}, to the database", dbSeries.Name, seriesId);
if ((series.Links?.Series?.Href.IsNullOrWhiteSpace() ?? true)
&& (series.Links?.Series?.Href.IsNullOrWhiteSpace() ?? true)
&& (series.Links?.Series?.Href.IsNullOrWhiteSpace() ?? true)
) continue;
var seriesMetadata = await _http.GetFromJsonAsync<NrkRadioSeries>(series.Links?.Series?.Href ?? series.Links?.Podcast?.Href ?? series.Links?.CustomSeason?.Href, cancellationToken);
if (seriesMetadata == null) continue;
await Task.Delay(1000, cancellationToken);
if (seriesMetadata.Embedded.Seasons?.Any() ?? false) {
foreach (var season in seriesMetadata.Embedded.Seasons) {
var dbSeason = RadioIndexDb.GetSeasonByNrkId(season.Id) ?? new RadioSeason() {
Name = season.Titles.Title,
NrkId = season.Id,
SeriesId = seriesId
};
var seasonId = dbSeason.Id > 0 ? dbSeason.Id : RadioIndexDb.AddSeason(dbSeason);
_logger.LogInformation("Added season {0} to series {1} with id {2}, to the database", dbSeason.Name, dbSeries.Name, seasonId);
await AddEpisodesAsync(season.Episodes.Embedded.Episodes, dbSeries, dbSeason, cancellationToken);
}
} else if (seriesMetadata.Embedded.Episodes.Embedded.Episodes?.Any() ?? false) {
await AddEpisodesAsync(seriesMetadata.Embedded.Episodes.Embedded.Episodes, dbSeries, null, cancellationToken);
}
}
path = response.Links?.NextPage?.Href?.HasValue() ?? false ? response.Links.NextPage.Href : "";
}
}
}
private async Task AddEpisodesAsync(List<NrkRadioSeries.EmbeddedModel.SeasonModel.EpisodeModel.EmbeddedModel.EpisodeModel> lol, RadioSeries dbSeries, RadioSeason dbSeason = null, CancellationToken cancellationToken = default) {
foreach (var episode in lol) {
var dbEpisode = RadioIndexDb.GetEpisodeByNrkId(episode.EpisodeId) ?? new RadioEpisode {
CanonicalUrl = episode.Links.Share.Href,
Name = episode.Titles.Title,
Description = episode.Titles.Subtitle,
NrkId = episode.EpisodeId,
SeasonId = dbSeason?.Id ?? -1,
SeriesId = dbSeries.Id
};
if (dbEpisode.NrkId.IsNullOrWhiteSpace()) {
_logger.LogWarning("No nrk id was found for episode {0}", dbEpisode.Name);
continue;
}
var manifestType = episode.Links.Playback.Href.Contains("podcast") ? "podcast" : "program";
var playbackResponse = await _http.GetFromJsonAsync<NrkPlaybackManifest>("/playback/manifest/" + manifestType + "/" + dbEpisode.NrkId, cancellationToken);
if (playbackResponse?.Playable == null) continue;
dbEpisode.SourceUrl = playbackResponse.Playable.Assets.FirstOrDefault()?.Url;
var episodeId = dbEpisode.Id > 0 ? dbEpisode.Id : RadioIndexDb.AddEpisode(dbEpisode);
_logger.LogInformation("Added episode {0} to series {1} season {2} with id {3}, to the database", dbEpisode.Name, dbSeries.Name, dbSeason?.Name ?? "!!NO SEASON!!", episodeId);
}
}
}
|
