quantum-space-buddies/QSB/EyeOfTheUniverse/EyeStateSync/Messages/FlickerMessage.cs

using QSB.Messaging;
using QSB.Player.TransformSync;
using QSB.Utility;
using QSB.WorldSync;
using QuantumUNET.Transport;
using System;
using UnityEngine;

namespace QSB.EyeOfTheUniverse.EyeStateSync.Messages
{
	internal class FlickerMessage : QSBMessage
	{
		static FlickerMessage() => GlobalMessenger<float, float>.AddListener(OWEvents.FlickerOffAndOn, Handler);

		private static void Handler(float offDuration, float onDuration)
		{
			if (PlayerTransformSync.LocalInstance)
			{
				new FlickerMessage(offDuration, onDuration).Send();
			}
		}

		private float _offDuration;
		private float _onDuration;

		private FlickerMessage(float offDuration, float onDuration)
		{
			_offDuration = offDuration;
			_onDuration = onDuration;
		}

		public override void Serialize(QNetworkWriter writer)
		{
			base.Serialize(writer);
			writer.Write(_offDuration);
			writer.Write(_onDuration);
		}

		public override void Deserialize(QNetworkReader reader)
		{
			base.Deserialize(reader);
			_offDuration = reader.ReadSingle();
			_onDuration = reader.ReadSingle();
		}

		public override bool ShouldReceive => WorldObjectManager.AllObjectsReady;

		public override void OnReceiveRemote()
		{
			// manually fire callbacks
			var eventTable = GlobalMessenger<float, float>.eventTable;
			lock (eventTable)
			{
				var eventData = eventTable[OWEvents.FlickerOffAndOn];
				if (eventData.isInvoking)
				{
					throw new InvalidOperationException("GlobalMessenger does not support recursive FireEvent calls to the same eventType.");
				}

				eventData.isInvoking = true;
				eventData.temp.AddRange(eventData.callbacks);
				foreach (var callback in eventData.temp)
				{
					// ignore callback for this message to prevent infinite loop
					if (callback == Handler)
					{
						continue;
					}

					try
					{
						callback(_offDuration, _onDuration);
					}
					catch (Exception exception)
					{
						Debug.LogException(exception);
					}
				}

				eventData.temp.Clear();
				eventData.isInvoking = false;
			}
		}
	}
}