video_legenda_old.js
4.1 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
140
141
142
143
144
var parameters = require('../helpers/parameters');
var properties = require('../helpers/properties');
var files = require('../helpers/files');
var core = require('../helpers/core');
var db = require('../db/api');
var queue_helper = require('../helpers/queue');
var exec = require('child_process').exec, child;
var uuid = require('node-uuid');
var mkdirp = require('mkdirp');
var async = require('async');
var _ = require('lodash');
var logger = require('../logsystem/main.js');
var url = require('url');
var requests = require('../helpers/requests');
var querystring = require('querystring');
function init(req, res, Request, queue) {
res.set("Content-Type", "application/json");
process(req, res, Request, queue);
}
function process(req, res, Request, queue) {
var id = uuid.v4();
var folder = properties.uploads_folder + id;
var locals = {};
var request_object = new Request({
id: id,
type: req.body.servico,
status: 'Submitted',
link: 'http://' + properties.SERVER_IP + ':' + properties.port + '/' + id + '.mp4',
link_video: req.body.video_url,
author: req.body.conteudista,
subtitle: 'http://150.165.204.80:5000/api/subtitle.srt',
dictionary: '1.0',
created_at: new Date(),
updated_at: new Date(),
});
db.create(request_object, function(result) {
if (result !== null) {
res.send(200, { 'id': result.id});
} else {
res.send(500, { 'error': 'Erro na criação da requisição.'});
}
});
async.series([
// Cria a pasta apropriada
function(callback) {
console.log("== Criando pasta " + folder);
mkdirp(folder, function(err) {
var error;
if (err) { error = "Erro na criação da pasta com o id: " + id + "; " + err; }
callback(error);
});
},
// Baixa e move os arquivos para a pasta correta
function(callback) {
console.log("== Baixando os arquivos");
try {
setTimeout(function() { downloadAndMoveFiles(folder, req, locals, callback); }, 1000);
} catch (err) {
console.log(" Erro " + err);
callback(err);
}
},
// Chama o core
function(callback) {
console.log("== Chamando o core");
// Faz a chamada ao core
try {
callCoreSubtitle(id, locals.video, locals.subtitle, req, res, Request, request_object, queue);
callback();
} catch (err) {
callback(err);
}
}
], function(err) {
// Se tiver erro
if (err) {
res.send(500, parameters.errorMessage(err));
return;
}
});
}
function downloadAndMoveFiles(folder, req, locals, callback) {
async.parallel([
// Download video
function(callback) {
console.log("Baixando video");
files.downloadAndMoveVideo(folder, req, locals, callback);
},
// Download subtitle
function(callback) {
console.log("Baixando legenda");
files.downloadAndMoveSubtitle(folder, req, locals, callback);
}
], function(err) {
console.log("=== Legenda e video baixados");
// Callback chamado depois de todas as tarefas
// Se tiver erro, vai passar para cima
callback(err);
});
}
function callCore(id, video, subtitle, req, res, Request, request_object) {
/* Cria a linha de comando */
/* slice(2) é para transformar ./path em path */
var command_line = 'vlibras_user/vlibras-core/./vlibras -V ' + video.path.slice(2) + ' -p bottom_right -r large --id ' + id + ' --mode devel > /tmp/core_log 2>&1';
console.log("=== Core: " + command_line);
console.log("ID: " + request_object.id);
core.call(id, command_line, req, res, Request, request_object, "videos");
}
function callCoreSubtitle(id, video, subtitle, req, res, Request, request_object, queue) {
var command_line = 'vlibras_user/vlibras-core/./vlibras -V ' + video.path.slice(2) + ' -S ' + subtitle.path.slice(2) + ' -l portugues -p '+ req.body.posicao + ' -r ' + req.body.tamanho + ' -b opaque --id ' + id + ' -m devel > /tmp/core_log 2>&1';
console.log("Chamada ao core == " + command_line);
var child;
var job = queue.create('exec_command_line', {
title: 'Command Line for: ' + req.body.servico,
command_line: command_line,
callback: req.body.callback,
idreq: request_object.id,
idsolicitacao: id
}).removeOnComplete( true ).save();
}
module.exports.init = init;