1 files changed, 71 insertions, 0 deletions
diff --git a/source/game/scripting/StarScriptableThread.hpp b/source/game/scripting/StarScriptableThread.hpp
new file mode 100644
index 0000000..65f007e
--- /dev/null
+++ b/source/game/scripting/StarScriptableThread.hpp
@@ -0,0 +1,71 @@
+#pragma once
+
+#include "StarThread.hpp"
+#include "StarLuaRoot.hpp"
+#include "StarLuaComponents.hpp"
+#include "StarRpcThreadPromise.hpp"
+
+namespace Star {
+
+STAR_CLASS(ScriptableThread);
+
+// Runs a Lua in a separate thread and guards exceptions that occur in
+// it.  All methods are designed to not throw exceptions, but will instead log
+// the error and trigger the ScriptableThread error state.
+class ScriptableThread : public Thread {
+public:
+  struct Message {
+    String message;
+    JsonArray args;
+    RpcThreadPromiseKeeper<Json> promise;
+  };
+
+  typedef LuaMessageHandlingComponent<LuaUpdatableComponent<LuaBaseComponent>> ScriptComponent;
+  typedef shared_ptr<ScriptComponent> ScriptComponentPtr;
+
+  ScriptableThread(Json parameters);
+  ~ScriptableThread();
+
+  void start();
+  // Signals the ScriptableThread to stop and then joins it
+  void stop();
+  void setPause(bool pause);
+
+  // An exception occurred and the
+  // ScriptableThread has stopped running.
+  bool errorOccurred();
+  bool shouldExpire();
+
+  // 
+  void passMessage(Message&& message);
+
+protected:
+  virtual void run();
+
+private:
+  void update();
+  Maybe<Json> receiveMessage(String const& message, JsonArray const& args);
+
+  mutable RecursiveMutex m_mutex;
+  
+  LuaRootPtr m_luaRoot;
+  StringMap<ScriptComponentPtr> m_scriptContexts;
+  
+  Json m_parameters;
+  String m_name;
+  
+  float m_timestep;
+
+  mutable RecursiveMutex m_messageMutex;
+  List<Message> m_messages;
+
+  atomic<bool> m_stop;
+  atomic<bool> m_pause;
+  mutable atomic<bool> m_errorOccurred;
+  mutable atomic<bool> m_shouldExpire;
+  
+  LuaCallbacks makeThreadCallbacks();
+  Json configValue(String const& name, Json def) const;
+};
+
+}