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

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

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

PeerRateLimitError = object of CatchableError

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

PubSubPeer = ref object of RootObj
  getConn*: GetConn
  onEvent*: OnEvent
  codec*: string
  sendConn*: Connection
  connectedFut: Future[void]
  address*: Option[MultiAddress]
  peerId*: PeerId
  handler*: RPCHandler
  observers*: ref seq[PubSubObserver]
  score*: float64
  sentIHaves*: Deque[HashSet[MessageId]]
  heDontWants*: Deque[HashSet[MessageId]]
  iHaveBudget*: int
  pingBudget*: int
  maxMessageSize: int
  appScore*: float64
  behaviourPenalty*: float64
  overheadRateLimitOpt*: Opt[TokenBucket]
  rpcmessagequeue: RpcMessageQueue

PubSubPeerEvent = object
  kind*: PubSubPeerEventKind

PubSubPeerEventKind {.pure.} = enum
  Connected, Disconnected

RPCHandler = proc (peer: PubSubPeer; data: seq[byte]): Future[void] {....gcsafe,
    raises: [].}

RpcMessageQueue = ref object
  priorityQueue: AsyncQueue[seq[byte]]
  nonPriorityQueue: AsyncQueue[seq[byte]]
  messageAvailableEvent: AsyncEvent
  queueProcessingTask: Future[void]
  isProcessing: bool

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

proc canAskIWant(p: PubSubPeer; msgId: MessageId): bool {....raises: [], tags: [].}

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

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

proc getAgent(peer: PubSubPeer): string {....raises: [], tags: [].}

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

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

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

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

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

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

proc recvObservers(p: PubSubPeer; msg: var RPCMsg) {....raises: [],
    tags: [RootEffect].}

proc send(p: PubSubPeer; msg: RPCMsg; anonymize: bool;
          isHighPriority: bool = false): Future[void] {.stackTrace: false,
    ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}

proc sendEncoded(p: PubSubPeer; msg: seq[byte]; isHighPriority: bool = false): Future[
    void] {.stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
            tags: [RootEffect].}

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

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

template formatItIMPL(it: PubSubPeer): auto