Separate consoles to different sources

src/openrct2/interface/StdInOutConsole.cpp

@@ -0,0 +1,91 @@
+#include "../OpenRCT2.h"
+#include "../thirdparty/linenoise.hpp"
+#include "Console.h"
+
+void StdInOutConsole::Start()
+{
+    std::thread replThread ([this]() -> void
+    {
+        std::this_thread::sleep_for(std::chrono::milliseconds(1000));
+
+        linenoise::SetMultiLine(true);
+        linenoise::SetHistoryMaxLen(32);
+
+        std::string prompt = "\033[32mopenrct2 $\x1b[0m ";
+        while (true)
+        {
+            std::string line;
+            std::string left = prompt;
+            auto quit = linenoise::Readline(left.c_str(), line);
+            if (quit) {
+                openrct2_finish();
+                break;
+            }
+            linenoise::AddHistory(line.c_str());
+            Eval(line).wait();
+        }
+    });
+    replThread.detach();
+}
+
+std::future<void> StdInOutConsole::Eval(const std::string &s)
+{
+    // Push on-demand evaluations onto a queue so that it can be processed deterministically
+    // on the main thead at the right time.
+    std::promise<void> barrier;
+    auto future = barrier.get_future();
+    _evalQueue.emplace(std::move(barrier), s);
+    return future;
+}
+
+void StdInOutConsole::ProcessEvalQueue()
+{
+    while (_evalQueue.size() > 0)
+    {
+        auto item = std::move(_evalQueue.front());
+        _evalQueue.pop();
+        auto promise = std::move(std::get<0>(item));
+        auto command = std::move(std::get<1>(item));
+
+        Execute(command);
+
+        // Signal the promise so caller can continue
+        promise.set_value();
+    }
+}
+
+void StdInOutConsole::Clear()
+{
+    linenoise::linenoiseClearScreen();
+}
+
+void StdInOutConsole::Close()
+{
+    openrct2_finish();
+}
+
+void StdInOutConsole::WriteLine(const std::string &s, uint32 colourFormat)
+{
+    std::string formatBegin;
+    if (colourFormat != FORMAT_WINDOW_COLOUR_2)
+    {
+        switch (colourFormat)
+        {
+            case FORMAT_RED:
+                formatBegin = "\033[31m";
+                break;
+            case FORMAT_YELLOW:
+                formatBegin = "\033[33m";
+                break;
+        }
+    }
+
+    if (formatBegin.empty())
+    {
+        std::printf("%s\n", s.c_str());
+    }
+    else
+    {
+        std::printf("%s%s%s\n", formatBegin.c_str(), s.c_str(), "\x1b[0m");
+    }
+}