Skip to content
This repository has been archived by the owner on Mar 10, 2020. It is now read-only.

Commit

Permalink
fix: set the FileResultStreamConverter explicitly
Browse files Browse the repository at this point in the history
The `SendFilesStream` used to run the `FileResultStreamConverter`
automatically. With making it an option to use a converter,
`SendFilesStream` can be used outside of the Files API, e.g. for
the DAG API.

Closes #696.
  • Loading branch information
vmx authored and daviddias committed Mar 14, 2018
1 parent 54ed260 commit dfad55e
Show file tree
Hide file tree
Showing 8 changed files with 57 additions and 18 deletions.
9 changes: 8 additions & 1 deletion src/files/add-pull-stream.js
Original file line number Diff line number Diff line change
@@ -1,6 +1,13 @@
'use strict'

const SendFilesStream = require('../utils/send-files-stream')
const FileResultStreamConverter = require('../utils/file-result-stream-converter')
const toPull = require('stream-to-pull-stream')

module.exports = (send) => (options) => toPull(SendFilesStream(send, 'add')(options))
module.exports = (send) => {
return (options) => {
options = options || {}
options.converter = FileResultStreamConverter
return toPull(SendFilesStream(send, 'add')(options))
}
}
9 changes: 8 additions & 1 deletion src/files/add-readable-stream.js
Original file line number Diff line number Diff line change
@@ -1,5 +1,12 @@
'use strict'

const SendFilesStream = require('../utils/send-files-stream')
const FileResultStreamConverter = require('../utils/file-result-stream-converter')

module.exports = (send) => SendFilesStream(send, 'add')
module.exports = (send) => {
return (options) => {
options = options || {}
options.converter = FileResultStreamConverter
return SendFilesStream(send, 'add')(options)
}
}
2 changes: 2 additions & 0 deletions src/files/add.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ const ConcatStream = require('concat-stream')
const once = require('once')
const isStream = require('is-stream')
const OtherBuffer = require('buffer').Buffer
const FileResultStreamConverter = require('../utils/file-result-stream-converter')
const SendFilesStream = require('../utils/send-files-stream')

module.exports = (send) => {
Expand All @@ -21,6 +22,7 @@ module.exports = (send) => {
if (!options) {
options = {}
}
options.converter = FileResultStreamConverter

const ok = Buffer.isBuffer(_files) ||
isStream.readable(_files) ||
Expand Down
4 changes: 3 additions & 1 deletion src/files/write.js
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
const promisify = require('promisify-es6')
const concatStream = require('concat-stream')
const once = require('once')
const FileResultStreamConverter = require('../utils/file-result-stream-converter')
const SendFilesStream = require('../utils/send-files-stream')

module.exports = (send) => {
Expand All @@ -28,7 +29,8 @@ module.exports = (send) => {

const options = {
args: pathDst,
qs: opts
qs: opts,
converter: FileResultStreamConverter
}

const stream = sendFilesStream(options)
Expand Down
7 changes: 6 additions & 1 deletion src/util/fs-add.js
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ const isNode = require('detect-node')
const promisify = require('promisify-es6')
const moduleConfig = require('../utils/module-config')
const SendOneFile = require('../utils/send-one-file-multiple-results')
const FileResultStreamConverter = require('../utils/file-result-stream-converter')

module.exports = (arg) => {
const sendOneFile = SendOneFile(moduleConfig(arg), 'add')
Expand Down Expand Up @@ -31,6 +32,10 @@ module.exports = (arg) => {
return callback(new Error('"path" must be a string'))
}

sendOneFile(path, { qs: opts }, callback)
const requestOpts = {
qs: opts,
converter: FileResultStreamConverter
}
sendOneFile(path, requestOpts, callback)
})
}
7 changes: 6 additions & 1 deletion src/util/url-add.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ const parseUrl = require('url').parse
const request = require('../utils/request')
const moduleConfig = require('../utils/module-config')
const SendOneFile = require('../utils/send-one-file-multiple-results')
const FileResultStreamConverter = require('../utils/file-result-stream-converter')

module.exports = (arg) => {
const sendOneFile = SendOneFile(moduleConfig(arg), 'add')
Expand Down Expand Up @@ -49,7 +50,11 @@ const requestWithRedirect = (url, opts, sendOneFile, callback) => {
}
requestWithRedirect(redirection, opts, sendOneFile, callback)
} else {
sendOneFile(res, { qs: opts }, callback)
const requestOpts = {
qs: opts,
converter: FileResultStreamConverter
}
sendOneFile(res, requestOpts, callback)
}
}).end()
}
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ const TransformStream = require('readable-stream').Transform
Transforms a stream of {Name, Hash} objects to include size
of the DAG object.
Usage: inputStream.pipe(new Converter())
Usage: inputStream.pipe(new FileResultStreamConverter())
Input object format:
{
Expand All @@ -22,7 +22,7 @@ const TransformStream = require('readable-stream').Transform
size: 20
}
*/
class ConverterStream extends TransformStream {
class FileResultStreamConverter extends TransformStream {
constructor (options) {
const opts = Object.assign({}, options || {}, { objectMode: true })
super(opts)
Expand All @@ -41,4 +41,4 @@ class ConverterStream extends TransformStream {
}
}

module.exports = ConverterStream
module.exports = FileResultStreamConverter
31 changes: 21 additions & 10 deletions src/utils/send-files-stream.js
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ const isStream = require('is-stream')
const once = require('once')
const prepareFile = require('./prepare-file')
const Multipart = require('./multipart')
const Converter = require('./converter')

function headers (file) {
const name = file.path
Expand Down Expand Up @@ -127,15 +126,27 @@ module.exports = (send, path) => {

response.on('error', (err) => retStream.emit('error', err))

response.on('data', (d) => {
if (d.Bytes && options.progress) {
options.progress(d.Bytes)
}
})
const convertedResponse = new Converter()
convertedResponse.once('end', () => retStream.push(null))
convertedResponse.on('data', (d) => retStream.push(d))
response.pipe(convertedResponse)
if (options.converter) {
response.on('data', (d) => {
if (d.Bytes && options.progress) {
options.progress(d.Bytes)
}
})

const Converter = options.converter
const convertedResponse = new Converter()
convertedResponse.once('end', () => retStream.push(null))
convertedResponse.on('data', (d) => retStream.push(d))
response.pipe(convertedResponse)
} else {
response.on('data', (d) => {
if (d.Bytes && options.progress) {
options.progress(d.Bytes)
}
retStream.push(d)
})
response.once('end', () => retStream.push(null))
}
})

// signal the multipart that the underlying stream has drained and that
Expand Down

0 comments on commit dfad55e

Please sign in to comment.