/*
 * qDebugStream.h
 *
 *  Created on: Jun 28, 2012
 *      Author: Anna Bergamaschi
 */

#ifndef QDEBUGSTREAM_H_
#define QDEBUGSTREAM_H_


#include "qDefs.h"


#include <QApplication>
#include <QWidget>
#include <QString>
#include <QCustomEvent>


#include <iostream>
#include <streambuf>
#include <string>
using namespace std;

#define STREAMEVENT 60001


//-------------------------------------------------------------------------------------------------------------------------------------------------

class qStreamEvent:public QEvent{
public:
	qStreamEvent(QString s):QEvent(static_cast<QEvent::Type>(STREAMEVENT)),str(s){
#ifdef PRINT_LOG
		printf("%s\n",str.toAscii().constData());
#endif
	}
	/** \returns the progress index */
	QString getString() {return str;}
private:
	QString str;

};

//-------------------------------------------------------------------------------------------------------------------------------------------------

class qDebugStream : public basic_streambuf<char> {

public:
	qDebugStream(ostream &stream, QWidget* w) : m_stream(stream), log_window(w) {
		pthread_mutex_init(&mutex, NULL);
		m_old_buf = stream.rdbuf();
		stream.rdbuf(this);
	}

//-------------------------------------------------------------------------------------------------------------------------------------------------

	~qDebugStream(){
		// output anything that is left
		if (!m_string.empty()) {
			pthread_mutex_lock(&mutex);
			QApplication::postEvent(log_window, new qStreamEvent(m_string.c_str()));
			pthread_mutex_unlock(&mutex);
		}
		m_stream.rdbuf(m_old_buf);
	}

//-------------------------------------------------------------------------------------------------------------------------------------------------

protected:
	virtual int_type overflow(int_type v){
		if (v == '\n'){
			pthread_mutex_lock(&mutex);
			QApplication::postEvent(log_window, new qStreamEvent(m_string.c_str()));
			m_string.erase(m_string.begin(), m_string.end());
			pthread_mutex_unlock(&mutex);
		}
		else
			m_string += v;
		return v;
	}

//-------------------------------------------------------------------------------------------------------------------------------------------------

	virtual streamsize xsputn(const char *p, streamsize n)	{
		pthread_mutex_lock(&mutex);
		m_string.append(p, p + n);

		//changed from uint because of 64 bit
		int pos = 0;

		while (pos != string::npos){
			pos = m_string.find('\n');
			if (pos != string::npos){
				string tmp(m_string.begin(), m_string.begin() + pos);
				QApplication::postEvent(log_window, new qStreamEvent(tmp.c_str()));
				m_string.erase(m_string.begin(), m_string.begin() + pos + 1);
			}
		}
		pthread_mutex_unlock(&mutex);
		return n;
	}

//-------------------------------------------------------------------------------------------------------------------------------------------------

private:
	pthread_mutex_t mutex;
	ostream &m_stream;
	streambuf *m_old_buf;
	string m_string;
	QWidget* log_window;
};

//-------------------------------------------------------------------------------------------------------------------------------------------------

#endif /* QDEBUGSTREAM_H_ */