import { Router } from 'express'; import { sortBy } from 'lodash'; import TheMovieDb from '../api/themoviedb'; import { MediaType } from '../constants/media'; import Media from '../entity/Media'; import type { User } from '../entity/User'; import type { GenreSliderItem } from '../interfaces/api/discoverInterfaces'; import { getSettings } from '../lib/settings'; import logger from '../logger'; import { mapProductionCompany } from '../models/Movie'; import { mapMovieResult, mapPersonResult, mapTvResult } from '../models/Search'; import { mapNetwork } from '../models/Tv'; import { isMovie, isPerson } from '../utils/typeHelpers'; export const createTmdbWithRegionLanguage = (user?: User): TheMovieDb => { const settings = getSettings(); const region = user?.settings?.region === 'all' ? '' : user?.settings?.region ? user?.settings?.region : settings.main.region; const originalLanguage = user?.settings?.originalLanguage === 'all' ? '' : user?.settings?.originalLanguage ? user?.settings?.originalLanguage : settings.main.originalLanguage; return new TheMovieDb({ region, originalLanguage, }); }; const discoverRoutes = Router(); discoverRoutes.get('/movies', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); try { const data = await tmdb.getDiscoverMovies({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), genre: req.query.genre ? Number(req.query.genre) : undefined, studio: req.query.studio ? Number(req.query.studio) : undefined, }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, results: data.results.map((result) => mapMovieResult( result, media.find( (req) => req.tmdbId === result.id && req.mediaType === MediaType.MOVIE ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving popular movies', { label: 'API', errorMessage: e.message, }); return next({ status: 500, message: 'Unable to retrieve popular movies.', }); } }); discoverRoutes.get<{ language: string }>( '/movies/language/:language', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); try { const languages = await tmdb.getLanguages(); const language = languages.find( (lang) => lang.iso_639_1 === req.params.language ); if (!language) { return next({ status: 404, message: 'Language not found.' }); } const data = await tmdb.getDiscoverMovies({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), originalLanguage: req.params.language, }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, language, results: data.results.map((result) => mapMovieResult( result, media.find( (req) => req.tmdbId === result.id && req.mediaType === MediaType.MOVIE ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving movies by language', { label: 'API', errorMessage: e.message, language: req.params.language, }); return next({ status: 500, message: 'Unable to retrieve movies by language.', }); } } ); discoverRoutes.get<{ genreId: string }>( '/movies/genre/:genreId', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); try { const genres = await tmdb.getMovieGenres({ language: req.locale ?? (req.query.language as string), }); const genre = genres.find( (genre) => genre.id === Number(req.params.genreId) ); if (!genre) { return next({ status: 404, message: 'Genre not found.' }); } const data = await tmdb.getDiscoverMovies({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), genre: Number(req.params.genreId), }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, genre, results: data.results.map((result) => mapMovieResult( result, media.find( (req) => req.tmdbId === result.id && req.mediaType === MediaType.MOVIE ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving movies by genre', { label: 'API', errorMessage: e.message, genreId: req.params.genreId, }); return next({ status: 500, message: 'Unable to retrieve movies by genre.', }); } } ); discoverRoutes.get<{ studioId: string }>( '/movies/studio/:studioId', async (req, res, next) => { const tmdb = new TheMovieDb(); try { const studio = await tmdb.getStudio(Number(req.params.studioId)); const data = await tmdb.getDiscoverMovies({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), studio: Number(req.params.studioId), }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, studio: mapProductionCompany(studio), results: data.results.map((result) => mapMovieResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.MOVIE ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving movies by studio', { label: 'API', errorMessage: e.message, studioId: req.params.studioId, }); return next({ status: 500, message: 'Unable to retrieve movies by studio.', }); } } ); discoverRoutes.get('/movies/upcoming', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); const now = new Date(); const offset = now.getTimezoneOffset(); const date = new Date(now.getTime() - offset * 60 * 1000) .toISOString() .split('T')[0]; try { const data = await tmdb.getDiscoverMovies({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), primaryReleaseDateGte: date, }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, results: data.results.map((result) => mapMovieResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.MOVIE ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving upcoming movies', { label: 'API', errorMessage: e.message, }); return next({ status: 500, message: 'Unable to retrieve upcoming movies.', }); } }); discoverRoutes.get('/tv', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); try { const data = await tmdb.getDiscoverTv({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), genre: req.query.genre ? Number(req.query.genre) : undefined, network: req.query.network ? Number(req.query.network) : undefined, }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, results: data.results.map((result) => mapTvResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.TV ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving popular series', { label: 'API', errorMessage: e.message, }); return next({ status: 500, message: 'Unable to retrieve popular series.', }); } }); discoverRoutes.get<{ language: string }>( '/tv/language/:language', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); try { const languages = await tmdb.getLanguages(); const language = languages.find( (lang) => lang.iso_639_1 === req.params.language ); if (!language) { return next({ status: 404, message: 'Language not found.' }); } const data = await tmdb.getDiscoverTv({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), originalLanguage: req.params.language, }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, language, results: data.results.map((result) => mapTvResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.TV ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving series by language', { label: 'API', errorMessage: e.message, language: req.params.language, }); return next({ status: 500, message: 'Unable to retrieve series by language.', }); } } ); discoverRoutes.get<{ genreId: string }>( '/tv/genre/:genreId', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); try { const genres = await tmdb.getTvGenres({ language: req.locale ?? (req.query.language as string), }); const genre = genres.find( (genre) => genre.id === Number(req.params.genreId) ); if (!genre) { return next({ status: 404, message: 'Genre not found.' }); } const data = await tmdb.getDiscoverTv({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), genre: Number(req.params.genreId), }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, genre, results: data.results.map((result) => mapTvResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.TV ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving series by genre', { label: 'API', errorMessage: e.message, genreId: req.params.genreId, }); return next({ status: 500, message: 'Unable to retrieve series by genre.', }); } } ); discoverRoutes.get<{ networkId: string }>( '/tv/network/:networkId', async (req, res, next) => { const tmdb = new TheMovieDb(); try { const network = await tmdb.getNetwork(Number(req.params.networkId)); const data = await tmdb.getDiscoverTv({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), network: Number(req.params.networkId), }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, network: mapNetwork(network), results: data.results.map((result) => mapTvResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.TV ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving series by network', { label: 'API', errorMessage: e.message, networkId: req.params.networkId, }); return next({ status: 500, message: 'Unable to retrieve series by network.', }); } } ); discoverRoutes.get('/tv/upcoming', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); const now = new Date(); const offset = now.getTimezoneOffset(); const date = new Date(now.getTime() - offset * 60 * 1000) .toISOString() .split('T')[0]; try { const data = await tmdb.getDiscoverTv({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), firstAirDateGte: date, }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, results: data.results.map((result) => mapTvResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.TV ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving upcoming series', { label: 'API', errorMessage: e.message, }); return next({ status: 500, message: 'Unable to retrieve upcoming series.', }); } }); discoverRoutes.get('/trending', async (req, res, next) => { const tmdb = createTmdbWithRegionLanguage(req.user); try { const data = await tmdb.getAllTrending({ page: Number(req.query.page), language: req.locale ?? (req.query.language as string), }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, results: data.results.map((result) => isMovie(result) ? mapMovieResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.MOVIE ) ) : isPerson(result) ? mapPersonResult(result) : mapTvResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.TV ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving trending items', { label: 'API', errorMessage: e.message, }); return next({ status: 500, message: 'Unable to retrieve trending items.', }); } }); discoverRoutes.get<{ keywordId: string }>( '/keyword/:keywordId/movies', async (req, res, next) => { const tmdb = new TheMovieDb(); try { const data = await tmdb.getMoviesByKeyword({ keywordId: Number(req.params.keywordId), page: Number(req.query.page), language: req.locale ?? (req.query.language as string), }); const media = await Media.getRelatedMedia( data.results.map((result) => result.id) ); return res.status(200).json({ page: data.page, totalPages: data.total_pages, totalResults: data.total_results, results: data.results.map((result) => mapMovieResult( result, media.find( (med) => med.tmdbId === result.id && med.mediaType === MediaType.MOVIE ) ) ), }); } catch (e) { logger.debug('Something went wrong retrieving movies by keyword', { label: 'API', errorMessage: e.message, keywordId: req.params.keywordId, }); return next({ status: 500, message: 'Unable to retrieve movies by keyword.', }); } } ); discoverRoutes.get<{ language: string }, GenreSliderItem[]>( '/genreslider/movie', async (req, res, next) => { const tmdb = new TheMovieDb(); try { const mappedGenres: GenreSliderItem[] = []; const genres = await tmdb.getMovieGenres({ language: req.locale ?? (req.query.language as string), }); await Promise.all( genres.map(async (genre) => { const genreData = await tmdb.getDiscoverMovies({ genre: genre.id }); mappedGenres.push({ id: genre.id, name: genre.name, backdrops: genreData.results .filter((title) => !!title.backdrop_path) .map((title) => title.backdrop_path) as string[], }); }) ); const sortedData = sortBy(mappedGenres, 'name'); return res.status(200).json(sortedData); } catch (e) { logger.debug('Something went wrong retrieving the movie genre slider', { label: 'API', errorMessage: e.message, }); return next({ status: 500, message: 'Unable to retrieve movie genre slider.', }); } } ); discoverRoutes.get<{ language: string }, GenreSliderItem[]>( '/genreslider/tv', async (req, res, next) => { const tmdb = new TheMovieDb(); try { const mappedGenres: GenreSliderItem[] = []; const genres = await tmdb.getTvGenres({ language: req.locale ?? (req.query.language as string), }); await Promise.all( genres.map(async (genre) => { const genreData = await tmdb.getDiscoverTv({ genre: genre.id }); mappedGenres.push({ id: genre.id, name: genre.name, backdrops: genreData.results .filter((title) => !!title.backdrop_path) .map((title) => title.backdrop_path) as string[], }); }) ); const sortedData = sortBy(mappedGenres, 'name'); return res.status(200).json(sortedData); } catch (e) { logger.debug('Something went wrong retrieving the series genre slider', { label: 'API', errorMessage: e.message, }); return next({ status: 500, message: 'Unable to retrieve series genre slider.', }); } } ); export default discoverRoutes;