// FIXME: Remember to replace this with actual version import { get, STATUS_CODE } from "../../kall/mod.ts"; import { components as searchComponents } from "./nrk-search.ts"; import { components as catalogComponents } from "./nrk-catalog.ts"; import { external as playbackComponents } from "./nrk-playback.ts"; type ArrayElement = A extends readonly (infer T)[] ? T : never; type PodcastEpisodes = catalogComponents["schemas"]["EpisodesHalResource"]; type Podcast = catalogComponents["schemas"]["SeriesHalResource"]; type PodcastEpisodesSingle = catalogComponents["schemas"]["EpisodeHalResource"]; export type Serie = catalogComponents["schemas"]["SeriesViewModel"]; export type OriginalEpisode = PodcastEpisodesSingle & { url: string }; export type PodcastEpisode = catalogComponents["schemas"]["PodcastEpisodeHalResource"]; export type SearchResultList = searchComponents["schemas"]["seriesResult"]["results"]; export type SearchResult = ArrayElement & { description?: string; }; type Manifest = playbackComponents["schemas/playback-channel.json"]["components"]["schemas"]["PlayableManifest"]; const nrkAPI = `https://psapi.nrk.no`; async function withDownloadLink( episode: PodcastEpisodesSingle, type: catalogComponents["schemas"]["Type"], ): Promise { // getting stream link let { status: playbackStatus, body: playbackResponse } = await get( `${nrkAPI}/playback/manifest/podcast/${episode.episodeId}`, ); if (type === "series") { const { status, body } = await get( `${nrkAPI}/playback/manifest/program/${episode.episodeId}`, ); playbackStatus = status; playbackResponse = body; } if (playbackStatus === STATUS_CODE.OK && playbackResponse) { return { ...episode, url: playbackResponse.playable.assets[0].url }; } else { throw `Error getting downloadLink for ${episode.episodeId}, serie: ${episode.originalTitle}. Status: ${playbackStatus}`; } } // TODO: Replace throws with `console.error` and return `null` if bad response. export const nrkRadio = { search: async (query: string): Promise => { if (query === "") { throw "Empty search query."; } const { status, body } = await get< searchComponents["schemas"]["searchresult"] >(`${nrkAPI}/radio/search/search?q=${query}`); if (status === STATUS_CODE.OK && body) { return body.results.series?.results; } throw `Something went wrong with ${query} - got status ${status}`; }, getSerieData: async (seriesId: string) => { let [ { status: episodeStatus, body: episodeResponse }, { status: seriesStatus, body: serieResponse }, ] = await Promise.all([ get( `${nrkAPI}/radio/catalog/podcast/${seriesId}/episodes`, ), get( `${nrkAPI}/radio/catalog/podcast/${seriesId}`, ), ]); if (episodeStatus !== STATUS_CODE.OK || seriesStatus !== STATUS_CODE.OK) { [ { status: episodeStatus, body: episodeResponse }, { status: seriesStatus, body: serieResponse }, ] = await Promise.all([ get( `https://psapi.nrk.no/radio/catalog/series/${seriesId}/episodes`, ), get( `https://psapi.nrk.no/radio/catalog/series/${seriesId}`, ), ]); } if ( episodeStatus === STATUS_CODE.OK && seriesStatus === STATUS_CODE.OK && serieResponse?.series && episodeResponse?._embedded.episodes?.length ) { const episodes = await Promise.all( episodeResponse._embedded.episodes.map((episode) => withDownloadLink(episode, serieResponse.type)), ); return { ...serieResponse.series, episodes, }; } throw `Error getting episodes for ${seriesId}: EpisodeStatus: ${episodeStatus}. SerieStatus: ${seriesStatus}`; }, getEpisode: async (seriesId: string, episodeId: string): Promise => { const url = `${nrkAPI}/radio/catalog/podcast/${seriesId}/episodes/${episodeId}`; const { status, body: episode } = await get(url); if (status === STATUS_CODE.OK && episode) { return episode; } console.error(`Error getting episode ${episodeId}. Status: ${status}. Series: ${seriesId}`); return null; }, };