DropConn = proc (peer: PubSubPeer) {....gcsafe, raises: [Defect].}

GetConn = proc (): Future[Connection] {....gcsafe, raises: [Defect].}

OnEvent = proc (peer: PubSubPeer; event: PubSubPeerEvent) {....gcsafe,
    raises: [Defect].}

PubSubObserver = ref object
  onRecv*: proc (peer: PubSubPeer; msgs: var RPCMsg) {....gcsafe, raises: [Defect].}
  onSend*: proc (peer: PubSubPeer; msgs: var RPCMsg) {....gcsafe, raises: [Defect].}

PubSubPeer = ref object of RootObj
  getConn*: GetConn
  onEvent*: OnEvent
  codec*: string
  sendConn*: Connection
  address*: Option[MultiAddress]
  peerId*: PeerId
  handler*: RPCHandler
  observers*: ref seq[PubSubObserver]
  score*: float64
  iWantBudget*: int
  iHaveBudget*: int
  maxMessageSize: int
  appScore*: float64
  behaviourPenalty*: float64
  when defined(libp2p_agents_metrics):
      shortAgent*: string

  

PubSubPeerEvent = object
  kind*: PubSubPeerEventKind

PubSubPeerEventKind {.pure.} = enum
  Connected, Disconnected

RPCHandler = proc (peer: PubSubPeer; msg: RPCMsg): Future[void] {....gcsafe,
    raises: [Defect].}

func `==`(a, b: PubSubPeer): bool {....raises: [], tags: [].}

proc connect(p: PubSubPeer) {....raises: [], tags: [RootEffect].}

proc connected(p: PubSubPeer): bool {....raises: [], tags: [].}

proc handle(p: PubSubPeer; conn: Connection): Future[void] {.stackTrace: false,
    ...gcsafe, raises: [], raises: [], tags: [RootEffect].}

func hash(p: PubSubPeer): Hash {....raises: [], tags: [].}

proc hasObservers(p: PubSubPeer): bool {....raises: [], tags: [].}

proc new(T: typedesc[PubSubPeer]; peerId: PeerId; getConn: GetConn;
         onEvent: OnEvent; codec: string; maxMessageSize: int): T:type {.
    ...raises: [].}

func outbound(p: PubSubPeer): bool {....raises: [], tags: [].}

proc send(p: PubSubPeer; msg: RPCMsg; anonymize: bool) {....raises: [Defect],
    raises: [], tags: [RootEffect, WriteIOEffect, TimeEffect].}

proc sendEncoded(p: PubSubPeer; msg: seq[byte]) {....raises: [Defect], raises: [],
    tags: [WriteIOEffect, TimeEffect, RootEffect].}

func shortLog(p: PubSubPeer): string {....raises: [], tags: [].}

template formatItIMPL(it: PubSubPeer): auto