feat: Add offset/length arguments to files.cat

package.json

@@ -42,7 +42,7 @@
     "is-stream": "^1.1.0",
     "libp2p-crypto": "^0.13.0",
     "lru-cache": "^4.1.2",
-    "multiaddr": "^4.0.0",
+    "multiaddr": "^5.0.0",
     "multibase": "~0.4.0",
     "multihashes": "~0.4.13",
     "ndjson": "^1.5.0",
@@ -79,7 +79,7 @@
     "go-ipfs-dep": "^0.4.14",
     "gulp": "^3.9.1",
     "hapi": "^17.3.1",
-    "interface-ipfs-core": "~0.64.0",
+    "interface-ipfs-core": "~0.64.2",
     "ipfs": "~0.28.2",
     "ipfsd-ctl": "~0.32.1",
     "pre-commit": "^1.2.2",

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) => {