From 2eccb41cf14efb7d5f941389a6833b71c36902fb Mon Sep 17 00:00:00 2001
From: Paul Brossier <piem@piem.org>
Date: Fri, 3 Feb 2017 12:02:49 +0100
Subject: [PATCH] examples/filter_source.js: add example, fix aubio_filter
 prototypes

---
 examples/filter_source.js | 65 +++++++++++++++++++++++++++++++++++++++++++++++
 index.js                  |  4 +--
 2 files changed, 67 insertions(+), 2 deletions(-)
 create mode 100644 examples/filter_source.js

diff --git a/examples/filter_source.js b/examples/filter_source.js
new file mode 100644
index 0000000..9e0fbb3
--- /dev/null
+++ b/examples/filter_source.js
@@ -0,0 +1,65 @@
+var aubio = require('../index.js');
+var ref = require('ref');
+
+var filter_source = function(inputfile, outputfile, params) {
+
+    // open input file for reading
+	var source = aubio.new_aubio_source(inputfile, params.samplerate, params.hop_s);
+    try {
+        source.readPointer();
+    } catch (e) {
+        console.log('failed opening ' + path + ' for reading');
+        return;
+    }
+
+    // get the real samplerate of the input file in case 0 was passed as params.samplerate
+    var samplerate = aubio.aubio_source_get_samplerate(source);
+
+    // open output file for writing
+	var sink = aubio.new_aubio_sink(outputfile, samplerate);
+    try {
+        sink.readPointer();
+    } catch (e) {
+        console.log('failed opening ' + path + ' for writing');
+        return;
+    }
+
+    // create filter
+    var filter = aubio.new_aubio_filter_a_weighting(samplerate);
+
+    // start processing
+	var total_frames = 0;
+	var readPtr = ref.alloc('int');
+	var samples = aubio.new_fvec(params.hop_s);
+    while (true) {
+		aubio.aubio_source_do(source, samples, readPtr);
+		aubio.aubio_filter_do(filter, samples);
+        aubio.aubio_sink_do(sink, samples, readPtr.deref());
+        total_frames += readPtr.deref();
+        if (readPtr.deref() != params.hop_s) { break; }
+    }
+	var cur_time = total_frames / samplerate;
+	console.log('read %d seconds (%d frames) from %s', cur_time.toFixed(3),
+            total_frames, inputfile);
+	console.log('wrote filtered version to %s', outputfile);
+
+    // clean up
+    aubio.del_aubio_sink(sink);
+    aubio.del_aubio_source(source);
+}
+
+if (process.argv[2] && process.argv[3]) {
+	var inputfile = process.argv[2];
+	var outputfile = process.argv[3];
+} else {
+  console.error('command line arguments are required.');
+  console.log('usage examples:');
+  console.log('   ' + process.argv[0] + ' ' + process.argv[1] + ' <fileinput.wav> <fileoutput.wav');
+  console.log('   ' + process.argv[0] + ' ' + process.argv[1] + ' <anotherfile.mp3> <fileoutput.wav>');
+  return;
+}
+
+filter_source(inputfile, outputfile, {
+	samplerate: 44100,
+	hop_s : 512,
+});
diff --git a/index.js b/index.js
index 105c7c4..4bc7705 100644
--- a/index.js
+++ b/index.js
@@ -27,9 +27,9 @@ var aubio = ffi.Library('libaubio', {
     "new_aubio_filter_a_weighting": [ "pointer", [ "int" ]],
     "new_aubio_filter_c_weighting": [ "pointer", [ "int" ]],
     // general do
-    "aubio_filter_do": [ "void", [ "pointer" ]],
+    "aubio_filter_do": [ "void", [ "pointer", "pointer" ]],
     // variations
-    "aubio_filter_do_outplace": [ "void", [ "pointer", "pointer" ]],
+    "aubio_filter_do_outplace": [ "void", [ "pointer", "pointer", "pointer" ]],
     "aubio_filter_do_filtfilt": [ "void", [ "pointer", "pointer" ]],
     "aubio_filter_do_reset": [ "void", [ "pointer", "pointer" ]],
     "del_aubio_filter": [ "void", [ "pointer" ]],
-- 
2.11.0