/* * Copyright 2023 Eduard Kargin * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using NLog; using Ragon.Protocol; using Ragon.Server.Entity; using Ragon.Server.IO; namespace Ragon.Server.Handler; public sealed class EntityCreateOperation : BaseOperation { private readonly Logger _logger = LogManager.GetCurrentClassLogger(); public EntityCreateOperation(RagonBuffer reader, RagonBuffer writer) : base(reader, writer) { } public override void Handle(RagonContext context, NetworkChannel channel) { var player = context.RoomPlayer; var room = context.Room; var attachId = Reader.ReadUShort(); var entityType = Reader.ReadUShort(); var eventAuthority = (RagonAuthority) Reader.ReadByte(); var propertiesCount = Reader.ReadUShort(); var entityParameters = new RagonEntityParameters() { Type = entityType, Authority = eventAuthority, AttachId = attachId, StaticId = 0, BufferedEvents = context.Configuration.LimitBufferedEvents, }; var entity = new RagonEntity(entityParameters); for (var i = 0; i < propertiesCount; i++) { var propertyType = Reader.ReadBool(); var propertySize = Reader.ReadUShort(); entity.AddProperty(new RagonProperty(propertySize, propertyType)); } if (Reader.Capacity > 0) entity.Payload.Read(Reader); var plugin = room.Plugin; if (!plugin.OnEntityCreate(player, entity)) return; entity.Attach(player); room.AttachEntity(entity); player.AttachEntity(entity); entity.Create(); _logger.Trace($"Player {context.Connection.Id}|{context.LobbyPlayer.Name} created entity {entity.Id}:{entity.Type}"); } }