Add FiveM (CitizenFX) loop manager

ECS_concat.lua

@@ -865,6 +865,9 @@ __F__["ECS"] = function()
       if (game and game.ClassName == "DataModel") then
          -- is roblox
          setLoopManager(__REQUIRE__("RobloxLoopManager")())
+      elseif (CreateThread and Wait and GetGameTimer and IsDuplicityVersion) then
+         -- is FiveM (CitizenFX)
+         setLoopManager(__REQUIRE__("FiveMLoopManager")())
       end
    end)
 
@@ -1399,6 +1402,45 @@ __F__["Event"] = function()
 
 end
 
+__F__["FiveMLoopManager"] = function()
+   -- src/FiveMLoopManager.lua
+   local function InitManager()
+
+      return {
+         Register = function(world)
+            local running = true
+
+            -- IsDuplicityVersion() returns true on the server. On the server there is
+            -- nothing to render, so the "render" step is skipped there.
+            local isServer = IsDuplicityVersion()
+
+            CreateThread(function()
+               while running do
+                  -- GetGameTimer() returns milliseconds, the Timer expects seconds
+                  local now = GetGameTimer() / 1000
+
+                  world:Update("process", now)
+                  world:Update("transform", now)
+
+                  if (not isServer) then
+                     world:Update("render", now)
+                  end
+
+                  Wait(0)
+               end
+            end)
+
+            return function()
+               running = false
+            end
+         end
+      }
+   end
+
+   return InitManager
+
+end
+
 __F__["Query"] = function()
    -- src/Query.lua
 

build.lua

@@ -12,6 +12,7 @@ local SRC_FILES = {
    "Entity",
    "EntityRepository",
    "Event",
+   "FiveMLoopManager",
    "Query",
    "QueryResult",
    "RobloxLoopManager",
@@ -69,22 +70,22 @@ local function concat()
       "      __M__[m] = { r = __F__[m]() }",
       "   end",
       "   return __M__[m].r",
-      "end",   
-      "",   
+      "end",
+      "",
    }
-   
+
    for i,name in ipairs(SRC_FILES) do
       local sourceFile = io.open("./src/"..name..".lua", "r")
       if not sourceFile then
          error("Could not open the input file `" .. OUTPUT_MINIFIED .. "`", 0)
       end
-   
+
       local content = sourceFile:read( "*a" )
-   
+
       for _,oname in ipairs(SRC_FILES) do
          content = content:gsub('require[(]["\']'..oname..'["\'][)]', '__REQUIRE__("'..oname..'")')
       end
-   
+
       table.insert(concatContent, table.concat({
          '__F__["'..name..'"] = function()',
          ("   -- src/"..name..".lua\n"..content):gsub("\n", "\n   "),
@@ -93,14 +94,14 @@ local function concat()
       }, "\n"))
       sourceFile:close()
    end
-   
+
    table.insert(concatContent, 'return __REQUIRE__("ECS")')
-   
+
    -- write ECS_concat.lua
    local fileConcat = io.open(OUTPUT_CONCAT..".lua", "w" )
    fileConcat:write( table.concat(concatContent, "\n"))
-   fileConcat:close()  
-   
+   fileConcat:close()
+
    -- teste import
    local ecsConcat = require(OUTPUT_CONCAT)
    _G.ECS = nil

src/ECS.lua

@@ -46,6 +46,9 @@ pcall(function()
    if (game and game.ClassName == "DataModel") then
       -- is roblox
       setLoopManager(require("RobloxLoopManager")())
+   elseif (CreateThread and Wait and GetGameTimer and IsDuplicityVersion) then
+      -- is FiveM (CitizenFX)
+      setLoopManager(require("FiveMLoopManager")())
    end
 end)
 

src/FiveMLoopManager.lua

@@ -0,0 +1,34 @@
+local function InitManager()
+
+   return {
+      Register = function(world)
+         local running = true
+
+         -- IsDuplicityVersion() returns true on the server. On the server there is
+         -- nothing to render, so the "render" step is skipped there.
+         local isServer = IsDuplicityVersion()
+
+         CreateThread(function()
+            while running do
+               -- GetGameTimer() returns milliseconds, the Timer expects seconds
+               local now = GetGameTimer() / 1000
+
+               world:Update("process", now)
+               world:Update("transform", now)
+
+               if (not isServer) then
+                  world:Update("render", now)
+               end
+
+               Wait(0)
+            end
+         end)
+
+         return function()
+            running = false
+         end
+      end
+   }
+end
+
+return InitManager