Univerter/index.js

const ytdl = require('ytdl-core'),
  fs = require('fs'),
  path = require('path'),
  express = require('express'),
  ffmpeg = require('ffmpeg'),
  bodyParser = require('body-parser')

const PORT = process.env.PORT || 8080
const app = express()
if (fs.existsSync(path.join(__dirname, 'cached'))) {
  fs.unlinkSync(path.join(__dirname, 'cached'))
}

fs.mkdirSync(path.join(__dirname, 'cached'))

const cacheDuration = 15 || process.env.CACHEDUR

process.on('uncaughtException', (err, origin) => {
  fs.writeSync(
    process.stderr.fd,
    `Caught exception: ${err}\n` +
    `Exception origin: ${origin}`,
  );
});

app.use(bodyParser.urlencoded({ extended: false }))

app.get("/getLink", async (req, res) => {
  const filename = req.query.filename
  const url = req.query.url
  const format = req.query.format
  const quality = req.query.quality

  if (!ytdl.validateURL(url)) {
    res.header("Content-Type", "text/html")
    res.write(`<link rel="stylesheet" href="/style.css">`)
    res.write(`<p>Invalid URL! Check the url for any errors! <br> ${url}</p>`)
    return
  }

  res.setHeader("Content-Type", "text/html");

  res.write(`<link rel="stylesheet" href="/style.css">`)
  // String(Math.floor(Math.random() * 100000)) +
  var ytpath = path.join(__dirname, 'cached/' + ytdl.getVideoID(url) + '.mp4')

  var vidinfo = await ytdl.getBasicInfo(url)

  var lastp = 0
  var ytvid = ytdl(url, { 'quality': quality, 'format': 'mp4' })

    .on("progress", (data, ctotal, etotal) => {
      var integer = 1
      var percent = (Math.ceil(ctotal / etotal * 100))
      if (percent % integer == 0 && lastp != percent) {
        res.write(`<p id="percent${percent}">Downloading... ${percent}%</p>`)
        res.write(`
        <style>
          #percent${lastp} {
            display: none;
          }
        </style>
        `)
        lastp = percent
      }
    })
    .pipe(fs.createWriteStream(ytpath))
    .on("close", () => {
      res.write("<p>Downloaded!</p>")
      var proc = new ffmpeg(ytpath)
      // res.write(`<p>Converting... (May take a while, <a href="https://github.com/Violets-puragtory/NoJS-YTConverter"> doesn't support progress updates yet</a>)</p>`)
      var endpath = ('cached/' + ytdl.getVideoID(url) + String(Math.floor(Math.random() * 100000)) + "Converted." + format)
      res.write(`<p id="convert${0}">Converting... 0% (Potentially Innacurate, Experimental!)</p>`)
      proc.then(function (video) {
        video
          .setVideoDuration(vidinfo.videoDetails.lengthSeconds)
          .setVideoFormat(format)
          .save(endpath, (error, file)=>{
            res.write("<p>Converted!</p>")
            res.write(`<p><a href="/download?path=${path.basename(file)}&filename=${filename}.${format}" target="_blank">Link to video download!</a> (Link is deleted after 15 minutes!)</p>`)
            setTimeout(()=>{
              if (fs.existsSync(ytpath)) {
                fs.unlinkSync(ytpath)
              }
              if (fs.existsSync(file)) {
                fs.unlinkSync(file)
              }
            }, 60 * 1000)
          })
      })

      var integer = 1
      var lastc = 0
      var percent = 0
      async function update() {
        if (fs.existsSync(endpath)) {
          var ffile = await fs.readFileSync(endpath)
          var yt = await fs.readFileSync(ytpath)
          percent = (Math.round(ffile.length / yt.length * (100 / integer))) * integer
          if (percent % integer == 0 && percent != lastc) {
            res.write(`<p id="convert${percent}">Converting... ${Math.min(percent, 100)}% (Potentially Innacurate, Experimental!)</p>`)
            res.write(`
            <style>
              #convert${lastc} {
                display: none;
              }
            </style>
            `)
            lastc = percent
          }
        }
        if (percent < 100) {
          setTimeout(() => {
            update()
          }, 500);
        } 
      }
      update()
    })
});

app.get('/download', (req, res) => {
  var file = req.query.path
  var filename = req.query.filename
  var dest = path.join(__dirname, 'cached/', file)

  if (fs.existsSync(dest)) {
    res.header('Content-Disposition', `attachment; filename="${filename}"`);
    fs.createReadStream(dest).pipe(res)
  } else {
    res.header("Content-Type", "text/html")
    res.write(`<link rel="stylesheet" href="/style.css">`)
    res.write(`<p>Uh oh! It seems that video couldn't be found... Maybe the URL expired? Or, the link was invalid. <br>If you believe this was a mistake, please put a issue on <a href="https://github.com/Violets-puragtory/NoJS-YTConverter/">Github</a></p>`, ()=>{
      res.end()
    })
  }
})

app.use(express.static(path.join(__dirname, 'static')))

app.listen(PORT, function () {
  console.log("Hosted on port " + PORT)
})