-
Notifications
You must be signed in to change notification settings - Fork 2
/
server.js
67 lines (64 loc) · 2.47 KB
/
server.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
// Server for monitoring GPS tracker in LocusMap (android)
// Copyright © 2018 Andrey Svetlichny. All rights reserved.
// Licensed under the Apache License, Version 2.0
process.env.TZ = 'Europe/Moscow'; // does not work in windows
const net = require('net');
const querystring = require('querystring');
const Logger = require('./logger');
const logger = new Logger();
function parseHttpHeader(header) {
const match = /(^[^ ]+) ([^? ]+)(\?([^ ]+))?/m.exec(header);
return {
method: match[1],
url: match[2],
params: querystring.parse(match[4])
};
}
const server = net.createServer((c) => {
server.getConnections((err, count) => console.log("client connected " + count));
c.on('end', () => console.log('client disconnected'));
c.on('data', (data) => {
// console.log('data');
if(('' + data).startsWith('GET ')) {
const header = parseHttpHeader(data);
if (header.url === '/gpx') { // Locus connected via HTTP - send GPX file
console.log('HTTP GET /gpx; params=', header.params);
const gpx = logger.getGpx(parseInt(header.params.limit) || 0);
c.write(
'HTTP/1.1 200 OK\r\n' +
'Accept-Ranges: bytes\r\n' +
'Cache-Control: public, max-age=0\r\n' +
'Content-Type: application/gpx+xml\r\n' +
'Content-Length: ' + gpx.length + '\r\n' +
'\r\n');
c.write(gpx);
} else if (header.url === '/status') { // Browser connected via HTTP - send status page
console.log('HTTP GET /status');
c.write(
'HTTP/1.1 200 OK\r\n' +
'Cache-Control: public, max-age=0\r\n' +
'Content-type: text/html\r\n' +
'\r\n');
c.end(logger.status());
} else {
console.log('HTTP GET ' + header.url);
c.end();
}
} else { // Tracker connected via TCP - decode and save GPS data
console.log('TCP');
logger.addRaw(data);
}
});
c.on('error', (err) => {
if (err.code === 'ECONNRESET')
console.log('client disconnected (ECONNRESET)');
else
console.log(err.stack);
});
});
server.on('error', (err) => {
throw err;
});
server.listen(20300, () => {
console.log('TCP and HTTP Server running on port 20300');
});