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
@@ -200,18 +200,6 @@ module.exports = (common) => {
           })
         })
 
-        it('with a multihash', (done) => {
-          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
-              expect(data.toString()).to.contain('Check out some of the other files in this directory:')
-              done()
-            }))
-          })
-        })
-
         it('streams a large file', (done) => {
           const hash = 'Qme79tX2bViL26vNjPsF3DP1R9rMKMvnPYJiKTTKPrXJjq'
           ipfs.cat(hash, (err, stream) => {
@@ -222,6 +210,15 @@ module.exports = (common) => {
               done()
             }))
           })
+
+      it('with a multihash', (done) => {
+        const mhBuf = new Buffer(bs58.decode('QmPZ9gcCEpqKTo6aq61g2nXGUhM4iCL3ewB6LDXZCtioEB'))
+        ipfs.cat(mhBuf, (err, stream) => {
+          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()
+          }))
         })
       })
     })
@@ -249,8 +246,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()
               }))
@@ -281,8 +277,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()
               }))
@@ -293,5 +288,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()
+            })
+        })
+      })
+    })
   })
 }