Remove extraneous message size filter

src/constants.js

@@ -34,8 +34,6 @@ exports.K = 20
 // Alpha is the concurrency for asynchronous requests
 exports.ALPHA = 3
 
-exports.maxMessageSize = 2 << 22 // 4MB
-
 exports.defaultRandomWalk = {
  enabled: true,
  queriesPerPeriod: 1,

src/network.js

@@ -186,9 +186,6 @@ async function writeReadMessage (stream, msg) {
  [msg],
  lp.encode(),
  stream,
- utils.itFilter(
- (msg) => msg.length < c.maxMessageSize
- ),
  lp.decode(),
  async source => {
  for await (const chunk of source) {

src/rpc/index.js

@@ -7,7 +7,6 @@ const PeerInfo = require('peer-info')
 const Message = require('../message')
 const handlers = require('./handlers')
 const utils = require('../utils')
-const c = require('../constants')
 
 module.exports = (dht) => {
  const log = utils.logger(dht.peerInfo.id, 'rpc')
@@ -63,16 +62,13 @@ module.exports = (dht) => {
  lp.decode(),
  source => (async function * () {
  for await (const msg of source) {
- // Check message size
- if (msg.length < c.maxMessageSize) {
- // handle the message
- const desMessage = Message.deserialize(msg.slice())
- const res = await handleMessage(peerInfo, desMessage)
+ // handle the message
+ const desMessage = Message.deserialize(msg.slice())
+ const res = await handleMessage(peerInfo, desMessage)
 
- // Not all handlers will return a response
- if (res) {
- yield res.serialize()
- }
+ // Not all handlers will return a response
+ if (res) {
+ yield res.serialize()
  }
  }
  })(),

src/utils.js

@@ -11,16 +11,6 @@ const { Record } = require('libp2p-record')
 const PeerId = require('peer-id')
 const errcode = require('err-code')
 
-exports.itFilter = function (predicate) {
- return source => (async function * () {
- for await (const msg of source) {
- if (predicate(msg)) {
- yield msg
- }
- }
- })()
-}
-
 /**
  * Creates a DHT ID by hashing a given buffer.
  *