From dcf28780b1e5aae0152c567a3de11e3eb7514622 Mon Sep 17 00:00:00 2001
From: Louis-Joseph Fournier <louis-joseph.fournier@parrot.com>
Date: Tue, 5 Jan 2016 15:20:43 +0100
Subject: [PATCH] Worker: use pulseaudio-simple API to get audio

---
 Tuner.pro             |  6 ++-
 harbour-sailtuner.pro |  5 ++-
 src/Tuner.cpp         |  2 +
 src/TunerWorker.cpp   | 86 +++++++++++++++++++++++++++++++++++--------
 src/TunerWorker.hpp   |  1 +
 5 files changed, 81 insertions(+), 19 deletions(-)

diff --git a/Tuner.pro b/Tuner.pro
index ff35621..78915e5 100644
--- a/Tuner.pro
+++ b/Tuner.pro
@@ -1,9 +1,11 @@
 QT += qml quick gui multimedia dbus
 TARGET = Tuner
 
-CONFIG += c++11 debug
+CONFIG += c++11 debug link_pkgconfig
 
-# PKGCONFIG += libpulse
+DEFINES += TARGET=\""$(TARGET")\"
+
+PKGCONFIG += libpulse-simple
 
 SOURCES += \
 	src/desktop.cpp \
diff --git a/harbour-sailtuner.pro b/harbour-sailtuner.pro
index a756127..a17e899 100644
--- a/harbour-sailtuner.pro
+++ b/harbour-sailtuner.pro
@@ -1,10 +1,11 @@
 QT += qml quick gui multimedia dbus
 TARGET = harbour-sailtuner
 
-CONFIG += c++11 sailfishapp sailfishapp_i18n sailfishapp_no_deploy_qml
+CONFIG += c++11 sailfishapp sailfishapp_i18n sailfishapp_no_deploy_qml link_pkgconfig
 
 DEFINES += TARGET=\""$(TARGET")\"
-# PKGCONFIG += libpulse
+
+PKGCONFIG += libpulse
 
 RESOURCES += \
 	qml/sailfish.qrc \
diff --git a/src/Tuner.cpp b/src/Tuner.cpp
index 7c29bdf..2006db1 100644
--- a/src/Tuner.cpp
+++ b/src/Tuner.cpp
@@ -35,6 +35,8 @@ Tuner::Tuner()
 	temperament_idx = 0;
 	la = Scale::defaultLa;
 
+	qRegisterMetaType<PitchDetection::PitchResult>("PitchDetection::PitchResult");
+
 	worker = new TunerWorker();
 
 	worker->moveToThread(&workerThread);
diff --git a/src/TunerWorker.cpp b/src/TunerWorker.cpp
index 8ba181f..daa23bf 100644
--- a/src/TunerWorker.cpp
+++ b/src/TunerWorker.cpp
@@ -20,9 +20,18 @@
 
 #include <iostream>
 #include <fstream>
+#include <stdint.h>
+
+extern "C" {
+#include <pulse/simple.h>
+}
 
 #include "TunerWorker.hpp"
 
+#define name_(x) #x
+#define name(x) name_(x)
+#define NAME name(TARGET)
+
 using namespace std;
 
 /// file name to record audio
@@ -50,6 +59,7 @@ TunerWorker::TunerWorker() :
 	la_to_update(0),
 	temperament_to_update(-1)
 {
+	//qRegisterMetaType<PitchDetection::PitchResult>("PitchDetection::PitchResult");
 }
 
 TunerWorker::~TunerWorker()
@@ -102,6 +112,11 @@ void TunerWorker::Entry()
 
 	int nbSamplePreventRunning = nbSecPreventRunning * PitchDetection::rate;
 	int nb_sample_running = 0;
+	bool new_stream = true;
+
+	int16_t *buffer = new int16_t[nbSampleBuffer];
+
+	PitchDetection::PitchResult result;
 
 	ofstream *file = NULL;
 	if (filename_record) file = new ofstream(filename_record);
@@ -109,6 +124,26 @@ void TunerWorker::Entry()
 	PitchDetection *pitchDetection = new PitchDetection();
 	emit temperamentListUpdated(pitchDetection->GetTemperamentList());
 
+	// pulseaudio
+	pa_simple *p_simple;
+	pa_sample_spec p_spec;
+
+	p_spec.format = PA_SAMPLE_S16NE;
+	p_spec.channels = 1;
+	p_spec.rate = PitchDetection::rate;
+
+	p_simple = pa_simple_new(
+		NULL,
+		NAME,
+		PA_STREAM_RECORD,
+		NULL,
+		"Mic",
+		&p_spec,
+		NULL,
+		NULL,
+		NULL
+	);
+
 	while (1) {
 		// wait for running
 		mutex.lock();
@@ -117,10 +152,7 @@ void TunerWorker::Entry()
 			while (!running && !quit) condition.wait(&mutex);
 			cerr << "wake-up" << endl;
 			// reset operations on start
-			if (!quit) {
-				pitchDetection->Reset();
-				nb_sample_running = 0;
-			}
+			new_stream = true;
 		}
 		if (quit) {
 			mutex.unlock();
@@ -137,26 +169,50 @@ void TunerWorker::Entry()
 		}
 		mutex.unlock();
 
-		// record in file is needed
-		//if (file) file->write((char*) ptr, nb_frame * sizeof(int16_t));
+		// if srteam was stopped, reset analyse
+		if (new_stream) {
+			pitchDetection->Reset();
+			nb_sample_running = 0;
+			// flush audio
+			pa_simple_flush(p_simple, NULL);
+			new_stream = false;
+		}
 
-		std::cout << __func__ << " do job" << std::endl;
+		// get audio data
+		int size = pa_simple_read(p_simple, (void*) buffer, nbSampleBuffer << 1, NULL);
+		if (size < 0) {
+			cerr << "audio read failed " << size << endl;
+			continue;
+		}
+		//cerr << "read " << nb_sample_running << endl;
+
+		// record in file is needed
+		if (file) file->write((char*) buffer, nbSampleBuffer << 1);
+
+		pitchDetection->AudioAnalyse(buffer, nbSampleBuffer);
+
+		if (pitchDetection->GetResultUpdated(result)) {
+			if (result.found) cout << Scale::NoteName(result.note) << " " << result.frequency << endl;
+			emit resultUpdated(result);
+		}
+
+		// prevent screen blanking
+		nb_sample_running += nbSampleBuffer;
+		if (nb_sample_running >= nbSamplePreventRunning && running) {
+			nb_sample_running = 0;
+			blank_prevent(true);
+		}
 	}
 
+	pa_simple_free(p_simple);
+
 	delete pitchDetection;
+	delete buffer;
 
 	if (file) {
 		file->close();
 		delete file;
 	}
-
-	cerr << __func__ << " quit" << endl;
-/*
-	// prevent screen blanking
-	if (nb_sample_running >= nbSamplePreventRunning && running) {
-		nb_sample_running = 0;
-		blank_prevent(true);
-	}*/
 }
 
 /// Set a filename before instanciation to record raw audio stream
diff --git a/src/TunerWorker.hpp b/src/TunerWorker.hpp
index ccb555a..6131817 100644
--- a/src/TunerWorker.hpp
+++ b/src/TunerWorker.hpp
@@ -36,6 +36,7 @@ class TunerWorker : public QObject {
 
 	private:
 	static const int nbSecPreventRunning = 40;
+	static const int nbSampleBuffer = 512;
 	static const char *filename_record;
 
 	QMutex mutex;