Skip to content

Commit 533d7ed

Browse files
RangerMauveandrewosh
authored andcommitted
Handle function extensions and don't double encode
1 parent e83175d commit 533d7ed

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

index.js

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -289,6 +289,7 @@ module.exports = CorestoreNetworker
289289

290290
class SwarmExtension {
291291
constructor (networker, name, opts) {
292+
if (typeof opts === 'function') opts = opts(this)
292293
this.networker = networker
293294
this.name = name
294295
this.encoding = codecs((opts && opts.encoding) || 'binary')
@@ -316,7 +317,6 @@ class SwarmExtension {
316317
}
317318

318319
broadcast (message) {
319-
if (this.encoding) message = this.encoding.encode(message)
320320
for (const peerExt of this._peerExtensions.values()) {
321321
peerExt.send(message)
322322
}
@@ -326,7 +326,6 @@ class SwarmExtension {
326326
const peerExt = this._peerExtensions.get(peer)
327327
if (!peer) throw new Error('Peer must be specified.')
328328
if (!peerExt) throw new Error('Extension not registered for peer ' + peer.remotePublicKey.toString('hex'))
329-
if (this.encoding) message = this.encoding.encode(message)
330329
peerExt.send(message)
331330
}
332331

0 commit comments

Comments
 (0)