INNER CODE UNIT · TypeScript

replayAnnouncements

dmotz/trystero · packages/nostr/src/index.ts:308

const replayAnnouncements = (client: SocketClient): void => {
  Object.entries(announcementMessages.forRelay(client)).forEach(
    ([topic, payload]) => {
      void publishMessage(client, topic, payload, true)
    }
  )
}

const publishMessage = async (
  client: SocketClient,
  topic: string,
  payload: string,
  isAnnouncement: boolean
) => {
  if (retiredRelays.has(client) || client.isClosed) {
    return isAnnouncement ? stopAnnouncing : undefined
  }
  const remaining = getRelayBackoffMs(client)

View source record →