Software Público Brasileiro

var requests = require('../helpers/requests');

var url = require('url');
var http = require('http');
var querystring = require('querystring');
var exec = require('child_process').exec, child;

function call(id, command_line, req, res) {
	/* 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);
	});

	// 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) {
				throw "Erro no retorno do core. Código: " + code;
			}

			// Se o core executou normal
			res.send(200, { 'response' : 'http://' + properties.SERVER_IP + ':' + properties.port + '/' + id + '.flv' });
		});

		// Se a chamada deu erro
		child.on('error', function(code, signal) {
			throw "Erro na chamada ao core";
		});


	// Se o callback foi definido
	} else {

		// Se a chamada foi feita com sucesso
		child.on('close', function(code, signal) {

			// Endereço do callback
			var path = url.parse(req.body.callback);

			// Se o core executou com erro
			if (code === 0) {
				var data = querystring.stringify({ 'response' : 'http://' + properties.SERVER_IP + ':' + properties.port + '/' + id + '.mp4' });
			} else {
				var data = querystring.stringify({ 'error': 'Erro no Core', 'code': code });
			}

			// 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 } );

				requests.postRequest(path, data);
		});

		// Retorno da primeira requisição
		res.send(200, JSON.stringify({ 'id': id }));
	}
}

module.exports.call = call;