Class RemoteMonitorRelayLiveness

constructor

• new RemoteMonitorRelayLiveness(
      store: EventStore,
      options: Nip66LivenessOptions,
  ): RemoteMonitorRelayLiveness

  Creates an independently usable monitor-backed liveness source

  Parameters

  • store: EventStore
  • options: Nip66LivenessOptions

  Returns RemoteMonitorRelayLiveness

  Throws

  if monitors, quorum, durations, or the initial report limit are invalid

Readonlyerrors$

Readonlyhealthy$

Readonlyonline$

Readonlyseen

Readonlyunhealthy$

healthy

• get healthy(): string[]

  Gets known relays that are eligible, including unknown observations

  Returns string[]

online

• get online(): string[]

  Gets relays with fresh positive observations

  Returns string[]

unhealthy

• get unhealthy(): string[]

  Gets relays excluded by fresh explicit negative consensus

  Returns string[]

connectToPool

• connectToPool(pool: RelayPool): void

  Subscribes to configured monitor event sources without tracking or probing target connections

  Parameters

  • pool: RelayPool

  Returns void

  Throws

  if this source has been destroyed

destroy

• destroy(): void

  Releases monitor subscriptions, store observers, and expiry timers

  Returns void

disconnectFromPool

• disconnectFromPool(pool: RelayPool): void

  Stops reading monitors from a pool without closing unrelated pool connections

  Parameters

  • pool: RelayPool

  Returns void

filter

• filter(relays: string[]): string[]

  Filters only relays excluded by fresh explicit negative consensus

  Parameters

  • relays: string[]

  Returns string[]

getState

• getState(relay: string): Nip66RelayState

  Gets fresh monitor consensus, returning unknown when no usable evidence exists

  Parameters

  • relay: string

  Returns Nip66RelayState

state

• state(relay: string): Observable<Nip66RelayState>

  Observes monitor consensus for one relay

  Parameters

  • relay: string

  Returns Observable<Nip66RelayState>