allow values with errors for error proof purposes

index.js

@@ -154,7 +154,9 @@ class DHT extends EventEmitter {
 
     function reply (err, value) {
       const closerNodes = nodes.encode(self.bucket.closest(message.target, 20))
-      if (err) return self._io.error(message, err, closerNodes, peer)
+      if (err) {
+        return self._io.error(message, err, closerNodes, peer, value && cmd.outputEncoding.encode(value))
+      }
       self._io.response(message, value && cmd.outputEncoding.encode(value), closerNodes, peer)
     }
   }

lib/io.js

@@ -231,15 +231,15 @@ class IO {
     this.send(Message.encode(message), peer)
   }
 
-  error (request, error, closerNodes, peer) {
+  error (request, error, closerNodes, peer, value) {
     const message = {
       type: TYPE.RESPONSE,
       rid: request.rid,
       id: this.id,
       closerNodes,
-      error: error.message
+      error: error.message,
+      value: value
     }
-
     this.send(Message.encode(message), peer)
   }
 

lib/query-stream.js

@@ -84,7 +84,9 @@ class QueryStream extends Readable {
     }
 
     if (message.error) {
-      this.emit('warning', new Error(message.error))
+      const { value } = message
+      const proof = value && this._decodeOutput(value)
+      this.emit('warning', new Error(message.error), proof)
       this._readMaybe()
       return
     }