fix: ensure Promise rejections are handled

libp2p · Mar 17, 2019 · 679d71c · 679d71c
1 parent 9059b61
commit 679d71c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/private.js b/src/private.js
@@ -272,16 +272,16 @@ module.exports = (dht) => ({
  // correct ourself
  if (dht._isSelf(v.from)) {
  try {
- return dht._putLocal(key, fixupRec)
+ await dht._putLocal(key, fixupRec)
  } catch (err) {
  dht._log.error('Failed error correcting self', err)
- return
  }
+ return
  }
 
  // send correction
  try {
- return dht._putValueToPeer(key, fixupRec, v.from)
+ await dht._putValueToPeer(key, fixupRec, v.from)
  } catch (err) {
  dht._log.error('Failed error correcting entry', err)
  }