app-transcoder/execIndex.js at master · mms-livestream/app-transcoder · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
/*jslint node: true */
/*jshint esversion: 6 */
"use strict";

let express = require("express");
let bodyParser = require("body-parser");
let core = require("mms-core");
const spawn = require("child_process").spawn;
let fs = require("fs");
let app = express();
let exec = require("child_process").exec;

let quality = ["500k", "1000k", "2000k"];
let count = 0;

let child;
let tmp;
child = exec("rm -r 1",function(error,stdout,stderr) {
  tmp = stdout;
});


app.post("/api/video/:contentId", function(req, res) {
  var contentId = req.params.contentId;
  count = count + 1;
  console.log(contentId);
  if (!fs.existsSync(contentId)) {


    //Création des répertoires
    if (!fs.existsSync(contentId)) {
      fs.mkdirSync(contentId);
    }
    if (!fs.existsSync(contentId + "/" + quality[0])) {
      fs.mkdirSync(contentId + "/" + quality[0]);
    }
    if (!fs.existsSync(contentId + "/" + quality[1])) {
      fs.mkdirSync(contentId + "/" + quality[1]);
    }
    if (!fs.existsSync(contentId + "/" + quality[2])) {
      fs.mkdirSync(contentId + "/" + quality[2]);
    }


    //execution du transcodeur
    let ls;
    ls = spawn("node", ["index.js", contentId, count]);
    console.log(
      "<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<" + " " + contentId
    );
    ls.stdout.on("data", data => {
      console.log(`stdout: ${data}`);
    });

    ls.stderr.on("data", data => {
      console.log(`stderr: ${data}`);
    });

    ls.on("close", code => {
      console.log(`child process exited with code ${code}`);
    });
  }

});
let server = app.listen(8088);
server.timeout = 100000000;
console.log("listenning in port 8088");