Run tasks

minecraft-server/src/server_behavior.rs

@@ -21,11 +21,13 @@ impl ServerBehavior {
         let world = Box::leak(Box::new(World::new(receiver.resubscribe())));
 
         // Send ticks to player handlers
+        let world2: &World = world;
         tokio::spawn(async move {
             let mut tick_id = 0;
             let mut tick = tokio::time::interval(Duration::from_millis(50));
             loop {
                 tick.tick().await;
+                world2.tick().await;
                 let _ = sender.send(ServerMessage::Tick(tick_id));
                 tick_id += 1;
             }

minecraft-server/src/world/ecs.rs

@@ -69,6 +69,8 @@ impl Entities {
         }
     }
 
+    // TODO: Since we lock tasks it makes it impossible for an entity task to itself call this function
+    // It would be resolved if we had a temporary task buffer that would be added only on Ecs::tick
     pub(super) async fn spawn_entity<E>(&self, entity: AnyEntity, world: &'static World, receiver: BroadcastReceiver<ServerMessage>) -> (Eid, UUID)
         where AnyEntity: TryAsEntityRef<E>, Handler<E>: EntityExt
     {
@@ -104,4 +106,12 @@ impl Entities {
         self.uuids.write().await.retain(|_,v| *v != eid);
         entity
     }
+
+    pub(super) async fn tick(&self, world: &'static World) {
+        let mut tasks = self.tasks.write().await;
+        for (eid, task) in tasks.iter_mut() {
+            let h = Handler::<Entity>::assume(*eid, world);
+            task.tick(h).await;
+        }
+    }
 }

minecraft-server/src/world/mod.rs

@@ -158,6 +158,11 @@ impl World {
             }
         }
     }
+
+    pub async fn tick(&'static self) {
+        self.entities.tick(self).await;
+        // TODO: tick world
+    }
 }
 
 #[cfg(test)]