bcelogstream.hpp

// This file is part of the BCESolve library for games of incomplete
// information
// Copyright (C) 2022 Benjamin A. Brooks
// 
// BCESolve free software: you can redistribute it and/or modify it
// under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// 
// BCESolve is distributed in the hope that it will be useful, but
// WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// General Public License for more details.
// 
// You should have received a copy of the GNU General Public License
// along with this program.  If not, see
// <http://www.gnu.org/licenses/>.
// 
// Benjamin A. Brooks
// ben@benjaminbrooks.net
// Chicago, IL
 
#ifndef BCELOGSTREAM_HPP
#define BCELOGSTREAM_HPP
 
#include <iostream>
#include <streambuf>
#include <string>
#include <QTextEdit>
 
 
class BCELogStream : public std::basic_streambuf<char>
{
public:
  BCELogStream(std::ostream &stream, QTextEdit* text_edit) : m_stream(stream)
  {
    log_window = text_edit;
    m_old_buf = stream.rdbuf();
    stream.rdbuf(this);
  }
 
  ~BCELogStream()
  {
    // output anything that is left
    if (!m_string.empty()) {
      QMetaObject::invokeMethod(log_window, "append", Qt::QueuedConnection, 
                Q_ARG(QString, m_string.c_str()));
      // log_window->append(m_string.c_str());
    }
 
    m_stream.rdbuf(m_old_buf);
  }
 
protected:
  virtual int_type overflow(int_type v)
  {
    if (v == '\n')
      {
    QMetaObject::invokeMethod(log_window, "append", Qt::QueuedConnection, 
                  Q_ARG(QString, m_string.c_str()));
    // log_window->append(m_string.c_str());
    m_string.erase(m_string.begin(), m_string.end());
      }
    else
      m_string += v;
 
    return v;
  }
 
  virtual std::streamsize xsputn(const char *p, std::streamsize n)
  {
    m_string.append(p, p + n);
 
    int pos = 0;
    while (pos != std::string::npos)
      {
    pos = m_string.find('\n');
    if (pos != std::string::npos)
      {
        std::string tmp(m_string.begin(), m_string.begin() + pos);
        QMetaObject::invokeMethod(log_window, "append", Qt::QueuedConnection, 
                      Q_ARG(QString, tmp.c_str()));
        // log_window->append(tmp.c_str());
        m_string.erase(m_string.begin(), m_string.begin() + pos + 1);
      }
      }
 
    return n;
  }
 
private:
  QTextEdit* log_window;
 
  std::ostream &m_stream;
  std::streambuf *m_old_buf;
  std::string m_string;
 
 
};
 
#endif