Add ipfs.files.get tests.

Author: hackergrrl

package.json

@@ -28,9 +28,9 @@
   },
   "homepage": "https://github.com/ipfs/interface-ipfs-core#readme",
   "dependencies": {
-    "bl": "^1.1.2",
     "bs58": "^3.0.0",
     "chai": "^3.5.0",
+    "concat-stream": "^1.5.1",
     "detect-node": "^2.0.3",
     "ipfs-merkle-dag": "^0.6.0",
     "readable-stream": "1.1.13"

src/files.js

@@ -7,10 +7,10 @@ const Readable = require('readable-stream')
 const path = require('path')
 const fs = require('fs')
 const isNode = require('detect-node')
-const bl = require('bl')
+const concat = require('concat-stream')
 
 module.exports = (common) => {
-  describe('.files', () => {
+  describe.only('.files', () => {
     let smallFile
     let bigFile
     let ipfs
@@ -209,8 +209,7 @@ module.exports = (common) => {
         const hash = 'QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB'
         ipfs.cat(hash, (err, stream) => {
           expect(err).to.not.exist
-          stream.pipe(bl((err, data) => {
-            expect(err).to.not.exist
+          stream.pipe(concat((data) => {
             expect(data.toString()).to.contain('Check out some of the other files in this directory:')
             done()
           }))
@@ -221,8 +220,7 @@ module.exports = (common) => {
         const mhBuf = new Buffer(bs58.decode('QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB'))
         ipfs.cat(mhBuf, (err, stream) => {
           expect(err).to.not.exist
-          stream.pipe(bl((err, data) => {
-            expect(err).to.not.exist
+          stream.pipe(concat((data) => {
             expect(data.toString()).to.contain('Check out some of the other files in this directory:')
             done()
           }))
@@ -233,8 +231,7 @@ module.exports = (common) => {
         const hash = 'Qme79tX2bViL26vNjPsF3DP1R9rMKMvnPYJiKTTKPrXJjq'
         ipfs.cat(hash, (err, stream) => {
           expect(err).to.not.exist
-          stream.pipe(bl((err, data) => {
-            expect(err).to.not.exist
+          stream.pipe(concat((data) => {
             expect(data).to.deep.equal(bigFile)
             done()
           }))
@@ -246,8 +243,7 @@ module.exports = (common) => {
           const hash = 'QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB'
           ipfs.cat(hash)
             .then((stream) => {
-              stream.pipe(bl((err, data) => {
-                expect(err).to.not.exist
+              stream.pipe(concat((data) => {
                 expect(data.toString()).to.contain('Check out some of the other files in this directory:')
                 done()
               }))
@@ -278,8 +274,7 @@ module.exports = (common) => {
           const hash = new Buffer(bs58.decode('QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB'))
           ipfs.cat(hash)
             .then((stream) => {
-              stream.pipe(bl((err, bldata) => {
-                expect(err).to.not.exist
+              stream.pipe(concat((bldata) => {
                 expect(bldata.toString()).to.contain('Check out some of the other files in this directory:')
                 done()
               }))
@@ -290,5 +285,91 @@ module.exports = (common) => {
         })
       })
     })
+
+    describe('.get', () => {
+      it('with a base58 encoded multihash', (done) => {
+        const hash = 'QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB'
+        ipfs.files.get(hash, (err, stream) => {
+          expect(err).to.not.exist
+          stream.pipe(concat((files) => {
+            expect(err).to.not.exist
+            expect(files).to.be.length(1)
+            expect(files[0].path).to.equal(hash)
+            files[0].content.pipe(concat((content) => {
+              expect(content.toString()).to.contain('Check out some of the other files in this directory:')
+              done()
+            }))
+          }))
+        })
+      })
+
+      it('with a multihash', (done) => {
+        const hash = 'QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB'
+        const mhBuf = new Buffer(bs58.decode(hash))
+        ipfs.files.get(mhBuf, (err, stream) => {
+          expect(err).to.not.exist
+          stream.pipe(concat((files) => {
+            expect(files).to.be.length(1)
+            expect(files[0].path).to.deep.equal(mhBuf)
+            files[0].content.pipe(concat((content) => {
+              expect(content.toString()).to.contain('Check out some of the other files in this directory:')
+              done()
+            }))
+          }))
+        })
+      })
+
+      it('large file', (done) => {
+        const hash = 'Qme79tX2bViL26vNjPsF3DP1R9rMKMvnPYJiKTTKPrXJjq'
+        ipfs.files.get(hash, (err, stream) => {
+          expect(err).to.not.exist
+          stream.pipe(concat((files) => {
+            expect(files).to.be.length(1)
+            expect(files[0].path).to.equal(hash)
+            files[0].content.pipe(concat((content) => {
+              expect(content).to.deep.equal(bigFile)
+              done()
+            }))
+          }))
+        })
+      })
+
+      describe('promise', () => {
+        it('with a base58 encoded string', (done) => {
+          const hash = 'QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB'
+          ipfs.files.get(hash)
+            .then((stream) => {
+              stream.pipe(concat((files) => {
+                expect(files).to.be.length(1)
+                expect(files[0].path).to.equal(hash)
+                files[0].content.pipe(concat((content) => {
+                  expect(content.toString()).to.contain('Check out some of the other files in this directory:')
+                  done()
+                }))
+              }))
+            })
+            .catch((err) => {
+              expect(err).to.not.exist
+            })
+        })
+
+        it('errors on invalid key', (done) => {
+          const hash = 'somethingNotMultihash'
+          ipfs.files.get(hash)
+            .then((stream) => {})
+            .catch((err) => {
+              expect(err).to.exist
+              const errString = err.toString()
+              if (errString === 'Error: invalid ipfs ref path') {
+                expect(err.toString()).to.contain('Error: invalid ipfs ref path')
+              }
+              if (errString === 'Error: Invalid Key') {
+                expect(err.toString()).to.contain('Error: Invalid Key')
+              }
+              done()
+            })
+        })
+      })
+    })
   })
 }