fix: use new js-waku API

eth-pm/src/App.tsx

@@ -163,15 +163,12 @@ function App() {
     if (!waku) return;
 
     const interval = setInterval(async () => {
-      let lightPushPeers = 0;
+      const lightPushPeers = await waku.store.peers();
-      // eslint-disable-next-line @typescript-eslint/no-unused-vars
+      const relayPeers = waku.relay.getMeshPeers();
-      for await (const _peer of waku.store.peers) {
-        lightPushPeers++;
-      }
 
       setPeerStats({
-        relayPeers: waku.relay.getPeers().size,
+        relayPeers: relayPeers.length,
-        lightPushPeers,
+        lightPushPeers: lightPushPeers.length,
       });
     }, 1000);
     return () => clearInterval(interval);

eth-pm/src/messaging/SendMessage.tsx

@@ -133,7 +133,7 @@ function sendMessage(
         .push(msg)
         .then((res) => {
           console.log("Message sent", res);
-          callback(res ? res.isSuccess : false);
+          callback(res?.isSuccess ?? false);
         })
         .catch((e) => {
           console.error("Failed to send message", e);

eth-pm/src/waku.ts

@@ -4,12 +4,13 @@ import { PrivateMessage, PublicKeyMessage } from "./messaging/wire";
 import { validatePublicKeyMessage } from "./crypto";
 import { Message } from "./messaging/Messages";
 import { equals } from "uint8arrays/equals";
+import { createWaku } from "js-waku/lib/create_waku";
 
 export const PublicKeyContentTopic = "/eth-pm/1/public-key/proto";
 export const PrivateMessageContentTopic = "/eth-pm/1/private-message/proto";
 
 export async function initWaku(): Promise<Waku> {
-  const waku = await Waku.create({ bootstrap: { default: true } });
+  const waku = await createWaku({ defaultBootstrap: true });
 
   // Wait to be connected to at least one peer
   await new Promise((resolve, reject) => {
@@ -17,7 +18,7 @@ export async function initWaku(): Promise<Waku> {
     // As we are not implementing connection management in this example
 
     setTimeout(reject, 10000);
-    waku.libp2p.connectionManager.on("peer:connect", () => {
+    waku.libp2p.connectionManager.addEventListener("peer:connect", () => {
       resolve(null);
     });
   });