1

我正在尝试使用 pusher 和 MongoDB 实现聊天功能。

我复制了从推送器创建我的应用程序后生成的appId、key和直接。secretcluster

const pusher = new Pusher({
  appId: "correctId which i got",
  key: "correct Key which i got",
  secret: "correct secret",
  cluster: "ap2",
  useTLS: true,
});

我住在印度，所以我猜 ap2 集群也是正确的。

这是我的触发请求：

db.once("open", () => {
  console.log("db is connected");

  const msgCollection = db.collection("messagecontents");
  const changeStream = msgCollection.watch();

  changeStream.on("change", (change) => {
    console.log("a change occured", change);

    if (change.operationType === "insert") {
      const messageDetails = change.fullDocument;
      pusher.trigger("messages", "inserted", {
        name: messageDetails.name,
        message: messageDetails.message,
      });
    } else {
      console.log("error triggering pusher");
    }
  });
});

我的控制台日志正确显示了更改，但我的 Pusher 调试控制台没有显示任何内容：

我的调试控制台截图图像

感谢您提前提供任何帮助

4

0 回答 0