get command

Author: nginnever

src/api/get.js

@@ -0,0 +1,24 @@
+'use strict'
+
+module.exports = (send) => {
+  return function get (path, archive, compress, compressionLevel, cb) {
+    if (archive === true && typeof compress === 'function') {
+      cb = compress
+      compressionLevel = null
+      compress = null
+    }
+    if (archive === true && typeof compress === 'number') {
+      archive = null
+      cb = compressionLevel
+      compressionLevel = compress
+      compress = true
+    }
+    if (typeof archive === 'function') {
+      cb = archive
+      archive = null
+      compressionLevel = null
+      compress = null
+    }
+    return send('get', path, [archive, compress, compressionLevel], null, cb)
+  }
+}

src/load-commands.js

@@ -11,6 +11,7 @@ function requireCommands () {
     dht: require('./api/dht'),
     diag: require('./api/diag'),
     id: require('./api/id'),
+    get: require('./api/get'),
     log: require('./api/log'),
     ls: require('./api/ls'),
     mount: require('./api/mount'),

test/api/get.spec.js

@@ -0,0 +1,119 @@
+/* eslint-env mocha */
+/* globals apiClients */
+'use strict'
+
+const expect = require('chai').expect
+const isNode = require('detect-node')
+const fs = require('fs')
+
+const path = require('path')
+const streamEqual = require('stream-equal')
+
+let testfile
+let testfileBig
+
+if (isNode) {
+  testfile = fs.readFileSync(path.join(__dirname, '/../testfile.txt'))
+  testfileBig = fs.createReadStream(path.join(__dirname, '/../15mb.random'), { bufferSize: 128 })
+} else {
+  testfile = require('raw!../testfile.txt')
+}
+
+describe('.get', () => {
+  it('get with no compression args', (done) => {
+    apiClients.a
+      .get('Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP', (err, res) => {
+        expect(err).to.not.exist
+
+        let buf = ''
+        res
+          .on('error', (err) => {
+            expect(err).to.not.exist
+          })
+          .on('data', (data) => {
+            buf += data
+          })
+          .on('end', () => {
+            expect(buf).to.contain(testfile.toString())
+            done()
+          })
+      })
+  })
+
+  it('get with archive true', (done) => {
+    apiClients.a
+      .get('Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP', true, (err, res) => {
+        expect(err).to.not.exist
+
+        let buf = ''
+        res
+          .on('error', (err) => {
+            expect(err).to.not.exist
+          })
+          .on('data', (data) => {
+            buf += data
+          })
+          .on('end', () => {
+            expect(buf).to.contain(testfile.toString())
+            done()
+          })
+      })
+  })
+
+  it('get with compression level', (done) => {
+    apiClients.a
+      .get('Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP', true, 1, (err, res) => {
+        expect(err).to.not.exist
+
+        let buf = ''
+        res
+          .on('error', (err) => {
+            expect(err).to.not.exist
+          })
+          .on('data', (data) => {
+            buf += data
+          })
+          .on('end', () => {
+            expect(buf).to.contain(testfile.toString())
+            done()
+          })
+      })
+  })
+
+  it.skip('get BIG file', (done) => {
+    if (!isNode) {
+      return done()
+    }
+
+    apiClients.a.get('Qme79tX2bViL26vNjPsF3DP1R9rMKMvnPYJiKTTKPrXJjq', (err, res) => {
+      expect(err).to.not.exist
+
+      // Do not blow out the memory of nodejs :)
+      streamEqual(res, testfileBig, (err, equal) => {
+        expect(err).to.not.exist
+        expect(equal).to.be.true
+        done()
+      })
+    })
+  })
+
+  describe('promise', () => {
+    it.skip('get', (done) => {
+      return apiClients.a.get('Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP')
+        .then((res) => {
+          let buf = ''
+          res
+            .on('error', (err) => {
+              throw err
+            })
+            .on('data', (data) => {
+              buf += data
+            })
+            .on('end', () => {
+              expect(buf).to.contain(testfile.toString())
+              done()
+            })
+        })
+    })
+  })
+})