core.js
4.13 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
var requests = require('../helpers/requests');
var properties = require('../helpers/properties');
var queue_helper = require('../helpers/queue');
var url = require('url');
var http = require('http');
var querystring = require('querystring');
var exec = require('child_process').exec, child;
var kue = require('kue'),
queue = kue.createQueue();
var logger = require('../logsystem/main.js');
var db = require('../db/api');
// req_type == "video" ou "outros" para ser usado no logger
function call(id, command_line, req, res, Request, request_object, req_type) {
/* 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);
// });
// para ser usado no logger
req_type = req_type === "videos" ? req_type : "outros";
logger.incrementService(req_type, "requisicoes");
var child,
job = queue.create('exec_command_line' + id, {
title: 'Command Line for: ' + req.body.servico,
command_line: command_line
}).removeOnComplete( true ).save();
queue.process('exec_command_line' + id, function(job, done){
child = queue_helper.exec_command_line(job.data.command_line, done);
});
job.on('complete', function() {
// Se o callback não foi definido
if (req.body.callback === undefined) {
// Se a chamada foi feita com sucesso
child.on('close', function(code, signal) {
// Se o core executou com erro
if (code !== 0) {
db.update(Request, request_object.id, 'Error', function (result) {
});
console.log("Erro no retorno do core. Código: " + code);
logger.incrementError('core', "Erro no retorno do core. Código: " + code);
} else {
// Se o core executou normal
db.update(Request, request_object.id, 'Completed', function (result) {});
res.send(200, { 'response' : 'http://' + properties.SERVER_IP + ':' + properties.port + '/' + id + '.mp4'});
logger.incrementService(req_type, "traducoes");
}
});
// Se a chamada deu erro
child.on('error', function(code, signal) {
console.log("Erro no retorno do core. Código: " + code);
logger.incrementError('core', "Erro no retorno do core. Código: " + code);
});
// Se o callback foi definido
} else {
// Se a chamada foi feita com sucesso
child.on('close', function(code, signal) {
var data;
// Endereço do callback
var path = url.parse(req.body.callback);
// Se o core executou com erro
// if (code === 0) {
// data = querystring.stringify({ 'response' : 'http://' + properties.SERVER_IP + ':' + properties.port + '/' + id + '.mp4', 'id' : id });
// } else {
// data = querystring.stringify({ 'error': 'Erro no Core', 'code': code, 'id' : id });
// logger.incrementError('core', "Erro no retorno do core. Código: " + code);
// }
// Se o core executou com erro
if (code !== 0) {
db.update(Request, request_object.id, 'Error', function (result) {
});
console.log("Erro no retorno do core. Código: " + code);
logger.incrementError('core', "Erro no retorno do core. Código: " + code);
} else {
// Se o core executou normal
db.update(Request, request_object.id, 'Completed', function (result) {});
res.send(200, { 'response' : 'http://' + properties.SERVER_IP + ':' + properties.port + '/' + id + '.mp4'});
logger.incrementService(req_type, "traducoes");
}
// Chama o callback
requests.postRequest(path, data);
});
// Se a chamada deu 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 } );
logger.incrementError('core', "Erro no retorno do core. Código: " + code);
requests.postRequest(path, data);
});
// Retorno da primeira requisição
res.send(200, JSON.stringify({ 'id': id }));
}
});
}
module.exports.call = call;