node.js ipfs发送消息typeerror：无法读取未定义的属性（Reading＆＃x27; Prublish Qupprance＆＃x27;）

Question

我正在尝试通过IPFS网络发送消息，但我一直在获得错误typeError：无法读取未定义的属性（读取'prublish'）。

错误发生在line node.pubsub.publish（topic，msg，（err）=＆gt; {}）。

ipfs.js是应用程序的主引擎，并包含与IPFS网络交互所需的方法。

“ sendnewmsg”方法用于将消息发送到主题中，其他同行可以在其中订阅和读取消息。

index.js调用并执行该方法。

您能帮我解决问题吗？

提前致谢！

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};

index.js：

const {IPFSEngine} = require('./ipfs');

const ipfs = new IPFSEngine();

ipfs.sendNewMsg(`topic2`,`Messages 2 ..!`)

Answer 1

该错误指出，当您尝试访问对象上的Publish属性时，node.pubsub是不确定的。

快速阅读，看来ipfs.create是一种异步API，结果您不在等待。它可以解释为什么您会在节点上获得未定义的pubsub属性。

使用异步函数，您可以编写类似的内容：

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}`);
  });
}

或不带异步/等待语法：

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}`);
    });
  })
}