video.js
4.72 KB
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
var parameters = require('../helpers/parameters');
var properties = require('../helpers/properties');
var requests = require('../helpers/requests');
var exec = require('child_process').exec, child;
var querystring = require('querystring');
var uuid = require('node-uuid');
var mkdirp = require('mkdirp');
var http = require('http');
var url = require('url');
var fs = require('fs');
function init(req, res) {
var id = uuid.v4();
/* Verifica se os paramêtros [posicao, tamanho, transparencia] possuem algum valor */
if ((req.body.posicao === '') || (req.body.tamanho === '') || (req.body.transparencia === '')) {
res.send(500, parameters.errorMessage('O valor de algum parâmetro está vazio'));
return;
}
/* Verifica se os paramêtros [linguagem, posicao, tamanho, transparencia] possuem os seus únicos valores possíveis */
if ((parameters.checkPosition(req.body.posicao) === false) || (parameters.checkSize(req.body.tamanho) === false) || (parameters.checkTransparency(req.body.transparencia) === false)) {
res.send(500, parameters.errorMessage('Parâmetros insuficientes ou inválidos'));
return;
}
/* Checa se o arquivo de vídeo submetivo possui uma extensão válida */
if (req.files.video !== undefined) {
if (parameters.checkVideo(req.files.video.name) === false) {
res.send(500, parameters.errorMessage('Vídeo enviado com extensão inválida'));
return;
}
var video = {
'name': req.files.video.name,
'path': req.files.video.path
}
processVideo(id, video, req, res);
} else if (req.body.video_url !== undefined) {
http.get(req.body.video_url, function(response) {
// Salva o arquivo em disco
response.pipe(fs.createWriteStream(id));
var video = {
'name': req.body.video_url.substring(req.body.video_url.lastIndexOf('/') + 1),
'path': id
}
processVideo(id, video, req, res);
}).on('error', function(e) {
error = 'Problema ao carregar video_url: ' + e.message;
res.send(500, parameters.errorMessage(error));
});
} else {
res.send(500, parameters.errorMessage('Video deve ser enviado como parâmetro "video" ou como "video_url"'));
return;
}
};
function processVideo(id, video, req, res) {
/* Cria uma pasta cujo o nome é o ID atual */
mkdirp(properties.uploads_folder + id, function(error) {
if (error) { console.log(error); res.send(500, parameters.errorMessage('Erro na criação da pasta com o ID: ' + id)); return; }
/* Move o vídeo submetido para a pasta com o seu ID correspondente */
fs.rename(video.path, properties.uploads_folder + id + '/' + video.name, function(error) {
if (error) { console.log(error); res.send(500, parameters.errorMessage('Erro ao mover o vídeo submetido')); return; }
});
/* Cria a linha de comando */
var command_line = 'vlibras_user/vlibras-core/./vlibras ' + parameters.getServiceType(req.body.servico) + ' uploads/' + id + '/' +
video.name + ' 1 ' + parameters.getPosition(req.body.posicao) + ' ' + parameters.getSize(req.body.tamanho) + ' ' +
parameters.getTransparency(req.body.transparencia) + ' ' + id + ' > /tmp/core_log 2>&1';
console.log(command_line);
/* Executa a linha de comando */
child = exec(command_line, function(err, stdout, stderr) {
// [stdout] = vlibras-core output
// console.log('Err: ' + err);
// console.log('STDOUT: ' + stdout);
// console.log('STDERR: ' + stderr);
});
if (req.body.callback === undefined) {
/* Listener que dispara quando a requisição ao core finaliza */
child.on('close', function(code, signal){
if (code !== 0) {
console.log('Erro código: ' + code); res.send(500, { 'error': 'Erro no Core', 'code': code }); return;
}
res.send(200, { 'response' : 'http://' + properties.SERVER_IP + ':' + properties.port + '/' + id + '.flv' });
});
child.on('error', function(code, signal){
res.send(500, parameters.errorMessage('Erro na chamada ao core'));
});
} else {
child.on('close', function(code, signal){
if (code !== 0) {
var path = url.parse(req.body.callback);
var data = querystring.stringify( { 'error': 'Erro no Core', 'code': code } );
requests.postRequest(path, data);
return;
}
var path = url.parse(req.body.callback);
var data = querystring.stringify({ 'response' : 'http://' + properties.SERVER_IP + ':' + properties.port + '/' + id + '.flv' });
requests.postRequest(path, data);
});
/* Listener que dispara quando a requisição ao core da erro */
child.on('error', function(code, signal){
var path = url.parse(req.body.callback);
var data = querystring.stringify( { 'error': 'Erro na chamada ao core', 'code': code, 'id': id } );
requests.postRequest(path, data);
});
res.send(200, JSON.stringify({ 'id': id }));
}
});
}
module.exports.init = init;