Upload from upload_mods.ps1

2025-06-04 16:11:59 +09:30
commit 7f792f7b8f
25 changed files with 1947 additions and 0 deletions
--- a/Scripts/NetPackages/NetPackageExplosionParams.cs
+++ b/Scripts/NetPackages/NetPackageExplosionParams.cs
@@ -0,0 +1,158 @@
+using System.Collections.Generic;
+using System.IO;
+using UnityEngine;
+
+public class NetPackageExplosionParams : NetPackage
+{
+	public NetPackageExplosionParams Setup(int _clrIdx, Vector3 _worldPos, Vector3i _blockPos, Quaternion _rotation, ExplosionData _explosionData, int _entityId, uint _explId, ItemValue _itemValueExplosive, List<BlockChangeInfo> explosionChanges, GameObject particle)
+	{
+		clrIdx = _clrIdx;
+		worldPos = _worldPos;
+		blockPos = _blockPos;
+		rotation = _rotation;
+		explosionData = _explosionData;
+		entityId = _entityId;
+		explosionId = _explId;
+		itemValueExplosive = null;
+		if(_itemValueExplosive != null)
+			itemValueExplosive = _itemValueExplosive.Clone();
+		this.explosionChanges.Clear();
+        this.explosionChanges.AddRange(explosionChanges);
+		if(particle != null)
+        {
+			if(particle.TryGetComponent<NetSyncHelper>(out var helper))
+			{
+				MemoryStream memoryStream = new MemoryStream();
+				using (PooledBinaryWriter _bw = MemoryPools.poolBinaryWriter.AllocSync(false))
+				{
+					_bw.SetBaseStream(memoryStream);
+					helper.OnExplosionServerInit(_bw);
+				}
+				dataToSync = memoryStream.ToArray();
+			}
+        }
+		return this;
+	}
+
+	public override void read(PooledBinaryReader _br)
+	{
+		clrIdx = (int)_br.ReadUInt16();
+		worldPos = StreamUtils.ReadVector3(_br);
+		blockPos = StreamUtils.ReadVector3i(_br);
+		rotation = StreamUtils.ReadQuaterion(_br);
+		int count = (int)_br.ReadUInt16();
+		explosionData = new ExplosionData(_br.ReadBytes(count));
+		entityId = _br.ReadInt32();
+		explosionId = _br.ReadUInt32();
+		int num = (int)_br.ReadUInt16();
+		explosionChanges = new List<BlockChangeInfo>(num);
+		for (int i = 0; i < num; i++)
+		{
+			BlockChangeInfo blockChangeInfo = new BlockChangeInfo();
+			blockChangeInfo.Read(_br);
+			explosionChanges.Add(blockChangeInfo);
+		}
+		if (_br.ReadBoolean())
+		{
+			itemValueExplosive = new ItemValue();
+			itemValueExplosive.Read(_br);
+		}
+		ushort bytes = _br.ReadUInt16();
+		if (bytes > 0)
+			dataToSync = _br.ReadBytes(bytes);
+	}
+
+	public override void write(PooledBinaryWriter _bw)
+	{
+		base.write(_bw);
+		_bw.Write((ushort)clrIdx);
+		StreamUtils.Write(_bw, worldPos);
+		StreamUtils.Write(_bw, blockPos);
+		StreamUtils.Write(_bw, rotation);
+		byte[] array = explosionData.ToByteArray();
+		_bw.Write((ushort)array.Length);
+		_bw.Write(array);
+		_bw.Write(entityId);
+		_bw.Write(explosionId);
+		_bw.Write((ushort)explosionChanges.Count);
+		for (int i = 0; i < explosionChanges.Count; i++)
+		{
+			explosionChanges[i].Write(_bw);
+		}
+		_bw.Write(itemValueExplosive != null);
+		if (itemValueExplosive != null)
+		{
+			itemValueExplosive.Write(_bw);
+		}
+		if (dataToSync != null && dataToSync.Length > 0)
+		{
+			_bw.Write((ushort)dataToSync.Length);
+			_bw.Write(dataToSync);
+		}
+		else
+			_bw.Write((ushort)0);
+	}
+
+	public override void ProcessPackage(World _world, GameManager _callbacks)
+	{
+		if (_world == null)
+		{
+			return;
+		}
+		bool isCustom = false;
+		if(explosionData.ParticleIndex >= WorldStaticData.prefabExplosions.Length)
+        {
+			isCustom = CustomExplosionManager.GetCustomParticleComponents(explosionData.ParticleIndex, out ExplosionComponent component) && component != null;
+			if (isCustom)
+			{
+				ExplosionValue value = new ExplosionValue()
+				{
+					Component = component,
+					CurrentExplosionParams = new ExplosionParams(clrIdx, worldPos, blockPos, rotation, explosionData, entityId, explosionId),
+					CurrentItemValue = itemValueExplosive?.Clone()
+				};
+				CustomExplosionManager.PushLastInitComponent(value);
+			}
+        }
+
+		GameObject result = _callbacks.ExplosionClient(clrIdx, worldPos, rotation, explosionData.ParticleIndex, explosionData.BlastPower, (float)explosionData.EntityRadius, (float)explosionData.BlockDamage, entityId, explosionChanges);
+		if (isCustom)
+		{
+			NetSyncHelper helper = result?.GetComponent<NetSyncHelper>();
+			if (helper != null && dataToSync != null)
+			{
+				using (PooledBinaryReader _br = MemoryPools.poolBinaryReader.AllocSync(false))
+				{
+					_br.SetBaseStream(new MemoryStream(dataToSync));
+					helper.OnExplosionClientInit(_br);
+				}
+			}
+			CustomExplosionManager.PopLastInitComponent();
+		}
+	}
+
+	public override NetPackageDirection PackageDirection
+	{
+		get
+		{
+			return NetPackageDirection.ToClient;
+		}
+	}
+
+	public override int GetLength()
+	{
+		return 80 + explosionChanges.Count * 30;
+	}
+
+	private int clrIdx;
+	private Vector3 worldPos;
+	private Vector3i blockPos;
+	private Quaternion rotation;
+	private ExplosionData explosionData;
+	private int entityId;
+	private uint explosionId;
+	private ItemValue itemValueExplosive;
+	private List<BlockChangeInfo> explosionChanges = new List<BlockChangeInfo>();
+	private byte[] dataToSync = null;
+}
+