Files: add unlink files

ipfs · Nov 22, 2017 · a1b61ad · a1b61ad
1 parent 71faa92
commit a1b61ad
Showing 1 changed file with 18 additions and 1 deletion.
diff --git a/src/core/components/files.js b/src/core/components/files.js
@@ -282,5 +282,22 @@ module.exports = function files (self) {
     },
 
     lsPullStreamImmutable: _lsPullStreamImmutable
-  }
+  },
+
+  unlink: promisify((ipfsPath, callback) => {
+    const cid = new CID(ipfsPath)
+    self._ipldResolver.get(cid, (err, node) => {
+      if (err) {
+        return callback(err)
+      }
+      pull(
+        pull.values(node.value.links),
+        pull.drain(
+          link => self._ipldResolver.bs.delete(new CID(link.multihash)),
+          () => self._ipldResolver.bs.delete(cid, callback)
+        )
+      )
+    })
+  })
+
 }