From 0c3e7667f3c87f13a3fc998d0baa66a7e6ee014c Mon Sep 17 00:00:00 2001
From: Hayden Young <haydenyoung@wijiti.com>
Date: Wed, 11 Oct 2023 23:03:22 +0100
Subject: [PATCH] chore: Catch heads iterator errors.

---
 src/sync.js | 18 +++++++++++++-----
 1 file changed, 13 insertions(+), 5 deletions(-)

diff --git a/src/sync.js b/src/sync.js
index 9123011..c644edb 100644
--- a/src/sync.js
+++ b/src/sync.js
@@ -142,15 +142,23 @@ const Sync = async ({ ipfs, log, events, onSynced, start, timeout }) => {
   let started = false
 
   const onPeerJoined = async (peerId) => {
-    const heads = await log.heads()
-    events.emit('join', peerId, heads)
+    try {
+      const heads = await log.heads()
+      events.emit('join', peerId, heads)
+    } catch (err) {
+      console.log('onPeerJoined', ipfs.libp2p.peerId.toString()) 
+    }
   }
 
   const sendHeads = async (source) => {
     return (async function * () {
-      const heads = await log.heads()
-      for await (const { bytes } of heads) {
-        yield bytes
+      try {
+        const heads = await log.heads()
+        for await (const { bytes } of heads) {
+          yield bytes
+        }
+      } catch (err) {
+        console.log('onPeerJoined', ipfs.libp2p.peerId.toString()) 
       }
     })()
   }