-
Notifications
You must be signed in to change notification settings - Fork 3
/
request.js
109 lines (98 loc) · 2.58 KB
/
request.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
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
import config from '../config';
import request from 'request';
/**
* Request
*
* A wrapper of npm 'request' to allow for
* genericizing request and response manipulations.
*/
export default {
get(url, options, callback) {
handleRequest(url, options, (req) => {
request.get(req, (err, res) => {
handleResponse(err, res, callback);
});
});
},
/**
* GET PROXY
*
* Functions the same as a get request but takes a
* response object instead of a callback and pipes
* the request response to the response object.
*/
getProxy(url, options, res) {
handleRequest(url, options, (req) => {
request.get(req).on('response', (resp) => {
if (options.status) {resp.statusCode = options.status;}
}).pipe(res);
});
},
post(url, options, callback) {
handleRequest(url, options, (req) => {
request.post(req, (err, res) => {
handleResponse(err, res, callback);
});
});
},
put (url, options, callback) {
handleRequest(url, options, (req) => {
request.put(req, (err, res) => {
handleResponse(err, res, callback);
});
});
},
del(url, options, callback) {
handleRequest(url, options, (req) => {
request.del(req, (err, res) => {
handleResponse(err, res, callback);
});
});
}
};
/**
* Handle Request
*
* Processes all requests before they fire.
*/
function handleRequest(url, options, callback) {
let req = {
url: url,
headers: {},
qs: {},
json: {}
};
req = parseOptions(req, options);
callback(req);
}
/**
* Handle Response
*
* Process all responses before they return
* to the callback.
*/
function handleResponse(err, res, callback) {
callback(err, res);
}
/**
* Parse Options
*
* Normalizes request options.
*/
function parseOptions(req, options) {
if (options.query) {req.qs = options.query;}
if (options.body) {req.json = options.body;}
if (options.hasOwnProperty('encoding')) {req.encoding = options.encoding;}
if (req.url && req.url.indexOf(config.scitran.url) > -1 && options.droneRequest !== false) {
req.headers = {
'X-SciTran-Auth': config.scitran.secret,
'User-Agent': 'SciTran Drone CRN Server'
};
}
if (options.headers) {
for (let key in options.headers) {
req.headers[key] = options.headers[key];
}
}
return req;
}