/
index.js
68 lines (68 loc) · 2.16 KB
/
index.js
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
const http = require('http');
const serverName = 'jfServerBase/' + require('./package.json').version;
/**
* Crea un servidor web y permite recuperar el cuerpo de la respuesta
* pasando un callback como segundo parámetro.
*/
module.exports = {
/**
* Crea el servidor web.
*
* @param {Number} port Puerto donde se escucharán las peticiones.
* @param {Function} cb Callback a ejecutar cuando se recibe una petición.
* @param {String} charset Juego de caracteres de los datos recibidos.
*/
create(port, cb, charset = 'utf8')
{
if (typeof cb !== 'function')
{
throw new TypeError('El callback es obligatorio');
}
return http
.createServer(
(request, response) => this.getBody(
request,
body => {
response.setHeader('Server', serverName);
cb(request, response, body)
},
charset
)
)
.listen(port);
},
/**
* Devuelve el cuerpo de la petición/respuesta.
*
* @param {http.IncomingMessage} message Petición/respuesta recibida.
* @param {Function} cb Callback a ejecutar cuando se lean todos los datos.
* @param {String} charset Juego de caracteres de los datos recibidos.
*/
getBody(message, cb, charset = 'utf8')
{
let _body = [];
message.addListener('data', chunk => _body.push(chunk));
message.addListener(
'end',
chunk =>
{
if (chunk)
{
_body.push(chunk);
}
_body = Buffer.concat(_body).toString(charset);
if (message.headers && (message.headers['content-type'] || '').indexOf('json') !== -1)
{
try
{
_body = JSON.parse(_body);
}
catch (e)
{
}
}
cb(_body);
}
);
}
};