-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathindex.js
More file actions
114 lines (87 loc) · 3.25 KB
/
index.js
File metadata and controls
114 lines (87 loc) · 3.25 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
/*
* Primary file for the API
*
*/
// Dependencies
const http = require('http');
const https = require('https');
const StringDecoder = require('string_decoder').StringDecoder;
const config = require('./lib/config');
const fs = require('fs');
const handlers = require('./lib/handlers');
const helpers = require('./lib/helpers');
// instantiate http server
var httpServer = http.createServer((req,res) => {
unifiedServer(req,res);
});
// Start the http server
httpServer.listen(config.httpPort, () => {
console.log(`The server is listening on port ${config.httpPort}`);
})
// instantiate the HTTPS server
var httpsServerOptions = {
'key': fs.readFileSync('./https/key.pem'),
'cert': fs.readFileSync('./https/cert.pem')
};
var httpsServer = https.createServer(httpsServerOptions,(req,res) => {
unifiedServer(req,res);
});
// Start the HTTPS server
httpsServer.listen(config.httpsPort, () => {
console.log(`The server is listening on port ${config.httpsPort}`);
})
// All the server logic for both the http and https server
var unifiedServer = function(req,res){
// Get the URL and parse it
var parsedUrl = new URL(req.url, `http://${req.headers.host}`);
// Get the path
var path = parsedUrl.pathname;
var trimmedPath = path.replace(/^\/+|\/+$/g, '');
// Get the query string as an object
var queryStringObject = parsedUrl.searchParams;
// Get the HTTP Method
var method = req.method.toLowerCase();
// Get the headers as an object
var headers = req.headers;
// Get the payload, if any
var decoder = new StringDecoder('utf-8');
var buffer = '';
req.on('data', (data) => {
buffer += decoder.write(data);
});
req.on('end', () => {
buffer += decoder.end();
// Choose the handler that this request should go to. If one is not found use the notFound handler
var choosenHandler = typeof(router[trimmedPath]) !== 'undefined' ? router[trimmedPath]: handlers.notFound;
// Construct the data object to send to the handler
var data = {
'trimmedPath' : trimmedPath,
'queryStringObject': queryStringObject,
'method': method,
'headers': headers,
'payload': helpers.parseJsonToObject(buffer)
};
// route the request to the handler specified in the router
choosenHandler(data, (statusCode, payload)=>{
// Use the status code called back by the handler, or default to 200
statusCode = typeof(statusCode) == 'number' ? statusCode : 200;
// Use the payload called back by the handler, or default to an empty object
payload = typeof(payload) == 'object' ? payload: {};
// Convert the payload to a string
var payloadString = JSON.stringify(payload);
// Return the response
res.setHeader('Content-Type', 'application/json');
res.writeHead(statusCode);
res.end(payloadString);
// Log the request path
console.log(`Returning this response: ${statusCode} ${payload}`);
});
});
};
// Define a request router
var router = {
'ping': handlers.ping,
'users': handlers.users,
'tokens': handlers.tokens,
'checks' : handlers.checks
};