Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-05-22 14:56:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add logger to Pubsub

Browse Source
This commit is contained in:
haad 2016-04-12 11:05:30 +02:00
parent f683ea7038
commit 332b7cf9f8
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/PubSub.js
View File

@ -1,6 +1,7 @@
'use strict'; 'use strict';
const io = require('socket.io-client'); const io = require('socket.io-client');
const logger = require('orbit-common/lib/logger')("orbit-db.Pubsub");
class Pubsub { class Pubsub {
constructor(ipfs) { constructor(ipfs) {
@ -17,9 +18,9 @@ class Pubsub {
this._socket = io.connect(`http://${host}:${port}`, { 'forceNew': true }); this._socket = io.connect(`http://${host}:${port}`, { 'forceNew': true });
this._socket.on('connect', resolve); this._socket.on('connect', resolve);
this._socket.on('connect_error', (err) => reject(new Error(`Connection refused to ${host}:${port}`))); this._socket.on('connect_error', (err) => reject(new Error(`Connection refused to Pubsub at '${host}:${port}'`)));
this._socket.on('disconnect', (socket) => console.log(`Disconnected from http://${host}:${port}`)); this._socket.on('disconnect', (socket) => logger.warn(`Disconnected from Pubsub at 'http://${host}:${port}'`));
this._socket.on('error', (e) => console.log('Pubsub socket error:', e)); this._socket.on('error', (e) => logger.error('Pubsub socket error:', e));
this._socket.on('message', this._handleMessage.bind(this)); this._socket.on('message', this._handleMessage.bind(this));
this._socket.on('subscribed', this._handleMessage.bind(this)); this._socket.on('subscribed', this._handleMessage.bind(this));
}); });