chore: add dht selectors and validators (#94)

Author: vasco-santos

src/pubsub/index.js

@@ -1,8 +1,6 @@
 'use strict'
 
 const debug = require('debug')
-/** @typedef {import('../types').EventEmitterFactory} Events */
-/** @type Events */
 const EventEmitter = require('events')
 const errcode = require('err-code')
 

src/pubsub/peer-streams.js

@@ -4,9 +4,6 @@ const debug = require('debug')
 const log = Object.assign(debug('libp2p-pubsub:peer-streams'), {
   error: debug('libp2p-pubsub:peer-streams:err')
 })
-
-/** @typedef {import('../types').EventEmitterFactory} Events */
-/** @type Events */
 const EventEmitter = require('events')
 
 const lp = require('it-length-prefixed')

src/types.d.ts

@@ -1,18 +1,5 @@
-export interface EventEmitterFactory {
-  new(): EventEmitter;
-}
+export type SelectFn = function (Uint8Array, Uint8Array[]): number
+export type ValidateFn = function (Uint8Array, Uint8Array): Promise<void>
 
-export interface EventEmitter {
-  addListener(event: string | symbol, listener: (...args: any[]) => void): EventEmitter;
-  on(event: string | symbol, listener: (...args: any[]) => void): EventEmitter;
-  once(event: string | symbol, listener: (...args: any[]) => void): EventEmitter;
-  removeListener(event: string | symbol, listener: (...args: any[]) => void): EventEmitter;
-  off(event: string | symbol, listener: (...args: any[]) => void): EventEmitter;
-  removeAllListeners(event?: string | symbol): EventEmitter;
-  setMaxListeners(n: number): EventEmitter;
-  getMaxListeners(): number;
-  listeners(event: string | symbol): Function[]; // eslint-disable-line @typescript-eslint/ban-types
-  rawListeners(event: string | symbol): Function[]; // eslint-disable-line @typescript-eslint/ban-types
-  emit(event: string | symbol, ...args: any[]): boolean;
-  listenerCount(event: string | symbol): number;
-}
+export type DhtSelectors = { [key: string]: SelectFn }
+export type DhtValidators = { [key: string]: { func: ValidateFn } }