///////////////////////////////////////////////////////////////
// MT1-Q7.cpp - class declaration for logger                 //
//                                                           //
// Jim Fawcett, CSE687 - Object Oriented Deisgn, Spring 2019 //
///////////////////////////////////////////////////////////////

#include <thread>
#include <iostream>
#include "../Cpp11-BlockingQueue/Cpp11-BlockingQueue.h"

//// required solution starts here ////////////////////////////

template<typename T>
class Logger
{
public:
  Logger(std::ostream& out = std::cout);
  Logger(const Logger&) = delete;
  Logger& operator=(const Logger&) = delete;
  void log(const T& t);
  void wait();
private:
  std::ostream& out_;      // streams are not copyable or assignable
  BlockingQueue<T> msgQ_;  // BlockingQueue is not copyable or assignable
  std::thread thrd_;
  void threadProc(BlockingQueue<T>& bQueue);
};

//// required solution ends here //////////////////////////////

template<typename T>
void Logger<T>::threadProc(BlockingQueue<T>& bQueue)
{
  while (true)
  {
    T t = bQueue.deQ();
    out_ << "\n  " << t;
    if (t == "quit")
      break;
  }
}

template<typename T>
Logger<T>::Logger(std::ostream& out) : out_(out)
{
  std::thread thrd(&Logger<T>::threadProc, this, std::ref(msgQ_));
  thrd_ = std::move(thrd);
}

template<typename T>
void Logger<T>::wait()
{
  thrd_.join();
}

template <typename T>
void Logger<T>::log(const T& t)
{
  msgQ_.enQ(t);
}

#include <fstream>

int main()
{
  std::cout << "\n  MT1-Q7 - Logger Declaration";
  std::cout << "\n -----------------------------\n";

  Logger<std::string> logger;
  for (size_t i = 0; i < 10; ++i)
  {
    logger.log("logging msg #" + std::to_string(i + 1));
  }
  logger.log("quit");

  std::ofstream fout("fileLogger.txt");
  if (fout.good())
  {
    Logger<std::string> fileLogger(fout);
    for (size_t i = 0; i < 10; ++i)
    {
      fileLogger.log("logging file-msg #" + std::to_string(i + 1));
    }
    fileLogger.log("quit");
    fileLogger.wait();
  }
  logger.wait();

  std::cout << "\n\n";
}