From 332b7cf9f8b3fde4c23da86e500e4e06d5743f0b Mon Sep 17 00:00:00 2001 From: haad Date: Tue, 12 Apr 2016 11:05:30 +0200 Subject: [PATCH] Add logger to Pubsub --- src/PubSub.js | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/PubSub.js b/src/PubSub.js index 8eff4ea..f441c06 100644 --- a/src/PubSub.js +++ b/src/PubSub.js @@ -1,6 +1,7 @@ '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 { constructor(ipfs) { @@ -17,9 +18,9 @@ class Pubsub { this._socket = io.connect(`http://${host}:${port}`, { 'forceNew': true }); this._socket.on('connect', resolve); - this._socket.on('connect_error', (err) => reject(new Error(`Connection refused to ${host}:${port}`))); - this._socket.on('disconnect', (socket) => console.log(`Disconnected from http://${host}:${port}`)); - this._socket.on('error', (e) => console.log('Pubsub socket error:', e)); + this._socket.on('connect_error', (err) => reject(new Error(`Connection refused to Pubsub at '${host}:${port}'`))); + this._socket.on('disconnect', (socket) => logger.warn(`Disconnected from Pubsub at 'http://${host}:${port}'`)); + this._socket.on('error', (e) => logger.error('Pubsub socket error:', e)); this._socket.on('message', this._handleMessage.bind(this)); this._socket.on('subscribed', this._handleMessage.bind(this)); });