Simple node.js pass-through stream (RW) which calculates the a crypto digest (sha/md5 hash) of a stream and also the length. Pipe your stream through this to get digest and length. (streams2)
npm install digest-stream
Provide a the digest algorithm, optional input encoding, digest encoding, and a listener function when you construct the stream. The listener will be called with the resultant digest and length of the stream just prior to end being emitted.
Since this uses the node.js crypto package, refer to http://nodejs.org/api/crypto.html for the specific options available.
digestStream(algorithm, [inputEncoding,] digestEncoding, [options], listenerFn)
- constructs a new stream instance, the listenerFn will be called prior to theend
event being emitted.inputEncoding
is optional and defaults tobinary
if not provided.options
- optional streams optionslistenerFn
function signature isfn(digest, dataLength)
-digest
is the digest for the stream data in the digest encoding format specified when instance was created.dataLength
is the length of the data in the stream (provided for convenience). If listenerFn returns an object that is an instance of Error, then the error will be signaled in the stream.
var digestStream = require('digest-stream');
var digest;
var dataLength;
function listenerFn(resultDigest, length) {
digest = resultDigest;
dataLength = length;
}
var dstream = digestStream('sha1', 'hex', listenerFn); // create instance
readstream
.pipe(dstream) // digest and length calculated as it passes through
.pipe(...)
- Easy to use pass-through stream which calculates the digest and length of string or Buffer streamlength of the string
- Builds on pass-stream to have all the normal pass-through functionality for a spec compliant stream
- works with node 0.10+ streams2 but is also compatible with 0.8
By making this simple pass-through stream which calculates the digest and length of a stream, it becomes really easy to add this functionality to a streaming workflow, just by piping it through this stream, the digest and length will be available prior to end
being fired.
- v1.0.0 - listenerFn can return an instance of Error and it will be signaled to the stream
If you have input or ideas or would like to get involved, you may:
- contact me via twitter @jeffbski - http://twitter.com/jeffbski
- open an issue on github to begin a discussion - https://github.com/jeffbski/digest-stream/issues
- fork the repo and send a pull request (ideally with tests) - https://github.com/jeffbski/digest-stream