Get threading of world working

1 files changed, 35 insertions, 0 deletions

diff --git a/src/world.rhm b/src/world.rhm
index 9357422..13fe048 100644
--- a/src/world.rhm
+++ b/src/world.rhm
@@ -3,6 +3,7 @@ import:
     "chunk.rhm" open
     "entity.rhm" open
     "item.rhm" open
+    "../thread/thread.rhm" open
 
 export:
     Chunk
@@ -18,9 +19,43 @@ export:
     Item
     Slot
 
+class MessageLogin(user :: String, thr)
+
 class World(chunks :: MutableList.now_of(Chunk),
             entities :: MutableList.now_of(Entity)):
 
+    field thread_evt = thread_receive_evt()
+    field tick_length = 0.6 // tick length is 600ms
+
     constructor():
         super(MutableList(), MutableList())
 
+    method login(user :: String, thr):
+        // TODO should be accessing some DB to get player
+        let player = EntityPlayer(0, 0, 0, chunks)
+        player.equip[Slot.right_hand] := Item.bronze_axe
+        entities.add(player)
+
+    method process_messages(timestamp :: Real):
+        let time_passed = current_timestamp() - timestamp
+        let remaining_time = math.max(tick_length - time_passed, 0)
+        let sync_res = sync_timeout(remaining_time, thread_evt)
+        if sync_res
+        | let msg = thread_receive()
+          match msg
+          | MessageLogin(user, thr): login(user, thr)
+          | ~else: println("Unknown message " +& msg)
+          process_messages(timestamp)
+        | #true // Return here
+
+    method tick_loop():
+        // TODO step through entities and simulate them
+        let starting_time = current_timestamp()
+        process_messages(starting_time)
+        println("Done tick")
+        tick_loop()
+
+
+    method simulate():
+        tick_loop()
+