olaven
/
nrss
1
0
Fork 0
Code Issues 6 Pull Requests Packages Projects Releases Wiki Activity

refactor: Less nesting, easier to read 

Signed-off-by: Tim Hårek Andreassen <tim@harek.no>
This commit is contained in:
Tim Hårek Andreassen 2024-04-06 23:59:59 +02:00
parent 23ce666847
commit 0982cb002c
No known key found for this signature in database
GPG Key ID: E59C7734F0E10EB5
1 changed files with 68 additions and 62 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

130
lib/nrk.ts
View File

@ -47,75 +47,81 @@ async function withDownloadLink(
} }
} }
export const nrkRadio = { async function search(query: string): Promise<SearchResultList | null> {
search: async (query: string): Promise<SearchResultList | null> => { if (query === "") {
if (query === "") { console.error("Empty search query.");
console.error("Empty search query.");
return null;
}
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;
}
console.error(`Something went wrong with ${query} - got status ${status}`);
return null; return null;
}, }
getSerieData: async ( const { status, body } = await get<
seriesId: string, searchComponents["schemas"]["searchresult"]
): Promise<{ episodes: OriginalEpisode[] } & (RadioSeries["series"] | Podcast["series"]) | null> => { >(`${nrkAPI}/radio/search/search?q=${query}`);
let [ if (status === STATUS_CODE.OK && body) {
return body.results.series?.results;
}
console.error(`Something went wrong with ${query} - got status ${status}`);
return null;
}
async function getSerieData(
seriesId: string,
): Promise<{ episodes: OriginalEpisode[] } & (RadioSeries["series"] | Podcast["series"]) | null> {
let [
{ status: episodeStatus, body: episodeResponse },
{ status: seriesStatus, body: serieResponse },
] = await Promise.all([
get<PodcastEpisodes>(
`${nrkAPI}/radio/catalog/podcast/${seriesId}/episodes`,
),
get<Podcast>(
`${nrkAPI}/radio/catalog/podcast/${seriesId}`,
),
]);
if (episodeStatus !== STATUS_CODE.OK || seriesStatus !== STATUS_CODE.OK) {
[
{ status: episodeStatus, body: episodeResponse }, { status: episodeStatus, body: episodeResponse },
{ status: seriesStatus, body: serieResponse }, { status: seriesStatus, body: serieResponse },
] = await Promise.all([ ] = await Promise.all([
get<PodcastEpisodes>( get<RadioSeriesEpisode>(
`${nrkAPI}/radio/catalog/podcast/${seriesId}/episodes`, `https://psapi.nrk.no/radio/catalog/series/${seriesId}/episodes`,
), ),
get<Podcast>( get<RadioSeries>(
`${nrkAPI}/radio/catalog/podcast/${seriesId}`, `https://psapi.nrk.no/radio/catalog/series/${seriesId}`,
), ),
]); ]);
}
if (episodeStatus !== STATUS_CODE.OK || seriesStatus !== STATUS_CODE.OK) { if (
[ episodeStatus === STATUS_CODE.OK && seriesStatus === STATUS_CODE.OK &&
{ status: episodeStatus, body: episodeResponse }, serieResponse?.series && episodeResponse?._embedded.episodes?.length
{ status: seriesStatus, body: serieResponse }, ) {
] = await Promise.all([ const episodes = await Promise.all(
get<RadioSeriesEpisode>( episodeResponse._embedded.episodes.map((episode) => withDownloadLink(episode, serieResponse.type)),
`https://psapi.nrk.no/radio/catalog/series/${seriesId}/episodes`,
),
get<RadioSeries>(
`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,
};
}
console.error(
`Error getting episodes for ${seriesId}: EpisodeStatus: ${episodeStatus}. SerieStatus: ${seriesStatus}`,
); );
return null; return {
}, ...serieResponse.series,
getEpisode: async (seriesId: string, episodeId: string): Promise<PodcastEpisode | null> => { episodes,
const url = `${nrkAPI}/radio/catalog/podcast/${seriesId}/episodes/${episodeId}`; };
const { status, body: episode } = await get<PodcastEpisode>(url); }
if (status === STATUS_CODE.OK && episode) { console.error(
return episode; `Error getting episodes for ${seriesId}: EpisodeStatus: ${episodeStatus}. SerieStatus: ${seriesStatus}`,
} );
console.error(`Error getting episode ${episodeId}. Status: ${status}. Series: ${seriesId}`); return null;
return null; }
},
async function getEpisode(seriesId: string, episodeId: string): Promise<PodcastEpisode | null> {
const url = `${nrkAPI}/radio/catalog/podcast/${seriesId}/episodes/${episodeId}`;
const { status, body: episode } = await get<PodcastEpisode>(url);
if (status === STATUS_CODE.OK && episode) {
return episode;
}
console.error(`Error getting episode ${episodeId}. Status: ${status}. Series: ${seriesId}`);
return null;
}
export const nrkRadio = {
search,
getSerieData,
getEpisode,
}; };