Skip to content
Snippets Groups Projects
Commit 6c6986fd authored by yamadapc's avatar yamadapc
Browse files

Add setWebSocket method

parent c33f0edb
No related branches found
No related tags found
No related merge requests found
...@@ -79,6 +79,13 @@ var Steem = function (_EventEmitter) { ...@@ -79,6 +79,13 @@ var Steem = function (_EventEmitter) {
} }
_createClass(Steem, [{ _createClass(Steem, [{
key: 'setWebSocket',
value: function setWebSocket(url) {
this.options.url = url;
this.stop();
this.start();
}
}, {
key: 'start', key: 'start',
value: function start() { value: function start() {
var _this2 = this; var _this2 = this;
...@@ -106,7 +113,6 @@ var Steem = function (_EventEmitter) { ...@@ -106,7 +113,6 @@ var Steem = function (_EventEmitter) {
this.releases.forEach(function (release) { this.releases.forEach(function (release) {
return release(); return release();
}); });
this.ws.removeEventListener();
this.ws.close(); this.ws.close();
delete this.ws; delete this.ws;
delete this.releases; delete this.releases;
...@@ -326,4 +332,5 @@ _bluebird2.default.promisifyAll(Steem.prototype); ...@@ -326,4 +332,5 @@ _bluebird2.default.promisifyAll(Steem.prototype);
// Export singleton instance // Export singleton instance
var steem = new Steem(); var steem = new Steem();
exports = module.exports = steem; exports = module.exports = steem;
exports.Steem = Steem; exports.Steem = Steem;
\ No newline at end of file exports.Steem.DEFAULTS = DEFAULTS;
\ No newline at end of file
...@@ -44,6 +44,12 @@ class Steem extends EventEmitter { ...@@ -44,6 +44,12 @@ class Steem extends EventEmitter {
this.start(); this.start();
} }
setWebSocket(url) {
this.options.url = url;
this.stop();
this.start();
}
start() { start() {
this.startP = new Promise((resolve /* , reject*/) => { this.startP = new Promise((resolve /* , reject*/) => {
this.ws = new WebSocket(this.options.url); this.ws = new WebSocket(this.options.url);
...@@ -69,7 +75,6 @@ class Steem extends EventEmitter { ...@@ -69,7 +75,6 @@ class Steem extends EventEmitter {
stop() { stop() {
this.releases.forEach((release) => release()); this.releases.forEach((release) => release());
this.ws.removeEventListener();
this.ws.close(); this.ws.close();
delete this.ws; delete this.ws;
delete this.releases; delete this.releases;
...@@ -272,3 +277,4 @@ Promise.promisifyAll(Steem.prototype); ...@@ -272,3 +277,4 @@ Promise.promisifyAll(Steem.prototype);
const steem = new Steem(); const steem = new Steem();
exports = module.exports = steem; exports = module.exports = steem;
exports.Steem = Steem; exports.Steem = Steem;
exports.Steem.DEFAULTS = DEFAULTS;
...@@ -12,6 +12,13 @@ describe('steem', function () { ...@@ -12,6 +12,13 @@ describe('steem', function () {
await steem.apiIdsP; await steem.apiIdsP;
}); });
describe('setWebSocket', () => {
it('works', () => {
steem.setWebSocket('ws://localhost');
steem.setWebSocket(steem.Steem.DEFAULTS.url);
});
});
describe('getFollowers', () => { describe('getFollowers', () => {
describe('getting ned\'s followers', () => { describe('getting ned\'s followers', () => {
it('works', async () => { it('works', async () => {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment