add tests for refs endpoint

src/files-regular/index.js

@@ -17,7 +17,13 @@ const tests = {
   getPullStream: require('./get-pull-stream'),
   ls: require('./ls'),
   lsReadableStream: require('./ls-readable-stream'),
-  lsPullStream: require('./ls-pull-stream')
+  lsPullStream: require('./ls-pull-stream'),
+  refs: require('./refs'),
+  refsReadableStream: require('./refs-readable-stream'),
+  refsPullStream: require('./refs-pull-stream'),
+  refsLocal: require('./refs-local'),
+  refsLocalPullStream: require('./refs-local-pull-stream'),
+  refsLocalReadableStream: require('./refs-local-readable-stream')
 }
 
 module.exports = createSuite(tests)

src/files-regular/refs-local-pull-stream.js

@@ -0,0 +1,14 @@
+/* eslint-env mocha */
+'use strict'
+
+const pull = require('pull-stream')
+
+module.exports = (createCommon, options) => {
+  const ipfsRefsLocal = (ipfs) => {
+    return (cb) => {
+      const stream = ipfs.refs.localPullStream()
+      pull(stream, pull.collect(cb))
+    }
+  }
+  require('./refs-local-tests')(createCommon, '.refs.localPullStream', ipfsRefsLocal, options)
+}

src/files-regular/refs-local-readable-stream.js

@@ -0,0 +1,15 @@
+/* eslint-env mocha */
+'use strict'
+
+const concat = require('concat-stream')
+
+module.exports = (createCommon, options) => {
+  const ipfsRefsLocal = (ipfs) => {
+    return (cb) => {
+      const stream = ipfs.refs.localReadableStream()
+      stream.on('error', cb)
+      stream.pipe(concat((refs) => cb(null, refs)))
+    }
+  }
+  require('./refs-local-tests')(createCommon, '.refs.localReadableStream', ipfsRefsLocal, options)
+}

src/files-regular/refs-local-tests.js

@@ -0,0 +1,60 @@
+/* eslint-env mocha */
+'use strict'
+
+const { fixtures } = require('./utils')
+const { getDescribe, getIt, expect } = require('../utils/mocha')
+
+module.exports = (createCommon, suiteName, ipfsRefsLocal, options) => {
+  const describe = getDescribe(options)
+  const it = getIt(options)
+  const common = createCommon()
+
+  describe(suiteName, function () {
+    this.timeout(40 * 1000)
+
+    let ipfs
+
+    before(function (done) {
+      // CI takes longer to instantiate the daemon, so we need to increase the
+      // timeout for the before step
+      this.timeout(60 * 1000)
+
+      common.setup((err, factory) => {
+        expect(err).to.not.exist()
+        factory.spawnNode((err, node) => {
+          expect(err).to.not.exist()
+          ipfs = node
+          done()
+        })
+      })
+    })
+
+    after((done) => common.teardown(done))
+
+    it('should get local refs', function (done) {
+      const content = (name) => ({
+        path: `test-folder/${name}`,
+        content: fixtures.directory.files[name]
+      })
+
+      const dirs = [
+        content('pp.txt'),
+        content('holmes.txt')
+      ]
+
+      ipfs.add(dirs, (err, res) => {
+        expect(err).to.not.exist()
+
+        ipfsRefsLocal(ipfs)((err, refs) => {
+          expect(err).to.not.exist()
+
+          const cids = refs.map(r => r.Ref)
+          expect(cids.includes('QmVwdDCY4SPGVFnNCiZnX5CtzwWDn6kAM98JXzKxE3kCmn')).to.eql(true)
+          expect(cids.includes('QmR4nFjTu18TyANgC65ArNWp5Yaab1gPzQ4D8zp7Kx3vhr')).to.eql(true)
+
+          done()
+        })
+      })
+    })
+  })
+}

src/files-regular/refs-local.js

@@ -0,0 +1,7 @@
+/* eslint-env mocha */
+'use strict'
+
+module.exports = (createCommon, options) => {
+  const ipfsRefsLocal = (ipfs) => (cb) => ipfs.refs.local(cb)
+  require('./refs-local-tests')(createCommon, '.refs.local', ipfsRefsLocal, options)
+}

src/files-regular/refs-pull-stream.js

@@ -0,0 +1,14 @@
+/* eslint-env mocha */
+'use strict'
+
+const pull = require('pull-stream')
+
+module.exports = (createCommon, options) => {
+  const ipfsRefs = (ipfs) => {
+    return (path, params, cb) => {
+      const stream = ipfs.refsPullStream(path, params)
+      pull(stream, pull.collect(cb))
+    }
+  }
+  require('./refs-tests')(createCommon, '.refsPullStream', ipfsRefs, options)
+}

src/files-regular/refs-readable-stream.js

@@ -0,0 +1,15 @@
+/* eslint-env mocha */
+'use strict'
+
+const concat = require('concat-stream')
+
+module.exports = (createCommon, options) => {
+  const ipfsRefs = (ipfs) => {
+    return (path, params, cb) => {
+      const stream = ipfs.refsReadableStream(path, params)
+      stream.on('error', cb)
+      stream.pipe(concat((refs) => cb(null, refs)))
+    }
+  }
+  require('./refs-tests')(createCommon, '.refsReadableStream', ipfsRefs, options)
+}