2015-12-30 03:36:14 +00:00
|
|
|
'use strict';
|
|
|
|
|
|
|
|
var PromiseA = require('bluebird');
|
|
|
|
var loopback = require('./loopback-listener');
|
|
|
|
|
|
|
|
module.exports.create = function (args) {
|
|
|
|
if (args.debug) {
|
|
|
|
console.log('[HP] create holepuncher');
|
|
|
|
console.log(args);
|
|
|
|
}
|
|
|
|
|
|
|
|
var servers = loopback.create(args);
|
2015-12-30 06:35:21 +00:00
|
|
|
//var promises = [];
|
2015-12-30 03:36:14 +00:00
|
|
|
|
|
|
|
if (args.debug) {
|
|
|
|
console.log('[HP] create servers');
|
|
|
|
console.log(servers);
|
|
|
|
}
|
|
|
|
|
2015-12-30 06:35:21 +00:00
|
|
|
function getExternalIps() {
|
|
|
|
return PromiseA.any(args.ipifyUrls.map(function (ipifyUrl) {
|
2015-12-30 03:36:14 +00:00
|
|
|
var getIp = require('./external-ip');
|
|
|
|
|
|
|
|
return getIp({ hostname: ipifyUrl, debug: args.debug });
|
|
|
|
}));
|
|
|
|
}
|
|
|
|
|
2015-12-30 06:35:21 +00:00
|
|
|
function testOpenPort(ip, portInfo) {
|
|
|
|
var requestAsync = require('./request');
|
|
|
|
|
|
|
|
return requestAsync({
|
|
|
|
secure: portInfo.secure
|
|
|
|
, rejectUnauthorized: false
|
|
|
|
, hostname: ip.address
|
|
|
|
// '/.well-known/com.daplie.loopback/'
|
|
|
|
, path: args.loopbackPrefix + args.key
|
|
|
|
// 'loopback.daplie.invalid'
|
|
|
|
, servername: args.loopbackHostname
|
|
|
|
, localAddress: ip.localAddress
|
|
|
|
, port: portInfo.external || portInfo.internal
|
|
|
|
, headers: {
|
|
|
|
// 'loopback.daplie.invalid'
|
|
|
|
Host: args.loopbackHostname
|
|
|
|
}
|
|
|
|
}).then(function (val) {
|
|
|
|
if (val !== args.value) {
|
|
|
|
return PromiseA.reject(new Error("invalid loopback token value"));
|
|
|
|
}
|
|
|
|
|
|
|
|
ip.validated = true;
|
|
|
|
|
|
|
|
ip.ports.push(portInfo);
|
|
|
|
portInfo.ips.push(ip);
|
|
|
|
|
|
|
|
return portInfo;
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
function testPort(opts) {
|
|
|
|
// TODO should ip.address === ip.localAddress be treated differently?
|
|
|
|
// TODO check local firewall?
|
|
|
|
// TODO would it ever make sense for a public ip to respond to upnp?
|
|
|
|
|
|
|
|
// TODO should we pass any or require all?
|
|
|
|
opts.portInfo.ips = [];
|
|
|
|
|
|
|
|
return PromiseA.any(opts.ips.map(function (ip) {
|
|
|
|
ip.ports = [];
|
|
|
|
|
|
|
|
if (!opts.pretest) {
|
|
|
|
//console.log('[HP pretest]', opts.pretest);
|
|
|
|
return ip;
|
|
|
|
}
|
|
|
|
|
|
|
|
return testOpenPort(ip, opts.portInfo);
|
|
|
|
}));
|
|
|
|
}
|
|
|
|
|
|
|
|
return getExternalIps().then(function (ips) {
|
|
|
|
var pretest = (-1 !== args.protocols.indexOf('none'));
|
|
|
|
var portInfos = args.plainPorts.concat(args.tlsPorts.map(function (info) {
|
|
|
|
info.secure = true;
|
|
|
|
return info;
|
|
|
|
}));
|
|
|
|
|
|
|
|
return PromiseA.all(portInfos.map(function (info) {
|
|
|
|
// TODO clone-merge args
|
|
|
|
return testPort({
|
|
|
|
portInfo: info
|
|
|
|
, ips: ips
|
|
|
|
, pretest: pretest
|
|
|
|
});
|
|
|
|
})).then(function (portInfos) {
|
|
|
|
if (args.debug) {
|
|
|
|
console.log('[HP] all done on the first try');
|
|
|
|
console.log(portInfos);
|
|
|
|
}
|
|
|
|
return portInfos;
|
|
|
|
}, function () {
|
|
|
|
// at least one port could not be mapped
|
|
|
|
var mappers = [];
|
|
|
|
|
|
|
|
if (-1 !== args.protocols.indexOf('upnp')
|
|
|
|
|| -1 !== args.protocols.indexOf('ssdp')
|
|
|
|
) {
|
|
|
|
mappers.push(require('./upnp'));
|
|
|
|
}
|
|
|
|
|
|
|
|
if (-1 !== args.protocols.indexOf('pmp')
|
|
|
|
|| -1 !== args.protocols.indexOf('nat-pmp')
|
|
|
|
) {
|
|
|
|
mappers.push(require('./pmp'));
|
|
|
|
}
|
|
|
|
|
|
|
|
return PromiseA.all(portInfos.map(function (portInfo) {
|
|
|
|
return PromiseA.any(mappers.map(function (fn) {
|
|
|
|
var p = fn(args, ips, portInfo);
|
|
|
|
|
|
|
|
if (portInfos.ips.length) {
|
|
|
|
return portInfos;
|
|
|
|
}
|
|
|
|
|
|
|
|
return p;
|
|
|
|
}));
|
|
|
|
})).then(function () {
|
|
|
|
if (args.debug) {
|
|
|
|
console.log("[HP] all ports successfully mapped");
|
|
|
|
console.log(portInfos);
|
|
|
|
}
|
|
|
|
|
|
|
|
return portInfos;
|
|
|
|
});
|
|
|
|
}).then(function () {
|
|
|
|
return portInfos;
|
|
|
|
}, function () {
|
|
|
|
console.warn('[HP] RVPN not implemented');
|
|
|
|
return portInfos;
|
|
|
|
});
|
2015-12-30 03:36:14 +00:00
|
|
|
});
|
|
|
|
};
|