Class PostgresPeersRepository

constructor

• new PostgresPeersRepository(
      _driver: PostgresStorageDriver,
  ): PostgresPeersRepository

  Parameters

  • _driver: PostgresStorageDriver

  Returns PostgresPeersRepository

Readonly_driver

deleteAll

• deleteAll(): Promise<void>

  Returns Promise<void>

getById

• getById(id: number): Promise<IPeersRepository.PeerInfo | null>

  Find a peer by their id. Should return a "min" peer if one is available.

  Parameters

  • id: number

  Returns Promise<IPeersRepository.PeerInfo | null>

getByPhone

• getByPhone(phone: string): Promise<IPeersRepository.PeerInfo | null>

  Find a peer by their phone. Should never return "min" peers

  Parameters

  • phone: string

  Returns Promise<IPeersRepository.PeerInfo | null>

getByUsername

• getByUsername(username: string): Promise<IPeersRepository.PeerInfo | null>

  Find a peer by their username (where usernames includes username). Should never return "min" peers

  Parameters

  • username: string

  Returns Promise<IPeersRepository.PeerInfo | null>

store

• store(peer: IPeersRepository.PeerInfo): Promise<void>

  Creates or updates a peer row. Unchanged peers are refreshed no more than once every 8h because getByUsername() rejects entries older than 24h.

  Parameters

  • peer: IPeersRepository.PeerInfo

  Returns Promise<void>

  See

  packages/core/src/highlevel/storage/service/peers.ts (PeersService.getByUsername)