const { getRouter } = require('stremio-addon-sdk'); const requestIp = require('request-ip'); const userAgentParser = require('ua-parser-js'); const addonInterface = require('./addon'); const qs = require('querystring') const { manifest } = require('./lib/manifest'); const { parseConfiguration, PreConfigurations } = require('./lib/configuration'); const landingTemplate = require('./lib/landingTemplate'); const moch = require('./moch/moch'); const router = getRouter({ ...addonInterface, manifest: manifest() }); router.get('/', (_, res) => { res.redirect('/configure') res.end(); }); router.get(`/:preconfiguration(${Object.keys(PreConfigurations).join('|')})`, (req, res) => { res.redirect(`/${req.params.preconfiguration}/configure`) res.end(); }); router.get('/:configuration?/configure', (req, res) => { const configValues = parseConfiguration(req.params.configuration || ''); const landingHTML = landingTemplate(manifest(configValues), configValues); res.setHeader('content-type', 'text/html'); res.end(landingHTML); }); router.get('/:configuration?/manifest.json', (req, res) => { const configValues = parseConfiguration(req.params.configuration || ''); const manifestBuf = JSON.stringify(manifest(configValues)); res.setHeader('Content-Type', 'application/json; charset=utf-8'); res.end(manifestBuf) }); router.get('/:configuration/:resource/:type/:id/:extra?.json', (req, res, next) => { const { configuration, resource, type, id } = req.params; const extra = req.params.extra ? qs.parse(req.url.split('/').pop().slice(0, -5)) : {} const configValues = { ...extra, ...parseConfiguration(configuration), ip: requestIp.getClientIp(req) }; addonInterface.get(resource, type, id, configValues) .then(resp => { const cacheHeaders = { cacheMaxAge: 'max-age', staleRevalidate: 'stale-while-revalidate', staleError: 'stale-if-error' }; const cacheControl = Object.keys(cacheHeaders) .map(prop => Number.isInteger(resp[prop]) && cacheHeaders[prop] + '=' + resp[prop]) .filter(val => !!val).join(', '); res.setHeader('Cache-Control', `${cacheControl}, public`); res.setHeader('Content-Type', 'application/json; charset=utf-8'); res.end(JSON.stringify(resp)); }) .catch(err => { if (err.noHandler) { if (next) { next() } else { res.writeHead(404); res.end(JSON.stringify({ err: 'not found' })); } } else { console.error(err); res.writeHead(500); res.end(JSON.stringify({ err: 'handler error' })); } }); }); router.get('/:moch/:apiKey/:infoHash/:cachedEntryInfo/:fileIndex/:filename?', (req, res) => { const userAgent = req.headers['user-agent'] || ''; const parameters = { mochKey: req.params.moch, apiKey: req.params.apiKey, infoHash: req.params.infoHash.toLowerCase(), fileIndex: isNaN(req.params.fileIndex) ? undefined : parseInt(req.params.fileIndex), cachedEntryInfo: req.params.cachedEntryInfo, ip: requestIp.getClientIp(req), isBrowser: !userAgent.includes('Stremio') && !!userAgentParser(userAgent).browser.name } moch.resolve(parameters) .then(url => { res.writeHead(302, { Location: url }); res.end(); }) .catch(error => { console.log(error); res.statusCode = 404; res.end(); }); }); module.exports = function (req, res) { router(req, res, function () { res.statusCode = 404; res.end(); }); };