Estoy tratando de enviar un mensaje a través de una red IPFS pero sigo recibiendo el error TypeError: Cannot read properties of undefined (reading 'publish') .
El error ocurre en la línea node.pubsub.publish(topic, msg, (err) => {}) .
ipfs.js es el motor principal de la aplicación y contiene los métodos necesarios para interactuar con la red IPFS.
El método 'sendNewMsg' se usa para enviar mensajes a un tema donde otros compañeros pueden suscribirse y leer los mensajes.
index.js llama y ejecuta el método.
¿Podría ayudarme a detectar y solucionar el problema?
¡Gracias por adelantado!
ipfs.js:
const IPFS = require('ipfs'); const BufferPackage = require('buffer'); const Buffer = BufferPackage.Buffer; class IPFSEngine { constructor(){ let node = IPFS.create({ EXPERIMENTAL: { pubsub: true }, repo: (() => `repo-${Math.random()}`)(), config: { Addresses: { Swarm: [ '/dns4/ws-star.discovery.libp2p.io/tcp/443/wss/p2p-websocket-star' ] } } }); this.node = node; } .... .... .... sendNewMsg(topic, newMsg) { let {node} = this; console.log('Message sent: ', newMsg) const msg = Buffer.from(newMsg) node.pubsub.publish(topic, msg, (err) => { if (err) { return console.error(`Failed to publish to ${topic}`, err) } // msg was broadcasted console.log(`Published to ${topic}`) }) } } // Export IPFSEngine module.exports = {IPFSEngine};índice.js:
const {IPFSEngine} = require('./ipfs'); const ipfs = new IPFSEngine(); ipfs.sendNewMsg(`topic2`,`Messages 2 ..!`)El error indica que node.pubsub no está definido mientras intenta acceder a la propiedad de publish en el objeto.
Al leer rápidamente un ejemplo de la documentación de IPFS , parece que IPFS.create es una API asíncrona, cuyo resultado no está esperando. Podría explicar por qué obtiene una propiedad pubsub indefinida en su nodo.
Usando una función asíncrona, podría escribir algo como:
async function sendNewMsg(topic, newMsg) { let { node } = this; console.log('Message sent: ', newMsg); const msg = Buffer.from(newMsg); (await node).pubsub.publish(topic, msg, (err) => { if (err) { return console.error(`Failed to publish to ${topic}`, err); } // msg was broadcasted console.log(`Published to ${topic}`); }); }O sin la sintaxis async/await:
function sendNewMsg2(topic, newMsg) { let { node } = this; console.log('Message sent: ', newMsg); const msg = Buffer.from(newMsg); node.then((readyNode) => { readyNode.pubsub.publish(topic, msg, (err) => { if (err) { return console.error(`Failed to publish to ${topic}`, err); } // msg was broadcasted console.log(`Published to ${topic}`); }); }) }