server.js

'use strict';

var express = require('express');
var app = express();
var logger = require('morgan')('dev');
var multer = require('multer');
var upload = multer({
  storage: multer.memoryStorage(),
  limits: {
    fileSize: 300 * 1024 * 1024 // 300MB
  }
});

var collectHlsSession = require('./hls-session');
var replay = require('./replay').replay;
var decrypt = require('./replay').decrypt;
var replayPlaylist = require('./m3u8-generator');

// the HAR currently being analyzed
// this variable is set whenever the user uploads a new HAR file
var activeHlsSession = null;

app.use(logger);

// CORS
app.use(function(req, res, next) {
  res.header('Access-Control-Allow-Origin', '*');
  res.header('Access-Control-Allow-Headers', 'Origin, X-Requested-With, Content-Type, Accept');
  next();
});

app.use(express.static(__dirname + '/public'));
app.use('/bootstrap', express.static(__dirname + '/node_modules/bootstrap'));
app.use('/aes-decrypter', express.static(__dirname + '/node_modules/aes-decrypter'));
app.use('/thumbcoil', express.static(__dirname + '/node_modules/thumbcoil'));
app.use('/m3u8-parser', express.static(__dirname + '/node_modules/m3u8-parser'));

app.post('/har', upload.single('har-file'), function(request, response, next) {
  var error;
  var har;

  try {
    har = JSON.parse(request.file.buffer.toString('utf8'));
  } catch(e) {
    error = {};
    error[e.name] = e.message;
    return response.status(500).send(error);
  }

  if (!har || !har.log || !har.log.entries) {
    error = {
      InvalidHar: 'Unable to locate HTTP requests in the uploaded file'
    };
    return response.status(500).send(error);
  }

  activeHlsSession = collectHlsSession(har);

  response.status(200).send(activeHlsSession.map(function(entry) {
    var result = {
      request: {
        method: entry.request.method,
        url: entry.request.url
      },
      response: {
        status: entry.response.status,
        contentType: entry.response.contentType,
        bodySize: entry.response.bodySize
      }
    };
    if (entry.key) {
      result.response.encrypted = true;
    }
    if (entry.playlistType) {
      result.response.playlistType = entry.playlistType;
    }

    return result;
  }));
});

function attachHlsSession(request, response, next) {
  response.locals.activeHlsSession = activeHlsSession;
  next();
}

app.get('/replay/:index/*', attachHlsSession, replay);
app.get('/decrypt/:index/*', attachHlsSession, decrypt);
app.get('/m3u8', attachHlsSession, replayPlaylist);
app.get('/m3u8/:start-:end', attachHlsSession, replayPlaylist);

app.listen(7777, function() {
  console.log('HLS HAR Analyzer running at http://localhost:7777/\n');
});