Merge pull request #8 from futpib/stream

Add stream support

Author: parshap

README.md

@@ -40,7 +40,9 @@ fpcalc("./audio.mp3", function(err, result) {
 
 Calculates the fingerprint of the given audio file.
 
-*File* must be the path to an audio file.
+*File* must be the path to an audio file or a readable stream.
+
+If using a stream, note that you will not get `duration` out due to an [fpcalc issue](https://github.com/acoustid/chromaprint/issues/53).
 
 *Options* may be an object with any of the following keys:
 

index.js

@@ -26,7 +26,12 @@ module.exports = function(file, options, callback) {
 args.push("-raw");
 }
 
-args.push(file);
+if (file && typeof file.pipe === "function") {
+args.push("-");
+options.stdin = file;
+} else {
+args.push(file);
+}
 
 run(args, options)
 .on("error", callback)
@@ -71,6 +76,11 @@ function run(args, options) {
 // event so that we can make sure the process exited without error.
 stream = es.through(null, function() {});
 
+// If passed stdin stream, pipe it to the child process
+if (options.stdin) {
+options.stdin.pipe(cp.stdin);
+}
+
 // Pass fpcalc stdout through the stream
 cp.stdout.pipe(stream);
 

test/test.js

@@ -2,6 +2,7 @@
 "use strict";
 
 var path = require("path"),
+fs = require("fs"),
 test = require("tape"),
 fpcalc = require("../");
 
@@ -52,3 +53,28 @@ test("fingerprint output", function(t) {
 t.ok(/^[-_a-zA-Z0-9]+$/.test(result.fingerprint));
 });
 });
+
+test("stream input", function(t) {
+t.plan(5);
+
+fpcalc(fs.createReadStream(TEST_FILE), {raw: true}, function(err, result) {
+t.ok(result.fingerprint);
+t.ok(Buffer.isBuffer(result.fingerprint));
+});
+
+fpcalc(fs.createReadStream(TEST_FILE), function(err, result) {
+t.ok(result.fingerprint);
+t.equal(typeof result.fingerprint, "string");
+t.ok(/^[-_a-zA-Z0-9]+$/.test(result.fingerprint));
+});
+});
+
+test("stream fignerprint is the same as file fingerprint", function(t) {
+t.plan(1);
+
+fpcalc(fs.createReadStream(TEST_FILE), function(err, streamResult) {
+fpcalc(TEST_FILE, function(err, fileResult) {
+t.equal(fileResult.fingerprint, streamResult.fingerprint);
+});
+});
+});