feat: Add offset/length arguments to files.cat

ipfs-inactive · Apr 24, 2018 · 17967c1 · 17967c1
1 parent 1f889d3
commit 17967c1
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 3 deletions.
diff --git a/src/files/cat-pull-stream.js b/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))

diff --git a/src/files/cat-readable-stream.js b/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)

diff --git a/src/files/cat.js b/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) => {