From a63a54987ddf9fd0f080e3242de5c104587f66eb Mon Sep 17 00:00:00 2001 From: Andre Staltz Date: Fri, 12 Jan 2024 17:11:39 +0200 Subject: [PATCH] no event.parsedAddress --- lib/plugin-hub.cjs | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/lib/plugin-hub.cjs b/lib/plugin-hub.cjs index 08a374a..e7146ce 100644 --- a/lib/plugin-hub.cjs +++ b/lib/plugin-hub.cjs @@ -1,4 +1,3 @@ -const bs58 = require('bs58') const cat = require('pull-cat') const Notify = require('pull-notify') const pull = require('pull-stream') @@ -19,13 +18,16 @@ function ErrorDuplex(message) { } /** - * @param {Array<[any, any]>} parsedAddress + * @param {string} addresses * @returns {string | undefined} */ -function extractSHSEPubkey(parsedAddress) { - for (const [transport, transform] of parsedAddress) { - if (transform.name === 'shse') { - return bs58.encode(transform.pubkey) +function extractSHSEPubkey(addresses) { + for (const address of addresses.split(';')) { + for (const [transport, transform] of address.split('~')) { + const [name, pubkey, extra] = transform.split(':') + if (name === 'shse') { + return pubkey + } } } } @@ -82,7 +84,7 @@ module.exports = { pull.filter( ({ type }) => type === 'connecting-failed' || type === 'disconnected' ), - pull.map(({ parsedAddress }) => extractSHSEPubkey(parsedAddress)), + pull.map(({ address }) => extractSHSEPubkey(address)), pull.filter((pubkey) => !!pubkey && attendants.has(pubkey)), pull.drain((pubkey) => { debug('farewell %s', pubkey)