feat: Add offset/length arguments to files.cat

Author: achingbrain

package.json

@@ -36,7 +36,7 @@
     "ipfs-block": "~0.7.1",
     "ipfs-unixfs": "~0.1.14",
     "ipld-dag-cbor": "^0.12.0",
-    "ipld-dag-pb": "^0.14.2",
+    "ipld-dag-pb": "^0.14.3",
     "is-ipfs": "^0.3.2",
     "is-stream": "^1.1.0",
     "libp2p-crypto": "^0.13.0",
@@ -77,9 +77,9 @@
     "go-ipfs-dep": "^0.4.14",
     "gulp": "^3.9.1",
     "hapi": "^17.3.1",
-    "interface-ipfs-core": "~0.61.0",
+    "interface-ipfs-core": "^0.64.0",
     "ipfs": "~0.28.2",
-    "ipfsd-ctl": "~0.32.0",
+    "ipfsd-ctl": "^0.32.1",
     "pre-commit": "^1.2.2",
     "pull-stream": "^3.6.7",
     "socket.io": "^2.1.0",

src/files/cat-pull-stream.js

@@ -19,7 +19,12 @@ module.exports = (send) => {
       }
     }
 
-    send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
+    const query = {
+      offset: opts.offset,
+      length: opts.length
+    }
+
+    send({ path: 'cat', args: hash, buffer: opts.buffer, qs: query }, (err, stream) => {
       if (err) { return p.end(err) }
 
       p.resolve(toPull(stream))

src/files/cat-readable-stream.js

@@ -19,7 +19,12 @@ module.exports = (send) => {
       }
     }
 
-    send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
+    const query = {
+      offset: opts.offset,
+      length: opts.length
+    }
+
+    send({ path: 'cat', args: hash, buffer: opts.buffer, qs: query }, (err, stream) => {
       if (err) { return pt.destroy(err) }
 
       pump(stream, pt)

src/files/cat.js

@@ -20,7 +20,12 @@ module.exports = (send) => {
       }
     }
 
-    send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
+    const query = {
+      offset: opts.offset,
+      length: opts.length
+    }
+
+    send({ path: 'cat', args: hash, buffer: opts.buffer, qs: query }, (err, stream) => {
       if (err) { return callback(err) }
 
       stream.pipe(bl((err, data) => {