This repository has been archived by the owner on Dec 11, 2020. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 8
/
index.js
65 lines (56 loc) · 1.72 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
var url = require('url');
var http = require('http');
var fs = require('fs');
var path = require('path');
var extend = require('extend');
function proxyRequest (localRequest, localResponse, next) {
var options = url.parse('http://' + localRequest.url.slice(1));
http.request(options, function (remoteRequest) {
if (remoteRequest.statusCode === 200) {
localResponse.writeHead(200, {
'Content-Type': remoteRequest.headers['content-type']
});
remoteRequest.pipe(localResponse);
} else {
localResponse.writeHead(remoteRequest.statusCode);
localResponse.end();
}
}).on('error', function(e) {
next();
}).end();
};
function Proxy (options) {
var config = extend({}, {
route: ''
}, options);
return function (localRequest, localResponse, next) {
if (typeof config.root === 'string') {
config.root = [config.root]
} else if (!Array.isArray(config.root)) {
throw new Error('No root specified')
}
var pathChecks = []
config.root.forEach(function(root, i) {
var p = path.resolve(root)+localRequest.url;
fs.access(p, function(err) {
pathChecks.push(err ? false : true)
if (config.root.length == ++i) {
var pathExists = pathChecks.some(function (p) {
return p;
});
if (pathExists) {
next();
} else {
if (localRequest.url.slice(0, config.route.length) === config.route) {
localRequest.url = localRequest.url.slice(config.route.length);
proxyRequest(localRequest, localResponse, next);
} else {
return next();
}
}
}
});
})
}
}
module.exports = Proxy;