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.
  *