using MLAPI.MonoBehaviours.Core;

using System.IO;

using UnityEngine;

public class SyncPosition : NetworkedBehaviour

{

private float lastSentTime;

public float PosUpdatesPerSecond = 20;

private void Awake()

{

if(isServer)

{

// RegisterMessageHandler("PositionUpdate", OnRecievePositionUpdate);

}

if(isClient)

{

// RegisterMessageHandler("SetClientPosition", OnSetClientPosition);

}

}

private void Update()

{

if (!isLocalPlayer)

return;

if(Time.time - lastSentTime > (1f / PosUpdatesPerSecond))

{

using(MemoryStream stream = new MemoryStream())

{

using (BinaryWriter writer = new BinaryWriter(stream))

{

writer.Write(transform.position.x);

writer.Write(transform.position.y);

writer.Write(transform.position.z);

}

SendToServer("PositionUpdate", "PositionUpdates", stream.ToArray());

}

lastSentTime = Time.time;

}

transform.Translate(new Vector3(Input.GetAxis("Horizontal") * Time.deltaTime, Input.GetAxis("Vertical") * Time.deltaTime, 0));

}

//This gets called on all clients except the one the position update is about.

void OnSetClientPosition(uint clientId, byte[] data)

{

using (MemoryStream stream = new MemoryStream(data))

{

using (BinaryReader reader = new BinaryReader(stream))

{

uint targetNetId = reader.ReadUInt32();

if (targetNetId != networkId)

return;

float x = reader.ReadSingle();

float y = reader.ReadSingle();

float z = reader.ReadSingle();

GetNetworkedObject(targetNetId).transform.position = new Vector3(x, y, z);

}

}

}

//This gets called on the server when a client sends it's position.

void OnRecievePositionUpdate(uint clientId, byte[] data)

{

//This makes it behave like a HLAPI Command. It's only invoked on the same object that called it.

if (clientId != ownerClientId)

return;

using (MemoryStream readStream = new MemoryStream(data))

{

using (BinaryReader reader = new BinaryReader(readStream))

{

float x = reader.ReadSingle();

float y = reader.ReadSingle();

float z = reader.ReadSingle();

transform.position = new Vector3(x, y, z);

}

using (MemoryStream writeStream = new MemoryStream())

{

using (BinaryWriter writer = new BinaryWriter(writeStream))

{

writer.Write(networkId);

writer.Write(transform.position.x);

writer.Write(transform.position.y);

writer.Write(transform.position.z);

}

//Sends the position to all clients except the one who requested it. Similar to a Rpc with a if(isLocalPlayer) return;

SendToNonLocalClients("SetClientPosition", "PositionUpdates", writeStream.ToArray());

}

}

}

}