diff --git a/src/adapters/ipfs/ipfs-coord.js b/src/adapters/ipfs/ipfs-coord.js index 990a98c..414e233 100644 --- a/src/adapters/ipfs/ipfs-coord.js +++ b/src/adapters/ipfs/ipfs-coord.js @@ -100,16 +100,11 @@ class IpfsCoordAdapter { // Subscribe to the chat pubsub channel async subscribeToChat () { - try { - await this.ipfsCoord.adapters.pubsub.subscribeToPubsubChannel( - this.config.chatPubSubChan, - console.log, - this.ipfsCoord.thisNode - ) - } catch (err) { - console.error('Error in subscribeToChat') - throw err - } + await this.ipfsCoord.adapters.pubsub.subscribeToPubsubChannel( + this.config.chatPubSubChan, + console.log, + this.ipfsCoord.thisNode + ) } } diff --git a/test/unit/adapters/ipfs-coord.adapter.unit.js b/test/unit/adapters/ipfs-coord.adapter.unit.js index d839c05..53f2c85 100644 --- a/test/unit/adapters/ipfs-coord.adapter.unit.js +++ b/test/unit/adapters/ipfs-coord.adapter.unit.js @@ -112,4 +112,20 @@ describe('#IPFS', () => { } }) }) + + describe('#subscribeToChat', () => { + it('should subscribe to the chat channel', async () => { + // Mock dependencies + uut.ipfsCoord = { + adapters: { + pubsub: { + subscribeToPubsubChannel: async () => { + } + } + } + } + + await uut.subscribeToChat() + }) + }) })