Class QueryStore

constructor

• new QueryStore(store: IEventStore): QueryStore

  Parameters

  • store: IEventStore

  Returns QueryStore

queries

queryKeepWarmTimeout

store

StaticQueries

blossomServers

• blossomServers(pubkey: string): Observable<undefined | URL[]>

  Creates a query for a users blossom servers

  Parameters

  • pubkey: string

  Returns Observable<undefined | URL[]>

contacts

• contacts(pubkey: string): Observable<undefined | ProfilePointer[]>

  Creates a ContactsQuery

  Parameters

  • pubkey: string

  Returns Observable<undefined | ProfilePointer[]>

createQuery

• createQuery<T extends unknown, Args extends any[]>(
      queryConstructor: QueryConstructor<T, Args>,
      ...args: Args,
  ): Observable<undefined | T>

  Creates a cached query

  Type Parameters

  • T extends unknown
  • Args extends any[]

  Parameters

  • queryConstructor: QueryConstructor<T, Args>
  • ...args: Args

  Returns Observable<undefined | T>

event

• event(id: string): Observable<undefined | Event>

  Creates a SingleEventQuery

  Parameters

  • id: string

  Returns Observable<undefined | Event>

events

• events(ids: string[]): Observable<undefined | Record<string, Event>>

  Creates a MultipleEventsQuery

  Parameters

  • ids: string[]

  Returns Observable<undefined | Record<string, Event>>

executeQuery

• executeQuery<T extends unknown, Args extends any[]>(
      queryConstructor: QueryConstructor<T, Args>,
      ...args: Args,
  ): Promise<T>

  Creates a query and waits for the next value

  Type Parameters

  • T extends unknown
  • Args extends any[]

  Parameters

  • queryConstructor: QueryConstructor<T, Args>
  • ...args: Args

  Returns Promise<T>

mailboxes

• mailboxes(
      pubkey: string,
  ): Observable<undefined | { inboxes: string[]; outboxes: string[] }>

  Creates a MailboxesQuery

  Parameters

  • pubkey: string

  Returns Observable<undefined | { inboxes: string[]; outboxes: string[] }>

mutes

• mutes(pubkey: string): Observable<undefined | Mutes>

  Creates a MuteQuery

  Parameters

  • pubkey: string

  Returns Observable<undefined | Mutes>

profile

• profile(pubkey: string): Observable<undefined | ProfileContent>

  Creates a ProfileQuery

  Parameters

  • pubkey: string

  Returns Observable<undefined | ProfileContent>

reactions

• reactions(event: Event): Observable<undefined | Event[]>

  Creates a ReactionsQuery

  Parameters

  • event: Event

  Returns Observable<undefined | Event[]>

replaceable

• replaceable(
      kind: number,
      pubkey: string,
      d?: string,
  ): Observable<undefined | Event>

  Creates a ReplaceableQuery

  Parameters

  • kind: number
  • pubkey: string
  • Optionald: string

  Returns Observable<undefined | Event>

replaceableSet

• replaceableSet(
      pointers: { identifier?: string; kind: number; pubkey: string }[],
  ): Observable<undefined | Record<string, Event>>

  Creates a ReplaceableSetQuery

  Parameters

  • pointers: { identifier?: string; kind: number; pubkey: string }[]

  Returns Observable<undefined | Record<string, Event>>

thread

• thread(
      root: string | EventPointer | AddressPointer,
  ): Observable<undefined | Thread>

  Creates a ThreadQuery

  Parameters

  • root: string | EventPointer | AddressPointer

  Returns Observable<undefined | Thread>

timeline

• timeline(
      filters: Filter | Filter[],
      keepOldVersions?: boolean,
  ): Observable<undefined | Event[]>

  Creates a TimelineQuery

  Parameters

  • filters: Filter | Filter[]
  • OptionalkeepOldVersions: boolean

  Returns Observable<undefined | Event[]>