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

JS API: added `openToTheWeb` method

parent 703f760f
No related branches found
No related tags found
No related merge requests found
...@@ -19,6 +19,7 @@ var dos2unix = require('./app/lib/dos2unix'); ...@@ -19,6 +19,7 @@ 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'); var upnp = require('./app/lib/upnp');
var bma = require('./app/lib/streams/bma');
function Server (dbConf, overrideConf) { function Server (dbConf, overrideConf) {
...@@ -450,6 +451,14 @@ function Server (dbConf, overrideConf) { ...@@ -450,6 +451,14 @@ function Server (dbConf, overrideConf) {
that.upnpAPI = upnpAPI; that.upnpAPI = upnpAPI;
return upnpAPI; return upnpAPI;
}); });
this.listenToTheWeb = (showLogs) => co(function *() {
let bmapi = yield bma(that, [{
ip: that.conf.ipv4,
port: that.conf.port
}], showLogs);
return bmapi.openConnections();
});
} }
util.inherits(Server, stream.Duplex); util.inherits(Server, stream.Duplex);
......
...@@ -7,7 +7,6 @@ var async = require('async'); ...@@ -7,7 +7,6 @@ var async = require('async');
var request = require('request'); var request = require('request');
var vucoin = require('vucoin'); var vucoin = require('vucoin');
var ucoin = require('../../../index'); var ucoin = require('../../../index');
var bma = require('../../../app/lib/streams/bma');
var multicaster = require('../../../app/lib/streams/multicaster'); var multicaster = require('../../../app/lib/streams/multicaster');
var Configuration = require('../../../app/lib/entity/configuration'); var Configuration = require('../../../app/lib/entity/configuration');
var Peer = require('../../../app/lib/entity/peer'); var Peer = require('../../../app/lib/entity/peer');
...@@ -221,13 +220,7 @@ function Node (dbName, options) { ...@@ -221,13 +220,7 @@ function Node (dbName, options) {
done && done(err); done && done(err);
}); });
}) })
.then(function(server){ .then((server) => server.listenToTheWeb());
return bma(server, [{
ip: server.conf.ipv4,
port: server.conf.port
}])
.then((bmapi) => bmapi.openConnections());
});
}; };
function service(callback) { function service(callback) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment