Class WakuNode

constructor

• new WakuNode(pubsubTopics, options, libp2p, protocolsEnabled, relay?): WakuNode

• Parameters

  • pubsubTopics: string[]
  • options: WakuOptions
  • libp2p: Libp2p
  • protocolsEnabled: ProtocolsEnabled
  • Optional relay: IRelay

  Returns WakuNode

connectionManager

Optional filter

Readonly health

libp2p

Optional lightPush

Readonly pubsubTopics

Optional relay

Optional store

peerId

• get peerId(): PeerId

• Returns a unique identifier for a node on the network.

  Returns PeerId

  Example

  console.log(waku.peerId); // 12D3KooWNmk9yXHfHJ4rUduRqD1TCTHkNFMPF9WP2dqWpZDL4aUb
  Copy

protocols

• get protocols(): string[]

• Returns a list of supported protocols.

  Returns string[]

  Example

  console.log(waku.protocols); // ['/ipfs/id/1.0.0', '/ipfs/ping/1.0.0', '/vac/waku/filter-push/2.0.0-beta1', '/vac/waku/metadata/1.0.0']
  Copy

dial

• dial(peer, protocols?): Promise<Stream>

• Dials to the provided peer

  Parameters

  • peer: PeerId | MultiaddrInput

    information to use for dialing
  • Optional protocols: Protocols[]

    array of Waku protocols to be used for dialing. If no provided - will be derived from mounted protocols.

  Returns Promise<Stream>

  Promise that will resolve to a Stream to a dialed peer

  Example

  await waku.dial(remotePeerId, [Protocols.LightPush]);
  
  waku.isConnected() === true;
  Copy

isConnected

• isConnected(): boolean

• Returns boolean

  true if the node has working connection and false otherwise

isStarted

• isStarted(): boolean

• Returns boolean

  true if the node was started and false otherwise

start

• start(): Promise<void>

• Starts all services and components related to functionality of Waku node.

  Returns Promise<void>

  Promise that will resolve when started.

  Example

  await waku.start();
  
  waku.isStarted() === true;
  Copy

stop

• stop(): Promise<void>

• Stops all recurring processes and services that are needed for functionality of Waku node.

  Returns Promise<void>

  Promise that resolves when stopped.

  Example

  await waku.stop();
  
  waku.isStarted === false;
  Copy

waitForPeers

• waitForPeers(protocols?, timeoutMs?): Promise<void>

• Resolves when Waku successfully gains connection to a remote peers that fits provided requirements. Must be used after attempting to connect to nodes, using IWaku.dial or if was bootstrapped by using IPeerExchange or DnsDiscoveryComponents.

  Parameters

  • Optional protocols: Protocols[]

    Protocols that need to be enabled by remote peers
  • Optional timeoutMs: number

    Timeout value in milliseconds after which promise rejects

  Returns Promise<void>

  Promise that resolves if all desired protocols are fulfilled by at least one remote peer, rejects if the timeoutMs is reached

  Throws

  If passing a protocol that is not mounted or Waku node is not started

  Example

  try {
   // let's wait for at least one LightPush node and timeout in 1 second
   await waku.waitForPeers([Protocols.LightPush], 1000);
  } catch(e) {
   waku.isConnected() === false;
   console.error("Failed to connect due to", e);
  }
  
  waku.isConnected() === true;
  Copy