#lang rhombus/static
import:
    "chunk.rhm" open
    "entity.rhm" open
    "item.rhm" open
    "../thread/thread.rhm" open

export:
    Chunk
    ActionResponse
    Direction
    World
    Tile
    Entity
    EntityPlayer
    EntityGatherable
    Direction
    ItemCap
    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()