deps: update protons to 5.1.0 (#364)

Author: achingbrain

package.json

@@ -176,7 +176,7 @@
     "p-defer": "^4.0.0",
     "p-queue": "^7.2.0",
     "private-ip": "^2.3.3",
-    "protons-runtime": "^3.0.1",
+    "protons-runtime": "^3.1.0",
     "timeout-abort-controller": "^3.0.0",
     "uint8arraylist": "^2.0.0",
     "uint8arrays": "^3.0.0",
@@ -200,7 +200,7 @@
     "lodash.random": "^3.2.0",
     "lodash.range": "^3.2.0",
     "p-retry": "^5.0.0",
-    "protons": "^5.0.0",
+    "protons": "^5.1.0",
     "sinon": "^14.0.0",
     "ts-sinon": "^2.0.2",
     "which": "^2.0.2"

src/message/dht.ts

@@ -190,7 +190,9 @@ export namespace Message {
             writer.ldelim()
           }
         }, (reader, length) => {
-          const obj: any = {}
+          const obj: any = {
+            addrs: []
+          }
 
           const end = length == null ? reader.len : reader.pos + length
 
@@ -202,7 +204,6 @@ export namespace Message {
                 obj.id = reader.bytes()
                 break
               case 2:
-                obj.addrs = obj.addrs ?? []
                 obj.addrs.push(reader.bytes())
                 break
               case 3:
@@ -214,12 +215,6 @@ export namespace Message {
             }
           }
 
-          obj.addrs = obj.addrs ?? []
-
-          if (obj.addrs == null) {
-            throw new Error('Protocol error: value for required field "addrs" was not found in protobuf')
-          }
-
           return obj
         })
       }
@@ -287,7 +282,10 @@ export namespace Message {
           writer.ldelim()
         }
       }, (reader, length) => {
-        const obj: any = {}
+        const obj: any = {
+          closerPeers: [],
+          providerPeers: []
+        }
 
         const end = length == null ? reader.len : reader.pos + length
 
@@ -308,11 +306,9 @@ export namespace Message {
               obj.record = reader.bytes()
               break
             case 8:
-              obj.closerPeers = obj.closerPeers ?? []
               obj.closerPeers.push(Message.Peer.codec().decode(reader, reader.uint32()))
               break
             case 9:
-              obj.providerPeers = obj.providerPeers ?? []
               obj.providerPeers.push(Message.Peer.codec().decode(reader, reader.uint32()))
               break
             default:
@@ -321,17 +317,6 @@ export namespace Message {
           }
         }
 
-        obj.closerPeers = obj.closerPeers ?? []
-        obj.providerPeers = obj.providerPeers ?? []
-
-        if (obj.closerPeers == null) {
-          throw new Error('Protocol error: value for required field "closerPeers" was not found in protobuf')
-        }
-
-        if (obj.providerPeers == null) {
-          throw new Error('Protocol error: value for required field "providerPeers" was not found in protobuf')
-        }
-
         return obj
       })
     }