utils.js

'use strict';

const api = require('./api');
const { DateTime } = require('luxon');
const db = require('./db');
const cache = require('memory-cache');

function durationFormat(seconds) {
	seconds = Number(seconds);
	const HH = Math.floor(seconds / 3600).toString().padStart(2, '0');
	const MM = Math.floor(seconds % 3600 / 60).toString().padStart(2, '0');
	const SS = Math.floor(seconds % 3600 % 60).toString().padStart(2, '0');
	return `${HH}:${MM}:${SS}`;
}

function pubDateFormat(published) {
	// stitcher returns dates in the LA tz AFAICT
	return DateTime.fromSQL(published, { zone: 'America/Los_Angeles' }).toISO();
}

async function getShowFeed(showId, userId) {
	const cachedFeed = cache.get(showId);
	if (cachedFeed) {
		return cachedFeed;
	}

	const feed = await api.GetFeedDetailsWithEpisodes(showId, userId);

	if (feed.seasons) {
		feed.episodes = [];
		await Promise.all(feed.seasons.map(async (season) => {
			const tmp = await api.GetFeedDetailsWithEpisodes(showId, userId, { seasonId: season.id });
			feed.episodes = feed.episodes.concat(tmp.episodes);
		}));

		// sort feed by pubDate
		feed.episodes.sort((a, b) => {
			if (a.published !== b.published) {
				return a.published < b.published ? 1 : -1;
			}
			return 0;
		});
	} else if (feed.details.episodeCount > feed.episodes.length) {
		// note: episodeCount is completely wrong if the show has seasons
		let offset = 50;
		while (feed.details.episodeCount > feed.episodes.length) {
			const tmp = await api.GetFeedDetailsWithEpisodes(showId, userId, { offset });
			feed.episodes = feed.episodes.concat(tmp.episodes);
			// magic numbers REEEEEE
			offset += 50;
		}
	}

	// stick feed in cache for 30 minutes
	cache.put(showId, feed, 1800000);

	return feed;
}

function stitcherAuth() {
	return async function(req, res, next) {
		try {
			const user = await api.CheckAuthentication(req.body.email, req.body.password);

			if (user.error) {
				return res.status(403).send(user.error);
			}

			if (user.subscriptionState !== '3') {
				return res.status(403).send('User is not a subscriber');
			}

			req.user = user;
			return next();
		} catch (e) {
			return res.status(500).send('Server error');
		}
	};
}

function tokenAuth() {
	return async function(req, res, next) {
		try {
			const user = await db.User.findOne({ where: { token: req.query.token } });
			if (!user) {
				return res.status(403).send('Incorrect token');
			}

			req.user = user;
			return next();
		} catch (e) {
			return res.status(500).send('Server error');
		}
	};
}

module.exports = { durationFormat, pubDateFormat, getShowFeed, stitcherAuth, tokenAuth };