Skip to content
Snippets Groups Projects
Commit 53c89f7a authored by Cédric Moreau's avatar Cédric Moreau
Browse files

JS API: added `upnp` method

parent fd0edf32
Branches
Tags
No related merge requests found
...@@ -7,7 +7,6 @@ var _ = require('underscore'); ...@@ -7,7 +7,6 @@ var _ = require('underscore');
var Q = require('q'); var Q = require('q');
let co = require('co'); let co = require('co');
let ucoin = require('../../index'); let ucoin = require('../../index');
var upnp = require('../lib/upnp');
let ucp = require('../lib/ucp'); let ucp = require('../lib/ucp');
let constants = require('../lib/constants'); let constants = require('../lib/constants');
let base58 = require('../lib/base58'); let base58 = require('../lib/base58');
...@@ -88,7 +87,7 @@ function WebAdmin (dbConf, overConf) { ...@@ -88,7 +87,7 @@ function WebAdmin (dbConf, overConf) {
this.openUPnP = () => co(function *() { this.openUPnP = () => co(function *() {
yield pluggedDALP; yield pluggedDALP;
return upnp(server.conf.port, server.conf.remoteport); return server.upnp();
}); });
this.regularUPnP = () => co(function *() { this.regularUPnP = () => co(function *() {
...@@ -97,7 +96,7 @@ function WebAdmin (dbConf, overConf) { ...@@ -97,7 +96,7 @@ function WebAdmin (dbConf, overConf) {
server.upnpAPI.stopRegular(); server.upnpAPI.stopRegular();
} }
try { try {
server.upnpAPI = yield upnp(server.conf.port, server.conf.remoteport); yield server.upnp();
server.upnpAPI.startRegular(); server.upnpAPI.startRegular();
} catch (e) { } catch (e) {
logger.error(e); logger.error(e);
......
...@@ -4,7 +4,6 @@ var co = require('co'); ...@@ -4,7 +4,6 @@ var co = require('co');
var Server = require('./server'); var Server = require('./server');
var bma = require('./app/lib/streams/bma'); var bma = require('./app/lib/streams/bma');
var webmin = require('./app/lib/streams/webmin'); var webmin = require('./app/lib/streams/webmin');
var upnp = require('./app/lib/upnp');
var logger = require('./app/lib/logger')('ucoin'); var logger = require('./app/lib/logger')('ucoin');
module.exports = function (dbConf, overConf) { module.exports = function (dbConf, overConf) {
...@@ -50,7 +49,7 @@ module.exports.statics = { ...@@ -50,7 +49,7 @@ module.exports.statics = {
if (server.upnpAPI) { if (server.upnpAPI) {
server.upnpAPI.stopRegular(); server.upnpAPI.stopRegular();
} }
server.upnpAPI = yield upnp(server.conf.port, server.conf.remoteport); yield server.upnp();
server.upnpAPI.startRegular(); server.upnpAPI.startRegular();
} catch (e) { } catch (e) {
logger.warn(e); logger.warn(e);
......
...@@ -18,6 +18,7 @@ var directory = require('./app/lib/directory'); ...@@ -18,6 +18,7 @@ var directory = require('./app/lib/directory');
var dos2unix = require('./app/lib/dos2unix'); var dos2unix = require('./app/lib/dos2unix');
var Synchroniser = require('./app/lib/sync'); var Synchroniser = require('./app/lib/sync');
var multicaster = require('./app/lib/streams/multicaster'); var multicaster = require('./app/lib/streams/multicaster');
var upnp = require('./app/lib/upnp');
function Server (dbConf, overrideConf) { function Server (dbConf, overrideConf) {
...@@ -443,6 +444,12 @@ function Server (dbConf, overrideConf) { ...@@ -443,6 +444,12 @@ function Server (dbConf, overrideConf) {
// The multicaster may answer 'unreachable peer' // The multicaster may answer 'unreachable peer'
.pipe(this.router()); .pipe(this.router());
}; };
this.upnp = () => co(function *() {
let upnpAPI = yield upnp(that.conf.port, that.conf.remoteport);
that.upnpAPI = upnpAPI;
return upnpAPI;
});
} }
util.inherits(Server, stream.Duplex); util.inherits(Server, stream.Duplex);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment