FloodSub {.public.} = ref object of PubSub
  floodsub*: PeerTable
  seen*: TimedCache[SaltedId]
  seenSalt*: sha256

FloodSubCodec = "/floodsub/1.0.0"

proc addSeen(f: FloodSub; saltedId: SaltedId): bool {....raises: [], tags: [].}

proc firstSeen(f: FloodSub; saltedId: SaltedId): Moment {....raises: [], tags: [].}

proc hasSeen(f: FloodSub; saltedId: SaltedId): bool {....raises: [], tags: [].}

proc salt(f: FloodSub; msgId: MessageId): SaltedId {....raises: [], tags: [].}

method init(f: FloodSub) {....raises: [], tags: [RootEffect].}

method initPubSub(f: FloodSub) {....raises: [InitializationError], raises: [],
                                 tags: [RootEffect].}

method publish(f: FloodSub; topic: string; data: seq[byte]): Future[int] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}

method rpcHandler(f: FloodSub; peer: PubSubPeer; data: seq[byte]): Future[void] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}

method unsubscribePeer(f: FloodSub; peer: PeerId) {....raises: [],
    tags: [WriteIOEffect, TimeEffect].}