fix(ipfs-core): fix repo gc typing

ipfs · Apr 8, 2021 · 1a96c39 · 1a96c39
1 parent db4d9d1
commit 1a96c39
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/packages/ipfs-core/src/components/repo/gc.js b/packages/ipfs-core/src/components/repo/gc.js
@@ -17,6 +17,7 @@ const BLOCK_RM_CONCURRENCY = 256
  * @typedef {import('ipfs-core-types/src/refs').API} RefsAPI
  * @typedef {import('ipfs-repo')} IPFSRepo
  * @typedef {import('interface-datastore').Key} Key
+ * @typedef {import('ipfs-repo/src/types').Block} Block
  */
 
 /**
@@ -101,7 +102,7 @@ async function createMarkedSet ({ pin, refs, repo }) {
  * @param {object} arg
  * @param {IPFSRepo} arg.repo
  * @param {Set<string>} markedSet
- * @param {AsyncIterable<CID>} blockKeys
+ * @param {AsyncIterable<CID|Block>} blockKeys
  */
 async function * deleteUnmarkedBlocks ({ repo }, markedSet, blockKeys) {
   // Iterate through all blocks and find those that are not in the marked set
@@ -110,12 +111,16 @@ async function * deleteUnmarkedBlocks ({ repo }, markedSet, blockKeys) {
   let removedBlocksCount = 0
 
   /**
-   * @param {CID} cid
+   * @param {Block|CID} cid
    */
   const removeBlock = async (cid) => {
     blocksCount++
 
     try {
+      if (!CID.isCID(cid)) {
+        return null
+      }
+
       const b32 = multibase.encode('base32', cid.multihash).toString()
 
       if (markedSet.has(b32)) {