index.js

import cors from 'cors';
import express from 'express';
import 'dotenv/config';
import path from 'path';
import OS from 'opensubtitles-api';

const OpenSubtitles = new OS({
    useragent: 'Popcorn Time NodeJS',
    username: '',
    password: '',
    ssl: true
});

const app = express();
const port = 8080;

app.use(cors());

const __dirname = path.resolve();
app.use(express.static(path.join(__dirname, './')));

const returnJSON = ({req, res, next, code, status, message, ...args}) => {
  res.status(code);
  res.json({
    status,
    message,
    ...args,
  });
  next();
};

app.use(express.json());

// const returnFinalSubs = async ({ req, res, next, imdbid, subs }) => {
//   let finalSubs = {};
//   Object.keys(await subs).forEach((lang, index) => {
//     request({
//       url: subs[lang].url,
//       encoding: null
//     }, (error, response, data) => {
//       if (error) returnJSON({ req, res, next, code: 400, status: 'error', message: 'Error while obtaining subtitles' });
//       unzip(data, (unzipError, buffer) => {
//         if (unzipError) returnJSON({ req, res, next, code: 400, status: 'error', message: 'Error while obtaining subtitles' });
//         const srtFile = `./${imdbid}-${lang}-srt.srt`;
//         try {
//           fs.writeFile(srtFile, buffer, {}, async () => {
//             await fs.createReadStream(srtFile)
//             .pipe(srtToVtt())
//             .pipe(fs.createWriteStream(`./${imdbid}-${lang}-vtt.vtt`));
//             finalSubs = {...finalSubs, [lang]: {
//               ...subs[lang],
//               vtt: `${API_URL}/${imdbid}-${lang}-vtt.vtt`
//             }};
//             if (index === Object.keys(subs).length - 1) {
//               returnJSON({ req, res, next, code: 200, status: 'ok', message: 'Subtitles obtained', subs: finalSubs });
//             }
//           })
//         } catch (err) {
//           returnJSON({ req, res, next, code: 400, status: 'error', message: 'Error while obtaining subtitles' });
//         }
//       });
//     });
//   });
// }

app.get('/subs/movie/:id', async (req, res, next) => {
  try {
    const { id: imdbid } = req.params;
    const subs = await OpenSubtitles.search({ imdbid, gzip: true });
    returnJSON({ req, res, next, code: 200, status: 'ok', imdbid, message: 'Subtitles obtained', subs: await subs });
  } catch (error) {
    console.log(error)
    returnJSON({ req, res, next, code: 400, status:  'error', message: 'Unexpected error' });
  }
})

app.get('/subs/tv/:id/:season/:episode', async (req, res, next) => {
  try {
    const { id: imdbid, season, episode } = req.params;
    const subs = await OpenSubtitles.search({ imdbid, season, episode, gzip: true });
    returnJSON({ req, res, next, code: 200, status: 'ok', subs });
  } catch (error) {
    returnJSON({ req, res, next, code: 400, status:  'error', message: 'Unexpected error' });
  }
})

app.listen(process.env.PORT || port, () => {
  console.log(`Subtitles API for Bitflix listening at http://localhost:${port}`);
});