SendPlayerHeartbeatRequestSystem.cs

using Improbable.Gdk.Core;
using Improbable.Gdk.PlayerLifecycle;
using Unity.Entities;
using UnityEngine;

namespace Improbable.Gdk.PlayerLifecycle
{
    [DisableAutoCreation]
    [UpdateBefore(typeof(SpatialOSUpdateGroup))]
    public class SendPlayerHeartbeatRequestSystem : ComponentSystem
    {
        private double timeOfNextHeartbeat;
        private EntityQuery group;
        private CommandSystem commandSystem;

        protected override void OnCreate()
        {
            base.OnCreate();

            timeOfNextHeartbeat = Time.ElapsedTime + PlayerLifecycleConfig.PlayerHeartbeatIntervalSeconds;

            group = GetEntityQuery(
                ComponentType.ReadOnly<PlayerHeartbeatServer.HasAuthority>(),
                ComponentType.ReadWrite<HeartbeatData>(),
                ComponentType.ReadOnly<SpatialEntityId>()
            );

            commandSystem = World.GetExistingSystem<CommandSystem>();
        }

        protected override void OnUpdate()
        {
            if (Time.ElapsedTime < timeOfNextHeartbeat)
            {
                return;
            }

            timeOfNextHeartbeat = Time.ElapsedTime + PlayerLifecycleConfig.PlayerHeartbeatIntervalSeconds;

            Entities.With(group).ForEach((ref SpatialEntityId spatialEntityId) =>
            {
                commandSystem.SendCommand(
                    new PlayerHeartbeatClient.PlayerHeartbeat.Request(spatialEntityId.EntityId, new Empty()));
            });
        }
    }
}