Commit 9cf663cd984d82a34c1bbbe5f97656f8a6266532
1 parent
3b5a29d1
Exists in
master
and in
1 other branch
Added callback for error in core request
Showing
1 changed file
with
11 additions
and
0 deletions
Show diff stats
server.js
| @@ -46,6 +46,11 @@ app.post('/api', function(req, res){ | @@ -46,6 +46,11 @@ app.post('/api', function(req, res){ | ||
| 46 | res.send(200, { 'response' : 'http://' + SERVER_IP + ':' + port + '/' + ID_FROM_BD + '.webm' }); | 46 | res.send(200, { 'response' : 'http://' + SERVER_IP + ':' + port + '/' + ID_FROM_BD + '.webm' }); |
| 47 | ID_FROM_BD++; | 47 | ID_FROM_BD++; |
| 48 | }); | 48 | }); |
| 49 | + | ||
| 50 | + /* Listener que dispara quando a requisição ao core da erro */ | ||
| 51 | + child.on('error', function(code, signal){ | ||
| 52 | + res.send(500, parameters.errorMessage('Erro na chamada ao core')); | ||
| 53 | + }); | ||
| 49 | } else { | 54 | } else { |
| 50 | res.send(500, parameters.errorMessage('Parâmetros insuficientes ou inválidos')); | 55 | res.send(500, parameters.errorMessage('Parâmetros insuficientes ou inválidos')); |
| 51 | } | 56 | } |
| @@ -86,6 +91,12 @@ app.post('/api', function(req, res){ | @@ -86,6 +91,12 @@ app.post('/api', function(req, res){ | ||
| 86 | /* Listener que dispara quando a requisição ao core finaliza */ | 91 | /* Listener que dispara quando a requisição ao core finaliza */ |
| 87 | child.on('close', function(code, signal){ | 92 | child.on('close', function(code, signal){ |
| 88 | res.send(200, { 'response' : 'http://' + SERVER_IP + ':' + port + '/' + ID_FROM_BD + '.flv' }); | 93 | res.send(200, { 'response' : 'http://' + SERVER_IP + ':' + port + '/' + ID_FROM_BD + '.flv' }); |
| 94 | + ID_FROM_BD++; | ||
| 95 | + }); | ||
| 96 | + | ||
| 97 | + /* Listener que dispara quando a requisição ao core da erro */ | ||
| 98 | + child.on('error', function(code, signal){ | ||
| 99 | + res.send(500, parameters.errorMessage('Erro na chamada ao core')); | ||
| 89 | }); | 100 | }); |
| 90 | }); | 101 | }); |
| 91 | } else { | 102 | } else { |