#include <iostream>
#include <string>
#include <chrono>
#include <thread>
#include <queue>
#include <functional>

std::queue<std::string> commandQueue;

bool busy = false;

void executeCommand(std::string command)
{
  std::this_thread::sleep_until(std::chrono::system_clock::now() + std::chrono::seconds(3)); // commands might "delay" the player.
  std::cout << "Command " << command << " done." << std::endl;
}

void doNextCommand()
{
  std::string cmd = commandQueue.front();
  commandQueue.pop();

  executeCommand(cmd);
  if(!commandQueue.empty())
    doNextCommand();

  busy = false;
}

void serviceQueue()
{
  if(busy) return;

  busy = true;

  // I have no idea what I'm doing here.I just think that I need to spin up a worker thread or make this
  // async because it shouldn't block further command input
  std::thread([](){ doNextCommand(); }).detach();
};

void commandQueueChanged()
{
  serviceQueue();
}


int main()
{
  while(true) {
    std::cout << "Enter a command to fire" << std::endl;
    std::string enterLine;
    getline(std::cin, enterLine);

    commandQueue.push(enterLine);
    commandQueueChanged(); // Some event will fire that notifies the command servicer to start servicing commands.
  };
  return 0;
};